Merge pull request #270 from mean-expert-official/development

2.1.0-rc.6

Author: jonathan-casarrubias

CHANGELOG.md

@@ -2,6 +2,17 @@
 
 This file is created to keep history of the LoopBack SDK Builder, it does not consider or keeps any history of its parent module `loopback-sdk-angular`.
 
+## Release 2.1.0-rc.6
+
+- Milestone Details: https://github.com/mean-expert-official/loopback-sdk-builder/milestone/28?closed=1
+
+- Fix: https://github.com/mean-expert-official/loopback-sdk-builder/issues/268
+- Fix: https://github.com/mean-expert-official/loopback-sdk-builder/issues/266
+- Fix: https://github.com/mean-expert-official/loopback-sdk-builder/issues/265
+- Fix: https://github.com/mean-expert-official/loopback-sdk-builder/issues/264
+- Fix: https://github.com/mean-expert-official/loopback-sdk-builder/issues/262
+- Fix: https://github.com/mean-expert-official/loopback-sdk-builder/issues/151
+
 ## Release 2.1.0-rc.5
 
 - Milestone Details: https://github.com/mean-expert-official/loopback-sdk-builder/milestone/27?closed=1

lib/angular2/index.js

@@ -147,8 +147,8 @@ module.exports = function generate(ctx) {
      * STORAGE
      */
     {
-      template: './shared/storage/internal.storage.ts',
-      output: '/storage/internal.storage.ts',
+      template: './shared/storage/storage.swaps.ts',
+      output: '/storage/storage.swaps.ts',
       params: {}
     }
   ];
@@ -159,6 +159,11 @@ module.exports = function generate(ctx) {
       output: '/storage/cookie.browser.ts',
       params: {}
     });
