Remove defaults and init
This commit is contained in:
parent
74a9aa4a72
commit
ca0f583399
2 changed files with 20 additions and 35 deletions
|
@ -7,8 +7,6 @@ import { JobQueue, createQueue } from "../queue"
|
||||||
import * as context from "../context"
|
import * as context from "../context"
|
||||||
import * as dbUtils from "../db"
|
import * as dbUtils from "../db"
|
||||||
|
|
||||||
const DEFAULT_WRITE_RATE_MS = 10000
|
|
||||||
|
|
||||||
let CACHE: BaseCache | null = null
|
let CACHE: BaseCache | null = null
|
||||||
async function getCache() {
|
async function getCache() {
|
||||||
if (!CACHE) {
|
if (!CACHE) {
|
||||||
|
@ -29,11 +27,6 @@ export const docWritethroughProcessorQueue = createQueue<ProcessDocMessage>(
|
||||||
JobQueue.DOC_WRITETHROUGH_QUEUE
|
JobQueue.DOC_WRITETHROUGH_QUEUE
|
||||||
)
|
)
|
||||||
|
|
||||||
let _init = false
|
|
||||||
export const init = () => {
|
|
||||||
if (_init) {
|
|
||||||
return
|
|
||||||
}
|
|
||||||
docWritethroughProcessorQueue.process(async message => {
|
docWritethroughProcessorQueue.process(async message => {
|
||||||
const { tenantId, cacheKeyPrefix } = message.data
|
const { tenantId, cacheKeyPrefix } = message.data
|
||||||
await context.doInTenant(tenantId, async () => {
|
await context.doInTenant(tenantId, async () => {
|
||||||
|
@ -46,6 +39,7 @@ export const init = () => {
|
||||||
},
|
},
|
||||||
async () => {
|
async () => {
|
||||||
await persistToDb(message.data)
|
await persistToDb(message.data)
|
||||||
|
console.log("DocWritethrough persisted", { data: message.data })
|
||||||
}
|
}
|
||||||
)
|
)
|
||||||
|
|
||||||
|
@ -54,8 +48,6 @@ export const init = () => {
|
||||||
}
|
}
|
||||||
})
|
})
|
||||||
})
|
})
|
||||||
_init = true
|
|
||||||
}
|
|
||||||
|
|
||||||
export async function persistToDb({
|
export async function persistToDb({
|
||||||
dbName,
|
dbName,
|
||||||
|
@ -97,11 +89,7 @@ export class DocWritethrough {
|
||||||
|
|
||||||
private cacheKeyPrefix: string
|
private cacheKeyPrefix: string
|
||||||
|
|
||||||
constructor(
|
constructor(db: Database, docId: string, writeRateMs: number) {
|
||||||
db: Database,
|
|
||||||
docId: string,
|
|
||||||
writeRateMs: number = DEFAULT_WRITE_RATE_MS
|
|
||||||
) {
|
|
||||||
this.db = db
|
this.db = db
|
||||||
this._docId = docId
|
this._docId = docId
|
||||||
this.writeRateMs = writeRateMs
|
this.writeRateMs = writeRateMs
|
||||||
|
|
|
@ -5,7 +5,6 @@ import _ from "lodash"
|
||||||
import {
|
import {
|
||||||
DocWritethrough,
|
DocWritethrough,
|
||||||
docWritethroughProcessorQueue,
|
docWritethroughProcessorQueue,
|
||||||
init,
|
|
||||||
} from "../docWritethrough"
|
} from "../docWritethrough"
|
||||||
import InMemoryQueue from "../../queue/inMemoryQueue"
|
import InMemoryQueue from "../../queue/inMemoryQueue"
|
||||||
|
|
||||||
|
@ -45,8 +44,6 @@ describe("docWritethrough", () => {
|
||||||
}, {} as Record<string, any>)
|
}, {} as Record<string, any>)
|
||||||
}
|
}
|
||||||
|
|
||||||
beforeAll(() => init())
|
|
||||||
|
|
||||||
beforeEach(async () => {
|
beforeEach(async () => {
|
||||||
resetTime()
|
resetTime()
|
||||||
documentId = structures.uuid()
|
documentId = structures.uuid()
|
||||||
|
|
Loading…
Reference in a new issue