initial commit with in memory implementation

Author: Yengas

.gitignore

@@ -0,0 +1,165 @@
+
+# Created by https://www.gitignore.io/api/go,vim,macos,intellij+all
+# Edit at https://www.gitignore.io/?templates=go,vim,macos,intellij+all
+
+### Go ###
+# Binaries for programs and plugins
+*.exe
+*.exe~
+*.dll
+*.so
+*.dylib
+
+# Test binary, built with `go test -c`
+*.test
+
+# Output of the go coverage tool, specifically when used with LiteIDE
+*.out
+
+# Dependency directories (remove the comment below to include it)
+# vendor/
+
+### Go Patch ###
+/vendor/
+/Godeps/
+
+### Intellij+all ###
+# Covers JetBrains IDEs: IntelliJ, RubyMine, PhpStorm, AppCode, PyCharm, CLion, Android Studio and WebStorm
+# Reference: https://intellij-support.jetbrains.com/hc/en-us/articles/206544839
+
+# User-specific stuff
+.idea/**/workspace.xml
+.idea/**/tasks.xml
+.idea/**/usage.statistics.xml
+.idea/**/dictionaries
+.idea/**/shelf
+
+# Generated files
+.idea/**/contentModel.xml
+
+# Sensitive or high-churn files
+.idea/**/dataSources/
+.idea/**/dataSources.ids
+.idea/**/dataSources.local.xml
+.idea/**/sqlDataSources.xml
+.idea/**/dynamic.xml
+.idea/**/uiDesigner.xml
+.idea/**/dbnavigator.xml
+
+# Gradle
+.idea/**/gradle.xml
+.idea/**/libraries
+
+# Gradle and Maven with auto-import
+# When using Gradle or Maven with auto-import, you should exclude module files,
+# since they will be recreated, and may cause churn.  Uncomment if using
+# auto-import.
+# .idea/modules.xml
+# .idea/*.iml
+# .idea/modules
+# *.iml
+# *.ipr
+
+# CMake
+cmake-build-*/
+
+# Mongo Explorer plugin
+.idea/**/mongoSettings.xml
+
+# File-based project format
+*.iws
+
+# IntelliJ
+out/
+
+# mpeltonen/sbt-idea plugin
+.idea_modules/
+
+# JIRA plugin
+atlassian-ide-plugin.xml
+
+# Cursive Clojure plugin
+.idea/replstate.xml
+
+# Crashlytics plugin (for Android Studio and IntelliJ)
+com_crashlytics_export_strings.xml
+crashlytics.properties
+crashlytics-build.properties
+fabric.properties
+
+# Editor-based Rest Client
+.idea/httpRequests
+
+# Android studio 3.1+ serialized cache file
+.idea/caches/build_file_checksums.ser
+
+### Intellij+all Patch ###
+# Ignores the whole .idea folder and all .iml files
+# See https://github.com/joeblau/gitignore.io/issues/186 and https://github.com/joeblau/gitignore.io/issues/360
+
+.idea/
+
+# Reason: https://github.com/joeblau/gitignore.io/issues/186#issuecomment-249601023
+
+*.iml
+modules.xml
+.idea/misc.xml
+*.ipr
+
+# Sonarlint plugin
+.idea/sonarlint
+
+### macOS ###
+# General
+.DS_Store
+.AppleDouble
+.LSOverride
+
+# Icon must end with two \r
+Icon
+
+# Thumbnails
+._*
+
+# Files that might appear in the root of a volume
+.DocumentRevisions-V100
+.fseventsd
+.Spotlight-V100
+.TemporaryItems
+.Trashes
+.VolumeIcon.icns
+.com.apple.timemachine.donotpresent
+
+# Directories potentially created on remote AFP share
+.AppleDB
+.AppleDesktop
+Network Trash Folder
+Temporary Items
+.apdisk
+
+### Vim ###
+# Swap
+[._]*.s[a-v][a-z]
+[._]*.sw[a-p]
+[._]s[a-rt-v][a-z]
+[._]ss[a-gi-z]
+[._]sw[a-p]
+
+# Session
+Session.vim
+Sessionx.vim
+
+# Temporary
+.netrwhist
+*~
+
+# Auto-generated tag files
+tags
+
+# Persistent undo
+[._]*.un~
+
+# Coc configuration directory
+.vim
+
+# End of https://www.gitignore.io/api/go,vim,macos,intellij+all

