• Description
• Installation
• Usage

Description

Annotation based, Java Spring like, REST library

Installation

kahve-rest runs on Node.js and is available as an NPM package. You can install kahve-rest in your project's directory as usual:

$ npm install kahve-core kahve-rest

You should set the "emitDecoratorMetadata" and "experimentalDecorators" config to true in your tsconfig.json file.

{ 
   "compilerOptions": { 
     ..., 
     "emitDecoratorMetadata": true,
     "experimentalDecorators": true,
   } 
}

Usage

See the example below and you can find a postman collection within "/example" directory to test the code below.

import { logger, LogLevel } from 'kahve-core';
import {
  RestController,
  RestGet,
  RestPost,
  RequestBody,
  RestPut,
  PathVariable,
  RestError,
  RestDelete,
  RestServer,
  RestServerConfig,
  RestServerController,
  RestServerPreStart,
  RestServerPostStart,
  HttpStatus,
  QueryParam,
  RequestHeader
} from 'kahve-rest';

// SET LOG LEVEL
logger.setLevel(LogLevel.DEBUG);

// CONTROLLER DEFINITION
@RestController('base/path')
class TestController {
  private list: string[] = [];

  @RestGet('get-item')
  public getItem(@QueryParam('index') index: number): string {
    const i = Number.parseInt(`${index}`);
    if (!this.isValidIndex(i)) throw new RestError('Out of bound.', HttpStatus.BAD_REQUEST);
    return this.list[i];
  }

  @RestGet('get-list')
  public getAll(): string[] {
    return this.list;
  }

  @RestGet('get-list-with-timeout')
  public getAllTimeout(): Promise<string[]> {
    return new Promise(resolve => setTimeout(() => resolve(this.list), 2000));
  }

  @RestPost('add-item')
  public createItem(@RequestBody() item: string, @RequestHeader('Authorization', true) auth: string): string {
    this.list.push(item);
    logger.info('Auth Token is:', auth);
    logger.info('New item added:', item);
    return item;
  }

  @RestPut('update-item/:index')
  public updateItem(@RequestBody() item: string, @PathVariable('index') ind: number): string {
    const i = Number.parseInt(`${ind}`);
    if (!this.isValidIndex(i)) throw new RestError('Out of bound.', HttpStatus.BAD_REQUEST);

    this.list[i] = item;
    logger.info('Item updated:', item);
    return this.list[i];
  }

  @RestDelete('delete-item/:index')
  public deleteUser(@PathVariable('index') index: number): boolean {
    const i = Number.parseInt(`${index}`);
    if (!this.isValidIndex(i)) throw new RestError('Out of bound.', HttpStatus.BAD_REQUEST);

    const deletedItem = this.list.splice(i, 1);
    logger.info('Item deleted:', deletedItem);
    return true;
  }

  private isValidIndex(index: number): boolean {
    return index < this.list.length;
  }
}

@RestServer()
class PublicServer {
  @RestServerConfig('PORT')
  private port: number = 9000;

  @RestServerController()
  private testController: TestController = new TestController();

  @RestServerPreStart()
  private preStart(): Promise<void> {
    logger.info('Do some preparing steps in here and also you can do async operations.');
    return new Promise(resolve => setTimeout(() => resolve(null), 1500));
  }

  @RestServerPostStart()
  private postStart(): void {
    logger.info(`Server is started. Port: ${this.port} Log level: ${logger.getLevel()}`);
  }
}

@RestServer()
class SecureServer {
  @RestServerConfig('PORT')
  private port: number = 9001;

  @RestServerConfig('KEY')
  private keyFile: string = './key.pem';

  @RestServerConfig('CERT')
  private certFile: string = './cert.pem';

  @RestServerConfig('SECURE')
  private isSecure: boolean = true;

  @RestServerController()
  private testController: TestController = new TestController();

  @RestServerPreStart()
  private preStart(): Promise<void> {
    logger.info('Do some preparing steps in here and also you can do async operations.');
    return new Promise(resolve => setTimeout(() => resolve(null), 1500));
  }

  @RestServerPostStart()
  private postStart(): void {
    logger.info(`Secure server is started. Port: ${this.port} Log level: ${logger.getLevel()}`);
  }
}

const publicServer = new PublicServer();
const secureServer = new SecureServer();