callhome

type CountrySummary struct {
	Country       string `json:"country" db:"country"`
	NoDeployments int    `json:"number_of_deployments" db:"count"`
}

type LocationService interface {
	// GetLocation returns the location information for a given IP address.
	GetLocation(ctx context.Context, ip string) (ip2location.IP2Locationrecord, error)
}

type PageMetadata struct {
	Total  uint64
	Offset uint64
	Limit  uint64
}

type Service interface {
	// Save saves the homing telemetry data and its location information.
	Save(ctx context.Context, t Telemetry) error
	// Retrieve retrieves homing telemetry data from the specified repository.
	Retrieve(ctx context.Context, pm PageMetadata, filters TelemetryFilters) (TelemetryPage, error)
	// RetrieveSummary gets distinct countries and ip addresses
	RetrieveSummary(ctx context.Context, filters TelemetryFilters) (TelemetrySummary, error)
	// ServeUI gets the callhome index html page
	ServeUI(ctx context.Context, filters TelemetryFilters) ([]byte, error)
}

type Telemetry struct {
	Services    pq.StringArray `json:"services,omitempty" db:"services"`
	Service     string         `json:"service,omitempty" db:"service"`
	Longitude   float64        `json:"longitude,omitempty" db:"longitude"`
	Latitude    float64        `json:"latitude,omitempty" db:"latitude"`
	IpAddress   string         `json:"-" db:"ip_address"`
	Version     string         `json:"magistrala_version,omitempty" db:"mg_version"`
	LastSeen    time.Time      `json:"last_seen" db:"service_time"`
	Country     string         `json:"country,omitempty" db:"country"`
	City        string         `json:"city,omitempty" db:"city"`
	ServiceTime time.Time      `json:"timestamp" db:"time"`
}

type TelemetryFilters struct {
	From    time.Time
	To      time.Time
	Country string
	City    string
	Version string
	Service string
}

type TelemetryPage struct {
	PageMetadata
	Telemetry []Telemetry
}

type TelemetryRepo interface {
	// Save persists the telemetry event. A non-nil error is returned to indicate
	// operation failure.
	Save(ctx context.Context, t Telemetry) error

	// RetrieveAll retrieves all telemetry events.
	RetrieveAll(ctx context.Context, pm PageMetadata, filters TelemetryFilters) (TelemetryPage, error)
	// RetrieveSummary gets distinct countries, cities,services and versions in a summarised form.
	RetrieveSummary(ctx context.Context, filters TelemetryFilters) (TelemetrySummary, error)
}

type TelemetrySummary struct {
	Countries        []CountrySummary `json:"countries,omitempty"`
	Cities           []string         `json:"cities,omitempty"`
	Services         []string         `json:"services,omitempty"`
	Versions         []string         `json:"versions,omitempty"`
	TotalDeployments int              `json:"total_deployments,omitempty"`
}