Added several use cases and restructured project.

Author: stemmlerjs

package-lock.json

@@ -4,6 +4,7 @@
   "description": "A Vinyl-Trading enterprise app built with Node.js + TypeScript using Domain-Driven Design",
   "main": "bin/www",
   "dependencies": {
+    "axios": "^0.19.0",
     "bcrypt-nodejs": "0.0.3",
     "chai": "^4.2.0",
     "dotenv": "^8.0.0",
@@ -17,6 +18,7 @@
     "typescript": "^3.5.2"
   },
   "devDependencies": {
+    "@types/axios": "^0.14.0",
     "@types/bcrypt-nodejs": "0.0.30",
     "@types/jest": "^24.0.15",
     "cross-env": "^5.2.0",

package.json

@@ -0,0 +1,20 @@
+
+import { Result } from "./Result";
+import { UseCaseError } from "./UseCaseError";
+
+export namespace GenericAppError {
+  export class UnexpectedError extends Result<UseCaseError> {
+    public constructor (err: any) {
+      super(false, {
+        message: `An unexpected error occurred.`,
+        error: err
+      } as UseCaseError)
+      console.log(`[AppError]: An unexpected error occurred`);
+      console.error(err);
+    }
+
+    public static create (err: any): UnexpectedError {
+      return new UnexpectedError(err);
+    }
+  }
+}

src/core/Result.ts

@@ -0,0 +1,93 @@
+
+export class Result<T> {
+  public isSuccess: boolean;
+  public isFailure: boolean
+  public error: T | string;
+  private _value: T;
+
+  public constructor (isSuccess: boolean, error?: T | string, value?: T) {
+    if (isSuccess && error) {
+      throw new Error("InvalidOperation: A result cannot be successful and contain an error");
+    }
+    if (!isSuccess && !error) {
+      throw new Error("InvalidOperation: A failing result needs to contain an error message");
+    }
+
+    this.isSuccess = isSuccess;
+    this.isFailure = !isSuccess;
+    this.error = error;
+    this._value = value;
+    
+    Object.freeze(this);
+  }
+
+  public getValue () : T {
+    if (!this.isSuccess) {
+      console.log(this.error,);
+      throw new Error("Can't get the value of an error result. Use 'errorValue' instead.")
+    } 
+
+    return this._value;
+  }
+
+  public errorValue (): T {
+    return this.error as T;
+  }
+
+  public static ok<U> (value?: U) : Result<U> {
+    return new Result<U>(true, null, value);
+  }
+
+  public static fail<U> (error: any): Result<U> {
+    return new Result<U>(false, error);
+  }
+
+  public static combine (results: Result<any>[]) : Result<any> {
+    for (let result of results) {
+      if (result.isFailure) return result;
+    }
+    return Result.ok();
+  }
+}
+
+export type Either<L, A> = Left<L, A> | Right<L, A>;
+
+export class Left<L, A> {
+  readonly value: L;
+
+  constructor(value: L) {
+    this.value = value;
+  }
+
+  isLeft(): this is Left<L, A> {
+    return true;
+  }
+
+  isRight(): this is Right<L, A> {
+    return false;
+  }
+}
+
+export class Right<L, A> {
+  readonly value: A;
+
+  constructor(value: A) {
+    this.value = value;
+  }
+
+  isLeft(): this is Left<L, A> {
+    return false;
+  }
+
+  isRight(): this is Right<L, A> {
+    return true;
+  }
+}
+
+export const left = <L, A>(l: L): Either<L, A> => {
+  return new Left(l);
+};
+
+export const right = <L, A>(a: A): Either<L, A> => {
+  return new Right<L, A>(a);
+};

src/core/logic/AppError.ts

@@ -0,0 +1,12 @@
+
+interface IUseCaseErrorError {
+  message: string;
+}
+
+export abstract class UseCaseError implements IUseCaseErrorError {
+  public readonly message: string;
+  
+  constructor (message: string) {
+    this.message = message;
+  }
+}

src/core/Guard.ts src/core/logic/Guard.ts

@@ -1 +1 @@
-import "./catalog"
+import "./modules/vinyl"

src/core/logic/Result.ts

@@ -0,0 +1,78 @@
+
+/*
+ * app/models/index.js
+ * 
+ * Loads all models and creates the relationships for those models and whatnot.
+ * Date: 2018/02/05
+ * 
+ * v1.0.0 - 2018/11/26 - Added co-op filters to AudienceFilters
+ */
+
+import * as fs from 'fs'
+import * as path from 'path'
+import config from '../config/config'
+import * as Sequelize from 'sequelize'
+
+
+const sequelize = config.db.conn;
+const { connectionStatus } = config.db
+
+// turns base_user => BaseUser
+function toCamelCase (str) {
+  const _ = str.indexOf("_");
+  if (~_) {
+    return toCamelCase(str.substring(0, _) 
+        + str.substring(_ + 1)
+          .substring(0, 1)
+          .toUpperCase() 
+        + str.substring(_ + 2)
+    )
+  }
+  else {
+    return str.substring(0, 1).toUpperCase() + str.substring(1);
+  }
+}
+
+let models: any = {};
+let modelsLoaded = false;
+
+const createModels = () => {
+  if (modelsLoaded) return models;
+
+  // Get all models
+  const modelsList = fs.readdirSync(path.resolve(__dirname, "./"))
+    .filter((t) => ~t.indexOf('.js') && !~t.indexOf("index") && !~t.indexOf(".map"))
+    .map((model) => sequelize.import(__dirname + '/' + model))
+
+  // Camel case the models
+  for (let i = 0; i < modelsList.length; i++) {
+    const modelName = toCamelCase(modelsList[i].name);
+    models[modelName] = modelsList[i];
+  }
+
+  // Create the relationships for the models;
+  Object.keys(models).forEach((modelName) => {
+    if (models[modelName].associate) {
+      models[modelName].associate(models);
+    }
+  });
+
+  models['sequelize'] = sequelize;
+  models['Sequelize'] = Sequelize;
+
+  modelsLoaded = true;
+
+  return models;
+}
+
+export default createModels();
+
+export function getModels () : Promise<any> {
+  return new Promise((resolve, reject) => {
+    connectionStatus.subscribe((status: boolean) => {
+      if (status) {
+        return resolve(createModels())
+      } 
+    })
+  })
+}

src/core/logic/UseCaseError.ts

@@ -1,8 +1,8 @@
 
-import { IHandle } from "../../../core/domain/events/IHandle";
-import { VinylCreatedEvent } from "../../../catalog/domain/events/vinylCreatedEvent";
-import { DomainEvents } from "../../../core/domain/events/DomainEvents";
-import { IVinylRepo } from "../../../catalog/repos/vinylRepo";
+import { IHandle } from "../../../../core/domain/events/IHandle";
+import { VinylCreatedEvent } from "../../../vinyl/domain/events/vinylCreatedEvent";
+import { DomainEvents } from "../../../../core/domain/events/DomainEvents";
+import { IVinylRepo } from "../../../vinyl/repos/vinylRepo";
 
 export class VinylCreatedSubscription implements IHandle<VinylCreatedEvent> {
   private vinylRepo: IVinylRepo;

src/index.ts

@@ -1,7 +1,7 @@
 
-import { AggregateRoot } from "../../core/domain/AggregateRoot";
-import { UniqueEntityID } from "../../core/domain/UniqueEntityID";
-import { Result } from "../../core/Result";
+import { AggregateRoot } from "../../../core/domain/AggregateRoot";
+import { UniqueEntityID } from "../../../core/domain/UniqueEntityID";
+import { Result } from "../../../core/logic/Result";
 import { UserId } from "../../users/domain/userId";
 
 interface TraderProps {

sequelize/config/config.js src/infra/sequelize/config/config.js

@@ -1,6 +1,6 @@
 
-import { Entity } from "../../core/domain/Entity";
-import { UniqueEntityID } from "../../core/domain/UniqueEntityID";
+import { Entity } from "../../../core/domain/Entity";
+import { UniqueEntityID } from "../../../core/domain/UniqueEntityID";
 
 export class TraderId extends Entity<any> {
 

sequelize/migrations/20190625131808-initial-migration.ts src/infra/sequelize/migrations/20190625131808-initial-migration.ts

@@ -1,5 +1,5 @@
-import { IDomainEvent } from "../../../core/domain/events/IDomainEvent";
-import { UniqueEntityID } from "../../../core/domain/UniqueEntityID";
+import { IDomainEvent } from "../../../../core/domain/events/IDomainEvent";
+import { UniqueEntityID } from "../../../../core/domain/UniqueEntityID";
 import { User } from "../user";
 
 export class UserCreatedEvent implements IDomainEvent {