commands

package
v0.2.5 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 27, 2022 License: Apache-2.0 Imports: 37 Imported by: 0

Documentation

Index

Constants

View Source
const NHTSARecallsMatchingVersion = "2022.10.20.0"

NHTSARecallsMatchingVersion is a YYYY.MM.DD.N version used for matching. Update this version if you change how matching works and existing matches will be rematched.

Variables

This section is empty.

Functions

This section is empty.

Types

type CreateDeviceDefinitionCommand

type CreateDeviceDefinitionCommand struct {
	Source string `json:"source"`
	Make   string `json:"make"`
	Model  string `json:"model"`
	Year   int    `json:"year"`
	// DeviceTypeID comes from the device_types.id table, determines what kind of device this is, typically a vehicle
	DeviceTypeID string `json:"device_type_id"`
	// DeviceAttributes sets definition metadata eg. vehicle info. Allowed key/values are defined in device_types.properties
	DeviceAttributes []*coremodels.UpdateDeviceTypeAttribute `json:"deviceAttributes"`
}

func (*CreateDeviceDefinitionCommand) Key

type CreateDeviceDefinitionCommandHandler

type CreateDeviceDefinitionCommandHandler struct {
	Repository repositories.DeviceDefinitionRepository
	DBS        func() *db.ReaderWriter
}

func (CreateDeviceDefinitionCommandHandler) Handle

func (ch CreateDeviceDefinitionCommandHandler) Handle(ctx context.Context, query mediator.Message) (interface{}, error)

type CreateDeviceDefinitionCommandResult

type CreateDeviceDefinitionCommandResult struct {
	ID string `json:"id"`
}

type CreateDeviceIntegrationCommand

type CreateDeviceIntegrationCommand struct {
	DeviceDefinitionID string `json:"device_definition_id"`
	IntegrationID      string `json:"integration_id"`
	Region             string `json:"region"`
}

func (*CreateDeviceIntegrationCommand) Key

type CreateDeviceIntegrationCommandHandler

type CreateDeviceIntegrationCommandHandler struct {
	Repository repositories.DeviceIntegrationRepository
}

func (CreateDeviceIntegrationCommandHandler) Handle

func (ch CreateDeviceIntegrationCommandHandler) Handle(ctx context.Context, query mediator.Message) (interface{}, error)

type CreateDeviceIntegrationCommandResult

type CreateDeviceIntegrationCommandResult struct {
	ID string `json:"id"`
}

type CreateDeviceMakeCommand added in v0.1.26

type CreateDeviceMakeCommand struct {
	Name    string `json:"name"`
	LogoURL string `json:"logo_url"`
}

func (*CreateDeviceMakeCommand) Key added in v0.1.26

type CreateDeviceMakeCommandHandler added in v0.1.26

type CreateDeviceMakeCommandHandler struct {
	Repository repositories.DeviceMakeRepository
}

func NewCreateDeviceMakeCommandHandler added in v0.1.26

func NewCreateDeviceMakeCommandHandler(repository repositories.DeviceMakeRepository) CreateDeviceMakeCommandHandler

func (CreateDeviceMakeCommandHandler) Handle added in v0.1.26

func (ch CreateDeviceMakeCommandHandler) Handle(ctx context.Context, query mediator.Message) (interface{}, error)

type CreateDeviceMakeCommandResult added in v0.1.26

type CreateDeviceMakeCommandResult struct {
	ID string `json:"id"`
}

type CreateDeviceStyleCommand added in v0.1.11

type CreateDeviceStyleCommand struct {
	DeviceDefinitionID string `json:"device_definition_id"`
	Name               string `json:"name"`
	ExternalStyleID    string `json:"external_style_id"`
	Source             string `json:"source"`
	SubModel           string `json:"sub_model"`
}

func (*CreateDeviceStyleCommand) Key added in v0.1.11

type CreateDeviceStyleCommandHandler added in v0.1.11

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

func (CreateDeviceStyleCommandHandler) Handle added in v0.1.11

func (ch CreateDeviceStyleCommandHandler) Handle(ctx context.Context, query mediator.Message) (interface{}, error)

type CreateDeviceStyleCommandResult added in v0.1.11

type CreateDeviceStyleCommandResult struct {
	ID string `json:"id"`
}

