schemalog

type Column struct {
	Name          string  `json:"name"`
	DataType      string  `json:"type"`
	DefaultValue  *string `json:"default,omitempty"`
	Nullable      bool    `json:"nullable"`
	Generated     bool    `json:"generated"`
	GeneratedKind string  `json:"generated_kind,omitempty"`
	Identity      string  `json:"identity,omitempty"`
	Unique        bool    `json:"unique"`
	// Metadata is NOT typed here because we don't fully control the content that is sent from the publisher.
	Metadata   *string `json:"metadata"`
	PgstreamID string  `json:"pgstream_id"`
}

type ColumnDiff struct {
	ColumnName       string
	ColumnPgstreamID string
	NameChange       *ValueChange[string]
	TypeChange       *ValueChange[string]
	UniqueChange     *ValueChange[bool]
	NullChange       *ValueChange[bool]
	DefaultChange    *ValueChange[*string]
	GeneratedChange  *ValueChange[bool]
	IdentityChange   *ValueChange[string]
}

type Constraint struct {
	Name       string `json:"name"`
	Type       string `json:"type"`
	Definition string `json:"definition"`
}

type Diff struct {
	TablesRemoved            []Table
	TablesAdded              []Table
	TablesChanged            []TableDiff
	MaterializedViewsRemoved []MaterializedView
	MaterializedViewsAdded   []MaterializedView
	MaterializedViewsChanged []MaterializedViewsDiff
}

type ForeignKey struct {
	Name       string `json:"name"`
	Definition string `json:"definition"`
}

type Index struct {
	Name       string   `json:"name"`
	Columns    []string `json:"columns"`
	Unique     bool     `json:"unique"`
	Definition string   `json:"definition"`
}

type LogEntry struct {
	ID         xid.ID                   `json:"id"`
	Version    int64                    `json:"version"`
	SchemaName string                   `json:"schema_name"`
	CreatedAt  SchemaCreatedAtTimestamp `json:"created_at"`
	Schema     Schema                   `json:"schema"`
	// Acked indicates if the schema has been processed and acknowledged by
	// pgstream after being updated in the source database
	Acked bool `json:"acked"`
}

type MaterializedView struct {
	Oid        string  `json:"oid"`
	Name       string  `json:"name"`
	Definition string  `json:"definition"`
	Indexes    []Index `json:"indexes,omitempty"`
}

type MaterializedViewsDiff struct {
	MaterializedViewName string
	NameChange           *ValueChange[string]
	IndexesAdded         []Index
	IndexesRemoved       []Index
	IndexesChanged       []string
}

type Schema struct {
	Tables            []Table            `json:"tables"`
	MaterializedViews []MaterializedView `json:"materialized_views,omitempty"`
	// Dropped will be true if the schema has been deleted
	Dropped bool `json:"dropped,omitempty"`
}

type SchemaCreatedAtTimestamp struct {
	time.Time
}

type Store interface {
	Insert(ctx context.Context, schemaName string) (*LogEntry, error)
	FetchLast(ctx context.Context, schemaName string, ackedOnly bool) (*LogEntry, error)
	Fetch(ctx context.Context, schemaName string, version int) (*LogEntry, error)
	Ack(ctx context.Context, le *LogEntry) error
	Close() error
}

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

type Table struct {
	Oid               string       `json:"oid"`
	Name              string       `json:"name"`
	Columns           []Column     `json:"columns"`
	PrimaryKeyColumns []string     `json:"primary_key_columns"`
	Indexes           []Index      `json:"indexes"`
	Constraints       []Constraint `json:"constraints"`
	ForeignKeys       []ForeignKey `json:"foreign_keys"`
	// PgstreamID is a unique identifier of the table generated by pgstream
	PgstreamID string `json:"pgstream_id"`
}

type TableDiff struct {
	TableName             string
	TablePgstreamID       string
	TableNameChange       *ValueChange[string]
	TablePrimaryKeyChange *ValueChange[[]string]
	ColumnsAdded          []Column
	ColumnsRemoved        []Column
	ColumnsChanged        []ColumnDiff
	IndexesAdded          []Index
	IndexesRemoved        []Index
	IndexesChanged        []string
	ConstraintsAdded      []Constraint
	ConstraintsRemoved    []Constraint
	ForeignKeysAdded      []ForeignKey
	ForeignKeysRemoved    []ForeignKey
}

type ValueChange[T any] struct {
	Old, New T
}