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