database

type ConnectorFunc ¶

type ConnectorFunc func() (*gorm.DB, zerolog.Logger, error)

ConnectorFunc is used to inject a database connection method into NewDatabaseConnection

func NewPostgreSQLConnector(log zerolog.Logger) ConnectorFunc

func NewSQLiteConnector(log zerolog.Logger) ConnectorFunc

type Datastore ¶

type Datastore interface {
	GetAirQualityObserveds(deviceId string, from, to time.Time, limit uint64) ([]models.AirQualityObserved, error)
	StoreAirQualityObserved(entityId, deviceId string, co2, humidity, temperature float64, timestamp time.Time) (*models.AirQualityObserved, error)
}

func NewDatabaseConnection(connect ConnectorFunc) (Datastore, error)

type DatastoreMock ¶

type DatastoreMock struct {
	// GetAirQualityObservedsFunc mocks the GetAirQualityObserveds method.
	GetAirQualityObservedsFunc func(deviceId string, from time.Time, to time.Time, limit uint64) ([]models.AirQualityObserved, error)

	// StoreAirQualityObservedFunc mocks the StoreAirQualityObserved method.
	StoreAirQualityObservedFunc func(entityId string, deviceId string, co2 float64, humidity float64, temperature float64, timestamp time.Time) (*models.AirQualityObserved, error)
	// contains filtered or unexported fields
}

DatastoreMock is a mock implementation of Datastore.

func TestSomethingThatUsesDatastore(t *testing.T) {

	// make and configure a mocked Datastore
	mockedDatastore := &DatastoreMock{
		GetAirQualityObservedsFunc: func(deviceId string, from time.Time, to time.Time, limit uint64) ([]models.AirQualityObserved, error) {
			panic("mock out the GetAirQualityObserveds method")
		},
		StoreAirQualityObservedFunc: func(entityId string, deviceId string, co2 float64, humidity float64, temperature float64, timestamp time.Time) (*models.AirQualityObserved, error) {
			panic("mock out the StoreAirQualityObserved method")
		},
	}

	// use mockedDatastore in code that requires Datastore
	// and then make assertions.

}

func (mock *DatastoreMock) GetAirQualityObserveds(deviceId string, from time.Time, to time.Time, limit uint64) ([]models.AirQualityObserved, error)

func (mock *DatastoreMock) GetAirQualityObservedsCalls() []struct {
	DeviceId string
	From     time.Time
	To       time.Time
	Limit    uint64
}

len(mockedDatastore.GetAirQualityObservedsCalls())

func (mock *DatastoreMock) StoreAirQualityObserved(entityId string, deviceId string, co2 float64, humidity float64, temperature float64, timestamp time.Time) (*models.AirQualityObserved, error)

func (mock *DatastoreMock) StoreAirQualityObservedCalls() []struct {
	EntityId    string
	DeviceId    string
	Co2         float64
	Humidity    float64
	Temperature float64
	Timestamp   time.Time
}

len(mockedDatastore.StoreAirQualityObservedCalls())