npm run format

src/core/auth/auth_transports.ts

@@ -7,7 +7,7 @@ interface AuthTransport {
     query: string,
     authOptions: InternalAuthOptions,
     authRequestType: AuthRequestType,
-    callback: Function
+    callback: Function,
   ): void;
 }
 

src/core/auth/channel_authorizer.ts

@@ -3,14 +3,14 @@ import {
   InternalAuthOptions,
   ChannelAuthorizationHandler,
   ChannelAuthorizationRequestParams,
-  ChannelAuthorizationCallback
+  ChannelAuthorizationCallback,
 } from './options';
 
 import Runtime from 'runtime';
 
 const composeChannelQuery = (
   params: ChannelAuthorizationRequestParams,
-  authOptions: InternalAuthOptions
+  authOptions: InternalAuthOptions,
 ) => {
   var query = 'socket_id=' + encodeURIComponent(params.socketId);
 
@@ -39,15 +39,15 @@ const composeChannelQuery = (
 };
 
 const ChannelAuthorizer = (
-  authOptions: InternalAuthOptions
+  authOptions: InternalAuthOptions,
 ): ChannelAuthorizationHandler => {
   if (typeof Runtime.getAuthorizers()[authOptions.transport] === 'undefined') {
     throw `'${authOptions.transport}' is not a recognized auth transport`;
   }
 
   return (
     params: ChannelAuthorizationRequestParams,
-    callback: ChannelAuthorizationCallback
+    callback: ChannelAuthorizationCallback,
   ) => {
     const query = composeChannelQuery(params, authOptions);
 
@@ -56,7 +56,7 @@ const ChannelAuthorizer = (
       query,
       authOptions,
       AuthRequestType.ChannelAuthorization,
-      callback
+      callback,
     );
   };
 };

src/core/auth/deprecated_channel_authorizer.ts

@@ -3,7 +3,7 @@ import {
   ChannelAuthorizationCallback,
   ChannelAuthorizationHandler,
   ChannelAuthorizationRequestParams,
-  InternalAuthOptions
+  InternalAuthOptions,
 } from './options';
 
 export interface DeprecatedChannelAuthorizer {
@@ -13,7 +13,7 @@ export interface DeprecatedChannelAuthorizer {
 export interface ChannelAuthorizerGenerator {
   (
     channel: Channel,
-    options: DeprecatedAuthorizerOptions
+    options: DeprecatedAuthorizerOptions,
   ): DeprecatedChannelAuthorizer;
 }
 
@@ -31,28 +31,26 @@ export interface DeprecatedAuthorizerOptions {
 export const ChannelAuthorizerProxy = (
   pusher,
   authOptions: InternalAuthOptions,
-  channelAuthorizerGenerator: ChannelAuthorizerGenerator
+  channelAuthorizerGenerator: ChannelAuthorizerGenerator,
 ): ChannelAuthorizationHandler => {
   const deprecatedAuthorizerOptions: DeprecatedAuthorizerOptions = {
     authTransport: authOptions.transport,
     authEndpoint: authOptions.endpoint,
     auth: {
       params: authOptions.params,
-      headers: authOptions.headers
-    }
+      headers: authOptions.headers,
+    },
   };
   return (
     params: ChannelAuthorizationRequestParams,
-    callback: ChannelAuthorizationCallback
+    callback: ChannelAuthorizationCallback,
   ) => {
     const channel = pusher.channel(params.channelName);
     // This line creates a new channel authorizer every time.
     // In the past, this was only done once per channel and reused.
     // We can do that again if we want to keep this behavior intact.
-    const channelAuthorizer: DeprecatedChannelAuthorizer = channelAuthorizerGenerator(
-      channel,
-      deprecatedAuthorizerOptions
-    );
+    const channelAuthorizer: DeprecatedChannelAuthorizer =
+      channelAuthorizerGenerator(channel, deprecatedAuthorizerOptions);
     channelAuthorizer.authorize(params.socketId, callback);
   };
 };

src/core/auth/options.ts

@@ -1,6 +1,6 @@
 export enum AuthRequestType {
   UserAuthentication = 'user-authentication',
-  ChannelAuthorization = 'channel-authorization'
+  ChannelAuthorization = 'channel-authorization',
 }
 
 export interface ChannelAuthorizationData {
@@ -11,7 +11,7 @@ export interface ChannelAuthorizationData {
 
 export type ChannelAuthorizationCallback = (
   error: Error | null,
-  authData: ChannelAuthorizationData | null
+  authData: ChannelAuthorizationData | null,
 ) => void;
 
 export interface ChannelAuthorizationRequestParams {
@@ -22,7 +22,7 @@ export interface ChannelAuthorizationRequestParams {
 export interface ChannelAuthorizationHandler {
   (
     params: ChannelAuthorizationRequestParams,
-    callback: ChannelAuthorizationCallback
+    callback: ChannelAuthorizationCallback,
   ): void;
 }
 
@@ -33,7 +33,7 @@ export interface UserAuthenticationData {
 
 export type UserAuthenticationCallback = (
   error: Error | null,
-  authData: UserAuthenticationData | null
+  authData: UserAuthenticationData | null,
 ) => void;
 
 export interface UserAuthenticationRequestParams {
@@ -43,7 +43,7 @@ export interface UserAuthenticationRequestParams {
 export interface UserAuthenticationHandler {
   (
     params: UserAuthenticationRequestParams,
-    callback: UserAuthenticationCallback
+    callback: UserAuthenticationCallback,
   ): void;
 }
 
@@ -61,12 +61,10 @@ export interface AuthOptionsT<AuthHandler> {
   customHandler?: AuthHandler;
 }
 
-export declare type UserAuthenticationOptions = AuthOptionsT<
-  UserAuthenticationHandler
->;
-export declare type ChannelAuthorizationOptions = AuthOptionsT<
-  ChannelAuthorizationHandler
->;
+export declare type UserAuthenticationOptions =
+  AuthOptionsT<UserAuthenticationHandler>;
+export declare type ChannelAuthorizationOptions =
+  AuthOptionsT<ChannelAuthorizationHandler>;
 
 export interface InternalAuthOptions {
   transport: 'ajax' | 'jsonp';

src/core/auth/user_authenticator.ts

@@ -3,14 +3,14 @@ import {
   InternalAuthOptions,
   UserAuthenticationHandler,
   UserAuthenticationRequestParams,
-  AuthRequestType
+  AuthRequestType,
 } from './options';
 
 import Runtime from 'runtime';
 
 const composeChannelQuery = (
   params: UserAuthenticationRequestParams,
-  authOptions: InternalAuthOptions
+  authOptions: InternalAuthOptions,
 ) => {
   var query = 'socket_id=' + encodeURIComponent(params.socketId);
 
@@ -37,15 +37,15 @@ const composeChannelQuery = (
 };
 
 const UserAuthenticator = (
-  authOptions: InternalAuthOptions
+  authOptions: InternalAuthOptions,
 ): UserAuthenticationHandler => {
   if (typeof Runtime.getAuthorizers()[authOptions.transport] === 'undefined') {
     throw `'${authOptions.transport}' is not a recognized auth transport`;
   }
 
   return (
     params: UserAuthenticationRequestParams,
-    callback: UserAuthenticationCallback
+    callback: UserAuthenticationCallback,
   ) => {
     const query = composeChannelQuery(params, authOptions);
 
@@ -54,7 +54,7 @@ const UserAuthenticator = (
       query,
       authOptions,
       AuthRequestType.UserAuthentication,
-      callback
+      callback,
     );
   };
 };

src/core/base64.ts

@@ -12,22 +12,22 @@ for (var i = 0, l = b64chars.length; i < l; i++) {
   b64tab[b64chars.charAt(i)] = i;
 }
 
-var cb_utob = function(c) {
+var cb_utob = function (c) {
   var cc = c.charCodeAt(0);
   return cc < 0x80
     ? c
     : cc < 0x800
-    ? fromCharCode(0xc0 | (cc >>> 6)) + fromCharCode(0x80 | (cc & 0x3f))
-    : fromCharCode(0xe0 | ((cc >>> 12) & 0x0f)) +
-      fromCharCode(0x80 | ((cc >>> 6) & 0x3f)) +
-      fromCharCode(0x80 | (cc & 0x3f));
+      ? fromCharCode(0xc0 | (cc >>> 6)) + fromCharCode(0x80 | (cc & 0x3f))
+      : fromCharCode(0xe0 | ((cc >>> 12) & 0x0f)) +
+        fromCharCode(0x80 | ((cc >>> 6) & 0x3f)) +
+        fromCharCode(0x80 | (cc & 0x3f));
 };
 
-var utob = function(u) {
+var utob = function (u) {
   return u.replace(/[^\x00-\x7F]/g, cb_utob);
 };
 
-var cb_encode = function(ccc) {
+var cb_encode = function (ccc) {
   var padlen = [0, 2, 1][ccc.length % 3];
   var ord =
     (ccc.charCodeAt(0) << 16) |
@@ -37,13 +37,13 @@ var cb_encode = function(ccc) {
     b64chars.charAt(ord >>> 18),
     b64chars.charAt((ord >>> 12) & 63),
     padlen >= 2 ? '=' : b64chars.charAt((ord >>> 6) & 63),
-    padlen >= 1 ? '=' : b64chars.charAt(ord & 63)
+    padlen >= 1 ? '=' : b64chars.charAt(ord & 63),
   ];
   return chars.join('');
 };
 
 var btoa =
   global.btoa ||
-  function(b) {
+  function (b) {
     return b.replace(/[\s\S]{1,3}/g, cb_encode);
   };

src/core/channels/channel.ts

@@ -7,7 +7,7 @@ import Metadata from './metadata';
 import UrlStore from '../utils/url_store';
 import {
   ChannelAuthorizationData,
-  ChannelAuthorizationCallback
+  ChannelAuthorizationCallback,
 } from '../auth/options';
 import { HTTPAuthError } from '../errors';
 
@@ -29,7 +29,7 @@ export default class Channel extends EventsDispatcher {
   subscriptionCount: null;
 
   constructor(name: string, pusher: Pusher) {
-    super(function(event, data) {
+    super(function (event, data) {
       Logger.debug('No callbacks on ' + name + ' for ' + event);
     });
 
@@ -52,13 +52,13 @@ export default class Channel extends EventsDispatcher {
   trigger(event: string, data: any) {
     if (event.indexOf('client-') !== 0) {
       throw new Errors.BadEventName(
-        "Event '" + event + "' does not start with 'client-'"
+        "Event '" + event + "' does not start with 'client-'",
       );
     }
     if (!this.subscribed) {
       var suffix = UrlStore.buildLogSuffix('triggeringClientEvents');
       Logger.warn(
-        `Client event triggered before channel 'subscription_succeeded' event . ${suffix}`
+        `Client event triggered before channel 'subscription_succeeded' event . ${suffix}`,
       );
     }
     return this.pusher.send_event(event, data, this.name);
@@ -127,27 +127,27 @@ export default class Channel extends EventsDispatcher {
               {},
               {
                 type: 'AuthError',
-                error: error.message
+                error: error.message,
               },
-              error instanceof HTTPAuthError ? { status: error.status } : {}
-            )
+              error instanceof HTTPAuthError ? { status: error.status } : {},
+            ),
           );
         } else {
           this.pusher.send_event('pusher:subscribe', {
             auth: data.auth,
             channel_data: data.channel_data,
-            channel: this.name
+            channel: this.name,
           });
         }
-      }
+      },
     );
   }
 
   /** Sends an unsubscription request. For internal use only. */
   unsubscribe() {
     this.subscribed = false;
     this.pusher.send_event('pusher:unsubscribe', {
-      channel: this.name
+      channel: this.name,
     });
   }
 

src/core/channels/channels.ts

@@ -57,7 +57,7 @@ export default class Channels {
 
   /** Proxies disconnection signal to all channels. */
   disconnect() {
-    Collections.objectApply(this.channels, function(channel) {
+    Collections.objectApply(this.channels, function (channel) {
       channel.disconnect();
     });
   }
@@ -78,7 +78,7 @@ function createChannel(name: string, pusher: Pusher): Channel {
     return Factory.createPresenceChannel(name, pusher);
   } else if (name.indexOf('#') === 0) {
     throw new Errors.BadChannelName(
-      'Cannot create a channel with name "' + name + '".'
+      'Cannot create a channel with name "' + name + '".',
     );
   } else {
     return Factory.createChannel(name, pusher);