| 1470 | } |
| 1471 | |
| 1472 | func pluginProtocolTestOutcome( |
| 1473 | info *relaycommon.RelayInfo, |
| 1474 | pluginKey string, |
| 1475 | taskID string, |
| 1476 | _ ...any, |
| 1477 | ) *taskSubmissionOutcome { |
| 1478 | return &taskSubmissionOutcome{ |
| 1479 | Result: &relay.TaskSubmitResult{}, |
| 1480 | Task: &model.Task{ |
| 1481 | TaskID: taskID, |
| 1482 | Platform: constant.TaskPlatform(pluginKey), |
| 1483 | UserId: info.UserId, |
| 1484 | Status: model.TaskStatusSubmitted, |
| 1485 | CreatedAt: 1_710_000_000, |
| 1486 | }, |
| 1487 | RelayInfo: info, |
| 1488 | } |
| 1489 | } |
| 1490 | |
| 1491 | func pluginProtocolTestSSEEventTypes(body string) []string { |
| 1492 | lines := strings.Split(body, "\n") |