iotwireless

type Destination struct {
	CreatedAt      time.Time         `json:"createdAt"`
	Tags           map[string]string `json:"tags,omitempty"`
	Name           string            `json:"name"`
	ARN            string            `json:"arn"`
	Expression     string            `json:"expression,omitempty"`
	ExpressionType string            `json:"expressionType,omitempty"`
	RoleArn        string            `json:"roleArn,omitempty"`
	Description    string            `json:"description,omitempty"`
	// AccountID and Region exist purely for store.Table's keyFn; see the
	// identical comment on WirelessDevice above.
	AccountID string `json:"-"`
	Region    string `json:"-"`
}

type DeviceProfile struct {
	CreatedAt time.Time         `json:"createdAt"`
	Tags      map[string]string `json:"tags,omitempty"`
	// LoRaWAN and Sidewalk hold the LoRaWANDeviceProfile /
	// SidewalkGetDeviceProfile configuration objects supplied at creation
	// time, echoed back verbatim on Get -- see the identical comment on
	// WirelessDevice.LoRaWAN above.
	LoRaWAN  map[string]any `json:"loRaWAN,omitempty"`
	Sidewalk map[string]any `json:"sidewalk,omitempty"`
	Name     string         `json:"name"`
	ID       string         `json:"id"`
	ARN      string         `json:"arn"`
	// AccountID and Region exist purely for store.Table's keyFn; see the
	// identical comment on WirelessDevice above.
	AccountID string `json:"-"`
	Region    string `json:"-"`
}

type EventConfigDoc struct {
	ConnectionStatus        map[string]any `json:"ConnectionStatus,omitempty"`
	DeviceRegistrationState map[string]any `json:"DeviceRegistrationState,omitempty"`
	Join                    map[string]any `json:"Join,omitempty"`
	MessageDeliveryStatus   map[string]any `json:"MessageDeliveryStatus,omitempty"`
	Proximity               map[string]any `json:"Proximity,omitempty"`
}

type ExportedServiceProfile = ServiceProfile

type ExportedWirelessDevice = WirelessDevice

type FuotaTask struct {
	CreatedAt time.Time         `json:"createdAt"`
	Tags      map[string]string `json:"tags,omitempty"`
	// LoRaWAN holds the LoRaWANFuotaTask configuration object supplied at
	// creation time, echoed back verbatim on Get -- see the identical
	// comment on WirelessDevice.LoRaWAN above.
	LoRaWAN             map[string]any `json:"loRaWAN,omitempty"`
	Name                string         `json:"name"`
	ID                  string         `json:"id"`
	ARN                 string         `json:"arn"`
	Description         string         `json:"description,omitempty"`
	FirmwareUpdateImage string         `json:"firmwareUpdateImage,omitempty"`
	FirmwareUpdateRole  string         `json:"firmwareUpdateRole,omitempty"`
	// Descriptor is the base64-encoded firmware metadata blob.
	Descriptor string `json:"descriptor,omitempty"`
	// Status tracks the FUOTA task lifecycle (Pending, FuotaSession_Waiting,
	// In_FuotaSession, FuotaDone, Delete_Waiting), matching
	// types.FuotaTaskStatus. Set to "Pending" at creation and advanced by
	// StartFuotaTask; previously this was fabricated by overwriting
	// FirmwareUpdateRole, corrupting that field -- see StartFuotaTask.
	Status string `json:"status,omitempty"`
	// AccountID and Region exist purely for store.Table's keyFn; see the
	// identical comment on WirelessDevice above.
	AccountID          string `json:"-"`
	Region             string `json:"-"`
	FragmentIntervalMS int32  `json:"fragmentIntervalMs,omitempty"`
	FragmentSizeBytes  int32  `json:"fragmentSizeBytes,omitempty"`
	RedundancyPercent  int32  `json:"redundancyPercent,omitempty"`
}

type GatewayTask struct {
	CreatedAt         time.Time
	WirelessGatewayID string
	TaskDefID         string
	Status            string
}

type GatewayTaskDefinition struct {
	Update          map[string]any
	ID              string
	ARN             string
	Name            string
	AutoCreateTasks bool
}

type Handler struct {
	Backend       StorageBackend
	AccountID     string
	DefaultRegion string
}

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

type LogLevelsConfig struct {
	DefaultLogLevel           string
	FuotaTaskLogOptions       []map[string]any
	WirelessDeviceLogOptions  []map[string]any
	WirelessGatewayLogOptions []map[string]any
}

