Add MapReport decoding and formatting support

- Added DecodeMapReport function to decode protobuf MapReport messages
- Added FormatMapReport function to display MapReport data in human-readable format
- Updated FormatTopicAndMapData to use the proper decoder and formatter
- Improved error handling with fallback to raw display

🤖 Generated with [Claude Code](https://claude.ai/code)

Co-Authored-By: Claude <noreply@anthropic.com>
This commit is contained in:
Daniel Pupius
2025-04-20 16:07:46 -07:00
parent 42304465a3
commit 2a7bc97a80
2 changed files with 215 additions and 122 deletions

View File

@@ -288,6 +288,15 @@ func DecodeJSONMessage(payload []byte) (map[string]interface{}, error) {
return jsonData, nil
}
// DecodeMapReport decodes a MapReport protobuf message (format "map")
func DecodeMapReport(payload []byte) (*pb.MapReport, error) {
var mapReport pb.MapReport
if err := proto.Unmarshal(payload, &mapReport); err != nil {
return nil, fmt.Errorf("failed to unmarshal MapReport: %v", err)
}
return &mapReport, nil
}
// IsASCII checks if the given byte array contains only ASCII characters
func IsASCII(data []byte) bool {
for _, b := range data {

View File

@@ -5,23 +5,23 @@ import (
"fmt"
"strings"
"time"
"google.golang.org/protobuf/encoding/protojson"
"google.golang.org/protobuf/proto"
pb "meshstream/proto/generated/meshtastic"
)
// FormatTelemetryMessage formats a Telemetry message
func FormatTelemetryMessage(telemetry *pb.Telemetry) string {
var builder strings.Builder
if telemetry == nil {
return "Error: nil telemetry data"
}
builder.WriteString("Telemetry Data:\n")
if telemetry.GetTime() != 0 {
tm := time.Unix(int64(telemetry.GetTime()), 0)
builder.WriteString(fmt.Sprintf(" Time: %s\n", tm.Format(time.RFC3339)))
@@ -30,54 +30,54 @@ func FormatTelemetryMessage(telemetry *pb.Telemetry) string {
// Check which telemetry type we have
if env := telemetry.GetEnvironmentMetrics(); env != nil {
builder.WriteString(" Environment Telemetry:\n")
temp := env.GetTemperature()
if temp != 0 {
builder.WriteString(fmt.Sprintf(" Temperature: %.2f °C\n", temp))
}
humidity := env.GetRelativeHumidity()
if humidity != 0 {
builder.WriteString(fmt.Sprintf(" Humidity: %.2f %%\n", humidity))
}
pressure := env.GetBarometricPressure()
if pressure != 0 {
builder.WriteString(fmt.Sprintf(" Pressure: %.2f hPa\n", pressure))
}
gasRes := env.GetGasResistance()
if gasRes != 0 {
builder.WriteString(fmt.Sprintf(" Gas Resistance: %.2f MΩ\n", gasRes))
}
iaq := env.GetIaq()
if iaq != 0 {
builder.WriteString(fmt.Sprintf(" Air Quality (IAQ): %d\n", iaq))
}
distance := env.GetDistance()
if distance != 0 {
builder.WriteString(fmt.Sprintf(" Distance: %.1f mm\n", distance))
}
lux := env.GetLux()
if lux != 0 {
builder.WriteString(fmt.Sprintf(" Light: %.1f lux\n", lux))
}
windDir := env.GetWindDirection()
if windDir != 0 {
directions := []string{"N", "NE", "E", "SE", "S", "SW", "W", "NW"}
dirIndex := int(windDir / 45) % 8
dirIndex := int(windDir/45) % 8
builder.WriteString(fmt.Sprintf(" Wind Direction: %d° (%s)\n", windDir, directions[dirIndex]))
}
windSpeed := env.GetWindSpeed()
if windSpeed != 0 {
builder.WriteString(fmt.Sprintf(" Wind Speed: %.1f m/s\n", windSpeed))
}
windGust := env.GetWindGust()
if windGust != 0 {
builder.WriteString(fmt.Sprintf(" Wind Gust: %.1f m/s\n", windGust))
@@ -86,32 +86,32 @@ func FormatTelemetryMessage(telemetry *pb.Telemetry) string {
if power := telemetry.GetPowerMetrics(); power != nil {
builder.WriteString(" Power Telemetry:\n")
ch1Volt := power.GetCh1Voltage()
if ch1Volt != 0 {
builder.WriteString(fmt.Sprintf(" Channel 1 Voltage: %.2f V\n", ch1Volt))
}
ch1Curr := power.GetCh1Current()
if ch1Curr != 0 {
builder.WriteString(fmt.Sprintf(" Channel 1 Current: %.2f mA\n", ch1Curr))
}
ch2Volt := power.GetCh2Voltage()
if ch2Volt != 0 {
builder.WriteString(fmt.Sprintf(" Channel 2 Voltage: %.2f V\n", ch2Volt))
}
ch2Curr := power.GetCh2Current()
if ch2Curr != 0 {
builder.WriteString(fmt.Sprintf(" Channel 2 Current: %.2f mA\n", ch2Curr))
}
ch3Volt := power.GetCh3Voltage()
if ch3Volt != 0 {
builder.WriteString(fmt.Sprintf(" Channel 3 Voltage: %.2f V\n", ch3Volt))
}
ch3Curr := power.GetCh3Current()
if ch3Curr != 0 {
builder.WriteString(fmt.Sprintf(" Channel 3 Current: %.2f mA\n", ch3Curr))
@@ -120,61 +120,61 @@ func FormatTelemetryMessage(telemetry *pb.Telemetry) string {
if air := telemetry.GetAirQualityMetrics(); air != nil {
builder.WriteString(" Air Quality Telemetry:\n")
pm10 := air.GetPm10Standard()
if pm10 != 0 {
builder.WriteString(fmt.Sprintf(" PM 1.0: %d µg/m³\n", pm10))
}
pm25 := air.GetPm25Standard()
if pm25 != 0 {
builder.WriteString(fmt.Sprintf(" PM 2.5: %d µg/m³\n", pm25))
}
pm100 := air.GetPm100Standard()
if pm100 != 0 {
builder.WriteString(fmt.Sprintf(" PM 10.0: %d µg/m³\n", pm100))
}
co2 := air.GetCo2()
if co2 != 0 {
builder.WriteString(fmt.Sprintf(" CO2: %d ppm\n", co2))
}
// VOC field not available in this version of the proto
}
// Device metrics
if device := telemetry.GetDeviceMetrics(); device != nil {
builder.WriteString(" Device Metrics:\n")
batLevel := device.GetBatteryLevel()
if batLevel != 0 {
builder.WriteString(fmt.Sprintf(" Battery Level: %d%%\n", batLevel))
}
voltage := device.GetVoltage()
if voltage != 0 {
builder.WriteString(fmt.Sprintf(" Voltage: %.2f V\n", voltage))
}
chanUtil := device.GetChannelUtilization()
if chanUtil != 0 {
builder.WriteString(fmt.Sprintf(" Channel Utilization: %.2f%%\n", chanUtil))
}
airUtil := device.GetAirUtilTx()
if airUtil != 0 {
builder.WriteString(fmt.Sprintf(" Air Utilization TX: %.2f%%\n", airUtil))
}
uptime := device.GetUptimeSeconds()
if uptime != 0 {
uptimeDur := time.Duration(uptime) * time.Second
builder.WriteString(fmt.Sprintf(" Uptime: %s\n", uptimeDur))
}
}
// Local stats
if stats := telemetry.GetLocalStats(); stats != nil {
builder.WriteString(" Local Statistics:\n")
@@ -204,21 +204,21 @@ func FormatTelemetryMessage(telemetry *pb.Telemetry) string {
builder.WriteString(fmt.Sprintf(" Total Nodes: %d\n", stats.GetNumTotalNodes()))
}
}
// Health metrics
if health := telemetry.GetHealthMetrics(); health != nil {
builder.WriteString(" Health Metrics:\n")
heartBpm := health.GetHeartBpm()
if heartBpm != 0 {
builder.WriteString(fmt.Sprintf(" Heart Rate: %d bpm\n", heartBpm))
}
spo2 := health.GetSpO2()
if spo2 != 0 {
builder.WriteString(fmt.Sprintf(" SpO2: %d%%\n", spo2))
}
temp := health.GetTemperature()
if temp != 0 {
builder.WriteString(fmt.Sprintf(" Body Temperature: %.1f °C\n", temp))
@@ -238,7 +238,7 @@ func FormatTelemetryMessage(telemetry *pb.Telemetry) string {
// FormatPositionMessage formats a Position message
func FormatPositionMessage(position *pb.Position) string {
var builder strings.Builder
if position == nil {
return "Error: nil position data"
}
@@ -252,10 +252,10 @@ func FormatPositionMessage(position *pb.Position) string {
// representing the position multiplied by 1e7 (10 million)
lat := float64(position.GetLatitudeI()) / 10000000.0
lon := float64(position.GetLongitudeI()) / 10000000.0
builder.WriteString(fmt.Sprintf(" Latitude: %.7f\n", lat))
builder.WriteString(fmt.Sprintf(" Longitude: %.7f\n", lon))
// Google Maps link for convenience
builder.WriteString(fmt.Sprintf(" Google Maps: https://maps.google.com/?q=%.7f,%.7f\n", lat, lon))
} else {
@@ -271,12 +271,12 @@ func FormatPositionMessage(position *pb.Position) string {
if position.GetTime() != 0 {
builder.WriteString(fmt.Sprintf(" Time: %d\n", position.GetTime()))
}
if position.GetTimestamp() != 0 {
// Convert UNIX timestamp to readable time
tm := time.Unix(int64(position.GetTimestamp()), 0)
builder.WriteString(fmt.Sprintf(" Timestamp: %s\n", tm.Format(time.RFC3339)))
if position.GetTimestampMillisAdjust() != 0 {
builder.WriteString(fmt.Sprintf(" Millis adjustment: %d\n", position.GetTimestampMillisAdjust()))
}
@@ -286,7 +286,7 @@ func FormatPositionMessage(position *pb.Position) string {
if position.GetLocationSource() != pb.Position_LOC_UNSET {
builder.WriteString(fmt.Sprintf(" Location Source: %s\n", position.GetLocationSource()))
}
if position.GetAltitudeSource() != pb.Position_ALT_UNSET {
builder.WriteString(fmt.Sprintf(" Altitude Source: %s\n", position.GetAltitudeSource()))
}
@@ -327,37 +327,37 @@ func FormatPositionMessage(position *pb.Position) string {
// FormatNodeInfoMessage formats a User message (used by the NODEINFO_APP port)
func FormatNodeInfoMessage(user *pb.User) string {
var builder strings.Builder
if user == nil {
return "Error: nil user data"
}
builder.WriteString("Node Information:\n")
if user.GetId() != "" {
builder.WriteString(fmt.Sprintf(" ID: %s\n", user.GetId()))
}
if user.GetLongName() != "" {
builder.WriteString(fmt.Sprintf(" Name: %s\n", user.GetLongName()))
}
if user.GetShortName() != "" {
builder.WriteString(fmt.Sprintf(" Short Name: %s\n", user.GetShortName()))
}
if user.GetHwModel() != pb.HardwareModel_UNSET {
builder.WriteString(fmt.Sprintf(" Hardware: %s\n", user.GetHwModel()))
}
if user.GetIsLicensed() {
builder.WriteString(" Licensed HAM operator\n")
}
if user.GetRole() != 0 {
builder.WriteString(fmt.Sprintf(" Role: %s\n", user.GetRole()))
}
if len(user.GetPublicKey()) > 0 {
builder.WriteString(fmt.Sprintf(" Public Key: %x\n", user.GetPublicKey()))
}
@@ -375,47 +375,47 @@ func FormatNodeInfoMessage(user *pb.User) string {
// FormatWaypointMessage formats a Waypoint message
func FormatWaypointMessage(waypoint *pb.Waypoint) string {
var builder strings.Builder
if waypoint == nil {
return "Error: nil waypoint data"
}
builder.WriteString("Waypoint:\n")
if waypoint.GetId() != 0 {
builder.WriteString(fmt.Sprintf(" ID: %d\n", waypoint.GetId()))
}
if waypoint.GetName() != "" {
builder.WriteString(fmt.Sprintf(" Name: %s\n", waypoint.GetName()))
}
if waypoint.GetDescription() != "" {
builder.WriteString(fmt.Sprintf(" Description: %s\n", waypoint.GetDescription()))
}
if waypoint.GetLatitudeI() != 0 && waypoint.GetLongitudeI() != 0 {
// Convert the integer coordinates to floating-point degrees
lat := float64(waypoint.GetLatitudeI()) / 10000000.0
lon := float64(waypoint.GetLongitudeI()) / 10000000.0
builder.WriteString(fmt.Sprintf(" Latitude: %.7f\n", lat))
builder.WriteString(fmt.Sprintf(" Longitude: %.7f\n", lon))
// Google Maps link for convenience
builder.WriteString(fmt.Sprintf(" Google Maps: https://maps.google.com/?q=%.7f,%.7f\n", lat, lon))
}
if waypoint.GetIcon() != 0 {
builder.WriteString(fmt.Sprintf(" Icon: %d\n", waypoint.GetIcon()))
}
if waypoint.GetExpire() != 0 {
// Convert UNIX timestamp to readable time
tm := time.Unix(int64(waypoint.GetExpire()), 0)
builder.WriteString(fmt.Sprintf(" Expires: %s\n", tm.Format(time.RFC3339)))
}
if waypoint.GetLockedTo() != 0 {
builder.WriteString(fmt.Sprintf(" Locked to node: %d\n", waypoint.GetLockedTo()))
}
@@ -435,19 +435,19 @@ func FormatDataMessage(data *pb.Data) string {
if data == nil {
return "Error: nil data"
}
var builder strings.Builder
builder.WriteString(fmt.Sprintf("Data (Port: %s):\n", data.GetPortnum()))
// Format payload based on port type
payload := data.GetPayload()
switch data.GetPortnum() {
case pb.PortNum_TEXT_MESSAGE_APP:
builder.WriteString(fmt.Sprintf(" Text Message: %s\n", string(payload)))
case pb.PortNum_TEXT_MESSAGE_COMPRESSED_APP:
builder.WriteString(fmt.Sprintf(" Compressed Text Message (%d bytes): %x\n", len(payload), payload))
case pb.PortNum_TELEMETRY_APP:
var telemetry pb.Telemetry
if err := proto.Unmarshal(payload, &telemetry); err == nil {
@@ -456,7 +456,7 @@ func FormatDataMessage(data *pb.Data) string {
builder.WriteString(fmt.Sprintf(" Failed to parse telemetry: %v\n", err))
builder.WriteString(fmt.Sprintf(" Raw bytes (%d): %x\n", len(payload), payload))
}
case pb.PortNum_POSITION_APP:
var position pb.Position
if err := proto.Unmarshal(payload, &position); err == nil {
@@ -465,7 +465,7 @@ func FormatDataMessage(data *pb.Data) string {
builder.WriteString(fmt.Sprintf(" Failed to parse position: %v\n", err))
builder.WriteString(fmt.Sprintf(" Raw bytes (%d): %x\n", len(payload), payload))
}
case pb.PortNum_NODEINFO_APP:
var user pb.User
if err := proto.Unmarshal(payload, &user); err == nil {
@@ -474,7 +474,7 @@ func FormatDataMessage(data *pb.Data) string {
builder.WriteString(fmt.Sprintf(" Failed to parse node info: %v\n", err))
builder.WriteString(fmt.Sprintf(" Raw bytes (%d): %x\n", len(payload), payload))
}
case pb.PortNum_WAYPOINT_APP:
var waypoint pb.Waypoint
if err := proto.Unmarshal(payload, &waypoint); err == nil {
@@ -483,7 +483,7 @@ func FormatDataMessage(data *pb.Data) string {
builder.WriteString(fmt.Sprintf(" Failed to parse waypoint: %v\n", err))
builder.WriteString(fmt.Sprintf(" Raw bytes (%d): %x\n", len(payload), payload))
}
default:
// For unknown types, show raw binary data
builder.WriteString(fmt.Sprintf(" Binary data (%d bytes): %x\n", len(payload), payload))
@@ -492,7 +492,7 @@ func FormatDataMessage(data *pb.Data) string {
builder.WriteString(fmt.Sprintf(" As text: %s\n", string(payload)))
}
}
// Show additional Data fields
if data.GetRequestId() != 0 {
builder.WriteString(fmt.Sprintf(" Request ID: %d\n", data.GetRequestId()))
@@ -512,7 +512,7 @@ func FormatDataMessage(data *pb.Data) string {
if data.GetWantResponse() {
builder.WriteString(" Wants Response: Yes\n")
}
return builder.String()
}
@@ -521,46 +521,46 @@ func FormatPayload(payload interface{}, portNum pb.PortNum) string {
if payload == nil {
return " No payload data\n"
}
switch portNum {
case pb.PortNum_TEXT_MESSAGE_APP:
// Text message
if text, ok := payload.(string); ok {
return fmt.Sprintf(" Text Message: %s\n", text)
}
case pb.PortNum_TEXT_MESSAGE_COMPRESSED_APP:
// Compressed text
if data, ok := payload.([]byte); ok {
return fmt.Sprintf(" Compressed Text Message (%d bytes): %x\n", len(data), data)
// TODO: Add decompression support
}
case pb.PortNum_TELEMETRY_APP:
// Telemetry data
if telemetry, ok := payload.(*pb.Telemetry); ok {
return FormatTelemetryMessage(telemetry)
}
case pb.PortNum_POSITION_APP:
// Position data
if position, ok := payload.(*pb.Position); ok {
return FormatPositionMessage(position)
}
case pb.PortNum_NODEINFO_APP:
// Node information
if user, ok := payload.(*pb.User); ok {
return FormatNodeInfoMessage(user)
}
case pb.PortNum_WAYPOINT_APP:
// Waypoint data
if waypoint, ok := payload.(*pb.Waypoint); ok {
return FormatWaypointMessage(waypoint)
}
}
// Default formatting for unknown types
switch v := payload.(type) {
case string:
@@ -579,31 +579,31 @@ func FormatPayload(payload interface{}, portNum pb.PortNum) string {
// FormatDecodedPacket formats a DecodedPacket into a human-readable string
func FormatDecodedPacket(packet *DecodedPacket) string {
var builder strings.Builder
if packet == nil {
return "Error: nil packet"
}
if packet.DecodeError != nil {
builder.WriteString(fmt.Sprintf("Error decoding packet: %v\n", packet.DecodeError))
return builder.String()
}
// Envelope info
builder.WriteString("Packet:\n")
builder.WriteString(fmt.Sprintf(" Channel ID: %s\n", packet.ChannelID))
if packet.GatewayID != "" {
builder.WriteString(fmt.Sprintf(" Gateway ID: %s\n", packet.GatewayID))
}
// Mesh packet info
builder.WriteString(fmt.Sprintf(" ID: %d\n", packet.ID))
builder.WriteString(fmt.Sprintf(" From: %d\n", packet.From))
builder.WriteString(fmt.Sprintf(" To: %d\n", packet.To))
// Additional fields that might be interesting
builder.WriteString(fmt.Sprintf(" Port: %s\n", packet.PortNum))
if packet.HopLimit != 0 {
builder.WriteString(fmt.Sprintf(" Hop Limit: %d\n", packet.HopLimit))
}
@@ -622,7 +622,7 @@ func FormatDecodedPacket(packet *DecodedPacket) string {
if packet.RelayNode != 0 {
builder.WriteString(fmt.Sprintf(" Relay Node: %d\n", packet.RelayNode))
}
// Additional data fields
if packet.RequestID != 0 {
builder.WriteString(fmt.Sprintf(" Request ID: %d\n", packet.RequestID))
@@ -642,42 +642,42 @@ func FormatDecodedPacket(packet *DecodedPacket) string {
if packet.WantResponse {
builder.WriteString(" Wants Response: Yes\n")
}
// Format the payload
builder.WriteString("\n")
builder.WriteString(FormatPayload(packet.Payload, packet.PortNum))
return builder.String()
}
// FormatServiceEnvelope formats a ServiceEnvelope message into a human-readable string
func FormatServiceEnvelope(envelope *pb.ServiceEnvelope) string {
var builder strings.Builder
builder.WriteString("ServiceEnvelope:\n")
// Print basic envelope info
builder.WriteString(fmt.Sprintf(" Channel ID: %s\n", envelope.GetChannelId()))
builder.WriteString(fmt.Sprintf(" Gateway ID: %s\n", envelope.GetGatewayId()))
// Print MeshPacket info if available
if packet := envelope.GetPacket(); packet != nil {
builder.WriteString("\nMeshPacket:\n")
builder.WriteString(fmt.Sprintf(" ID: %d\n", packet.GetId()))
builder.WriteString(fmt.Sprintf(" From: %d\n", packet.GetFrom()))
builder.WriteString(fmt.Sprintf(" To: %d\n", packet.GetTo()))
// Output routing and hop information
builder.WriteString(fmt.Sprintf(" Hop Limit: %d\n", packet.GetHopLimit()))
builder.WriteString(fmt.Sprintf(" Hop Start: %d\n", packet.GetHopStart()))
builder.WriteString(fmt.Sprintf(" Want ACK: %v\n", packet.GetWantAck()))
builder.WriteString(fmt.Sprintf(" Priority: %s\n", packet.GetPriority()))
// Output if the packet was delivered via MQTT
if packet.GetViaMqtt() {
builder.WriteString(" Via MQTT: Yes\n")
}
// Relay and next hop info
if packet.GetNextHop() != 0 {
builder.WriteString(fmt.Sprintf(" Next Hop: %d\n", packet.GetNextHop()))
@@ -685,25 +685,25 @@ func FormatServiceEnvelope(envelope *pb.ServiceEnvelope) string {
if packet.GetRelayNode() != 0 {
builder.WriteString(fmt.Sprintf(" Relay Node: %d\n", packet.GetRelayNode()))
}
// Show public key information if available (for PKI-encrypted packets)
if len(packet.GetPublicKey()) > 0 {
builder.WriteString(fmt.Sprintf(" Public Key: %x\n", packet.GetPublicKey()))
builder.WriteString(fmt.Sprintf(" PKI Encrypted: %v\n", packet.GetPkiEncrypted()))
}
// Determine payload type
if packet.GetDecoded() != nil {
// For already decoded packets, use our specialized data formatter
builder.WriteString("\n")
builder.WriteString(FormatDataMessage(packet.GetDecoded()))
} else if packet.GetEncrypted() != nil {
// Encrypted payload information
builder.WriteString("\n Encrypted Payload:\n")
builder.WriteString(fmt.Sprintf(" Size: %d bytes\n", len(packet.GetEncrypted())))
builder.WriteString(fmt.Sprintf(" Channel: %d\n", packet.GetChannel()))
// Print the first few bytes of the encrypted payload for identification
if len(packet.GetEncrypted()) > 0 {
displayLen := len(packet.GetEncrypted())
@@ -712,23 +712,23 @@ func FormatServiceEnvelope(envelope *pb.ServiceEnvelope) string {
}
builder.WriteString(fmt.Sprintf(" First %d bytes: %x\n", displayLen, packet.GetEncrypted()[:displayLen]))
}
// If the packet has channel ID, it's using channel-based encryption
channelId := envelope.GetChannelId()
if channelId != "" {
builder.WriteString(fmt.Sprintf(" Encryption: Channel-based (Channel ID: %s)\n", channelId))
// Attempt to decrypt the payload using the channel key
channelKey := GetChannelKey(channelId)
builder.WriteString(fmt.Sprintf(" Using key (%d bytes): %x\n", len(channelKey), channelKey))
// Try to decrypt
decrypted, err := XOR(packet.GetEncrypted(), channelKey, packet.GetId(), packet.GetFrom())
if err != nil {
builder.WriteString(fmt.Sprintf(" Decryption error: %v\n", err))
} else {
builder.WriteString(fmt.Sprintf(" Decrypted (%d bytes): %x\n", len(decrypted), decrypted))
// Try to parse the decrypted payload as a Data message
var data pb.Data
if err := proto.Unmarshal(decrypted, &data); err == nil {
@@ -748,7 +748,7 @@ func FormatServiceEnvelope(envelope *pb.ServiceEnvelope) string {
}
}
}
// Use protojson to generate a full JSON representation for debugging
marshaler := protojson.MarshalOptions{
Multiline: true,
@@ -759,7 +759,7 @@ func FormatServiceEnvelope(envelope *pb.ServiceEnvelope) string {
builder.WriteString("\nFull Protobuf Structure:\n")
builder.WriteString(string(jsonBytes))
}
return builder.String()
}
@@ -777,9 +777,9 @@ func indent(s, prefix string) string {
// FormatJSONMessage formats a JSON message into a human-readable string
func FormatJSONMessage(jsonData map[string]interface{}) string {
var builder strings.Builder
builder.WriteString("JSON Message:\n")
// Extract and display common fields
if from, ok := jsonData["from"].(string); ok {
builder.WriteString(fmt.Sprintf(" From: %s\n", from))
@@ -793,21 +793,21 @@ func FormatJSONMessage(jsonData map[string]interface{}) string {
if timestamp, ok := jsonData["timestamp"].(string); ok {
builder.WriteString(fmt.Sprintf(" Timestamp: %s\n", timestamp))
}
// Format the full JSON for reference
jsonBytes, err := json.MarshalIndent(jsonData, " ", " ")
if err == nil {
builder.WriteString("\nFull JSON Structure:\n ")
builder.WriteString(string(jsonBytes))
}
return builder.String()
}
// FormatTopicAndPacket formats both topic information and a decoded packet
func FormatTopicAndPacket(topicInfo *TopicInfo, decodedPacket *DecodedPacket) string {
var builder strings.Builder
// Display topic information
builder.WriteString(fmt.Sprintf("Topic: %s\n", topicInfo.FullTopic))
builder.WriteString(fmt.Sprintf("Region Path: %s\n", topicInfo.RegionPath))
@@ -818,17 +818,17 @@ func FormatTopicAndPacket(topicInfo *TopicInfo, decodedPacket *DecodedPacket) st
builder.WriteString(fmt.Sprintf("User ID: %s\n", topicInfo.UserID))
}
builder.WriteString("\n")
// Format the decoded packet
builder.WriteString(FormatDecodedPacket(decodedPacket))
return builder.String()
}
// FormatTopicAndJSONData formats both topic information and decoded JSON data
func FormatTopicAndJSONData(topicInfo *TopicInfo, jsonData map[string]interface{}) string {
var builder strings.Builder
// Display topic information
builder.WriteString(fmt.Sprintf("Topic: %s\n", topicInfo.FullTopic))
builder.WriteString(fmt.Sprintf("Region Path: %s\n", topicInfo.RegionPath))
@@ -839,14 +839,91 @@ func FormatTopicAndJSONData(topicInfo *TopicInfo, jsonData map[string]interface{
builder.WriteString(fmt.Sprintf("User ID: %s\n", topicInfo.UserID))
}
builder.WriteString("\n")
// Format the JSON data
builder.WriteString(FormatJSONMessage(jsonData))
return builder.String()
}
// FormatMapReport formats a MapReport message
func FormatMapReport(report *pb.MapReport) string {
var builder strings.Builder
builder.WriteString("Map Report:\n")
if report.GetLongName() != "" {
builder.WriteString(fmt.Sprintf(" Name: %s\n", report.GetLongName()))
}
if report.GetShortName() != "" {
builder.WriteString(fmt.Sprintf(" Short Name: %s\n", report.GetShortName()))
}
// Format hardware model
if report.GetHwModel() != pb.HardwareModel_UNSET {
builder.WriteString(fmt.Sprintf(" Hardware: %s\n", report.GetHwModel()))
}
// Format role
if report.GetRole() != 0 {
builder.WriteString(fmt.Sprintf(" Role: %s\n", report.GetRole()))
}
// Format firmware version
if report.GetFirmwareVersion() != "" {
builder.WriteString(fmt.Sprintf(" Firmware: %s\n", report.GetFirmwareVersion()))
}
// Format region
if report.GetRegion() != 0 {
builder.WriteString(fmt.Sprintf(" Region: %s\n", report.GetRegion()))
}
// Format modem preset
if report.GetModemPreset() != 0 {
builder.WriteString(fmt.Sprintf(" Modem Preset: %s\n", report.GetModemPreset()))
}
if report.GetHasDefaultChannel() {
builder.WriteString(" Uses Default Channel: Yes\n")
}
// Format location data
if report.GetLatitudeI() != 0 && report.GetLongitudeI() != 0 {
lat := float64(report.GetLatitudeI()) / 10000000.0
lon := float64(report.GetLongitudeI()) / 10000000.0
builder.WriteString(fmt.Sprintf(" Latitude: %.7f\n", lat))
builder.WriteString(fmt.Sprintf(" Longitude: %.7f\n", lon))
// Google Maps link for convenience
builder.WriteString(fmt.Sprintf(" Google Maps: https://maps.google.com/?q=%.7f,%.7f\n", lat, lon))
}
if report.GetAltitude() != 0 {
builder.WriteString(fmt.Sprintf(" Altitude: %d meters\n", report.GetAltitude()))
}
if report.GetPositionPrecision() != 0 {
builder.WriteString(fmt.Sprintf(" Position Precision: %d bits\n", report.GetPositionPrecision()))
}
if report.GetNumOnlineLocalNodes() != 0 {
builder.WriteString(fmt.Sprintf(" Connected Nodes: %d\n", report.GetNumOnlineLocalNodes()))
}
// Marshal to JSON for detailed view
jsonBytes, err := protojson.MarshalOptions{Multiline: true, Indent: " "}.Marshal(report)
if err == nil {
builder.WriteString("\nFull MapReport Structure:\n")
builder.WriteString(string(jsonBytes))
}
return builder.String()
}
// FormatTopicAndMapData formats topic information and map data as text
// FormatTopicAndMapData formats topic information and map data
func FormatTopicAndMapData(topicInfo *TopicInfo, payload []byte) string {
var builder strings.Builder
@@ -861,12 +938,19 @@ func FormatTopicAndMapData(topicInfo *TopicInfo, payload []byte) string {
}
builder.WriteString("\n")
// Display map data as text
builder.WriteString("Map Data:\n")
if IsASCII(payload) {
builder.WriteString(fmt.Sprintf(" Text Content: %s\n", string(payload)))
// Try to decode and format as a MapReport
mapReport, err := DecodeMapReport(payload)
if err != nil {
// Fall back to displaying raw data
builder.WriteString(fmt.Sprintf("Failed to decode as MapReport: %v\n", err))
if IsASCII(payload) {
builder.WriteString(fmt.Sprintf("Raw Text Content: %s\n", string(payload)))
} else {
builder.WriteString(fmt.Sprintf("Raw Binary Data (%d bytes): %x\n", len(payload), payload))
}
} else {
builder.WriteString(fmt.Sprintf(" Data is not ASCII text, showing hex: %x\n", payload))
// Format the decoded MapReport
builder.WriteString(FormatMapReport(mapReport))
}
return builder.String()
@@ -875,7 +959,7 @@ func FormatTopicAndMapData(topicInfo *TopicInfo, payload []byte) string {
// FormatTopicAndRawData formats topic information and raw data for unsupported formats
func FormatTopicAndRawData(topicInfo *TopicInfo, payload []byte) string {
var builder strings.Builder
// Display topic information
builder.WriteString(fmt.Sprintf("Topic: %s\n", topicInfo.FullTopic))
builder.WriteString(fmt.Sprintf("Region Path: %s\n", topicInfo.RegionPath))
@@ -886,10 +970,10 @@ func FormatTopicAndRawData(topicInfo *TopicInfo, payload []byte) string {
builder.WriteString(fmt.Sprintf("User ID: %s\n", topicInfo.UserID))
}
builder.WriteString("\n")
// Display raw data
builder.WriteString(fmt.Sprintf("Unsupported format: %s\n", topicInfo.Format))
builder.WriteString(fmt.Sprintf("Raw Data (%d bytes): %x\n", len(payload), payload))
return builder.String()
}
}