cosmosdb

type ConfigProvider interface {
	GetCosmosDBSettings() Settings
}

type ContainerInfo struct {
	ID               string
	RID              string
	PartitionKeyPath string
}

type ContainerSpec struct {
	ID               string
	PartitionKeyPath string
}

type DatabaseInfo struct {
	ID  string
	RID string
}

type DocumentInfo struct {
	Timestamp        time.Time
	Body             map[string]any
	ID               string
	RID              string
	Self             string
	ETag             string
	PartitionKeyJSON string
}

type Handler struct {
	Backend StorageBackend
	// TableBackend holds Table API tables/entities -- a completely
	// independent odatatable.InMemoryBackend instance from Backend's own
	// database/container/document state (see table_api.go and AZURE.md
	// section 9's M6 milestone). It is not yet included in
	// Handler.Snapshot/Restore's persistence lifecycle -- see PARITY.md's
	// Table API addendum.
	TableBackend *odatatable.InMemoryBackend

	// MasterKey is the base64-encoded master key checkAuth verifies
	// against when ValidateAuth is true.
	MasterKey string
	// Port is the TCP port StartWorker binds. Set from Settings at Init time
	// (see provider.go); defaults to DefaultPort. Like services/azuretable,
	// this is a single fixed, protocol-conventional port -- no fallback
	// pool, so StartWorker fails fast if it's unavailable.
	Port int
	// ValidateAuth opts into cryptographic master-key signature
	// verification. See masterkey.go and checkAuth.
	ValidateAuth bool
	// contains filtered or unexported fields
}

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

type Provider struct{}

type QueryParameter struct {
	Value any    `json:"value"`
	Name  string `json:"name"`
}

type Settings struct {
	// MasterKey is the base64-encoded master key checkAuth verifies request
	// signatures against when ValidateAuth is true. Defaults to the real
	// emulator's own well-known key (DefaultMasterKey).
	MasterKey string `` //nolint:lll // config struct tags are intentionally verbose
	/* 248-byte string literal not displayed */
	// Port is the fixed TCP port for the dedicated Cosmos DB listener. See
	// handler.go's StartWorker for what happens when it's unavailable
	// (fails fast; no fallback pool, matching services/azureblob,
	// services/azurequeue, and services/azuretable).
	Port int `` //nolint:lll // config struct tags are intentionally verbose
	/* 172-byte string literal not displayed */
	// ValidateAuth opts into cryptographic master-key signature
	// verification of the Authorization header (opt-in, off by default --
	// mirrors services/s3's WithPresignValidation and pkgs/azureauth's
	// VerifySharedKey opt-in pattern). See masterkey.go.
	ValidateAuth bool `` //nolint:lll // config struct tags are intentionally verbose
	/* 169-byte string literal not displayed */
}

type StorageBackend interface {
	CreateDatabase(id string) (DatabaseInfo, error)
	GetDatabase(id string) (DatabaseInfo, error)
	ListDatabases() []DatabaseInfo
	DeleteDatabase(id string) error

	CreateContainer(dbID string, spec ContainerSpec) (ContainerInfo, error)
	GetContainer(dbID, containerID string) (ContainerInfo, error)
	ListContainers(dbID string) ([]ContainerInfo, error)
	DeleteContainer(dbID, containerID string) error

	// CreateDocument creates (or, if upsert, inserts-or-replaces) a document
	// in containerID. The document's partition key value is derived from
	// body per the container's declared partition key path; body's "id"
	// field is used verbatim if present (a non-string "id" is rejected), or
	// generated if absent.
	CreateDocument(dbID, containerID string, body map[string]any, upsert bool) (DocumentInfo, error)
	GetDocument(dbID, containerID, partitionKey, id string) (DocumentInfo, error)
	ReplaceDocument(
		dbID, containerID, partitionKey, id string, body map[string]any, ifMatch string,
	) (DocumentInfo, error)
	DeleteDocument(dbID, containerID, partitionKey, id, ifMatch string) error
	// ListDocuments returns every document in containerID, ordered by ID,
	// for both the read-feed (GET .../docs) and the SQL query engine's FROM
	// clause. Cross-partition: it is not filtered by partition key.
	ListDocuments(dbID, containerID string) ([]DocumentInfo, error)

	// Reset clears all in-memory state. Used by the
	// POST /_gopherstack/reset endpoint for CI pipelines and rapid local development.
	Reset()
}