Method Dispatch

app/controlplane/pkg/biz/auditor.go:54–89

Dispatch logs an entry to the audit log asynchronously. The actor is resolved from the request context (user, API token or system); the generation and publishing is delegated to the shared auditor.Dispatcher.

(ctx context.Context, entry auditor.LogEntry, orgID *uuid.UUID)

// from the request context (user, API token or system); the generation and
// publishing is delegated to the shared auditor.Dispatcher.
func (uc *AuditorUseCase) Dispatch(ctx context.Context, entry auditor.LogEntry, orgID *uuid.UUID) {
	ctx, span := otelx.Start(ctx, auditorTracer, "AuditorUseCase.Dispatch")
	defer span.End()

	// dynamically load user information from the context
	var opts []auditor.GeneratorOption
	var gotActor bool

	// Determine actor from context
	switch {
	case entities.CurrentUser(ctx) != nil:
		user := entities.CurrentUser(ctx)
		parsedUUID, _ := uuid.Parse(user.ID)
		fullName := strings.TrimSpace(fmt.Sprintf("%s %s", user.FirstName, user.LastName))
		opts = append(opts, auditor.WithActor(auditor.ActorTypeUser, parsedUUID, user.Email, fullName))
		gotActor = true
	case entities.CurrentAPIToken(ctx) != nil:
		apiToken := entities.CurrentAPIToken(ctx)
		parsedUUID, _ := uuid.Parse(apiToken.ID)
		opts = append(opts, auditor.WithActor(auditor.ActorTypeAPIToken, parsedUUID, "", apiToken.Name))
		gotActor = true
	default:
		opts = append(opts, auditor.WithActor(auditor.ActorTypeSystem, uuid.Nil, "", ""))
	}

	if !gotActor && entry.RequiresActor() {
		uc.log.Warn("failed to get actor information, required by the audit log entry")
		return
	}

	if orgID != nil {
		opts = append(opts, auditor.WithOrgID(*orgID))
	}

	uc.dispatcher.Dispatch(entry, opts...)
}