lbs

type Alarm struct {
	FenceId          string     `json:"fence_id,noempty"`
	FenceName        string     `json:"fence_name,noempty"`
	MonitoredObjects []string   `json:"monitored_objects"`
	Action           string     `json:"action"`
	AlarmPoint       AlarmPoint `json:"alarm_point"`
	PrePoint         AlarmPoint `json:"pre_point"`
}

type AlarmHistory struct {
	FenceId         int               `json:"fence_id"`
	FenceName       string            `json:"fence_name"`
	MonitoredPerson string            `json:"monitored_person"`
	Action          string            `json:"action"`
	AlarmPoint      HistoryAlarmPoint `json:"alarm_point"`
	PrePoint        HistoryPrePoint   `json:"pre_point"`
}

type AlarmInfo struct {
	FenceId          int            `json:"fence_id,noempty"`
	FenceName        string         `json:"fence_name,noempty"`
	MonitoredObjects string         `json:"monitored_person"`
	Action           string         `json:"action"`
	AlarmPoint       AlarmPointInfo `json:"alarm_point"`
	PrePoint         AlarmPointInfo `json:"pre_point"`
	UserId           string
}

type AlarmInfos struct {
	Type      int         `json:"type"`
	ServiceId int         `json:"service_id"`
	Alarms    []AlarmInfo `json:"content"`
}

type AlarmNotification struct {
	Type      int      `json:"type"`
	ServiceId string   `json:"service_id"`
	Alarms    []*Alarm `json:"alarms"`
}

type AlarmPoint struct {
	Longitude  float64    `json:"longitude"`
	Latitude   float64    `json:"latitude"`
	Radius     int        `json:"radius"`
	CoordType  string     `json:"coord_type"`
	LocTime    *time.Time `json:"loc_time"`
	CreateTime *time.Time `json:"create_time"`
}

type AlarmPointInfo struct {
	Longitude  float64 `json:"longitude"`
	Latitude   float64 `json:"latitude"`
	Radius     int     `json:"radius"`
	CoordType  string  `json:"coord_type"`
	LocTime    int     `json:"loc_time"`
	CreateTime int     `json:"create_time"`
}

type AlarmTopic struct {
	TopicName string
	Alarm     *AlarmNotification `json:"alarm"`
}

type BaiduBatchHistoryAlarmsResp struct {
	Status  int            `json:"status"`
	Message string         `json:"message"`
	Size    int            `json:"size"`
	Total   int            `json:"total"`
	Alarms  []AlarmHistory `json:"alarms"`
}

type BaiduGetHistoryAlarmsResponse struct {
	Status  int            `json:"status"`
	Message string         `json:"message"`
	Size    int            `json:"size"`
	Alarms  []AlarmHistory `json:"alarms"`
}

type BaiduGetStayPointResp struct {
	Status     int     `json:"status"`
	Message    string  `json:"message"`
	Size       int     `json:"size"`
	Total      int     `json:"total"`
	StartPoint Point   `json:"start_point"`
	EndPoint   Point   `json:"end_point"`
	Points     []Point `json:"points"`
}

type BaiduQueryStatusResponse struct {
	Status            int               `json:"status"`
	Message           string            `json:"message"`
	Size              int               `json:"size"`
	MonitoredStatuses []MonitoredStatus `json:"monitored_statuses"`
}

type CircleGeofence struct {
	Name             string
	MonitoredObjects string
	Longitude        float64
	Latitude         float64
	Radius           float64
	CoordType        CoordType
	Denoise          int
	FenceId          string
}

type Collection struct {
	UserId        string    `bson:"user_id"`
	CollectionId  string    `bson:"collection_id"`
	CreatedAt     time.Time `bson:"created_at"`
	LastUpdatedAt time.Time `bson:"last_updated_at"`
	Status        string    `bson:"status"`
}

type Config struct {
	AccessKey string
	ServiceId string
}

type CoordType string

