48 lines
1.5 KiB
Nim
48 lines
1.5 KiB
Nim
import ../model/config_type
|
|
import ../model/state_type
|
|
import ../notifier/notifier
|
|
import ../model/log_type
|
|
|
|
import execute
|
|
import prune
|
|
|
|
import os
|
|
import times
|
|
import strformat
|
|
import nativesockets
|
|
|
|
proc genArchiveName(): string =
|
|
let hostname = getHostname()
|
|
let ts = getTime().format("yyyy-MM-dd'T'HH:mm:ss'.'ffffff")
|
|
return fmt"{hostname}-{ts}"
|
|
|
|
proc createArchive(nc: NorgConfig, repo: Repository, archivename: string, retry: int = 0): int =
|
|
let further_args = nc.args.further_args
|
|
let res = run genCreateCommand(repo = archivename, sources = nc.source_directories, stats=nc.args.stats, further_args = further_args)
|
|
if res != 0:
|
|
info "Failed to run Restic. Waiting 15 seconds and trying again"
|
|
sleep 15 * 1000 # 15 seconds
|
|
if retry == nc.retries:
|
|
return 1
|
|
else:
|
|
return createArchive(nc, repo, archivename, retry + 1)
|
|
return res
|
|
|
|
proc createBackup*(nc: NorgConfig, repo: Repository): int =
|
|
let start_time = now()
|
|
notify(nc.notifiers, state=Running)
|
|
let archivename = repo.path & "::" & genArchiveName()
|
|
debug "Creating Archive: ", archivename
|
|
let res = createArchive(nc, repo, archivename)
|
|
let end_time = now()
|
|
let total = (end_time - start_time).inMilliSeconds()
|
|
case res
|
|
of 0:
|
|
if not repo.append_only:
|
|
discard pruneRepo(nc, repo)
|
|
notify(nc.notifiers, state=Success, runtime=total)
|
|
of 1:
|
|
notify(nc.notifiers, state=Failure, runtime=total)
|
|
else:
|
|
notify(nc.notifiers, state=Failure, runtime=total, msg = $res)
|
|
return res
|