queries

package
v1.5.8 Latest Latest
Warning

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

Go to latest
Published: Aug 14, 2025 License: Apache-2.0 Imports: 39 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CompatibilitySheetRow added in v1.2.56

type CompatibilitySheetRow struct {
	DefinitionID string `json:"definitionId"`
	Make         string `json:"make"`
	Model        string `json:"model"`
	Year         int    `json:"year"`
	Compatible   string `json:"compatible"`
}

func (*CompatibilitySheetRow) UnmarshalJSON added in v1.2.82

func (v *CompatibilitySheetRow) UnmarshalJSON(data []byte) error

UnmarshalJSON Custom unmarshaller for CompatibilitySheetRow struct because model can sometimes be interpreted as a number

type DecodeVINQuery added in v0.6.8

type DecodeVINQuery struct {
	VIN        string `json:"vin"`
	KnownModel string `json:"knownModel"`
	KnownYear  int32  `json:"knownYear"`
	Country    string `json:"country"`
}

func (*DecodeVINQuery) Key added in v0.6.8

func (*DecodeVINQuery) Key() string

type DecodeVINQueryHandler added in v0.6.8

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

func NewDecodeVINQueryHandler added in v0.6.8

func NewDecodeVINQueryHandler(dbs func() *db.ReaderWriter, vinDecodingService services.VINDecodingService,
	vinRepository repositories.VINRepository,
	logger *zerolog.Logger,
	fuelAPIService gateways.FuelAPIService,
	powerTrainTypeService services.PowerTrainTypeService,
	deviceDefinitionOnChainService gateways.DeviceDefinitionOnChainService,
	identity gateways.IdentityAPI) DecodeVINQueryHandler

func (DecodeVINQueryHandler) Handle added in v0.6.8

type DeviceDefinitionQueryResponse added in v0.1.9

type DeviceDefinitionQueryResponse struct {
	ID           string      `json:"id"`
	NameSlug     string      `json:"name_slug"`
	Model        string      `json:"model"`
	Year         int         `json:"year"`
	ImageURL     null.String `json:"image_url,omitempty"`
	CreatedAt    time.Time   `json:"created_at,omitempty"`
	UpdatedAt    time.Time   `json:"updated_at,omitempty"`
	Metadata     null.JSON   `json:"metadata"`
	Source       null.String `json:"source"`
	Verified     bool        `json:"verified"`
	ExternalID   null.String `json:"external_id"`
	DeviceMakeID string      `json:"device_make_id"`
	Make         string      `json:"make"`
	ExternalIDs  null.JSON   `json:"external_ids"`
}

type GetAllDeviceDefinitionAutocompleteItem added in v1.2.31

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

type GetAllDeviceDefinitionByAutocompleteQuery added in v1.2.31

type GetAllDeviceDefinitionByAutocompleteQuery struct {
	Query string `json:"query"`
}

func (*GetAllDeviceDefinitionByAutocompleteQuery) Key added in v1.2.31

type GetAllDeviceDefinitionByAutocompleteQueryHandler added in v1.2.31

type GetAllDeviceDefinitionByAutocompleteQueryHandler struct {
	Service search.TypesenseAPIService
}

func NewGetAllDeviceDefinitionByAutocompleteQueryHandler added in v1.2.31

func NewGetAllDeviceDefinitionByAutocompleteQueryHandler(service search.TypesenseAPIService) GetAllDeviceDefinitionByAutocompleteQueryHandler

func (GetAllDeviceDefinitionByAutocompleteQueryHandler) Handle added in v1.2.31

type GetAllDeviceDefinitionByAutocompleteQueryResult added in v1.2.31

type GetAllDeviceDefinitionByAutocompleteQueryResult struct {
	Items []GetAllDeviceDefinitionAutocompleteItem `json:"items"`
}

type GetAllDeviceDefinitionBySearchQuery added in v1.2.31

type GetAllDeviceDefinitionBySearchQuery struct {
	Query    string `json:"query"`
	Make     string `json:"make"`
	Model    string `json:"model"`
	Year     int    `json:"year"`
	Page     int    `json:"page"`
	PageSize int    `json:"pageSize"`
}