type MulticastGroup struct {
	CreatedAt time.Time         `json:"createdAt"`
	Tags      map[string]string `json:"tags,omitempty"`
	// LoRaWAN holds the LoRaWANMulticast configuration object supplied at
	// creation time, echoed back verbatim on Get -- see the identical
	// comment on WirelessDevice.LoRaWAN above.
	LoRaWAN     map[string]any `json:"loRaWAN,omitempty"`
	Name        string         `json:"name"`
	ID          string         `json:"id"`
	ARN         string         `json:"arn"`
	Description string         `json:"description,omitempty"`
	Status      string         `json:"status"`
	// AccountID and Region exist purely for store.Table's keyFn; see the
	// identical comment on WirelessDevice above.
	AccountID string `json:"-"`
	Region    string `json:"-"`
}

type NetworkAnalyzerConfig struct {
	Tags        map[string]string `json:"tags,omitempty"`
	Name        string            `json:"name"`
	ARN         string            `json:"arn"`
	Description string            `json:"description,omitempty"`
	AccountID   string            `json:"-"`
	Region      string            `json:"-"`
	// TraceContent holds the TraceContent object (LogLevel,
	// MulticastFrameInfo, WirelessDeviceFrameInfo) supplied at creation or
	// update time, echoed back verbatim on Get -- see the identical comment
	// on WirelessDevice.LoRaWAN above.
	TraceContent     map[string]any `json:"traceContent,omitempty"`
	WirelessDevices  []string       `json:"wirelessDevices,omitempty"`
	WirelessGateways []string       `json:"wirelessGateways,omitempty"`
	MulticastGroups  []string       `json:"multicastGroups,omitempty"`
}

type PositionConfigEntry struct {
	Solvers            map[string]any `json:"solvers,omitempty"`
	ResourceIdentifier string         `json:"resourceIdentifier"`
	ResourceType       string         `json:"resourceType"`
	Destination        string         `json:"destination,omitempty"`
}

type Provider struct{}

type QueuedMessage struct {
	ReceivedAt    time.Time
	MessageID     string
	PayloadBase64 string
	TransmitMode  int32
}

type Resettable interface {
	Reset()
}

type ResourceEventConfigEntry struct {
	Config         EventConfigDoc `json:"config"`
	Identifier     string         `json:"identifier"`
	IdentifierType string         `json:"identifierType"`
	PartnerType    string         `json:"partnerType,omitempty"`
}

type ServiceProfile struct {
	CreatedAt time.Time         `json:"createdAt"`
	Tags      map[string]string `json:"tags,omitempty"`
	// LoRaWAN holds the LoRaWANServiceProfile configuration object supplied
	// at creation time, echoed back verbatim on Get -- see the identical
	// comment on WirelessDevice.LoRaWAN above.
	LoRaWAN map[string]any `json:"loRaWAN,omitempty"`
	Name    string         `json:"name"`
	ID      string         `json:"id"`
	ARN     string         `json:"arn"`
	// AccountID and Region exist purely for store.Table's keyFn; see the
	// identical comment on WirelessDevice above.
	AccountID string `json:"-"`
	Region    string `json:"-"`
}

type SingleWirelessDeviceImportTask struct {
	CreatedAt        time.Time `json:"createdAt"`
	ARN              string    `json:"arn"`
	WirelessDeviceID string    `json:"wirelessDeviceId"`
	DestinationName  string    `json:"destinationName"`
	Status           string    `json:"status"`
}

type Snapshottable interface {
	Snapshot(ctx context.Context) []byte
	Restore(ctx context.Context, data []byte) error
}

