diff --git a/src/services/nostr/index.ts b/src/services/nostr/index.ts index 45e041f3..fb66bc34 100644 --- a/src/services/nostr/index.ts +++ b/src/services/nostr/index.ts @@ -20,11 +20,11 @@ export default class NostrSubprocess { this.childProcess = fork("./build/src/services/nostr/handler") this.childProcess.on("error", (error) => { this.log(ERROR, "nostr subprocess error", error) - throw error }) - + this.childProcess.on("exit", (code) => { - this.log(ERROR, "nostr subprocess exited with code", `nostr subprocess exited with code ${code}`) + this.log(ERROR, `nostr subprocess exited with code ${code}`) + throw new Error(`nostr subprocess exited with code ${code}`) }) this.childProcess.on("message", (message: ChildProcessResponse) => { diff --git a/src/services/storage/db/storageInterface.ts b/src/services/storage/db/storageInterface.ts index 62935e6a..5d279992 100644 --- a/src/services/storage/db/storageInterface.ts +++ b/src/services/storage/db/storageInterface.ts @@ -59,12 +59,12 @@ export class StorageInterface extends EventEmitter { this.process.on('error', (error: Error) => { this.log(ERROR, 'Storage processor error:', error); this.isConnected = false; - throw error }); this.process.on('exit', (code: number) => { this.log(ERROR, `Storage processor exited with code ${code}`); this.isConnected = false; + throw new Error(`Storage processor exited with code ${code}`) }); this.isConnected = true; diff --git a/src/services/storage/tlv/tlvFilesStorageFactory.ts b/src/services/storage/tlv/tlvFilesStorageFactory.ts index 0b1b5ecf..4825aef1 100644 --- a/src/services/storage/tlv/tlvFilesStorageFactory.ts +++ b/src/services/storage/tlv/tlvFilesStorageFactory.ts @@ -60,6 +60,7 @@ export class TlvStorageFactory extends EventEmitter { this.process.on('exit', (code: number) => { this.log(ERROR, `Tlv Storage processor exited with code ${code}`); this.isConnected = false; + throw new Error(`Tlv Storage processor exited with code ${code}`) }); this.isConnected = true;