-
Notifications
You must be signed in to change notification settings - Fork 0
/
device_test.go
279 lines (259 loc) · 9.74 KB
/
device_test.go
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
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
package auth
import (
"os"
"testing"
log "github.com/sirupsen/logrus"
)
func init() {
// log.SetFormatter(&log.JSONFormatter{})
log.SetFormatter(&log.TextFormatter{
DisableColors: false,
FullTimestamp: true,
})
log.SetReportCaller(false)
log.SetOutput(os.Stdout)
log.SetLevel(log.TraceLevel)
}
func TestDevOnCloud(t *testing.T) {
url := "http://auth.eensymachines.in/devices/000000007920365b"
status := &DeviceStatus{}
if err := DeviceStatusOnCloud(url, status); err != nil {
t.Error(err)
}
t.Log(status)
if status.Lock {
t.Log("Device is locked")
return
}
t.Log("Device is unlocked")
return
}
// func TestDevice(t *testing.T) {
// reg, e := ThisDeviceReg("kneeru@gmail.com")
// if e != nil {
// t.Error(e)
// return
// }
// t.Log(reg)
// }
// // lclDbConnect : helps you get a quick connection to local database connection
// // start the mongo container before the tests
// // depending on the database you are trying to connect you may have to change the details inside
// func lclDbConnect() (coll *DeviceRegColl, coll2 *BlacklistColl, close func(), err error) {
// ip := "192.168.0.39"
// session, err := mgo.Dial(ip)
// if err != nil {
// return
// }
// close = func() {
// session.Close()
// }
// c := session.DB("autolumin").C("devreg")
// if c == nil {
// log.Error("Failed to get collection")
// err = fmt.Errorf("Failed database collection connection")
// return
// }
// c2 := session.DB("autolumin").C("devblacklist")
// if c2 == nil {
// log.Error("Failed to get blacklist collection")
// err = fmt.Errorf("Failed database collection connection")
// return
// }
// log.Debugf("Now connected to the mongo database @ %s", ip)
// coll = &DeviceRegColl{c}
// coll2 = &BlacklistColl{c2}
// return
// }
// /*http handler for test purposes so that we can test apis as well.*/
// func apiDeviceOfSerial(w http.ResponseWriter, r *http.Request, prm httprouter.Params) {
// // getting the router param
// serial := prm.ByName("serial")
// coll, coll2, sessionClose, err := lclDbConnect()
// if err != nil {
// log.Error(err)
// w.WriteHeader(http.StatusInternalServerError)
// return
// }
// defer sessionClose()
// w.Header().Set("Content-Type", "application/json; charset=UTF-8")
// if r.Method == "GET" {
// status, err := coll.DeviceOfSerial(serial)
// if err != nil {
// log.Error(err)
// w.WriteHeader(http.StatusInternalServerError)
// return
// }
// if err := json.NewEncoder(w).Encode(status); err != nil {
// w.WriteHeader(http.StatusInternalServerError)
// return
// }
// } else if r.Method == "POST" {
// queries := r.URL.Query()
// lock := queries.Get("lock")
// if lock != "" {
// // trying to alter the device lock status
// lockstatus, err := strconv.ParseBool(lock)
// if err != nil {
// w.WriteHeader(http.StatusBadRequest)
// return
// }
// if lockstatus {
// if coll.LockDevice(serial) != nil {
// w.WriteHeader(http.StatusInternalServerError)
// return
// }
// } else {
// if coll.UnLockDevice(serial) != nil {
// w.WriteHeader(http.StatusInternalServerError)
// return
// }
// }
// }
// black := queries.Get("black")
// if black != "" {
// blackstatus, err := strconv.ParseBool(black)
// if err != nil {
// w.WriteHeader(http.StatusBadRequest)
// return
// }
// if blackstatus {
// if coll2.Black(&Blacklist{serial, "Changing black status from apiDeviceOfSerial"}) != nil {
// w.WriteHeader(http.StatusInternalServerError)
// return
// }
// } else {
// if coll2.White(serial) != nil {
// w.WriteHeader(http.StatusInternalServerError)
// return
// }
// }
// }
// }
// w.WriteHeader(http.StatusOK)
// return
// }
// func apiDevices(w http.ResponseWriter, r *http.Request, prm httprouter.Params) {
// w.Header().Set("Content-Type", "application/json; charset=UTF-8")
// coll, coll2, sessionClose, err := lclDbConnect()
// if err != nil {
// log.Error(err)
// w.WriteHeader(http.StatusInternalServerError)
// return
// }
// defer sessionClose()
// if r.Method == "POST" {
// decoder := json.NewDecoder(r.Body)
// reg := &DeviceReg{}
// err := decoder.Decode(reg)
// if err != nil {
// log.Error(err)
// w.WriteHeader(http.StatusBadRequest)
// return
// }
// err = coll.InsertDeviceReg(reg, coll2.Collection)
// if _, ok := err.(ErrInvalid); ok {
// w.WriteHeader(http.StatusBadRequest)
// return
// } else if _, ok := err.(ErrForbid); ok {
// w.WriteHeader(http.StatusForbidden)
// return
// } else if _, ok := err.(ErrDuplicate); ok {
// w.WriteHeader(http.StatusBadRequest)
// return
// } else if _, ok := err.(ErrQueryFailed); ok {
// w.WriteHeader(http.StatusInternalServerError)
// return
// }
// w.WriteHeader(http.StatusOK)
// return
// }
// }
// func TestMockApi(t *testing.T) {
// router := httprouter.New()
// router.GET("/devices/:serial", apiDeviceOfSerial)
// router.POST("/devices/:serial", apiDeviceOfSerial)
// router.POST("/devices/", apiDevices)
// log.Fatal(http.ListenAndServe("0.0.0.0:8080", router))
// }
// func TestDeviceLogin(t *testing.T) {
// // we quickly start a small http server so that we can test the login function
// go func() {
// router := httprouter.New()
// router.GET("/devices/:serial", apiDeviceOfSerial)
// router.POST("/devices/:serial", apiDeviceOfSerial)
// log.Fatal(http.ListenAndServe(":8080", router))
// }()
// reg, err := ThisDeviceReg("kneeru@gmail.com")
// if err != nil {
// t.Error(err)
// return
// }
// t.Log("------------------ Now testing registration --------------------")
// t.Logf("This device registration %v", reg)
// isreg, err := IsRegistered(fmt.Sprintf("http://localhost:8080/devices/%s", reg.Serial))
// assert.True(t, isreg, "This device was supposed to be registered")
// assert.Nil(t, err, fmt.Sprintf("Unexpected error when IsRegistered %s", err))
// t.Log("------------------ Now locking the device --------------------")
// resp, err := http.Post(fmt.Sprintf("http://localhost:8080/devices/%s?lock=true", reg.Serial), "application/json", nil)
// assert.Nil(t, err, "Did not expect error making the lock request")
// assert.Equal(t, resp.StatusCode, 200, "Was expecting 200 OK when locking the device")
// t.Log("------------------ Now testing lock status --------------------")
// locked, err := IsLocked(fmt.Sprintf("http://localhost:8080/devices/%s", reg.Serial))
// assert.True(t, locked, "The device was not supposed to be locked")
// assert.Nil(t, err, fmt.Sprintf("Unexpected error when IsRegistered %s", err))
// t.Log("------------------ Now unlocking the device --------------------")
// resp, err = http.Post(fmt.Sprintf("http://localhost:8080/devices/%s?lock=false", reg.Serial), "application/json", nil)
// assert.Nil(t, err, "Did not expect error making the lock request")
// assert.Equal(t, resp.StatusCode, 200, "Was expecting 200 OK when unlocking the device")
// t.Log("------------------ Now testing lock status --------------------")
// locked, err = IsLocked(fmt.Sprintf("http://localhost:8080/devices/%s", reg.Serial))
// assert.False(t, locked, "The device was not supposed to be locked")
// assert.Nil(t, err, fmt.Sprintf("Unexpected error when IsRegistered %s", err))
// t.Log("------------------ Now testing device owner --------------------")
// owned, err := IsOwnedBy(fmt.Sprintf("http://localhost:8080/devices/%s", reg.Serial), "kneeru@gmail.com")
// assert.True(t, owned, "The device was not supposed to be locked")
// assert.Nil(t, err, fmt.Sprintf("Unexpected error when IsRegistered %s", err))
// t.Log("------------------ Now testing invalid device owner --------------------")
// owned, err = IsOwnedBy(fmt.Sprintf("http://localhost:8080/devices/%s", reg.Serial), "jokebiden@gmail.com")
// assert.False(t, owned, "This devce is not owned by the user, invalid test result ")
// assert.Nil(t, err, fmt.Sprintf("Unexpected error when IsRegistered %s", err))
// // here is a chance to lock the device via api
// // Here now we change the serial number to see if and how the api reacts to it
// reg.Serial = "35435kjkljfdsf"
// t.Log("------------------ Now testing invalid registration --------------------")
// t.Logf("This device registration %v", reg)
// isreg, err = IsRegistered(fmt.Sprintf("http://localhost:8080/devices/%s", reg.Serial))
// assert.False(t, isreg, "This device was supposed to be registered")
// assert.Nil(t, err, fmt.Sprintf("Unexpected error when IsRegistered %s", err))
// }
// func TestFindUserDevices(t *testing.T) {
// t.Log("############### now for the user that is in the database ############### ")
// coll, _, sessionClose, _ := lclDbConnect()
// defer sessionClose()
// result, err := coll.FindUserDevices("kneeru@gmail.com")
// assert.Nil(t, err, fmt.Sprintf("Error in FindUserDevices %s", err))
// for _, r := range result {
// t.Log(r)
// }
// // Now the user thats not existent
// t.Log("############### now for the user that isnt in the database ############### ")
// result, err = coll.FindUserDevices("unknown@gmail.com")
// assert.Nil(t, err, fmt.Sprintf("Error in FindUserDevices %s", err))
// // We woudl be expecting empty result
// for _, r := range result {
// t.Log(r)
// }
// }
// func TestDeviceOfSerial(t *testing.T) {
// t.Log("############### now for the user that is in the database ############### ")
// coll, _, sessionClose, _ := lclDbConnect()
// defer sessionClose()
// result, err := coll.DeviceOfSerial("000000007920365b")
// assert.Nil(t, err, fmt.Sprintf("Error in DeviceOfSerial %s", err))
// t.Log(result)
// t.Log("############### now for the user that isnt in the database ############### ")
// result, err = coll.DeviceOfSerial("000000007920365c")
// assert.Nil(t, err, fmt.Sprintf("Error in DeviceOfSerial %s", err))
// t.Log(result)
// }