api

type BucketRequest struct {
	Name  string `json:"name"`
	After string `json:"after"`
}

type Client interface {
	SyncStream(ctx context.Context, req *SyncStreamRequest, handler LineHandler) error
	GetWriteCheckpoint(ctx context.Context, clientID string) (string, error)
	SetToken(token string)
}

type Error struct {
	Kind       ErrorKind
	StatusCode int
	Message    string
	Err        error
}

type ErrorKind int

type HTTPDoer interface {
	Do(req *http.Request) (*http.Response, error)
}

type LineHandler func(line []byte) error

type RequestedStreamSubscription struct {
	Stream           string `json:"stream"`
	Parameters       string `json:"parameters,omitempty"`
	OverridePriority *int   `json:"override_priority,omitempty"`
}

type SchemaColumn struct {
	Name string `json:"name"`
	Type string `json:"type"` // "text", "integer", "real"
}

type SchemaTable struct {
	Name    string         `json:"name"`
	Columns []SchemaColumn `json:"columns"`
}

type StreamSubscription struct {
	IncludeDefaults bool                          `json:"include_defaults"`
	Subscriptions   []RequestedStreamSubscription `json:"subscriptions"`
}

type SyncStreamRequest struct {
	Buckets         []BucketRequest     `json:"buckets"`
	IncludeChecksum bool                `json:"include_checksum"`
	RawData         bool                `json:"raw_data"`
	BinaryData      bool                `json:"binary_data"`
	ClientID        string              `json:"client_id"`
	Parameters      map[string]any      `json:"parameters,omitempty"`
	Streams         *StreamSubscription `json:"streams,omitempty"`
	AppMetadata     json.RawMessage     `json:"app_metadata,omitempty"`
}