history

type CommonConversationManager struct {
	ConversationPersistenceAdapter ConversationPersistenceAdapter
	Summarizer                     core.HistorySummarizer

	Options []ConversationManagerOptions
}

type ConversationManagerOptions func(*CommonConversationManager)

type ConversationPersistenceAdapter interface {
	NewRunID(ctx context.Context) string
	LoadMessages(ctx context.Context, namespace string, previousMessageID string) ([]conversation.ConversationMessage, error)
	SaveMessages(ctx context.Context, namespace, msgId, previousMsgId, conversationId string, messages []responses.InputMessageUnion, meta map[string]any) error
	SaveSummary(ctx context.Context, namespace string, summary conversation.Summary) error
}

type ConversationRunManager struct {
	ConversationPersistenceAdapter

	RunState *core.RunState
	// contains filtered or unexported fields
}

type RunOption func(manager *ConversationRunManager)