Method recordTaskIngress

internal/network/tasks.go:405–442

(
	ctx context.Context,
	ingress TaskIngressContext,
	action string,
	direction string,
	reason string,
	payload any,
)

}

func (m *Manager) recordTaskIngress(
	ctx context.Context,
	ingress TaskIngressContext,
	action string,
	direction string,
	reason string,
	payload any,
) {
	if m == nil || m.auditor == nil {
		return
	}
	writer, ok := m.auditor.(TaskIngressAuditWriter)
	if !ok {
		return
	}
	if err := writer.RecordTaskIngress(ctx, TaskIngressAudit{
		WorkspaceID: strings.TrimSpace(ingress.WorkspaceID),
		Action:      strings.TrimSpace(action),
		Direction:   strings.TrimSpace(direction),
		PeerID:      strings.TrimSpace(ingress.PeerID),
		Channel:     strings.TrimSpace(ingress.Channel),
		RequestID:   strings.TrimSpace(ingress.RequestID),
		Reason:      strings.TrimSpace(reason),
		Payload:     payload,
	}); err != nil {
		m.logger.Warn(
			"network.audit.record_task_ingress_failed",
			"action",
			action,
			"peer_id",
			ingress.PeerID,
			"request_id",
			ingress.RequestID,
			"error",
			err,
		)
	}
}

func validateRequestedTaskChannel(ingressChannel string, requestedChannel string) error {
	trimmed := strings.TrimSpace(requestedChannel)