stores

type AgreementArtifactRecord struct {
	AgreementID          string
	TenantID             string
	OrgID                string
	ExecutedObjectKey    string
	ExecutedSHA256       string
	CertificateObjectKey string
	CertificateSHA256    string
	CorrelationID        string
	CreatedAt            time.Time
	UpdatedAt            time.Time
}

type AgreementArtifactStore interface {
	SaveAgreementArtifacts(ctx context.Context, scope Scope, record AgreementArtifactRecord) (AgreementArtifactRecord, error)
	GetAgreementArtifacts(ctx context.Context, scope Scope, agreementID string) (AgreementArtifactRecord, error)
}

type AgreementDraftPatch struct {
	Title      *string
	Message    *string
	DocumentID *string
}

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

type AgreementQuery struct {
	Status   string
	Limit    int
	Offset   int
	SortDesc bool
}

type AgreementRecord struct {
	ID                     string
	TenantID               string
	OrgID                  string
	DocumentID             string
	SourceType             string
	SourceGoogleFileID     string
	SourceGoogleDocURL     string
	SourceModifiedTime     *time.Time
	SourceExportedAt       *time.Time
	SourceExportedByUserID string
	SourceMimeType         string
	SourceIngestionMode    string
	Status                 string
	Title                  string
	Message                string
	Version                int64
	SentAt                 *time.Time
	CompletedAt            *time.Time
	VoidedAt               *time.Time
	DeclinedAt             *time.Time
	ExpiredAt              *time.Time
	CreatedByUserID        string
	UpdatedByUserID        string
	CreatedAt              time.Time
	UpdatedAt              time.Time
}

type AgreementStore interface {
	CreateDraft(ctx context.Context, scope Scope, record AgreementRecord) (AgreementRecord, error)
	GetAgreement(ctx context.Context, scope Scope, id string) (AgreementRecord, error)
	ListAgreements(ctx context.Context, scope Scope, query AgreementQuery) ([]AgreementRecord, error)
	UpdateDraft(ctx context.Context, scope Scope, id string, patch AgreementDraftPatch, expectedVersion int64) (AgreementRecord, error)
	Transition(ctx context.Context, scope Scope, id string, input AgreementTransitionInput) (AgreementRecord, error)
	UpsertParticipantDraft(ctx context.Context, scope Scope, agreementID string, patch ParticipantDraftPatch, expectedVersion int64) (ParticipantRecord, error)
	DeleteParticipantDraft(ctx context.Context, scope Scope, agreementID, participantID string) error
	ListParticipants(ctx context.Context, scope Scope, agreementID string) ([]ParticipantRecord, error)
	UpsertRecipientDraft(ctx context.Context, scope Scope, agreementID string, patch RecipientDraftPatch, expectedVersion int64) (RecipientRecord, error)
	DeleteRecipientDraft(ctx context.Context, scope Scope, agreementID, recipientID string) error
	ListRecipients(ctx context.Context, scope Scope, agreementID string) ([]RecipientRecord, error)
	TouchRecipientView(ctx context.Context, scope Scope, agreementID, recipientID string, viewedAt time.Time) (RecipientRecord, error)
	CompleteRecipient(ctx context.Context, scope Scope, agreementID, recipientID string, completedAt time.Time, expectedVersion int64) (RecipientRecord, error)
	DeclineRecipient(ctx context.Context, scope Scope, agreementID, recipientID, reason string, declinedAt time.Time, expectedVersion int64) (RecipientRecord, error)
	UpsertFieldDefinitionDraft(ctx context.Context, scope Scope, agreementID string, patch FieldDefinitionDraftPatch) (FieldDefinitionRecord, error)
	DeleteFieldDefinitionDraft(ctx context.Context, scope Scope, agreementID, fieldDefinitionID string) error
	ListFieldDefinitions(ctx context.Context, scope Scope, agreementID string) ([]FieldDefinitionRecord, error)
	UpsertFieldInstanceDraft(ctx context.Context, scope Scope, agreementID string, patch FieldInstanceDraftPatch) (FieldInstanceRecord, error)
	DeleteFieldInstanceDraft(ctx context.Context, scope Scope, agreementID, fieldInstanceID string) error
	ListFieldInstances(ctx context.Context, scope Scope, agreementID string) ([]FieldInstanceRecord, error)
	UpsertFieldDraft(ctx context.Context, scope Scope, agreementID string, patch FieldDraftPatch) (FieldRecord, error)
	DeleteFieldDraft(ctx context.Context, scope Scope, agreementID, fieldID string) error
	ListFields(ctx context.Context, scope Scope, agreementID string) ([]FieldRecord, error)
}

