From 72e95438ebbaeb9acf5fc51763b4b5dd03548a3a Mon Sep 17 00:00:00 2001
From: Tom Ball <tballmsft@users.noreply.github.com>
Date: Tue, 16 May 2017 16:19:52 -0700
Subject: [PATCH] add support for radio groups (#399)

* add groupID to radio

* add groupId

* bump up to new version
---
 package.json       |  2 +-
 sim/dalboard.ts    |  2 +-
 sim/state/radio.ts | 37 +++++++++++++++++++++++--------------
 3 files changed, 25 insertions(+), 16 deletions(-)

diff --git a/package.json b/package.json
index 5e621160..2f398734 100644
--- a/package.json
+++ b/package.json
@@ -38,6 +38,6 @@
     "semantic-ui-less": "^2.2.4"
   },
   "dependencies": {
-    "pxt-core": "0.12.71"
+    "pxt-core": "0.12.72"
   }
 }
diff --git a/sim/dalboard.ts b/sim/dalboard.ts
index 32de0146..5f15f20e 100644
--- a/sim/dalboard.ts
+++ b/sim/dalboard.ts
@@ -97,7 +97,7 @@ namespace pxsim {
                     break;
                 case "radiopacket":
                     let packet = <SimulatorRadioPacketMessage>msg;
-                    this.radioState.recievePacket(packet);
+                    this.radioState.receivePacket(packet);
                     break;
             }
         }
diff --git a/sim/state/radio.ts b/sim/state/radio.ts
index 00501f16..1d928f6e 100644
--- a/sim/state/radio.ts
+++ b/sim/state/radio.ts
@@ -41,14 +41,13 @@ namespace pxsim {
                 rssi: -1,
                 serial: 0,
                 time: 0,
-                payload: { type: -1 }
+                payload: { type: -1, groupId: 0 }
             };
         }
     }
 
     export class RadioBus {
         // uint8_t radioDefaultGroup = MICROBIT_RADIO_DEFAULT_GROUP;
-        groupId = 0; // todo
         power = 0;
         serial = 0;
         transmitSerialNumber = false;
@@ -59,10 +58,6 @@ namespace pxsim {
             this.serial = Math.floor(Math.random() * Math.pow(2, 32)) - Math.pow(2, 31); // 32 bit signed integer
         }
 
-        setGroup(id: number) {
-            this.groupId = id & 0xff; // byte only
-        }
-
         setTransmitPower(power: number) {
             this.power = Math.max(0, Math.min(7, power));
         }
@@ -71,26 +66,37 @@ namespace pxsim {
             this.transmitSerialNumber = !!sn;
         }
 
-        broadcast(msg: number) {
+        broadcast(msg: number, groupId: number) {
             Runtime.postMessage(<SimulatorEventBusMessage>{
                 type: "eventbus",
                 id: DAL.MES_BROADCAST_GENERAL_ID,
                 eventid: msg,
                 power: this.power,
-                group: this.groupId
+                group: groupId
             })
         }
     }
 
     export class RadioState {
         bus: RadioBus;
+        groupId: number;
 
         constructor(runtime: Runtime) {
             this.bus = new RadioBus(runtime);
+            this.groupId = 0;
         }
 
-        public recievePacket(packet: SimulatorRadioPacketMessage) {
-            this.bus.datagram.queue(packet)
+        public setGroup(id: number) {
+            this.groupId = id & 0xff; // byte only
+        }
+
+        public broadcast(msg: number) {
+            this.bus.broadcast(msg, this.groupId)
+        }
+
+        public receivePacket(packet: SimulatorRadioPacketMessage) {
+            if (this.groupId == packet.payload.groupId)
+                this.bus.datagram.queue(packet)
         }
     }
 }
@@ -103,7 +109,7 @@ namespace pxsim.radio {
     }
 
     export function broadcastMessage(msg: number): void {
-        board().radioState.bus.broadcast(msg);
+        board().radioState.broadcast(msg);
     }
 
     export function onBroadcastMessageReceived(msg: number, handler: RefAction): void {
@@ -111,7 +117,7 @@ namespace pxsim.radio {
     }
 
     export function setGroup(id: number): void {
-        board().radioState.bus.setGroup(id);
+        board().radioState.setGroup(id);
     }
 
     export function setTransmitPower(power: number): void {
@@ -125,7 +131,8 @@ namespace pxsim.radio {
     export function sendNumber(value: number): void {
         board().radioState.bus.datagram.send({
             type: PacketPayloadType.NUMBER,
-            numberData: value
+            groupId: board().radioState.groupId,
+            numberData: value,
         });
     }
 
@@ -133,7 +140,8 @@ namespace pxsim.radio {
         msg = msg.substr(0, 19);
         board().radioState.bus.datagram.send({
             type: PacketPayloadType.STRING,
-            stringData: msg
+            groupId: board().radioState.groupId,
+            stringData: msg,
         });
     }
 
@@ -153,6 +161,7 @@ namespace pxsim.radio {
         msg.push()
         board().radioState.bus.datagram.send({
             type: PacketPayloadType.VALUE,
+            groupId: board().radioState.groupId,
             stringData: name,
             numberData: value
         });