conversationstore

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

type MemoryStoreOption func(*MemoryStore)

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

type Result struct {
	Store Store
}

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

type Store interface {
	Create(ctx context.Context, conversation *StoredConversation) error
	Get(ctx context.Context, id string) (*StoredConversation, error)
	// MergeMetadata atomically overlays metadata without rewriting items that a
	// concurrently completing Responses turn may be appending.
	MergeMetadata(ctx context.Context, id string, metadata map[string]string) (*StoredConversation, error)
	// AppendItems atomically appends items to an existing conversation, so two
	// concurrently completing turns cannot overwrite each other's exchange the
	// way a Get-then-Update would.
	AppendItems(ctx context.Context, id string, items []json.RawMessage) error
	// DeleteItem atomically removes one item and returns the updated snapshot.
	DeleteItem(ctx context.Context, id, itemID string) (*StoredConversation, error)
	Delete(ctx context.Context, id string) error
	Close() error
}

type StoredConversation struct {
	Conversation *core.Conversation `json:"conversation"`
	Items        []json.RawMessage  `json:"items,omitempty"`
	UserPath     string             `json:"user_path,omitempty"`
	RequestID    string             `json:"request_id,omitempty"`
	StoredAt     time.Time          `json:"stored_at"`
	ExpiresAt    time.Time          `json:"expires_at"`
}