updates

Author: triniwiz

Procfile

@@ -0,0 +1 @@
+web: npm run start:server-demo

apps/server-demo/src/main.ts

@@ -23,13 +23,11 @@ app.post('/pusher/auth', function (req, res) {
   const auth = pusher.authenticate(socketId, channel, presenceData);
   res.send(auth);
 });
-const port = process.env.PORT || 5000;
+let port = Number(process.env.PORT || 5000);
 app.listen(port);
 
-
-
-
-const io = require("socket.io")(3000, {
+port++;
+const io = require("socket.io")(port, {
   path: "/",
   serveClient: true,
   pingInterval: 10000,
@@ -56,8 +54,8 @@ io.on('connection', function (socket) {
     addedUser = true;
     socket.username = data.username;
     console.log('Username: ', data.username);
-    userList.push({ username: data.username });
-    socket.emit('login', { userList: userList });
+    userList.push({username: data.username});
+    socket.emit('login', {userList: userList});
     socket.broadcast.emit('user joined', {
       username: data.username
     });
@@ -86,7 +84,7 @@ io.on('connection', function (socket) {
     console.log('User Disconnected')
     if (addedUser) {
       for (let i = 0; i < userList.length; i++) {
-        if (socket.username === userList[ i ].username) {
+        if (socket.username === userList[i].username) {
           userList.splice(i, 1)
         }
       }
@@ -113,3 +111,197 @@ nspChat.on('connect', (socket) => {
   })
 })
 
+
+/* WebRTC 1O1 */
+
+port++;
+const wio = require("socket.io")(port, {
+  path: "/",
+  serveClient: true,
+  pingInterval: 10000,
+  pingTimeout: 5000,
+  cookie: false
+});
+
+const wMessageList = []
+let userMap = new Map();
+const lobby = 'lobby';
+
+function getOtherUser(id) {
+  const keys = Array.from(userMap.keys());
+  const filtered = keys.filter((value) => {
+    if (value.indexOf(id) === -1) {
+      return value;
+    }
+  });
+  return userMap.get(filtered[0]);
+}
+
+wio.on('connection', function (socket) {
+  socket.on('disconnect', function () {
+    userMap.delete(socket.id);
+  });
+  userMap.set(socket.id, "");
+  console.log('User Connected: -> ' + socket.id);
+  socket.emit('connected', 'Welcome');
+
+  socket.on('init', function (data) {
+    socket.join(data.id);
+    userMap.set(socket.id, data.id);
+  });
+
+  socket.on('call', function (data) {
+    console.log('call from', data.from);
+    const otherId = getOtherUser(socket.id);
+    io.in(otherId).emit('call:incoming', {
+      from: data.from,
+      to: otherId,
+      sdp: data.sdp
+    });
+  });
+
+  socket.on('iceCandidate', function (data) {
+    console.log('call:iceCandidate', data.from);
+    const otherId = getOtherUser(socket.id);
+    io.in(otherId).emit('call:iceCandidate', Object.assign({}, data, {
+      to: otherId
+    }));
+  });
+
+  socket.on('answer', function (data) {
+    console.log('call:answer', data.from);
+    const otherId = getOtherUser(socket.id);
+    io.in(otherId).emit('call:answer', {
+      from: data.from,
+      sdp: data.sdp,
+      to: otherId
+    });
+  });
+
+  socket.on('answered', function (data) {
+    console.log('call:answered', data.from);
+    const otherId = getOtherUser(socket.id);
+    io.in(otherId).emit('call:answered', {
+      from: data.from,
+      sdp: data.sdp,
+      to: otherId
+    });
+  })
+
+});
+
+
+port++;
+const wio1 = require("socket.io")(port, {
+  path: "/",
+  serveClient: true,
+  pingInterval: 10000,
+  pingTimeout: 5000,
+  cookie: false
+});
+
+const wio1NspChat = wio1.of('/chat')
+const wio1NspDefault = wio1.of('/')
+
+let wio1MessageList = []
+let wio1UserList = []
+
+wio1.on('connection', function (socket) {
+  console.log('User Connected');
+  socket.emit('connected', 'Welcome');
+  let addedUser = false;
+
+  socket.on('add user', function (data) {
+    if (addedUser) return;
+    addedUser = true;
+    socket.username = data.username;
+    console.log('Username: ', data.username);
+    wio1UserList.push({
+      username: data.username
+    });
+
+    socket.emit('login', {
+      userList: wio1UserList
+    });
+
+    socket.broadcast.emit('user joined', {
+      username: data.username
+    });
+
+    socket.join(data.username);
+  });
+
+  socket.on('call', function (data) {
+    console.log('call from', data.from);
+    console.log('call to', data.to);
+    io.sockets.in(data.to).emit('call:incoming', data);
+  });
+
+
+  socket.on('iceCandidate', function (data) {
+    io.sockets.in(data.to).emit('call:iceCandidate', data);
+  });
+
+  socket.on('answer', function (data) {
+    console.log('answer from', data.from);
+    console.log('answer to', data.to);
+    io.sockets.in(data.to).emit('call:answer', data);
+  });
+
+  socket.on('answered', function (data) {
+    console.log('answer from', data.from);
+    console.log('answer to', data.to);
+    io.sockets.in(data.to).emit('call:answered', data);
+  })
+
+  socket.on('new message', function (data, cb) {
+    cb(true);
+    console.log(data);
+    wio1MessageList.push(data);
+    socket.broadcast.emit('new message', data);
+  })
+
+  socket.on('getUsers', function () {
+    socket.emit('getUsers', wio1UserList);
+  })
+  socket.on('user count', function () {
+    socket.emit('user count', wio1UserList.length)
+  })
+  socket.on('getMessages', function () {
+    socket.emit('getMessages', wio1MessageList)
+  })
+
+  socket.on('disconnect', function () {
+    console.log('User Disconnected');
+    if (addedUser) {
+      for (let i = 0; i < wio1UserList.length; i++) {
+        if (socket.username === wio1UserList[i].username) {
+          wio1UserList.splice(i, 1);
+        }
+      }
+      socket.broadcast.emit('user left', {
+        username: socket.username
+      });
+
+      socket.emit('getUsers', wio1UserList);
+    }
+  })
+})
+
+wio1NspDefault.on('connect', (socket) => {
+  console.log('Joined Namespace: /')
+  socket.on('disconnect', () => {
+    console.log('Left Namespace: /')
+  })
+})
+
+wio1NspChat.on('connect', (socket) => {
+  console.log('Joined Namespace: /chat')
+
+  socket.on('disconnect', () => {
+    console.log('Left Namespace: /chat')
+  })
+})
+
+
+

package.json

@@ -10,10 +10,12 @@
     "config": "nx g @nativescript/plugin-tools:config",
     "publish-packages": "nx g @nativescript/plugin-tools:publish",
     "docs:build": "cd docs && vuepress build src",
-    "docs:dev": "cd docs && vuepress dev src"
+    "docs:dev": "cd docs && vuepress dev src",
+    "start:server-demo": "node dist/apps/server-demo/main"
   },
   "private": true,
   "dependencies": {
+    "@types/node": "^15.3.0",
     "body-parser": "^1.19.0",
     "cors": "^2.8.5",
     "date-fns": "^2.21.3",
@@ -66,5 +68,8 @@
     "**/*": [
       "nx format:write --files"
     ]
+  },
+  "engines" : {
+    "node" : "14.x"
   }
 }

packages/nativescript-couchbase/platforms/android/couchbase-release.aar

@@ -1,5 +1,4 @@
 <manifest xmlns:android="http://schemas.android.com/apk/res/android"
     package="com.github.triniwiz.couchbase">
-
-    /
-</manifest>
+  <uses-sdk android:minSdkVersion="22"/>
+</manifest>

packages/nativescript-couchbase/src-native/TNSCouchbase/.idea/compiler.xml

@@ -6,7 +6,7 @@ repositories {
 
 dependencies {
   def kotlin_version = "1.4.21"
-  implementation 'com.squareup.okhttp3:okhttp:3.10.0'
+  implementation 'com.squareup.okhttp3:okhttp:3.14.9'
   implementation 'com.github.bumptech.glide:okhttp3-integration:4.11.0'
   implementation 'jp.wasabeef:glide-transformations:4.1.0'
   implementation 'jp.co.cyberagent.android:gpuimage:2.0.3'

packages/nativescript-couchbase/src-native/TNSCouchbase/.idea/misc.xml

@@ -1,4 +1,4 @@
-import {Property, View} from "@nativescript/core";
+import {ImageAsset, ImageSource, Property, View} from "@nativescript/core";
 import {Stretch} from "@nativescript/core/ui/image";
 
 export class ImageZoomBase extends View {