utils.go

package gossamer

import (
	"encoding/json"
	"errors"
	"github.com/satori/go.uuid"
	"log"
	"net/http"
	"strings"
)

func ResolveEntityLink(id string, ent EntityType) string {
	s := string(ent)

	if id != "" {
		s += "(" + id + ")"
	}
	return s
}

func ResolveSelfLinkUrl(id string, ent EntityType) string {
	return "http://" + GLOB_ENV_HOST + "/v1.0/" + ResolveEntityLink(id, ent)
}

func GetAssociatedEntityId(entity SensorThing, et EntityType) string {
	switch entity.GetType() {
	case ENTITY_THINGS:
		// e := (entity).(*ThingEntity)

	case ENTITY_OBSERVATIONS:
		// e := (entity).(*ObservationEntity)

	case ENTITY_HISTORICALLOCATIONS:
		// e := (entity).(*HistoricalLocationEntity)

	case ENTITY_SENSORS:
		// e := (entity).(*SensorEntity)

	case ENTITY_LOCATIONS:
		// e := (entity).(*LocationEntity)

	case ENTITY_FEATURESOFINTEREST:
		// e := (entity).(*FeatureOfInterestEntity)

	case ENTITY_DATASTREAMS:
		e := (entity).(*DatastreamEntity)
		switch {
		case et == ENTITY_SENSOR || et == ENTITY_SENSORS:
			return e.IdSensor

		case et == ENTITY_THING || et == ENTITY_THINGS:
			return e.IdThing

		case et == ENTITY_OBSERVEDPROPERTIES || et == ENTITY_OBSERVEDPROPERTY:
			return e.IdObservedProperty
		}

	case ENTITY_OBSERVEDPROPERTIES:
		// e := (entity).(*ObservedPropertyEntity)
	}
	return ""
}

func SetAssociatedEntityId(entity SensorThing, et EntityType, id string) {
	switch entity.GetType() {
	case ENTITY_THINGS:
		e := (entity).(*ThingEntity)
		if et == ENTITY_LOCATIONS {
			entity := NewLocationEntity()
			entity.Id = id
			e.Locations = []*LocationEntity{entity}
		}

		if et == ENTITY_DATASTREAMS {
			entity := NewDatastreamEntity()
			entity.Id = id
			e.Datastreams = []*DatastreamEntity{entity}
		}

	case ENTITY_OBSERVATIONS:
		e := (entity).(*ObservationEntity)
		if et == ENTITY_DATASTREAMS {
			e.Datastream = NewDatastreamEntity()
			e.Datastream.Id = id
		}

		if et == ENTITY_FEATURESOFINTEREST {
			e.FeatureOfInterest = NewFeatureOfInterestEntity()
			e.FeatureOfInterest.Id = id
		}

	case ENTITY_HISTORICALLOCATIONS:
		e := (entity).(*HistoricalLocationEntity)
		log.Println(e)

	case ENTITY_SENSORS:
		e := (entity).(*SensorEntity)
		log.Println(e)

	case ENTITY_LOCATIONS:
		e := (entity).(*LocationEntity)
		log.Println(e)

	case ENTITY_FEATURESOFINTEREST:
		e := (entity).(*FeatureOfInterestEntity)
		log.Println(e)

	case ENTITY_DATASTREAMS:
		e := (entity).(*DatastreamEntity)
		if et == ENTITY_THINGS {
			e.Thing = NewThingEntity()
			e.Thing.Id = id
		}

		if et == ENTITY_OBSERVEDPROPERTIES {
			e.ObservedProperty = NewObservedPropertyEntity()
			e.ObservedProperty.Id = id
		}

		if et == ENTITY_SENSORS {
			e.Sensor = NewSensorEntity()
			e.Sensor.Id = id
		}

	case ENTITY_OBSERVEDPROPERTIES:
		e := (entity).(*ObservedPropertyEntity)
		log.Println(e)
	}
}

