From e02af3c35327a7aafc172b02b3e83c8e4e3af173 Mon Sep 17 00:00:00 2001 From: Siegfried Siegert Date: Sun, 20 Sep 2020 17:53:23 +0200 Subject: [PATCH] Store timestamp in database --- models/db.go | 2 +- models/devices.go | 13 ++++++++++--- 2 files changed, 11 insertions(+), 4 deletions(-) diff --git a/models/db.go b/models/db.go index cb0daed..7d1ecb7 100644 --- a/models/db.go +++ b/models/db.go @@ -30,7 +30,7 @@ func NewDB(dataSourceName string) (*DB, error) { projectName TEXT, mac TEXT, sn TEXT, - lastMsg TEXT);` + lastMsg TIMESTAMP DEFAULT CURRENT_TIMESTAMP);` _, err = db.Exec(sqlStmt) if err != nil { return nil, err diff --git a/models/devices.go b/models/devices.go index 4a7879c..dfb76b2 100644 --- a/models/devices.go +++ b/models/devices.go @@ -2,6 +2,7 @@ package models import ( "fmt" + "time" ) type Device struct { @@ -33,13 +34,19 @@ func (db *DB) AllDevices() ([]*Device, error) { if err = rows.Err(); err != nil { return nil, err } + return devices, nil } func (db *DB) InsertDevice(device *Device) error { - sqlStmt := `INSERT OR REPLACE INTO devices (topic, customerID, deviceID, projectName, mac, sn, lastMsg) - VALUES($1, $2, $3, $4, $5, $6, $7);` - _, err := db.Exec(sqlStmt, device.TOPIC, device.CustomerID, device.DeviceID, device.ProjectName, device.MAC, device.SN, device.LastMsg) + + timeStamp := time.Now().Format(time.RFC3339) + // DEBUG + fmt.Printf("Timestamp: %s\n", timeStamp) + + sqlStmt := `INSERT OR REPLACE INTO devices (topic, customerID, deviceID, projectName, mac, sn) + VALUES($1, $2, $3, $4, $5, $6);` + _, err := db.Exec(sqlStmt, device.TOPIC, device.CustomerID, device.DeviceID, device.ProjectName, device.MAC, device.SN) if err != nil { return err }