Implemented sms read

Author: brokenCursor

args.go

@@ -9,7 +9,7 @@ type (
 
 	SMSSendArgs struct {
 		PhoneNumber string `validate:"e164" arg:"-p,--phone,required" help:"Receiver's phone number"`
-		Message     string `validate:"printascii" arg:"-m,--msg,required" help:"Message to be sent"`
+		Message     string `validate:"alphanum" arg:"-m,--msg,required" help:"Message to be sent"`
 	}
 
 	SMSReadArgs struct {

drivers/driver_ctl.go

@@ -3,6 +3,7 @@ package drivers
 import (
 	"fmt"
 	"log/slog"
+	"time"
 
 	"github.com/brokenCursor/usb-modem-cli/logging"
 	"github.com/spf13/viper"
@@ -27,12 +28,13 @@ type (
 		BaseModem
 
 		SendSMS(phone string, message string) error
-		// GetAllSMS() ([]SMS, error)
+		ReadAllSMS() ([]SMS, error)
 	}
 )
 
 type (
 	SMS struct {
+		Time    time.Time
 		Sender  string
 		Message string
 	}
@@ -53,7 +55,6 @@ func init() {
 }
 
 func IsRegistered(name string) bool {
-	// Check if driver has already been registered
 	_, ok := Drivers[name]
 	return ok
 }

drivers/zte8810ft.go

@@ -1,6 +1,7 @@
 package drivers
 
 import (
+	"encoding/hex"
 	"encoding/json"
 	"fmt"
 	"io"
@@ -14,6 +15,7 @@ import (
 	cfg "github.com/brokenCursor/usb-modem-cli/config"
 	"github.com/spf13/viper"
 	"github.com/warthog618/sms/encoding/gsm7"
+	"github.com/warthog618/sms/encoding/ucs2"
 )
 
 // DO NOT USE DIRECTLY
@@ -31,6 +33,17 @@ type (
 	pppConnected struct {
 		Connected string `json:"ppp_status"`
 	}
+
+	rawIncomingSMS struct {
+		Messages []struct {
+			ID           string `json:"id"`
+			Source       string `json:"number"`
+			Content      string `json:"content"`
+			Tag          string `json:"tag"`
+			Date         string `json:"date"`
+			DraftGroupID string `json:"draft_group_id"`
+		} `json:"messages"`
+	}
 )
 
 func init() {
@@ -227,14 +240,8 @@ func (m *zte8810ft) GetCellConnStatus() (*LinkStatus, error) {
 }
 
 func (m *zte8810ft) SendSMS(phone string, message string) error {
-	// GET /goform/goform_set_cmd_process?goformId=SEND_SMS
-	// Prepare everything to make a request
-
 	// Encode message into GSM-7 as byte array
 	encodedMsg, err := gsm7.Encode([]byte(message))
-	switch err {
-
-	}
 	if err != nil {
 		return ActionError{Action: "sms send", Err: err}
 	}
@@ -304,3 +311,79 @@ func (m *zte8810ft) SendSMS(phone string, message string) error {
 
 	return nil
 }
+
+func (m *zte8810ft) ReadAllSMS() ([]SMS, error) {
+	// http://10.96.170.1/goform/goform_get_cmd_process?cmd=sms_data_total&page=0&data_per_page=100&mem_store=1&tags=12&order_by=order+by+id+desc&_=1724578532798
+	// Build query
+	u := m.getBaseURL("/goform/goform_get_cmd_process")
+	query := u.Query()
+	query.Add("cmd", "sms_data_total")
+	query.Add("page", "0")
+	query.Add("data_per_page", "100")
+	query.Add("mem_store", "1")
+	query.Add("tags", "12") // 1 - Received, unread | 2 - Sent | 12 - Received, read + unread | 11 - Drafts (??)
+	query.Add("order_by", "order by id desc")
+	query.Add("_", strconv.FormatInt((time.Now().UnixMilli)(), 10))
+	u.RawQuery = query.Encode()
+
+	request, err := m.getNewRequest("GET", u, http.Header{}, nil)
+	if err != nil {
+		return nil, ActionError{Action: "sms read", Err: err}
+	}
+	m.logger.With("request", request.URL.String()).Debug("request")
+
+	resp, err := m.httpClient.Do(request)
+
+	// Process errors
+	switch {
+	case err != nil:
+		return nil, ActionError{Action: "status", Err: err}
+	case resp.StatusCode != 200:
+		return nil, ActionError{Action: "status", Err: fmt.Errorf("response status %d", resp.StatusCode)}
+	}
+
+	// Read the response
+	defer resp.Body.Close()
+	body, err := io.ReadAll(resp.Body)
+	if err != nil {
+		return nil, ErrUnknown
+	}
+
+	rawSMS := new(rawIncomingSMS)
+
+	err = json.Unmarshal(body, &rawSMS)
+	if err != nil {
+		m.logger.With("body", body).Debug("failed to unmarshal body to struct")
+		return nil, ActionError{Action: "sms read", Err: err}
+	}
+
+	processedSMS := make([]SMS, len(rawSMS.Messages))
+	for i := range rawSMS.Messages {
+		processedSMS[i].Sender = rawSMS.Messages[i].Source
+
+		// Extract datetime
+		date, err := time.Parse("06,01,02,15,04,05,-07", rawSMS.Messages[i].Date)
+		if err != nil {
+			m.logger.With("id", rawSMS.Messages[i].ID, "raw_date", rawSMS.Messages[i].Date, "err", err).Debug("failed to parse datetime")
+			return nil, ActionError{Action: "sms read", Err: fmt.Errorf("failed to decode message datetime")}
+		}
+		processedSMS[i].Time = date
+
+		// Extract contents
+		rawBytes, err := hex.DecodeString(rawSMS.Messages[i].Content)
+		if err != nil {
+			m.logger.With("id", rawSMS.Messages[i].ID, "raw_content", rawSMS.Messages[i].Content).Debug("failed to parse content")
+			return nil, ActionError{Action: "sms read", Err: fmt.Errorf("failed to parse message content")}
+		}
+
+		runes, err := ucs2.Decode(rawBytes)
+		if err != nil {
+			m.logger.With("id", rawSMS.Messages[i].ID, "raw_content", rawSMS.Messages[i].Content).Debug("failed to decode content")
+			return nil, ActionError{Action: "sms read", Err: fmt.Errorf("failed to decode message content")}
+		}
+
+		processedSMS[i].Message = string(runes)
+	}
+
+	return processedSMS, nil
+}

mcli.go

@@ -3,6 +3,7 @@ package main
 import (
 	"log/slog"
 	"os"
+	"time"
 
 	"github.com/alexflint/go-arg"
 	"github.com/brokenCursor/usb-modem-cli/config"
@@ -98,7 +99,6 @@ func run() error {
 			}
 		}
 	case args.SMS != nil:
-		// None of this is implemented :)
 		sms, ok := modem.(drivers.ModemSMS)
 		if !ok {
 			return DriverSupportError{Driver: modem, Function: "SMS"}
@@ -108,13 +108,22 @@ func run() error {
 		case args.SMS.Send != nil:
 			err := validate.Struct(args.SMS.Send)
 			if err != nil {
-				parser.FailSubcommand("Unknown action", "sms")
+				parser.FailSubcommand("Unknown values or action", "sms")
 			}
 
 			err = sms.SendSMS(args.SMS.Send.PhoneNumber, args.SMS.Send.Message)
 			if err != nil {
 				return err
 			}
+		case args.SMS.Read != nil:
+			messages, err := sms.ReadAllSMS()
+			if err != nil {
+				return err
+			}
+
+			for i := range messages {
+				cfmt.Printf("{{ID:}}::cyan %d\n{{Source:}}::green %s\n{{Time:}}::yellow %s\n{{Text:}}::#FA8100\n%s\n---\n", i, messages[i].Sender, messages[i].Time.Format(time.DateTime), messages[i].Message)
+			}
 		}
 	case parser.Subcommand() == nil:
 		parser.Fail("Missing or unknown command")