fixture

type CommandDependency struct {
	Label    [2]string
	Callback func() (any, error)
}

type CommandFunc func(in *CommandInput) (*CommandOutput, error)

type CommandInput struct {
	Fixture *Fixture
	Table   string
	Key     string
	Field   string

	Line string
}

type CommandOutput struct {
	Dependencies []*CommandDependency
	IsUpdate     bool
	Value        any
}

type Config struct {
	// The default name for the primary key field.
	// This value can be overwritten by TableOptions.
	// Default: "id"
	PrimaryKeyName string

	// The default references for all tables.
	// Can be overwritten by TableOptions.
	References map[string]string

	// Whether to write records asynchronously or synchronously.
	// Default: WriteAsync
	WriteMode int

	// TableOptions can be used to set table specific options or
	// create multiple profiles for the same table. E.g.:
	//
	// 	tableOptions := map[string]*fixture.TableOptions{
	// 		"foo": {
	// 			DefaultValues: fixture.Record{
	// 				"bar": "default value",
	// 			},
	// 		},
	// 		"foo#profile2": {
	// 			TableName:     "foo",
	// 			DefaultValues: fixture.Record{
	// 				"bar": "profile2 value",
	// 			},
	// 		},
	// 	}
	TableOptions map[string]*TableOptions
	// contains filtered or unexported fields
}

type Database map[string]Table

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

type Fixture struct {
	Context context.Context
	Logger  *zerolog.Logger

	// Config are a set of parameters that can be reused across fixtures,
	// and should only be set once.
	Config *Config

	// The writer used for this runner.
	Writer Writer

	// The directory where fixture files are located.
	// If non-empty, will be prepended to File.
	Dir string

	// TODO: Should check for one of?
	File       string
	Body       io.Reader
	BodyFormat string

	// Database can be used to set an initial database state.
	// Any records defined in the File/Body will be merged with
	// the ones defined here.
	Database Database

	// If defined, the fixture body will be parsed as a Go text/template string
	// and executed with TemplateData as its data.
	TemplateData map[string]any

	PrintJSON               bool
	DoNotCreateDependencies bool
	// contains filtered or unexported fields
}

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

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

type PostgresWriter struct {
	Conn   *pgxpool.Pool
	Tx     pgx.Tx
	GormDB *gorm.DB
}

type Record map[string]any

type RecordError struct {
	Table string
	Key   string
	Field string
	Err   error
}

type RedisWriter struct {
	Client *redis.Client
}

type Table map[string]Record

type TableOptions struct {
	TableName      string
	PrimaryKeyName string
	References     map[string]string
	WriteMode      int
	DefaultValues  Record
	BeforeWrite    func(ctx context.Context, record Record) error
}

type Writer interface {
	Insert(f *Fixture, table, key string, record Record) error
	Update(f *Fixture, table, key string, record Record) error
}