Update create-matrix.js

This commit is contained in:
Aleksandr Statciuk 2022-02-07 06:11:40 +03:00
parent 091d43c4f7
commit 002d8804df
2 changed files with 8 additions and 11 deletions

View file

@ -1,7 +1,8 @@
const { logger, db } = require('../core')
async function main() {
const docs = await db.find({}).sort({ cluster_id: 1 })
await db.streams.load()
const docs = await db.streams.find({}).sort({ cluster_id: 1 })
const cluster_id = docs.reduce((acc, curr) => {
if (!acc.includes(curr.cluster_id)) acc.push(curr.cluster_id)
return acc