func (*GetAllDeviceDefinitionBySearchQuery) Key added in v1.2.31

type GetAllDeviceDefinitionBySearchQueryHandler added in v1.2.31

type GetAllDeviceDefinitionBySearchQueryHandler struct {
	Service search.TypesenseAPIService
}

func NewGetAllDeviceDefinitionBySearchQueryHandler added in v1.2.31

func NewGetAllDeviceDefinitionBySearchQueryHandler(service search.TypesenseAPIService) GetAllDeviceDefinitionBySearchQueryHandler

func (GetAllDeviceDefinitionBySearchQueryHandler) Handle added in v1.2.31

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

type GetAllDeviceDefinitionBySearchQueryResult added in v1.2.31

type GetAllDeviceDefinitionBySearchQueryResult struct {
	DeviceDefinitions []GetAllDeviceDefinitionItem     `json:"deviceDefinitions"`
	Facets            GetAllDeviceDefinitionFacet      `json:"facets"`
	Pagination        GetAllDeviceDefinitionPagination `json:"pagination"`
}

type GetAllDeviceDefinitionFacet added in v1.2.31

type GetAllDeviceDefinitionFacet struct {
	Makes  []GetAllDeviceDefinitionFacetItem `json:"makes"`
	Models []GetAllDeviceDefinitionFacetItem `json:"models"`
	Years  []GetAllDeviceDefinitionFacetItem `json:"years"`
}

type GetAllDeviceDefinitionFacetItem added in v1.2.31

type GetAllDeviceDefinitionFacetItem struct {
	Name  string `json:"name"`
	Count int    `json:"count"`
}

type GetAllDeviceDefinitionItem added in v1.2.31

type GetAllDeviceDefinitionItem struct {
	ID                 string `json:"id"`
	DeviceDefinitionID string `json:"legacy_ksuid"` //nolint
	Name               string `json:"name"`
	Make               string `json:"make"`
	// ManufacturerTokenID int    `json:"manufacturerTokenId"` // todo
	Model    string `json:"model"`
	Year     int    `json:"year"`
	ImageURL string `json:"imageUrl"`
}

type GetAllDeviceDefinitionPagination added in v1.2.31

type GetAllDeviceDefinitionPagination struct {
	Page       int `json:"page"`
	PageSize   int `json:"pageSize"`
	TotalItems int `json:"totalItems"`
	TotalPages int `json:"totalPages"`
}

type GetAllDeviceTypeQuery added in v0.2.3

type GetAllDeviceTypeQuery struct {
}

func (*GetAllDeviceTypeQuery) Key added in v0.2.3

type GetAllDeviceTypeQueryHandler added in v0.2.3

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

func NewGetAllDeviceTypeQueryHandler added in v0.2.3

func NewGetAllDeviceTypeQueryHandler(dbs func() *db.ReaderWriter) GetAllDeviceTypeQueryHandler

func (GetAllDeviceTypeQueryHandler) Handle added in v0.2.3

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

type GetAllIntegrationQuery

type GetAllIntegrationQuery struct {
}

func (*GetAllIntegrationQuery) Key

type GetAllIntegrationQueryHandler

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

func NewGetAllIntegrationQueryHandler

func NewGetAllIntegrationQueryHandler(dbs func() *db.ReaderWriter) GetAllIntegrationQueryHandler

func (GetAllIntegrationQueryHandler) Handle

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

type GetCompatibilityR1SheetQuery added in v1.2.56

type GetCompatibilityR1SheetQuery struct {
}

func (*GetCompatibilityR1SheetQuery) Key added in v1.2.56

type GetCompatibilityR1SheetQueryHandler added in v1.2.56

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

func NewCompatibilityR1SheetQueryHandler added in v1.2.56

func NewCompatibilityR1SheetQueryHandler(settings *config.Settings) GetCompatibilityR1SheetQueryHandler

func (GetCompatibilityR1SheetQueryHandler) Handle added in v1.2.56

func (crs GetCompatibilityR1SheetQueryHandler) Handle(ctx context.Context, _ mediator.Message) (interface{}, error)

type GetDeviceDefinitionByDynamicFilterQuery added in v0.1.9

