messagerepo

type Index struct {
	*opensearch.Client
	IndexName string
}

type Message struct {
	ID          string    `json:"id"`
	MessageID   string    `json:"messageId"`
	SpecVersion string    `json:"specversion"`
	Type        string    `json:"type"`
	Time        time.Time `json:"time"`
	Subject     string    `json:"subject"`
	Source      string    `json:"source"`
	Data        string    `json:"data"`
	ReceivedAt  time.Time `json:"receivedAt"`
}

type MessageUpdate struct {
	Subject *string `json:"subject,omitempty"`
	Data    *string `json:"data,omitempty"`
}

type Store interface {
	// Save persists a chat message.
	Save(ctx context.Context, msg Message) error

	// SearchByID retrieves a chat message by its unique identifier.
	SearchByID(ctx context.Context, id string) (Message, error)

	// Search queries chat messages based on various criteria.
	// Parameters:
	//   - query: text to match within the message subject (if empty, all messages are returned)
	//   - startTime, endTime: optional time range filters for the message timestamp
	//   - filterSource, filterType: optional exact-match filters for source and type fields
	//   - page, pageSize: pagination parameters (page is 1-based; if pageSize==0 then pagination is ignored)
	//   - sortField, sortOrder: sorting parameters (defaults are applied if empty)
	//
	// Returns:
	//   - a slice of messages matching the query
	//   - the total number of matching messages
	//   - the query execution duration in milliseconds
	Search(ctx context.Context, query string, startTime, endTime *time.Time, filterSource, filterType string, page, pageSize int, sortField, sortOrder string) ([]Message, int64, int64, error)

	// Update modifies specified fields of a stored chat message.
	Update(ctx context.Context, id string, update MessageUpdate) error

	// Delete removes a chat message from storage.
	Delete(ctx context.Context, id string) error
}