Method ActivateSourceSession

internal/resources/kernel.go:173–222

ActivateSourceSession registers the active nonce and resets the snapshot version counter for one source.

(
	ctx context.Context,
	actor MutationActor,
	source ResourceSource,
	sessionNonce string,
)

// ActivateSourceSession registers the active nonce and resets the snapshot version counter for one source.
func (k *Kernel) ActivateSourceSession(
	ctx context.Context,
	actor MutationActor,
	source ResourceSource,
	sessionNonce string,
) error {
	if ctx == nil {
		return errors.New("resources: activate source session context is required")
	}

	normalizedActor, err := normalizeActor(actor)
	if err != nil {
		return err
	}
	if normalizedActor.Kind == MutationActorKindExtension {
		return fmt.Errorf("%w: extension actors cannot activate source sessions", ErrPermissionDenied)
	}

	normalizedSource := source.Normalize()
	if err := normalizedSource.Validate("source"); err != nil {
		return err
	}
	trimmedNonce := strings.TrimSpace(sessionNonce)
	if trimmedNonce == "" {
		return fmt.Errorf("%w: session_nonce is required", ErrValidation)
	}

	unlock := k.lockSource(normalizedSource)
	defer unlock()

	return k.withImmediateTransaction(ctx, "activate source session", func(exec sqlExecutor) error {
		updatedAt := store.FormatTimestamp(k.now())
		if _, err := exec.ExecContext(
			ctx,
			activateSourceStateQuery,
			normalizedSource.Kind,
			normalizedSource.ID,
			trimmedNonce,
			updatedAt,
		); err != nil {
			return fmt.Errorf(
				"resources: activate source session %q/%q: %w",
				normalizedSource.Kind,
				normalizedSource.ID,
				err,
			)
		}
		return nil
	})
}

// ResetSource deletes all source-owned records and source state in one transaction.
func (k *Kernel) ResetSource(ctx context.Context, actor MutationActor, source ResourceSource) error {