aboutsummaryrefslogtreecommitdiff
path: root/transport
diff options
context:
space:
mode:
Diffstat (limited to 'transport')
-rw-r--r--transport/serial/serial.go73
1 files changed, 0 insertions, 73 deletions
diff --git a/transport/serial/serial.go b/transport/serial/serial.go
index 618c16d..e3412c5 100644
--- a/transport/serial/serial.go
+++ b/transport/serial/serial.go
@@ -192,79 +192,6 @@ func (c *Conn) decodeProtos(printDebug bool, ch chan *meshtastic.FromRadio) {
log.Fatal(err)
}
ch <- &msg2
- continue
-
- // i think everthing below was just crap for initial debugging and testing. will cleanup (TODO)
- //fmt.Println("proto message parsed")
-
- switch msg2.PayloadVariant.(type) {
- case *meshtastic.FromRadio_Packet:
- //log.Debug("packet recvd")
- pkt := msg2.GetPacket()
- payload := pkt.GetPayloadVariant()
- switch payload.(type) {
- case *meshtastic.MeshPacket_Decoded:
- //log.Info("got decoded packet")
- data := pkt.GetDecoded()
- switch data.Portnum {
- case meshtastic.PortNum_TEXT_MESSAGE_APP:
- go func() {
- txtCh <- pkt
- }()
- //fmt.Println("payload:", string(data.Payload))
- //fmt.Println("to:", pkt.To)
- case meshtastic.PortNum_ADMIN_APP:
- var adminMsg meshtastic.AdminMessage
- err := proto.Unmarshal(data.Payload, &adminMsg)
- if err != nil {
- log.Fatal(err)
- }
- // log.Println("admin msg", adminMsg)
- switch adminMsg.GetPayloadVariant().(type) {
- case *meshtastic.AdminMessage_GetDeviceMetadataResponse:
- //log.Info("metadata:", adminMsg.GetGetDeviceMetadataResponse())
- }
- }
- //log.Info("data", "packet", data)
- case *meshtastic.MeshPacket_Encrypted:
- log.Info("got encrypted packet")
- }
- //log.Info("got packet", pkt)
- case *meshtastic.FromRadio_Metadata:
- log.Info("got metadata", msg2.GetMetadata())
-
- case *meshtastic.FromRadio_ConfigCompleteId:
- log.Info("config complete", msg2.GetConfigCompleteId())
- case *meshtastic.FromRadio_MyInfo: //*generated.deleteme.FromRadio_MyInfo:
- //log.WithField("my_node", msg.GetMyInfo()).Debug("got my node info")
- //fmt.Println(msg2.GetMyInfo().MyNodeNum)
- /*
- case *message.FromRadio_Radio:
- log.WithField("radio", msg.GetRadio()).Debug("got radio config")
- m.radioConfig = msg.GetRadio()
- case *message.FromRadio_NodeInfo:
- log.WithField("node", msg.GetNodeInfo()).Debug("got node info")
- m.pub(TOPIC_NODE, msg.GetNodeInfo())
- case *message.FromRadio_ConfigCompleteId:
- // TODO: implement this
- log.WithField("node", msg.GetConfigCompleteId()).Debug("got config complete")
-
- */
- case *meshtastic.FromRadio_MqttClientProxyMessage:
- mqttMessage := msg2.GetMqttClientProxyMessage()
-
- switch payload := mqttMessage.GetPayloadVariant().(type) {
- case *meshtastic.MqttClientProxyMessage_Data:
- //payload.Data
- fmt.Println("got data payload")
- case *meshtastic.MqttClientProxyMessage_Text:
- fmt.Println("payload text", payload.Text)
- }
- log.Info("got mqtt client proxy")
-
- default:
- //log.Info("fromRadio", msg2.GetPayloadVariant())
- }
}
}
func readUntilProtobuf(reader io.Reader, printDebug bool) ([]byte, error) {