type AgreementTransitionInput struct {
	ToStatus        string
	ExpectedVersion int64
}

type AuditEventQuery struct {
	Limit    int
	Offset   int
	SortDesc bool
}

type AuditEventRecord struct {
	ID           string
	TenantID     string
	OrgID        string
	AgreementID  string
	EventType    string
	ActorType    string
	ActorID      string
	IPAddress    string
	UserAgent    string
	MetadataJSON string
	CreatedAt    time.Time
}

type AuditEventStore interface {
	Append(ctx context.Context, scope Scope, event AuditEventRecord) (AuditEventRecord, error)
	ListForAgreement(ctx context.Context, scope Scope, agreementID string, query AuditEventQuery) ([]AuditEventRecord, error)
}

type DocumentQuery struct {
	TitleContains string
	Limit         int
	Offset        int
}

type DocumentRecord struct {
	ID                     string
	TenantID               string
	OrgID                  string
	Title                  string
	SourceObjectKey        string
	SourceSHA256           string
	SourceType             string
	SourceGoogleFileID     string
	SourceGoogleDocURL     string
	SourceModifiedTime     *time.Time
	SourceExportedAt       *time.Time
	SourceExportedByUserID string
	SourceMimeType         string
	SourceIngestionMode    string
	SizeBytes              int64
	PageCount              int
	CreatedAt              time.Time
	UpdatedAt              time.Time
}

type DocumentStore interface {
	Create(ctx context.Context, scope Scope, record DocumentRecord) (DocumentRecord, error)
	Get(ctx context.Context, scope Scope, id string) (DocumentRecord, error)
	List(ctx context.Context, scope Scope, query DocumentQuery) ([]DocumentRecord, error)
}

type DraftPatch struct {
	WizardStateJSON *string
	Title           *string
	CurrentStep     *int
	DocumentID      *string
	ExpiresAt       *time.Time
	UpdatedAt       *time.Time
}

type DraftQuery struct {
	CreatedByUserID string
	WizardID        string
	Limit           int
	Cursor          string
	SortDesc        bool
}

type DraftRecord struct {
	ID              string
	WizardID        string
	TenantID        string
	OrgID           string
	CreatedByUserID string
	DocumentID      string
	Title           string
	CurrentStep     int
	WizardStateJSON string
	Revision        int64
	CreatedAt       time.Time
	UpdatedAt       time.Time
	ExpiresAt       time.Time
}

type DraftStore interface {
	CreateDraftSession(ctx context.Context, scope Scope, record DraftRecord) (DraftRecord, bool, error)
	GetDraftSession(ctx context.Context, scope Scope, id string) (DraftRecord, error)
	ListDraftSessions(ctx context.Context, scope Scope, query DraftQuery) ([]DraftRecord, string, error)
	UpdateDraftSession(ctx context.Context, scope Scope, id string, patch DraftPatch, expectedRevision int64) (DraftRecord, error)
	DeleteDraftSession(ctx context.Context, scope Scope, id string) error
	DeleteExpiredDraftSessions(ctx context.Context, before time.Time) (int, error)
}

type DraftUpgradeIssue struct {
	Field   string
	Message string
}

type DraftUpgradeReport struct {
	AgreementID string
	Upgraded    bool
	Actions     []string
	Issues      []DraftUpgradeIssue
}

type EmailLogRecord struct {
	ID                string
	TenantID          string
	OrgID             string
	AgreementID       string
	RecipientID       string
	TemplateCode      string
	ProviderMessageID string
	Status            string
	FailureReason     string
	AttemptCount      int
	MaxAttempts       int
	CorrelationID     string
	NextRetryAt       *time.Time
	SentAt            *time.Time
	CreatedAt         time.Time
	UpdatedAt         time.Time
}

