feat: debug e2e failing

Author: lacroixthomas

cmd/processor/handler.go

@@ -239,12 +239,29 @@ func (h *processorHandler) processAllocation(req *allocationpb.AllocationRequest
 
 	resultObj, err := h.allocator.Allocate(h.ctx, gsa)
 	if err != nil {
-		return allocationResult{
-			error: &rpcstatus.Status{
-				Code:    int32(codes.Internal),
-				Message: fmt.Sprintf("Allocator error: %v", err),
+		unallocated := &allocationv1.GameServerAllocation{
+			Spec: gsa.Spec,
+			Status: allocationv1.GameServerAllocationStatus{
+				State: allocationv1.GameServerAllocationUnAllocated,
 			},
 		}
+		response, convErr := converters.ConvertGSAToAllocationResponse(unallocated, h.grpcUnallocatedStatusCode)
+		if convErr != nil {
+			grpcStatus, ok := status.FromError(convErr)
+			code := h.grpcUnallocatedStatusCode
+			msg := convErr.Error()
+			if ok {
+				code = grpcStatus.Code()
+				msg = grpcStatus.Message()
+			}
+			return allocationResult{
+				error: &rpcstatus.Status{
+					Code:    int32(code),
+					Message: msg,
+				},
+			}
+		}
+		return allocationResult{response: response}
 	}
 
 	if s, ok := resultObj.(*metav1.Status); ok {

pkg/sdkserver/sdkserver.go

@@ -1213,7 +1213,7 @@ func (s *SDKServer) RemoveListValue(ctx context.Context, in *beta.RemoveListValu
 
 	// Track this removal for batch persistence to K8s
 	batchList := s.gsListUpdates[in.Name]
-	
+
 	removedFromBatch := false
 	if len(batchList.valuesToAppend) > 0 {
 		newAppend := make([]string, 0, len(batchList.valuesToAppend))