thunder

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

type Condition struct {
	Column   string `json:"column"`
	Operator string `json:"operator"`
	Value    string `json:"value,omitempty"`
}

type DbDeleteEvent struct {
	Relation *Relation
	Pkey     string
}

type DbEvent any // DbDeleteEvent | DbInsertEvent | DbPatchEvent | DbTruncateEvent

type DbInsertEvent struct {
	Pkey    string
	Version int
}

type DbPatchEvent struct {
	Relation  *Relation
	Version   int
	Pkey      string
	JsonPatch []byte
}

type DbTruncateEvent struct {
	Relation *Relation
}

type Document struct {
	Pkey    string `json:"_pkey"`
	Version int    `json:"_version"`

	Json []byte `json:"json"`
}

type Exporter interface {
	Name() string
	MimeType() string
	Load(w io.Writer) error
	BeforeAll() error
	WriteDocument(doc *Document, itemPosition uint64) error
	AfterAll() error
}

type JsonConfig struct {
	Sources    []*JsonSource    `json:"sources"`
	Targets    []*JsonTarget    `json:"targets"`
	Processors []*JsonProcessor `json:"processors"`
}

type JsonMapping []JsonMappingField

type JsonMappingField struct {
	FieldType string `json:"_type"`

	// Simple field
	Column string `json:"column,omitempty"`
	Alias  string `json:"alias,omitempty"`

	// Relation
	Name        string   `json:"name,omitempty"`
	Type        string   `json:"type,omitempty"`
	Table       string   `json:"table,omitempty"`
	PrimaryKeys []string `json:"primary_keys,omitempty"`
	LocalKey    string   `json:"local_key,omitempty"`

	UsePivotTable   bool               `json:"use_pivot_table,omitempty"`
	PivotTable      string             `json:"pivot_table,omitempty"`
	ForeignPivotKey string             `json:"foreign_pivot_key,omitempty"`
	LocalPivotKey   string             `json:"local_pivot_key,omitempty"`
	PivotFields     []JsonMappingField `json:"pivot_fields,omitempty"`

	ForeignKey string `json:"foreign_key,omitempty"`

	Mapping JsonMapping `json:"mapping,omitempty"`
}

type JsonProcessor struct {
	ID string `json:"ID"`

	Source  string   `json:"source"`  // as source_id
	Targets []string `json:"targets"` // as targets_id

	Table       string      `json:"table"`
	PrimaryKeys []string    `json:"primary_keys"`
	Conditions  []Condition `json:"conditions"`

	Mapping JsonMapping `json:"mapping"`

	Index string `json:"index"`

	Enabled bool `json:"enabled"`
}

type JsonSource struct {
	ID     string `json:"id"`
	Driver string `json:"driver"`
	Config any    `json:"config"`
}

type JsonTarget struct {
	ID     string `json:"id"`
	Driver string `json:"driver"`
	Config any    `json:"config"`
}

type Mapping struct {
	Fields    []SimpleField
	Relations []Relation
}

type Module interface {
	RequiredModules() []string

	New() Module

	Start() error
	Stop() error
}

type Processor struct {
	ID string

	Indexing atomic.Bool

	Listening         atomic.Bool
	ListenBroadcaster *utils.Broadcaster[DbEvent, TargetEvent]

	Source  *Source
	Targets []*Target

	Table       string
	PrimaryKeys []string
	Conditions  []Condition

	Mapping Mapping

	Index string

	Enabled bool
}

type Relation struct {
	Name string

	Many bool

	Table       string
	PrimaryKeys []string

	LocalKey   string
	Pivot      *RelationPivot
	ForeignKey string

	Mapping Mapping

	// Recursive navigation
	Parent   *Relation
	Children []*Relation
}

type RelationPivot struct {
	Table      string
	LocalKey   string
	ForeignKey string

	Fields []SimpleField
}

type SimpleField struct {
	Column string
	Name   *string // Use Column as Name if empty or nil
}

type Source struct {
	ID     string
	Driver SourceDriver
	Config utils.DynamicConfig
}

type SourceDriver interface {
	ID() string

	New(config any) (SourceDriver, error)

	Config() SourceDriverConfig

	TestConfig() (string, error) // TODO USELESS REPLACE IN FAVOR OF STATS TO CHECK NOT EMPTY
	Stats() (*SourceDriverStats, error)

	// GetDocumentsForProcessor use limit=0 to unlimited
	GetDocumentsForProcessor(processor *Processor, in chan<- *Document, ctx context.Context, limit uint64) error

	Start(processor *Processor, in utils.BroadcasterIn[DbEvent]) error
	Stop() error
}

type SourceDriverConfig struct {
	Name   string              `json:"name"`
	Config utils.DynamicConfig `json:"-"`

	// As inlined SVG
	Image string   `json:"image,omitempty"`
	Notes []string `json:"notes,omitempty"`
}

type SourceDriverStats map[string]SourceDriverStatsTable

type SourceDriverStatsTable struct {
	Columns     []string `json:"columns"`
	PrimaryKeys []string `json:"primary_keys"`
}

type Target struct {
	ID     string
	Driver TargetDriver
	Config utils.DynamicConfig
}

type TargetDeleteEvent struct {
	Relation *Relation
	Pkey     string
}

type TargetDriver interface {
	ID() string

	New(config any) (TargetDriver, error)

	Config() TargetDriverConfig

	TestConfig() (string, error) // TODO USELESS REPLACE IN FAVOR OF STATS TO CHECK NOT EMPTY

	HandleEvents(processor *Processor, eventsChan <-chan TargetEvent) error

	Shutdown() error
}

type TargetDriverConfig struct {
	Name   string              `json:"name"`
	Config utils.DynamicConfig `json:"-"`

	// As inlined SVG
	Image string   `json:"image,omitempty"`
	Notes []string `json:"notes,omitempty"`
}

type TargetEvent any // TargetDeleteEvent | TargetInsertEvent | TargetPatchEvent | TargetTruncateEvent

type TargetInsertEvent struct {
	Pkey    string
	Version int
	Json    []byte
}

type TargetPatchEvent struct {
	Relation  *Relation
	Pkey      string
	Version   int
	JsonPatch []byte
}

type TargetTruncateEvent struct {
	Relation *Relation
}