Initial commit

README.md

@@ -1,3 +1,5 @@
 # go-agwpe
 
-Provides a client implementation of the AGWPE protocol for Go
+Provides a client implementation of the AGWPE protocol for Go.
+
+Ported in part from https://github.com/mfncooper/pyham_pe.

agw.go

@@ -0,0 +1,33 @@
+package main
+
+import "encoding/binary"
+
+type Frame struct {
+	Port      byte
+	Reserved0 [3]byte
+	DataKind  byte
+	Reserved1 byte
+	PID       byte
+	Reserved2 byte
+	CallFrom  [10]byte
+	CallTo    [10]byte
+	DataLen   uint32
+	User      [4]byte
+}
+
+func (f *Frame) Serialize() []byte {
+	buf := make([]byte, 36)
+
+	buf[0] = f.Port
+	// Ignore reserved bytes 1 to 3
+	buf[4] = f.DataKind
+	// Ignore reserved byte 5
+	buf[6] = f.PID
+	// Ignore reserved byte 7
+	copy(buf[8:18], f.CallFrom[:])
+	copy(buf[18:28], f.CallTo[:])
+	binary.BigEndian.PutUint32(buf[28:32], f.DataLen)
+	copy(buf[32:36], f.User[:])
+
+	return buf
+}

go.mod

@@ -0,0 +1,3 @@
+module go-agw/agw
+
+go 1.24.5

main.go

@@ -0,0 +1,68 @@
+package main
+
+import (
+	"bytes"
+	"encoding/binary"
+	"fmt"
+	"net"
+	"time"
+)
+
+func main() {
+	address := "172.16.0.4:8000"
+	timeout := 5 * time.Second
+	send_buf := new(bytes.Buffer)
+	recv_buf := make([]byte, 1024)
+
+	conn, err := net.DialTimeout("tcp", address, timeout)
+	if err != nil {
+		fmt.Printf("Failed to connect: %v\n", err)
+		return
+	}
+	defer conn.Close()
+
+	fmt.Printf("Connected to %s\n", address)
+
+	rFrame := Frame{
+		Port:     0x01,
+		DataKind: 0x52,
+	}
+
+	err = binary.Write(send_buf, binary.LittleEndian, rFrame)
+	if err != nil {
+		fmt.Println("Binary write error:", err)
+	}
+
+	byteSlice := send_buf.Bytes()
+
+	_, err = conn.Write(byteSlice)
+	if err != nil {
+		fmt.Println("Error sending frame to server:", err)
+		return
+	}
+
+	n, err := conn.Read(recv_buf)
+	if err != nil {
+		fmt.Println("Error reading:", err)
+		return
+	}
+	fmt.Printf("Received %d bytes:\n", n)
+
+	reader := bytes.NewReader(recv_buf)
+	var f Frame
+	err = binary.Read(reader, binary.LittleEndian, &f)
+	if err != nil {
+		fmt.Println("Error decoding:", err)
+		return
+	}
+	fmt.Println("Response frame:")
+	fmt.Printf("Port: %d\n", f.Port)
+	fmt.Printf("DataKind: %c\n", f.DataKind)
+	fmt.Printf("PID: 0x%02X\n", f.PID)
+	fmt.Printf("CallFrom: %s\n", f.CallFrom)
+	fmt.Printf("CallTo: %s\n", f.CallTo)
+	fmt.Printf("DataLen: %d\n", f.DataLen)
+	major_verion := (uint16(recv_buf[37]) << 8) | uint16(recv_buf[36])
+	minor_verion := (uint16(recv_buf[41]) << 8) | uint16(recv_buf[40])
+	fmt.Printf("AGWPE version: %d.%d\n", major_verion, minor_verion)
+}