func DecodeJsonToEntityStruct(decoder *json.Decoder, et EntityType) (SensorThing, error) {
	var err error
	switch et {
	case ENTITY_THINGS:
		var e ThingEntity
		err = decoder.Decode(&e)
		return &e, err

	case ENTITY_OBSERVATIONS:
		var e ObservationEntity
		err = decoder.Decode(&e)
		return &e, err

	case ENTITY_HISTORICALLOCATIONS:
		return nil, errors.New("Adding Historical Locations not allowed")

	case ENTITY_SENSORS:
		var e SensorEntity
		err = decoder.Decode(&e)
		return &e, err

	case ENTITY_LOCATIONS:
		var e LocationEntity
		err = decoder.Decode(&e)
		return &e, err

	case ENTITY_FEATURESOFINTEREST:
		var e FeatureOfInterestEntity
		err = decoder.Decode(&e)
		return &e, err

	case ENTITY_DATASTREAMS:
		var e DatastreamEntity
		err = decoder.Decode(&e)
		return &e, err

	case ENTITY_OBSERVEDPROPERTIES:
		var e ObservedPropertyEntity
		err = decoder.Decode(&e)
		return &e, err
	}
	return nil, errors.New("Unknown Entity Type")
}

func ThrowHttpOk(msg string, w http.ResponseWriter) {
	http.Error(w, msg, http.StatusOK)
}

func ThrowHttpCreated(msg string, w http.ResponseWriter) {
	http.Error(w, msg, http.StatusCreated)
}

func ThrowHttpBadRequest(msg string, w http.ResponseWriter) {
	http.Error(w, msg, http.StatusBadRequest)
}

func ThrowHttpInternalServerError(msg string, w http.ResponseWriter) {
	http.Error(w, msg, http.StatusInternalServerError)
}

func ThrowHttpMethodNotAllowed(msg string, w http.ResponseWriter) {
	http.Error(w, msg, http.StatusMethodNotAllowed)
}

func ThrowNotAcceptable(msg string, w http.ResponseWriter) {
	http.Error(w, msg, http.StatusNotAcceptable)
}

func GenerateEntityId() string {
	return uuid.NewV4().String()
}

func IsEntity(e string) bool {
	if strings.HasPrefix(e, "Thing") ||
		strings.HasPrefix(e, "Things") ||
		strings.HasPrefix(e, "Location") ||
		strings.HasPrefix(e, "Locations") ||
		strings.HasPrefix(e, "HistoricalLocation") ||
		strings.HasPrefix(e, "HistoricalLocations") ||
		strings.HasPrefix(e, "Datastream") ||
		strings.HasPrefix(e, "Datastreams") ||
		strings.HasPrefix(e, "Sensor") ||
		strings.HasPrefix(e, "Sensors") ||
		strings.HasPrefix(e, "Observation") ||
		strings.HasPrefix(e, "Observations") ||
		strings.HasPrefix(e, "ObservedProperty") ||
		strings.HasPrefix(e, "ObservedProperties") ||
		strings.HasPrefix(e, "FeaturesOfInterest") {
		return true
	}
	return false
}

func IsSingularEntity(e string) bool {
	if (strings.HasPrefix(e, "Location") && !strings.HasPrefix(e, "Locations")) ||
		(strings.HasPrefix(e, "Thing") && !strings.HasPrefix(e, "Things")) ||
		(strings.HasPrefix(e, "HistoricalLocation") && !strings.HasPrefix(e, "HistoricalLocations")) ||
		(strings.HasPrefix(e, "Datastream") && !strings.HasPrefix(e, "Datastreams")) ||
		(strings.HasPrefix(e, "Sensor") && !strings.HasPrefix(e, "Sensors")) ||
		(strings.HasPrefix(e, "Observation") && !strings.HasPrefix(e, "Observations")) ||
		(strings.HasPrefix(e, "ObservedProperty") && !strings.HasPrefix(e, "ObservedProperties")) {
		return true
	}
	return false
}