type EmailLogStore interface {
	CreateEmailLog(ctx context.Context, scope Scope, record EmailLogRecord) (EmailLogRecord, error)
	UpdateEmailLog(ctx context.Context, scope Scope, id string, patch EmailLogRecord) (EmailLogRecord, error)
	ListEmailLogs(ctx context.Context, scope Scope, agreementID string) ([]EmailLogRecord, error)
}

type ExternalFieldRef struct {
	Object          string
	Field           string
	Type            string
	Required        bool
	ConstraintsJSON string
}

type ExternalSchema struct {
	ObjectType string
	Version    string
	Fields     []ExternalFieldRef
}

type FieldDefinitionDraftPatch struct {
	ID             string
	ParticipantID  *string
	Type           *string
	Required       *bool
	ValidationJSON *string
}

type FieldDefinitionRecord struct {
	ID             string
	TenantID       string
	OrgID          string
	AgreementID    string
	ParticipantID  string
	Type           string
	Required       bool
	ValidationJSON string
	CreatedAt      time.Time
	UpdatedAt      time.Time
}

type FieldDraftPatch struct {
	ID          string
	RecipientID *string
	Type        *string
	PageNumber  *int
	PosX        *float64
	PosY        *float64
	Width       *float64
	Height      *float64
	Required    *bool
}

type FieldInstanceDraftPatch struct {
	ID                string
	FieldDefinitionID *string
	PageNumber        *int
	X                 *float64
	Y                 *float64
	Width             *float64
	Height            *float64
	TabIndex          *int
	Label             *string
	AppearanceJSON    *string
	PlacementSource   *string
	ResolverID        *string
	Confidence        *float64
	PlacementRunID    *string
	ManualOverride    *bool
}

type FieldInstanceRecord struct {
	ID                string
	TenantID          string
	OrgID             string
	AgreementID       string
	FieldDefinitionID string
	PageNumber        int
	X                 float64
	Y                 float64
	Width             float64
	Height            float64
	TabIndex          int
	Label             string
	AppearanceJSON    string
	PlacementSource   string
	ResolverID        string
	Confidence        float64
	PlacementRunID    string
	ManualOverride    bool
	CreatedAt         time.Time
	UpdatedAt         time.Time
}

type FieldRecord struct {
	ID                string
	FieldDefinitionID string
	TenantID          string
	OrgID             string
	AgreementID       string
	RecipientID       string
	Type              string
	PageNumber        int
	PosX              float64
	PosY              float64
	Width             float64
	Height            float64
	Required          bool
	CreatedAt         time.Time
	UpdatedAt         time.Time
}

type FieldValueRecord struct {
	ID                  string
	TenantID            string
	OrgID               string
	AgreementID         string
	RecipientID         string
	FieldID             string
	ValueText           string
	ValueBool           *bool
	SignatureArtifactID string
	Version             int64
	CreatedAt           time.Time
	UpdatedAt           time.Time
}

type FixtureSet struct {
	DocumentID              string
	AgreementID             string
	RecipientID             string
	ParticipantID           string
	FieldDefinitionID       string
	FieldInstanceID         string
	SigningTokenID          string
	FieldID                 string
	FieldValueID            string
	SignatureArtifactID     string
	AuditEventID            string
	EmailLogID              string
	IntegrationCredentialID string
}

type GoogleImportRunFailureInput struct {
	ErrorCode        string
	ErrorMessage     string
	ErrorDetailsJSON string
	CompletedAt      time.Time
}

type GoogleImportRunInput struct {
	UserID            string
	GoogleFileID      string
	SourceVersionHint string
	DedupeKey         string
	DocumentTitle     string
	AgreementTitle    string
	CreatedByUserID   string
	CorrelationID     string
	RequestedAt       time.Time
}

type GoogleImportRunQuery struct {
	UserID   string
	Limit    int
	Cursor   string
	SortDesc bool
}