type GetDeviceDefinitionByDynamicFilterQuery struct {
	DefinitionID    string   `json:"definition_id"`
	Year            int      `json:"year"`
	Model           string   `json:"model"`
	VerifiedVinList []string `json:"verified_vin_list"`
	PageIndex       int      `json:"page_index"`
	PageSize        int      `json:"page_size"`
	MakeSlug        string
}

func (*GetDeviceDefinitionByDynamicFilterQuery) Key added in v0.1.9

type GetDeviceDefinitionByDynamicFilterQueryHandler added in v0.1.9

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

func NewGetDeviceDefinitionByDynamicFilterQueryHandler added in v0.1.9

func NewGetDeviceDefinitionByDynamicFilterQueryHandler(dbs func() *db.ReaderWriter, onChainSvc gateways.DeviceDefinitionOnChainService) GetDeviceDefinitionByDynamicFilterQueryHandler

func (GetDeviceDefinitionByDynamicFilterQueryHandler) Handle added in v0.1.9

type GetDeviceDefinitionByIDQuery added in v0.1.2

type GetDeviceDefinitionByIDQuery struct {
	DeviceDefinitionID string `json:"deviceDefinitionId"`
}

func (*GetDeviceDefinitionByIDQuery) Key added in v0.1.2

type GetDeviceDefinitionByIDQueryHandler added in v0.1.2

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

func NewGetDeviceDefinitionByIDQueryHandler added in v0.1.2

func NewGetDeviceDefinitionByIDQueryHandler(onChainSvc gateways.DeviceDefinitionOnChainService, dbs func() *db.ReaderWriter) GetDeviceDefinitionByIDQueryHandler

func (GetDeviceDefinitionByIDQueryHandler) Handle added in v0.1.2

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

type GetDeviceDefinitionByIDQueryV2 added in v1.2.75

type GetDeviceDefinitionByIDQueryV2 struct {
	DefinitionID string `json:"definitionId"`
}

func (*GetDeviceDefinitionByIDQueryV2) Key added in v1.2.75

type GetDeviceDefinitionByIDQueryV2Handler added in v1.2.75

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

func NewGetDeviceDefinitionByIDQueryV2Handler added in v1.2.75

func NewGetDeviceDefinitionByIDQueryV2Handler(ddOnChainSvc gateways.DeviceDefinitionOnChainService, dbs func() *db.ReaderWriter) GetDeviceDefinitionByIDQueryV2Handler

func (GetDeviceDefinitionByIDQueryV2Handler) Handle added in v1.2.75

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

type GetDeviceDefinitionByMakeModelYearQuery

type GetDeviceDefinitionByMakeModelYearQuery struct {
	Make  string `json:"make" validate:"required"`
	Model string `json:"model" validate:"required"`
	Year  int    `json:"year" validate:"required"`
}

func (*GetDeviceDefinitionByMakeModelYearQuery) Key

type GetDeviceDefinitionByMakeModelYearQueryHandler

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

func (GetDeviceDefinitionByMakeModelYearQueryHandler) Handle

type GetDeviceDefinitionImagesByIDsQuery added in v1.1.0

type GetDeviceDefinitionImagesByIDsQuery struct {
	DefinitionID []string `json:"definitionId" validate:"required"`
}

func (*GetDeviceDefinitionImagesByIDsQuery) Key added in v1.1.0

type GetDeviceDefinitionImagesByIDsQueryHandler added in v1.1.0

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

func NewGetDeviceDefinitionImagesByIDsQueryHandler added in v1.1.0

func NewGetDeviceDefinitionImagesByIDsQueryHandler(dbs func() *db.ReaderWriter, log *zerolog.Logger) GetDeviceDefinitionImagesByIDsQueryHandler

func (GetDeviceDefinitionImagesByIDsQueryHandler) Handle added in v1.1.0

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

type GetDeviceStyleByDeviceDefinitionIDQuery added in v0.1.31

type GetDeviceStyleByDeviceDefinitionIDQuery struct {
	DefinitionID string `json:"definition_id"`
}

func (*GetDeviceStyleByDeviceDefinitionIDQuery) Key added in v0.1.31

type GetDeviceStyleByDeviceDefinitionIDQueryHandler added in v0.1.31

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

