feat: initial implementation of Create() in MetricsDAO

pkg/dao/dao.go

@@ -2,7 +2,7 @@ package dao
 
 import (
 	"database/sql"
-	"errors"
+	"encoding/json"
 
 	"github.com/aerogear/aerogear-metrics-api/pkg/mobile"
 )
@@ -12,8 +12,15 @@ type MetricsDAO struct {
 }
 
 // Create a metrics record
-func (m *MetricsDAO) Create(metric mobile.Metric) (mobile.Metric, error) {
-	return metric, errors.New("Not Implemented yet")
+func (m *MetricsDAO) Create(metric mobile.Metric) error {
+	data, err := json.Marshal(metric.Data)
+
+	if err != nil {
+		return err
+	}
+
+	_, err = db.Exec("INSERT INTO mobileappmetrics(clientId, data) VALUES($1, $2)", metric.ClientId, data)
+	return err
 }
 
 // Ping checks that we are connected to the database

pkg/dao/db.go

@@ -46,6 +46,9 @@ func DoInitialSetup() error {
 	if db == nil {
 		return errors.New("cannot setup database, must call Connect() first")
 	}
+	if _, err := db.Exec("CREATE EXTENSION IF NOT EXISTS timescaledb CASCADE;"); err != nil {
+		return err
+	}
 	if _, err := db.Exec("CREATE TABLE IF NOT EXISTS mobileappmetrics(clientId varchar(30) NOT NULL, event_time timestamptz NOT NULL DEFAULT now() Not NULL, data jsonb)"); err != nil {
 		return err
 	}

pkg/mobile/interfaces.go

@@ -2,5 +2,5 @@ package mobile
 
 // MetricCreator defines how a metric can be created
 type MetricCreator interface {
-	Create(m Metric) (Metric, error)
+	Create(m Metric) error
 }

pkg/mobile/metrics.go

@@ -9,5 +9,5 @@ func NewMetricsService(dao MetricCreator) *MetricsService {
 }
 
 func (m MetricsService) Create(metric Metric) (Metric, error) {
-	return metric, nil
+	return metric, m.mdao.Create(metric)
 }