type Engine interface {
	// Add monitored object's track points
	AddTrackPoint(point TrackPoint)
	AddTrackPoints(points []TrackPoint)
	// Create circle geofence and return goefence id if successful
	CreateCircleGeofence(c CircleGeofence) (string, error)
	// Update an existed geofence
	UpdateCircleGeofence(c CircleGeofence) error
	// Delete an existed geofence or monitored objects
	DeleteGeofence(fenceIds []string, objects []string) ([]string, error)
	// List geofences matched with ids or objects
	ListGeofence(fenceIds []string, objects []string) ([]*Geofence, error)
	// Add monitored object for specifed geofence
	AddMonitoredObject(fenceId string, objects []string) error
	// Remove monitored object from specified geofence
	RemoveMonitoredObject(fenceId string, objects []string) error
	// List monitored object in specifed geofence
	ListMonitoredObjects(fenceId string, pageIndex int, pageSize int) (int, []string)
	// Create poly geofence and return goefence id if successful
	CreatePolyGeofence(c PolyGeofence) (string, error)
	// Update an existed poly geofence
	UpdatePolyGeofence(c PolyGeofence) error

	// Alarms
	QueryStatus(monitoredPerson string, fenceIds []string) (BaiduQueryStatusResponse, error)
	GetHistoryAlarms(monitoredPerson string, fenceIds []string) (BaiduGetHistoryAlarmsResponse, error)
	BatchGetHistoryAlarms(input *grpc_pandas_v1.BatchGetHistoryAlarmsRequest) (BaiduBatchHistoryAlarmsResp, error)
	GetStayPoints(input *grpc_pandas_v1.GetStayPointsRequest) (BaiduGetStayPointResp, error)
	UnmarshalAlarmNotification(content []byte) (*AlarmNotification, error)

	//Entity
	AddEntity(EntityName string, EntityDesc string) error
	UpdateEntity(EntityName string, EntityDesc string) error
	DeleteEntity(EntityName string) error
	ListEntity(userId string, collectionId string, CoordTypeOutput string, PageIndex int32, pageSize int32) (int, baiduListEntityStruct)
}

type Entity struct {
	EntityName   string             `json:"entity_name"`
	EntityDesc   string             `json:"entity_desc"`
	LastLocation LastLocationStruct `json:"latest_location"`
}

type EntityRecord struct {
	UserId        string    `bson:"user_id"`
	CollectionId  string    `bson:"collection_id"`
	EntityName    string    `bson:"entity_name"`
	CreatedAt     time.Time `bson:"created_at"`
	LastUpdatedAt time.Time `bson:"last_updated_at"`
}

type Geofence struct {
	FenceId         int       `json:"fence_id"`
	FenceName       string    `json:"fence_name"`
	MonitoredObject string    `json:"monitored_person"`
	Shape           string    `json:"shape"`
	Longitude       float64   `json:"longitude"`
	Latitude        float64   `json:"latitude"`
	Radius          float64   `json:"radius"`
	CoordType       CoordType `json:"coord_type"`
	Denoise         int       `json:"denoise"`
	CreateTime      string    `json:"create_time"`
	UpdateTime      string    `json:"modify_time"`
	Vertexes        []Vertexe `json:"vertexes"`
}

type HistoryAlarmPoint struct {
	Longitude  float64 `json:"longitude"`
	Latitude   float64 `json:"latitude"`
	Radius     int     `json:"radius"`
	CoordType  string  `json:"coord_type"`
	LocTime    string  `json:"loc_time"`
	CreateTime string  `json:"create_time"`
}

type HistoryPrePoint struct {
	Longitude  float64 `json:"longitude"`
	Latitude   float64 `json:"latitude"`
	Radius     int     `json:"radius"`
	CoordType  string  `json:"coord_type"`
	LocTime    string  `json:"loc_time"`
	CreateTime string  `json:"create_time"`
}

type LastLocationStruct struct {
	Latitude  float64 `json:"latitude"`
	Longitude float64 `json:"longitude"`
}

type Location struct {
	Latitude  float64 `json:"latitude"`
	Longitude float64 `json:"longitude"`
	Time      string  `json:"loc_time"`
}

