storage

type AuditEvent struct {
	EventID    corepkg.EventID   `json:"event_id"`
	SessionID  corepkg.SessionID `json:"session_id,omitempty"`
	TaskID     corepkg.TaskID    `json:"task_id,omitempty"`
	TraceID    corepkg.TraceID   `json:"trace_id,omitempty"`
	Timestamp  time.Time         `json:"timestamp"`
	Actor      string            `json:"actor,omitempty"`
	Action     string            `json:"action"`
	Decision   corepkg.Decision  `json:"decision,omitempty"`
	ReasonCode string            `json:"reason_code,omitempty"`
	RiskLevel  corepkg.RiskLevel `json:"risk_level,omitempty"`
	Result     string            `json:"result,omitempty"`
	LatencyMS  int64             `json:"latency_ms,omitempty"`
	Metadata   map[string]string `json:"metadata,omitempty"`
}

type AuditStore interface {
	Append(ctx context.Context, event AuditEvent) error
}

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

type ErrorCode string

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

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

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

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

type Locker interface {
	// LockSession acquires the session-scoped lock.
	// acquireCtx is only for acquisition waiting/cancellation.
	// Implementations must not bind lock lifetime to acquireCtx after acquisition.
	LockSession(acquireCtx context.Context, sessionID corepkg.SessionID) (UnlockFunc, error)
	// LockTask acquires the task-scoped lock.
	// acquireCtx is only for acquisition waiting/cancellation.
	// Implementations must not bind lock lifetime to acquireCtx after acquisition.
	LockTask(acquireCtx context.Context, taskID corepkg.TaskID) (UnlockFunc, error)
}

type NopAuditStore struct{}

type NopPromptHistoryStore struct{}

type PromptEntry struct {
	Timestamp time.Time         `json:"timestamp"`
	Workspace string            `json:"workspace"`
	SessionID corepkg.SessionID `json:"session_id"`
	Prompt    string            `json:"prompt"`
}

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

type PromptHistoryWriter interface {
	Append(workspace string, sessionID corepkg.SessionID, prompt string, at time.Time) error
}

type PromptSearchQuery struct {
	Tokens          []string
	WorkspaceFilter string
	SessionFilter   string
}

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

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

type TaskLogRecord struct {
	TaskID    corepkg.TaskID  `json:"-"`
	Offset    int64           `json:"-"`
	EventID   string          `json:"event_id"`
	Type      string          `json:"type"`
	Payload   json.RawMessage `json:"payload,omitempty"`
	CreatedAt time.Time       `json:"ts"`
}

type TaskStore interface {
	AppendLog(ctx context.Context, taskID corepkg.TaskID, record TaskLogRecord) (offset int64, err error)
	ReadLogFrom(ctx context.Context, taskID corepkg.TaskID, offset int64, limit int) (records []TaskLogRecord, next int64, err error)
}

type TaskStoreOptions struct {
	// SyncOnAppend controls whether AppendLog calls fsync per record.
	SyncOnAppend bool
}

type UnlockFunc func() error