Something went wrong. Try again.
A decentralized music tracking and discovery platform built on AT Protocol 🎵 rocksky.app
spotify atproto lastfm musicbrainz scrobbling listenbrainz
Something went wrong. Try again.
12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667import fs from "fs";import path from "path";import os from "os";import { logger } from "logger";
export function cleanUpJetstreamLockOnExit(did: string) { process.on("exit", async () => { try { await fs.promises.unlink( path.join(os.tmpdir(), `rocksky-jetstream-${did}.lock`), ); process.exit(0); } catch (error) { logger.error`Error cleaning up Jetstream lock: ${error}`; process.exit(1); } });
process.on("SIGINT", async () => { try { await fs.promises.unlink( path.join(os.tmpdir(), `rocksky-jetstream-${did}.lock`), ); process.exit(0); } catch (error) { logger.error`Error cleaning up Jetstream lock: ${error}`; process.exit(1); } });
process.on("SIGTERM", async () => { try { await fs.promises.unlink( path.join(os.tmpdir(), `rocksky-jetstream-${did}.lock`), ); process.exit(0); } catch (error) { logger.error`Error cleaning up Jetstream lock: ${error}`; process.exit(1); } });
process.on("uncaughtException", async () => { try { await fs.promises.unlink( path.join(os.tmpdir(), `rocksky-jetstream-${did}.lock`), ); process.exit(1); } catch (error) { logger.error`Error cleaning up Jetstream lock: ${error}`; process.exit(1); } });
process.on("unhandledRejection", async () => { try { await fs.promises.unlink( path.join(os.tmpdir(), `rocksky-jetstream-${did}.lock`), ); process.exit(1); } catch (error) { logger.error`Error cleaning up Jetstream lock: ${error}`; process.exit(1); } });}