type Manager interface {
	// Add monitored object's track points
	AddTrackPoint(principal auth.Principal, point TrackPoint)
	AddTrackPoints(principal auth.Principal, points []TrackPoint)
	// Create circle geofence and return goefence id if successful
	CreateCircleGeofence(principal auth.Principal, c CircleGeofence) (string, error)
	// Update an existed geofence
	UpdateCircleGeofence(principal auth.Principal, c CircleGeofence) error
	// Delete an existed geofence or monitored objects
	DeleteGeofence(principal auth.Principal, fenceIds []string, objects []string) ([]string, error)
	// List geofences matched with ids or objects
	ListGeofence(principal auth.Principal, fenceIds []string, objects []string) ([]*Geofence, error)
	// Add monitored object for specifed geofence
	AddMonitoredObject(principal auth.Principal, fenceId string, objects []string) error
	// Remove monitored object from specified geofence
	RemoveMonitoredObject(principal auth.Principal, fenceId string, objects []string) error
	// List monitored object in specifed geofence
	ListMonitoredObjects(principal auth.Principal, fenceId string, pageIndex int, pageSize int) (int, []string)
	// Create poly geofence and return goefence id if successful
	CreatePolyGeofence(principal auth.Principal, c PolyGeofence) (string, error)
	// Update an existed poly geofence
	UpdatePolyGeofence(principal auth.Principal, c PolyGeofence) error

	// Alarms
	QueryStatus(principal auth.Principal, monitoredPerson string, fenceIds []string) (BaiduQueryStatusResponse, error)
	GetHistoryAlarms(principal auth.Principal, monitoredPerson string, fenceIds []string) (BaiduGetHistoryAlarmsResponse, error)
	BatchGetHistoryAlarms(principal auth.Principal, input *grpc_pandas_v1.BatchGetHistoryAlarmsRequest) (BaiduBatchHistoryAlarmsResp, error)
	GetStayPoints(principal auth.Principal, input *grpc_pandas_v1.GetStayPointsRequest) (BaiduGetStayPointResp, error)
	UnmarshalAlarmNotification(principal auth.Principal, content []byte) (*AlarmNotification, error)

	//Entity
	AddEntity(principal auth.Principal, EntityName string, EntityDesc string) error
	UpdateEntity(principal auth.Principal, EntityName string, EntityDesc string) error
	DeleteEntity(principal auth.Principal, EntityName string) error
	ListEntity(principal auth.Principal, collectionId string, CoordTypeOutput string, PageIndex int32, pageSize int32) (int, baiduListEntityStruct)
}

type MonitoredStatus struct {
	FenceId         int    `json:"fence_id"`
	MonitoredStatus string `json:"monitored_status"`
}

type Point struct {
	Longitude float64 `json:"longitude"`
	Latitude  float64 `json:"latitude"`
	CoordType string  `json:"coord_type"`
	LocTime   int     `json:"loc_time"`
}

type PolyGeofence struct {
	Name             string
	MonitoredObjects string
	Vertexes         string
	CoordType        CoordType
	Denoise          int
	FenceId          string
}

type Repository interface {
	// Helper
	AddCollection(userId string, collectionId string) error
	RemoveCollection(userId string, collectionId string) error
	GetAllCollections() ([]*Collection, error)
	UpdateCollection(userId string, p *Collection) error

	// Geofences
	AddGeofence(userId string, collectionId string, fenceName string, fenceId string) error
	RemoveGeofence(userId string, collectionId string, fenceId string) error
	IsGeofenceExistWithName(userId string, collectionId string, fenceName string) bool
	IsGeofenceExistWithId(userId string, collectionId string, fenceId string) bool
	GetFences(userId, collectionId string) ([]*geofenceRecord, error)
	GetFenceUserId(fenceId string) (string, error)

	//Entity
	AddEntity(userId string, collectionId string, entityName string) error
	DeleteEntity(userId string, collectionId string, entityName string) error
	UpdateEntity(userId string, collectionId string, entityName string, entity EntityRecord) error
	IsEntityExistWithName(userId string, collectionId string, entityName string) bool
	GetEntities(userId string, collectionId string) ([]*EntityRecord, error)

	Close()
}

type TrackPoint struct {
	EntityName string    `json:"entity_name"`
	Latitude   float64   `json:"latitude"`
	Longitude  float64   `json:"longitude"`
	CoordType  CoordType `json:"coord_type_input"`
	Time       string    `json:"loc_time"`
}

type UserId struct {
	UserId string `bson:"user_id"`
}

type Vertexe struct {
	Longitude float64 `json:"longitude"`
	Latitude  float64 `json:"latitude"`
}