Function UploadNodeState

cmd/priv-dashboard/test/main.go:144–185

(url string)

}

func UploadNodeState(url string) {
	helloUrl := fmt.Sprintf("%s/hello", url)
	stateUrl := fmt.Sprintf("%s/reportstate", url)
	states := make([]IState, 0)

	for i := 0; i < TotalPeer; i++ {
		s := generateState()
		states = append(states, s)
		_, err := sendMessage(helloUrl, s.ID())
		if err != nil {
			log.Warn("Send message to resp", "err", err.Error())
			return
		}
	}

	sendStates := func() {
		for _, s := range states {
			s.Update()
			data, err := s.Serialize()
			if err != nil {
				log.Info("Fail to Marshal node state", "error", err.Error())
				continue
			}
			res, err := sendMessage(stateUrl, data)
			if err != nil {
				log.Info("Fail to upload node state", "id", s.ID(), "error", err.Error())
			} else {
				log.Info("get response", "Serialize data", data, "response", res)
			}
		}
	}

	sendStates()
	ticker := time.NewTicker(1 * time.Minute)
	defer ticker.Stop()
	for {
		select {
		case <-ticker.C:
			sendStates()
		}
	}
}

func generateState() IState {
	privateKey, _ := ecdsa.GenerateKey(crypto.S256(), crand.Reader)