Add delay on federation

player/federation.go

@@ -3,12 +3,35 @@ package player
 import (
 	"bytes"
 	"encoding/json"
+	"log"
 	"net/http"
+	"time"
 
 	"git.nemunai.re/nemunaire/reveil/model"
 )
 
-func FederatedWakeUp(srv reveil.FederationSettings, seed int64) error {
+func FederatedWakeUp(k string, srv reveil.FederationSettings, seed int64) {
+	if srv.Delay == 0 {
+		err := federatedWakeUp(srv, seed)
+		if err != nil {
+			log.Printf("Unable to do federated wakeup on %s: %s", k, err.Error())
+		} else {
+			log.Printf("Federated wakeup on %s: launched!", k)
+		}
+	} else {
+		go func() {
+			time.Sleep(time.Duration(srv.Delay) * time.Millisecond)
+			err := federatedWakeUp(srv, seed)
+			if err != nil {
+				log.Printf("Unable to do federated wakeup on %s: %s", k, err.Error())
+			} else {
+				log.Printf("Federated wakeup on %s: launched!", k)
+			}
+		}()
+	}
+}
+
+func federatedWakeUp(srv reveil.FederationSettings, seed int64) error {
 	req := map[string]interface{}{"seed": seed}
 	req_enc, err := json.Marshal(req)
 	if err != nil {

player/player.go

@@ -58,12 +58,7 @@ func WakeUp(cfg *config.Config, routine []reveil.Identifier, federated bool) (er
 		}
 
 		for k, srv := range settings.Federation {
-			err = FederatedWakeUp(srv, seed)
-			if err != nil {
-				log.Printf("Unable to do federated wakeup on %s: %s", k, err.Error())
-			} else {
-				log.Printf("Federated wakeup on %s: launched!", k)
-			}
+			FederatedWakeUp(k, srv, seed)
 		}
 	}