Method resolveTaskPeerContext

internal/network/tasks.go:345–389

(
	ctx context.Context,
	ingress TaskIngressContext,
	action string,
)

}

func (m *Manager) resolveTaskPeerContext(
	ctx context.Context,
	ingress TaskIngressContext,
	action string,
) (resolvedTaskPeerContext, error) {
	if ctx == nil {
		return resolvedTaskPeerContext{}, errors.New("network: task ingress context is required")
	}
	if m == nil {
		return resolvedTaskPeerContext{}, errors.New("network: manager is required")
	}
	if err := ingress.Validate(); err != nil {
		return resolvedTaskPeerContext{}, err
	}
	if m.tasks == nil {
		return resolvedTaskPeerContext{}, m.rejectTaskIngress(ctx, ingress, action, ErrTaskIngressUnavailable, nil)
	}
	if m.peers == nil {
		return resolvedTaskPeerContext{}, m.rejectTaskIngress(ctx, ingress, action, ErrTaskIngressPeerNotFound, nil)
	}
	ingress.WorkspaceID = strings.TrimSpace(ingress.WorkspaceID)
	ingress.Channel = strings.TrimSpace(ingress.Channel)
	ingress.PeerID = strings.TrimSpace(ingress.PeerID)

	peer, ok := m.peers.RemoteByPeer(ingress.WorkspaceID, ingress.Channel, ingress.PeerID, m.now().UTC())
	if !ok {
		return resolvedTaskPeerContext{}, m.rejectTaskIngress(ctx, ingress, action, ErrTaskIngressPeerNotFound, nil)
	}
	if !containsString(peer.PeerCard.Capabilities, networkTaskWriteCapability) {
		return resolvedTaskPeerContext{}, m.rejectTaskIngress(ctx, ingress, action, ErrTaskIngressCapabilityDenied, nil)
	}

	actor, err := taskpkg.DeriveNetworkPeerActorContext(
		strings.TrimSpace(ingress.PeerID),
		networkTaskOriginRef(ingress),
	)
	if err != nil {
		return resolvedTaskPeerContext{}, m.rejectTaskIngress(ctx, ingress, action, err, nil)
	}
	return resolvedTaskPeerContext{
		ingress: ingress,
		peer:    peer,
		actor:   actor,
	}, nil
}

func (m *Manager) rejectTaskIngress(
	ctx context.Context,