Remove defaults and init

packages/backend-core/src/cache/docWritethrough.ts

@@ -7,8 +7,6 @@ import { JobQueue, createQueue } from "../queue"
 import * as context from "../context"
 import * as dbUtils from "../db"
 
-const DEFAULT_WRITE_RATE_MS = 10000
-
 let CACHE: BaseCache | null = null
 async function getCache() {
   if (!CACHE) {
@@ -29,12 +27,7 @@ export const docWritethroughProcessorQueue = createQueue<ProcessDocMessage>(
   JobQueue.DOC_WRITETHROUGH_QUEUE
 )
 
-let _init = false
+docWritethroughProcessorQueue.process(async message => {
-export const init = () => {
-  if (_init) {
-    return
-  }
-  docWritethroughProcessorQueue.process(async message => {
   const { tenantId, cacheKeyPrefix } = message.data
   await context.doInTenant(tenantId, async () => {
     const lockResponse = await locks.doWithLock(
@@ -46,6 +39,7 @@ export const init = () => {
       },
       async () => {
         await persistToDb(message.data)
+        console.log("DocWritethrough persisted", { data: message.data })
       }
     )
 
@@ -53,9 +47,7 @@ export const init = () => {
       console.log(`Ignoring redlock conflict in write-through cache`)
     }
   })
-  })
+})
-  _init = true
-}
 
 export async function persistToDb({
   dbName,
@@ -97,11 +89,7 @@ export class DocWritethrough {
 
   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._docId = docId
     this.writeRateMs = writeRateMs

packages/backend-core/src/cache/tests/docWritethrough.spec.ts

@@ -5,7 +5,6 @@ import _ from "lodash"
 import {
   DocWritethrough,
   docWritethroughProcessorQueue,
-  init,
 } from "../docWritethrough"
 import InMemoryQueue from "../../queue/inMemoryQueue"
 
@@ -45,8 +44,6 @@ describe("docWritethrough", () => {
       }, {} as Record<string, any>)
     }
 
-    beforeAll(() => init())
-
     beforeEach(async () => {
       resetTime()
       documentId = structures.uuid()