e3d6607796ea5d8bbb35b6bdca24cf971b1d72bc
[src/xds/xds-server.git] / lib / crosssdk / sdks.go
1 package crosssdk
2
3 import (
4         "fmt"
5         "path"
6         "path/filepath"
7         "strings"
8         "sync"
9
10         "github.com/Sirupsen/logrus"
11         common "github.com/iotbzh/xds-common/golib"
12         "github.com/iotbzh/xds-server/lib/xdsconfig"
13 )
14
15 // SDKs List of installed SDK
16 type SDKs struct {
17         Sdks map[string]*SDK
18
19         mutex sync.Mutex
20 }
21
22 // Init creates a new instance of Syncthing
23 func Init(cfg *xdsconfig.Config, log *logrus.Logger) (*SDKs, error) {
24         s := SDKs{
25                 Sdks: make(map[string]*SDK),
26         }
27
28         // Retrieve installed sdks
29         sdkRD := cfg.FileConf.SdkRootDir
30
31         if common.Exists(sdkRD) {
32
33                 // Assume that SDK install tree is <rootdir>/<profile>/<version>/<arch>
34                 dirs, err := filepath.Glob(path.Join(sdkRD, "*", "*", "*"))
35                 if err != nil {
36                         log.Debugf("Error while retrieving SDKs: dir=%s, error=%s", sdkRD, err.Error())
37                         return &s, err
38                 }
39                 s.mutex.Lock()
40                 defer s.mutex.Unlock()
41
42                 for _, d := range dirs {
43                         if !common.IsDir(d) {
44                                 continue
45                         }
46                         sdk, err := NewCrossSDK(d)
47                         if err != nil {
48                                 log.Debugf("Error while processing SDK dir=%s, err=%s", d, err.Error())
49                                 continue
50                         }
51                         s.Sdks[sdk.ID] = sdk
52                 }
53         }
54
55         log.Debugf("SDKs: %d cross sdks found", len(s.Sdks))
56
57         return &s, nil
58 }
59
60 // ResolveID Complete an SDK ID (helper for user that can use partial ID value)
61 func (s *SDKs) ResolveID(id string) (string, error) {
62         if id == "" {
63                 return "", nil
64         }
65
66         match := []string{}
67         for iid := range s.Sdks {
68                 fmt.Printf("SEB prefix iid=%v id=%v\n", iid, id)
69                 if strings.HasPrefix(iid, id) {
70                         match = append(match, iid)
71                         fmt.Printf("  SEB match (%d): %v\n", len(match), match)
72                 }
73         }
74         fmt.Printf("SEB match (%d): %v\n", len(match), match)
75
76         if len(match) == 1 {
77                 return match[0], nil
78         } else if len(match) == 0 {
79                 return id, fmt.Errorf("Unknown id")
80         }
81         return id, fmt.Errorf("Multiple IDs found with provided prefix: " + id)
82 }
83
84 // Get returns an SDK from id
85 func (s *SDKs) Get(id string) *SDK {
86         s.mutex.Lock()
87         defer s.mutex.Unlock()
88
89         sc, exist := s.Sdks[id]
90         if !exist {
91                 return nil
92         }
93         return sc
94 }
95
96 // GetAll returns all existing SDKs
97 func (s *SDKs) GetAll() []SDK {
98         s.mutex.Lock()
99         defer s.mutex.Unlock()
100         res := []SDK{}
101         for _, v := range s.Sdks {
102                 res = append(res, *v)
103         }
104         return res
105 }
106
107 // GetEnvCmd returns the command used to initialized the environment for an SDK
108 func (s *SDKs) GetEnvCmd(id string, defaultID string) []string {
109         if id == "" && defaultID == "" {
110                 // no env cmd
111                 return []string{}
112         }
113
114         s.mutex.Lock()
115         defer s.mutex.Unlock()
116
117         if sdk, exist := s.Sdks[id]; exist {
118                 return sdk.GetEnvCmd()
119         }
120
121         if sdk, exist := s.Sdks[defaultID]; defaultID != "" && exist {
122                 return sdk.GetEnvCmd()
123         }
124
125         // Return default env that may be empty
126         return []string{}
127 }