From d6fd86a1d7d8b5464275e89a27dded21386995a9 Mon Sep 17 00:00:00 2001
From: Martti Malmi <sirius@iki.fi>
Date: Tue, 8 Jan 2019 14:47:01 +0200
Subject: [PATCH] chrome multicast stub

---
 lib/multicast.js | 76 ++++++++++++++++++++++++++++++++++++------------
 package.json     |  4 +++
 2 files changed, 62 insertions(+), 18 deletions(-)

diff --git a/lib/multicast.js b/lib/multicast.js
index 4f1c7773..d2754ac9 100644
--- a/lib/multicast.js
+++ b/lib/multicast.js
@@ -1,29 +1,33 @@
-var Gun = (typeof window !== "undefined")? window.Gun : require('../gun');
+var Gun = (typeof window !== 'undefined')? window.Gun : require('../gun');
+
+var MULTICAST_ADDR = '233.255.255.255';
+var MULTICAST_INTERVAL = 1000;
+var PORT = 20000;
+var DEFAULT_GUN_PORT = 8765;
+var ENC = 'utf8';
 
 Gun.on('create', function(root){
 	this.to.next(root);
-	var opt = root.opt;
-	if(typeof window !== "undefined"){
-		return; // do nothing for now - Chrome extensions could use multicast though
-	}
+	var opt = root.opt, u;
 	if(false === opt.multicast){ return }
 	opt.multicast = opt.multicast || {};
+	if(typeof window === 'undefined'){
+		nodeMulticast(root, opt);
+	} else if (chrome && chrome.sockets && chrome.sockets.udp) {
+		chromeMulticast(root, opt);
+	}
+});
 
-  var MULTICAST_ADDR = "233.255.255.255";
-	var MULTICAST_INTERVAL = 1000;
-  var PORT = 20000;
-	var DEFAULT_GUN_PORT = 8765;
-  var ENC = 'utf8';
+function nodeMulticast(root, opt) {
+	var dgram = require('dgram');
+  var process = require('process');
 
-  var dgram = require("dgram");
-  var process = require("process");
-
-  socket = dgram.createSocket({ type: "udp4", reuseAddr: true });
+  socket = dgram.createSocket({ type: 'udp4', reuseAddr: true });
 
   socket.bind(PORT);
 
   var address;
-  socket.on("listening", function() {
+  socket.on('listening', function() {
     socket.addMembership(MULTICAST_ADDR);
 		if (opt.multicast && opt.multicast.port) { // if port is specified, advertise our node
 			console.log(`Advertising this node (port ${opt.multicast.port}) on multicast (${MULTICAST_ADDR})`);
@@ -41,11 +45,11 @@ Gun.on('create', function(root){
     };
     var message = Buffer.from(JSON.stringify(msgObj), ENC);
     socket.send(message, 0, message.length, PORT, MULTICAST_ADDR, function() {
-      // console.info(`Sending message "${message}"`);
+      // console.info(`Sending message '${message}'`);
     });
   }
 
-  socket.on("message", function(message, rinfo) {
+  socket.on('message', function(message, rinfo) {
     try {
       var msgObj = JSON.parse(message.toString(ENC));
       if (!(msgObj.gun && msgObj.gun.port)) { return }
@@ -58,4 +62,40 @@ Gun.on('create', function(root){
       // console.error(`Received multicast from ${rinfo.address}:${rinfo.port} but failed to connect:`, e);
     }
   });
-});
+}
+
+function chromeMulticast(root, opt) {
+	chrome.sockets.udp.create({bufferSize: 1024 * 1024}, function (createInfo) {
+    var socketId = createInfo.socketId;
+    var ttl = 12;
+    chrome.sockets.udp.setMulticastTimeToLive(socketId, ttl, function (result) {
+      if (result != 0) {
+        console.error('Set TTL Error: ', 'Unknown error');
+      }
+      chrome.sockets.udp.bind(socketId, '0.0.0.0', PORT, function (result) {
+        if (result != 0) {
+          chrome.sockets.udp.close(socketId, function () {
+            console.error('Error on bind(): ', result);
+          });
+        } else {
+          chrome.sockets.udp.joinGroup(socketId, MULTICAST_ADDR, function (result) {
+            if (result != 0) {
+              chrome.sockets.udp.close(socketId, function () {
+                console.error('Error on joinGroup(): ', result);
+              });
+            } else {
+              me.socketId = socketId;
+              chrome.sockets.udp.onReceive.addListener(info => {
+								console.log('msg received', info);
+							});
+              chrome.sockets.udp.onReceiveError.addListener(info => {
+								console.error('receive error');
+							});
+              console.log('Chrome multicast socket listening');
+            }
+          });
+        }
+      });
+    });
+  });
+}
diff --git a/package.json b/package.json
index d851b46e..d3d4aff4 100644
--- a/package.json
+++ b/package.json
@@ -1,6 +1,10 @@
 {
   "name": "gun",
+<<<<<<< HEAD
   "version": "0.9.999997",
+=======
+  "version": "0.9.101",
+>>>>>>> chrome multicast stub
   "description": "A realtime, decentralized, offline-first, graph data synchronization engine.",
   "main": "index.js",
   "browser": "gun.min.js",