Added webapp Dashboard + logic to interact with server.

[src/xds/xds-agent.git] / lib / agent / apiv1.go

diff --git a/lib/agent/apiv1.go b/lib/agent/apiv1.go
new file mode 100644 (file)
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
+}