pretty print event logs and linter

client.go

@@ -168,9 +168,8 @@ func (hc *HeliumClient) Register(ctx context.Context) (upstream *coordinator.Cha
 			}
 
 			ev := api.ToNodeEvent(apiEvent)
-			log.Printf("[client] received event: %s", ev)
 			eventsStream <- ev
-			log.Printf("[client] fwd event: %s", ev)
+			log.Printf("[client] new event: %s", ev)
 		}
 	}()
 

node/coordinator.go

@@ -22,6 +22,21 @@ func (ev Event) IsSetup() bool {
 	return ev.SetupEvent != nil
 }
 
+func (ev Event) String() string {
+	switch {
+	case ev.SetupEvent != nil:
+		return fmt.Sprintf("SETUP PROTOCOL %s", ev.SetupEvent.String())
+	case ev.ComputeEvent != nil:
+		switch {
+		case ev.ComputeEvent.CircuitEvent != nil:
+			return fmt.Sprintf("COMPUTE CIRCUIT %s", ev.ComputeEvent.CircuitEvent.String())
+		case ev.ComputeEvent.ProtocolEvent != nil:
+			return fmt.Sprintf("COMPUTE PROTOCOL %s", ev.ComputeEvent.ProtocolEvent.String())
+		}
+	}
+	return "INVALID	EVENT"
+}
+
 type Coordinator coordinator.Coordinator[Event]
 
 type setupCoordinator struct {

node/node.go

@@ -375,12 +375,12 @@ func (node *Node) createNewSession(sessParams sessions.Parameters) (sess *sessio
 	return sess, nil
 }
 
-func (s *Node) PutOperand(opl circuits.OperandLabel, op *circuits.Operand) error {
-	return s.compute.PutOperand(opl, op)
+func (node *Node) PutOperand(opl circuits.OperandLabel, op *circuits.Operand) error {
+	return node.compute.PutOperand(opl, op)
 }
 
-func (s *Node) GetOperand(opl circuits.OperandLabel) (*circuits.Operand, bool) {
-	return s.compute.GetOperand(opl)
+func (node *Node) GetOperand(opl circuits.OperandLabel) (*circuits.Operand, bool) {
+	return node.compute.GetOperand(opl)
 }
 
 // func (node *Node) sendShares(ctx context.Context) {

server.go

@@ -351,12 +351,12 @@ func (hsv *HeliumServer) PutCiphertext(inctx context.Context, apict *pb.Cipherte
 	return &pb.CiphertextID{CiphertextId: string(ct.ID)}, nil
 }
 
-func (s *HeliumServer) PutOperand(opl circuits.OperandLabel, op *circuits.Operand) error {
-	return s.helperNode.PutOperand(opl, op)
+func (hsv *HeliumServer) PutOperand(opl circuits.OperandLabel, op *circuits.Operand) error {
+	return hsv.helperNode.PutOperand(opl, op)
 }
 
-func (s *HeliumServer) GetOperand(opl circuits.OperandLabel) (*circuits.Operand, bool) {
-	return s.helperNode.GetOperand(opl)
+func (hsv *HeliumServer) GetOperand(opl circuits.OperandLabel) (*circuits.Operand, bool) {
+	return hsv.helperNode.GetOperand(opl)
 }
 
 func (hsv *HeliumServer) Logf(msg string, v ...any) {

services/compute/service.go

@@ -532,7 +532,7 @@ func (s *Service) sendCompletedPdToCircuit(pd protocols.Descriptor) error {
 	c, has := s.runningCircuits[cid]
 	s.runningCircuitsMu.RUnlock()
 	if !has {
-		panic(fmt.Errorf("circuit is not runnig: %s", cid))
+		panic(fmt.Errorf("circuit is not running: %s", cid))
 	}
 
 	return c.CompletedProtocol(pd)