commands

package
v0.2.4 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 

func (*CreateDeviceDefinitionCommand) Key() string

type CreateDeviceDefinitionCommandHandler 

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

func NewCreateDeviceDefinitionCommandHandler 

func NewCreateDeviceDefinitionCommandHandler(repository repositories.DeviceDefinitionRepository, dbs func() *db.ReaderWriter) CreateDeviceDefinitionCommandHandler

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 

func (*CreateDeviceIntegrationCommand) Key() string

type CreateDeviceIntegrationCommandHandler 

type CreateDeviceIntegrationCommandHandler struct {
	Repository repositories.DeviceIntegrationRepository
}

func NewCreateDeviceIntegrationCommandHandler 

func NewCreateDeviceIntegrationCommandHandler(repository repositories.DeviceIntegrationRepository) CreateDeviceIntegrationCommandHandler

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 

func (*CreateDeviceMakeCommand) Key() string

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 

func (*CreateDeviceStyleCommand) Key() string

type CreateDeviceStyleCommandHandler added in v0.1.11 

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

func NewCreateDeviceStyleCommandHandler added in v0.1.11 

func NewCreateDeviceStyleCommandHandler(repository repositories.DeviceStyleRepository, cache services.DeviceDefinitionCacheService) CreateDeviceStyleCommandHandler

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 

func (*CreateDeviceTypeCommand) Key() string

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 

func (*CreateIntegrationCommand) Key() string

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 

func (*DeleteDeviceTypeCommand) Key() string

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 

func (*SyncNHTSARecallsCommand) Key() string

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 

func (*SyncSearchDataCommand) Key() string

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 

func (*SyncSmartCartCompatibilityCommand) Key() string

type SyncSmartCartCompatibilityCommandHandler 

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

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

func NewSyncSmartCartCompatibilityCommandHandler 

func NewSyncSmartCartCompatibilityCommandHandler(dbs func() *db.ReaderWriter, scSvc gateways.SmartCarService, repository repositories.DeviceDefinitionRepository) SyncSmartCartCompatibilityCommandHandler

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 

func (*SyncSmartCartForwardCompatibilityCommand) Key() string

type SyncSmartCartForwardCompatibilityCommandHandler 

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

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

func NewSyncSmartCartForwardCompatibilityCommandHandler 

func NewSyncSmartCartForwardCompatibilityCommandHandler(dbs func() *db.ReaderWriter, scSvc gateways.SmartCarService, repository repositories.DeviceDefinitionRepository) SyncSmartCartForwardCompatibilityCommandHandler

func (SyncSmartCartForwardCompatibilityCommandHandler) Handle 

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

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 

func (*SyncTeslaIntegrationCommand) Key() string

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 

func (*UpdateDeviceDefinitionCommand) Key() string

type UpdateDeviceDefinitionCommandHandler 

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

func NewUpdateDeviceDefinitionCommandHandler 

func NewUpdateDeviceDefinitionCommandHandler(repository repositories.DeviceDefinitionRepository, dbs func() *db.ReaderWriter, cache services.DeviceDefinitionCacheService) UpdateDeviceDefinitionCommandHandler

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 

func (*UpdateDeviceDefinitionImageCommand) Key() string

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 

func (*UpdateDeviceMakeCommand) Key() string

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 

func (*UpdateDeviceStyleCommand) Key() string

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 

func (*UpdateDeviceTypeCommand) Key() string

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"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.