jpt/edgeboxctl
1
0
Fork 0
mirror of https://github.com/edgebox-iot/edgeboxctl.git synced 2026-10-19 17:55:16 +02:00
Code Issues Packages Projects Releases Wiki Activity

Added storage module, base structs, getDevices() func, taskGetStorageDevices (ticks every 30)

Browse Source
This commit is contained in:
Paulo Truta
2021-06-06 12:29:46 +00:00
parent c9f97d42bf
commit fd002987fa
2 changed files with 103 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
internal/tasks/tasks.go
+33
View File
@@ -10,6 +10,7 @@ import (
"github.com/edgebox-iot/edgeboxctl/internal/diagnostics"
"github.com/edgebox-iot/edgeboxctl/internal/edgeapps"
"github.com/edgebox-iot/edgeboxctl/internal/storage"
"github.com/edgebox-iot/edgeboxctl/internal/system"
"github.com/edgebox-iot/edgeboxctl/internal/utils"
_ "github.com/go-sql-driver/mysql" // Mysql Driver
@@ -253,12 +254,14 @@ func ExecuteSchedules(tick int) {
uptime := taskGetSystemUptime()
log.Println("Uptime is " + uptime + " seconds (" + system.GetUptimeFormatted() + ")")
log.Println(taskGetStorageDevices())
log.Println(taskGetEdgeApps())
}
if tick%30 == 0 {
// Executing every 30 ticks
log.Println(taskGetStorageDevices())
log.Println(taskGetEdgeApps())
}
@@ -435,3 +438,33 @@ func taskGetSystemUptime() string {
return uptime
}
func taskGetStorageDevices() string {
fmt.Println("Executing taskGetStorageDevices")
devices := storage.GetDevices()
devicesJSON, _ := json.Marshal(devices)
db, err := sql.Open("sqlite3", utils.GetSQLiteDbConnectionDetails())
if err != nil {
log.Fatal(err.Error())
}
statement, err := db.Prepare("REPLACE into option (name, value, created, updated) VALUES (?, ?, ?, ?);") // Prepare SQL Statement
if err != nil {
log.Fatal(err.Error())
}
formatedDatetime := utils.GetSQLiteFormattedDateTime(time.Now())
_, err = statement.Exec("STORAGE_DEVICES_LIST", devicesJSON, formatedDatetime, formatedDatetime) // Execute SQL Statement
if err != nil {
log.Fatal(err.Error())
}
db.Close()
return string(devicesJSON)
}