type StorageBackend interface {
	Reset()

	CreateWirelessDevice(
		accountID, region, name, devType, destinationName, description, positioning string,
		loRaWAN, sidewalk map[string]any,
		tags map[string]string,
	) (*WirelessDevice, error)
	GetWirelessDevice(accountID, region, id string) (*WirelessDevice, error)
	ListWirelessDevices(accountID, region string) []*WirelessDevice
	DeleteWirelessDevice(accountID, region, id string) error

	CreateWirelessGateway(
		accountID, region, name, description string,
		loRaWAN map[string]any,
		tags map[string]string,
	) (*WirelessGateway, error)
	GetWirelessGateway(accountID, region, id string) (*WirelessGateway, error)
	ListWirelessGateways(accountID, region string) []*WirelessGateway
	DeleteWirelessGateway(accountID, region, id string) error

	CreateServiceProfile(
		accountID, region, name string,
		loRaWAN map[string]any,
		tags map[string]string,
	) (*ServiceProfile, error)
	GetServiceProfile(accountID, region, id string) (*ServiceProfile, error)
	ListServiceProfiles(accountID, region string) []*ServiceProfile
	DeleteServiceProfile(accountID, region, id string) error

	CreateDestination(
		accountID, region, name, expression, expressionType, roleArn, description string,
		tags map[string]string,
	) (*Destination, error)
	GetDestination(accountID, region, name string) (*Destination, error)
	ListDestinations(accountID, region string) []*Destination
	DeleteDestination(accountID, region, name string) error

	CreateDeviceProfile(
		accountID, region, name string,
		loRaWAN, sidewalk map[string]any,
		tags map[string]string,
	) (*DeviceProfile, error)
	GetDeviceProfile(accountID, region, id string) (*DeviceProfile, error)
	ListDeviceProfiles(accountID, region string) []*DeviceProfile
	DeleteDeviceProfile(accountID, region, id string) error

	CreateFuotaTask(
		accountID, region, name, description, firmwareUpdateImage, firmwareUpdateRole, descriptor string,
		fragmentIntervalMS, fragmentSizeBytes, redundancyPercent int32,
		loRaWAN map[string]any,
		tags map[string]string,
	) (*FuotaTask, error)
	GetFuotaTask(accountID, region, id string) (*FuotaTask, error)
	ListFuotaTasks(accountID, region string) []*FuotaTask
	DeleteFuotaTask(accountID, region, id string) error
	UpdateFuotaTask(accountID, region, id, name, description string) error

	UpdateWirelessGateway(accountID, region, id, name, description string, loRaWANUpdates map[string]any) error

	UpdateDestination(accountID, region, name, expression, expressionType, roleArn, description string) error

	CreateMulticastGroup(
		accountID, region, name, description string,
		loRaWAN map[string]any,
		tags map[string]string,
	) (*MulticastGroup, error)
	GetMulticastGroup(accountID, region, id string) (*MulticastGroup, error)
	ListMulticastGroups(accountID, region string) []*MulticastGroup
	DeleteMulticastGroup(accountID, region, id string) error
	UpdateMulticastGroup(accountID, region, id, name, description string) error

	CreateNetworkAnalyzerConfig(
		accountID, region, name, description string,
		wirelessDevices, wirelessGateways, multicastGroups []string,
		traceContent map[string]any,
		tags map[string]string,
	) (*NetworkAnalyzerConfig, error)
	GetNetworkAnalyzerConfig(accountID, region, name string) (*NetworkAnalyzerConfig, error)
	ListNetworkAnalyzerConfigs(accountID, region string) []*NetworkAnalyzerConfig
	DeleteNetworkAnalyzerConfig(accountID, region, name string) error
	UpdateNetworkAnalyzerConfig(
		accountID, region, name, description string,
		wirelessDevices, wirelessGateways []string,
		traceContent map[string]any,
	) error

	AssociateAwsAccountWithPartnerAccount(
		accountID, region, partnerAccountID string,
		tags map[string]string,
	) (string, error)
	AssociateMulticastGroupWithFuotaTask(fuotaTaskID, multicastGroupID string) error
	AssociateWirelessDeviceWithFuotaTask(fuotaTaskID, wirelessDeviceID string) error
	AssociateWirelessDeviceWithMulticastGroup(multicastGroupID, wirelessDeviceID string) error
	AssociateWirelessDeviceWithThing(accountID, region, wirelessDeviceID, thingArn string) error
	AssociateWirelessGatewayWithCertificate(accountID, region, gatewayID, iotCertificateID string) (string, error)
	AssociateWirelessGatewayWithThing(accountID, region, gatewayID, thingArn string) error
	CancelMulticastGroupSession(multicastGroupID string) error
	ListMulticastGroupDeviceIDs(multicastGroupID string) []string
	ListFuotaTaskDeviceIDs(fuotaTaskID string) []string
	StartBulkAssociateWirelessDeviceWithMulticastGroup(accountID, region, multicastGroupID string) error
	StartBulkDisassociateWirelessDeviceFromMulticastGroup(multicastGroupID string) error

	// GetWirelessDeviceThingArn returns the ARN of the IoT Thing associated
	// with a wireless device via AssociateWirelessDeviceWithThing, or "" if
	// none is associated. Used by GetWirelessDevice to surface ThingArn/
	// ThingName, matching real AWS's response shape.
	GetWirelessDeviceThingArn(wirelessDeviceID string) string
	// GetWirelessGatewayThingArn returns the ARN of the IoT Thing associated
	// with a wireless gateway via AssociateWirelessGatewayWithThing, or "" if
	// none is associated. Used by GetWirelessGateway to surface ThingArn/
	// ThingName, matching real AWS's response shape.
	GetWirelessGatewayThingArn(gatewayID string) string

	// Extended operations implemented across the various <family>.go files.
	StartFuotaTask(accountID, region, id string) error
	DisassociateWirelessDeviceFromFuotaTask(fuotaTaskID, wirelessDeviceID string) error
	ListMulticastGroupsByFuotaTask(accountID, region, fuotaTaskID string) []*MulticastGroup
	DisassociateMulticastGroupFromFuotaTask(fuotaTaskID, multicastGroupID string) error
	DisassociateWirelessDeviceFromMulticastGroup(multicastGroupID, wirelessDeviceID string) error
	StartMulticastGroupSession(multicastGroupID string) error
	GetMulticastGroupSession(multicastGroupID string) (time.Time, error)

	DisassociateWirelessGatewayFromCertificate(accountID, region, gatewayID string) error
	DisassociateWirelessGatewayFromThing(accountID, region, gatewayID string) error
	GetWirelessGatewayCertificate(accountID, region, gatewayID string) (string, error)

	UpdateWirelessDevice(
		accountID, region, id, name, description, destinationName, positioning string,
		loRaWAN, sidewalk map[string]any,
	) error
	DisassociateWirelessDeviceFromThing(accountID, region, wirelessDeviceID string) error

	GetPartnerAccount(partnerAccountID string) (string, error)
	ListPartnerAccounts() map[string]string
	DisassociateAwsAccountFromPartnerAccount(partnerAccountID string) error

	GetLogLevelsByResourceTypes() LogLevelsConfig
	UpdateLogLevelsByResourceTypes(cfg LogLevelsConfig) error
	ResetAllResourceLogLevels() error
	GetResourceLogLevel(resourceID string) string
	PutResourceLogLevel(resourceID, logLevel string) error
	ResetResourceLogLevel(resourceID string) error

	CreateWirelessGatewayTask(gatewayID, taskDefID string) (*GatewayTask, error)
	GetWirelessGatewayTask(gatewayID string) (*GatewayTask, error)
	DeleteWirelessGatewayTask(gatewayID string) error
	CreateWirelessGatewayTaskDefinition(
		accountID, region, name string,
		autoCreateTasks bool,
		update map[string]any,
	) (*GatewayTaskDefinition, error)
	GetWirelessGatewayTaskDefinition(id string) (*GatewayTaskDefinition, error)
	ListWirelessGatewayTaskDefinitions() []*GatewayTaskDefinition
	DeleteWirelessGatewayTaskDefinition(id string) error

	GetPosition(resourceID string) map[string]any
	UpdatePosition(resourceID string, position map[string]any) error

	PutPositionConfiguration(resourceID, resourceType, destination string, solvers map[string]any) error
	GetPositionConfiguration(resourceID string) (*PositionConfigEntry, bool)
	ListPositionConfigurations(resourceType string) []*PositionConfigEntry

	GetEventConfigurationByResourceTypes() *EventConfigDoc
	UpdateEventConfigurationByResourceTypes(doc *EventConfigDoc)
	ListEventConfigurations(resourceType string) []*ResourceEventConfigEntry
	GetResourceEventConfiguration(identifier string) (*ResourceEventConfigEntry, bool)
	UpdateResourceEventConfiguration(identifier, identifierType, partnerType string, doc *EventConfigDoc)

	GetMetricConfigurationStatus() string
	UpdateMetricConfigurationStatus(status string) error

	ListQueuedMessages(wirelessDeviceID string) []QueuedMessage
	DeleteQueuedMessages(wirelessDeviceID string) error
	EnqueueMessage(wirelessDeviceID string, msg QueuedMessage)

	StartWirelessDeviceImportTask(accountID, region, destinationName string) (*WirelessDeviceImportTask, error)
	StartSingleWirelessDeviceImportTask(
		accountID, region, destinationName string,
	) (*SingleWirelessDeviceImportTask, error)
	GetWirelessDeviceImportTask(id string) (*WirelessDeviceImportTask, error)
	DeleteWirelessDeviceImportTask(id string) error
	UpdateWirelessDeviceImportTask(id, destinationName string) error
	ListWirelessDeviceImportTasks() []*WirelessDeviceImportTask

	TagResource(arn string, tags map[string]string) error
	UntagResource(arn string, tagKeys []string) error
	ListTagsForResource(arn string) (map[string]string, error)
}

