StyAndCo/zeppelin
3
0
Fork 0
mirror of https://github.com/ZeppelinBot/Zeppelin.git synced 2025-07-14 22:07:19 +00:00
Code Releases Activity

Revert "format: Prettier"

Browse source 
This reverts commit 517ce4f52f.
This commit is contained in:
Jonathan 2021-04-02 23:21:53 -04:00
parent 517ce4f52f
commit 7e8ffb9ee3
No known key found for this signature in database
GPG key ID: 19B04E3CBE0885B1
161 changed files with 659 additions and 534 deletions
Download patch file Download diff file Expand all files Collapse all files

8
backend/src/migrations/1556909512501-MigrateUsernamesToNewHistoryTable.ts
View file

@ -9,23 +9,23 @@ export class MigrateUsernamesToNewHistoryTable1556909512501 implements Migration
const migratedUsernames = new Set();
await new Promise(async (resolve) => {
await new Promise(async resolve => {
const stream = await queryRunner.stream("SELECT CONCAT(user_id, '-', username) AS `key` FROM username_history");
stream.on("result", (row) => {
stream.on("result", row => {
migratedUsernames.add(row.key);
});
stream.on("end", resolve);
});
const migrateNextBatch = (): Promise<{ finished: boolean; migrated?: number }> => {
return new Promise(async (resolve) => {
return new Promise(async resolve => {
const toInsert: any[][] = [];
const toDelete: number[] = [];
const stream = await queryRunner.stream(
`SELECT * FROM name_history WHERE type=1 ORDER BY timestamp ASC LIMIT ${BATCH_SIZE}`,
);
stream.on("result", (row) => {
stream.on("result", row => {
const key = `${row.user_id}-${row.value}`;
if (!migratedUsernames.has(key)) {

57
backend/src/migrations/1617410382003-AFKStatus.ts
View file

@ -1,33 +1,34 @@
import { MigrationInterface, QueryRunner, Table } from "typeorm";
export class AFKStatus1617410382003 implements MigrationInterface {
public async up(queryRunner: QueryRunner): Promise<void> {
await queryRunner.createTable(
new Table({
name: "afk",
columns: [
{
name: "id",
type: "int",
isPrimary: true,
isGenerated: true,
generationStrategy: "increment",
},
{
name: "user_id",
type: "bigint",
},
{
name: "status",
type: "varchar",
length: "255",
},
],
}),
);
}
public async down(queryRunner: QueryRunner): Promise<void> {
return queryRunner.dropTable("afk");
}
public async up(queryRunner: QueryRunner): Promise<void> {
await queryRunner.createTable(
new Table({
name: "afk",
columns: [
{
name: "id",
type: "int",
isPrimary: true,
isGenerated: true,
generationStrategy: "increment",
},
{
name: "user_id",
type: "bigint",
},
{
name: "status",
type: "varchar",
length: "255",
}
]
})
);
}
public async down(queryRunner: QueryRunner): Promise<void> {
return queryRunner.dropTable("afk");
}
}