1 files changed, 129 insertions, 0 deletions
diff --git a/lib/agent/apiv1.go b/lib/agent/apiv1.go
new file mode 100644
index 0000000..77b05ba
--- /dev/null
+++ b/lib/agent/apiv1.go
@@ -0,0 +1,129 @@
+package agent
+
+import (
+	"fmt"
+	"strconv"
+
+	"github.com/gin-gonic/gin"
+	"github.com/iotbzh/xds-agent/lib/xdsconfig"
+)
+
+const apiBaseUrl = "/api/v1"
+
+// APIService .
+type APIService struct {
+	*Context
+	apiRouter   *gin.RouterGroup
+	serverIndex int
+}
+
+// NewAPIV1 creates a new instance of API service
+func NewAPIV1(ctx *Context) *APIService {
+	s := &APIService{
+		Context:     ctx,
+		apiRouter:   ctx.webServer.router.Group(apiBaseUrl),
+		serverIndex: 0,
+	}
+
+	s.apiRouter.GET("/version", s.getVersion)
+
+	s.apiRouter.GET("/config", s.getConfig)
+	s.apiRouter.POST("/config", s.setConfig)
+
+	s.apiRouter.GET("/browse", s.browseFS)
+
+	s.apiRouter.GET("/projects", s.getProjects)
+	s.apiRouter.GET("/project/:id", s.getProject)
+	s.apiRouter.POST("/project", s.addProject)
+	s.apiRouter.POST("/project/sync/:id", s.syncProject)
+	s.apiRouter.DELETE("/project/:id", s.delProject)
+
+	s.apiRouter.POST("/exec", s.execCmd)
+	s.apiRouter.POST("/exec/:id", s.execCmd)
+	s.apiRouter.POST("/signal", s.execSignalCmd)
+
+	s.apiRouter.GET("/events", s.eventsList)
+	s.apiRouter.POST("/events/register", s.eventsRegister)
+	s.apiRouter.POST("/events/unregister", s.eventsUnRegister)
+
+	return s
+}
+
+// Stop Used to stop/close created services
+func (s *APIService) Stop() {
+	for _, svr := range s.xdsServers {
+		svr.Close()
+	}
+}
+
+// AddXdsServer Add a new XDS Server to the list of a server
+func (s *APIService) AddXdsServer(cfg xdsconfig.XDSServerConf) (*XdsServer, error) {
+	var svr *XdsServer
+	var exist, tempoID bool
+	tempoID = false
+
+	// First check if not already exist and update it
+	if svr, exist = s.xdsServers[cfg.ID]; exist {
+
+		// Update: Found, so just update some settings
+		svr.ConnRetry = cfg.ConnRetry
+
+		tempoID = svr.IsTempoID()
+		if svr.Connected && !svr.Disabled && svr.BaseURL == cfg.URL && tempoID {
+			return svr, nil
+		}
+
+		// URL differ or not connected, so need to reconnect
+		svr.BaseURL = cfg.URL
+
+	} else {
+
+		// Create a new server object
+		if cfg.APIBaseURL == "" {
+			cfg.APIBaseURL = apiBaseUrl
+		}
+		if cfg.APIPartialURL == "" {
+			cfg.APIPartialURL = "/server/" + strconv.Itoa(s.serverIndex)
+			s.serverIndex = s.serverIndex + 1
+		}
+
+		// Create a new XDS Server
+		svr = NewXdsServer(s.Context, cfg)
+
+		svr.SetLoggerOutput(s.Config.LogVerboseOut)
+
+		// Passthrough routes (handle by XDS Server)
+		grp := s.apiRouter.Group(svr.PartialURL)
+		svr.SetAPIRouterGroup(grp)
+		svr.PassthroughGet("/sdks")
+		svr.PassthroughGet("/sdk/:id")
+	}
+
+	// Established connection
+	err := svr.Connect()
+
+	// Delete temporary ID with it has been replaced by right Server ID
+	if tempoID && !svr.IsTempoID() {
+		delete(s.xdsServers, cfg.ID)
+	}
+
+	// Add to map
+	s.xdsServers[svr.ID] = svr
+
+	// Load projects
+	if err == nil && svr.Connected {
+		err = s.projects.Init(svr)
+	}
+
+	return svr, err
+}
+
+// DelXdsServer Delete an XDS Server from the list of a server
+func (s *APIService) DelXdsServer(id string) error {
+	if _, exist := s.xdsServers[id]; !exist {
+		return fmt.Errorf("Unknown Server ID %s", id)
+	}
+	// Don't really delete, just disable it
+	s.xdsServers[id].Close()
+	return nil
+}