From 28f7e48dc61164e574bf7e77012edd8319d33f14 Mon Sep 17 00:00:00 2001 From: syuilo Date: Wed, 30 Jun 2021 23:33:50 +0900 Subject: [PATCH 1/2] improve type --- src/server/api/stream/channels/messaging.ts | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/server/api/stream/channels/messaging.ts b/src/server/api/stream/channels/messaging.ts index 4c41dc820b..58427e2771 100644 --- a/src/server/api/stream/channels/messaging.ts +++ b/src/server/api/stream/channels/messaging.ts @@ -10,7 +10,7 @@ export default class extends Channel { public static requireCredential = true; private otherpartyId: string | null; - private otherparty?: User; + private otherparty: User | null; private groupId: string | null; private subCh: string; private typers: Record = {}; @@ -18,9 +18,9 @@ export default class extends Channel { @autobind public async init(params: any) { - this.otherpartyId = params.otherparty as string; - this.otherparty = await Users.findOne({ id: this.otherpartyId }); - this.groupId = params.group as string; + this.otherpartyId = params.otherparty; + this.otherparty = this.otherpartyId ? await Users.findOneOrFail({ id: this.otherpartyId }) : null; + this.groupId = params.group; // Check joining if (this.groupId) { From 65addc8206f9cbeac5e352f46ed8f07d9aa50257 Mon Sep 17 00:00:00 2001 From: syuilo Date: Thu, 1 Jul 2021 00:50:19 +0900 Subject: [PATCH 2/2] refactoring --- src/services/chart/core.ts | 18 +++++++++--------- 1 file changed, 9 insertions(+), 9 deletions(-) diff --git a/src/services/chart/core.ts b/src/services/chart/core.ts index 4a554daa78..14cbd92802 100644 --- a/src/services/chart/core.ts +++ b/src/services/chart/core.ts @@ -52,7 +52,7 @@ export default abstract class Chart> { private static readonly columnDot = '_'; private name: string; - private queue: { + private buffer: { diff: DeepPartial; group: string | null; }[] = []; @@ -330,28 +330,28 @@ export default abstract class Chart> { @autobind protected commit(diff: DeepPartial, group: string | null = null): void { - this.queue.push({ + this.buffer.push({ diff, group, }); } @autobind public async save() { - if (this.queue.length === 0) { + if (this.buffer.length === 0) { logger.info(`${this.name}: Write skipped`); return; } - // TODO: 前の時間のログがqueueにあった場合のハンドリング + // TODO: 前の時間のログがbufferにあった場合のハンドリング // 例えば、save が20分ごとに行われるとして、前回行われたのは 01:50 だったとする。 - // 次に save が行われるのは 02:10 ということになるが、もし 01:55 に新規ログが queue に追加されたとすると、 + // 次に save が行われるのは 02:10 ということになるが、もし 01:55 に新規ログが buffer に追加されたとすると、 // そのログは本来は 01:00~ のログとしてDBに保存されて欲しいのに、02:00~ のログ扱いになってしまう。 // これを回避するための実装は複雑になりそうなため、一旦保留。 const update = async (log: Log) => { const finalDiffs = {} as Record; - for (const diff of this.queue.filter(q => q.group === log.group).map(q => q.diff)) { + for (const diff of this.buffer.filter(q => q.group === log.group).map(q => q.diff)) { const columns = Chart.convertObjectToFlattenColumns(diff); for (const [k, v] of Object.entries(columns)) { @@ -378,11 +378,11 @@ export default abstract class Chart> { logger.info(`${this.name + (log.group ? `:${log.group}` : '')}: Updated`); - // TODO: この一連の処理が始まった後に新たにqueueに入ったものは消さないようにする - this.queue = this.queue.filter(q => q.group !== log.group); + // TODO: この一連の処理が始まった後に新たにbufferに入ったものは消さないようにする + this.buffer = this.buffer.filter(q => q.group !== log.group); }; - const groups = removeDuplicates(this.queue.map(log => log.group)); + const groups = removeDuplicates(this.buffer.map(log => log.group)); await Promise.all(groups.map(group => this.getCurrentLog(group).then(log => update(log)))); }