Implement UplinkMsgWifi + wifi stream record workaround.

Author: brocaar

internal/integration/loracloud/client/das/structs.go

@@ -49,6 +49,13 @@ type UplinkMsgGNSS struct {
 	GNSSUse2DSolver         bool             `json:"gnss_use_2D_solver,omitempty"`
 }
 
+// UplinkMsgWifi implements the LoRa Cloud UplinkMsg object containing a wifi payload.
+type UplinkMsgWifi struct {
+	MsgType   string           `json:"msgtype"` // Must be set to "wifi"
+	Payload   helpers.HEXBytes `json:"payload"`
+	Timestamp float64          `json:"timestamp"` // Seconds since UTC
+}
+
 // UplinkMsgJoining implements the LoRa Cloud UplinkMsg object indicating a session reset.
 type UplinkMsgJoining struct {
 	MsgType   string  `json:"msgtype"`   // Must be set to "joining"

internal/integration/loracloud/loracloud.go

@@ -659,8 +659,8 @@ func (i *Integration) streamGeolocWorkaround(ctx context.Context, vars map[strin
 			continue
 		}
 
-		// gnss with pcb || gnss with patch antenna
 		if p[0] == 0x06 || p[0] == 0x07 {
+			// gnss with pcb || gnss with patch antenna
 			msg := das.UplinkMsgGNSS{
 				MsgType:   "gnss",
 				Payload:   helpers.HEXBytes(p[2:]),
@@ -684,6 +684,26 @@ func (i *Integration) streamGeolocWorkaround(ctx context.Context, vars map[strin
 				return errors.Wrap(err, "das error")
 			}
 
+			err = i.handleDASResponse(ctx, vars, devEUI, resp, ii, pl)
+			if err != nil {
+				return errors.Wrap(err, "handle das response error")
+			}
+		} else if p[0] == 0x08 {
+			// wifi
+			msg := das.UplinkMsgWifi{
+				MsgType:   "wifi",
+				Payload:   helpers.HEXBytes(p[2:]),
+				Timestamp: float64(helpers.GetTimestamp(pl.RxInfo).UnixNano()) / float64(time.Second),
+			}
+
+			client := das.New(i.dasURI, i.config.DASToken)
+			resp, err := client.UplinkSend(ctx, das.UplinkRequest{
+				helpers.EUI64(devEUI): msg,
+			})
+			if err != nil {
+				return errors.Wrap(err, "das error")
+			}
+
 			err = i.handleDASResponse(ctx, vars, devEUI, resp, ii, pl)
 			if err != nil {
 				return errors.Wrap(err, "handle das response error")