Angular 2 Example - QuickStart

console.clear();

import {Component, Injectable, Inject} from '@angular/core';
import {bootstrap} from '@angular/platform-browser-dynamic';
import {Observable, Subject} from 'rxjs/Rx';
import io from 'socket.io-client';


@Injectable()
export class ChatRoom{
  url$ = Observable.of('https://socket-chat-example-qsaokhakmv.now.sh/');
  private socket$;
  public connected$;
  public message$;
  public messages$;
  
  public send$ = new Subject();

  constructor(@Inject('io') io){
    this.socket$ = this.url$
      .switchMap(url => Observable.of(io(url)));  
      
    this.message$ = this.socket$
      .switchMap(socket => Observable.fromEvent(socket, 'chat message'));
    
    this.messages$ = this.message$
      .startWith([]).scan((acc, curr)=> [...acc, curr]);
    
    const disconnect$ = this.socket$
      .switchMap(socket => Observable.fromEvent(socket, 'disconnect'));
      
    const connect$ = this.socket$
      .switchMap(socket => Observable.fromEvent(socket, 'connect'));
    
    this.connected$ = Observable.merge(
      connect$.mapTo(true),
      disconnect$.mapTo(false)
    );
    
    this.send$.withLatestFrom(this.socket$, (message, socket)=>{
      return {message, socket};
    })
    .subscribe(({message, socket})=>{
      socket.emit('chat message', message);
    })
  }
}

@Component({
    selector: 'my-app',
    styles:[`
    *{font-family: Monaco, Consolas;}
    `],
    template: `
      <h2>{{(chatRoom.connected$ | async) ? "Connected!" : "Disconnected..."}}</h2>
      <input #i (keyup.enter)="chatRoom.send$.next(i.value); i.value = ''">
      <div *ngFor="let message of chatRoom.messages$ | async">
        {{message}}
      </div>
    `
})
export class App {
    constructor(private chatRoom:ChatRoom) {
      
    }
}

bootstrap(App, [
    {provide: 'io', useValue: io},
    ChatRoom
]);

<!DOCTYPE html>
<html>
  <head>
    <title>Angular 2 @ngrx/store</title>
    <meta charset="UTF-8">
    <meta name="viewport" content="width=device-width, initial-scale=1">

    <!-- 1. Load libraries -->
     <!-- Polyfill(s) for older browsers -->
    <script src="https://npmcdn.com/es6-shim@0.35.0/es6-shim.min.js"></script>

    <script src="https://npmcdn.com/zone.js@0.6.12?main=browser"></script>
    <script src="https://npmcdn.com/reflect-metadata@0.1.3"></script>
    <script src="https://npmcdn.com/systemjs@0.19.27/dist/system.src.js"></script>

    <!-- 2. Configure SystemJS -->
    <script src="systemjs.config.js"></script>
    <script>
      console.clear();
      System.import('app').catch(function(err){ console.error(err); });
    </script>
  </head>

  <!-- 3. Display the application -->
  <body>
    <my-app>Loading...</my-app>
  </body>
</html>

/**
 * PLUNKER VERSION (based on systemjs.config.js in angular.io)
 * System configuration for Angular 2 samples
 * Adjust as necessary for your application needs.
 */
(function(global) {

  var ngVer = '@2.0.0-rc.1'; // lock in the angular package version; do not let it float to current!

  //map tells the System loader where to look for things
  var  map = {
    'app':                        'app',

    '@angular':                   'https://npmcdn.com/@angular', // sufficient if we didn't pin the version
    'angular2-in-memory-web-api': 'https://npmcdn.com/angular2-in-memory-web-api', // get latest
    '@ngrx/store':                'https://raw.githubusercontent.com/MikeRyan52/store/core-refactor/src',
    '@ngrx/effects':                'https://raw.githubusercontent.com/ngrx/effects/master/lib',
    '@ngrx/core':                 'https://raw.githubusercontent.com/ngrx/core/master/lib',
    'rxjs':                       'https://npmcdn.com/rxjs@5.0.0-beta.6',
    'socket.io-client':                  'https://npmcdn.com/socket.io-client@1.4.6/socket.io.js',
    'ts':                         'https://npmcdn.com/plugin-typescript@4.0.10/lib/plugin.js',
    'typescript':                 'https://npmcdn.com/typescript@1.8.10/lib/typescript.js'
 };

  //packages tells the System loader how to load when no filename and/or no extension
  var packages = {
    'app':                        { main: 'main.ts',  defaultExtension: 'ts' },
    'rxjs':                       { defaultExtension: 'js' },
    'socket.io-client ':                  { defaultExtension: 'js' },
    '@ngrx/core':                { main: 'index', defaultExtension: 'ts' },
    '@ngrx/store':                { main: 'index', defaultExtension: 'ts' },
    '@ngrx/effects':                { main: 'index', defaultExtension: 'ts' },
    'angular2-in-memory-web-api': { defaultExtension: 'js' },
  };

  var ngPackageNames = [
    'common',
    'compiler',
    'core',
    'http',
    'platform-browser',
    'platform-browser-dynamic',
    'router',
    'router-deprecated',
    'upgrade',
  ];

  // Add map entries for each angular package
  // only because we're pinning the version with `ngVer`.
  ngPackageNames.forEach(function(pkgName) {
    map['@angular/'+pkgName] = 'https://npmcdn.com/@angular/' + pkgName + ngVer;
  });

  // Add package entries for angular packages
  ngPackageNames.forEach(function(pkgName) {

    // Bundled (~40 requests):
    packages['@angular/'+pkgName] = { main: pkgName + '.umd.js', defaultExtension: 'js' };

    // Individual files (~300 requests):
    //packages['@angular/'+pkgName] = { main: 'index.js', defaultExtension: 'js' };
  });

  var config = {
    // DEMO ONLY! REAL CODE SHOULD NOT TRANSPILE IN THE BROWSER
    transpiler: 'typescript',
    typescriptOptions: {
      emitDecoratorMetadata: true
    },

    map: map,
    packages: packages
  }

  System.config(config);

})(this);