activity

type Emitter struct {
	// contains filtered or unexported fields
}

type EntRecorder struct {
	Client *ent.Client
}

type RecordFunc func(context.Context, RecordInput) (catalogdomain.ActivityEvent, error)

type RecordInput struct {
	ProjectID uuid.UUID
	TicketID  *uuid.UUID
	AgentID   *uuid.UUID
	EventType activityevent.Type
	Message   string
	Metadata  map[string]any
	CreatedAt time.Time
}

type Recorder interface {
	RecordActivityEvent(ctx context.Context, input RecordInput) (catalogdomain.ActivityEvent, error)
}