flash

type Client struct {
	Config *ClientConfig
	// contains filtered or unexported fields
}

type ClientConfig struct {
	DatabaseCnx string
	Driver      Driver
	Logger      *zerolog.Logger

	ShutdownTimeout time.Duration
}

type CreateEventCallback func(event Operation) error

type DatabaseEvent struct {
	ListenerUid string
	Event       Event
}

type DatabaseEventsChan chan *DatabaseEvent

type DeleteEvent struct {
	Old *EventData
}

type DeleteEventCallback func(event Operation) error

type Driver interface {
	Init(clientConfig *ClientConfig) error
	Close() error

	HandleOperationListenStart(listenerUid string, listenerConfig *ListenerConfig, operation Operation) error
	HandleOperationListenStop(listenerUid string, listenerConfig *ListenerConfig, operation Operation) error
	Listen(eventsChan *DatabaseEventsChan) error
}

type DriverTestConfig struct {
	ImagesVersions []string `default:"postgres,flash"`

	Database string
	Username string
	Password string

	ContainerCustomizers []testcontainers.ContainerCustomizer

	PropagationTimeout  time.Duration // Delay for event propagated from the DB to the eventsChan
	RegistrationTimeout time.Duration // Delay for OperationListenStart / HandleOperationListenStop

	Parallel bool
}

type Event interface {
	GetOperation() Operation
}

type EventCallback func(event Event)

type EventData map[string]any

type ExecSqlFunc func(t *testing.T, sql string) string

type InsertEvent struct {
	New *EventData
}

type Listener struct {
	Config *ListenerConfig

	// Internals
	sync.Mutex
	// contains filtered or unexported fields
}

type ListenerCondition struct {
	Column string
	//Operator string //TODO actually only equals are implemented
	Value any
}

type ListenerConfig struct {
	Table              string   // Can be prefixed by schema - e.g: public.posts
	Fields             []string // Empty fields means all ( SELECT * )
	MaxParallelProcess int      // Default to 1 (not parallel) -> use -1 for Infinity

	Conditions []*ListenerCondition
}

type Operation uint8

type TestFn func(t *testing.T, name string, f func(t *testing.T), restore bool)

type TruncateEvent struct{}

type UpdateEvent struct {
	Old *EventData
	New *EventData
}