add index.ts

Author: Alex Yang

.DS_Store

@@ -0,0 +1,2 @@
+node_modules
+dist

.gitignore

@@ -2,9 +2,11 @@
   "name": "mock-echo",
   "version": "0.0.1",
   "description": "Mock laravel Echo",
-  "main": "index.js",
+  "main": "dist/index.js",
   "scripts": {
-    "test": "echo \"Error: no test specified\" && exit 1"
+    "build": "tsc",
+    "dev": "tsc -w",
+    "prepublish": "npm run build"
   },
   "repository": {
     "type": "git",
@@ -20,5 +22,13 @@
   "bugs": {
     "url": "https://github.com/alexxiyang/mock-echo/issues"
   },
+  "dependencies": {
+    "lodash": "^4.17.10"
+  },
+  "devDependencies": {
+    "@types/lodash": "^4.14.93",
+    "@types/node": "^6.0.60",
+    "typescript": "^2.6.0"
+  },
   "homepage": "https://github.com/alexxiyang/mock-echo#readme"
 }

package-lock.json

@@ -0,0 +1,216 @@
+import _ from 'lodash'
+
+class Channel {
+    events: object
+    clientEvents: Array<string>
+    constructor () {
+        this.events = {}
+    }
+    listen (eventName: string, fn: any) {
+        this.events[eventName] = fn;
+        return this
+    }
+    broadcast (eventName, event) {
+        if (typeof this.events[eventName] === 'undefined') {
+            console.error(`Channel didn't listen to event: ${eventName}`);
+            return
+        }
+        this.events[eventName](event);
+    }
+    eventExist (eventName) {
+        return typeof this.events[eventName] !== 'undefined'
+    }
+
+    clientEventExist (eventName) {
+        return typeof this.clientEvents[`client-${eventName}`] !== 'undefined'
+    }
+}
+
+class PrivateChannel extends Channel {
+    clientEvents: Array<string>
+    notificationFn: any
+    constructor () {
+        super()
+        this.clientEvents = []
+        this.notificationFn = null
+    }
+
+    userWhisper (eventName, event) {
+        if (typeof this.clientEvents[`client-${eventName}`] === 'undefined') {
+            console.error(`Channel didn't listen to client event: ${eventName}`)
+            return
+        }
+        this.clientEvents[`client-${eventName}`](event)
+    }
+
+    listenForWhisper (eventName, whisperFn) {
+        this.clientEvents[`client-${eventName}`] = whisperFn
+        return this
+    }
+
+    notification (notificationFn) {
+        this.notificationFn = notificationFn
+        return this
+    }
+
+    notify (notifiable) {
+        this.notificationFn(notifiable)
+    }
+}
+
+class PresenceChannel extends PrivateChannel {
+    users: Array<any>
+    hereFn: any
+    joiningFn: any
+    leavingFn: any
+
+    constructor () {
+        super()
+        this.users = []
+        this.hereFn = null
+        this.joiningFn = null
+        this.leavingFn = null
+    }
+
+    iJoin (user: any) {
+        if (user == null) {
+            console.error('user is null!')
+            return
+        }
+
+        user.subId = Math.floor(Math.random() * 1000)
+        this.users.push(user)
+
+        let broadcastUsers = this.getBroadcastUsers()
+        this.hereFn(broadcastUsers)
+    }
+    userJoin (user) {
+        if (user == null) {
+            console.error('user is null!')
+            return
+        }
+        
+        let subId = Math.floor(Math.random() * 1000)
+        user.subId = subId
+        this.users.push(user)
+
+        let broadcastUser = this.getBroadcastUser(user)
+        this.joiningFn(broadcastUser)
+
+        return subId;
+    }
+    userLeave (subId) {
+        if (subId == null) {
+            console.error('subId is null!')
+            return
+        }
+
+        let leavingUser = this.findUserBySubId(subId)
+        if (leavingUser == null) {
+            console.error(`Cannot find user by subId ${subId} !`)
+            return
+        }
+        let broadcastUser = this.getBroadcastUser(leavingUser)
+        this.leavingFn(broadcastUser)
+    }
+    findUserBySubId (subId) {
+        let targetUser = null
+        for(let i = this.users.length -1; i >= 0 ; i--){
+            let user = this.users[i]
+            if (user.subId === subId) {
+                targetUser = user
+                this.users.splice(i, 1)
+            }
+        }
+        return targetUser
+    }
+    getBroadcastUser (user) {
+        let broadcastUser = _.cloneDeep(user)
+        delete broadcastUser['subId']
+        return broadcastUser
+    }
+    getBroadcastUsers () {
+        let broadcastUsers = []
+        for (let i = 0; i < this.users.length; i++) {
+            broadcastUsers.push(this.getBroadcastUser(this.users[i]))
+        }
+        return broadcastUsers
+    }
+    here (fn) {
+        this.hereFn = fn
+        return this
+    }
+    joining (fn) {
+        this.joiningFn = fn
+        return this
+    }
+    leaving (fn) {
+        this.leavingFn = fn
+        return this
+    }
+
+    notification (notificationFn) {
+        console.error(`Presence channel doesn't support notification`)
+        return this
+    }
+}
+
+class MockEcho {
+    channels: object
+    constructor () {
+        this.channels = {};
+    }
+    private(channelName) {
+        return this.listenChannelByFullName(`private-${channelName}`);
+    }
+    channel(channelName) {
+        return this.listenChannelByFullName(channelName);
+    }
+    join(channelName) {
+        let presenceChannel = this.listenChannelByFullName(`presence-${channelName}`)
+        return presenceChannel
+    }
+
+    listenChannelByFullName(fullName) {
+        if (typeof this.channels[fullName] === 'undefined') {
+            if (fullName.startsWith('presence-')) {
+                this.channels[fullName] = new PresenceChannel()
+            } else if (fullName.startsWith('private-')) {
+                this.channels[fullName] = new PrivateChannel()
+            } else {
+                this.channels[fullName] = new Channel()
+            }
+        }
+        return this.channels[fullName]
+    }
+    getPrivateChannel(channelName) {
+        return this.getChannelByFullName(`private-${channelName}`);
+    }
+    getChannel(channelName) {
+        return this.getChannelByFullName(channelName);
+    }
+    getPresenceChannel (channelName) {
+        return this.getChannelByFullName(`presence-${channelName}`);
+    }
+    getChannelByFullName(fullName) {
+        if (typeof this.channels[fullName] === 'undefined') {
+            console.error(`Echo doesn't have channel: ${fullName}`);
+            return
+        }
+        return this.channels[fullName];
+    }
+    channelExistByFullName (fullName) {
+        return typeof this.channels[fullName] !== 'undefined';
+    }
+    privateChannelExist (channelName) {
+        return this.channelExistByFullName(`private-${channelName}`)
+    }
+    channelExist (channelName) {
+        return this.channelExistByFullName(channelName)
+    }
+    presenceChannelExist (channelName) {
+        return this.channelExistByFullName(`presence-${channelName}`)
+    }
+}
+
+export default MockEcho;

package.json

@@ -0,0 +1,31 @@
+{
+    "compilerOptions": {
+      "allowSyntheticDefaultImports": true,
+      "module": "commonjs",
+      "moduleResolution": "node",
+      "noImplicitAny": false,
+      "outDir": "./dist",
+      "pretty": true,
+      "preserveConstEnums": true,
+      "removeComments": true,
+      "target": "es5",
+      "lib": ["es2015", "dom"],
+      "types": ["node"]
+    },
+    "files": [
+      "src/index.ts"
+    ],
+    "exclude": [
+      "node_modules"
+    ],
+    "compileOnSave": false,
+    "buildOnSave": false,
+    "atom": {
+      "formatOnSave": false,
+      "rewriteTsconfig": false
+    },
+    "typeRoots": [
+      "../node_modules/@types"
+    ]
+  }
+