main.go

package main

import (
	"fabric-edgenode/NodeUtils"
	"fabric-edgenode/clients"
	"fabric-edgenode/models"
	"log"
	"os"

	"github.com/gin-gonic/gin"
)

var peertopics = []string{"register", "upload", "filereq", "KeyUpload", "ReceiveKeyUpload", "ReceiveKeyReq", "DataForwarding", "ReceiveFileRequestFromCenter"}

func main() {
	var nodeinfo = models.NodeInfo{
		KafkaAddr:    os.Getenv("KAFKA_IP"),
		PeerNodeName: os.Getenv("PEER_NODE_NAME"),
		NodeName:     os.Getenv("SERVICE_NODE_HOST"),
		LeftStorage:  os.Getenv("LEFT_STORAGE"),
		LocationX:    os.Getenv("LOCATION_X"),
		LocationY:    os.Getenv("LOCATION_Y"),
	}
	var node = NodeUtils.Nodestructure{
		KafkaIp:       os.Getenv("KAFKA_IP"),
		ZookeeperAddr: os.Getenv("ZOOKEEPER_ADDR"),
		Couchdb_addr:  os.Getenv("COUCHDB_ADDR"),
		PeerNodeName:  os.Getenv("PEER_NODE_NAME"),
		OrgID:         os.Getenv("ORG_ID"),
		KeyPath:       os.Getenv("KEY_PATH"),
		CenterAddr:    os.Getenv("CENTER_ADDR"),
		ConfigPath:    "/conf/config.yaml",
		NodeInfo:      &nodeinfo,
	}
	log.Println("nodeinfo:", nodeinfo)
	log.Println("node:", node)
	// var node = NodeUtils.Nodestructure{
	// 	KafkaIp:      "0.0.0.0:9092",
	// 	Couchdb_addr: "http://admin:123456@couchdb0:5984",
	// 	PeerNodeName: "peer0.org1.example.com:7051",
	// 	OrgID:        "1",
	// 	KeyPath:      "./fixtures/crypto-config/peerOrganizations/org1.example.com/peers/peer0.org1.example.com/msp/keystore/priv_sk",
	// 	CenterAddr:   "0.0.0.0:9091",
	// 	ConfigPath:   "./cfg/org1conf.yaml",
	// }

	//init node
	node.InitPeerNode(peertopics)
	defer clients.FabricClose()
	//start websocket
	go NodeUtils.InitWebsocket()

	//gin router
	r := gin.Default()
	r.POST("/register", NodeUtils.Register) //http://10.0.0.144:8083/register
	r.POST("/upload", NodeUtils.Upload)     //http://10.0.0.144:8083/upload
	r.GET("/load", NodeUtils.GetNodeLoad)
	r.Run("0.0.0.0:8083") // 0.0.0.0:8083
}