Documentation
¶
Overview ¶
Package store provides database access for msgvault.
Index ¶
- type Checkpoint
- type Label
- type Message
- type Participant
- type Source
- type Stats
- type Store
- func (s *Store) Close() error
- func (s *Store) CompleteSync(syncID int64, finalHistoryID string) error
- func (s *Store) CountMessagesForSource(sourceID int64) (int64, error)
- func (s *Store) CountMessagesWithRaw(sourceID int64) (int64, error)
- func (s *Store) DB() *sql.DB
- func (s *Store) EnsureConversation(sourceID int64, sourceConversationID, title string) (int64, error)
- func (s *Store) EnsureLabel(sourceID int64, sourceLabelID, name, labelType string) (int64, error)
- func (s *Store) EnsureLabelsBatch(sourceID int64, labels map[string]string) (map[string]int64, error)
- func (s *Store) EnsureParticipant(email, displayName, domain string) (int64, error)
- func (s *Store) EnsureParticipantsBatch(addresses []mime.Address) (map[string]int64, error)
- func (s *Store) FailSync(syncID int64, errMsg string) error
- func (s *Store) GetActiveSync(sourceID int64) (*SyncRun, error)
- func (s *Store) GetLastSuccessfulSync(sourceID int64) (*SyncRun, error)
- func (s *Store) GetMessageRaw(messageID int64) ([]byte, error)
- func (s *Store) GetOrCreateSource(sourceType, identifier string) (*Source, error)
- func (s *Store) GetRandomMessageIDs(sourceID int64, limit int) ([]int64, error)
- func (s *Store) GetSourceByIdentifier(identifier string) (*Source, error)
- func (s *Store) GetStats() (*Stats, error)
- func (s *Store) InitSchema() error
- func (s *Store) MarkMessageDeleted(sourceID int64, sourceMessageID string) error
- func (s *Store) MarkMessageDeletedByGmailID(permanent bool, gmailID string) error
- func (s *Store) MessageExistsBatch(sourceID int64, sourceMessageIDs []string) (map[string]int64, error)
- func (s *Store) Rebind(query string) string
- func (s *Store) ReplaceMessageLabels(messageID int64, labelIDs []int64) error
- func (s *Store) ReplaceMessageRecipients(messageID int64, recipientType string, participantIDs []int64, ...) error
- func (s *Store) StartSync(sourceID int64, syncType string) (int64, error)
- func (s *Store) UpdateSourceSyncCursor(sourceID int64, cursor string) error
- func (s *Store) UpdateSyncCheckpoint(syncID int64, cp *Checkpoint) error
- func (s *Store) UpsertAttachment(messageID int64, filename, mimeType, storagePath, contentHash string, size int) error
- func (s *Store) UpsertMessage(msg *Message) (int64, error)
- func (s *Store) UpsertMessageBody(messageID int64, bodyText, bodyHTML sql.NullString) error
- func (s *Store) UpsertMessageRaw(messageID int64, rawData []byte) error
- type SyncRun
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Checkpoint ¶
type Checkpoint struct {
PageToken string
MessagesProcessed int64
MessagesAdded int64
MessagesUpdated int64
ErrorsCount int64
}
Checkpoint represents sync progress for resumption.
type Label ¶
type Label struct {
ID int64
SourceID sql.NullInt64
SourceLabelID sql.NullString
Name string
LabelType sql.NullString
}
Label represents a Gmail label.
type Message ¶
type Message struct {
ID int64
ConversationID int64
SourceID int64
SourceMessageID string
MessageType string // "email"
SentAt sql.NullTime
ReceivedAt sql.NullTime
InternalDate sql.NullTime
SenderID sql.NullInt64
IsFromMe bool
Subject sql.NullString
Snippet sql.NullString
SizeEstimate int64
HasAttachments bool
AttachmentCount int
DeletedAt sql.NullTime
ArchivedAt time.Time
}
Message represents a message in the database.
type Participant ¶
type Participant struct {
ID int64
EmailAddress sql.NullString
DisplayName sql.NullString
Domain sql.NullString
}
Participant represents a person in the participants table.
type Source ¶
type Source struct {
ID int64
SourceType string // "gmail"
Identifier string // email address
DisplayName sql.NullString
GoogleUserID sql.NullString
LastSyncAt sql.NullTime
SyncCursor sql.NullString // historyId for Gmail
CreatedAt time.Time
UpdatedAt time.Time
}
Source represents a Gmail account or other message source.
type Stats ¶
type Stats struct {
MessageCount int64
ThreadCount int64
AttachmentCount int64
LabelCount int64
SourceCount int64
DatabaseSize int64
}
Stats holds database statistics.
type Store ¶
type Store struct {
// contains filtered or unexported fields
}
Store provides database operations for msgvault.
func Open ¶
Open opens or creates the database at the given path. Currently only SQLite is supported. PostgreSQL URLs will return an error.
func (*Store) CompleteSync ¶
CompleteSync marks a sync as successfully completed.
func (*Store) CountMessagesForSource ¶
CountMessagesForSource returns the count of messages for a specific source (account).
func (*Store) CountMessagesWithRaw ¶
CountMessagesWithRaw returns the count of messages that have raw MIME stored.
func (*Store) EnsureConversation ¶
func (s *Store) EnsureConversation(sourceID int64, sourceConversationID, title string) (int64, error)
EnsureConversation gets or creates a conversation (thread) for a message.
func (*Store) EnsureLabel ¶
EnsureLabel gets or creates a label.
func (*Store) EnsureLabelsBatch ¶
func (s *Store) EnsureLabelsBatch(sourceID int64, labels map[string]string) (map[string]int64, error)
EnsureLabelsBatch ensures all labels exist and returns a map of source_label_id -> internal ID.
func (*Store) EnsureParticipant ¶
EnsureParticipant gets or creates a participant by email.
func (*Store) EnsureParticipantsBatch ¶
EnsureParticipantsBatch gets or creates participants in batch. Returns a map of email -> participant ID.
func (*Store) GetActiveSync ¶
GetActiveSync returns the most recent running sync for a source, if any.
func (*Store) GetLastSuccessfulSync ¶
GetLastSuccessfulSync returns the most recent successful sync for a source.
func (*Store) GetMessageRaw ¶
GetMessageRaw retrieves and decompresses the raw MIME data for a message.
func (*Store) GetOrCreateSource ¶
GetOrCreateSource gets or creates a source by type and identifier.
func (*Store) GetRandomMessageIDs ¶
GetRandomMessageIDs returns a random sample of message IDs for a source. Uses reservoir sampling with random offsets for O(limit) performance on large tables, falling back to ORDER BY RANDOM() for small tables where the overhead isn't significant.
func (*Store) GetSourceByIdentifier ¶
GetSourceByIdentifier returns a source by its identifier (email address).
func (*Store) InitSchema ¶
InitSchema initializes the database schema. This creates all tables if they don't exist.
func (*Store) MarkMessageDeleted ¶
MarkMessageDeleted marks a message as deleted from the source.
func (*Store) MarkMessageDeletedByGmailID ¶
MarkMessageDeletedByGmailID marks a message as deleted by its Gmail ID. This is used by the deletion executor which only has the Gmail message ID. The permanent flag indicates whether the message was permanently deleted or just trashed.
func (*Store) MessageExistsBatch ¶
func (s *Store) MessageExistsBatch(sourceID int64, sourceMessageIDs []string) (map[string]int64, error)
MessageExistsBatch checks which message IDs already exist in the database. Returns a map of source_message_id -> internal message_id for existing messages.
func (*Store) Rebind ¶
Rebind converts a query with ? placeholders to the appropriate format for the current database driver. Currently SQLite-only (no conversion needed). When PostgreSQL support is added, this will convert ? to $1, $2, etc.
func (*Store) ReplaceMessageLabels ¶
ReplaceMessageLabels replaces all labels for a message.
func (*Store) ReplaceMessageRecipients ¶
func (s *Store) ReplaceMessageRecipients(messageID int64, recipientType string, participantIDs []int64, displayNames []string) error
ReplaceMessageRecipients replaces all recipients for a message.
func (*Store) UpdateSourceSyncCursor ¶
UpdateSourceSyncCursor updates the sync cursor (historyId) for a source.
func (*Store) UpdateSyncCheckpoint ¶
func (s *Store) UpdateSyncCheckpoint(syncID int64, cp *Checkpoint) error
UpdateSyncCheckpoint saves progress for resumption.
func (*Store) UpsertAttachment ¶
func (s *Store) UpsertAttachment(messageID int64, filename, mimeType, storagePath, contentHash string, size int) error
UpsertAttachment stores an attachment record.
func (*Store) UpsertMessage ¶
UpsertMessage inserts or updates a message.
func (*Store) UpsertMessageBody ¶
func (s *Store) UpsertMessageBody(messageID int64, bodyText, bodyHTML sql.NullString) error
UpsertMessageBody stores the body text and HTML for a message in the separate message_bodies table.
type SyncRun ¶
type SyncRun struct {
ID int64
SourceID int64
StartedAt time.Time
CompletedAt sql.NullTime
Status string // "running", "completed", "failed"
MessagesProcessed int64
MessagesAdded int64
MessagesUpdated int64
ErrorsCount int64
ErrorMessage sql.NullString
CursorBefore sql.NullString // Page token for resumption
CursorAfter sql.NullString // Final history ID
}
SyncRun represents a sync operation in progress or completed.
Source Files