models

type API interface {
	Start()
	GetConfig() *configuration.Config

	GetAcceptedPaths() []string
	GetVersionInfo() *VersionInfo
	GetBasePathInfo() *entities.ArrayResponse
	GetEndpoints() *map[entities.EntityType]Endpoint
	GetTopics(prefix string) *[]Topic

	GetThing(id interface{}, qo *odata.QueryOptions, path string) (*entities.Thing, error)
	GetThingByDatastream(id interface{}, qo *odata.QueryOptions, path string) (*entities.Thing, error)
	GetThingsByLocation(id interface{}, qo *odata.QueryOptions, path string) (*entities.ArrayResponse, error)
	GetThingByHistoricalLocation(id interface{}, qo *odata.QueryOptions, path string) (*entities.Thing, error)
	GetThings(qo *odata.QueryOptions, path string) (*entities.ArrayResponse, error)
	PostThing(thing *entities.Thing) (*entities.Thing, []error)
	PatchThing(id interface{}, thing *entities.Thing) (*entities.Thing, error)
	PutThing(id interface{}, thing *entities.Thing) (*entities.Thing, []error)
	DeleteThing(id interface{}) error

	GetLocation(id interface{}, qo *odata.QueryOptions, path string) (*entities.Location, error)
	GetLocations(qo *odata.QueryOptions, path string) (*entities.ArrayResponse, error)
	GetLocationsByHistoricalLocation(hlID interface{}, qo *odata.QueryOptions, path string) (*entities.ArrayResponse, error)
	GetLocationsByThing(thingID interface{}, qo *odata.QueryOptions, path string) (*entities.ArrayResponse, error)
	PostLocation(location *entities.Location) (*entities.Location, []error)
	PostLocationByThing(thingID interface{}, location *entities.Location) (*entities.Location, []error)
	PatchLocation(id interface{}, location *entities.Location) (*entities.Location, error)
	PutLocation(id interface{}, location *entities.Location) (*entities.Location, []error)
	DeleteLocation(id interface{}) error

	GetHistoricalLocation(id interface{}, qo *odata.QueryOptions, path string) (*entities.HistoricalLocation, error)
	GetHistoricalLocations(qo *odata.QueryOptions, path string) (*entities.ArrayResponse, error)
	GetHistoricalLocationsByLocation(locationID interface{}, qo *odata.QueryOptions, path string) (*entities.ArrayResponse, error)
	GetHistoricalLocationsByThing(thingID interface{}, qo *odata.QueryOptions, path string) (*entities.ArrayResponse, error)
	PostHistoricalLocation(hl *entities.HistoricalLocation) (*entities.HistoricalLocation, []error)
	PutHistoricalLocation(id interface{}, hl *entities.HistoricalLocation) (*entities.HistoricalLocation, []error)
	PatchHistoricalLocation(id interface{}, hl *entities.HistoricalLocation) (*entities.HistoricalLocation, error)
	DeleteHistoricalLocation(id interface{}) error

	GetDatastream(id interface{}, qo *odata.QueryOptions, path string) (*entities.Datastream, error)
	GetDatastreams(qo *odata.QueryOptions, path string) (*entities.ArrayResponse, error)
	GetDatastreamByObservation(id interface{}, qo *odata.QueryOptions, path string) (*entities.Datastream, error)
	GetDatastreamsByThing(thingID interface{}, qo *odata.QueryOptions, path string) (*entities.ArrayResponse, error)
	GetDatastreamsBySensor(sensorID interface{}, qo *odata.QueryOptions, path string) (*entities.ArrayResponse, error)
	GetDatastreamsByObservedProperty(sensorID interface{}, qo *odata.QueryOptions, path string) (*entities.ArrayResponse, error)
	PostDatastream(datastream *entities.Datastream) (*entities.Datastream, []error)
	PostDatastreamByThing(thingID interface{}, datastream *entities.Datastream) (*entities.Datastream, []error)
	PatchDatastream(id interface{}, datastream *entities.Datastream) (*entities.Datastream, error)
	PutDatastream(id interface{}, datastream *entities.Datastream) (*entities.Datastream, []error)
	DeleteDatastream(id interface{}) error

	GetFeatureOfInterest(id interface{}, qo *odata.QueryOptions, path string) (*entities.FeatureOfInterest, error)
	GetFeatureOfInterestByObservation(id interface{}, qo *odata.QueryOptions, path string) (*entities.FeatureOfInterest, error)
	GetFeatureOfInterests(qo *odata.QueryOptions, path string) (*entities.ArrayResponse, error)
	PostFeatureOfInterest(foi *entities.FeatureOfInterest) (*entities.FeatureOfInterest, []error)
	PatchFeatureOfInterest(id interface{}, foi *entities.FeatureOfInterest) (*entities.FeatureOfInterest, error)
	PutFeatureOfInterest(id interface{}, foi *entities.FeatureOfInterest) (*entities.FeatureOfInterest, []error)
	DeleteFeatureOfInterest(id interface{}) error

	GetObservation(id interface{}, qo *odata.QueryOptions, path string) (*entities.Observation, error)
	GetObservations(qo *odata.QueryOptions, path string) (*entities.ArrayResponse, error)
	GetObservationsByDatastream(datastreamID interface{}, qo *odata.QueryOptions, path string) (*entities.ArrayResponse, error)
	GetObservationsByFeatureOfInterest(foiID interface{}, qo *odata.QueryOptions, path string) (*entities.ArrayResponse, error)
	PostObservation(observation *entities.Observation) (*entities.Observation, []error)
	PostObservationByDatastream(datastreamID interface{}, observation *entities.Observation) (*entities.Observation, []error)
	PatchObservation(id interface{}, observation *entities.Observation) (*entities.Observation, error)
	PutObservation(id interface{}, observation *entities.Observation) (*entities.Observation, []error)
	DeleteObservation(id interface{}) error

	GetObservedProperty(id interface{}, qo *odata.QueryOptions, path string) (*entities.ObservedProperty, error)
	GetObservedProperties(qo *odata.QueryOptions, path string) (*entities.ArrayResponse, error)
	GetObservedPropertyByDatastream(datastreamID interface{}, qo *odata.QueryOptions, path string) (*entities.ObservedProperty, error)
	PostObservedProperty(op *entities.ObservedProperty) (*entities.ObservedProperty, []error)
	PatchObservedProperty(id interface{}, op *entities.ObservedProperty) (*entities.ObservedProperty, error)
	PutObservedProperty(id interface{}, op *entities.ObservedProperty) (*entities.ObservedProperty, []error)
	DeleteObservedProperty(id interface{}) error

	GetSensor(id interface{}, qo *odata.QueryOptions, path string) (*entities.Sensor, error)
	GetSensorByDatastream(id interface{}, qo *odata.QueryOptions, path string) (*entities.Sensor, error)
	GetSensors(qo *odata.QueryOptions, path string) (*entities.ArrayResponse, error)
	PostSensor(sensor *entities.Sensor) (*entities.Sensor, []error)
	PatchSensor(id interface{}, sensor *entities.Sensor) (*entities.Sensor, error)
	DeleteSensor(id interface{}) error
	PutSensor(id interface{}, sensor *entities.Sensor) (*entities.Sensor, []error)

	PostCreateObservations(co *entities.CreateObservations) ([]string, []error)

	LinkLocation(thingID interface{}, locationID interface{}) error
	SetLinks(entity entities.Entity, qo *odata.QueryOptions)
	CreateNextLink(incomingURL string, qo *odata.QueryOptions) string
}

