diff --git a/src/queue-lease-store.ts b/src/queue-lease-store.ts index 05831e7..a06d3b6 100644 --- a/src/queue-lease-store.ts +++ b/src/queue-lease-store.ts @@ -87,10 +87,13 @@ function isQueueOwnerHeartbeatStale(owner: QueueOwnerRecord): boolean { } async function ensureQueueDir(): Promise { - await fs.mkdir(queueBaseDir(), { recursive: true }); + const baseDir = queueBaseDir(); + await fs.mkdir(baseDir, { recursive: true, mode: 0o700 }); + await fs.chmod(baseDir, 0o700); const socketDir = queueSocketBaseDir(); if (socketDir) { - await fs.mkdir(socketDir, { recursive: true }); + await fs.mkdir(socketDir, { recursive: true, mode: 0o700 }); + await fs.chmod(socketDir, 0o700); } }