Function enforceBoundTaskChannel

internal/network/tasks.go:463–494

(
	taskID string,
	boundChannel string,
	ingressChannel string,
	patch *taskpkg.Patch,
)

}

func enforceBoundTaskChannel(
	taskID string,
	boundChannel string,
	ingressChannel string,
	patch *taskpkg.Patch,
) error {
	trimmedBound := strings.TrimSpace(boundChannel)
	if trimmedBound == "" {
		return nil
	}
	if err := ValidateChannel(trimmedBound); err != nil {
		if patch != nil && patchAllowsStaleChannelRepair(strings.TrimSpace(ingressChannel), *patch) {
			return nil
		}
		return fmt.Errorf(
			"%w: task %q channel %q no longer validates",
			ErrTaskChannelStale,
			strings.TrimSpace(taskID),
			trimmedBound,
		)
	}
	if trimmedBound != strings.TrimSpace(ingressChannel) {
		return fmt.Errorf(
			"%w: task %q channel %q does not match ingress channel %q",
			ErrTaskChannelMismatch,
			strings.TrimSpace(taskID),
			trimmedBound,
			strings.TrimSpace(ingressChannel),
		)
	}
	return nil
}

func patchAllowsStaleChannelRepair(ingressChannel string, patch taskpkg.Patch) bool {
	if patch.NetworkChannel == nil {