type GoogleImportRunRecord struct {
	ID                string
	TenantID          string
	OrgID             string
	UserID            string
	GoogleFileID      string
	SourceVersionHint string
	DedupeKey         string
	DocumentTitle     string
	AgreementTitle    string
	CreatedByUserID   string
	CorrelationID     string
	Status            string
	DocumentID        string
	AgreementID       string
	SourceMimeType    string
	IngestionMode     string
	ErrorCode         string
	ErrorMessage      string
	ErrorDetailsJSON  string
	CreatedAt         time.Time
	UpdatedAt         time.Time
	StartedAt         *time.Time
	CompletedAt       *time.Time
}

type GoogleImportRunStore interface {
	BeginGoogleImportRun(ctx context.Context, scope Scope, input GoogleImportRunInput) (GoogleImportRunRecord, bool, error)
	MarkGoogleImportRunRunning(ctx context.Context, scope Scope, id string, startedAt time.Time) (GoogleImportRunRecord, error)
	MarkGoogleImportRunSucceeded(ctx context.Context, scope Scope, id string, input GoogleImportRunSuccessInput) (GoogleImportRunRecord, error)
	MarkGoogleImportRunFailed(ctx context.Context, scope Scope, id string, input GoogleImportRunFailureInput) (GoogleImportRunRecord, error)
	GetGoogleImportRun(ctx context.Context, scope Scope, id string) (GoogleImportRunRecord, error)
	ListGoogleImportRuns(ctx context.Context, scope Scope, query GoogleImportRunQuery) ([]GoogleImportRunRecord, string, error)
}

type GoogleImportRunSuccessInput struct {
	DocumentID     string
	AgreementID    string
	SourceMimeType string
	IngestionMode  string
	CompletedAt    time.Time
}

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

type IntegrationBindingRecord struct {
	ID             string
	TenantID       string
	OrgID          string
	Provider       string
	EntityKind     string
	ExternalID     string
	InternalID     string
	ProvenanceJSON string
	Version        int64
	CreatedAt      time.Time
	UpdatedAt      time.Time
}

type IntegrationChangeEventRecord struct {
	ID             string
	TenantID       string
	OrgID          string
	AgreementID    string
	Provider       string
	EventType      string
	SourceEventID  string
	IdempotencyKey string
	PayloadJSON    string
	EmittedAt      time.Time
	CreatedAt      time.Time
}

type IntegrationCheckpointRecord struct {
	ID            string
	TenantID      string
	OrgID         string
	RunID         string
	CheckpointKey string
	Cursor        string
	PayloadJSON   string
	Version       int64
	CreatedAt     time.Time
	UpdatedAt     time.Time
}

type IntegrationConflictRecord struct {
	ID               string
	TenantID         string
	OrgID            string
	RunID            string
	BindingID        string
	Provider         string
	EntityKind       string
	ExternalID       string
	InternalID       string
	Status           string
	Reason           string
	PayloadJSON      string
	ResolutionJSON   string
	ResolvedByUserID string
	ResolvedAt       *time.Time
	Version          int64
	CreatedAt        time.Time
	UpdatedAt        time.Time
}

type IntegrationCredentialRecord struct {
	ID                    string
	TenantID              string
	OrgID                 string
	UserID                string
	Provider              string
	EncryptedAccessToken  string
	EncryptedRefreshToken string
	Scopes                []string
	ExpiresAt             *time.Time
	ProfileJSON           string     // OAuth profile data, e.g. {"email": "user@example.com"}
	LastUsedAt            *time.Time // Last API call using this credential
	CreatedAt             time.Time
	UpdatedAt             time.Time
}

type IntegrationCredentialStore interface {
	UpsertIntegrationCredential(ctx context.Context, scope Scope, record IntegrationCredentialRecord) (IntegrationCredentialRecord, error)
	GetIntegrationCredential(ctx context.Context, scope Scope, provider, userID string) (IntegrationCredentialRecord, error)
	DeleteIntegrationCredential(ctx context.Context, scope Scope, provider, userID string) error
	// ListIntegrationCredentials returns all credentials for a provider, optionally filtered by base user ID prefix.
	// The baseUserIDPrefix filters credentials whose UserID starts with the given prefix (supports scoped user IDs).
	ListIntegrationCredentials(ctx context.Context, scope Scope, provider string, baseUserIDPrefix string) ([]IntegrationCredentialRecord, error)
}

