Browse Source

create gateways durring migration

Matthew R Kasun 2 years ago
parent
commit
a1f0315847
1 changed files with 21 additions and 1 deletions
  1. 21 1
      controllers/migrate.go

+ 21 - 1
controllers/migrate.go

@@ -74,8 +74,28 @@ func migrate(w http.ResponseWriter, r *http.Request) {
 	}
 	r.Body = io.NopCloser(strings.NewReader(string(payload)))
 	r.ContentLength = int64(len(string(payload)))
-	createNode(w, r)
 	if err := database.DeleteRecord(database.NODES_TABLE_NAME, data.LegacyNodeID); err != nil {
 		logger.Log(0, "error deleting legacy node", legacyNode.Name, err.Error())
 	}
+	createNode(w, r)
+	//newly created node has same node id as legacy node allowing using legacyNode.ID in gateway creation
+	if legacyNode.IsIngressGateway == "yes" {
+		if _, err := logic.CreateIngressGateway(legacyNode.Network, legacyNode.ID, false); err != nil {
+			logger.Log(0, "error creating ingress gateway during migration", err.Error())
+		}
+	}
+	if legacyNode.IsEgressGateway == "yes" {
+		if _, err := logic.CreateEgressGateway(legacyNode.EgressGatewayRequest); err != nil {
+			logger.Log(0, "error creating egress gateway during migration", err.Error())
+		}
+	}
+	if legacyNode.IsRelay == "yes" {
+		if _, _, err := logic.CreateRelay(models.RelayRequest{
+			NodeID:     legacyNode.ID,
+			NetID:      legacyNode.Network,
+			RelayAddrs: legacyNode.RelayAddrs,
+		}); err != nil {
+			logger.Log(0, "error creating relay during migration", err.Error())
+		}
+	}
 }