Linter pleasing

ekms/internal/kms/kmsintercom.go

@@ -61,7 +61,11 @@ func (s *kmsTalkerServer) KeyIdNotification(ctx context.Context, in *pb.KeyIdNot
 		return nil, err
 	}
 
-	defer resp.Body.Close()
+	defer func() {
+		if closeError := resp.Body.Close(); closeError != nil {
+			log.Errorf("KeyIdNotification: response closing failure: %s", err)
+		}
+	}()
 
 	// TODO: add proper status code handling
 	if resp.StatusCode != 200 {
@@ -226,8 +230,12 @@ func (s *kmsTalkerServer) KeyForwarding(ctx context.Context, in *pb.KeyForwardin
 	log.Infof("%s received a payload: %s, from %s", s.eKMS.kmsName, decryptedPayload, route.Previous.tcpSocketStr)
 
 	if route.Next != nil {
-		log.Infof("%s forwards payload to : %s", s.eKMS.kmsName, route.Next.tcpSocketStr)
-		go route.Next.SendPayload(decryptedPayload, pathId)
+		log.Infof("%s is trying to forward payload to : %s", s.eKMS.kmsName, route.Next.tcpSocketStr)
+		err := route.Next.SendPayload(decryptedPayload, pathId)
+		if err != nil {
+			return nil, status.Errorf(codes.Internal, "%s", err)
+		}
+		log.Infof("%s forwarded the payload to : %s successfully", s.eKMS.kmsName, route.Next.tcpSocketStr)
 	} else {
 		log.Infof("%s received the final payload: %s", s.eKMS.kmsName, string(decryptedPayload))
 	}

ekms/restserver/restserver.go

@@ -22,7 +22,8 @@ func SetupETSI14RestServer(etsi14RESTService *ETSI14RESTService) {
 	etsi14APIController := restserver.NewDefaultAPIController(etsi14RESTService)
 
 	router := restserver.NewRouter(etsi14APIController)
-	go http.ListenAndServe(etsi14RESTService.serviceAddress, router)
+	// NOTE check again, currently ignoring
+	go http.ListenAndServe(etsi14RESTService.serviceAddress, router) //nolint:errcheck
 	logrus.Info("Server started")
 }
 

quantumlayer/example/main.go

@@ -52,7 +52,7 @@ func main() {
 		return
 	}
 
-	stopChan := make(chan os.Signal)
+	stopChan := make(chan os.Signal, 1)
 	signal.Notify(stopChan, os.Interrupt, syscall.SIGTERM)
 
 	ql := quantumlayer.NewQuantumlayerEmuPRNG(kmsClient, os.Stdout, logrus.GetLevel(), false)

quantumlayer/quantumlayer-emu-prng.go

@@ -134,7 +134,11 @@ func (qlemuprng *QuantumlayerEmuPRNG) PowerOn() {
 				log.Fatalf("QuantumlayerEmuPRNG: UDP failure: %s", err)
 				return
 			}
-			defer qlemuprng.udpSrvConn.Close()
+			defer func() {
+				if closeError := qlemuprng.udpSrvConn.Close(); closeError != nil {
+					log.Errorf("QuantumlayerEmuPRNG: udpSrvConn closing failure: %s", err)
+				}
+			}()
 
 			// Retrieve local UDP address and store it for further actions.
 			tempPort, ok := qlemuprng.udpSrvConn.LocalAddr().(*net.UDPAddr)