func NewGetDeviceStyleByDeviceDefinitionIDQueryHandler added in v0.1.31

func NewGetDeviceStyleByDeviceDefinitionIDQueryHandler(dbs func() *db.ReaderWriter) GetDeviceStyleByDeviceDefinitionIDQueryHandler

func (GetDeviceStyleByDeviceDefinitionIDQueryHandler) Handle added in v0.1.31

type GetDeviceStyleByExternalIDQuery added in v0.1.27

type GetDeviceStyleByExternalIDQuery struct {
	ExternalDeviceID string `json:"external_device_id"`
}

func (*GetDeviceStyleByExternalIDQuery) Key added in v0.1.27

type GetDeviceStyleByExternalIDQueryHandler added in v0.1.27

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

func NewGetDeviceStyleByExternalIDQueryHandler added in v0.1.27

func NewGetDeviceStyleByExternalIDQueryHandler(dbs func() *db.ReaderWriter) GetDeviceStyleByExternalIDQueryHandler

func (GetDeviceStyleByExternalIDQueryHandler) Handle added in v0.1.27

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

type GetDeviceStyleByFilterQuery added in v0.1.40

type GetDeviceStyleByFilterQuery struct {
	DefinitionID string `json:"definition_id"`
	Name         string `json:"name"`
	SubModel     string `json:"sub_model"`
}

func (*GetDeviceStyleByFilterQuery) Key added in v0.1.40

type GetDeviceStyleByFilterQueryHandler added in v0.1.40

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

func NewGetDeviceStyleByFilterQueryHandler added in v0.1.40

func NewGetDeviceStyleByFilterQueryHandler(dbs func() *db.ReaderWriter) GetDeviceStyleByFilterQueryHandler

func (GetDeviceStyleByFilterQueryHandler) Handle added in v0.1.40

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

type GetDeviceStyleByIDQuery added in v0.1.27

type GetDeviceStyleByIDQuery struct {
	DeviceStyleID string `json:"device_style_id"`
}

func (*GetDeviceStyleByIDQuery) Key added in v0.1.27

type GetDeviceStyleByIDQueryHandler added in v0.1.27

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

func NewGetDeviceStyleByIDQueryHandler added in v0.1.27

func NewGetDeviceStyleByIDQueryHandler(dbs func() *db.ReaderWriter, onchainSvc gateways.DeviceDefinitionOnChainService) GetDeviceStyleByIDQueryHandler

func (GetDeviceStyleByIDQueryHandler) Handle added in v0.1.27

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

type GetDeviceTypeByIDQuery added in v0.2.0

type GetDeviceTypeByIDQuery struct {
	DeviceTypeID string `json:"device_type_id"`
}

func (*GetDeviceTypeByIDQuery) Key added in v0.2.0

type GetDeviceTypeByIDQueryHandler added in v0.2.0

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

func NewGetDeviceTypeByIDQueryHandler added in v0.2.0

func NewGetDeviceTypeByIDQueryHandler(dbs func() *db.ReaderWriter) GetDeviceTypeByIDQueryHandler

func (GetDeviceTypeByIDQueryHandler) Handle added in v0.2.0

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

type GetIntegrationByIDQuery added in v0.1.26

type GetIntegrationByIDQuery struct {
	IntegrationID []string `json:"integration_id" validate:"required"`
}

func (*GetIntegrationByIDQuery) Key added in v0.1.26

type GetIntegrationByIDQueryHandler added in v0.1.26

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

func NewGetIntegrationByIDQueryHandler added in v0.1.26

func NewGetIntegrationByIDQueryHandler(dbs func() *db.ReaderWriter) GetIntegrationByIDQueryHandler

func (GetIntegrationByIDQueryHandler) Handle added in v0.1.26

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

type GetIntegrationByTokenIDQuery added in v1.0.7

type GetIntegrationByTokenIDQuery struct {
	TokenID int `json:"tokenId" validate:"required"`
}

func (*GetIntegrationByTokenIDQuery) Key added in v1.0.7

type GetIntegrationByTokenIDQueryHandler added in v1.0.7

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

func NewGetIntegrationByTokenIDQueryHandler added in v1.0.7

