Skip to content
Snippets Groups Projects
Commit bac36979 authored by Malte Bauch's avatar Malte Bauch
Browse files

Send kmsinfo earlier

parent d5d94569
No related branches found
No related tags found
No related merge requests found
......@@ -145,10 +145,6 @@ func (es *etsiServer) ETSISendPayload(ctx context.Context, in *pb.ETSISendPayloa
return nil, status.Errorf(codes.Internal, "No route found for path id: %s", in.GetPathId())
}
if err := route.Next.SendPayload([]byte(in.GetPayload()), pathId); err != nil {
return nil, status.Errorf(codes.Internal, "Failed to send payload: ", err)
}
// NOTE: For demo purpose only
json, err := json.Marshal(KMSInfo{
Name: es.handlingEkms.kmsName,
......@@ -164,6 +160,10 @@ func (es *etsiServer) ETSISendPayload(ctx context.Context, in *pb.ETSISendPayloa
log.Println("Failed to send KMS info message: ", err)
}
if err := route.Next.SendPayload([]byte(in.GetPayload()), pathId); err != nil {
return nil, status.Errorf(codes.Internal, "Failed to send payload: ", err)
}
return &pb.ETSISendPayloadResponse{
Timestamp: time.Now().Unix(),
}, nil
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment