commands

package
v1.2.47 Latest Latest
Warning

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

Go to latest
Published: Oct 1, 2024 License: Apache-2.0 Imports: 28 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BulkValidateVinCommand added in v0.8.3

type BulkValidateVinCommand struct {
	VINs []string `json:"vins"`
}

func (*BulkValidateVinCommand) Key added in v0.8.3

type BulkValidateVinCommandHandler added in v0.8.3

type BulkValidateVinCommandHandler struct {
	DBS                                  func() *db.ReaderWriter
	DecodeVINHandler                     queries.DecodeVINQueryHandler
	DeviceDefinitionCompatibilityHandler queries.GetCompatibilityByDeviceDefinitionQueryHandler
	DeviceDefinitionDataHandler          queries.GetDeviceDefinitionByIDQueryHandler
}

func NewBulkValidateVinCommandHandler added in v0.8.3

func NewBulkValidateVinCommandHandler(dbs func() *db.ReaderWriter, decodeVINHandler queries.DecodeVINQueryHandler, deviceDefinitionCompatibilityHandler queries.GetCompatibilityByDeviceDefinitionQueryHandler, deviceDefintionDataHandler queries.GetDeviceDefinitionByIDQueryHandler) BulkValidateVinCommandHandler

func (BulkValidateVinCommandHandler) Handle added in v0.8.3

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

type BulkValidateVinCommandResult added in v0.8.3

type BulkValidateVinCommandResult struct {
	DecodedVINs    []DecodedVIN `json:"decoded_vins"`
	NotDecodedVins []string     `json:"not_decoded_vins"`
}

type CreateDeviceDefinitionCommand

type CreateDeviceDefinitionCommand struct {
	Source             string `json:"source"`
	Make               string `json:"make"`
	Model              string `json:"model"`
	Year               int    `json:"year"`
	HardwareTemplateID string `json:"hardware_template_id,omitempty"`
	// 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"`
	Verified         bool                                    `json:"verified"`
}

func (*CreateDeviceDefinitionCommand) Key

type CreateDeviceDefinitionCommandHandler

type CreateDeviceDefinitionCommandHandler struct {
	Repository repositories.DeviceDefinitionRepository
	DBS        func() *db.ReaderWriter
	// contains filtered or unexported fields
}

func NewCreateDeviceDefinitionCommandHandler

func NewCreateDeviceDefinitionCommandHandler(repository repositories.DeviceDefinitionRepository, dbs func() *db.ReaderWriter, powerTrainTypeService services.PowerTrainTypeService) 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"`
	NameSlug string `json:"name_slug"`
}

type CreateDeviceIntegrationCommand

type CreateDeviceIntegrationCommand struct {
	DeviceDefinitionID string                                                `json:"device_definition_id"`
	IntegrationID      string                                                `json:"integration_id"`
	Region             string                                                `json:"region"`
	Features           []*coremodels.UpdateDeviceIntegrationFeatureAttribute `json:"features"`
}

func (*CreateDeviceIntegrationCommand) Key

type CreateDeviceIntegrationCommandHandler

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

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"`
	ExternalIDs        string `json:"external_ids,omitempty"`
	Metadata           string `json:"metadata,omitempty"`
	HardwareTemplateID string `json:"hardware_template_id,omitempty"`
}

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"`
	HardwareTemplateID string `json:"hardware_template_id"`
}

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"`
	TokenID int    `json:"token_id"`
}

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 CreateIntegrationFeatureCommand added in v0.3.5

type CreateIntegrationFeatureCommand struct {
	ID              string  `json:"id"`
	ElasticProperty string  `json:"elastic_property"`
	DisplayName     string  `json:"display_name"`
	CSSIcon         string  `json:"css_icon"`
	FeatureWeight   float64 `json:"feature_weight"`
}

func (*CreateIntegrationFeatureCommand) Key added in v0.3.5

type CreateIntegrationFeatureCommandHandler added in v0.3.5

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

func NewCreateIntegrationFeatureCommandHandler added in v0.3.5

func NewCreateIntegrationFeatureCommandHandler(dbs func() *db.ReaderWriter) CreateIntegrationFeatureCommandHandler

