Fix InfluxDB time bug (absmach#689)

Signed-off-by: Dušan Borovčanin <dusan.borovcanin@mainflux.com>
drasko · Apr 4, 2019 · 57a0eea · 57a0eea
1 parent 54131c6
commit 57a0eea
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/writers/influxdb/messages.go b/writers/influxdb/messages.go
@@ -9,6 +9,7 @@ package influxdb
 
 import (
 	"errors"
+	"math"
 	"strconv"
 	"sync"
 	"time"
@@ -112,7 +113,9 @@ func (repo *influxRepo) savePoint(point *influxdata.Point) error {
 
 func (repo *influxRepo) Save(msg mainflux.Message) error {
 	tgs, flds := repo.tagsOf(&msg), repo.fieldsOf(&msg)
-	t := time.Unix(int64(msg.Time), 0)
+
+	sec, dec := math.Modf(msg.Time)
+	t := time.Unix(int64(sec), int64(dec*(1e9)))
 
 	pt, err := influxdata.NewPoint(pointName, tgs, flds, t)
 	if err != nil {