lib/xdsserver/apiv1-folders.go

   1 package xdsserver
   2
   3 import (
   4         "net/http"
   5         "os"
   6
   7         "github.com/gin-gonic/gin"
   8         common "github.com/iotbzh/xds-common/golib"
   9         "github.com/iotbzh/xds-server/lib/xsapiv1"
  10 )
  11
  12 // getFolders returns all folders configuration
  13 func (s *APIService) getFolders(c *gin.Context) {
  14         c.JSON(http.StatusOK, s.mfolders.GetConfigArr())
  15 }
  16
  17 // getFolder returns a specific folder configuration
  18 func (s *APIService) getFolder(c *gin.Context) {
  19         id, err := s.mfolders.ResolveID(c.Param("id"))
  20         if err != nil {
  21                 common.APIError(c, err.Error())
  22                 return
  23         }
  24         f := s.mfolders.Get(id)
  25         if f == nil {
  26                 common.APIError(c, "Invalid id")
  27                 return
  28         }
  29
  30         c.JSON(http.StatusOK, (*f).GetConfig())
  31 }
  32
  33 // addFolder adds a new folder to server config
  34 func (s *APIService) addFolder(c *gin.Context) {
  35         var cfgArg xsapiv1.FolderConfig
  36         if c.BindJSON(&cfgArg) != nil {
  37                 common.APIError(c, "Invalid arguments")
  38                 return
  39         }
  40
  41         s.Log.Debugln("Add folder config: ", cfgArg)
  42
  43         newFld, err := s.mfolders.Add(cfgArg)
  44         if err != nil {
  45                 common.APIError(c, err.Error())
  46                 return
  47         }
  48
  49         // Create xds-project.conf file
  50         // FIXME: move to folders.createUpdate func (but gin context needed)
  51         fld := s.mfolders.Get(newFld.ID)
  52         prjConfFile := (*fld).GetFullPath("xds-project.conf")
  53         if !common.Exists(prjConfFile) {
  54                 fd, err := os.OpenFile(prjConfFile, os.O_CREATE|os.O_TRUNC|os.O_WRONLY, 0666)
  55                 if err != nil {
  56                         common.APIError(c, err.Error())
  57                         return
  58                 }
  59                 fd.WriteString("# XDS project settings\n")
  60                 fd.WriteString("export XDS_SERVER_URL=" + c.Request.Host + "\n")
  61                 fd.WriteString("export XDS_PROJECT_ID=" + newFld.ID + "\n")
  62                 if newFld.DefaultSdk == "" {
  63                         sdks := s.sdks.GetAll()
  64                         newFld.DefaultSdk = sdks[0].ID
  65                 }
  66                 fd.WriteString("export XDS_SDK_ID=" + newFld.DefaultSdk + "\n")
  67                 fd.Close()
  68         }
  69
  70         c.JSON(http.StatusOK, newFld)
  71 }
  72
  73 // syncFolder force synchronization of folder files
  74 func (s *APIService) syncFolder(c *gin.Context) {
  75         id, err := s.mfolders.ResolveID(c.Param("id"))
  76         if err != nil {
  77                 common.APIError(c, err.Error())
  78                 return
  79         }
  80         s.Log.Debugln("Sync folder id: ", id)
  81
  82         err = s.mfolders.ForceSync(id)
  83         if err != nil {
  84                 common.APIError(c, err.Error())
  85                 return
  86         }
  87
  88         c.JSON(http.StatusOK, "")
  89 }
  90
  91 // delFolder deletes folder from server config
  92 func (s *APIService) delFolder(c *gin.Context) {
  93         id, err := s.mfolders.ResolveID(c.Param("id"))
  94         if err != nil {
  95                 common.APIError(c, err.Error())
  96                 return
  97         }
  98
  99         s.Log.Debugln("Delete folder id ", id)
 100
 101         delEntry, err := s.mfolders.Delete(id)
 102         if err != nil {
 103                 common.APIError(c, err.Error())
 104                 return
 105         }
 106         c.JSON(http.StatusOK, delEntry)
 107 }
 108
 109 // updateFolder update some field of a folder
 110 func (s *APIService) updateFolder(c *gin.Context) {
 111         id, err := s.mfolders.ResolveID(c.Param("id"))
 112         if err != nil {
 113                 common.APIError(c, err.Error())
 114                 return
 115         }
 116
 117         s.Log.Debugln("Update folder id ", id)
 118
 119         var cfgArg xsapiv1.FolderConfig
 120         if c.BindJSON(&cfgArg) != nil {
 121                 common.APIError(c, "Invalid arguments")
 122                 return
 123         }
 124
 125         upFld, err := s.mfolders.Update(id, cfgArg)
 126         if err != nil {
 127                 common.APIError(c, err.Error())
 128                 return
 129         }
 130         c.JSON(http.StatusOK, upFld)
 131 }