Function main

packages/node-runtime/src/services/contacts/worker-entry.ts:19–39

()

}

async function main(): Promise<void> {
  if (!parentPort) throw new Error('contacts worker requires parentPort')
  const options = workerData as ContactsWorkerStartupOptions
  initAppLogger(options.paths.logsDir)
  const pathProvider = new StaticPathProvider(options.paths)
  const dbManager = new DatabaseManager(pathProvider, {
    nativeBinding: options.nativeBinding,
    runtime: options.runtimeIdentity,
    allowMissingRuntimeForTests: !options.runtimeIdentity,
  })
  const adapter = createDatabaseManagerAdapter(dbManager)
  const onProgress = (progress: ContactsComputeProgress) => parentPort?.postMessage({ type: 'progress', progress })
  const snapshot = computeContactsSnapshot({
    adapter,
    signature: options.signature,
    timeRangePreset: options.timeRangePreset,
    factsCacheDir: getContactsFactsCacheDir(pathProvider.getUserDataDir()),
    onProgress,
  })
  parentPort.postMessage({ type: 'success', snapshot })
}

main().catch((error) => {
  parentPort?.postMessage({