diff options
| author | syuilo <Syuilotan@yahoo.co.jp> | 2021-10-22 05:36:48 +0900 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2021-10-22 05:36:48 +0900 |
| commit | 4e4c559db6964cbf17fcadf38d55fc79c995ca42 (patch) | |
| tree | 0e136ef1bf75c201b5805e667129082db3abcb61 /src/queue/processors/system | |
| parent | リモートノートで意図せずローカルカスタム絵文字が使... (diff) | |
| download | sharkey-4e4c559db6964cbf17fcadf38d55fc79c995ca42.tar.gz sharkey-4e4c559db6964cbf17fcadf38d55fc79c995ca42.tar.bz2 sharkey-4e4c559db6964cbf17fcadf38d55fc79c995ca42.zip | |
Migrate to Chart.js v3 (#7896)
* wip
* wip
* wip
* wip
* wip
* wip
* wip
* 定期的にresync
* Update overview.vue
* wip
* wip
Diffstat (limited to 'src/queue/processors/system')
| -rw-r--r-- | src/queue/processors/system/index.ts | 12 | ||||
| -rw-r--r-- | src/queue/processors/system/resync-charts.ts | 21 |
2 files changed, 33 insertions, 0 deletions
diff --git a/src/queue/processors/system/index.ts b/src/queue/processors/system/index.ts new file mode 100644 index 0000000000..52b7868105 --- /dev/null +++ b/src/queue/processors/system/index.ts @@ -0,0 +1,12 @@ +import * as Bull from 'bull'; +import { resyncCharts } from './resync-charts'; + +const jobs = { + resyncCharts, +} as Record<string, Bull.ProcessCallbackFunction<{}> | Bull.ProcessPromiseFunction<{}>>; + +export default function(dbQueue: Bull.Queue<{}>) { + for (const [k, v] of Object.entries(jobs)) { + dbQueue.process(k, v); + } +} diff --git a/src/queue/processors/system/resync-charts.ts b/src/queue/processors/system/resync-charts.ts new file mode 100644 index 0000000000..b36b024cfb --- /dev/null +++ b/src/queue/processors/system/resync-charts.ts @@ -0,0 +1,21 @@ +import * as Bull from 'bull'; + +import { queueLogger } from '../../logger'; +import { driveChart, notesChart, usersChart } from '@/services/chart/index'; + +const logger = queueLogger.createSubLogger('resync-charts'); + +export default async function resyncCharts(job: Bull.Job<{}>, done: any): Promise<void> { + logger.info(`Resync charts...`); + + // TODO: ユーザーごとのチャートも更新する + // TODO: インスタンスごとのチャートも更新する + await Promise.all([ + driveChart.resync(), + notesChart.resync(), + usersChart.resync(), + ]); + + logger.succ(`All charts successfully resynced.`); + done(); +} |