commands

package
v1.0.21 Latest Latest
Warning

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

 Go to latest Published: Sep 25, 2023 License: Apache-2.0 Imports: 40 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 ApproveReviewCommand added in v0.4.0 

type ApproveReviewCommand struct {
	ReviewID   string `json:"review_id"`
	ApprovedBy string `json:"approved_by"`
}

func (*ApproveReviewCommand) Key added in v0.4.0 

func (*ApproveReviewCommand) Key() string

type ApproveReviewCommandHandler added in v0.4.0 

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

func NewApproveReviewCommandHandler added in v0.4.0 

func NewApproveReviewCommandHandler(dbs func() *db.ReaderWriter) ApproveReviewCommandHandler

func (ApproveReviewCommandHandler) Handle added in v0.4.0 

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

type ApproveReviewCommandResult added in v0.4.0 

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

type BulkValidateVinCommand added in v0.8.3 

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

func (*BulkValidateVinCommand) Key added in v0.8.3 

func (*BulkValidateVinCommand) Key() string

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

func (*CreateDeviceDefinitionCommand) Key 

func (*CreateDeviceDefinitionCommand) Key() string

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

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 

func (*CreateDeviceIntegrationCommand) Key() string

type CreateDeviceIntegrationCommandHandler 

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

func NewCreateDeviceIntegrationCommandHandler 

func NewCreateDeviceIntegrationCommandHandler(repository repositories.DeviceIntegrationRepository,
	dbs func() *db.ReaderWriter,
	cache services.DeviceDefinitionCacheService,
	deviceDefinitionRepository repositories.DeviceDefinitionRepository) 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"`
	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 

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

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

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

func (*CreateIntegrationFeatureCommand) Key() string

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 CreateReviewCommand added in v0.4.0 

type CreateReviewCommand struct {
	DeviceDefinitionID string `json:"device_definition_id"`
	URL                string `json:"url"`
	ImageURL           string `json:"imageURL"`
	Channel            string `json:"channel"`
	Comments           string `json:"comments"`
}

func (*CreateReviewCommand) Key added in v0.4.0 

func (*CreateReviewCommand) Key() string

type CreateReviewCommandHandler added in v0.4.0 

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

func NewCreateReviewCommandHandler added in v0.4.0 

func NewCreateReviewCommandHandler(dbs func() *db.ReaderWriter) CreateReviewCommandHandler

func (CreateReviewCommandHandler) Handle added in v0.4.0 

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

type CreateReviewCommandResult added in v0.4.0 

type CreateReviewCommandResult 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 

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

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

func (*DeleteIntegrationFeatureCommand) Key added in v0.3.5 

func (*DeleteIntegrationFeatureCommand) Key() string

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 DeleteReviewCommand added in v0.4.0 

type DeleteReviewCommand struct {
	ReviewID string `json:"review_id"`
}

func (*DeleteReviewCommand) Key added in v0.4.0 

func (*DeleteReviewCommand) Key() string

type DeleteReviewCommandHandler added in v0.4.0 

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

func NewDeleteReviewCommandHandler added in v0.4.0 

func NewDeleteReviewCommandHandler(dbs func() *db.ReaderWriter) DeleteReviewCommandHandler

func (DeleteReviewCommandHandler) Handle added in v0.4.0 

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

type DeleteReviewCommandResult added in v0.4.0 

type DeleteReviewCommandResult 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 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, _ 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 SyncPowerTrainTypeCommand added in v1.0.14 

type SyncPowerTrainTypeCommand struct {
	ForceUpdate  bool
	DeviceTypeID string
}

func (*SyncPowerTrainTypeCommand) Key added in v1.0.14 

func (*SyncPowerTrainTypeCommand) Key() string

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 

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

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 

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, _ 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, _ 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"`
	Verified           bool                        `json:"verified"`
	Model              string                      `json:"model"`
	Year               int16                       `json:"year"`
	HardwareTemplateID string                      `json:"hardware_template_id,omitempty"`
	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"`
	ExternalIds      []*coremodels.ExternalID                `json:"externalIds"`
}

func (*UpdateDeviceDefinitionCommand) Key 

func (*UpdateDeviceDefinitionCommand) Key() string

func (*UpdateDeviceDefinitionCommand) ValidateUpdate added in v0.6.3 

func (udc *UpdateDeviceDefinitionCommand) ValidateUpdate() error

ValidateUpdate validates the contents of a UpdateDeviceDefinitionCommand for purpose of updating record

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)

Handle will update an existing device def, or if it doesn't exist create it on the fly. We may want to change create to be explicit

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"`
	Features      []*coremodels.UpdateDeviceIntegrationFeatureAttribute `json:"features"`
}

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 

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

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

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

func (*UpdateIntegrationFeatureCommand) Key() string

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

type UpdateReviewCommand added in v0.4.0 

type UpdateReviewCommand struct {
	ReviewID string `json:"review_id"`
	URL      string `json:"url"`
	ImageURL string `json:"imageURL"`
	Channel  string `json:"channel"`
	Comments string `json:"comments"`
}

func (*UpdateReviewCommand) Key added in v0.4.0 

func (*UpdateReviewCommand) Key() string

type UpdateReviewCommandHandler added in v0.4.0 

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

func NewUpdateReviewCommandHandler added in v0.4.0 

func NewUpdateReviewCommandHandler(dbs func() *db.ReaderWriter) UpdateReviewCommandHandler

func (UpdateReviewCommandHandler) Handle added in v0.4.0 

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

type UpdateReviewCommandResult added in v0.4.0 

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

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.