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

format: Prettier

Browse source
This commit is contained in:
Jonathan 2021-04-02 23:19:38 -04:00
parent 70be2a2055
commit 517ce4f52f
No known key found for this signature in database
GPG key ID: 19B04E3CBE0885B1
161 changed files with 534 additions and 659 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,34 +1,33 @@
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 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 down(queryRunner: QueryRunner): Promise<void> {
return queryRunner.dropTable("afk");
}
}