query

type Backend string

type Block struct {
	ID        string          `json:"id"`
	ParentID  string          `json:"parent_id"`
	Height    uint64          `json:"height"`
	Timestamp time.Time       `json:"timestamp"`
	Status    string          `json:"status"`
	TxCount   int             `json:"tx_count"`
	TxIDs     []string        `json:"tx_ids"`
	Data      json.RawMessage `json:"data"`
	Metadata  json.RawMessage `json:"metadata"`
	CreatedAt time.Time       `json:"created_at"`
}

type Column struct {
	Name     string
	Type     ColumnType
	Nullable bool
	Default  string
	Primary  bool
}

type ColumnType string

type Config struct {
	Backend  Backend
	URL      string            // Connection URL
	Database string            // Database name (for MongoDB)
	DataDir  string            // For file-based backends
	Options  map[string]string // Backend-specific options
}

type Edge struct {
	Source    string    `json:"source"`
	Target    string    `json:"target"`
	Type      string    `json:"type"`
	CreatedAt time.Time `json:"created_at"`
}

type Engine interface {
	// Backend returns the backend type (sqlite, postgres, etc.)
	Backend() Backend

	// Lifecycle
	Init(ctx context.Context) error
	Close() error
	Ping(ctx context.Context) error

	// Schema management
	InitSchema(ctx context.Context, schema Schema) error
	Migrate(ctx context.Context, schema Schema) error

	// Block queries
	InsertBlock(ctx context.Context, table string, block *Block) error
	GetBlock(ctx context.Context, table string, id string) (*Block, error)
	GetBlockByHeight(ctx context.Context, table string, height uint64) (*Block, error)
	GetRecentBlocks(ctx context.Context, table string, limit int) ([]*Block, error)
	GetBlockRange(ctx context.Context, table string, start, end uint64) ([]*Block, error)

	// Vertex queries
	InsertVertex(ctx context.Context, table string, vertex *Vertex) error
	GetVertex(ctx context.Context, table string, id string) (*Vertex, error)
	GetRecentVertices(ctx context.Context, table string, limit int) ([]*Vertex, error)
	GetVerticesByEpoch(ctx context.Context, table string, epoch uint32) ([]*Vertex, error)

	// Edge queries
	InsertEdge(ctx context.Context, table string, edge *Edge) error
	GetEdges(ctx context.Context, table string, vertexID string) ([]*Edge, error)
	GetIncomingEdges(ctx context.Context, table string, vertexID string) ([]*Edge, error)

	// Generic queries
	Query(ctx context.Context, query string, args ...interface{}) ([]Row, error)
	Exec(ctx context.Context, query string, args ...interface{}) (Result, error)

	// Aggregations
	Count(ctx context.Context, table string, where string, args ...interface{}) (int64, error)
	Sum(ctx context.Context, table string, column, where string, args ...interface{}) (float64, error)

	// Transaction support
	Begin(ctx context.Context) (Tx, error)
}

type Index struct {
	Name    string
	Table   string
	Columns []string
	Unique  bool
}

type Result struct {
	RowsAffected int64
	LastInsertID int64
}

type Row map[string]interface{}

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

type Schema struct {
	Name    string
	Tables  []Table
	Indexes []Index
}

type Table struct {
	Name    string
	Columns []Column
}

type Tx interface {
	Engine
	Commit() error
	Rollback() error
}

type Vertex struct {
	ID        string          `json:"id"`
	Type      string          `json:"type"`
	ParentIDs []string        `json:"parent_ids"`
	Height    uint64          `json:"height"`
	Epoch     uint32          `json:"epoch"`
	TxIDs     []string        `json:"tx_ids"`
	Timestamp time.Time       `json:"timestamp"`
	Status    string          `json:"status"`
	Data      json.RawMessage `json:"data"`
	Metadata  json.RawMessage `json:"metadata"`
	CreatedAt time.Time       `json:"created_at"`
}