type IntegrationFoundationStore interface {
	UpsertMappingSpec(ctx context.Context, scope Scope, record MappingSpecRecord) (MappingSpecRecord, error)
	GetMappingSpec(ctx context.Context, scope Scope, id string) (MappingSpecRecord, error)
	ListMappingSpecs(ctx context.Context, scope Scope, provider string) ([]MappingSpecRecord, error)
	PublishMappingSpec(ctx context.Context, scope Scope, id string, expectedVersion int64, publishedAt time.Time) (MappingSpecRecord, error)

	UpsertIntegrationBinding(ctx context.Context, scope Scope, record IntegrationBindingRecord) (IntegrationBindingRecord, error)
	GetIntegrationBindingByExternal(ctx context.Context, scope Scope, provider, entityKind, externalID string) (IntegrationBindingRecord, error)
	ListIntegrationBindings(ctx context.Context, scope Scope, provider, entityKind, internalID string) ([]IntegrationBindingRecord, error)

	CreateIntegrationSyncRun(ctx context.Context, scope Scope, record IntegrationSyncRunRecord) (IntegrationSyncRunRecord, error)
	UpdateIntegrationSyncRunStatus(ctx context.Context, scope Scope, id, status, lastError, cursor string, completedAt *time.Time, expectedVersion int64) (IntegrationSyncRunRecord, error)
	GetIntegrationSyncRun(ctx context.Context, scope Scope, id string) (IntegrationSyncRunRecord, error)
	ListIntegrationSyncRuns(ctx context.Context, scope Scope, provider string) ([]IntegrationSyncRunRecord, error)

	UpsertIntegrationCheckpoint(ctx context.Context, scope Scope, record IntegrationCheckpointRecord) (IntegrationCheckpointRecord, error)
	ListIntegrationCheckpoints(ctx context.Context, scope Scope, runID string) ([]IntegrationCheckpointRecord, error)

	CreateIntegrationConflict(ctx context.Context, scope Scope, record IntegrationConflictRecord) (IntegrationConflictRecord, error)
	GetIntegrationConflict(ctx context.Context, scope Scope, id string) (IntegrationConflictRecord, error)
	ListIntegrationConflicts(ctx context.Context, scope Scope, runID, status string) ([]IntegrationConflictRecord, error)
	ResolveIntegrationConflict(ctx context.Context, scope Scope, id, status, resolutionJSON, resolvedByUserID string, resolvedAt time.Time, expectedVersion int64) (IntegrationConflictRecord, error)

	AppendIntegrationChangeEvent(ctx context.Context, scope Scope, record IntegrationChangeEventRecord) (IntegrationChangeEventRecord, error)
	ListIntegrationChangeEvents(ctx context.Context, scope Scope, agreementID string) ([]IntegrationChangeEventRecord, error)

	ClaimIntegrationMutation(ctx context.Context, scope Scope, idempotencyKey string, firstSeenAt time.Time) (bool, error)
}

type IntegrationSyncRunRecord struct {
	ID              string
	TenantID        string
	OrgID           string
	Provider        string
	Direction       string
	MappingSpecID   string
	Status          string
	Cursor          string
	LastError       string
	AttemptCount    int
	Version         int64
	StartedAt       time.Time
	CompletedAt     *time.Time
	CreatedByUserID string
	CreatedAt       time.Time
	UpdatedAt       time.Time
}

type IssuedSigningToken struct {
	Token  string
	Record SigningTokenRecord
}

type JobRunInput struct {
	JobName       string
	DedupeKey     string
	AgreementID   string
	RecipientID   string
	CorrelationID string
	MaxAttempts   int
	AttemptedAt   time.Time
}

type JobRunRecord struct {
	ID            string
	TenantID      string
	OrgID         string
	JobName       string
	DedupeKey     string
	AgreementID   string
	RecipientID   string
	CorrelationID string
	Status        string
	AttemptCount  int
	MaxAttempts   int
	LastError     string
	NextRetryAt   *time.Time
	CreatedAt     time.Time
	UpdatedAt     time.Time
}

