dbsync

type DBSyncConfig struct {
	WatchConfig bool `default:"true" yaml:"watchConfig"`

	StateFile string `default:"dbsync.state.yaml" yaml:"stateFile"`

	Destination DBSyncDestination `yaml:"destination"`
	Source      DBSyncSource      `yaml:"source"`

	Tables DBSyncSourceTables `yaml:"tables"`
}

type DBSyncDestination struct {
	URL      string `yaml:"url"`
	Token    string `yaml:"token"`
	Insecure bool   `yaml:"insecure"`

	SyncInterval time.Duration `default:"5s" yaml:"syncInterval"`
}

type DBSyncSource struct {
	// Refer to https://github.com/go-sql-driver/mysql#dsn-data-source-name for details
	DSN string `yaml:"dsn"`
}

type DBSyncSourceTables struct {
	Jobs      DBSyncTable `yaml:"jobs"`
	JobGrades DBSyncTable `yaml:"jobGrades"`
	Licenses  DBSyncTable `yaml:"licenses"`

	Users        UsersDBSyncTable `yaml:"users"`
	UserLicenses DBSyncTable      `yaml:"userLicenses"`
	Vehicles     DBSyncTable      `yaml:"vehicles"`
}

type DBSyncState struct {
	Jobs      *TableSyncState `yaml:"jobs"`
	JobGrades *TableSyncState `yaml:"jobGrades"`
	Licenses  *TableSyncState `yaml:"licenses"`

	Users         *TableSyncState `yaml:"users"`
	OwnedVehicles *TableSyncState `yaml:"ownedVehicles"`
	// contains filtered or unexported fields
}

type DBSyncTable struct {
	Enabled           bool           `yaml:"enabled"`
	UpdatedTimeColumn *string        `yaml:"updatedTimeColumn"`
	Query             string         `yaml:"query"`
	SyncInterval      *time.Duration `yaml:"syncInterval"`
}

type DBSyncTableSyncInterval interface {
	GetSyncInterval() *time.Duration
}

type DateOfBirthNormalizer struct {
	Formats      []string `yaml:"formats"`
	OutputFormat string   `default:"" yaml:"output"`
}

type Params struct {
	fx.In

	LC         fx.Lifecycle
	Shutdowner fx.Shutdowner

	Logger *zap.Logger
	Config *config.Config
}

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

type TableSyncState struct {
	LastCheck *time.Time `yaml:"lastCheck"`
	Offset    uint64     `yaml:"offset"`
	LastID    *string    `yaml:"lastId"`
	SyncedUp  bool       `yaml:"syncedUp"`
	// contains filtered or unexported fields
}

type UsersDBSyncTable struct {
	DBSyncTable `yaml:",inline" mapstructure:",squash"`

	SplitName    bool                  `default:"false" yaml:"splitName"`
	DateOfBirth  DateOfBirthNormalizer `yaml:"dateOfBirth"`
	ValueMapping *UsersValueMappings   `yaml:"valueMapping"`
}

type UsersValueMappings struct {
	Sex *ValueMapping `yaml:"sex"`
}

type ValueMapping struct {
	Fallback *string           `yaml:"fallback"`
	Values   map[string]string `yaml:"values"`
}