Mirroristas/pockethost
2
0
Fork 0
mirror of https://github.com/pockethost/pockethost.git synced 2025-06-06 06:06:45 +00:00
Code Issues Packages Projects Releases Wiki Activity

chore: kill span process for central db when shutting down

Browse Source
This commit is contained in:
Ben Allfree 2023-01-23 15:16:22 +00:00
parent 6d63078fcf
commit 22cb70d444
1 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
packages/daemon/src/services/PocketBaseService.ts
View File

@ -6,7 +6,12 @@ import {
smartFetch, smartFetch,
tryFetch, tryFetch,
} from '$util' } from '$util'
import { createTimerManager, logger, safeCatch } from '@pockethost/common' import {
createCleanupManager,
createTimerManager,
logger,
safeCatch,
} from '@pockethost/common'
import { mkSingleton } from '@pockethost/common/src/mkSingleton' import { mkSingleton } from '@pockethost/common/src/mkSingleton'
import { keys } from '@s-libs/micro-dash' import { keys } from '@s-libs/micro-dash'
import { spawn } from 'child_process' import { spawn } from 'child_process'
@ -58,6 +63,7 @@ export const createPocketbaseService = async (
const { cachePath, checkIntervalMs } = config const { cachePath, checkIntervalMs } = config
const cm = createCleanupManager()
const tm = createTimerManager({}) const tm = createTimerManager({})
const osName = type().toLowerCase() const osName = type().toLowerCase()
@ -158,6 +164,7 @@ export const createPocketbaseService = async (
} }
dbg(`Spawning ${slug}`, { bin, args }) dbg(`Spawning ${slug}`, { bin, args })
const ls = spawn(bin, args) const ls = spawn(bin, args)
cm.add(() => ls.kill())
ls.stdout.on('data', (data) => { ls.stdout.on('data', (data) => {
dbg(`${slug} stdout: ${data}`) dbg(`${slug} stdout: ${data}`)
@ -199,6 +206,7 @@ export const createPocketbaseService = async (
const shutdown = () => { const shutdown = () => {
dbg(`Shutting down pocketbaseService`) dbg(`Shutting down pocketbaseService`)
tm.shutdown() tm.shutdown()
cm.shutdown()
} }
return { return {