type CreateDeviceTypeCommand added in v0.2.3

type CreateDeviceTypeCommand struct {
	ID   string `json:"id"`
	Name string `json:"name"`
}

func (*CreateDeviceTypeCommand) Key added in v0.2.3

type CreateDeviceTypeCommandHandler added in v0.2.3

type CreateDeviceTypeCommandHandler struct {
	DBS func() *db.ReaderWriter
}

func NewCreateDeviceTypeCommandHandler added in v0.2.3

func NewCreateDeviceTypeCommandHandler(dbs func() *db.ReaderWriter) CreateDeviceTypeCommandHandler

func (CreateDeviceTypeCommandHandler) Handle added in v0.2.3

func (ch CreateDeviceTypeCommandHandler) Handle(ctx context.Context, query mediator.Message) (interface{}, error)

type CreateDeviceTypeCommandResult added in v0.2.3

type CreateDeviceTypeCommandResult struct {
	ID string `json:"id"`
}

type CreateIntegrationCommand added in v0.1.28

type CreateIntegrationCommand struct {
	Vendor string `json:"vendor"`
	Type   string `json:"type"`
	Style  string `json:"style"`
}

func (*CreateIntegrationCommand) Key added in v0.1.28

type CreateIntegrationCommandHandler added in v0.1.28

type CreateIntegrationCommandHandler struct {
	DBS func() *db.ReaderWriter
}

func NewCreateIntegrationCommandHandler added in v0.1.28

func NewCreateIntegrationCommandHandler(dbs func() *db.ReaderWriter) CreateIntegrationCommandHandler

func (CreateIntegrationCommandHandler) Handle added in v0.1.28

func (ch CreateIntegrationCommandHandler) Handle(ctx context.Context, query mediator.Message) (interface{}, error)

type CreateIntegrationCommandResult added in v0.1.28

type CreateIntegrationCommandResult struct {
	ID string `json:"id"`
}

type DeleteDeviceTypeCommand added in v0.2.3

type DeleteDeviceTypeCommand struct {
	ID string `json:"id"`
}

func (*DeleteDeviceTypeCommand) Key added in v0.2.3

type DeleteDeviceTypeCommandHandler added in v0.2.3

type DeleteDeviceTypeCommandHandler struct {
	DBS func() *db.ReaderWriter
}

func NewDeleteDeviceTypeCommandHandler added in v0.2.3

func NewDeleteDeviceTypeCommandHandler(dbs func() *db.ReaderWriter) DeleteDeviceTypeCommandHandler

func (DeleteDeviceTypeCommandHandler) Handle added in v0.2.3

func (ch DeleteDeviceTypeCommandHandler) Handle(ctx context.Context, query mediator.Message) (interface{}, error)

type DeleteDeviceTypeCommandResult added in v0.2.3

type DeleteDeviceTypeCommandResult struct {
	ID string `json:"id"`
}

type NHTSARecallMetadata added in v0.2.4

type NHTSARecallMetadata struct {
	MatchingVersion string   `json:"matchingVersion,omitempty"`
	MatchType       string   `json:"matchType,omitempty"`
	MatchedMake     []string `json:"matchedMake,omitempty"`
	MatchedModel    []string `json:"matchedModel,omitempty"`
	AdditionalData  []string `json:"additionalData,omitempty"`
}

type SyncIPFSDataCommand

type SyncIPFSDataCommand struct {
}

func (*SyncIPFSDataCommand) Key

func (*SyncIPFSDataCommand) Key() string

type SyncIPFSDataCommandHandler

type SyncIPFSDataCommandHandler struct {
	DBS          func() *db.ReaderWriter
	IPFSEndpoint string
}

func NewSyncIPFSDataCommandHandler

func NewSyncIPFSDataCommandHandler(dbs func() *db.ReaderWriter, IPFSEndpoint string) SyncIPFSDataCommandHandler

func (SyncIPFSDataCommandHandler) Handle

func (ch SyncIPFSDataCommandHandler) Handle(ctx context.Context, query mediator.Message) (interface{}, error)

type SyncIPFSDataCommandResult

type SyncIPFSDataCommandResult struct {
}

type SyncNHTSARecallsCommand added in v0.2.4

type SyncNHTSARecallsCommand struct {
}

