Method CreateTaskFromPeer

internal/network/tasks.go:173–199

CreateTaskFromPeer creates one task on behalf of an authenticated network peer after channel and capability validation succeed.

(
	ctx context.Context,
	ingress TaskIngressContext,
	spec taskpkg.CreateTask,
)

// CreateTaskFromPeer creates one task on behalf of an authenticated network
// peer after channel and capability validation succeed.
func (m *Manager) CreateTaskFromPeer(
	ctx context.Context,
	ingress TaskIngressContext,
	spec taskpkg.CreateTask,
) (*taskpkg.Task, error) {
	peerCtx, err := m.resolveTaskPeerContext(ctx, ingress, networkTaskActionCreate)
	if err != nil {
		return nil, err
	}
	if err := validateRequestedTaskChannel(peerCtx.ingress.Channel, spec.NetworkChannel); err != nil {
		return nil, m.rejectTaskIngress(ctx, peerCtx.ingress, networkTaskActionCreate, err, map[string]any{
			tasksNetworkChannelKey: strings.TrimSpace(spec.NetworkChannel),
		})
	}

	record, err := m.tasks.CreateTask(ctx, spec, peerCtx.actor)
	if err != nil {
		return nil, m.rejectTaskIngress(ctx, peerCtx.ingress, networkTaskActionCreate, err, map[string]any{
			tasksNetworkChannelKey: strings.TrimSpace(spec.NetworkChannel),
		})
	}
	m.recordTaskIngress(ctx, peerCtx.ingress, networkTaskActionCreate, AuditDirectionReceived, "", map[string]any{
		tasksTaskIDKey:         record.ID,
		tasksNetworkChannelKey: strings.TrimSpace(record.NetworkChannel),
	})
	return record, nil
}

// UpdateTaskFromPeer applies one mutable task patch through the task manager
// after enforcing channel-bound ingress rules.