emitter for private messages.

Author: syslogic

.gitignore

@@ -53,3 +53,4 @@ lint/tmp/
 /server/.idea/php.xml
 /server/.idea/modules.xml
 /server/.idea/misc.xml
+/server/.idea/jsLibraryMappings.xml

mobile/src/main/java/io/syslogic/socketio/fragment/ChatFragment.java

@@ -40,12 +40,6 @@ public class ChatFragment extends BaseFragment {
     private final Handler mTypingHandler = new Handler(Looper.getMainLooper());
     private boolean mTyping = false;
 
-    @Override
-    public void onAttach(@NonNull Context context) {
-        super.onAttach(context);
-        mAdapter = new ChatAdapter(this.mItems);
-    }
-
     @Override
     public void onCreate(Bundle savedInstanceState) {
         super.onCreate(savedInstanceState);
@@ -56,11 +50,12 @@ public void onCreate(Bundle savedInstanceState) {
                 mSocket.on(Socket.EVENT_CONNECT, this.onConnect);
                 mSocket.on(Socket.EVENT_DISCONNECT, this.onDisconnect);
                 mSocket.on(Socket.EVENT_CONNECT_ERROR, this.onConnectError);
-                mSocket.on("new message", onNewMessage);
-                mSocket.on("user joined", onUserJoined);
-                mSocket.on("user left", onUserLeft);
-                mSocket.on("typing", onTyping);
-                mSocket.on("stop typing", onStopTyping);
+                mSocket.on("new message", this.onNewMessage);
+                mSocket.on("private message", this.onPrivateMessage);
+                mSocket.on("user joined", this.onUserJoined);
+                mSocket.on("user left", this.onUserLeft);
+                mSocket.on("typing", this.onTyping);
+                mSocket.on("stop typing", this.onStopTyping);
                 if (!mSocket.connected()) {mSocket.connect();}
             }
         }
@@ -71,17 +66,24 @@ public void onDestroy() {
         mSocket.off(Socket.EVENT_CONNECT, this.onConnect);
         mSocket.off(Socket.EVENT_DISCONNECT, this.onDisconnect);
         mSocket.off(Socket.EVENT_CONNECT_ERROR, this.onConnectError);
-        mSocket.off("new message", onNewMessage);
-        mSocket.off("user joined", onUserJoined);
-        mSocket.off("user left", onUserLeft);
-        mSocket.off("typing", onTyping);
-        mSocket.off("stop typing", onStopTyping);
+        mSocket.off("new message", this.onNewMessage);
+        mSocket.off("private message", this.onPrivateMessage);
+        mSocket.off("user joined", this.onUserJoined);
+        mSocket.off("user left", this.onUserLeft);
+        mSocket.off("typing", this.onTyping);
+        mSocket.off("stop typing", this.onStopTyping);
 
         if (requireActivity() instanceof MainActivity activity) {
             leaveRoom(activity);
         }
         super.onDestroy();
     }
+    
+    @Override
+    public void onAttach(@NonNull Context context) {
+        super.onAttach(context);
+        this.mAdapter = new ChatAdapter(context, this.mItems);
+    }
 
     @Override
     public View onCreateView(@NonNull LayoutInflater inflater, ViewGroup parent, Bundle savedInstanceState) {
@@ -231,6 +233,10 @@ private void scrollToBottom() {
         addMessage(username, message);
     });
 
+    private final Emitter.Listener onPrivateMessage = args -> requireActivity().runOnUiThread(() -> {
+
+    });
+
     private final Emitter.Listener onUserJoined = args -> requireActivity().runOnUiThread(() -> {
         JSONObject data = (JSONObject) args[0];
         String username;

mobile/src/main/java/io/syslogic/socketio/recyclerview/ChatAdapter.java

@@ -1,5 +1,6 @@
 package io.syslogic.socketio.recyclerview;
 
+import android.content.Context;
 import android.view.LayoutInflater;
 import android.view.ViewGroup;
 
@@ -17,7 +18,7 @@
 public class ChatAdapter extends RecyclerView.Adapter<ChatAdapter.ViewHolder> {
     private final ArrayList<ChatMessage> mItems;
 
-    public ChatAdapter(@NonNull ArrayList<ChatMessage> items) {
+    public ChatAdapter(Context context, @NonNull ArrayList<ChatMessage> items) {
         mItems = items;
     }
 

server/index.js

@@ -1,35 +1,30 @@
-var path = require('path');
-var express = require('express');
-var port = process.env.PORT || 3000;
+const path = require('path');
+const express = require('express');
+const port = process.env.PORT || 3000;
 
-var app = express();
+const app = express();
 app.use(express.static(path.join(__dirname, 'public')));
-var server = require('http').createServer(app);
-
-// Close the server if listening doesn't fail
-// server.once('listening', function() {
-    // console.log('Closing port %d...', port);
-    // server.close();
-// });
+const server = require('http').createServer(app);
+const io = require('socket.io') (server, {
+    transports: ['polling', 'websocket'],
+    path: '/socket.io'
+});
 
 server.listen(port, () => {
     console.log('Listening at port %d', port);
 });
 
-var io = require('socket.io')(server,  {
-    transports: ['polling', 'websocket'],
-    path: '/socket.io'
-});
-
 // Chatroom
-var numUsers = 0;
+let numUsers = 0;
 
+// On connection ...
 io.on('connection', (socket) => {
 
-    var addedUser = false;
-
+    console.log('new client has connected from %s', socket.address);
     socket.join('default');
 
+    let addedUser = false;
+
     // when the client emits 'new message', this listens and executes
     socket.on('new message', (data) => {
         console.log('user %s wrote: %s', socket.username, data);
@@ -39,6 +34,10 @@ io.on('connection', (socket) => {
         });
     });
 
+    socket.on("private message", (anotherSocketId, message) => {
+        socket.to(anotherSocketId).emit("private message", socket.id, message);
+    });
+
     // when the client emits 'add user', this listens and executes
     socket.on('add user', (username) => {