func (*SyncNHTSARecallsCommand) Key added in v0.2.4

type SyncNHTSARecallsCommandHandler added in v0.2.4

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

func NewSyncNHTSARecallsCommandHandler added in v0.2.4

func NewSyncNHTSARecallsCommandHandler(dbs func() *db.ReaderWriter, logger *zerolog.Logger, recallsRepo repositories.DeviceNHTSARecallsRepository, ddRepo repositories.DeviceDefinitionRepository, file *string) SyncNHTSARecallsCommandHandler

func (SyncNHTSARecallsCommandHandler) DownloadFileToTemp added in v0.2.4

func (ch SyncNHTSARecallsCommandHandler) DownloadFileToTemp(filename string, url string) (localpath *string, err error)

func (SyncNHTSARecallsCommandHandler) Handle added in v0.2.4

func (ch SyncNHTSARecallsCommandHandler) Handle(ctx context.Context, query mediator.Message) (interface{}, error)

type SyncNHTSARecallsCommandResult added in v0.2.4

type SyncNHTSARecallsCommandResult struct {
	InsertedCount int `json:"insertedCount"`
	MatchCount    int `json:"matchCount"`
}

type SyncSearchDataCommand

type SyncSearchDataCommand struct {
}

func (*SyncSearchDataCommand) Key

type SyncSearchDataCommandHandler

type SyncSearchDataCommandHandler struct {
	DBS func() *db.ReaderWriter
	// contains filtered or unexported fields
}

func NewSyncSearchDataCommandHandler

func NewSyncSearchDataCommandHandler(dbs func() *db.ReaderWriter, esSvc elastic.SearchService, logger zerolog.Logger) SyncSearchDataCommandHandler

func (SyncSearchDataCommandHandler) Handle

func (ch SyncSearchDataCommandHandler) Handle(ctx context.Context, query mediator.Message) (interface{}, error)

type SyncSearchDataCommandResult

type SyncSearchDataCommandResult struct {
	Status bool
}

type SyncSmartCartCompatibilityCommand

type SyncSmartCartCompatibilityCommand struct {
}

func (*SyncSmartCartCompatibilityCommand) Key

type SyncSmartCartCompatibilityCommandHandler

type SyncSmartCartCompatibilityCommandHandler struct {
	DBS func() *db.ReaderWriter

	Repository repositories.DeviceDefinitionRepository
	// contains filtered or unexported fields
}

func (SyncSmartCartCompatibilityCommandHandler) Handle

func (ch SyncSmartCartCompatibilityCommandHandler) Handle(ctx context.Context, query mediator.Message) (interface{}, error)

type SyncSmartCartCompatibilityCommandResult

type SyncSmartCartCompatibilityCommandResult struct {
	Status bool
}

type SyncSmartCartForwardCompatibilityCommand

type SyncSmartCartForwardCompatibilityCommand struct {
}

func (*SyncSmartCartForwardCompatibilityCommand) Key

type SyncSmartCartForwardCompatibilityCommandHandler

type SyncSmartCartForwardCompatibilityCommandHandler struct {
	DBS func() *db.ReaderWriter

	Repository repositories.DeviceDefinitionRepository
	// contains filtered or unexported fields
}

func (SyncSmartCartForwardCompatibilityCommandHandler) Handle

type SyncSmartCartForwardCompatibilityCommandResult

type SyncSmartCartForwardCompatibilityCommandResult struct {
	Status bool
}

type SyncTeslaIntegrationCommand added in v0.1.17

type SyncTeslaIntegrationCommand struct {
}

func (*SyncTeslaIntegrationCommand) Key added in v0.1.17

type SyncTeslaIntegrationCommandResult added in v0.1.17

type SyncTeslaIntegrationCommandResult struct {
	Status bool
}

type SyncTestlaIntegrationCommandHandler added in v0.1.17

type SyncTestlaIntegrationCommandHandler struct {
	DBS func() *db.ReaderWriter
	// contains filtered or unexported fields
}

func NewSyncTestlaIntegrationCommandHandler added in v0.1.17

func NewSyncTestlaIntegrationCommandHandler(dbs func() *db.ReaderWriter, log *zerolog.Logger) SyncTestlaIntegrationCommandHandler