type APIVersion struct {
	Version string `json:"version"`
}

type Database interface {
	Start()
	CreateSchema(location string) error

	GetThing(id interface{}, qo *odata.QueryOptions) (*entities.Thing, error)
	GetThingByDatastream(id interface{}, qo *odata.QueryOptions) (t *entities.Thing, e error)
	GetThingsByLocation(id interface{}, qo *odata.QueryOptions) (t []*entities.Thing, count int, hasNext bool, e error)
	GetThingByHistoricalLocation(id interface{}, qo *odata.QueryOptions) (t *entities.Thing, e error)
	GetThings(qo *odata.QueryOptions) (t []*entities.Thing, count int, hasNext bool, e error)
	PostThing(*entities.Thing) (*entities.Thing, error)
	PatchThing(interface{}, *entities.Thing) (*entities.Thing, error)
	PutThing(interface{}, *entities.Thing) (*entities.Thing, error)
	DeleteThing(id interface{}) error

	GetLocation(id interface{}, qo *odata.QueryOptions) (*entities.Location, error)
	GetLocations(qo *odata.QueryOptions) (l []*entities.Location, count int, hasNext bool, e error)
	GetLocationsByHistoricalLocation(id interface{}, qo *odata.QueryOptions) (l []*entities.Location, count int, hasNext bool, e error)
	GetLocationsByThing(id interface{}, qo *odata.QueryOptions) (l []*entities.Location, count int, hasNext bool, e error)
	GetLocationByDatastreamID(id interface{}, qo *odata.QueryOptions) (*entities.Location, error)
	PostLocation(*entities.Location) (*entities.Location, error)
	LinkLocation(id interface{}, locationID interface{}) error
	PatchLocation(interface{}, *entities.Location) (*entities.Location, error)
	DeleteLocation(id interface{}) error
	PutLocation(interface{}, *entities.Location) (*entities.Location, error)

	GetObservedProperty(id interface{}, qo *odata.QueryOptions) (*entities.ObservedProperty, error)
	GetObservedPropertyByDatastream(id interface{}, qo *odata.QueryOptions) (*entities.ObservedProperty, error)
	GetObservedProperties(qo *odata.QueryOptions) (o []*entities.ObservedProperty, count int, hasNext bool, e error)
	PostObservedProperty(*entities.ObservedProperty) (*entities.ObservedProperty, error)
	PatchObservedProperty(interface{}, *entities.ObservedProperty) (*entities.ObservedProperty, error)
	PutObservedProperty(interface{}, *entities.ObservedProperty) (*entities.ObservedProperty, error)
	DeleteObservedProperty(id interface{}) error

	GetSensor(id interface{}, qo *odata.QueryOptions) (*entities.Sensor, error)
	GetSensorByDatastream(id interface{}, qo *odata.QueryOptions) (*entities.Sensor, error)
	GetSensors(qo *odata.QueryOptions) (s []*entities.Sensor, count int, hasNext bool, e error)
	PostSensor(*entities.Sensor) (*entities.Sensor, error)
	PatchSensor(interface{}, *entities.Sensor) (*entities.Sensor, error)
	PutSensor(interface{}, *entities.Sensor) (*entities.Sensor, error)
	DeleteSensor(id interface{}) error

	GetDatastream(id interface{}, qo *odata.QueryOptions) (*entities.Datastream, error)
	GetDatastreams(qo *odata.QueryOptions) (d []*entities.Datastream, count int, hasNext bool, e error)
	GetDatastreamByObservation(id interface{}, qo *odata.QueryOptions) (*entities.Datastream, error)
	GetDatastreamsByThing(id interface{}, qo *odata.QueryOptions) (d []*entities.Datastream, count int, hasNext bool, e error)
	GetDatastreamsBySensor(id interface{}, qo *odata.QueryOptions) (d []*entities.Datastream, count int, hasNext bool, e error)
	GetDatastreamsByObservedProperty(id interface{}, qo *odata.QueryOptions) (d []*entities.Datastream, count int, hasNext bool, e error)
	PostDatastream(*entities.Datastream) (*entities.Datastream, error)
	PatchDatastream(interface{}, *entities.Datastream) (*entities.Datastream, error)
	DeleteDatastream(id interface{}) error
	DatastreamExists(int) bool
	PutDatastream(interface{}, *entities.Datastream) (*entities.Datastream, error)

	GetFeatureOfInterest(id interface{}, qo *odata.QueryOptions) (*entities.FeatureOfInterest, error)
	GetFeatureOfInterestIDByLocationID(id interface{}) (interface{}, error)
	GetFeatureOfInterestByObservation(id interface{}, qo *odata.QueryOptions) (*entities.FeatureOfInterest, error)
	GetFeatureOfInterests(qo *odata.QueryOptions) (f []*entities.FeatureOfInterest, count int, hasNext bool, e error)
	PostFeatureOfInterest(*entities.FeatureOfInterest) (*entities.FeatureOfInterest, error)
	PutFeatureOfInterest(interface{}, *entities.FeatureOfInterest) (*entities.FeatureOfInterest, error)
	PatchFeatureOfInterest(interface{}, *entities.FeatureOfInterest) (*entities.FeatureOfInterest, error)
	DeleteFeatureOfInterest(id interface{}) error

	GetObservation(id interface{}, qo *odata.QueryOptions) (*entities.Observation, error)
	GetObservations(qo *odata.QueryOptions) (o []*entities.Observation, count int, hasNext bool, e error)
	GetObservationsByDatastream(id interface{}, qo *odata.QueryOptions) (o []*entities.Observation, count int, hasNext bool, e error)
	GetObservationsByFeatureOfInterest(id interface{}, qo *odata.QueryOptions) (o []*entities.Observation, count int, hasNext bool, e error)
	PostObservation(*entities.Observation) (*entities.Observation, error)
	PatchObservation(interface{}, *entities.Observation) (*entities.Observation, error)
	PutObservation(interface{}, *entities.Observation) (*entities.Observation, error)
	DeleteObservation(id interface{}) error

	GetHistoricalLocation(id interface{}, qo *odata.QueryOptions) (*entities.HistoricalLocation, error)
	GetHistoricalLocations(qo *odata.QueryOptions) (h []*entities.HistoricalLocation, count int, hasNext bool, e error)
	GetHistoricalLocationsByLocation(id interface{}, qo *odata.QueryOptions) (h []*entities.HistoricalLocation, count int, hasNext bool, e error)
	GetHistoricalLocationsByThing(id interface{}, qo *odata.QueryOptions) (h []*entities.HistoricalLocation, count int, hasNext bool, e error)
	PostHistoricalLocation(*entities.HistoricalLocation) (*entities.HistoricalLocation, error)
	PutHistoricalLocation(interface{}, *entities.HistoricalLocation) (*entities.HistoricalLocation, error)
	PatchHistoricalLocation(interface{}, *entities.HistoricalLocation) (*entities.HistoricalLocation, error)
	DeleteHistoricalLocation(id interface{}) error

	ThingExists(thingID interface{}) bool
	LocationExists(thingID interface{}) bool
}