type JobRunStore interface {
	BeginJobRun(ctx context.Context, scope Scope, input JobRunInput) (JobRunRecord, bool, error)
	MarkJobRunSucceeded(ctx context.Context, scope Scope, id string, completedAt time.Time) (JobRunRecord, error)
	MarkJobRunFailed(ctx context.Context, scope Scope, id, failureReason string, nextRetryAt *time.Time, failedAt time.Time) (JobRunRecord, error)
	GetJobRunByDedupe(ctx context.Context, scope Scope, jobName, dedupeKey string) (JobRunRecord, error)
	ListJobRuns(ctx context.Context, scope Scope, agreementID string) ([]JobRunRecord, error)
}

type MappingRule struct {
	SourceObject string
	SourceField  string
	TargetEntity string
	TargetPath   string
	Required     bool
	DefaultValue string
	Transform    string
}

type MappingSpecRecord struct {
	ID              string
	TenantID        string
	OrgID           string
	Provider        string
	Name            string
	Version         int64
	Status          string
	ExternalSchema  ExternalSchema
	Rules           []MappingRule
	CompiledJSON    string
	CompiledHash    string
	PublishedAt     *time.Time
	CreatedByUserID string
	UpdatedByUserID string
	CreatedAt       time.Time
	UpdatedAt       time.Time
}

type ObjectStorageSecurityPolicy struct {
	RequireEncryption bool
	AllowedAlgorithms map[string]struct{}
}

type OutboxClaimInput = txoutbox.ClaimInput

type OutboxDispatchInput = txoutbox.DispatchInput

type OutboxDispatchResult = txoutbox.DispatchResult

type OutboxMessageRecord = txoutbox.Message

type OutboxPublisher = txoutbox.Publisher

type OutboxQuery = txoutbox.Query

type OutboxStore interface {
	txoutbox.Store[Scope]
}

type ParticipantDraftPatch struct {
	ID           string
	Email        *string
	Name         *string
	Role         *string
	SigningStage *int
}

type ParticipantRecord struct {
	ID            string
	TenantID      string
	OrgID         string
	AgreementID   string
	Email         string
	Name          string
	Role          string
	SigningStage  int
	FirstViewAt   *time.Time
	LastViewAt    *time.Time
	DeclinedAt    *time.Time
	DeclineReason string
	CompletedAt   *time.Time
	Version       int64
	CreatedAt     time.Time
	UpdatedAt     time.Time
}

type PlacementResolverScore struct {
	ResolverID string
	Accuracy   float64
	Cost       float64
	Latency    float64
	Score      float64
	Supported  bool
	Reason     string
}

type PlacementRunRecord struct {
	ID                      string
	TenantID                string
	OrgID                   string
	AgreementID             string
	Status                  string
	ReasonCode              string
	ResolverOrder           []string
	ExecutedResolvers       []string
	ResolverScores          []PlacementResolverScore
	Suggestions             []PlacementSuggestionRecord
	SelectedSuggestionIDs   []string
	UnresolvedDefinitionIDs []string
	SelectedSource          string
	PolicyJSON              string
	MaxBudget               float64
	BudgetUsed              float64
	MaxTimeMS               int64
	ElapsedMS               int64
	ManualOverrideCount     int
	CreatedByUserID         string
	Version                 int64
	CreatedAt               time.Time
	UpdatedAt               time.Time
	CompletedAt             *time.Time
}

type PlacementRunStore interface {
	UpsertPlacementRun(ctx context.Context, scope Scope, record PlacementRunRecord) (PlacementRunRecord, error)
	GetPlacementRun(ctx context.Context, scope Scope, agreementID, runID string) (PlacementRunRecord, error)
	ListPlacementRuns(ctx context.Context, scope Scope, agreementID string) ([]PlacementRunRecord, error)
}

type PlacementSuggestionRecord struct {
	ID                string
	FieldDefinitionID string
	ResolverID        string
	Confidence        float64
	PageNumber        int
	X                 float64
	Y                 float64
	Width             float64
	Height            float64
	Label             string
	MetadataJSON      string
}

