feat(messages): define messages model and factories

add models for Query, Event and Command messages and implement creators for each one of them

Author: juanmarin-co

src/domain/message-factory.ts

@@ -0,0 +1,14 @@
+import { MessageCreator } from './model/message-creator.model'
+import { Command, Query, Event } from './model/messages.model'
+
+export function createCommand<T>(name: string): MessageCreator<Command<T>, T> {
+  return (id: string, data: T) => new Command(id, name, data)
+}
+
+export function createQuery<T>(name: string): MessageCreator<Query<T>, T> {
+  return (id: string, data: T) => new Query(id, name, data)
+}
+
+export function createEvent<T>(name: string): MessageCreator<Event<T>, T> {
+  return (id: string, data: T) => new Event(id, name, data)
+}

src/domain/model/message-creator.model.ts

@@ -0,0 +1,3 @@
+import { Message } from './messages.model'
+
+export type MessageCreator<R extends Message<T>, T> = (id: string, data: T) => R

src/domain/model/messages.model.ts

@@ -0,0 +1,17 @@
+export class Message<T> {
+  id: string
+  name: string
+  data: T
+
+  constructor(id: string, name: string, data: T) {
+    this.id = id
+    this.name = name
+    this.data = data
+  }
+}
+
+export class Command<T> extends Message<T> {}
+
+export class Query<T> extends Message<T> {}
+
+export class Event<T> extends Message<T> {}

src/reactive-commons.ts

@@ -1,4 +1,2 @@
-// Import here Polyfills if needed. Recommended core-js (npm i -D core-js)
-// import "core-js/fn/array.find"
-// ...
-export default class DummyClass {}
+export { Command, Query, Event } from './domain/model/messages.model'
+export { createCommand, createQuery, createEvent } from './domain/message-factory'

test/message-factory.test.ts

@@ -0,0 +1,52 @@
+import {
+  Command,
+  createCommand,
+  Query,
+  createQuery,
+  Event,
+  createEvent
+} from '../src/reactive-commons'
+
+describe(`Message factory`, () => {
+  it(`builds valid command instances`, () => {
+    const expected = {
+      id: '123',
+      name: 'microservice.executeTask',
+      data: 'withThisParam'
+    }
+
+    const creator = createCommand('microservice.executeTask')
+    const result = creator('123', 'withThisParam')
+
+    expect(result).toMatchObject(expected)
+    expect(result).toBeInstanceOf(Command)
+  })
+
+  it(`builds valid query instances`, () => {
+    const expected = {
+      id: '123',
+      name: 'microservice.fetchSomething',
+      data: 'withThisParam'
+    }
+
+    const creator = createQuery('microservice.fetchSomething')
+    const result = creator('123', 'withThisParam')
+
+    expect(result).toMatchObject(expected)
+    expect(result).toBeInstanceOf(Query)
+  })
+
+  it(`builds valid query instances`, () => {
+    const expected = {
+      id: '123',
+      name: 'microservice.somethingHappened',
+      data: 'withThisData'
+    }
+
+    const creator = createEvent('microservice.somethingHappened')
+    const result = creator('123', 'withThisData')
+
+    expect(result).toMatchObject(expected)
+    expect(result).toBeInstanceOf(Event)
+  })
+})