func (SyncTestlaIntegrationCommandHandler) Handle added in v0.1.17

func (ch SyncTestlaIntegrationCommandHandler) Handle(ctx context.Context, query mediator.Message) (interface{}, error)

type UpdateDeviceDefinitionCommand

type UpdateDeviceDefinitionCommand struct {
	DeviceDefinitionID string `json:"deviceDefinitionId"`
	Source             string `json:"source"`
	ExternalID         string `json:"external_id"`
	ImageURL           string `json:"image_url"`
	VehicleInfo        *UpdateDeviceVehicleInfo
	Verified           bool                       `json:"verified"`
	Model              string                     `json:"model"`
	Year               int16                      `json:"year"`
	DeviceMakeID       string                     `json:"device_make_id"`
	DeviceStyles       []UpdateDeviceStyles       `json:"deviceStyles"`
	DeviceIntegrations []UpdateDeviceIntegrations `json:"deviceIntegrations"`
	// DeviceTypeID comes from the device_types.id table, determines what kind of device this is, typically a vehicle
	DeviceTypeID string `json:"device_type_id"`
	// DeviceAttributes sets definition metadata eg. vehicle info. Allowed key/values are defined in device_types.properties
	DeviceAttributes []*coremodels.UpdateDeviceTypeAttribute `json:"deviceAttributes"`
}

func (*UpdateDeviceDefinitionCommand) Key

type UpdateDeviceDefinitionCommandHandler

type UpdateDeviceDefinitionCommandHandler struct {
	Repository repositories.DeviceDefinitionRepository
	DBS        func() *db.ReaderWriter
	DDCache    services.DeviceDefinitionCacheService
}

func (UpdateDeviceDefinitionCommandHandler) Handle

func (ch UpdateDeviceDefinitionCommandHandler) Handle(ctx context.Context, query mediator.Message) (interface{}, error)

type UpdateDeviceDefinitionCommandResult

type UpdateDeviceDefinitionCommandResult struct {
	ID string `json:"id"`
}

type UpdateDeviceDefinitionImageCommand added in v0.1.6

type UpdateDeviceDefinitionImageCommand struct {
	DeviceDefinitionID string `json:"deviceDefinitionId"`
	ImageURL           string `json:"image_url"`
}

func (*UpdateDeviceDefinitionImageCommand) Key added in v0.1.6

type UpdateDeviceDefinitionImageCommandHandler added in v0.1.6

type UpdateDeviceDefinitionImageCommandHandler struct {
	DBS     func() *db.ReaderWriter
	DDCache services.DeviceDefinitionCacheService
}

func NewUpdateDeviceDefinitionImageCommandHandler added in v0.1.6

func NewUpdateDeviceDefinitionImageCommandHandler(dbs func() *db.ReaderWriter, cache services.DeviceDefinitionCacheService) UpdateDeviceDefinitionImageCommandHandler

func (UpdateDeviceDefinitionImageCommandHandler) Handle added in v0.1.6

func (ch UpdateDeviceDefinitionImageCommandHandler) Handle(ctx context.Context, query mediator.Message) (interface{}, error)

type UpdateDeviceDefinitionImageCommandResult added in v0.1.6

type UpdateDeviceDefinitionImageCommandResult struct {
	ID string `json:"id"`
}

type UpdateDeviceIntegrations added in v0.1.11

type UpdateDeviceIntegrations struct {
	IntegrationID string    `json:"integration_id"`
	Capabilities  null.JSON `json:"capabilities,omitempty"`
	CreatedAt     time.Time `json:"created_at,omitempty"`
	UpdatedAt     time.Time `json:"updated_at,omitempty"`
	Region        string    `json:"region"`
}

type UpdateDeviceMakeCommand added in v0.1.38

type UpdateDeviceMakeCommand struct {
	ID              string          `json:"id"`
	Name            string          `json:"name"`
	LogoURL         null.String     `json:"logo_url"`
	OemPlatformName null.String     `json:"oem_platform_name"`
	TokenID         *big.Int        `json:"tokenId,omitempty"`
	ExternalIds     json.RawMessage `json:"external_ids"`
}

func (*UpdateDeviceMakeCommand) Key added in v0.1.38

type UpdateDeviceMakeCommandHandler added in v0.1.38

