New Radio API (#287)

* Adding radio API for receiving a packet

* More new radio API changes

* renaming some properties

* Redoing radio packet parsing and updating new callback api

libs/radio/radio.cpp

@@ -3,6 +3,26 @@
 using namespace pxt;
 
 #define MAX_FIELD_NAME_LENGTH 12
+#define MAX_PAYLOAD_LENGTH 20
+#define PACKET_PREFIX_LENGTH 9
+#define VALUE_PACKET_NAME_LEN_OFFSET 13
+
+
+// Packet Spec:
+// | 0              | 1 ... 4       | 5 ... 8           | 9 ... 28
+// ----------------------------------------------------------------
+// | packet type    | system time   | serial number     | payload
+//
+// Serial number defaults to 0 unless enabled by user
+
+// payload: number (9 ... 12)
+#define PACKET_TYPE_NUMBER 0
+
+// payload: number (9 ... 12), name length (13), name (14 ... 26)
+#define PACKET_TYPE_VALUE 1
+
+// payload: string length (9), string (10 ... 28)
+#define PACKET_TYPE_STRING 2
 
 //% color=270 weight=34
 namespace radio {
@@ -15,6 +35,12 @@ namespace radio {
 
     PacketBuffer packet;
 
+    uint8_t type;
+    uint32_t time;
+    uint32_t serial;
+    int value;
+    StringData* msg;
+
     int radioEnable() {
         int r = uBit.radio.enable();
         if (r != MICROBIT_OK) {
@@ -38,6 +64,105 @@ namespace radio {
         registerWithDal(MES_BROADCAST_GENERAL_ID, message, f);
     }
 
+    void setPacketPrefix(uint8_t* buf, int type) {
+        // prefix: type (0), time (1..4), serial (5..8)
+        uint32_t t = system_timer_current_time();
+        uint32_t sn = transmitSerialNumber ? microbit_serial_number() : 0;
+
+        buf[0] = (uint8_t) type;
+        memcpy(buf + 1, &t, 4);
+        memcpy(buf + 5, &sn, 4);
+    }
+
+    uint8_t copyStringValue(uint8_t* buf, StringData* data, uint8_t maxLength) {
+        ManagedString s(data);
+        uint8_t len = min(maxLength, s.length());
+
+        // One byte for length of the string
+        buf[0] = len;
+
+        if (len > 0) {
+            memcpy(buf + 1, s.toCharArray(), len);
+        }
+        return len + 1;
+    }
+
+    StringData* getStringValue(uint8_t* buf, uint8_t maxLength) {
+        // First byte is the string length
+        uint8_t len = min(maxLength, buf[0]);
+
+        if (len) {
+            char name[maxLength + 1];
+            memcpy(name, buf + 1, len);
+            name[len] = 0;
+            return ManagedString(name).leakData();
+        }
+        return ManagedString().leakData();
+    }
+
+    /**
+     * Takes a packet from the micro:bit radio queue.
+     * @param writeToSerial if true, write the received packet to serial without updating the global packet;
+                            if false, update the global packet instead
+     */
+    void receivePacket(bool writeToSerial) {
+        PacketBuffer p = uBit.radio.datagram.recv();
+
+        uint8_t* buf = p.getBytes();
+        uint8_t tp;
+        int t;
+        int s;
+        int v;
+        StringData* m;
+
+
+        memcpy(&tp, buf, 1);
+        memcpy(&t, buf + 1, 4);
+        memcpy(&s, buf + 5, 4);
+
+        if (tp == PACKET_TYPE_STRING) {
+            v = 0;
+            m = getStringValue(buf + PACKET_PREFIX_LENGTH, MAX_PAYLOAD_LENGTH - 1);
+        }
+        else {
+            memcpy(&v, buf + 9, 4);
+            if (tp == PACKET_TYPE_VALUE) {
+                m = getStringValue(buf + VALUE_PACKET_NAME_LEN_OFFSET, MAX_FIELD_NAME_LENGTH);
+            }
+            else {
+                m = ManagedString().leakData();
+            }
+        }
+
+        if (!writeToSerial) {
+            // Refresh global packet
+            packet = p;
+            type = tp;
+            time = t;
+            serial = s;
+            value = v;
+            msg = m;
+        }
+        else {
+            // Convert the packet to JSON and send over serial
+            uBit.serial.send("{");
+            uBit.serial.send("\"t\":");
+            uBit.serial.send(t);
+            uBit.serial.send(",\"s\":");
+            uBit.serial.send(s);
+            if (tp == PACKET_TYPE_STRING || tp == PACKET_TYPE_VALUE) {
+                uBit.serial.send(",\"n\":\"");
+                uBit.serial.send(m);
+                uBit.serial.send("\"");
+            }
+            if (tp == PACKET_TYPE_NUMBER || tp == PACKET_TYPE_VALUE) {
+                uBit.serial.send(",\"v\":");
+                uBit.serial.send(v);
+            }
+            uBit.serial.send("}\r\n");
+        }
+    }
+
     /**
      * Broadcasts a number over radio to any connected micro:bit in the group.
      */
@@ -46,10 +171,14 @@ namespace radio {
     //% blockId=radio_datagram_send block="radio send number %value" blockGap=8
     void sendNumber(int value) {
         if (radioEnable() != MICROBIT_OK) return;
-        uint32_t t = system_timer_current_time();
+        uint8_t length = PACKET_PREFIX_LENGTH + sizeof(uint32_t);
-        uint32_t sn = transmitSerialNumber ? microbit_serial_number() : 0;
+        uint8_t buf[length];
-        uint32_t buf[] = { (uint32_t)value, t, sn };
+        memset(buf, 0, length);
-        uBit.radio.datagram.send((uint8_t*)buf, 3*sizeof(uint32_t));
+
+        setPacketPrefix(buf, PACKET_TYPE_NUMBER);
+        memcpy(buf + PACKET_PREFIX_LENGTH, &value, 4);
+
+        uBit.radio.datagram.send(buf, length);
     }
 
     /**
@@ -65,24 +194,20 @@ namespace radio {
         if (radioEnable() != MICROBIT_OK) return;
 
         ManagedString n(name);
-        uint32_t t = system_timer_current_time();
-        uint32_t sn = transmitSerialNumber ? microbit_serial_number() : 0;
         uint8_t buf[32];
-        uint32_t* buf32 = (uint32_t*)buf;
         memset(buf, 0, 32);
-        buf32[0] = value;                      // 4 bytes: value
+
-        buf32[1] = t; // 4 bytes: running time
+        setPacketPrefix(buf, PACKET_TYPE_VALUE);
-        buf32[2] = sn; // 4 bytes: serial number
+        memcpy(buf + PACKET_PREFIX_LENGTH, &value, 4);
-        uint8_t len = min(MAX_FIELD_NAME_LENGTH, n.length());          // 1 byte: string length
+
-        if (len > 0) {
+        int stringLen = copyStringValue(buf + VALUE_PACKET_NAME_LEN_OFFSET, name, MAX_FIELD_NAME_LENGTH);
-            buf[12] = len;                          //
+
-            memcpy(buf + 13, n.toCharArray(), len); // 13-25: field name
+        uBit.radio.datagram.send(buf, VALUE_PACKET_NAME_LEN_OFFSET + stringLen);
-        }
-        uBit.radio.datagram.send(buf, 13 + len);
     }
 
     /**
-     * Broadcasts a number over radio to any connected micro:bit in the group.
+     * Broadcasts a string along with the device serial number
+     * and running time to any connected micro:bit in the group.
      */
     //% help=radio/send-string
     //% weight=58
@@ -90,16 +215,18 @@ namespace radio {
     void sendString(StringData* msg) {
         if (radioEnable() != MICROBIT_OK) return;
 
-        ManagedString s(msg);
+        uint8_t buf[32];
-        if (s.length() > MICROBIT_RADIO_MAX_PACKET_SIZE)
+        memset(buf, 0, 32);
-            s = s.substring(0, MICROBIT_RADIO_MAX_PACKET_SIZE);
 
-        uBit.radio.datagram.send(s);
+        setPacketPrefix(buf, PACKET_TYPE_STRING);
+        int stringLen = copyStringValue(buf + PACKET_PREFIX_LENGTH, msg, MAX_PAYLOAD_LENGTH - 1);
+
+        uBit.radio.datagram.send(buf, PACKET_PREFIX_LENGTH + stringLen);
     }
 
     /**
-    * Reads a value sent with `stream value` and writes it
+    * Reads the next packet from the radio queue and and writes it to serial
-    * to the serial stream as JSON
+    * as JSON.
     */
     //% help=radio/write-value-to-serial
     //% weight=3
@@ -107,63 +234,22 @@ namespace radio {
     //% advanced=true
     void writeValueToSerial() {
         if (radioEnable() != MICROBIT_OK) return;
-        PacketBuffer p = uBit.radio.datagram.recv();
+        receivePacket(true);
-        int length = p.length();
-        uint8_t* bytes = p.getBytes();
-        int value;
-
-        uBit.serial.send("{");
-        if (length >= 4) {
-            memcpy(&value, bytes, 4);
-            uBit.serial.send("\"v\":"); uBit.serial.send(value);
-            if(length >= 8) {
-                memcpy(&value, bytes + 4, 4);
-                uBit.serial.send(",\"t\":"); uBit.serial.send(value);
-                if (length >= 12) {
-                    memcpy(&value, bytes + 8, 4);
-                    uBit.serial.send(",\"s\":"); uBit.serial.send(value);
-                    if (length >= 13) {
-                        char name[MAX_FIELD_NAME_LENGTH+1];
-                        uint8_t len = min(MAX_FIELD_NAME_LENGTH, bytes[12]);
-                        memcpy(name, bytes + 13, len);
-                        name[len] = 0;
-                        uBit.serial.send(",\"n\":\""); uBit.serial.send(name); uBit.serial.send("\"");
-                    }
-                }
-            }
-        }
-        uBit.serial.send("}\r\n");
-    }
-
-
-    /**
-     * Reads a number at a given index, between ``0`` and ``3``, from the packet received by ``receive number``. Not supported in simulator.
-     * @param index index of the number to read from 0 to 3. 1 eg
-     */
-    //% help=radio/received-number-at
-    //% weight=45 debug=true
-    int receivedNumberAt(int index) {
-        if (radioEnable() != MICROBIT_OK) return 0;
-        if (0 <= index && index < packet.length() / 4) {
-            // packet.getBytes() is not aligned
-            int r;
-            memcpy(&r, packet.getBytes() + index * 4, 4);
-            return r;
-        }
-        return 0;
     }
 
     /**
-     * Reads the next packet as a number from the radio queue.
+     * Reads the next packet from the radio queue and returns the packet's number
+     * payload or 0 if the packet did not contain a number.
      */
     //% help=radio/receive-number
     //% weight=46
     //% blockId=radio_datagram_receive block="radio receive number" blockGap=8
+    //% advanced=true
     int receiveNumber()
     {
         if (radioEnable() != MICROBIT_OK) return 0;
-        packet = uBit.radio.datagram.recv();
+        receivePacket(false);
-        return receivedNumberAt(0);
+        return value;
     }
 
     /**
@@ -172,28 +258,32 @@ namespace radio {
     //% help=radio/on-data-received
     //% weight=50
     //% blockId=radio_datagram_received_event block="radio on data received" blockGap=8
+    //% advanced=true
     void onDataReceived(Action body) {
         if (radioEnable() != MICROBIT_OK) return;
         registerWithDal(MICROBIT_ID_RADIO, MICROBIT_RADIO_EVT_DATAGRAM, body);
-        // make the the receive buffer has a free spot
+        // make sure the receive buffer has a free spot
         receiveNumber();
     }
 
 
     /**
-    * Reads the next packet as a string and returns it.
+     * Reads the next packet from the radio queue and returns the packet's string
+     * payload or the empty string if the packet did not contain a string.
      */
     //% blockId=radio_datagram_receive_string block="radio receive string" blockGap=8
     //% weight=44
     //% help=radio/receive-string
+    //% advanced=true
     StringData* receiveString() {
         if (radioEnable() != MICROBIT_OK) return ManagedString().leakData();
-        packet = uBit.radio.datagram.recv();
+        receivePacket(false);
-        return ManagedString(packet).leakData();
+        return msg;
     }
 
     /**
-     * Gets the received signal strength indicator (RSSI) from the packet received by ``receive number``. Not supported in simulator.
+     * Gets the received signal strength indicator (RSSI) from the last packet taken
+     * from the radio queue (via ``receiveNumber``, ``receiveString``, etc). Not supported in simulator.
      * namespace=radio
      */
     //% help=radio/received-signal-strength
@@ -242,4 +332,48 @@ namespace radio {
         if (radioEnable() != MICROBIT_OK) return;
         transmitSerialNumber = transmit;
     }
+
+    /**
+     * Returns the number payload from the last packet taken from the radio queue
+     * (via ``receiveNumber``, ``receiveString``, etc) or 0 if that packet did not
+     * contain a number.
+     */
+    //% help=radio/received-number
+    int receivedNumber() {
+        if (radioEnable() != MICROBIT_OK) return 0;
+        return value;
+    }
+
+    /**
+     * Returns the serial number of the sender micro:bit from the last packet taken
+     * from the radio queue (via ``receiveNumber``, ``receiveString``, etc) or 0 if
+     * that packet did not send a serial number.
+     */
+    //% help=radio/received-serial
+    uint32_t receivedSerial() {
+        if (radioEnable() != MICROBIT_OK) return 0;
+        return serial;
+    }
+
+    /**
+     * Returns the string payload from the last packet taken from the radio queue
+     * (via ``receiveNumber``, ``receiveString``, etc) or the empty string if that
+     * packet did not contain a string.
+     */
+    //% help=radio/received-string
+    StringData* receivedString() {
+        if (radioEnable() != MICROBIT_OK) return ManagedString().leakData();
+        return msg;
+    }
+
+    /**
+     * Returns the system time of the sender micro:bit at the moment when it sent the
+     * last packet taken from the radio queue (via ``receiveNumber``,
+     * ``receiveString``, etc).
+     */
+    //% help=radio/received-time
+    uint32_t receivedTime() {
+        if (radioEnable() != MICROBIT_OK) return 0;
+        return time;
+    }
 }

libs/radio/radio.ts

@@ -3,4 +3,49 @@
  */
 //% color=#E3008C weight=34
 namespace radio {
+    export class Packet {
+        /**
+         * The number payload if a number was sent in this packet (via ``sendNumber()`` or ``sendValue()``)
+         * or 0 if this packet did not contain a number.
+         */
+        public receivedNumber: number;
+        /**
+         * The string payload if a string was sent in this packet (via ``sendString()`` or ``sendValue()``)
+         * or the empty string if this packet did not contain a string.
+         */
+        public text: string;
+        /**
+         * The system time of the sender of the packet at the time the packet was sent.
+         */
+        public time: number;
+        /**
+         * The serial number of the sender of the packet or 0 if the sender did not sent their serial number.
+         */
+        public serial: number;
+        /**
+         * The received signal strength indicator (RSSI) of the packet.
+         */
+        public signal: number;
+    }
+
+    /**
+     * Registers code to run when the radio receives a packet. Also takes the
+     * received packet from the radio queue.
+     */
+    //% mutate=true
+    //% mutateText=Packet
+    //% mutateDefaults="receivedNumber;text,receivedNumber;text"
+    //% blockId=radio_on_packet block="on radio received" blockGap=8
+    export function onDataPacketReceived(cb: (packet: Packet) => void) {
+        onDataReceived(() => {
+            receiveNumber();
+            const packet = new Packet();
+            packet.receivedNumber = receivedNumber();
+            packet.time = receivedTime();
+            packet.serial = receivedSerial();
+            packet.text = receivedString();
+            packet.signal = receivedSignalStrength();
+            cb(packet)
+        });
+    }
 }

libs/radio/shims.d.ts

@@ -25,7 +25,8 @@ declare namespace radio {
     function sendValue(name: string, value: number): void;
 
     /**
-     * Broadcasts a number over radio to any connected micro:bit in the group.
+     * Broadcasts a string along with the device serial number
+     * and running time to any connected micro:bit in the group.
      */
     //% help=radio/send-string
     //% weight=58
@@ -33,8 +34,8 @@ declare namespace radio {
     function sendString(msg: string): void;
 
     /**
-     * Reads a value sent with `stream value` and writes it
+     * Reads the next packet from the radio queue and and writes it to serial
-     * to the serial stream as JSON
+     * as JSON.
      */
     //% help=radio/write-value-to-serial
     //% weight=3
@@ -43,19 +44,13 @@ declare namespace radio {
     function writeValueToSerial(): void;
 
     /**
-     * Reads a number at a given index, between ``0`` and ``3``, from the packet received by ``receive number``. Not supported in simulator.
+     * Reads the next packet from the radio queue and returns the packet's number
-     * @param index index of the number to read from 0 to 3. 1 eg
+     * payload or 0 if the packet did not contain a number.
-     */
-    //% help=radio/received-number-at
-    //% weight=45 debug=true shim=radio::receivedNumberAt
-    function receivedNumberAt(index: number): number;
-
-    /**
-     * Reads the next packet as a number from the radio queue.
      */
     //% help=radio/receive-number
     //% weight=46
-    //% blockId=radio_datagram_receive block="radio receive number" blockGap=8 shim=radio::receiveNumber
+    //% blockId=radio_datagram_receive block="radio receive number" blockGap=8
+    //% advanced=true shim=radio::receiveNumber
     function receiveNumber(): number;
 
     /**
@@ -63,19 +58,23 @@ declare namespace radio {
      */
     //% help=radio/on-data-received
     //% weight=50
-    //% blockId=radio_datagram_received_event block="radio on data received" blockGap=8 shim=radio::onDataReceived
+    //% blockId=radio_datagram_received_event block="radio on data received" blockGap=8
+    //% advanced=true shim=radio::onDataReceived
     function onDataReceived(body: () => void): void;
 
     /**
-     * Reads the next packet as a string and returns it.
+     * Reads the next packet from the radio queue and returns the packet's string
+     * payload or the empty string if the packet did not contain a string.
      */
     //% blockId=radio_datagram_receive_string block="radio receive string" blockGap=8
     //% weight=44
-    //% help=radio/receive-string shim=radio::receiveString
+    //% help=radio/receive-string
+    //% advanced=true shim=radio::receiveString
     function receiveString(): string;
 
     /**
-     * Gets the received signal strength indicator (RSSI) from the packet received by ``receive number``. Not supported in simulator.
+     * Gets the received signal strength indicator (RSSI) from the last packet taken
+     * from the radio queue (via ``receiveNumber``, ``receiveString``, etc). Not supported in simulator.
      * namespace=radio
      */
     //% help=radio/received-signal-strength
@@ -112,6 +111,38 @@ declare namespace radio {
     //% blockId=radio_set_transmit_serial_number block="radio set transmit serial number %transmit"
     //% advanced=true shim=radio::setTransmitSerialNumber
     function setTransmitSerialNumber(transmit: boolean): void;
+
+    /**
+     * Returns the number payload from the last packet taken from the radio queue
+     * (via ``receiveNumber``, ``receiveString``, etc) or 0 if that packet did not
+     * contain a number.
+     */
+    //% help=radio/received-number shim=radio::receivedNumber
+    function receivedNumber(): number;
+
+    /**
+     * Returns the serial number of the sender micro:bit from the last packet taken
+     * from the radio queue (via ``receiveNumber``, ``receiveString``, etc) or 0 if
+     * that packet did not send a serial number.
+     */
+    //% help=radio/received-serial shim=radio::receivedSerial
+    function receivedSerial(): number;
+
+    /**
+     * Returns the string payload from the last packet taken from the radio queue
+     * (via ``receiveNumber``, ``receiveString``, etc) or the empty string if that
+     * packet did not contain a string.
+     */
+    //% help=radio/received-string shim=radio::receivedString
+    function receivedString(): string;
+
+    /**
+     * Returns the system time of the sender micro:bit at the moment when it sent the
+     * last packet taken from the radio queue (via ``receiveNumber``,
+     * ``receiveString``, etc).
+     */
+    //% help=radio/received-time shim=radio::receivedTime
+    function receivedTime(): number;
 }
 
 // Auto-generated. Do not edit. Really.

sim/state/radio.ts

@@ -1,15 +1,14 @@
 namespace pxsim {
     export interface PacketBuffer {
-        data: number[] | string;
+        payload: SimulatorRadioPacketPayload;
-        rssi?: number;
+        rssi: number;
+        serial: number;
+        time: number;
     }
 
     export class RadioDatagram {
         datagram: PacketBuffer[] = [];
-        lastReceived: PacketBuffer = {
+        lastReceived: PacketBuffer = RadioDatagram.defaultPacket();
-            data: [0, 0, 0, 0],
-            rssi: -1
-        };
 
         constructor(private runtime: Runtime) {
         }
@@ -21,35 +20,43 @@ namespace pxsim {
             (<DalBoard>runtime.board).bus.queue(DAL.MICROBIT_ID_RADIO, DAL.MICROBIT_RADIO_EVT_DATAGRAM);
         }
 
-        send(buffer: number[] | string) {
+        send(payload: SimulatorRadioPacketPayload) {
-            if (buffer instanceof String) buffer = buffer.slice(0, 32);
-            else buffer = buffer.slice(0, 8);
-
             Runtime.postMessage(<SimulatorRadioPacketMessage>{
                 type: "radiopacket",
-                data: buffer
+                rssi: 0, // Not yet supported
+                serial: board().radioState.bus.transmitSerialNumber ? board().radioState.bus.serial : 0,
+                time: 0, // Not yet supported
+                payload
             })
         }
 
         recv(): PacketBuffer {
             let r = this.datagram.shift();
-            if (!r) r = {
+            if (!r) r = RadioDatagram.defaultPacket();
-                data: [0, 0, 0, 0],
-                rssi: -1
-            };
             return this.lastReceived = r;
         }
+
+        private static defaultPacket(): PacketBuffer {
+            return {
+                rssi: -1,
+                serial: 0,
+                time: 0,
+                payload: { type: -1 }
+            };
+        }
     }
 
     export class RadioBus {
         // uint8_t radioDefaultGroup = MICROBIT_RADIO_DEFAULT_GROUP;
         groupId = 0; // todo
         power = 0;
+        serial = 0;
         transmitSerialNumber = false;
         datagram: RadioDatagram;
 
         constructor(private runtime: Runtime) {
             this.datagram = new RadioDatagram(runtime);
+            this.serial = Math.floor(Math.random() * Math.pow(2, 32)) - Math.pow(2, 31); // 32 bit signed integer
         }
 
         setGroup(id: number) {
@@ -83,12 +90,18 @@ namespace pxsim {
         }
 
         public recievePacket(packet: SimulatorRadioPacketMessage) {
-            this.bus.datagram.queue({ data: packet.data, rssi: packet.rssi || 0 })
+            this.bus.datagram.queue(packet)
         }
     }
 }
 
 namespace pxsim.radio {
+    enum PacketPayloadType {
+        NUMBER = 0,
+        VALUE = 1,
+        STRING = 2
+    }
+
     export function broadcastMessage(msg: number): void {
         board().radioState.bus.broadcast(msg);
     }
@@ -110,41 +123,57 @@ namespace pxsim.radio {
     }
 
     export function sendNumber(value: number): void {
-        board().radioState.bus.datagram.send([value]);
+        board().radioState.bus.datagram.send({
+            type: PacketPayloadType.NUMBER,
+            numberData: value
+        });
     }
 
     export function sendString(msg: string): void {
-        board().radioState.bus.datagram.send(msg);
+        msg = msg.substr(0, 19);
+        board().radioState.bus.datagram.send({
+            type: PacketPayloadType.STRING,
+            stringData: msg
+        });
     }
 
     export function writeValueToSerial(): void {
         let b = board();
-        let v = b.radioState.bus.datagram.recv().data[0];
+        let p = b.radioState.bus.datagram.recv();
-        b.writeSerial(`{v:${v}}`);
+
+        switch(p.payload.type) {
+            case PacketPayloadType.NUMBER:
+                b.writeSerial(`{"t":${p.time},"s":${p.serial},"v":${p.payload.numberData}}`)
+                break;
+            case PacketPayloadType.VALUE:
+                b.writeSerial(`{"t":${p.time},"s":${p.serial},"n":"${p.payload.stringData}","v":${p.payload.numberData}}`)
+                break;
+            case PacketPayloadType.STRING:
+                b.writeSerial(`{"t":${p.time},"s":${p.serial},"n":"${p.payload.stringData}"}`)
+                break;
+            default:
+        }
     }
 
     export function sendValue(name: string, value: number) {
-        board().radioState.bus.datagram.send([value]);
+        name = name.substr(0, 12);
+        const msg: number[] = [];
+        msg.push()
+        board().radioState.bus.datagram.send({
+            type: PacketPayloadType.VALUE,
+            stringData: name,
+            numberData: value
+        });
     }
 
     export function receiveNumber(): number {
-        let buffer = board().radioState.bus.datagram.recv().data;
+        const packet = board().radioState.bus.datagram.recv();
-        if (buffer instanceof Array) return buffer[0];
+        return receivedNumber();
-
-        return 0;
     }
 
     export function receiveString(): string {
-        let buffer = board().radioState.bus.datagram.recv().data;
+        const packet = board().radioState.bus.datagram.recv();
-        if (typeof buffer === "string") return <string>buffer;
+        return receivedString();
-        return "";
-    }
-
-    export function receivedNumberAt(index: number): number {
-        let buffer = board().radioState.bus.datagram.recv().data;
-        if (buffer instanceof Array) return buffer[index] || 0;
-
-        return 0;
     }
 
     export function receivedSignalStrength(): number {
@@ -155,4 +184,20 @@ namespace pxsim.radio {
         pxtcore.registerWithDal(DAL.MICROBIT_ID_RADIO, DAL.MICROBIT_RADIO_EVT_DATAGRAM, handler);
         radio.receiveNumber();
     }
+
+    export function receivedNumber(): number {
+        return board().radioState.bus.datagram.lastReceived.payload.numberData || 0;
+    }
+
+    export function receivedSerial(): number {
+        return board().radioState.bus.datagram.lastReceived.serial;
+    }
+
+    export function receivedString(): string {
+        return board().radioState.bus.datagram.lastReceived.payload.stringData || "";
+    }
+
+    export function receivedTime(): number {
+        return board().radioState.bus.datagram.lastReceived.time;
+    }
 }