func (CreateIntegrationFeatureCommandHandler) Handle added in v0.3.5

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

type CreateIntegrationFeatureCommandResult added in v0.3.5

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

type DecodedVIN added in v0.8.3

type DecodedVIN struct {
	VIN                   string                          `json:"vin"`
	DeviceDefinitionID    string                          `json:"device_definition_id"`
	DeviceMake            models.DeviceMake               `json:"device_make"`
	DeviceYear            int32                           `json:"device_year"`
	DeviceModel           string                          `json:"device_model"`
	CompatibilityFeatures []*p_grpc.DeviceCompatibilities `json:"compatibility_features"`
}

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 DeleteIntegrationFeatureCommand added in v0.3.5

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

func (*DeleteIntegrationFeatureCommand) Key added in v0.3.5

type DeleteIntegrationFeatureCommandHandler added in v0.3.5

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

func NewDeleteIntegrationFeatureCommandHandler added in v0.3.5

func NewDeleteIntegrationFeatureCommandHandler(dbs func() *db.ReaderWriter) DeleteIntegrationFeatureCommandHandler

func (DeleteIntegrationFeatureCommandHandler) Handle added in v0.3.5

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

type DeleteIntegrationFeatureResult added in v0.3.5

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

type DemoCommand added in v1.0.17

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

func (*DemoCommand) Key added in v1.0.17

func (c *DemoCommand) Key() string

type DemoCommandHandler added in v1.0.17

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

func NewDemoCommandHandler added in v1.0.17

func NewDemoCommandHandler(dbs func() *db.ReaderWriter) DemoCommandHandler

func (DemoCommandHandler) Handle added in v1.0.17

func (c DemoCommandHandler) Handle(_ context.Context, cmd mediator.Message) (interface{}, error)

type DemoCommandResult added in v1.0.17

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

type SyncPowerTrainTypeCommand added in v1.0.14

type SyncPowerTrainTypeCommand struct {
	ForceUpdate  bool
	DeviceTypeID string
}

func (*SyncPowerTrainTypeCommand) Key added in v1.0.14

type SyncPowerTrainTypeCommandHandler added in v1.0.14

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

func NewSyncPowerTrainTypeCommandHandler added in v1.0.14

func NewSyncPowerTrainTypeCommandHandler(dbs func() *db.ReaderWriter, logger zerolog.Logger, powerTrainTypeService services.PowerTrainTypeService) SyncPowerTrainTypeCommandHandler

func (SyncPowerTrainTypeCommandHandler) Handle added in v1.0.14

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

type SyncPowerTrainTypeCommandResult added in v1.0.14

type SyncPowerTrainTypeCommandResult struct {
	Status bool
}

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, _ 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

Handle adds device_integrations for any makes and years that are found on the smartcar website

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, _ mediator.Message) (interface{}, error)

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"`
	Metadata           json.RawMessage `json:"metadata"`
	HardwareTemplateID string          `json:"hardware_template_id,omitempty"`
}

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"`
	HardwareTemplateID string `json:"hardware_template_id,omitempty"`
}

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 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 UpdateIntegrationFeatureCommand added in v0.3.5

type UpdateIntegrationFeatureCommand struct {
	ID              string  `json:"id"`
	ElasticProperty string  `json:"elastic_property"`
	DisplayName     string  `json:"display_name"`
	CSSIcon         string  `json:"css_icon"`
	FeatureWeight   float64 `json:"feature_weight"`
}

func (*UpdateIntegrationFeatureCommand) Key added in v0.3.5

type UpdateIntegrationFeatureCommandHandler added in v0.3.5

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

func NewUpdateIntegrationFeatureCommandHandler added in v0.3.5

func NewUpdateIntegrationFeatureCommandHandler(dbs func() *db.ReaderWriter) UpdateIntegrationFeatureCommandHandler

func (UpdateIntegrationFeatureCommandHandler) Handle added in v0.3.5

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

type UpdateIntegrationFeatureResult added in v0.3.5

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

Jump to

Keyboard shortcuts

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