type WirelessDevice struct {
	CreatedAt            time.Time         `json:"createdAt"`
	LastUplinkReceivedAt *time.Time        `json:"lastUplinkReceivedAt,omitempty"`
	Tags                 map[string]string `json:"tags,omitempty"`
	// LoRaWAN and Sidewalk hold the request's nested LoRaWAN/Sidewalk
	// configuration object verbatim (whatever JSON object the client sent in
	// CreateWirelessDevice/UpdateWirelessDevice), round-tripped back exactly
	// on Get/List. Stored opaquely rather than as individually typed fields
	// because the real shapes (types.LoRaWANDevice / SidewalkCreateWirelessDevice)
	// carry many optional nested vendor sub-objects (ABP/OTAA session keys,
	// FPorts, ...); this still captures real, non-fabricated client state.
	LoRaWAN         map[string]any `json:"loRaWAN,omitempty"`
	Sidewalk        map[string]any `json:"sidewalk,omitempty"`
	Positioning     string         `json:"positioning,omitempty"`
	Name            string         `json:"name"`
	ID              string         `json:"id"`
	ARN             string         `json:"arn"`
	Description     string         `json:"description,omitempty"`
	Type            string         `json:"type"`
	DestinationName string         `json:"destinationName,omitempty"`
	// AccountID and Region are not part of the AWS wire shape for this
	// resource; they exist purely so store.Table's keyFn (store_setup.go) can
	// derive the account+region-scoped composite key this backend requires.
	// Tagged json:"-" so they never leak into an API response; Snapshot/
	// Restore round-trips them via the deviceSnapshot DTO instead (see
	// persistence.go).
	AccountID string `json:"-"`
	Region    string `json:"-"`
}

