repositories

Documentation

Index

• type DeviceDefinitionRepository
  • func NewDeviceDefinitionRepository(dbs func() *db.ReaderWriter, ...) DeviceDefinitionRepository
• type DeviceIntegrationRepository
  • func NewDeviceIntegrationRepository(dbs func() *db.ReaderWriter) DeviceIntegrationRepository
• type DeviceMMYJoinQueryOutput
• type DeviceMakeRepository
  • func NewDeviceMakeRepository(dbs func() *db.ReaderWriter) DeviceMakeRepository
• type DeviceStyleRepository
  • func NewDeviceStyleRepository(dbs func() *db.ReaderWriter) DeviceStyleRepository
• type GetDeviceCompatibilityRequest
• type IntegrationsMetadata
• type PowertrainType
  • func (p PowertrainType) String() string
• type VINRepository
  • func NewVINRepository(dbs func() *db.ReaderWriter, registryInstance *contracts.Registry) VINRepository

Types

type DeviceDefinitionRepository

type DeviceDefinitionRepository interface {
	GetByID(ctx context.Context, id string) (*models.DeviceDefinition, error)
	GetByMakeModelAndYears(ctx context.Context, mk string, model string, year int, loadIntegrations bool) (*models.DeviceDefinition, error)
	GetBySlugAndYear(ctx context.Context, slug string, year int, loadIntegrations bool) (*models.DeviceDefinition, error)
	GetBySlugName(ctx context.Context, slug string, loadIntegrations bool) (*models.DeviceDefinition, error)
	GetAll(ctx context.Context) ([]*models.DeviceDefinition, error)
	GetDevicesByMakeYearRange(ctx context.Context, makeID string, yearStart, yearEnd int32) ([]*models.DeviceDefinition, error)
	GetDevicesMMY(ctx context.Context) ([]*DeviceMMYJoinQueryOutput, error)
	GetWithIntegrations(ctx context.Context, id string) (*models.DeviceDefinition, error)
	GetOrCreate(ctx context.Context, tx *sql.Tx, source string, extID string, makeOrID string, model string, year int, deviceTypeID string, metaData null.JSON, verified bool, hardwareTemplateID *string) (*models.DeviceDefinition, error)
	CreateOrUpdate(ctx context.Context, dd *models.DeviceDefinition, deviceStyles []*models.DeviceStyle, deviceIntegrations []*models.DeviceIntegration) (*models.DeviceDefinition, error)
	FetchDeviceCompatibility(ctx context.Context, makeID, integrationID, region, cursor string, size int64) (models.DeviceDefinitionSlice, error)
}

func NewDeviceDefinitionRepository

func NewDeviceDefinitionRepository(dbs func() *db.ReaderWriter, deviceDefinitionOnChainService gateways.DeviceDefinitionOnChainService) DeviceDefinitionRepository

type DeviceIntegrationRepository

type DeviceIntegrationRepository interface {
	Create(ctx context.Context, deviceDefinitionID string, integrationID string, region string, features []map[string]interface{}) (*models.DeviceIntegration, error)
}

func NewDeviceIntegrationRepository

func NewDeviceIntegrationRepository(dbs func() *db.ReaderWriter) DeviceIntegrationRepository

type DeviceMMYJoinQueryOutput

type DeviceMMYJoinQueryOutput struct {
	DefinitionNameSlug string `boil:"definition_name_slug"`
	ModelSlug          string `boil:"model_slug"`
	Year               int16  `boil:"year"`
	MakeSlug           string `boil:"make_name_slug"`
}

type DeviceMakeRepository

type DeviceMakeRepository interface {
	GetAll(ctx context.Context) ([]*models.DeviceMake, error)
	GetBySlug(ctx context.Context, slug string) (*models.DeviceMake, error)
	GetOrCreate(ctx context.Context, makeName string, logURL string, externalIDs string, metadata string, hardwareTemplateID string) (*models.DeviceMake, error)
}

func NewDeviceMakeRepository

func NewDeviceMakeRepository(dbs func() *db.ReaderWriter) DeviceMakeRepository

type DeviceStyleRepository

type DeviceStyleRepository interface {
	Create(ctx context.Context, deviceDefinitionID string, name string, externalStyleID string, source string, subModel string, templateID string) (*models.DeviceStyle, error)
}

func NewDeviceStyleRepository

func NewDeviceStyleRepository(dbs func() *db.ReaderWriter) DeviceStyleRepository

type GetDeviceCompatibilityRequest

type GetDeviceCompatibilityRequest struct {
	MakeID        string `json:"makeId" validate:"required"`
	IntegrationID string `json:"integrationId" validate:"required"`
	Region        string `json:"region" validate:"required"`
	Cursor        string `json:"cursor"`
	Size          int64  `json:"size"`
}

type IntegrationsMetadata

type IntegrationsMetadata struct {
	AutoPiDefaultTemplateID      int                    `json:"autoPiDefaultTemplateId"`
	AutoPiPowertrainToTemplateID map[PowertrainType]int `json:"autoPiPowertrainToTemplateId,omitempty"`
}

IntegrationsMetadata represents json stored in integrations table metadata jsonb column

type PowertrainType

type PowertrainType string

const (
	ICE  PowertrainType = "ICE"
	HEV  PowertrainType = "HEV"
	PHEV PowertrainType = "PHEV"
	BEV  PowertrainType = "BEV"
	FCEV PowertrainType = "FCEV"
)

func (PowertrainType) String

func (p PowertrainType) String() string

type VINRepository

type VINRepository interface {
	GetOrCreateWMI(ctx context.Context, wmi string, mk string) (*models.Wmi, error)
}

func NewVINRepository

func NewVINRepository(dbs func() *db.ReaderWriter, registryInstance *contracts.Registry) VINRepository