networkHttpController_test.go 16 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566
  1. package controller
  2. import (
  3. "testing"
  4. "time"
  5. "github.com/gravitl/netmaker/functions"
  6. "github.com/gravitl/netmaker/models"
  7. "github.com/stretchr/testify/assert"
  8. )
  9. type NetworkValidationTestCase struct {
  10. testname string
  11. network models.Network
  12. errMessage string
  13. }
  14. func deleteNet(t *testing.T) {
  15. nodes, err := functions.GetAllNodes()
  16. assert.Nil(t, err)
  17. for _, node := range nodes {
  18. t.Log("deleting node", node.Name)
  19. err := DeleteNode(node.MacAddress, node.Network)
  20. assert.Nil(t, err)
  21. }
  22. dns, err := GetAllDNS()
  23. assert.Nil(t, err)
  24. for _, entry := range dns {
  25. t.Log("deleting dns enty", entry.Name, entry.Network)
  26. err := DeleteDNS(entry.Name, entry.Network)
  27. assert.Nil(t, err)
  28. }
  29. networks, _ := models.GetNetworks()
  30. for _, network := range networks {
  31. t.Log("deleting network", network.NetID)
  32. success, err := DeleteNetwork(network.NetID)
  33. t.Log(success, err)
  34. }
  35. }
  36. func createNet() {
  37. var network models.Network
  38. network.NetID = "skynet"
  39. network.AddressRange = "10.0.0.1/24"
  40. network.DisplayName = "mynetwork"
  41. _, err := GetNetwork("skynet")
  42. if err != nil {
  43. CreateNetwork(network)
  44. }
  45. }
  46. func getNet() models.Network {
  47. network, _ := GetNetwork("skynet")
  48. return network
  49. }
  50. func TestGetNetworks(t *testing.T) {
  51. //calls models.GetNetworks --- nothing to be done
  52. }
  53. func TestCreateNetwork(t *testing.T) {
  54. deleteNet(t)
  55. var network models.Network
  56. network.NetID = "skynet"
  57. network.AddressRange = "10.0.0.1/24"
  58. network.DisplayName = "mynetwork"
  59. err := CreateNetwork(network)
  60. assert.Nil(t, err)
  61. }
  62. func TestGetDeleteNetwork(t *testing.T) {
  63. createNet()
  64. //create nodes
  65. t.Run("NetworkwithNodes", func(t *testing.T) {
  66. })
  67. t.Run("GetExistingNetwork", func(t *testing.T) {
  68. network, err := GetNetwork("skynet")
  69. assert.Nil(t, err)
  70. assert.Equal(t, "skynet", network.NetID)
  71. })
  72. t.Run("DeleteExistingNetwork", func(t *testing.T) {
  73. err := DeleteNetwork("skynet")
  74. assert.Nil(t, err)
  75. })
  76. t.Run("GetNonExistantNetwork", func(t *testing.T) {
  77. network, err := GetNetwork("skynet")
  78. assert.NotNil(t, err)
  79. assert.Equal(t, "mongo: no documents in result", err.Error())
  80. assert.Equal(t, "", network.NetID)
  81. })
  82. t.Run("NonExistantNetwork", func(t *testing.T) {
  83. err := DeleteNetwork("skynet")
  84. assert.Nil(t, err)
  85. })
  86. }
  87. func TestGetNetwork(t *testing.T) {
  88. createNet()
  89. t.Run("NoNetwork", func(t *testing.T) {
  90. network, err := GetNetwork("badnet")
  91. assert.NotNil(t, err)
  92. assert.Equal(t, "mongo: no documents in result", err.Error())
  93. assert.Equal(t, models.Network{}, network)
  94. })
  95. t.Run("Valid", func(t *testing.T) {
  96. network, err := GetNetwork("skynet")
  97. assert.Nil(t, err)
  98. assert.Equal(t, "skynet", network.NetID)
  99. })
  100. }
  101. func TestUpdateNetwork(t *testing.T) {
  102. createNet()
  103. network := getNet()
  104. t.Run("NetID", func(t *testing.T) {
  105. var networkupdate models.Network
  106. networkupdate.NetID = "wirecat"
  107. _, err := UpdateNetwork(networkupdate, network)
  108. assert.NotNil(t, err)
  109. assert.Equal(t, "NetID is not editable", err.Error())
  110. })
  111. t.Run("LocalRange", func(t *testing.T) {
  112. var networkupdate models.Network
  113. //NetID needs to be set as it will be in updateNetwork
  114. networkupdate.NetID = "skynet"
  115. networkupdate.LocalRange = "192.168.0.1/24"
  116. update, err := UpdateNetwork(networkupdate, network)
  117. assert.Nil(t, err)
  118. t.Log(err, update)
  119. })
  120. }
  121. func TestKeyUpdate(t *testing.T) {
  122. createNet()
  123. existing, err := GetNetwork("skynet")
  124. assert.Nil(t, err)
  125. time.Sleep(time.Second * 1)
  126. network, err := KeyUpdate("skynet")
  127. assert.Nil(t, err)
  128. network, err = GetNetwork("skynet")
  129. assert.Nil(t, err)
  130. assert.Greater(t, network.KeyUpdateTimeStamp, existing.KeyUpdateTimeStamp)
  131. }
  132. func TestCreateKey(t *testing.T) {
  133. createNet()
  134. var accesskey models.AccessKey
  135. var network models.Network
  136. network.NetID = "skynet"
  137. t.Run("InvalidName", func(t *testing.T) {
  138. network, err := GetNetwork("skynet")
  139. assert.Nil(t, err)
  140. accesskey.Name = "bad-name"
  141. _, err = CreateAccessKey(accesskey, network)
  142. assert.NotNil(t, err)
  143. assert.Contains(t, err.Error(), "Field validation for 'Name' failed on the 'alphanum' tag")
  144. })
  145. t.Run("NameTooLong", func(t *testing.T) {
  146. network, err := GetNetwork("skynet")
  147. assert.Nil(t, err)
  148. accesskey.Name = "Thisisareallylongkeynamethatwillfail"
  149. _, err = CreateAccessKey(accesskey, network)
  150. assert.NotNil(t, err)
  151. assert.Contains(t, err.Error(), "Field validation for 'Name' failed on the 'max' tag")
  152. })
  153. t.Run("BlankName", func(t *testing.T) {
  154. network, err := GetNetwork("skynet")
  155. assert.Nil(t, err)
  156. accesskey.Name = ""
  157. key, err := CreateAccessKey(accesskey, network)
  158. assert.Nil(t, err)
  159. assert.NotEqual(t, "", key.Name)
  160. })
  161. t.Run("InvalidValue", func(t *testing.T) {
  162. network, err := GetNetwork("skynet")
  163. assert.Nil(t, err)
  164. accesskey.Value = "bad-value"
  165. _, err = CreateAccessKey(accesskey, network)
  166. assert.NotNil(t, err)
  167. assert.Contains(t, err.Error(), "Field validation for 'Value' failed on the 'alphanum' tag")
  168. })
  169. t.Run("BlankValue", func(t *testing.T) {
  170. network, err := GetNetwork("skynet")
  171. assert.Nil(t, err)
  172. accesskey.Name = "mykey"
  173. accesskey.Value = ""
  174. key, err := CreateAccessKey(accesskey, network)
  175. assert.Nil(t, err)
  176. assert.NotEqual(t, "", key.Value)
  177. assert.Equal(t, accesskey.Name, key.Name)
  178. })
  179. t.Run("ValueTooLong", func(t *testing.T) {
  180. network, err := GetNetwork("skynet")
  181. assert.Nil(t, err)
  182. accesskey.Name = "keyname"
  183. accesskey.Value = "AccessKeyValuethatistoolong"
  184. _, err = CreateAccessKey(accesskey, network)
  185. assert.NotNil(t, err)
  186. assert.Contains(t, err.Error(), "Field validation for 'Value' failed on the 'max' tag")
  187. })
  188. t.Run("BlankUses", func(t *testing.T) {
  189. network, err := GetNetwork("skynet")
  190. assert.Nil(t, err)
  191. accesskey.Uses = 0
  192. accesskey.Value = ""
  193. key, err := CreateAccessKey(accesskey, network)
  194. assert.Nil(t, err)
  195. assert.Equal(t, 1, key.Uses)
  196. })
  197. t.Run("DuplicateKey", func(t *testing.T) {
  198. network, err := GetNetwork("skynet")
  199. assert.Nil(t, err)
  200. accesskey.Name = "mykey"
  201. _, err = CreateAccessKey(accesskey, network)
  202. assert.NotNil(t, err)
  203. assert.Equal(t, "Duplicate AccessKey Name", err.Error())
  204. })
  205. }
  206. func TestGetKeys(t *testing.T) {
  207. deleteNet(t)
  208. createNet()
  209. network, err := GetNetwork("skynet")
  210. assert.Nil(t, err)
  211. var key models.AccessKey
  212. key.Name = "mykey"
  213. _, err = CreateAccessKey(key, network)
  214. assert.Nil(t, err)
  215. t.Run("KeyExists", func(t *testing.T) {
  216. keys, err := GetKeys(network.NetID)
  217. assert.Nil(t, err)
  218. assert.NotEqual(t, models.AccessKey{}, keys)
  219. })
  220. t.Run("NonExistantKey", func(t *testing.T) {
  221. err := DeleteKey("mykey", "skynet")
  222. assert.Nil(t, err)
  223. keys, err := GetKeys(network.NetID)
  224. assert.Nil(t, err)
  225. assert.Equal(t, []models.AccessKey(nil), keys)
  226. })
  227. }
  228. func TestDeleteKey(t *testing.T) {
  229. createNet()
  230. network, err := GetNetwork("skynet")
  231. assert.Nil(t, err)
  232. var key models.AccessKey
  233. key.Name = "mykey"
  234. _, err = CreateAccessKey(key, network)
  235. assert.Nil(t, err)
  236. t.Run("ExistingKey", func(t *testing.T) {
  237. err := DeleteKey("mykey", "skynet")
  238. assert.Nil(t, err)
  239. })
  240. t.Run("NonExistantKey", func(t *testing.T) {
  241. err := DeleteKey("mykey", "skynet")
  242. assert.NotNil(t, err)
  243. assert.Equal(t, "key mykey does not exist", err.Error())
  244. })
  245. }
  246. func TestSecurityCheck(t *testing.T) {
  247. t.Run("NoNetwork", func(t *testing.T) {
  248. err := SecurityCheck(false, "", "Bearer secretkey")
  249. assert.Nil(t, err)
  250. })
  251. t.Run("WithNetwork", func(t *testing.T) {
  252. err := SecurityCheck(false, "skynet", "Bearer secretkey")
  253. assert.Nil(t, err)
  254. })
  255. t.Run("BadNet", func(t *testing.T) {
  256. err := SecurityCheck(false, "badnet", "Bearer secretkey")
  257. assert.NotNil(t, err)
  258. t.Log(err)
  259. })
  260. t.Run("BadToken", func(t *testing.T) {
  261. err := SecurityCheck(false, "skynet", "Bearer badkey")
  262. assert.NotNil(t, err)
  263. t.Log(err)
  264. })
  265. }
  266. func TestValidateNetworkUpdate(t *testing.T) {
  267. //yes := true
  268. //no := false
  269. deleteNet(t)
  270. //DeleteNetworks
  271. cases := []NetworkValidationTestCase{
  272. NetworkValidationTestCase{
  273. testname: "InvalidAddress",
  274. network: models.Network{
  275. AddressRange: "10.0.0.256",
  276. },
  277. errMessage: "Field validation for 'AddressRange' failed on the 'cidr' tag",
  278. },
  279. NetworkValidationTestCase{
  280. testname: "InvalidAddress6",
  281. network: models.Network{
  282. AddressRange6: "2607::ag",
  283. },
  284. errMessage: "Field validation for 'AddressRange6' failed on the 'cidr' tag",
  285. },
  286. NetworkValidationTestCase{
  287. testname: "BadDisplayName",
  288. network: models.Network{
  289. DisplayName: "skynet*",
  290. },
  291. errMessage: "Field validation for 'DisplayName' failed on the 'alphanum' tag",
  292. },
  293. NetworkValidationTestCase{
  294. testname: "DisplayNameTooLong",
  295. network: models.Network{
  296. DisplayName: "Thisisareallylongdisplaynamethatistoolong",
  297. },
  298. errMessage: "Field validation for 'DisplayName' failed on the 'max' tag",
  299. },
  300. NetworkValidationTestCase{
  301. testname: "DisplayNameTooShort",
  302. network: models.Network{
  303. DisplayName: "1",
  304. },
  305. errMessage: "Field validation for 'DisplayName' failed on the 'min' tag",
  306. },
  307. NetworkValidationTestCase{
  308. testname: "InvalidNetID",
  309. network: models.Network{
  310. NetID: "contains spaces",
  311. },
  312. errMessage: "Field validation for 'NetID' failed on the 'alphanum' tag",
  313. },
  314. NetworkValidationTestCase{
  315. testname: "NetIDTooLong",
  316. network: models.Network{
  317. NetID: "LongNetIDName",
  318. },
  319. errMessage: "Field validation for 'NetID' failed on the 'max' tag",
  320. },
  321. NetworkValidationTestCase{
  322. testname: "ListenPortTooLow",
  323. network: models.Network{
  324. DefaultListenPort: 1023,
  325. },
  326. errMessage: "Field validation for 'DefaultListenPort' failed on the 'min' tag",
  327. },
  328. NetworkValidationTestCase{
  329. testname: "ListenPortTooHigh",
  330. network: models.Network{
  331. DefaultListenPort: 65536,
  332. },
  333. errMessage: "Field validation for 'DefaultListenPort' failed on the 'max' tag",
  334. },
  335. NetworkValidationTestCase{
  336. testname: "KeepAliveTooBig",
  337. network: models.Network{
  338. DefaultKeepalive: 1010,
  339. },
  340. errMessage: "Field validation for 'DefaultKeepalive' failed on the 'max' tag",
  341. },
  342. NetworkValidationTestCase{
  343. testname: "InvalidLocalRange",
  344. network: models.Network{
  345. LocalRange: "192.168.0.1",
  346. },
  347. errMessage: "Field validation for 'LocalRange' failed on the 'cidr' tag",
  348. },
  349. NetworkValidationTestCase{
  350. testname: "CheckInIntervalTooBig",
  351. network: models.Network{
  352. DefaultCheckInInterval: 100001,
  353. },
  354. errMessage: "Field validation for 'DefaultCheckInInterval' failed on the 'max' tag",
  355. },
  356. NetworkValidationTestCase{
  357. testname: "CheckInIntervalTooSmall",
  358. network: models.Network{
  359. DefaultCheckInInterval: 1,
  360. },
  361. errMessage: "Field validation for 'DefaultCheckInInterval' failed on the 'min' tag",
  362. },
  363. }
  364. for _, tc := range cases {
  365. t.Run(tc.testname, func(t *testing.T) {
  366. network := models.Network(tc.network)
  367. err := ValidateNetworkUpdate(network)
  368. assert.NotNil(t, err)
  369. assert.Contains(t, err.Error(), tc.errMessage)
  370. })
  371. }
  372. }
  373. func TestValidateNetworkCreate(t *testing.T) {
  374. yes := true
  375. no := false
  376. deleteNet(t)
  377. //DeleteNetworks
  378. cases := []NetworkValidationTestCase{
  379. NetworkValidationTestCase{
  380. testname: "InvalidAddress",
  381. network: models.Network{
  382. AddressRange: "10.0.0.256",
  383. NetID: "skynet",
  384. IsDualStack: &no,
  385. },
  386. errMessage: "Field validation for 'AddressRange' failed on the 'cidr' tag",
  387. },
  388. NetworkValidationTestCase{
  389. testname: "BadDisplayName",
  390. network: models.Network{
  391. AddressRange: "10.0.0.1/24",
  392. NetID: "skynet",
  393. DisplayName: "skynet*",
  394. IsDualStack: &no,
  395. },
  396. errMessage: "Field validation for 'DisplayName' failed on the 'alphanum' tag",
  397. },
  398. NetworkValidationTestCase{
  399. testname: "DisplayNameTooLong",
  400. network: models.Network{
  401. AddressRange: "10.0.0.1/24",
  402. NetID: "skynet",
  403. DisplayName: "Thisisareallylongdisplaynamethatistoolong",
  404. IsDualStack: &no,
  405. },
  406. errMessage: "Field validation for 'DisplayName' failed on the 'max' tag",
  407. },
  408. NetworkValidationTestCase{
  409. testname: "DisplayNameTooShort",
  410. network: models.Network{
  411. AddressRange: "10.0.0.1/24",
  412. NetID: "skynet",
  413. DisplayName: "1",
  414. IsDualStack: &no,
  415. },
  416. errMessage: "Field validation for 'DisplayName' failed on the 'min' tag",
  417. },
  418. NetworkValidationTestCase{
  419. testname: "NetIDMissing",
  420. network: models.Network{
  421. AddressRange: "10.0.0.1/24",
  422. IsDualStack: &no,
  423. },
  424. errMessage: "Field validation for 'NetID' failed on the 'required' tag",
  425. },
  426. NetworkValidationTestCase{
  427. testname: "InvalidNetID",
  428. network: models.Network{
  429. AddressRange: "10.0.0.1/24",
  430. NetID: "contains spaces",
  431. IsDualStack: &no,
  432. },
  433. errMessage: "Field validation for 'NetID' failed on the 'alphanum' tag",
  434. },
  435. NetworkValidationTestCase{
  436. testname: "NetIDTooShort",
  437. network: models.Network{
  438. AddressRange: "10.0.0.1/24",
  439. NetID: "",
  440. IsDualStack: &no,
  441. },
  442. errMessage: "Field validation for 'NetID' failed on the 'required' tag",
  443. },
  444. NetworkValidationTestCase{
  445. testname: "NetIDTooLong",
  446. network: models.Network{
  447. AddressRange: "10.0.0.1/24",
  448. NetID: "LongNetIDName",
  449. IsDualStack: &no,
  450. },
  451. errMessage: "Field validation for 'NetID' failed on the 'max' tag",
  452. },
  453. NetworkValidationTestCase{
  454. testname: "ListenPortTooLow",
  455. network: models.Network{
  456. AddressRange: "10.0.0.1/24",
  457. NetID: "skynet",
  458. DefaultListenPort: 1023,
  459. IsDualStack: &no,
  460. },
  461. errMessage: "Field validation for 'DefaultListenPort' failed on the 'min' tag",
  462. },
  463. NetworkValidationTestCase{
  464. testname: "ListenPortTooHigh",
  465. network: models.Network{
  466. AddressRange: "10.0.0.1/24",
  467. NetID: "skynet",
  468. DefaultListenPort: 65536,
  469. IsDualStack: &no,
  470. },
  471. errMessage: "Field validation for 'DefaultListenPort' failed on the 'max' tag",
  472. },
  473. NetworkValidationTestCase{
  474. testname: "KeepAliveTooBig",
  475. network: models.Network{
  476. AddressRange: "10.0.0.1/24",
  477. NetID: "skynet",
  478. DefaultKeepalive: 1010,
  479. IsDualStack: &no,
  480. },
  481. errMessage: "Field validation for 'DefaultKeepalive' failed on the 'max' tag",
  482. },
  483. NetworkValidationTestCase{
  484. testname: "InvalidLocalRange",
  485. network: models.Network{
  486. AddressRange: "10.0.0.1/24",
  487. NetID: "skynet",
  488. LocalRange: "192.168.0.1",
  489. IsDualStack: &no,
  490. },
  491. errMessage: "Field validation for 'LocalRange' failed on the 'cidr' tag",
  492. },
  493. NetworkValidationTestCase{
  494. testname: "DualStackWithoutIPv6",
  495. network: models.Network{
  496. AddressRange: "10.0.0.1/24",
  497. NetID: "skynet",
  498. IsDualStack: &yes,
  499. },
  500. errMessage: "Field validation for 'AddressRange6' failed on the 'addressrange6_valid' tag",
  501. },
  502. NetworkValidationTestCase{
  503. testname: "CheckInIntervalTooBig",
  504. network: models.Network{
  505. AddressRange: "10.0.0.1/24",
  506. NetID: "skynet",
  507. IsDualStack: &no,
  508. DefaultCheckInInterval: 100001,
  509. },
  510. errMessage: "Field validation for 'DefaultCheckInInterval' failed on the 'max' tag",
  511. },
  512. NetworkValidationTestCase{
  513. testname: "CheckInIntervalTooSmall",
  514. network: models.Network{
  515. AddressRange: "10.0.0.1/24",
  516. NetID: "skynet",
  517. IsDualStack: &no,
  518. DefaultCheckInInterval: 1,
  519. },
  520. errMessage: "Field validation for 'DefaultCheckInInterval' failed on the 'min' tag",
  521. },
  522. }
  523. for _, tc := range cases {
  524. t.Run(tc.testname, func(t *testing.T) {
  525. err := ValidateNetworkCreate(tc.network)
  526. assert.NotNil(t, err)
  527. assert.Contains(t, err.Error(), tc.errMessage)
  528. })
  529. }
  530. t.Run("DuplicateNetID", func(t *testing.T) {
  531. deleteNet(t)
  532. var net1, net2 models.Network
  533. net1.NetID = "skynet"
  534. net1.AddressRange = "10.0.0.1/24"
  535. net1.DisplayName = "mynetwork"
  536. net2.NetID = "skynet"
  537. net2.AddressRange = "10.0.1.1/24"
  538. net2.IsDualStack = &no
  539. err := CreateNetwork(net1)
  540. assert.Nil(t, err)
  541. err = ValidateNetworkCreate(net2)
  542. assert.NotNil(t, err)
  543. assert.Contains(t, err.Error(), "Field validation for 'NetID' failed on the 'netid_valid' tag")
  544. })
  545. t.Run("DuplicateDisplayName", func(t *testing.T) {
  546. var network models.Network
  547. network.NetID = "wirecat"
  548. network.AddressRange = "10.0.100.1/24"
  549. network.IsDualStack = &no
  550. network.DisplayName = "mynetwork"
  551. err := ValidateNetworkCreate(network)
  552. assert.NotNil(t, err)
  553. assert.Contains(t, err.Error(), "Field validation for 'DisplayName' failed on the 'displayname_unique' tag")
  554. })
  555. }