cmd/server/main.go

@@ -0,0 +1,47 @@
+package main
+
+import (
+	"fmt"
+	add_device "iot-demo/pkg/add-device"
+	add_metrics "iot-demo/pkg/add-metrics"
+	"iot-demo/pkg/ingestion"
+	query_metrics "iot-demo/pkg/query-metrics"
+	"iot-demo/pkg/registry"
+	"iot-demo/pkg/storage/memory"
+	"iot-demo/pkg/tokenizer"
+	"time"
+)
+
+func main() {
+	registryRepository := memory.NewRegistry()
+	registryService := registry.NewService(registryRepository)
+
+	ingestionRepository := memory.NewIngestion()
+	ingestionService := ingestion.NewDecimalService(ingestionRepository)
+
+	jwtConfig := tokenizer.Config{Secret: []byte("hello-world")}
+	jwt := tokenizer.NewJWT(jwtConfig)
+
+	deviceAdder := add_device.NewService(registryService, tokenizer.DeviceJWT(jwt))
+	metricAdder := add_metrics.NewService(ingestionService)
+	metricQuerier := query_metrics.NewService(ingestionService)
+
+	device, token, err := deviceAdder.Register("asd", "aasd", time.Now())
+	fmt.Printf("device: %v, token: %v, err: %v\n", device, token, err)
+
+	got, ok := registryRepository.Get(device.ID)
+	fmt.Printf("got device: %v, ok: %v\n", got, ok)
+
+	metrics := []*ingestion.DecimalMetricValue{
+		{0, ingestion.Time(time.Now())},
+		{1, ingestion.Time(time.Now())},
+		{1, ingestion.Time(time.Now())},
+		{1, ingestion.Time(time.Now())},
+	}
+
+	err = metricAdder.Add(device.ID, metrics)
+	fmt.Printf("insert err: %v\n", err)
+
+	gotm, err := metricQuerier.Query(device.ID)
+	fmt.Printf("queried metrics: %v, err: %v\n", gotm, err)
+}

go.mod

@@ -0,0 +1,5 @@
+module iot-demo
+
+go 1.13
+
+require github.com/dgrijalva/jwt-go v3.2.0+incompatible

go.sum

@@ -0,0 +1,2 @@
+github.com/dgrijalva/jwt-go v3.2.0+incompatible h1:7qlOGliEKZXTDg6OTjfoBKDXWrumCAMpl/TFQ4/5kLM=
+github.com/dgrijalva/jwt-go v3.2.0+incompatible/go.mod h1:E3ru+11k8xSBh+hMPgOLZmtrrCbhqsmaPHjLKYnJCaQ=

pkg/add-device/add-device.go

@@ -0,0 +1,42 @@
+package add_device
+
+import (
+	"iot-demo/pkg/auth"
+	"iot-demo/pkg/registry"
+	"time"
+)
+
+type Registerer interface {
+	Register(serialNumber string, firmwareVersion string, registrationDate time.Time) (*registry.Device, error)
+}
+
+type Tokenizer interface {
+	Create(authInfo *auth.DeviceCredential) (auth.Token, error)
+}
+
+type Service struct {
+	registerer Registerer
+	tokenizer Tokenizer
+}
+
+func (s *Service) Register(serialNumber string, firmwareVersion string, registrationDate time.Time) (*registry.Device, auth.Token, error) {
+	device, err := s.registerer.Register(serialNumber, firmwareVersion, registrationDate)
+	if err != nil {
+		return nil, "", err
+	}
+
+	authInfo := auth.DeviceCredential{DeviceID: device.ID}
+	token, err := s.tokenizer.Create(&authInfo)
+	if err != nil {
+		return nil, "", err
+	}
+
+	return device, token, nil
+}
+
+func NewService(registerer Registerer, tokenizer Tokenizer) *Service {
+	return &Service{
+		registerer: registerer,
+		tokenizer:  tokenizer,
+	}
+}