func DiscoverEntityType(e string) EntityType {
	switch {
	case strings.HasPrefix(e, "Things"):
		return ENTITY_THINGS

	case strings.HasPrefix(e, "Thing"):
		return ENTITY_THING

	case strings.HasPrefix(e, "Locations"):
		return ENTITY_LOCATIONS

	case strings.HasPrefix(e, "Location"):
		return ENTITY_LOCATION

	case strings.HasPrefix(e, "Datastreams"):
		return ENTITY_DATASTREAMS

	case strings.HasPrefix(e, "Datastream"):
		return ENTITY_DATASTREAM

	case strings.HasPrefix(e, "Sensors"):
		return ENTITY_SENSORS

	case strings.HasPrefix(e, "Sensor"):
		return ENTITY_SENSOR

	case strings.HasPrefix(e, "Observations"):
		return ENTITY_OBSERVATIONS

	case strings.HasPrefix(e, "Observation"):
		return ENTITY_OBSERVATION

	case strings.HasPrefix(e, "ObservedProperties"):
		return ENTITY_OBSERVEDPROPERTIES

	case strings.HasPrefix(e, "ObservedProperty"):
		return ENTITY_OBSERVEDPROPERTY

	case strings.HasPrefix(e, "FeaturesOfInterest"):
		return ENTITY_FEATURESOFINTEREST

	case strings.HasPrefix(e, "HistoricalLocations"):
		return ENTITY_HISTORICALLOCATIONS

	case strings.HasPrefix(e, "HistoricalLocation"):
		return ENTITY_HISTORICALLOCATION

	default:
		return ENTITY_UNKNOWN
	}
}

func NewThingEntity() *ThingEntity {
	t := &ThingEntity{}

	return t
}

func NewThingEntityWithId(id string) *ThingEntity {
	t := &ThingEntity{}
	t.Id = id

	return t
}

func NewLocationEntity() *LocationEntity {
	e := &LocationEntity{}

	return e
}

func NewLocationEntityWithId(id string) *LocationEntity {
	e := &LocationEntity{}
	e.Id = id

	return e
}

func NewHistoricalLocationEntity() *HistoricalLocationEntity {
	e := &HistoricalLocationEntity{}

	return e
}

func NewHistoricalLocationEntityWithId(id string) *HistoricalLocationEntity {
	e := &HistoricalLocationEntity{}
	e.Id = id

	return e
}

func NewDatastreamEntity() *DatastreamEntity {
	e := &DatastreamEntity{}

	return e
}

func NewDatastreamEntityWithId(id string) *DatastreamEntity {
	e := &DatastreamEntity{}
	e.Id = id

	return e
}

func NewSensorEntity() *SensorEntity {
	e := &SensorEntity{}

	return e
}

func NewSensorEntityWithId(id string) *SensorEntity {
	e := &SensorEntity{}
	e.Id = id

	return e
}

func NewObservedPropertyEntity() *ObservedPropertyEntity {
	e := &ObservedPropertyEntity{}

	return e
}

func NewObservedPropertyEntityWithId(id string) *ObservedPropertyEntity {
	e := &ObservedPropertyEntity{}
	e.Id = id

	return e
}

func NewObservationEntity() *ObservationEntity {
	e := &ObservationEntity{}

	return e
}

func NewObservationEntityWithId(id string) *ObservationEntity {
	e := &ObservationEntity{}
	e.Id = id

	return e
}

func CloneObservationEntity(o Observation) *ObservationEntity {
	n := NewObservationEntity()
	n.Id = o.GetId()
	n.Parameters = o.GetParameters()
	n.PhenomenonTime = o.GetPhenomenonTime()
	n.Result = o.GetResult()
	n.ResultQuality = o.GetResultQuality()
	n.ResultTime = o.GetResultTime()
	n.ValidTime = o.GetValidTime()

	return n
}

func CloneSensorEntity(o Sensor) *SensorEntity {
	n := NewSensorEntity()
	n.Id = o.GetId()
	n.Description = o.GetDescription()
	n.EncodingType = o.GetEncodingType()
	n.Metadata = o.GetMetadata()

	return n
}

func NewFeatureOfInterestEntity() *FeatureOfInterestEntity {
	e := &FeatureOfInterestEntity{}

	return e
}

func NewFeatureOfInterestEntityWithId(id string) *FeatureOfInterestEntity {
	e := &FeatureOfInterestEntity{}
	e.Id = id

	return e
}