Add support for ZLT G3000A

README.md

@@ -10,6 +10,8 @@ Supports the following ONT models
   * `ONT_MODEL: zte_f670`
 * ZTE F660
   * `ONT_MODEL: zte_f670`
+* ZLT G3000A (Globe Telecom Philippines firmware)
+  * `ONT_MODEL: zlt_g3000a`
 
 ## Environment variables
 * `ONT_WEB_HOST`

devices.go

@@ -15,3 +15,6 @@ type AN5506_Stock struct {
 
 type ZTEF670L struct {
 }
+
+type ZLTG3000A struct {
+}

globals.go

@@ -1,5 +1,6 @@
 package main
 
-var cachedPage = new(DocPage)  // main page
-var cachedPage2 = new(DocPage) // additional page
+var cachedPage = new(DocPage)         // main page
+var cachedPage2 = new(DocPage)        // additional page
+var cachedGponData = new(GponPayload) // zlt g3000a payload
 var gponSvc OntDevice

gpon-parser.go

@@ -60,8 +60,11 @@ func initGponSvc() {
 		} else if strings.EqualFold(model, "zte_f670") {
 			log.Println("ONT Model is ZTE F670L")
 			gponSvc = new(ZTEF670L)
+		} else if strings.EqualFold(model, "zlt_g3000a") {
+			log.Println("ONT Model is ZLT G3000A WiFi 6")
+			gponSvc = new(ZLTG3000A)
 		} else {
-			log.Println("Invalid ONT model provided in env variable 'ONT_MODEL', valid args are ['an5506_stock', 'hg6245d_globe', 'zte_f670']")
+			log.Println("Invalid ONT model provided in env variable 'ONT_MODEL', valid args are ['an5506_stock', 'hg6245d_globe', 'zte_f670', 'zlt_g3000a']")
 			os.Exit(-10)
 		}
 	} else {

mutex.go

@@ -12,6 +12,11 @@ type DocPage struct {
 	docStr string
 }
 
+type GponPayload struct {
+	sync.RWMutex
+	doc *ZLTG3000A_Payload
+}
+
 func (docPage *DocPage) GetPage() *html.Node {
 	docPage.RLock()
 	defer docPage.RUnlock()
@@ -36,6 +41,18 @@ func (docPage *DocPage) SetStrPage(docStr string) {
 	docPage.Unlock()
 }
 
+func (gponPayload *GponPayload) GetGponData() *ZLTG3000A_Payload {
+	gponPayload.RLock()
+	defer gponPayload.RUnlock()
+	return gponPayload.doc
+}
+
+func (gponPayload *GponPayload) SetGponData(payload *ZLTG3000A_Payload) {
+	gponPayload.Lock()
+	gponPayload.doc = payload
+	gponPayload.Unlock()
+}
+
 type LoginCreds struct {
 	sync.RWMutex
 	username string

zltg3000a.go

@@ -0,0 +1,224 @@
+package main
+
+import (
+	"bytes"
+	"encoding/json"
+	"fmt"
+	"io"
+	"math"
+	"strconv"
+	"strings"
+
+	"net/http"
+)
+
+// Define a struct to match the JSON response
+type ZLTG3000A_Payload struct {
+	Success            bool   `json:"success"`
+	Cmd                int    `json:"cmd"`
+	PonSN              string `json:"pon_sn"`
+	XponMode           string `json:"xponMode"`
+	TrafficStatus      string `json:"trafficStatus"`
+	TxPower            string `json:"TxPower"`
+	RxPower            string `json:"RxPower"`
+	WorkTemperature    string `json:"WorkTemperature"`
+	IP                 string `json:"IP"`
+	Netmask            string `json:"netmask"`
+	Type               string `json:"type"`
+	FirstDNS           string `json:"firstDNS"`
+	WifiName24         string `json:"wifiName24"`
+	WifiOpen24         string `json:"wifiOpen24"`
+	WifiName5          string `json:"wifiName5"`
+	WifiOpen5          string `json:"wifiOpen5"`
+	LineEnabled        string `json:"lineEnabled"`
+	SipName            string `json:"sipName"`
+	Status             string `json:"Status"`
+	RegFailReason      string `json:"RegFailReason"`
+	CycleNum           string `json:"CycleNum"`
+	VEntryName         string `json:"vEntryName"`
+	VEntryID           string `json:"vEntryID"`
+	VActive            string `json:"vActive"`
+	VWANModem          string `json:"vWANModem"`
+	VWanStatus4        string `json:"vWanStatus4"`
+	VIP                string `json:"vIP"`
+	VWanStatus6        string `json:"vWanStatus6"`
+	VIP6               string `json:"vIP6"`
+	Tr069ConnectStatus string `json:"tr069_connect_status"`
+	ParamType          string `json:"param_type"`
+	LosType            string `json:"los_type"`
+	BandsteerEnable    string `json:"bandsteerEnable"`
+	Mac                string `json:"mac"`
+	BoardType          string `json:"board_type"`
+	DeviceSN           string `json:"device_sn"`
+	Memory             string `json:"memory"`
+	HwVersion          string `json:"hwversion"`
+	Uptime             string `json:"uptime"`
+	CPUUsage           string `json:"cpu_usage"`
+	FakeVersion        string `json:"fake_version"`
+}
+
+func (o ZLTG3000A) GetGponUrl() string {
+	host := getenv("ONT_WEB_HOST", "192.168.254.254")
+	port := getenv("ONT_WEB_PORT", "80")
+	return fmt.Sprintf("http://%s:%s/cgi-bin/http.cgi", host, port)
+}
+
+// memoryUsage calculates memory usage percentage and returns it as a float
+func (o ZLTG3000A) ParseMemoryUsage(memory string) (float64, error) {
+	// Split the memory string by commas
+	parts := strings.Split(memory, ",")
+
+	// Convert the first and second parts to numbers (assuming the first two parts are total and available memory)
+	totalMemoryStr := removeLastNChars((strings.TrimSpace(parts[0])), 3)
+	usedMemoryStr := removeLastNChars((strings.TrimSpace(parts[1])), 3)
+
+	// Convert strings to integers
+	totalMemory, err := strconv.Atoi(totalMemoryStr)
+	if err != nil {
+		return 0, fmt.Errorf("error converting total memory: %v", err)
+	}
+
+	usedMemory, err := strconv.Atoi(usedMemoryStr)
+	if err != nil {
+		return 0, fmt.Errorf("error converting used memory: %v", err)
+	}
+
+	// Calculate memory usage percentage
+	memoryUsage := 100 - (float64(usedMemory) / float64(totalMemory) * 100)
+
+	// Return the raw float value
+	return memoryUsage, nil
+}
+
+// fetchData makes the HTTP request and returns the response or an error
+func (o ZLTG3000A) fetchData(url string, jsonData []byte) (*ZLTG3000A_Payload, error) {
+	// Create a new request
+	req, err := http.NewRequest("POST", url, bytes.NewBuffer(jsonData))
+	if err != nil {
+		return nil, fmt.Errorf("error creating request: %v", err)
+	}
+
+	// Add headers to the request
+	req.Header.Set("Accept", "application/json, text/plain, */*")
+	req.Header.Set("Accept-Language", "en-US,en;q=0.9")
+	req.Header.Set("Cache-Control", "no-cache")
+	req.Header.Set("Connection", "keep-alive")
+	req.Header.Set("Content-Type", "application/json")
+	req.Header.Set("Origin", "http://globebroadband.net")
+	req.Header.Set("Pragma", "no-cache")
+	req.Header.Set("Referer", "http://globebroadband.net/")
+	req.Header.Set("Sec-GPC", "1")
+	req.Header.Set("User-Agent", "Mozilla/5.0 (X11; Linux x86_64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/128.0.0.0 Safari/537.36")
+
+	// Send the request using an HTTP client
+	client := &http.Client{}
+	resp, err := client.Do(req)
+	if err != nil {
+		return nil, fmt.Errorf("error sending request: %v", err)
+	}
+	defer resp.Body.Close()
+
+	// Read the response body
+	body, err := io.ReadAll(resp.Body)
+	if err != nil {
+		return nil, fmt.Errorf("error reading response: %v", err)
+	}
+
+	// Unmarshal JSON response into the Response struct
+	var result ZLTG3000A_Payload
+	err = json.Unmarshal(body, &result)
+	if err != nil {
+		return nil, fmt.Errorf("error unmarshaling response: %v", err)
+	}
+
+	// Return the result as a pointer to the Response struct
+	return &result, nil
+}
+
+// cron job
+func (o ZLTG3000A) UpdateCachedPage() {
+	// Define the URL and request body
+	url := o.GetGponUrl()
+	jsonData := []byte(`{"cmd":481,"method":"GET","sessionId":""}`)
+
+	// Call the fetchData function
+	response, err := o.fetchData(url, jsonData)
+
+	if err == nil {
+		cachedGponData.SetGponData(response)
+	} else {
+		cachedGponData.SetGponData(nil)
+	}
+}
+
+func (o ZLTG3000A) GetOpticalInfo() *OpticalStats {
+	var opticalInfo *OpticalStats
+
+	if cachedGponData.GetGponData() != nil {
+		opticalInfo = new(OpticalStats)
+		gp := cachedGponData.GetGponData()
+
+		opticalInfo.TxPower, _ = o.ConvertPowerToDBm(gp.TxPower)
+		opticalInfo.RxPower, _ = o.ConvertPowerToDBm(gp.RxPower)
+		opticalInfo.Temperature, _ = o.ConvertPowerToDBm(gp.WorkTemperature)
+		// opticalInfo.SupplyVoltage  info not available
+		// opticalInfo.BiasCurrent    info not available
+	}
+
+	return opticalInfo
+}
+
+func (o ZLTG3000A) GetDeviceInfo() *DeviceStats {
+	var deviceInfo *DeviceStats
+
+	if cachedGponData.GetGponData() != nil {
+		deviceInfo = new(DeviceStats)
+		gp := cachedGponData.GetGponData()
+
+		deviceInfo.DeviceModel = gp.BoardType
+		deviceInfo.ModelSerial = gp.PonSN
+		deviceInfo.SoftwareVersion = gp.FakeVersion
+		deviceInfo.MemoryUsage, _ = o.ParseMemoryUsage(gp.Memory)
+		deviceInfo.CpuUsage, _ = strconv.ParseFloat(gp.CPUUsage, 64)
+		deviceInfo.Uptime, _ = strconv.ParseInt(gp.Uptime, 10, 64)
+	}
+
+	return deviceInfo
+}
+
+// ConvertPowerToDBm converts raw power value to dBm
+func (o ZLTG3000A) ConvertPowerToDBm(power string) (float64, error) {
+	// Convert string to number
+	powerVal, err := strconv.ParseFloat(power, 64)
+	if err != nil {
+		return 0, err // Return 0 and the error if conversion fails
+	}
+
+	// Perform the conversion: log10(power / 10000)
+	convertedPower := math.Log10(powerVal / 1e4)
+
+	// Round the result to one decimal place
+	convertedPower = math.Round(convertedPower*100) / 10
+
+	// Return the raw float value instead of a formatted string
+	return convertedPower, nil
+}
+
+// convertWorkTemperature converts the WorkTemperature value to a float.
+func (o ZLTG3000A) ConvertWorkTemperature(workTemperature string) (float64, error) {
+	// Convert the input string to a number
+	r, err := strconv.ParseFloat(workTemperature, 64)
+	if err != nil {
+		return 0, err // Return 0 and the error if conversion fails
+	}
+
+	// Calculate the temperature based on the conditions
+	var temperature float64
+	if r >= math.Pow(2, 15) {
+		temperature = -math.Round((math.Pow(2, 16) - r) / 256)
+	} else {
+		temperature = math.Round(r / 256)
+	}
+
+	return temperature, nil
+}