initial

Author: jurkovic-nikola

.github/workflows/go.yml

@@ -0,0 +1,31 @@
+# This workflow will build a golang project
+# For more information see: https://docs.github.com/en/actions/automating-builds-and-tests/building-and-testing-go
+
+name: Go
+
+on:
+  push:
+    branches: [ "main" ]
+  pull_request:
+    branches: [ "main" ]
+
+permissions:
+  contents: read
+
+jobs:
+  build:
+    runs-on: ubuntu-latest
+    steps:
+      - uses: actions/checkout@v4
+      - name: Setup Go
+        uses: actions/setup-go@v5
+        with:
+          go-version: '1.23.8'
+      - name: Update
+        run: sudo apt-get update
+      - name: Install system dependencies
+        run: sudo apt-get install -y libudev-dev
+      - name: Install dependencies
+        run: go get .
+      - name: Build
+        run: go build -v ./...

.gitignore

@@ -0,0 +1,2 @@
+.idea/
+openlinkhub_tray

go.mod

@@ -0,0 +1,5 @@
+module openlinkhub_tray
+
+go 1.23.8
+
+require github.com/godbus/dbus/v5 v5.1.0

go.sum

@@ -0,0 +1,2 @@
+github.com/godbus/dbus/v5 v5.1.0 h1:4KLkAxT3aOY8Li4FRJe/KvhoNFFxo0m6fNuFUO8QJUk=
+github.com/godbus/dbus/v5 v5.1.0/go.mod h1:xhWf0FNVPg57R7Z0UbKHbJfkEywrmjJnf7w5xrFpKfA=

main.go

@@ -0,0 +1,30 @@
+package main
+
+import (
+	"flag"
+	"fmt"
+	"log"
+	"net"
+	"openlinkhub_tray/src/common"
+	"openlinkhub_tray/src/controller"
+)
+
+func main() {
+	ip := flag.String("ip", "127.0.0.1", "IP address of the OpenLinkHub service")
+	port := flag.Int("port", 27003, "Port number of the OpenLinkHub service")
+	flag.Parse()
+
+	// Crash it
+	if net.ParseIP(*ip) == nil {
+		log.Fatalf("Invalid IP address: %s", *ip)
+	}
+
+	// Format backend address
+	addr := fmt.Sprintf("%s:%d", *ip, *port)
+
+	// Store it
+	common.BackendAddr = addr
+
+	// Run
+	controller.Init()
+}

src/common/common.go

@@ -0,0 +1,64 @@
+package common
+
+import (
+	"encoding/json"
+	"errors"
+	"fmt"
+	"io"
+	"net/http"
+	"strconv"
+	"time"
+)
+
+var BackendAddr string
+
+type Response struct {
+	Code   int  `json:"code"`
+	Status int  `json:"status"`
+	Data   Data `json:"data"`
+}
+
+type Data struct {
+	CpuTemp string                    `json:"cpu_temp"`
+	GpuTemp string                    `json:"gpu_temp"`
+	Battery map[string]BatteryDetails `json:"battery"`
+}
+
+type BatteryDetails struct {
+	Device     string `json:"Device"`
+	Level      int    `json:"Level"`
+	DeviceType int    `json:"DeviceType"`
+}
+
+// LoadDataFromBackend will load systray data from backend service
+func LoadDataFromBackend() (*Response, error) {
+	url := fmt.Sprintf("http://%s/api/systray", BackendAddr)
+	client := http.Client{Timeout: 5 * time.Second}
+
+	resp, err := client.Get(url)
+	if err != nil {
+		return nil, err
+	}
+	defer func(Body io.ReadCloser) {
+		err := Body.Close()
+		if err != nil {
+
+		}
+	}(resp.Body)
+
+	if resp.StatusCode != http.StatusOK {
+		return nil, errors.New("Non-200 response code: " + strconv.Itoa(resp.StatusCode))
+	}
+
+	body, err := io.ReadAll(resp.Body)
+	if err != nil {
+		return nil, err
+	}
+
+	var response Response
+	err = json.Unmarshal(body, &response)
+	if err != nil {
+		return nil, err
+	}
+	return &response, nil
+}

src/controller/controller.go

@@ -0,0 +1,46 @@
+package controller
+
+import (
+	"fmt"
+	"openlinkhub_tray/src/common"
+	"openlinkhub_tray/src/systray"
+	"sync"
+	"time"
+)
+
+var (
+	menuMutex sync.Mutex
+	queueTime = 60
+)
+
+// processMenu will process any menu adding / changes
+func processMenu() {
+	menuMutex.Lock()
+	defer menuMutex.Unlock()
+	response, err := common.LoadDataFromBackend()
+	if err == nil {
+		systray.SyncBatteryToMenu(response)
+	} else {
+		fmt.Println("Failed to load data from backend. Error:", err)
+	}
+}
+
+func Init() {
+	ready := make(chan struct{})
+	go func() {
+		systray.Init(ready)
+	}()
+
+	<-ready // Wait for systray to be ready
+
+	go func() {
+		ticker := time.NewTicker(time.Duration(queueTime) * time.Second)
+		defer ticker.Stop()
+
+		processMenu()
+		for range ticker.C {
+			processMenu()
+		}
+	}()
+	select {}
+}