123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623 |
- package main
- import (
- "encoding/json"
- "io/ioutil"
- "net/http"
- "testing"
- "time"
- "github.com/gravitl/netmaker/models"
- "github.com/stretchr/testify/assert"
- )
- func TestCreateNetwork(t *testing.T) {
- network := models.Network{}
- network.NetID = "skynet"
- network.AddressRange = "10.71.0.0/16"
- deleteNetworks(t)
- t.Run("InvalidToken", func(t *testing.T) {
- response, err := api(t, network, http.MethodPost, baseURL+"/api/networks", "badkey")
- assert.Nil(t, err, err)
- assert.Equal(t, http.StatusUnauthorized, response.StatusCode)
- defer response.Body.Close()
- var message models.ErrorResponse
- err = json.NewDecoder(response.Body).Decode(&message)
- assert.Nil(t, err, err)
- assert.Equal(t, http.StatusUnauthorized, message.Code)
- assert.Contains(t, message.Message, "rror verifying user toke")
- })
- t.Run("CreateNetwork", func(t *testing.T) {
- response, err := api(t, network, http.MethodPost, baseURL+"/api/networks", "secretkey")
- assert.Nil(t, err, err)
- assert.Equal(t, http.StatusOK, response.StatusCode)
- })
- t.Run("DuplicateNetwork", func(t *testing.T) {
- response, err := api(t, network, http.MethodPost, baseURL+"/api/networks", "secretkey")
- assert.Nil(t, err, err)
- assert.Equal(t, http.StatusBadRequest, response.StatusCode)
- })
- t.Run("BadName", func(t *testing.T) {
- network.NetID = "thisnameistoolong"
- response, err := api(t, network, http.MethodPost, baseURL+"/api/networks", "secretkey")
- assert.Nil(t, err, err)
- assert.Equal(t, http.StatusBadRequest, response.StatusCode)
- })
- t.Run("BadAddress", func(t *testing.T) {
- network.NetID = "wirecat"
- network.AddressRange = "10.300.20.56/36"
- response, err := api(t, network, http.MethodPost, baseURL+"/api/networks", "secretkey")
- assert.Nil(t, err, err)
- assert.Equal(t, http.StatusBadRequest, response.StatusCode)
- })
- }
- func TestGetNetworks(t *testing.T) {
- t.Run("ValidToken", func(t *testing.T) {
- response, err := api(t, "", http.MethodGet, baseURL+"/api/networks", "secretkey")
- assert.Nil(t, err, err)
- defer response.Body.Close()
- assert.Equal(t, http.StatusOK, response.StatusCode)
- err = json.NewDecoder(response.Body).Decode(&Networks)
- assert.Nil(t, err, err)
- })
- t.Run("InvalidToken", func(t *testing.T) {
- response, err := api(t, "", http.MethodGet, baseURL+"/api/networks", "badkey")
- assert.Nil(t, err, err)
- defer response.Body.Close()
- var message models.ErrorResponse
- err = json.NewDecoder(response.Body).Decode(&message)
- assert.Nil(t, err, err)
- assert.Equal(t, http.StatusUnauthorized, response.StatusCode)
- assert.Equal(t, http.StatusUnauthorized, message.Code)
- assert.Contains(t, message.Message, "rror verifying user toke")
- })
- }
- func TestGetNetwork(t *testing.T) {
- t.Run("ValidToken", func(t *testing.T) {
- var network models.Network
- response, err := api(t, "", http.MethodGet, baseURL+"/api/networks/skynet", "secretkey")
- assert.Nil(t, err, err)
- defer response.Body.Close()
- assert.Equal(t, http.StatusOK, response.StatusCode)
- err = json.NewDecoder(response.Body).Decode(&network)
- assert.Nil(t, err, err)
- // --- needs fixing ------ returns previous name
- //assert.Equal(t, "skynet", network.DisplayName)
- })
- t.Run("InvalidToken", func(t *testing.T) {
- response, err := api(t, "", http.MethodGet, baseURL+"/api/networks/skynet", "badkey")
- assert.Nil(t, err, err)
- defer response.Body.Close()
- var message models.ErrorResponse
- err = json.NewDecoder(response.Body).Decode(&message)
- assert.Nil(t, err, err)
- assert.Equal(t, http.StatusUnauthorized, response.StatusCode)
- assert.Equal(t, http.StatusUnauthorized, message.Code)
- assert.Contains(t, message.Message, "rror verifying user toke")
- })
- t.Run("InvalidNetwork", func(t *testing.T) {
- response, err := api(t, "", http.MethodGet, baseURL+"/api/networks/badnetwork", "secretkey")
- assert.Nil(t, err, err)
- defer response.Body.Close()
- var message models.ErrorResponse
- err = json.NewDecoder(response.Body).Decode(&message)
- assert.Nil(t, err, err)
- assert.Contains(t, message.Message, "his network does not exist")
- assert.Equal(t, http.StatusNotFound, response.StatusCode)
- })
- }
- func TestDeleteNetwork(t *testing.T) {
- t.Run("InvalidKey", func(t *testing.T) {
- setup(t)
- response, err := api(t, "", http.MethodDelete, baseURL+"/api/networks/skynet", "badkey")
- assert.Nil(t, err, err)
- defer response.Body.Close()
- var message models.ErrorResponse
- err = json.NewDecoder(response.Body).Decode(&message)
- assert.Nil(t, err, err)
- assert.Equal(t, http.StatusUnauthorized, response.StatusCode)
- assert.Equal(t, http.StatusUnauthorized, message.Code)
- assert.Contains(t, message.Message, "rror verifying user toke")
- })
- t.Run("Badnetwork", func(t *testing.T) {
- response, err := api(t, "", http.MethodDelete, baseURL+"/api/networks/badnetwork", "secretkey")
- assert.Nil(t, err, err)
- defer response.Body.Close()
- var message models.ErrorResponse
- err = json.NewDecoder(response.Body).Decode(&message)
- assert.Nil(t, err, err)
- assert.Contains(t, message.Message, "his network does not exist")
- assert.Equal(t, http.StatusNotFound, response.StatusCode)
- })
- t.Run("NodesExist", func(t *testing.T) {
- setup(t)
- response, err := api(t, "", http.MethodDelete, baseURL+"/api/networks/skynet", "secretkey")
- assert.Nil(t, err, err)
- assert.Equal(t, http.StatusForbidden, response.StatusCode)
- defer response.Body.Close()
- var message models.ErrorResponse
- err = json.NewDecoder(response.Body).Decode(&message)
- assert.Nil(t, err, err)
- assert.Contains(t, message.Message, "Node check failed")
- assert.Equal(t, http.StatusForbidden, message.Code)
- })
- t.Run("ValidKey", func(t *testing.T) {
- type Message struct {
- DeletedCount int64
- }
- setup(t)
- deleteAllNodes(t)
- response, err := api(t, "", http.MethodDelete, baseURL+"/api/networks/skynet", "secretkey")
- assert.Nil(t, err, err)
- defer response.Body.Close()
- var message Message
- err = json.NewDecoder(response.Body).Decode(&message)
- assert.Nil(t, err, err)
- assert.Equal(t, http.StatusOK, response.StatusCode)
- assert.Equal(t, int64(1), message.DeletedCount)
- })
- }
- func TestCreateKey(t *testing.T) {
- //ensure we are working with known networks
- deleteNetworks(t)
- createNetwork(t)
- key := models.AccessKey{}
- key.Name = "skynet"
- key.Uses = 10
- t.Run("MultiUse", func(t *testing.T) {
- response, err := api(t, key, http.MethodPost, baseURL+"/api/networks/skynet/keys", "secretkey")
- assert.Nil(t, err, err)
- assert.Equal(t, http.StatusOK, response.StatusCode)
- defer response.Body.Close()
- message, err := ioutil.ReadAll(response.Body)
- assert.Nil(t, err, err)
- assert.NotNil(t, message, message)
- returnedkey := getKey(t, key.Name)
- assert.Equal(t, key.Name, returnedkey.Name)
- assert.Equal(t, key.Uses, returnedkey.Uses)
- })
- deleteKey(t, "skynet", "skynet")
- t.Run("ZeroUse", func(t *testing.T) {
- //
- key.Uses = 0
- response, err := api(t, key, http.MethodPost, baseURL+"/api/networks/skynet/keys", "secretkey")
- assert.Nil(t, err, err)
- assert.Equal(t, http.StatusOK, response.StatusCode)
- defer response.Body.Close()
- message, err := ioutil.ReadAll(response.Body)
- assert.Nil(t, err, err)
- assert.NotNil(t, message, message)
- returnedkey := getKey(t, key.Name)
- assert.Equal(t, key.Name, returnedkey.Name)
- assert.Equal(t, 1, returnedkey.Uses)
- })
- t.Run("DuplicateAccessKey", func(t *testing.T) {
- response, err := api(t, key, http.MethodPost, baseURL+"/api/networks/skynet/keys", "secretkey")
- assert.Nil(t, err, err)
- assert.Equal(t, http.StatusBadRequest, response.StatusCode)
- defer response.Body.Close()
- var message models.ErrorResponse
- err = json.NewDecoder(response.Body).Decode(&message)
- assert.Nil(t, err)
- assert.Equal(t, http.StatusBadRequest, message.Code)
- assert.Equal(t, "Duplicate AccessKey Name", message.Message)
- })
- t.Run("InvalidToken", func(t *testing.T) {
- response, err := api(t, key, http.MethodPost, baseURL+"/api/networks/skynet/keys", "badkey")
- assert.Nil(t, err, err)
- assert.Equal(t, http.StatusUnauthorized, response.StatusCode)
- defer response.Body.Close()
- var message models.ErrorResponse
- err = json.NewDecoder(response.Body).Decode(&message)
- assert.Nil(t, err, err)
- assert.Equal(t, http.StatusUnauthorized, message.Code)
- assert.Contains(t, message.Message, "rror verifying user toke")
- })
- t.Run("Badnetwork", func(t *testing.T) {
- response, err := api(t, key, http.MethodPost, baseURL+"/api/networks/badnetwork/keys", "secretkey")
- assert.Nil(t, err, err)
- defer response.Body.Close()
- var message models.ErrorResponse
- err = json.NewDecoder(response.Body).Decode(&message)
- assert.Nil(t, err, err)
- assert.Contains(t, message.Message, "his network does not exist")
- assert.Equal(t, http.StatusNotFound, response.StatusCode)
- })
- }
- func TestDeleteKey(t *testing.T) {
- //ensure we are working with known networks
- deleteNetworks(t)
- createNetwork(t)
- //ensure key exists
- createKey(t)
- t.Run("KeyValid", func(t *testing.T) {
- response, err := api(t, "", http.MethodDelete, baseURL+"/api/networks/skynet/keys/skynet", "secretkey")
- assert.Nil(t, err, err)
- assert.Equal(t, http.StatusOK, response.StatusCode)
- })
- t.Run("InValidKey", func(t *testing.T) {
- response, err := api(t, "", http.MethodDelete, baseURL+"/api/networks/skynet/keys/badkey", "secretkey")
- assert.Nil(t, err, err)
- defer response.Body.Close()
- var message models.ErrorResponse
- err = json.NewDecoder(response.Body).Decode(&message)
- assert.Nil(t, err, err)
- assert.Equal(t, http.StatusBadRequest, message.Code)
- assert.Equal(t, "key badkey does not exist", message.Message)
- assert.Equal(t, http.StatusBadRequest, response.StatusCode)
- })
- t.Run("KeyInValidnetwork", func(t *testing.T) {
- response, err := api(t, "", http.MethodDelete, baseURL+"/api/networks/badnetwork/keys/skynet", "secretkey")
- assert.Nil(t, err, err)
- defer response.Body.Close()
- var message models.ErrorResponse
- err = json.NewDecoder(response.Body).Decode(&message)
- assert.Nil(t, err, err)
- assert.Contains(t, message.Message, "his network does not exist")
- assert.Equal(t, http.StatusNotFound, response.StatusCode)
- })
- t.Run("InvalidCredentials", func(t *testing.T) {
- response, err := api(t, "", http.MethodDelete, baseURL+"/api/networks/skynet/keys/skynet", "badkey")
- assert.Nil(t, err, err)
- assert.Equal(t, http.StatusUnauthorized, response.StatusCode)
- defer response.Body.Close()
- var message models.ErrorResponse
- err = json.NewDecoder(response.Body).Decode(&message)
- assert.Nil(t, err, err)
- assert.Equal(t, http.StatusUnauthorized, message.Code)
- assert.Contains(t, message.Message, "rror verifying user toke")
- })
- }
- func TestGetKeys(t *testing.T) {
- //ensure we are working with known networks
- deleteNetworks(t)
- createNetwork(t)
- createKey(t)
- t.Run("Valid", func(t *testing.T) {
- response, err := api(t, "", http.MethodGet, baseURL+"/api/networks/skynet/keys", "secretkey")
- assert.Nil(t, err, err)
- assert.Equal(t, http.StatusOK, response.StatusCode)
- defer response.Body.Close()
- var keys []models.AccessKey
- err = json.NewDecoder(response.Body).Decode(&keys)
- assert.Nil(t, err, err)
- })
- t.Run("Invalidnetwork", func(t *testing.T) {
- response, err := api(t, "", http.MethodGet, baseURL+"/api/networks/badnetwork/keys", "secretkey")
- assert.Nil(t, err, err)
- defer response.Body.Close()
- var message models.ErrorResponse
- err = json.NewDecoder(response.Body).Decode(&message)
- assert.Nil(t, err, err)
- assert.Contains(t, message.Message, "his network does not exist")
- assert.Equal(t, http.StatusNotFound, response.StatusCode)
- })
- t.Run("InvalidCredentials", func(t *testing.T) {
- response, err := api(t, "", http.MethodGet, baseURL+"/api/networks/skynet/keys", "badkey")
- assert.Nil(t, err, err)
- assert.Equal(t, http.StatusUnauthorized, response.StatusCode)
- defer response.Body.Close()
- var message models.ErrorResponse
- err = json.NewDecoder(response.Body).Decode(&message)
- assert.Nil(t, err, err)
- assert.Equal(t, http.StatusUnauthorized, message.Code)
- assert.Contains(t, message.Message, "rror verifying user toke")
- })
- }
- func TestUpdateNetwork(t *testing.T) {
- //ensure we are working with known networks
- deleteNetworks(t)
- createNetwork(t)
- var returnedNetwork models.Network
- t.Run("UpdateNetID", func(t *testing.T) {
- type Network struct {
- NetID string
- }
- var network Network
- network.NetID = "wirecat"
- response, err := api(t, network, http.MethodPut, baseURL+"/api/networks/skynet", "secretkey")
- assert.Nil(t, err, err)
- assert.Equal(t, http.StatusBadRequest, response.StatusCode)
- defer response.Body.Close()
- var message models.ErrorResponse
- err = json.NewDecoder(response.Body).Decode(&message)
- assert.Nil(t, err, err)
- assert.Equal(t, http.StatusBadRequest, message.Code)
- assert.Equal(t, "NetID is not editable", message.Message)
- })
- t.Run("Invalidnetwork", func(t *testing.T) {
- type Network struct {
- NetID string
- }
- var network Network
- network.NetID = "wirecat"
- response, err := api(t, network, http.MethodPut, baseURL+"/api/networks/badnetwork", "secretkey")
- assert.Nil(t, err, err)
- defer response.Body.Close()
- var message models.ErrorResponse
- err = json.NewDecoder(response.Body).Decode(&message)
- assert.Nil(t, err, err)
- assert.Equal(t, http.StatusNotFound, message.Code)
- assert.Contains(t, message.Message, "his network does not exist")
- assert.Equal(t, http.StatusNotFound, response.StatusCode)
- })
- t.Run("UpdateAddress", func(t *testing.T) {
- type Network struct {
- AddressRange string
- }
- var network Network
- network.AddressRange = "10.0.0.1/24"
- response, err := api(t, network, http.MethodPut, baseURL+"/api/networks/skynet", "secretkey")
- assert.Nil(t, err, err)
- assert.Equal(t, http.StatusOK, response.StatusCode)
- defer response.Body.Close()
- err = json.NewDecoder(response.Body).Decode(&returnedNetwork)
- assert.Nil(t, err, err)
- assert.Equal(t, network.AddressRange, returnedNetwork.AddressRange)
- })
- t.Run("UpdateAddressInvalid", func(t *testing.T) {
- type Network struct {
- AddressRange string
- }
- var network Network
- network.AddressRange = "10.0.0.1/36"
- response, err := api(t, network, http.MethodPut, baseURL+"/api/networks/skynet", "secretkey")
- assert.Nil(t, err, err)
- assert.Equal(t, http.StatusBadRequest, response.StatusCode)
- defer response.Body.Close()
- var message models.ErrorResponse
- err = json.NewDecoder(response.Body).Decode(&message)
- assert.Nil(t, err, err)
- assert.Equal(t, http.StatusBadRequest, message.Code)
- assert.Contains(t, message.Message, "validation for 'AddressRange' failed")
- })
- t.Run("UpdateDisplayName", func(t *testing.T) {
- type Network struct {
- DisplayName string
- }
- var network Network
- network.DisplayName = "wirecat"
- response, err := api(t, network, http.MethodPut, baseURL+"/api/networks/skynet", "secretkey")
- assert.Nil(t, err, err)
- assert.Equal(t, http.StatusOK, response.StatusCode)
- defer response.Body.Close()
- err = json.NewDecoder(response.Body).Decode(&returnedNetwork)
- assert.Nil(t, err, err)
- assert.Equal(t, network.DisplayName, returnedNetwork.DisplayName)
- })
- t.Run("UpdateDisplayNameInvalidName", func(t *testing.T) {
- type Network struct {
- DisplayName string
- }
- var network Network
- //create name that is longer than 100 chars
- name := ""
- for i := 0; i < 101; i++ {
- name = name + "a"
- }
- network.DisplayName = name
- response, err := api(t, network, http.MethodPut, baseURL+"/api/networks/skynet", "secretkey")
- assert.Nil(t, err, err)
- assert.Equal(t, http.StatusBadRequest, response.StatusCode)
- var message models.ErrorResponse
- err = json.NewDecoder(response.Body).Decode(&message)
- assert.Nil(t, err, err)
- assert.Equal(t, http.StatusBadRequest, message.Code)
- assert.Contains(t, message.Message, "Field validation for 'DisplayName' failed")
- })
- t.Run("UpdateInterface", func(t *testing.T) {
- type Network struct {
- DefaultInterface string
- }
- var network Network
- network.DefaultInterface = "netmaker"
- response, err := api(t, network, http.MethodPut, baseURL+"/api/networks/skynet", "secretkey")
- assert.Nil(t, err, err)
- assert.Equal(t, http.StatusOK, response.StatusCode)
- defer response.Body.Close()
- err = json.NewDecoder(response.Body).Decode(&returnedNetwork)
- assert.Nil(t, err, err)
- assert.Equal(t, network.DefaultInterface, returnedNetwork.DefaultInterface)
- })
- t.Run("UpdateListenPort", func(t *testing.T) {
- type Network struct {
- DefaultListenPort int32
- }
- var network Network
- network.DefaultListenPort = 6000
- response, err := api(t, network, http.MethodPut, baseURL+"/api/networks/skynet", "secretkey")
- assert.Nil(t, err, err)
- assert.Equal(t, http.StatusOK, response.StatusCode)
- defer response.Body.Close()
- err = json.NewDecoder(response.Body).Decode(&returnedNetwork)
- assert.Nil(t, err, err)
- assert.Equal(t, network.DefaultListenPort, returnedNetwork.DefaultListenPort)
- })
- t.Run("UpdateListenPortInvalidPort", func(t *testing.T) {
- type Network struct {
- DefaultListenPort int32
- }
- var network Network
- network.DefaultListenPort = 65540
- response, err := api(t, network, http.MethodPut, baseURL+"/api/networks/skynet", "secretkey")
- assert.Nil(t, err, err)
- var message models.ErrorResponse
- err = json.NewDecoder(response.Body).Decode(&message)
- assert.Nil(t, err, err)
- assert.Equal(t, http.StatusBadRequest, message.Code)
- assert.Contains(t, message.Message, "Field validation for 'DefaultListenPort' failed")
- assert.Equal(t, http.StatusBadRequest, response.StatusCode)
- })
- t.Run("UpdatePostUP", func(t *testing.T) {
- type Network struct {
- DefaultPostUp string
- }
- var network Network
- network.DefaultPostUp = "sudo wg add-conf wc-netmaker /etc/wireguard/peers/conf"
- response, err := api(t, network, http.MethodPut, baseURL+"/api/networks/skynet", "secretkey")
- assert.Nil(t, err, err)
- assert.Equal(t, http.StatusOK, response.StatusCode)
- defer response.Body.Close()
- err = json.NewDecoder(response.Body).Decode(&returnedNetwork)
- assert.Nil(t, err, err)
- assert.Equal(t, network.DefaultPostUp, returnedNetwork.DefaultPostUp)
- })
- t.Run("UpdatePostDown", func(t *testing.T) {
- type Network struct {
- DefaultPostDown string
- }
- var network Network
- network.DefaultPostDown = "test string"
- response, err := api(t, network, http.MethodPut, baseURL+"/api/networks/skynet", "secretkey")
- assert.Nil(t, err, err)
- assert.Equal(t, http.StatusOK, response.StatusCode)
- defer response.Body.Close()
- err = json.NewDecoder(response.Body).Decode(&returnedNetwork)
- assert.Nil(t, err, err)
- assert.Equal(t, network.DefaultPostDown, returnedNetwork.DefaultPostDown)
- })
- t.Run("UpdateKeepAlive", func(t *testing.T) {
- type Network struct {
- DefaultKeepalive int32
- }
- var network Network
- network.DefaultKeepalive = 60
- response, err := api(t, network, http.MethodPut, baseURL+"/api/networks/skynet", "secretkey")
- assert.Nil(t, err, err)
- assert.Equal(t, http.StatusOK, response.StatusCode)
- defer response.Body.Close()
- err = json.NewDecoder(response.Body).Decode(&returnedNetwork)
- assert.Nil(t, err, err)
- assert.Equal(t, network.DefaultKeepalive, returnedNetwork.DefaultKeepalive)
- })
- t.Run("UpdateKeepAliveTooBig", func(t *testing.T) {
- //does not fails ----- value gets updated.
- // ----- needs fixing -----
- //t.Skip()
- type Network struct {
- DefaultKeepAlive int32
- }
- var network Network
- network.DefaultKeepAlive = 2000
- response, err := api(t, network, http.MethodPut, baseURL+"/api/networks/skynet", "secretkey")
- assert.Nil(t, err, err)
- var message models.ErrorResponse
- err = json.NewDecoder(response.Body).Decode(&message)
- assert.Nil(t, err, err)
- assert.Equal(t, http.StatusBadRequest, message.Code)
- assert.Contains(t, message.Message, "Field validation for 'DefaultKeepalive' failed on the 'max' tag")
- assert.Equal(t, http.StatusBadRequest, response.StatusCode)
- })
- t.Run("UpdateSaveConfig", func(t *testing.T) {
- //t.Skip()
- //not updatable, ensure attempt to change does not result in change
- type Network struct {
- DefaultSaveConfig *bool
- }
- var network Network
- var value bool
- oldnet := getNetwork(t, "skynet")
- if *oldnet.DefaultSaveConfig == true {
- value = false
- } else {
- value = true
- }
- network.DefaultSaveConfig = &value
- response, err := api(t, network, http.MethodPut, baseURL+"/api/networks/skynet", "secretkey")
- assert.Nil(t, err, err)
- assert.Equal(t, http.StatusOK, response.StatusCode)
- newnet := getNetwork(t, "skynet")
- assert.Equal(t, oldnet.DefaultSaveConfig, newnet.DefaultSaveConfig)
- })
- t.Run("UpdateManualSignUP", func(t *testing.T) {
- type Network struct {
- AllowManualSignUp *bool
- }
- var network Network
- value := true
- network.AllowManualSignUp = &value
- response, err := api(t, network, http.MethodPut, baseURL+"/api/networks/skynet", "secretkey")
- assert.Nil(t, err, err)
- assert.Equal(t, http.StatusOK, response.StatusCode)
- defer response.Body.Close()
- err = json.NewDecoder(response.Body).Decode(&returnedNetwork)
- assert.Nil(t, err, err)
- assert.Equal(t, network.AllowManualSignUp, returnedNetwork.AllowManualSignUp)
- })
- t.Run("DefaultCheckInterval", func(t *testing.T) {
- type Network struct {
- CheckInInterval int32
- }
- var network Network
- network.CheckInInterval = 60
- response, err := api(t, network, http.MethodPut, baseURL+"/api/networks/skynet", "secretkey")
- assert.Nil(t, err, err)
- assert.Equal(t, http.StatusOK, response.StatusCode)
- defer response.Body.Close()
- err = json.NewDecoder(response.Body).Decode(&returnedNetwork)
- assert.Nil(t, err, err)
- assert.Equal(t, network.CheckInInterval, returnedNetwork.DefaultCheckInInterval)
- })
- t.Run("DefaultCheckIntervalTooBig", func(t *testing.T) {
- type Network struct {
- CheckInInterval int32
- }
- var network Network
- network.CheckInInterval = 100001
- response, err := api(t, network, http.MethodPut, baseURL+"/api/networks/skynet", "secretkey")
- assert.Nil(t, err, err)
- var message models.ErrorResponse
- err = json.NewDecoder(response.Body).Decode(&message)
- assert.Nil(t, err, err)
- assert.Equal(t, http.StatusBadRequest, message.Code)
- assert.Contains(t, message.Message, "Field validation for 'DefaultCheckInInterval' failed")
- assert.Equal(t, http.StatusBadRequest, response.StatusCode)
- })
- t.Run("MultipleFields", func(t *testing.T) {
- type Network struct {
- DisplayName string
- DefaultListenPort int32
- }
- var network Network
- network.DefaultListenPort = 7777
- network.DisplayName = "multi"
- response, err := api(t, network, http.MethodPut, baseURL+"/api/networks/skynet", "secretkey")
- assert.Nil(t, err, err)
- assert.Equal(t, http.StatusOK, response.StatusCode)
- defer response.Body.Close()
- err = json.NewDecoder(response.Body).Decode(&returnedNetwork)
- assert.Nil(t, err, err)
- assert.Equal(t, network.DisplayName, returnedNetwork.DisplayName)
- assert.Equal(t, network.DefaultListenPort, returnedNetwork.DefaultListenPort)
- })
- }
- func TestKeyUpdate(t *testing.T) {
- //get current network settings
- oldnet := getNetwork(t, "skynet")
- //update key
- time.Sleep(time.Second * 1)
- reply, err := api(t, "", http.MethodPost, baseURL+"/api/networks/skynet/keyupdate", "secretkey")
- assert.Nil(t, err, err)
- assert.Equal(t, http.StatusOK, reply.StatusCode)
- newnet := getNetwork(t, "skynet")
- assert.Greater(t, newnet.KeyUpdateTimeStamp, oldnet.KeyUpdateTimeStamp)
- }
|