+    schema.push({
+      template: './shared/storage/storage.browser.ts',
+      output: '/storage/storage.browser.ts',
+      params: {}
+    });
   }
   // Add Server Specific Code
   if (ctx.driver === 'ng2universal') {
@@ -470,7 +475,7 @@ module.exports = function generate(ctx) {
       { module: 'LoopBackAuth', from: './services/core/auth.service'},
       { module: 'LoggerService', from: './services/custom/logger.service'},
       { module: 'SDKModels', from: './services/custom/SDKModels'},
-      { module: 'InternalStorage', from: './storage/internal.storage'},
+      { module: 'InternalStorage, SDKStorage', from: './storage/storage.swaps'},
       { module: 'HttpModule', from: '@angular/http'},
       { module: 'CommonModule', from: '@angular/common'},
       { module: 'NgModule, ModuleWithProviders', from: '@angular/core'}
@@ -479,13 +484,15 @@ module.exports = function generate(ctx) {
     switch (driver) {
       case 'ng2web':
         imports.push({ module: 'CookieBrowser', from: './storage/cookie.browser'});
+        imports.push({ module: 'StorageBrowser', from: './storage/storage.browser'});
           if (isIo === 'enabled') {
             imports.push({ module: 'SocketBrowser', from: './sockets/socket.browser'});
           }
       break;
       case 'ng2universal':
         imports.push({ module: 'CookieBrowser', from: './storage/cookie.browser'});
         imports.push({ module: 'CookieNode', from: './storage/cookie.node'});
+        imports.push({ module: 'StorageBrowser', from: './storage/storage.browser'});
           if (isIo === 'enabled') {
             imports.push({ module: 'SocketBrowser', from: './sockets/socket.browser'});
             imports.push({ module: 'SocketNode', from: './sockets/socket.node'});
@@ -528,6 +535,7 @@ module.exports = function generate(ctx) {
       case 'browser':
         if (driver === 'ng2web' || driver === 'ng2universal') {
           imports.push('{ provide: InternalStorage, useClass: CookieBrowser }');
+          imports.push('{ provide: SDKStorage, useClass: StorageBrowser }');
           if (isIo === 'enabled') {
             imports.push('{ provide: SocketDriver, useClass: SocketBrowser }');
           }
@@ -544,6 +552,7 @@ module.exports = function generate(ctx) {
       case 'nativescript':
         if (driver === 'ng2native') {
           imports.push('{ provide: InternalStorage, useClass: StorageNative }');
+          imports.push('{ provide: SDKStorage, useClass: StorageNative }');
           if (isIo === 'enabled') {
             imports.push('{ provide: SocketDriver, useClass: SocketNative }');
           }

lib/angular2/shared/index.ejs

@@ -18,14 +18,14 @@
 * // App Root 
 * import { AppComponent }   from './app.component';
 * // Feature Modules
-* import { SDKModule }      from './shared/sdk/sdk.module';
+* import { SDK[Browser|Node|Native]Module } from './shared/sdk/sdk.module';
 * // Import Routing
 * import { routing }        from './app.routing';
 * @NgModule({
 *  imports: [
 *    BrowserModule,
 *    routing,
-*    SDKModule.forRoot()
+*    SDK[Browser|Node|Native]Module.forRoot()
 *  ],
 *  declarations: [ AppComponent ],
 *  bootstrap:    [ AppComponent ]

lib/angular2/shared/models/flref.ejs

@@ -165,7 +165,7 @@ export class FireLoopRef<T> {
       }
       sbj.next(data);
     };
-    this.socket.on(nowEvent, pullNow);
+    this.socket.onZone(nowEvent, pullNow);
     return sbj.asObservable();
   }
   /**
@@ -176,12 +176,12 @@ export class FireLoopRef<T> {
   **/
   private broadcasts(event: string, request: any): Observable<T> {
     let sbj: Subject<T> = new Subject<T>();
-    this.socket.on(
+    this.socket.onZone(
       `${event}.broadcast.announce.${ this.id }`,
       (res: T) =>
         this.socket.emit(`${event}.broadcast.request.${ this.id }`, request)
     );
-    this.socket.on(`${ event }.broadcast.${ this.id }`, (data) => sbj.next(data));
+    this.socket.onZone(`${ event }.broadcast.${ this.id }`, (data) => sbj.next(data));
     return sbj.asObservable();
   }
   /**
@@ -203,7 +203,7 @@ export class FireLoopRef<T> {
       parent: this.parent && this.parent.instance ? this.parent.instance : null
     };
     this.socket.emit(event, config);
-    this.socket.on(`${ this.model.getModelName() }.value.result.${ this.id }`, (res: any) =>
+    this.socket.onZone(`${ this.model.getModelName() }.value.result.${ this.id }`, (res: any) =>
       subject.next(res.error ? Observable.throw(res.error) : res)
     );
     return subject.asObservable();

lib/angular2/shared/services/core/auth.ejs

@@ -1,7 +1,7 @@
 /* tslint:disable */
 declare var Object: any;
 import { Injectable, Inject } from '@angular/core';
-import { InternalStorage } from '../../storage/internal.storage';
+import { InternalStorage } from '../../storage/storage.swaps';
 import { SDKToken, AccessToken } from '../../models/BaseModels';
 
 /**

lib/angular2/shared/services/core/base.ejs

@@ -88,17 +88,16 @@ export abstract class BaseLoopBackApi {
       body = postBody;
     }
     // Separate filter object from url params
-    let filter: string = '';
     if (urlParams.filter) {
-      filter = `?filter=${ encodeURI(JSON.stringify(urlParams.filter))}`;
+      headers.append('filter', JSON.stringify(urlParams.filter));
       delete urlParams.filter;
     }
 
     this.searchParams.setJSON(urlParams);
     let request: Request = new Request({
       headers : headers,
       method  : method,
-      url     : `${requestUrl}${filter}`,
+      url     : requestUrl,
       search  : Object.keys(urlParams).length > 0
               ? this.searchParams.getURLSearchParams() : null,
       body    : body ? JSON.stringify(body) : undefined

lib/angular2/shared/services/core/realtime.ejs

@@ -22,10 +22,13 @@ export class RealTime {
     @Inject(SDKModels) protected models: SDKModels,
     @Inject(LoopBackAuth) protected auth: LoopBackAuth,
     @Inject(JSONSearchParams) protected searchParams: JSONSearchParams
-  ) {
-    this.socket   = this.getConnection();
-    this.IO       = new IO(this.socket);
-    this.FireLoop = new FireLoop(this.socket, models);
+  ) {}
+
+  disconnect(): void {
+    this.connected = false;
+    this.IO        = null;
+    this.FireLoop  = null;
+    this.connections.disconnect();
   }
 
   getConnection(): void {
@@ -41,11 +44,17 @@ export class RealTime {
     if (this.connected) {
       subject.next();
     } else {
+      this.socket   = this.getConnection();
+      this.IO       = new IO(this.socket);
+      this.FireLoop = new FireLoop(this.socket, this.models);
       this.socket.on('connect', () => {
         this.connected = true;
         subject.next();
       });
-      this.socket.on('disconnect', () => this.connected = false);
+      this.socket.on('disconnect', () => {
+        subject.complete();
+        this.disconnect();
+      });
     }
     return subject.asObservable();
   }

lib/angular2/shared/sockets/connections.ts

@@ -1,5 +1,5 @@
 /* tslint:disable */
-import { Injectable, Inject } from '@angular/core';
+import { Injectable, Inject, NgZone } from '@angular/core';
 import { SocketDriver } from './socket.driver';
 import { AccessToken } from '../models';
 /**
@@ -14,16 +14,25 @@ import { AccessToken } from '../models';
 @Injectable()
 export class SocketConnections {
   private connections: any = {};
-  private configured: boolean  = false;
-  constructor(@Inject(SocketDriver) private driver: SocketDriver) {}
+  private configured: boolean = false;
+  constructor(
+    @Inject(SocketDriver) private driver: SocketDriver,
+    @Inject(NgZone) private zone: NgZone
+  ) { }
   getHandler(url: string, token: AccessToken) {
+      console.log('Getting handler for socket connections');
     if (!this.connections[url]) {
       console.log('Creating a new connection with: ', url);
-      let config: any = { log: false, secure: false, forceWebsockets: true };
+      let config: any = { log: false, secure: false, forceNew: true, forceWebsockets: true };
       this.connections[url] = this.driver.connect(url, config);
+      this.connections[url].onZone = ((event: string, handler: Function) => {
+        this.connections[url].on(event, (data: any) => {
+          this.zone.run(() => handler(data));
+        });
+      });
       this.connections[url].on('connect', () => {
-        if (!this.configured) 
-        this.setupConnection(url, token, config);
+        if (!this.configured)
+          this.setupConnection(url, token, config);
       });
       let forceConfig: any = setInterval(() => {
         if (!this.configured && this.connections[url].connected) {
@@ -40,17 +49,35 @@ export class SocketConnections {
     return this.connections[url];
   }
 
+  public disconnect() {
+    Object.keys(this.connections).forEach((connKey) => {
+      if (this.connections[connKey].connected) {
+        this.connections[connKey].disconnect();
+      }
+    });
+    this.connections = {};
+    this.configured  = false;
+  }
+
   private setupConnection(url: string, token: AccessToken, config: any): void {
     this.configured = true;
     console.log('Connected to %s', url);
-    if(token.id) {
+    if (token.id) {
+      console.log('Emitting authentication', token.id);
       this.connections[url].emit('authentication', token);
     }
     this.connections[url].on('unauthorized', (res: any) => console.error('Unauthenticated', res));
-    setInterval(() => this.connections[url].emit('lb-ping'), 15000);
+    let heartbeater: any = setInterval(() => {
+      if (this.connections[url]) {
+        this.connections[url].emit('lb-ping');
+      } else {
+      clearInterval(heartbeater);
+      }
+    }, 15000);
     this.connections[url].on('lb-pong', (data: any) => console.info('Heartbeat: ', data));
     this.connections[url].on('disconnect', (data: any) => {
-      console.info('Unexpected disconnection from IO - Socket IO will try to reconnect');
+      this.disconnect();
+      console.info('Disconnected from WebSocket server');
     });
   }
 }

lib/angular2/shared/storage/cookie.browser.ts

@@ -26,7 +26,7 @@ export class CookieBrowser {
 
   set(key: string, value: any, expires?: Date) {
     this.cookies[key] = value;
-    let cookie = `${key}=${value}${expires ? `; expires=${ expires.toUTCString() }` : ''}`;
+    let cookie = `${key}=${value}; path=/${expires ? `; expires=${ expires.toUTCString() }` : ''}`;
     window.document.cookie = cookie;
   }