Alpha 20 update

Author: kamil.mysliwiec

CHANGELOG.md

@@ -0,0 +1,5 @@
+## 1.0.0-ALPHA-20
+
+- Microservices support (TCP & Redis transports)
+- NestRunner -> NestFactory,
+- Simplify application initialization & configuration

Readme.md

@@ -47,8 +47,8 @@ We want to create scalable, modern and easy to maintain applications. Nest helps
 
 ## Starter repos
 
-- [TypeScript] (https://github.com/kamilmysliwiec/nest-typescript-starter)
-- [Babel] (https://github.com/kamilmysliwiec/nest-babel-starter/)
+- [TypeScript](https://github.com/kamilmysliwiec/nest-typescript-starter)
+- [Babel](https://github.com/kamilmysliwiec/nest-babel-starter/)
 
 ## Future
 

example/app.ts

@@ -0,0 +1,8 @@
+import { NestFactory } from '../../src/nest-factory';
+import { Transport } from '../../src/common/enums/transport.enum';
+import { MicroserviceModule } from './modules/microservice.module';
+
+const app = NestFactory.createMicroservice(
+    MicroserviceModule, { transport: Transport.TCP, port: 5667 }
+);
+app.listen(() => console.log('Microservice listen on port:', 5667 ));

example/math/microservice.ts

@@ -0,0 +1,16 @@
+import { Controller } from '../../../src/common/utils/controller.decorator';
+import { MessagePattern } from '../../../src/microservices/utils/pattern.decorator';
+
+@Controller()
+export class MathController {
+
+    @MessagePattern({ command: 'add' })
+    multiply(data, respond) {
+        if (!data) {
+            respond(new Error('Invalid arguments'));
+            return;
+        }
+        const numbers = data.numbers || [];
+        respond(null, numbers.reduce((a, b) => a + b));
+    }
+}

example/math/modules/math.controller.ts

@@ -0,0 +1,7 @@
+import { Module } from '../../../src/common/utils/module.decorator';
+import { MathController } from './math.controller';
+
+@Module({
+    controllers: [ MathController ]
+})
+export class MicroserviceModule {}

example/math/modules/microservice.module.ts

@@ -1,7 +1,9 @@
 import { Module } from './../../src/';
 import { UsersModule } from './users/users.module';
+import { ClientController } from './client/client.controller';
 
 @Module({
-    modules: [ UsersModule ]
+    modules: [ UsersModule ],
+    controllers: [ ClientController ]
 })
 export class ApplicationModule {}

example/modules/app.module.ts

@@ -0,0 +1,21 @@
+import { Controller } from '../../../src/common/utils/controller.decorator';
+import { Client } from '../../../src/microservices/utils/client.decorator';
+import { RequestMapping } from '../../../src/common/utils/request-mapping.decorator';
+import { ClientProxy } from '../../../src/microservices/client/client-proxy';
+import { Observable } from 'rxjs/Observable';
+import { Transport } from '../../../src/common/enums/transport.enum';
+import 'rxjs/add/operator/catch';
+
+@Controller()
+export class ClientController {
+
+    @Client({ transport: Transport.TCP, port: 5667 })
+    client: ClientProxy;
+
+    @RequestMapping({ path: 'client' })
+    sendCommand() {
+        this.client.send({ command: 'add' }, { numbers: [ 1, 2, 3 ] })
+            .catch((err) => Observable.empty())
+            .subscribe((val) => console.log(val))
+    }
+}

example/modules/client/client.controller.ts

@@ -1,4 +1,4 @@
-import { UsersService } from "./users.service";
+import { UsersService } from './users.service';
 import { HttpException } from '../../../src/core/exceptions/http-exception';
 import { Middleware } from '../../../src/common/utils';
 import { NestMiddleware } from '../../../src/core/middlewares/interfaces/nest-middleware.interface';
@@ -10,7 +10,7 @@ export class AuthMiddleware implements NestMiddleware {
 
     resolve() {
         return (req, res, next) => {
-            const userName = req.headers["x-access-token"];
+            const userName = req.headers['x-access-token'];
             const users = this.usersService.getUsers();
 
             const user = users.find((user) => user.name === userName);

example/modules/users/auth.middleware.ts

@@ -1,14 +1,13 @@
-import { SocketGateway } from '../../../src/socket/utils/socket-gateway.decorator';
+import { WebSocketGateway } from '../../../src/socket/utils/socket-gateway.decorator';
 import { SubscribeMessage } from '../../../src/socket/utils/subscribe-message.decorator';
 import { Subject } from 'rxjs/Subject';
 import { GatewayServer } from '../../../src/socket/utils/gateway-server.decorator';
 
-@SocketGateway({ port: 2000 })
+@WebSocketGateway({ port: 2000 })
 export class ChatGateway {
     private msg$ = new Subject<any>();
 
-    @GatewayServer
-    server;
+    @GatewayServer server;
 
     get msgStream() {
         return this.msg$.asObservable();
@@ -19,4 +18,4 @@ export class ChatGateway {
         this.msg$.next({ client, data });
     }
 
-}
+}