Draft: Akms ckms api implementation

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))
 	}