type UpdateDeviceMakeCommandHandler struct {
	DBS func() *db.ReaderWriter
}

func NewUpdateDeviceMakeCommandHandler added in v0.1.38

func NewUpdateDeviceMakeCommandHandler(dbs func() *db.ReaderWriter) UpdateDeviceMakeCommandHandler

func (UpdateDeviceMakeCommandHandler) Handle added in v0.1.38

func (ch UpdateDeviceMakeCommandHandler) Handle(ctx context.Context, query mediator.Message) (interface{}, error)

type UpdateDeviceMakeCommandResult added in v0.1.38

type UpdateDeviceMakeCommandResult struct {
	ID string `json:"id"`
}

type UpdateDeviceStyleCommand added in v0.1.38

type UpdateDeviceStyleCommand struct {
	ID                 string `json:"id"`
	DeviceDefinitionID string `json:"device_definition_id"`
	Name               string `json:"name"`
	ExternalStyleID    string `json:"external_style_id"`
	Source             string `json:"source"`
	SubModel           string `json:"sub_model"`
}

func (*UpdateDeviceStyleCommand) Key added in v0.1.38

type UpdateDeviceStyleCommandHandler added in v0.1.38

type UpdateDeviceStyleCommandHandler struct {
	DBS func() *db.ReaderWriter
}

func NewUpdateDeviceStyleCommandHandler added in v0.1.38

func NewUpdateDeviceStyleCommandHandler(dbs func() *db.ReaderWriter) UpdateDeviceStyleCommandHandler

func (UpdateDeviceStyleCommandHandler) Handle added in v0.1.38

func (ch UpdateDeviceStyleCommandHandler) Handle(ctx context.Context, query mediator.Message) (interface{}, error)

type UpdateDeviceStyleCommandResult added in v0.1.38

type UpdateDeviceStyleCommandResult struct {
	ID string `json:"id"`
}

type UpdateDeviceStyles added in v0.1.11

type UpdateDeviceStyles struct {
	ID              string    `json:"id"`
	Name            string    `json:"name"`
	ExternalStyleID string    `json:"external_style_id"`
	Source          string    `json:"source"`
	CreatedAt       time.Time `json:"created_at,omitempty"`
	UpdatedAt       time.Time `json:"updated_at,omitempty"`
	SubModel        string    `json:"sub_model"`
}

type UpdateDeviceTypeCommand added in v0.2.3

type UpdateDeviceTypeCommand struct {
	ID               string                                  `json:"id"`
	Name             string                                  `json:"name"`
	DeviceAttributes []*coremodels.CreateDeviceTypeAttribute `json:"deviceAttributes"`
}

func (*UpdateDeviceTypeCommand) Key added in v0.2.3

type UpdateDeviceTypeCommandHandler added in v0.2.3

type UpdateDeviceTypeCommandHandler struct {
	DBS func() *db.ReaderWriter
}

func NewUpdateDeviceTypeCommandHandler added in v0.2.3

func NewUpdateDeviceTypeCommandHandler(dbs func() *db.ReaderWriter) UpdateDeviceTypeCommandHandler

func (UpdateDeviceTypeCommandHandler) Handle added in v0.2.3

func (ch UpdateDeviceTypeCommandHandler) Handle(ctx context.Context, query mediator.Message) (interface{}, error)

type UpdateDeviceTypeCommandResult added in v0.2.3

type UpdateDeviceTypeCommandResult struct {
	ID string `json:"id"`
}

type UpdateDeviceVehicleInfo

type UpdateDeviceVehicleInfo struct {
	FuelType            string `json:"fuel_type,omitempty"`
	DrivenWheels        string `json:"driven_wheels,omitempty"`
	NumberOfDoors       string `json:"number_of_doors,omitempty"`
	BaseMSRP            int    `json:"base_msrp,omitempty"`
	EPAClass            string `json:"epa_class,omitempty"`
	VehicleType         string `json:"vehicle_type,omitempty"` // VehicleType PASSENGER CAR, from NHTSA
	MPGHighway          string `json:"mpg_highway,omitempty"`
	MPGCity             string `json:"mpg_city,omitempty"`
	FuelTankCapacityGal string `json:"fuel_tank_capacity_gal,omitempty"`
	MPG                 string `json:"mpg,omitempty"`
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL