|
@@ -13,12 +13,13 @@ import (
|
|
|
// CreateRelay - creates a relay
|
|
|
func CreateRelay(relay models.RelayRequest) (models.Node, error) {
|
|
|
node, err := GetNodeByID(relay.NodeID)
|
|
|
- if node.OS == "macos" { // add in darwin later
|
|
|
- return models.Node{}, errors.New(node.OS + " is unsupported for relay")
|
|
|
- }
|
|
|
if err != nil {
|
|
|
return models.Node{}, err
|
|
|
}
|
|
|
+ if node.OS == "macos" { // add in darwin later
|
|
|
+ return models.Node{}, errors.New(node.OS + " is unsupported for relay")
|
|
|
+ }
|
|
|
+
|
|
|
err = ValidateRelay(relay)
|
|
|
if err != nil {
|
|
|
return models.Node{}, err
|
|
@@ -26,17 +27,13 @@ func CreateRelay(relay models.RelayRequest) (models.Node, error) {
|
|
|
node.IsRelay = "yes"
|
|
|
node.RelayAddrs = relay.RelayAddrs
|
|
|
|
|
|
- key, err := GetRecordKey(relay.NodeID, relay.NetID)
|
|
|
- if err != nil {
|
|
|
- return node, err
|
|
|
- }
|
|
|
node.SetLastModified()
|
|
|
node.PullChanges = "yes"
|
|
|
nodeData, err := json.Marshal(&node)
|
|
|
if err != nil {
|
|
|
return node, err
|
|
|
}
|
|
|
- if err = database.Insert(key, string(nodeData), database.NODES_TABLE_NAME); err != nil {
|
|
|
+ if err = database.Insert(node.ID, string(nodeData), database.NODES_TABLE_NAME); err != nil {
|
|
|
return models.Node{}, err
|
|
|
}
|
|
|
err = SetRelayedNodes("yes", node.Network, node.RelayAddrs)
|