type PostCommitHook = txoutbox.PostCommitHook

type RecipientDraftPatch struct {
	ID           string
	Email        *string
	Name         *string
	Role         *string
	SigningOrder *int
}

type RecipientRecord struct {
	ID          string
	TenantID    string
	OrgID       string
	AgreementID string
	Email       string
	Name        string
	Role        string

	SigningOrder  int
	FirstViewAt   *time.Time
	LastViewAt    *time.Time
	DeclinedAt    *time.Time
	DeclineReason string
	CompletedAt   *time.Time
	Version       int64
	CreatedAt     time.Time
	UpdatedAt     time.Time
}

type RetentionLifecycleCheck struct {
	CheckedAt        time.Time
	ArtifactDueCount int
	LogDueCount      int
	PIIDueCount      int
}

type RetentionPolicy struct {
	ArtifactTTL    time.Duration
	LogTTL         time.Duration
	PIIMetadataTTL time.Duration
}

type SQLiteStore struct {
	*InMemoryStore
	// contains filtered or unexported fields
}

type Scope struct {
	TenantID string
	OrgID    string
}

type SignatureArtifactRecord struct {
	ID          string
	TenantID    string
	OrgID       string
	AgreementID string
	RecipientID string
	Type        string
	ObjectKey   string
	SHA256      string
	CreatedAt   time.Time
}

type SignatureArtifactStore interface {
	CreateSignatureArtifact(ctx context.Context, scope Scope, record SignatureArtifactRecord) (SignatureArtifactRecord, error)
	GetSignatureArtifact(ctx context.Context, scope Scope, id string) (SignatureArtifactRecord, error)
}

type SignerProfileRecord struct {
	ID                    string
	TenantID              string
	OrgID                 string
	Subject               string
	Key                   string
	FullName              string
	Initials              string
	TypedSignature        string
	DrawnSignatureDataURL string
	DrawnInitialsDataURL  string
	Remember              bool
	CreatedAt             time.Time
	UpdatedAt             time.Time
	ExpiresAt             time.Time
}

type SignerProfileStore interface {
	UpsertSignerProfile(ctx context.Context, scope Scope, record SignerProfileRecord) (SignerProfileRecord, error)
	GetSignerProfile(ctx context.Context, scope Scope, subject, key string, now time.Time) (SignerProfileRecord, error)
	DeleteSignerProfile(ctx context.Context, scope Scope, subject, key string) error
}

type SigningStore interface {
	UpsertFieldValue(ctx context.Context, scope Scope, value FieldValueRecord, expectedVersion int64) (FieldValueRecord, error)
	ListFieldValuesByRecipient(ctx context.Context, scope Scope, agreementID, recipientID string) ([]FieldValueRecord, error)
}

type SigningTokenRecord struct {
	ID          string
	TenantID    string
	OrgID       string
	AgreementID string
	RecipientID string
	TokenHash   string
	Status      string
	ExpiresAt   time.Time
	RevokedAt   *time.Time
	CreatedAt   time.Time
}

type SigningTokenStore interface {
	CreateSigningToken(ctx context.Context, scope Scope, record SigningTokenRecord) (SigningTokenRecord, error)
	GetSigningTokenByHash(ctx context.Context, scope Scope, tokenHash string) (SigningTokenRecord, error)
	RevokeActiveSigningTokens(ctx context.Context, scope Scope, agreementID, recipientID string, revokedAt time.Time) (int, error)
}

type Store interface {
	TxStore
	TransactionManager
}

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

type TokenServiceOption func(*TokenService)

type TransactionManager interface {
	WithTx(ctx context.Context, fn func(tx TxStore) error) error
}

type TxHooks = txoutbox.Hooks

type TxStore interface {
	DocumentStore
	AgreementStore
	DraftStore
	SigningStore
	SignatureArtifactStore
	SignerProfileStore
	SigningTokenStore
	AuditEventStore
	AgreementArtifactStore
	EmailLogStore
	JobRunStore
	GoogleImportRunStore
	OutboxStore
	IntegrationCredentialStore
	IntegrationFoundationStore
	PlacementRunStore
}