(ingressChannel string, requestedChannel string)
| 442 | } |
| 443 | |
| 444 | func validateRequestedTaskChannel(ingressChannel string, requestedChannel string) error { |
| 445 | trimmed := strings.TrimSpace(requestedChannel) |
| 446 | if trimmed == "" { |
| 447 | return nil |
| 448 | } |
| 449 | if err := ValidateChannel(trimmed); err != nil { |
| 450 | return err |
| 451 | } |
| 452 | if trimmed != strings.TrimSpace(ingressChannel) { |
| 453 | return fmt.Errorf( |
| 454 | "%w: requested channel %q does not match ingress channel %q", |
| 455 | ErrTaskChannelMismatch, |
| 456 | trimmed, |
| 457 | strings.TrimSpace(ingressChannel), |
| 458 | ) |
| 459 | } |
| 460 | return nil |
| 461 | } |
| 462 | |
| 463 | func enforceBoundTaskChannel( |
| 464 | taskID string, |
no test coverage detected