type Endpoint interface {
	GetName() string
	GetURL() string
	GetOperations() []EndpointOperation
	GetSupportedExpandParams() []string
	GetSupportedSelectParams() []string
	ShowOutputInfo() bool
}

type EndpointOperation struct {
	OperationType HTTPOperation
	Path          string //relative path to the endpoint for example: /v1.0/myendpoint/
	Handler       HTTPHandler
}

type ErrorContent struct {
	StatusText string   `json:"status"`
	StatusCode int      `json:"code"`
	Messages   []string `json:"message"`
}

type ErrorResponse struct {
	Error ErrorContent `json:"error"`
}

type GostServerVersion struct {
	Version string `json:"version"`
}

type HTTPHandler func(w http.ResponseWriter, r *http.Request, e *Endpoint, a *API)

type HTTPOperation string

type MQTTClient interface {
	Start(*API)
	Stop()
	Publish(string, string, byte) //topic, message, qos
}

type MQTTHandler func(a *API, prefix, topic string, message []byte)

type MQTTInternalHandler func(a *API, message []byte, id string)

type Topic struct {
	Path    string
	Handler MQTTHandler
}

type VersionInfo struct {
	GostServerVersion GostServerVersion `json:"gostServerVersion"`
	APIVersion        APIVersion        `json:"sensorThingsApiVersion"`
}