func NewGetIntegrationByTokenIDQueryHandler(dbs func() *db.ReaderWriter, log *zerolog.Logger) GetIntegrationByTokenIDQueryHandler

func (GetIntegrationByTokenIDQueryHandler) Handle added in v1.0.7

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

type GetIntegrationOptionsQuery added in v0.3.8

type GetIntegrationOptionsQuery struct {
	MakeID string
}

func (*GetIntegrationOptionsQuery) Key added in v0.3.8

type GetIntegrationOptionsQueryHandler added in v0.3.8

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

func NewGetIntegrationOptionsQueryHandler added in v0.3.8

func NewGetIntegrationOptionsQueryHandler(dbs func() *db.ReaderWriter) GetIntegrationOptionsQueryHandler

func (GetIntegrationOptionsQueryHandler) Handle added in v0.3.8

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

type GetR1CompatibilitySearch added in v1.2.55

type GetR1CompatibilitySearch struct {
	Query    string `json:"query"`
	Page     int    `json:"page"`
	PageSize int    `json:"pageSize"`
}

func (*GetR1CompatibilitySearch) Key added in v1.2.55

type GetR1CompatibilitySearchQueryHandler added in v1.2.55

type GetR1CompatibilitySearchQueryHandler struct {
	Service search.TypesenseAPIService
}

func NewGetR1CompatibilitySearchQueryHandler added in v1.2.55

func NewGetR1CompatibilitySearchQueryHandler(service search.TypesenseAPIService) GetR1CompatibilitySearchQueryHandler

func (GetR1CompatibilitySearchQueryHandler) Handle added in v1.2.55

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

type GetR1CompatibilitySearchQueryResult added in v1.2.55

type GetR1CompatibilitySearchQueryResult struct {
	DeviceDefinitions []GetR1SearchEntryItem           `json:"deviceDefinitions"`
	Pagination        GetAllDeviceDefinitionPagination `json:"pagination"`
}

type GetR1SearchEntryItem added in v1.2.55

type GetR1SearchEntryItem struct {
	DefinitionID string `json:"id"` //nolint
	Make         string `json:"make"`
	Model        string `json:"model"`
	Year         int    `json:"year"`
	Compatible   string `json:"compatible"`
	Name         string `json:"name"`
}

type GetVINProfileQuery added in v1.3.2

type GetVINProfileQuery struct {
	VIN string `json:"vin"`
}

func (*GetVINProfileQuery) Key added in v1.3.2

func (*GetVINProfileQuery) Key() string

type GetVINProfileQueryHandler added in v1.3.2

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

func NewGetVINProfileQueryHandler added in v1.3.2

func NewGetVINProfileQueryHandler(dbs func() *db.ReaderWriter, logger *zerolog.Logger, powertrainSvc services.PowerTrainTypeService) GetVINProfileQueryHandler

func (GetVINProfileQueryHandler) Handle added in v1.3.2

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

type GetVINProfileResponse added in v1.3.2

type GetVINProfileResponse struct {
	VIN            string `json:"vin"`
	ProfileRaw     []byte `json:"profileRaw"`
	Vendor         string `json:"vendor"`
	PowertrainType string `json:"powertrainType,omitempty"`
}

type IntegrationOption added in v0.3.8

type IntegrationOption struct {
	IntegrationID     string `boil:"integration_id"`
	IntegrationVendor string `boil:"vendor"`
	Region            string `boil:"region"`
}

type UpsertDecodingQuery added in v1.3.6

type UpsertDecodingQuery struct {
	VIN          string `json:"vin"`
	DefinitionID string `json:"definitionId"`
}

func (*UpsertDecodingQuery) Key added in v1.3.6

func (*UpsertDecodingQuery) Key() string

type UpsertDecodingQueryHandler added in v1.3.6

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

func NewUpsertDecodingQueryHandler added in v1.3.6

func NewUpsertDecodingQueryHandler(dbs func() *db.ReaderWriter,
	logger *zerolog.Logger,
	deviceDefinitionOnChainService gateways.DeviceDefinitionOnChainService) UpsertDecodingQueryHandler

func (UpsertDecodingQueryHandler) Handle added in v1.3.6

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

Jump to

Keyboard shortcuts

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