( c *gin.Context, machine *relay.PluginResponsesMachine, taskStatus string, )
| 1102 | } |
| 1103 | |
| 1104 | func writeTaskPluginProtocolFailureResponse( |
| 1105 | c *gin.Context, |
| 1106 | machine *relay.PluginResponsesMachine, |
| 1107 | taskStatus string, |
| 1108 | ) { |
| 1109 | if taskStatus == string(model.TaskStatusFailure) { |
| 1110 | response, err := machine.FinalResponse(nil, taskStatus) |
| 1111 | if err != nil { |
| 1112 | logger.LogError(c, "task protocol terminal failure response failed: "+err.Error()) |
| 1113 | respondPluginProtocolError(c, http.StatusInternalServerError, "task_protocol_error", "Task protocol request failed") |
| 1114 | return |
| 1115 | } |
| 1116 | c.JSON(http.StatusOK, response) |
| 1117 | return |
| 1118 | } |
| 1119 | response, err := machine.FailureResponse(taskStatus) |
| 1120 | if err != nil { |
| 1121 | logger.LogError(c, "task protocol failure response failed: "+err.Error()) |
| 1122 | respondPluginProtocolError(c, http.StatusInternalServerError, "task_protocol_error", "Task protocol request failed") |
| 1123 | return |
| 1124 | } |
| 1125 | c.JSON(http.StatusOK, response) |
| 1126 | } |
| 1127 | |
| 1128 | func writeTaskPluginProtocolTimeoutResponse( |
| 1129 | c *gin.Context, |
no test coverage detected