type WirelessDeviceImportTask struct {
	CreatedAt                      time.Time `json:"createdAt"`
	ID                             string    `json:"id"`
	ARN                            string    `json:"arn"`
	DestinationName                string    `json:"destinationName"`
	Status                         string    `json:"status"`
	StatusReason                   string    `json:"statusReason,omitempty"`
	InitializedImportedDeviceCount int64     `json:"initializedImportedDeviceCount"`
	PendingImportedDeviceCount     int64     `json:"pendingImportedDeviceCount"`
	OnboardedImportedDeviceCount   int64     `json:"onboardedImportedDeviceCount"`
	FailedImportedDeviceCount      int64     `json:"failedImportedDeviceCount"`
}

type WirelessGateway struct {
	CreatedAt            time.Time         `json:"createdAt"`
	LastUplinkReceivedAt *time.Time        `json:"lastUplinkReceivedAt,omitempty"`
	Tags                 map[string]string `json:"tags,omitempty"`
	// LoRaWAN holds the request's nested LoRaWAN gateway configuration object
	// (GatewayEui, RfRegion, JoinEuiFilters, NetIdFilters, MaxEirp, SubBands,
	// Beaconing, ...) verbatim -- see the identical comment on
	// WirelessDevice.LoRaWAN above for why this is stored opaquely.
	LoRaWAN          map[string]any `json:"loRaWAN,omitempty"`
	Name             string         `json:"name"`
	ID               string         `json:"id"`
	ARN              string         `json:"arn"`
	Description      string         `json:"description,omitempty"`
	ConnectionStatus string         `json:"connectionStatus,omitempty"`
	FirmwareVersion  string         `json:"firmwareVersion,omitempty"`
	FirmwareModel    string         `json:"firmwareModel,omitempty"`
	FirmwareStation  string         `json:"firmwareStation,omitempty"`
	// AccountID and Region exist purely for store.Table's keyFn; see the
	// identical comment on WirelessDevice above.
	AccountID string `json:"-"`
	Region    string `json:"-"`
}