storeiface

type CRMIntegrationStore interface {
	SyncRunStore
	CRMIntegrationWriter
}

type CRMIntegrationWriter interface {
	UpsertCRMIntegration(ctx context.Context, raw json.RawMessage) (*sqlite.CRMIntegrationRecord, error)
}

type CRMSchemaStore interface {
	SyncRunStore
	CRMSchemaWriter
}

type CRMSchemaWriter interface {
	UpsertCRMSchema(ctx context.Context, integrationID string, objectType string, raw json.RawMessage) (int64, error)
}

type CallRawReader interface {
	CallRawJSON(ctx context.Context, callID string) (json.RawMessage, error)
}

type CallSearcher interface {
	SearchCallsRaw(ctx context.Context, params sqlite.CallSearchParams) ([]json.RawMessage, error)
}

type CallWriter interface {
	UpsertCall(ctx context.Context, raw json.RawMessage) (*sqlite.CallRecord, error)
}

type Closer interface {
	Close() error
}

type CoreReadStore interface {
	SyncStatusReader
	CallSearcher
	SearchTranscriptSegments(ctx context.Context, query string, limit int) ([]sqlite.TranscriptSearchResult, error)
}

type GongSettingWriter interface {
	UpsertGongSetting(ctx context.Context, kind string, raw json.RawMessage) (*sqlite.GongSettingRecord, error)
}

type GovernanceIngestCacheCleaner interface {
	DeleteGovernanceIngestCachedCall(ctx context.Context, callID string) error
}

type GovernanceIngestSkipWriter interface {
	RecordGovernanceIngestSkippedCall(ctx context.Context, params sqlite.GovernanceIngestSkippedCallParams) error
	RecordGovernanceIngestSkippedCallAndDeleteCachedCall(ctx context.Context, params sqlite.GovernanceIngestSkippedCallParams) error
	ClearGovernanceIngestSkippedCall(ctx context.Context, callID string) error
}

type ScorecardActivityStore interface {
	SyncRunStore
	ScorecardActivityWriter
}

type ScorecardActivityWriter interface {
	UpsertScorecardActivity(ctx context.Context, raw json.RawMessage) (*sqlite.ScorecardActivityRecord, error)
}

type SettingsStore interface {
	SyncRunStore
	GongSettingWriter
}

type SyncRunStore interface {
	StartSyncRun(ctx context.Context, params sqlite.StartSyncRunParams) (*sqlite.SyncRun, error)
	FinishSyncRun(ctx context.Context, runID int64, params sqlite.FinishSyncRunParams) error
}

type SyncStatusReader interface {
	SyncStatusSummary(ctx context.Context) (*sqlite.SyncStatusSummary, error)
}

type SyncStore interface {
	SyncRunStore
	CallWriter
	UserWriter
	GovernanceIngestSkipWriter
	GovernanceIngestCacheCleaner
}

type TranscriptStore interface {
	SyncRunStore
	TranscriptWriter
	FindCallsMissingTranscripts(ctx context.Context, limit int) ([]sqlite.MissingTranscriptCall, error)
	SearchTranscriptSegments(ctx context.Context, query string, limit int) ([]sqlite.TranscriptSearchResult, error)
	GovernanceIngestSkipWriter
	GovernanceIngestCacheCleaner
	CallRawReader
}

type TranscriptWriter interface {
	UpsertTranscript(ctx context.Context, raw json.RawMessage) (*sqlite.TranscriptRecord, error)
}

type UserWriter interface {
	UpsertUser(ctx context.Context, raw json.RawMessage) (*sqlite.UserRecord, error)
}