export sync status from api

Author: cenkalti

server.go

@@ -2,7 +2,9 @@ package putiosync
 
 import (
 	"context"
+	"encoding/json"
 	"fmt"
+	"net"
 	"net/http"
 	"time"
 
@@ -23,6 +25,10 @@ func newServer(addr string) *httpServer {
 	m := http.NewServeMux()
 	m.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) { _, _ = w.Write([]byte("putio-sync")) })
 	m.HandleFunc("/syncing", func(w http.ResponseWriter, r *http.Request) { _, _ = w.Write([]byte(fmt.Sprintf("%v", syncing))) })
+	m.HandleFunc("/status", func(w http.ResponseWriter, r *http.Request) {
+		b, _ := json.Marshal(map[string]string{"status": syncStatus})
+		_, _ = w.Write(b)
+	})
 	s := &httpServer{
 		srv: &http.Server{
 			Addr:         addr,
@@ -39,8 +45,13 @@ func (s *httpServer) Close() {
 }
 
 func (s *httpServer) Start() {
+	l, err := net.Listen("tcp4", s.srv.Addr)
+	if err != nil {
+		log.Fatal(err)
+	}
+	log.Infoln("Server is listening on", l.Addr().String())
 	go func() {
-		if err := s.srv.ListenAndServe(); err != http.ErrServerClosed {
+		if err := s.srv.Serve(l); err != http.ErrServerClosed {
 			log.Fatal(err)
 		}
 	}()

sync.go

@@ -34,6 +34,7 @@ var (
 	tempDirPath    string
 	uploader       *tus.Uploader
 	syncing        bool
+	syncStatus     = "Starting sync..."
 )
 
 func Sync(ctx context.Context, config Config) error {
@@ -74,7 +75,8 @@ REPEAT_LOOP:
 			}
 			log.Error(err)
 		} else {
-			log.Infoln("Sync finished successfully")
+			syncStatus = "Sync finished successfully"
+			log.Infoln(syncStatus)
 		}
 		if cfg.Repeat == 0 {
 			break
@@ -165,7 +167,8 @@ func syncRoots(ctx context.Context) error {
 	syncing = true
 	defer func() { syncing = false }()
 	for _, job := range jobs {
-		log.Infoln(job.String())
+		syncStatus = job.String()
+		log.Infoln(syncStatus)
 		if cfg.DryRun {
 			continue
 		}