implement app run

app.go

@@ -2,8 +2,10 @@ package main
 
 import (
 	"errors"
+	"fmt"
 	"regexp"
 	"strings"
+	"sync"
 	"time"
 
 	log "github.com/sirupsen/logrus"
@@ -546,14 +548,43 @@ func (a *App) RunFull() error {
 	log.WithFields(log.Fields{"app": a.name}).Debugf("starting")
 	defer log.WithFields(log.Fields{"app": a.name}).Debugf("done")
 
+	if cfgRun {
+		return fmt.Errorf("backup already running")
+	}
+
+	cfgMx.Lock()
+	defer cfgMx.Unlock()
+
+	cfgRun = true
+	defer func() { cfgRun = false }()
+
 	boxes := a.Boxes()
 
-	for _, box := range boxes {
-		if err := box.Open(); err != nil {
-			log.WithFields(log.Fields{"app": a.name, "call": "box.Open", "box": box.name, "error": err}).Errorf("")
-			return err
-		}
-		defer box.Close()
+	var wg sync.WaitGroup
+
+	// Open boxes
+	for _, b := range boxes {
+		wg.Add(1)
+		go func(box *Box) {
+			defer wg.Done()
+			if err := box.Open(); err != nil {
+				log.WithFields(log.Fields{"name": box.name, "call": "Open", "error": err}).Errorf("")
+				return
+			}
+		}(b)
+		defer b.Close()
 	}
+
+	wg.Wait()
+
+	if sched, err := a.Run(time.Now()); err != nil {
+		log.WithFields(log.Fields{"call": "Run", "error": err}).Errorf("")
+		return err
+	} else {
+		if sched == "" {
+			return fmt.Errorf("no backup needed")
+		}
+	}
+
 	return nil
 }