lib/folder/folder-pathmap.go

   1 package folder
   2
   3 import (
   4         "fmt"
   5         "io/ioutil"
   6         "os"
   7         "path/filepath"
   8
   9         common "github.com/iotbzh/xds-common/golib"
  10         "github.com/iotbzh/xds-server/lib/xdsconfig"
  11         uuid "github.com/satori/go.uuid"
  12 )
  13
  14 // IFOLDER interface implementation for native/path mapping folders
  15
  16 // PathMap .
  17 type PathMap struct {
  18         globalConfig *xdsconfig.Config
  19         config       FolderConfig
  20 }
  21
  22 // NewFolderPathMap Create a new instance of PathMap
  23 func NewFolderPathMap(gc *xdsconfig.Config) *PathMap {
  24         f := PathMap{
  25                 globalConfig: gc,
  26         }
  27         return &f
  28 }
  29
  30 // NewUID Get a UUID
  31 func (f *PathMap) NewUID(suffix string) string {
  32         return uuid.NewV1().String() + "_" + suffix
  33 }
  34
  35 // Add a new folder
  36 func (f *PathMap) Add(cfg FolderConfig) (*FolderConfig, error) {
  37         if cfg.DataPathMap.ServerPath == "" {
  38                 return nil, fmt.Errorf("ServerPath must be set")
  39         }
  40
  41         // Use shareRootDir if ServerPath is a relative path
  42         dir := cfg.DataPathMap.ServerPath
  43         if !filepath.IsAbs(dir) {
  44                 dir = filepath.Join(f.globalConfig.FileConf.ShareRootDir, dir)
  45         }
  46
  47         // Sanity check
  48         if !common.Exists(dir) {
  49                 // try to create if not existing
  50                 if err := os.MkdirAll(dir, 0755); err != nil {
  51                         return nil, fmt.Errorf("Cannot create ServerPath directory: %s", dir)
  52                 }
  53         }
  54         if !common.Exists(dir) {
  55                 return nil, fmt.Errorf("ServerPath directory is not accessible: %s", dir)
  56         }
  57         file, err := ioutil.TempFile(dir, "xds_pathmap_check")
  58         if err != nil {
  59                 return nil, fmt.Errorf("ServerPath sanity check error: %s", err.Error())
  60         }
  61         defer os.Remove(file.Name())
  62
  63         msg := "sanity check PathMap Add folder"
  64         n, err := file.Write([]byte(msg))
  65         if err != nil || n != len(msg) {
  66                 return nil, fmt.Errorf("ServerPath sanity check error: %s", err.Error())
  67         }
  68
  69         f.config = cfg
  70         f.config.RootPath = dir
  71         f.config.DataPathMap.ServerPath = dir
  72         f.config.IsInSync = true
  73         f.config.Status = StatusEnable
  74
  75         return &f.config, nil
  76 }
  77
  78 // GetConfig Get public part of folder config
  79 func (f *PathMap) GetConfig() FolderConfig {
  80         return f.config
  81 }
  82
  83 // GetFullPath returns the full path
  84 func (f *PathMap) GetFullPath(dir string) string {
  85         if &dir == nil {
  86                 return f.config.DataPathMap.ServerPath
  87         }
  88         return filepath.Join(f.config.DataPathMap.ServerPath, dir)
  89 }
  90
  91 // Remove a folder
  92 func (f *PathMap) Remove() error {
  93         // nothing to do
  94         return nil
  95 }
  96
  97 // RegisterEventChange requests registration for folder change event
  98 func (f *PathMap) RegisterEventChange(cb *EventCB, data *EventCBData) error {
  99         return nil
 100 }
 101
 102 // UnRegisterEventChange remove registered callback
 103 func (f *PathMap) UnRegisterEventChange() error {
 104         return nil
 105 }
 106
 107 // Sync Force folder files synchronization
 108 func (f *PathMap) Sync() error {
 109         return nil
 110 }
 111
 112 // IsInSync Check if folder files are in-sync
 113 func (f *PathMap) IsInSync() (bool, error) {
 114         return true, nil
 115 }