do not allow multiple instances

src/autorestic.ts

@@ -4,11 +4,11 @@ import minimist from 'minimist'
 import { init } from './config'
 import handlers, { error, help } from './handlers'
 import { Config } from './types'
-
+import { readLock, writeLock, unlock } from './lock'
-
 
 process.on('uncaughtException', err => {
 	console.log(err.message)
+	unlock()
 	process.exit(1)
 })
 
@@ -36,6 +36,17 @@ export let config: Config
 async function main() {
 	config = init()
 
+	// Don't let 2 instances run on the same config
+	const lock = readLock()
+	if (lock.running) {
+		console.log('An instance of autorestic is already running for this config file'.red)
+		return
+	}
+	writeLock({
+		...lock,
+		running: true,
+	})
+
 	// For dev
 	// return await handlers['cron']([], { ...flags, all: true })
 
@@ -46,6 +57,7 @@ async function main() {
 
 	const fn = handlers[command] || error
 	await fn(args, flags)
+	unlock()
 }
 
 

src/cron.ts

@@ -1,49 +1,21 @@
-import fs from 'fs'
-
 import CronParser from 'cron-parser'
 
 import { config } from './autorestic'
 import { checkAndConfigureBackendsForLocations } from './backend'
-import { Location, Lockfile } from './types'
+import { Location } from './types'
 import { backupLocation } from './backup'
-import { pathRelativeToConfigFile } from './utils'
+import { readLock, writeLock } from './lock'
-
 
-const getLockFileName = () => {
-  const LOCK_FILE = '.autorestic.lock'
-  return pathRelativeToConfigFile(LOCK_FILE)
-}
-
-const readLock = (): Lockfile => {
-  const name = getLockFileName()
-  let lock = {}
-  try {
-    lock = JSON.parse(fs.readFileSync(name, { encoding: 'utf-8' }))
-  } catch { }
-  return lock
-}
-const writeLock = (diff: Lockfile = {}) => {
-  const name = getLockFileName()
-  const newLock = Object.assign(
-    readLock(),
-    diff
-  )
-  fs.writeFileSync(name, JSON.stringify(newLock, null, 2), { encoding: 'utf-8' })
-}
 
 const runCronForLocation = (name: string, location: Location) => {
-  const lock = readLock()[name]
+  const lock = readLock()
   const parsed = CronParser.parseExpression(location.cron || '')
   const last = parsed.prev()
 
-  if (!lock || last.toDate().getTime() > lock.lastRun) {
+  if (!lock.crons[name] || last.toDate().getTime() > lock.crons[name].lastRun) {
     backupLocation(name, location)
-    writeLock({
+    lock.crons[name] = { lastRun: Date.now() }
-      [name]: {
+    writeLock(lock)
-        ...lock,
-        lastRun: Date.now()
-      }
-    })
   } else {
     console.log(`${name.yellow} ▶ Skipping. Sheduled for: ${parsed.next().toString().underline.blue}`)
   }

src/lock.ts

@@ -0,0 +1,32 @@
+import fs from 'fs'
+
+import { pathRelativeToConfigFile } from "./utils"
+import { Lockfile } from "./types"
+
+export const getLockFileName = () => {
+  const LOCK_FILE = '.autorestic.lock'
+  return pathRelativeToConfigFile(LOCK_FILE)
+}
+
+export const readLock = (): Lockfile => {
+  const name = getLockFileName()
+  let lock = {
+    running: false,
+    crons: {}
+  }
+  try {
+    lock = JSON.parse(fs.readFileSync(name, { encoding: 'utf-8' }))
+  } catch { }
+  return lock
+}
+export const writeLock = (lock: Lockfile) => {
+  const name = getLockFileName()
+  fs.writeFileSync(name, JSON.stringify(lock, null, 2), { encoding: 'utf-8' })
+}
+
+export const unlock = () => {
+  writeLock({
+    ...readLock(),
+    running: false,
+  })
+}

src/types.ts

@@ -93,9 +93,12 @@ export type Config = {
 }
 
 export type Lockfile = {
+	running: boolean
+	crons: {
 		[name: string]: {
 			lastRun: number
 		}
+	}
 }
 
 export type Flags = { [arg: string]: any }