Increases speed for filtering unique members.

package.json

@@ -27,13 +27,11 @@
     "express": "^4.17.1",
     "inquirer": "^7.1.0",
     "ioredis": "^4.16.0",
-    "lodash": "^4.17.15",
     "request": "^2.88.2",
     "socket.io": "^2.3.0",
     "yargs": "^15.3.1"
   },
   "devDependencies": {
-    "@types/lodash": "^4.14.149",
     "@types/node": "^13.9.1",
     "typescript": "^3.8.3"
   },

src/api/http-api.ts

@@ -1,6 +1,5 @@
 import { Log } from './../log';
 let url = require('url');
-import * as _ from 'lodash';
 
 export class HttpApi {
     /**
@@ -129,8 +128,10 @@ export class HttpApi {
         };
 
         if (this.channel.isPresence(channelName)) {
-            this.channel.presence.getMembers(channelName).then(members => {
-                result['user_count'] = _.uniqBy(members, 'user_id').length;
+            this.channel.presence.getMembers(channelName).then((members: any[]) => {
+                result['user_count'] = members.reduce(
+                    (map, member) => map.set(member.user_id, member), new Map()
+                ).size;
 
                 res.json(result);
             });
@@ -158,11 +159,12 @@ export class HttpApi {
         }
 
         this.channel.presence.getMembers(channelName).then(members => {
-            let users = [];
-
-            _.uniqBy(members, 'user_id').forEach((member: any) => {
-                users.push({ id: member.user_id, user_info: member.user_info });
-            });
+            let users = [
+                ...members.reduce((map, member) => map.set(member.user_id, {
+                    id: member.user_id,
+                    user_info: member.user_info
+                }), new Map())
+            ]
 
             res.json({ users: users });
         }, error => Log.error(error));

src/channels/presence-channel.ts

@@ -1,6 +1,5 @@
 import { Database } from './../database';
 import { Log } from './../log';
-var _ = require("lodash");
 
 export class PresenceChannel {
     /**
@@ -94,7 +93,11 @@ export class PresenceChannel {
 
                         this.db.set(channel + ":members", members);
 
-                        members = _.uniqBy(members.reverse(), "user_id");
+                        members = [
+                            ...members.reduce(
+                                (map, member) => map.set(member.user_id, member), new Map()
+                            ).values()
+                        ]
 
                         this.onSubscribed(socket, channel, members);