pkg/add-metrics/add-metrics.go

@@ -0,0 +1,22 @@
+package add_metrics
+
+import (
+	"iot-demo/pkg/ingestion"
+)
+
+type Inserter interface {
+	Insert(deviceID int, metricsToInsert []*ingestion.DecimalMetricValue) error
+}
+
+type Service struct {
+	inserter Inserter
+}
+
+func (s *Service) Add(deviceID int, metricsToInsert []*ingestion.DecimalMetricValue) error {
+	return s.inserter.Insert(deviceID, metricsToInsert)
+}
+
+func NewService(inserter Inserter) *Service {
+	return &Service{inserter: inserter}
+}
+

pkg/auth/device.go

@@ -0,0 +1,7 @@
+package auth
+
+type Token string
+
+type DeviceCredential struct {
+	DeviceID int `json:"id"`
+}

pkg/ingestion/metric.go

@@ -0,0 +1,34 @@
+package ingestion
+
+type DecimalMetricValue struct {
+	Value float64 `json:"value"`
+	// Epoch timestamp in seconds
+	Time Time `json:"time" swaggertype:"primitive,integer" example:"1578859629"`
+}
+
+type DecimalRepository interface {
+	Insert(deviceID int, metricsToInsert []*DecimalMetricValue) error
+	Query(deviceID int) ([]*DecimalMetricValue, error)
+}
+
+type DecimalService struct {
+	repository DecimalRepository
+}
+
+// insert metrics into the backing repository, notify all listeners
+func (ss *DecimalService) Insert(deviceID int, metricsToInsert []*DecimalMetricValue) error {
+	err := ss.repository.Insert(deviceID, metricsToInsert)
+	if err != nil {
+		return err
+	}
+
+	return nil
+}
+
+func (ss *DecimalService) Query(deviceID int) ([]*DecimalMetricValue, error) {
+	return ss.repository.Query(deviceID)
+}
+
+func NewDecimalService(repository DecimalRepository) *DecimalService {
+	return &DecimalService{repository: repository}
+}

pkg/ingestion/time.go

@@ -0,0 +1,42 @@
+package ingestion
+
+import (
+	"strconv"
+	"time"
+)
+
+// Time defines a timestamp encoded as epoch seconds in JSON
+type Time time.Time
+
+// MarshalJSON is used to convert the timestamp to JSON
+func (t Time) MarshalJSON() ([]byte, error) {
+	return []byte(strconv.FormatInt(time.Time(t).Unix(), 10)), nil
+}
+
+// UnmarshalJSON is used to convert the timestamp from JSON
+func (t *Time) UnmarshalJSON(s []byte) (err error) {
+	r := string(s)
+	q, err := strconv.ParseInt(r, 10, 64)
+	if err != nil {
+		return err
+	}
+	*(*time.Time)(t) = time.Unix(q, 0)
+	return nil
+}
+
+// Unix returns t as a Unix time, the number of seconds elapsed
+// since January 1, 1970 UTC. The result does not depend on the
+// location associated with t.
+func (t Time) Unix() int64 {
+	return time.Time(t).Unix()
+}
+
+// Time returns the JSON time as a time.Time instance in UTC
+func (t Time) Time() time.Time {
+	return time.Time(t).UTC()
+}
+
+// String returns t as a formatted string
+func (t Time) String() string {
+	return t.Time().String()
+}

pkg/query-metrics/query-metrics.go

@@ -0,0 +1,22 @@
+package query_metrics
+
+import (
+	"iot-demo/pkg/ingestion"
+)
+
+type Querier interface {
+	Query(deviceID int) ([]*ingestion.DecimalMetricValue, error)
+}
+
+type Service struct {
+	querier Querier
+}
+
+func (s *Service) Query(deviceID int) ([]*ingestion.DecimalMetricValue, error) {
+	return s.querier.Query(deviceID)
+}
+
+func NewService(querier Querier) *Service {
+	return &Service{querier: querier}
+}
+