serve configuration files on http endpoint

Author: creativeprojects

config/config.go

@@ -701,6 +701,11 @@ func (c *Config) getProfilePath(key string) string {
 	return c.flatKey(constants.SectionConfigurationProfiles, key)
 }
 
+// HasRemote returns true if the remote exists in the configuration
+func (c *Config) HasRemote(remoteName string) bool {
+	return c.IsSet(c.flatKey(constants.SectionConfigurationRemotes, remoteName))
+}
+
 func (c *Config) GetRemote(remoteName string) (*Remote, error) {
 	if c.GetVersion() < Version02 {
 		return nil, ErrNotSupportedInVersion1

serve.go

@@ -1,22 +1,68 @@
 package main
 
 import (
+	"context"
 	"fmt"
 	"io"
 	"net/http"
+	"os"
+	"os/signal"
+	"time"
+
+	"github.com/creativeprojects/clog"
 )
 
 func serveCommand(w io.Writer, cmdCtx commandContext) error {
 	if len(cmdCtx.flags.resticArgs) < 2 {
 		return fmt.Errorf("missing argument: port")
 	}
-	handler := http.HandlerFunc(func(resp http.ResponseWriter, req *http.Request) {
-		resp.Write([]byte("Hello, World!"))
+	handler := http.NewServeMux()
+	handler.HandleFunc("GET /configuration/{remote}", func(resp http.ResponseWriter, req *http.Request) {
+		remoteName := req.PathValue("remote")
+		if !cmdCtx.config.HasRemote(remoteName) {
+			resp.WriteHeader(http.StatusNotFound)
+			resp.Write([]byte("remote not found"))
+			return
+		}
+		remote, err := cmdCtx.config.GetRemote(remoteName)
+		if err != nil {
+			resp.WriteHeader(http.StatusBadRequest)
+			resp.Write([]byte(err.Error()))
+			return
+		}
+
+		clog.Infof("sending configuration for %q", remoteName)
+		resp.Header().Set("Content-Type", "application/x-tar")
+		resp.WriteHeader(http.StatusOK)
+		sendFiles(resp, remote.SendFiles)
 	})
+
+	quit := make(chan os.Signal, 1)
+	signal.Notify(quit, os.Interrupt)
+	defer signal.Stop(quit)
+
 	server := &http.Server{
 		Addr:    fmt.Sprintf("localhost:%s", cmdCtx.flags.resticArgs[1]),
 		Handler: handler,
 	}
+
+	// put the shutdown code in a goroutine
+	go func(server *http.Server, quit chan os.Signal) {
+		<-quit
+
+		clog.Info("shutting down the server")
+		ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
+		defer cancel()
+
+		err := server.Shutdown(ctx)
+		if err != nil {
+			clog.Errorf("error while shutting down the server: %v", err)
+		}
+
+	}(server, quit)
+
+	// we want to return the server error if any so we need to keep it in the main thread.
+	clog.Infof("listening on %s", server.Addr)
 	err := server.ListenAndServe()
 	if err != nil && err != http.ErrServerClosed {
 		return err