initial commit

Author: RobinBuschmann

.editorconfig

@@ -0,0 +1,14 @@
+# http://editorconfig.org
+root = true
+
+[*]
+charset = utf-8
+indent_style = space
+indent_size = 2
+end_of_line = lf
+insert_final_newline = true
+trim_trailing_whitespace = true
+
+[*.md]
+insert_final_newline = false
+trim_trailing_whitespace = false

.gitignore

@@ -0,0 +1,11 @@
+# tmp
+.idea
+.DS_Store
+
+# lib
+node_modules
+
+# build
+**/*.js
+**/*.js.map
+**/*.d.ts

index.ts

@@ -0,0 +1 @@
+import './lib/server';

lib/app.ts

@@ -0,0 +1,31 @@
+import * as express from 'express';
+import * as bodyParser from 'body-parser';
+import * as errorhandler from 'strong-error-handler';
+import {movies} from './routes/movies';
+import {actors} from './routes/actors';
+
+export const app = express();
+
+// middleware for parsing application/x-www-form-urlencoded
+app.use(bodyParser.urlencoded({extended: true}));
+
+// middleware for json body parsing
+app.use(bodyParser.json({limit: '5mb'}));
+
+// enable corse for all origins
+app.use((req, res, next) => {
+  res.header("Access-Control-Allow-Origin", "*");
+  res.header("Access-Control-Expose-Headers", "x-total-count");
+  res.header("Access-Control-Allow-Methods", "GET,PUT,POST,DELETE,PATCH");
+  res.header("Access-Control-Allow-Headers", "Content-Type,authorization");
+
+  next();
+});
+
+app.use('/movies', movies);
+app.use('/actors', actors);
+
+app.use(errorhandler({
+  debug: process.env.ENV !== 'prod',
+  log: true,
+}));

lib/models/Actor.ts

@@ -0,0 +1,41 @@
+import {Model, Column, Table, BelongsToMany, Scopes, CreatedAt, UpdatedAt} from "sequelize-typescript";
+import {Movie} from "./Movie";
+import {MovieActor} from "./MovieActor";
+
+@Scopes({
+  movies: {
+    include: [
+      {
+        model: () => Movie,
+        through: {attributes: []},
+      },
+    ],
+  },
+})
+@Table
+export class Actor extends Model<Actor> {
+
+  @Column
+  firstName: string;
+
+  @Column
+  lastName: string;
+
+  @Column
+  birthday: Date;
+
+  @BelongsToMany(() => Movie, () => MovieActor)
+  movies?: Movie[];
+
+  @CreatedAt
+  @Column
+  createdAt: Date;
+
+  @UpdatedAt
+  @Column
+  updatedAt: Date;
+
+  static scope(name: string = 'defaultScope'): typeof Actor {
+    return super.scope.call(this, name);
+  }
+}

lib/models/Genre.ts

@@ -0,0 +1,32 @@
+import {Model, Column, Table, BelongsToMany, Scopes, PrimaryKey, CreatedAt, UpdatedAt} from "sequelize-typescript";
+import {Movie} from "./Movie";
+import {MovieGenre} from "./MovieGenre";
+
+@Scopes({
+  movies: {
+    include: [
+      {
+        model: () => Movie,
+        through: {attributes: []},
+      },
+    ],
+  },
+})
+@Table
+export class Genre extends Model<Genre> {
+
+  @PrimaryKey
+  @Column
+  name: string;
+
+  @BelongsToMany(() => Movie, () => MovieGenre)
+  movies?: Movie[];
+
+  @CreatedAt
+  @Column
+  createdAt: Date;
+
+  @UpdatedAt
+  @Column
+  updatedAt: Date;
+}

lib/models/Movie.ts

@@ -0,0 +1,70 @@
+import {Model, Column, Table, BelongsToMany, Scopes, CreatedAt, UpdatedAt} from "sequelize-typescript";
+import * as Promise from "bluebird";
+import {MovieActor} from "./MovieActor";
+import {Actor} from "./Actor";
+import {ICreateOptions} from "sequelize-typescript/lib/interfaces/ICreateOptions";
+import {Genre} from "./Genre";
+import {MovieGenre} from "./MovieGenre";
+
+@Scopes({
+  cast: {
+    include: [{
+      model: () => Actor,
+      through: {attributes: []},
+    }],
+  },
+  genre: {
+    include: [{
+      model: () => Genre,
+      through: {attributes: []},
+    }]
+  },
+  full: {
+    include: [{
+      model: () => Actor,
+      through: {attributes: []},
+    }, {
+      model: () => Genre,
+      through: {attributes: []},
+    }]
+  }
+})
+@Table
+export class Movie extends Model<Movie> {
+
+  @Column
+  title: string;
+
+  @Column
+  year: number;
+
+  @BelongsToMany(() => Actor, () => MovieActor)
+  cast?: Actor[];
+
+  @BelongsToMany(() => Genre, () => MovieGenre)
+  genres?: Genre[];
+
+  @CreatedAt
+  @Column
+  createdAt: Date;
+
+  @UpdatedAt
+  @Column
+  updatedAt: Date;
+
+  static create(values?: any, options?: ICreateOptions): Promise<Movie> {
+    const include: any = [];
+    if (values) {
+      if (values.cast) include.push(Actor);
+      if (values.genres) include.push(Genre);
+    }
+    if (!options) options = {};
+    options.include = options.include ? options.include.concat(include) : include;
+
+    return super.create.call(this, values, options);
+  }
+
+  static scope(name: string = 'defaultScope'): typeof Movie {
+    return super.scope.call(this, name);
+  }
+}

lib/models/MovieActor.ts

@@ -0,0 +1,15 @@
+import {Model, Column, Table, ForeignKey} from "sequelize-typescript";
+import {Movie} from "./Movie";
+import {Actor} from "./Actor";
+
+@Table
+export class MovieActor extends Model<MovieActor> {
+
+  @ForeignKey(() => Movie)
+  @Column
+  movieId: number;
+
+  @ForeignKey(() => Actor)
+  @Column
+  actorId: number;
+}

lib/models/MovieGenre.ts

@@ -0,0 +1,15 @@
+import {Model, Column, Table, ForeignKey} from "sequelize-typescript";
+import {Movie} from "./Movie";
+import {Genre} from "./Genre";
+
+@Table
+export class MovieGenre extends Model<MovieGenre> {
+
+  @ForeignKey(() => Movie)
+  @Column
+  movieId: number;
+
+  @ForeignKey(() => Genre)
+  @Column
+  genre: string;
+}

lib/routes/actors.ts

@@ -0,0 +1,44 @@
+import {Router} from 'express';
+import {Actor} from '../models/Actor';
+import {MovieActor} from '../models/MovieActor';
+
+export const actors = Router();
+
+actors.post('/', (req, res, next) => {
+  Actor
+    .create(req.body)
+    .then(() => res.sendStatus(201))
+    .catch(next);
+});
+
+actors.post('/:id/movies/:movieId', (req, res, next) => {
+  MovieActor
+    .create({
+      actorId: req.params['id'], movieId: req.params['movieId']
+    })
+    .then(() => res.sendStatus(200))
+    .catch(next);
+});
+
+actors.get('', (req, res, next) => {
+  Actor
+    .scope(req.query['scope'])
+    .findAll()
+    .then(_actors => res.json(_actors))
+    .catch(next);
+});
+
+actors.get('/:id', (req, res, next) => {
+  Actor
+    .scope(req.query['scope'])
+    .findById(req.params['id'])
+    .then(actor => res.json(actor))
+    .catch(next);
+});
+
+actors.put('/:id', (req, res, next) => {
+  Actor
+    .update(req.body, {where: {id: req.params['id']}})
+    .then(() => res.sendStatus(200))
+    .catch(next);
+});