processors

type FenceData struct {
	H3Indexes []string `json:"h3Indexes"`
}

type Privacy struct {
	Group        goka.Group
	StatusInput  goka.Stream
	FenceTable   goka.Table
	StatusOutput goka.Stream

	Logger *zerolog.Logger
}

type PrivacyV2 struct {
	Group        goka.Group
	StatusInput  goka.Stream
	FenceTable   goka.Table
	StatusOutput goka.Stream

	Logger *zerolog.Logger
}

type SignalData struct {
	// Timestamp is in unix millis, when signal was queried
	Timestamp int64  `json:"timestamp,omitempty"`
	Name      string `json:"name,omitempty"`
	Value     any    `json:"value,omitempty"`
}

type StatusData struct {
	Latitude   *float64       `json:"latitude"`
	Longitude  *float64       `json:"longitude"`
	IsRedacted *bool          `json:"isRedacted"`
	Overflow   map[string]any `json:"-"`
}

type StatusEventV2[A any] struct {
	shared.CloudEvent[A]
	Signature string `json:"signature"`
}

type StatusV2Data struct {
	// Timestamp is in unix millis, when payload was sent
	Timestamp int64                  `json:"timestamp,omitempty"`
	Device    map[string]interface{} `json:"device,omitempty"`
	Vehicle   Vehicle                `json:"vehicle,omitempty"`
}

type Vehicle struct {
	Make    string       `json:"make,omitempty"`
	Model   string       `json:"model,omitempty"`
	Year    int          `json:"year,omitempty"`
	Signals []SignalData `json:"signals,omitempty"`
}