Merge pull request #2 from hiroqn/update-dependencies

Update dependencies

.gitignore

@@ -1,6 +1,5 @@
 node_modules
 build
-typings
 lib
 src/**/*.js
 example

package.json

@@ -10,15 +10,17 @@
     "url": "https://github.com/hiroqn/cyclebot/issues"
   },
   "dependencies": {
-    "ms": "^0.7.3",
-    "ramda": "^0.22.1",
-    "rxjs": "^5.0.2",
-    "ws": "^1.1.1"
+    "ms": "^2.0.0",
+    "ramda": "^0.25.0",
+    "rxjs": "^5.4.3",
+    "ws": "^3.2.0"
   },
   "devDependencies": {
-    "@types/ramda": "ts2.1",
-    "typescript": "^2.1.4",
-    "typings": "^2.0.0"
+    "@types/ms": "^0.7.30",
+    "@types/node": "^8.0.44",
+    "@types/ramda": "^0.24.17",
+    "@types/ws": "^3.2.0",
+    "typescript": "^2.5.2"
   },
   "files": [
     "src",

src/event-source.ts

@@ -3,14 +3,17 @@ import {Status, PartialStatus} from './state/status';
 import {empty} from 'rxjs/observable/empty';
 import {of} from 'rxjs/observable/of';
 import {IncomingMessage} from './state/message';
-import {Channel} from './state/channel';
-import {InstantMessage} from './state/ims';
+import {Channel, isChannel} from './state/channel';
+import {InstantMessage, isInstantMessage} from './state/ims';
 import {findOne} from './util/map'
 type O<T> = Observable<T>;
+type BothPS = PartialStatus<IncomingMessage<Channel> | IncomingMessage<InstantMessage>>;
+type ChanPS = PartialStatus<IncomingMessage<Channel>>;
+type IMPS = PartialStatus<IncomingMessage<InstantMessage>>;
 
 export class EventSource {
 
-    private _message$: O<PartialStatus<IncomingMessage<Channel> | IncomingMessage<InstantMessage>>>;
+    private _message$: O<BothPS>;
 
     constructor(_status$: Observable<Status>) {
         const [, message$] = _status$.partition(status => typeof status.event === 'string');
@@ -19,7 +22,7 @@ export class EventSource {
     }
 
     selectByChannelName(name: string): Observable<IncomingMessage<Channel>> {
-        return this._message$.mergeMap(({event, channels}) => {
+        return this._message$.filter<BothPS, ChanPS>((ps: BothPS): ps is ChanPS => isChannel(ps.event.channel)).mergeMap(({event, channels}) => {
             const channel = findOne(channel => name === channel.name, channels);
             if (channel && !event.user.is_bot) {
                 return of(event);
@@ -30,7 +33,7 @@ export class EventSource {
     }
 
     selectByUserName(name: string): Observable<IncomingMessage<InstantMessage>> {
-        return this._message$.mergeMap(({users, event, ims}) => {
+        return this._message$.filter<BothPS, IMPS>((ps: BothPS): ps is IMPS => isInstantMessage(ps.event.channel)).mergeMap(({users, event, ims}) => {
             const user = findOne(user => name === user.name, users);
             if (!user) {
                 return empty();

src/make-slack-bot-driver.ts

@@ -1,4 +1,4 @@
-import * as ms from 'ms';
+import ms = require('ms');
 import * as WebSocket from 'ws';
 import {contains} from 'ramda';
 /**
@@ -78,7 +78,7 @@ export function makeSlackBotDriver(token: string, options?: makeBotDriverOptions
             const pong$: O<Timestamp<{}>> = fromEvent(socket, 'pong')
                 .timestamp();
 
-            const pingOutput$ = ping$.mapTo(() => socket.ping(null, {}, true));
+            const pingOutput$ = ping$.mapTo(() => socket.ping(null, true, true));
             const pongOutput$ = fromEvent(socket, 'ping').mapTo(() => socket.pong());
             const terminateOutput$ = ping$.withLatestFrom(pong$, (ping, pong) => ping.timestamp - pong.timestamp)
                 .filter(diff => diff > pingInterval * (pingRetryLimit - 0.5))

src/state/channel.ts

@@ -1,4 +1,4 @@
-import {where, is, pick, assoc} from 'ramda';
+import {pick, assoc} from 'ramda';
 
 export type Channel = {
     id: string;
@@ -9,14 +9,16 @@ export type Channel = {
     creator: string;
 }
 
-export const isChannel = where({
-    id: is(String),
-    name: is(String),
-    is_member: is(Boolean),
-    is_archived: is(Boolean),
-    created: is(Number),
-    creator: is(String)
-});
+export function isChannel(x: any): x is Channel {
+    return typeof x === 'object' &&
+        x !== null &&
+        typeof x.id === 'string' &&
+        typeof x.name === 'string' &&
+        typeof x.is_member === 'boolean' &&
+        typeof x.is_archived === 'boolean' &&
+        typeof x.created === 'number' &&
+        typeof x.creator === 'string';
+};
 
 const channelKeyList: Array<keyof Channel> = [
     'id',

src/state/ims.ts

@@ -1,4 +1,4 @@
-import {where, is, pick} from 'ramda';
+import {pick} from 'ramda';
 
 export type InstantMessage = {
     id: string;
@@ -7,12 +7,14 @@ export type InstantMessage = {
     created: number;
 }
 
-export const isInstantMessage = where({
-    id: is(String),
-    user: is(String),
-    is_open: is(Boolean),
-    created: is(Number)
-});
+export function isInstantMessage(x: any): x is InstantMessage {
+    return typeof x === 'object' &&
+        x !== null &&
+        typeof x.id === 'string' &&
+        typeof x.user === 'string' &&
+        typeof x.is_open === 'boolean' &&
+        typeof x.created === 'number';
+};
 
 const imKeyList: Array<keyof InstantMessage> = [
     'id',

src/state/status.ts

@@ -53,7 +53,7 @@ export function updateChannel(key: string, project: (x: Channel) => Channel): Ac
 }
 
 export function deleteChannel(key: string): Action {
-    return curryDel(key);
+    return over(lensProp('channels'), curryDel(key));
 }
 
 export function updateUser(key: string, project: (x: User) => User): Action {

tsconfig.json

@@ -17,7 +17,6 @@
     "sourceMap": true
   },
   "include": [
-    "src/**/*.ts",
-    "typings/index.d.ts"
+    "src/**/*.ts"
   ]
 }