feat: event support

example.env

@@ -11,6 +11,9 @@ DATABASE_IMPLEMENTATION="mongodb"
 MONGODB_CONNECTION_STRING="mongodb://development:development@localhost:27017"
 MONGODB_DATABASE_NAME="comify"
 
+# EVENT BROKER (memory)
+EVENT_BROKER_IMPLEMENTATION="memory"
+
 # FILE STORE (memory | minio)
 FILE_STORE_IMPLEMENTATION="minio"
 MINIO_END_POINT="localhost"

package.json

@@ -25,12 +25,12 @@
     "standalone": "jitar start --env-file=development.env --service=services/standalone.json --http-body-limit=512000",
     "repository": "jitar start --env-file=development.env --service=services/repository.json",
     "proxy": "jitar start --env-file=development.env --service=services/proxy.json --http-body-limit=512000",
-    "gateway": "jitar start --env-file=development.env --service=services/gateway.json --http-body-limit=512000",
-    "bff": "jitar start --env-file=development.env --service=services/bff.json --http-body-limit=512000",
-    "notification": "jitar start --env-file=development.env --service=services/notification.json --http-body-limit=512000",
-    "notification2": "jitar start --env-file=development.env --service=services/notification2.json --http-body-limit=512000",
-    "reads": "jitar start --env-file=development.env --service=services/reads.json --http-body-limit=512000",
-    "writes": "jitar start --env-file=development.env --service=services/writes.json --http-body-limit=512000"
+    "gateway": "jitar start --env-file=development.env --service=services/gateway.json --http-body-limit=640000",
+    "bff": "jitar start --env-file=development.env --service=services/bff.json --http-body-limit=640000",
+    "notification": "jitar start --env-file=development.env --service=services/notification.json --http-body-limit=640000",
+    "notification2": "jitar start --env-file=development.env --service=services/notification2.json --http-body-limit=640000",
+    "reads": "jitar start --env-file=development.env --service=services/reads.json --http-body-limit=640000",
+    "writes": "jitar start --env-file=development.env --service=services/writes.json --http-body-limit=640000"
   },
   "files": [
     "CHANGELOG.md",

resources/global.json

@@ -1,6 +1,7 @@
 [
     "./integrations/authentication",
     "./integrations/database",
+    "./integrations/eventbroker",
     "./integrations/filestore",
     "./integrations/logging",
     "./integrations/notification"

segments/bff.json

@@ -5,31 +5,37 @@
 
     "./domain/creator/getByNicknameAggregated": { "default": {  "access": "public" } },
     "./domain/creator/getMeAggregated": { "default": {  "access": "public" } },
-    "./domain/creator/updateFullName": { "default": {  "access": "public" }},
-    "./domain/creator/updateNickname": { "default": {  "access": "public" }},
+    "./domain/creator/updateFullName": { "default": {  "access": "public" } },
+    "./domain/creator/updateNickname": { "default": {  "access": "public" } },
 
+    "./domain/creator.metrics/create": { "subscriptions": {  "access": "private" } },
+    "./domain/creator.metrics/updateFollowers": { "subscriptions": {  "access": "private" } },
+    "./domain/creator.metrics/updateFollowing": { "subscriptions": {  "access": "private" } },
+    "./domain/creator.metrics/updatePosts": { "subscriptions": {  "access": "private" } },
+
+    "./domain/notification/notify": { "subscriptions": {  "access": "private" } },
     "./domain/notification/getRecentAggregated": { "default": {  "access": "public" } },
     "./domain/notification/getByIdAggregated": { "default": {  "access": "public" } },
 
-    "./domain/post/add": { "default": {  "access": "public" } },
+    "./domain/post/create": { "default": {  "access": "private" }, "subscribe": {  "access": "private" } },
+    "./domain/post/createWithComic": { "default": {  "access": "public" } },
+    "./domain/post/createWithComment": { "default": {  "access": "public" } },
     "./domain/post/exploreAggregated": { "default": {  "access": "public" } },
     "./domain/post/getByIdAggregated": { "default": {  "access": "public" } },
+    "./domain/post/getByParentAggregated": { "default": {  "access": "public" } },
     "./domain/post/getByCreatorAggregated": { "default": {  "access": "public" } },
-    "./domain/post/getAllAggregated": { "default": { "access": "public"}},
     "./domain/post/getByFollowingAggregated": { "default": {  "access": "public" } },
-    "./domain/post/remove": { "default": {  "access": "public" } },
-    "./domain/post/toggleRating": { "default": {  "access": "public" } },
+    "./domain/post/getRecommendedAggregated": { "default": { "access": "public"}},
+    "./domain/post/remove": { "default": {  "access": "public" }, "subscribe": {  "access": "private" } },
+
+    "./domain/post.metrics/create": { "subscriptions": {  "access": "private" } },
+    "./domain/post.metrics/updateRatings": { "subscriptions": {  "access": "private" } },
+    "./domain/post.metrics/updateReactions": { "subscriptions": {  "access": "private" } },
+
+    "./domain/rating/toggle": { "default": { "access": "public" }, "subscribe": {  "access": "private" } },
 
-    "./domain/reaction/createWithComic": { "default": {  "access": "public" } },
-    "./domain/reaction/createWithComment": { "default": {  "access": "public" } },
-    "./domain/reaction/getByIdAggregated": { "default": {  "access": "public" } },
-    "./domain/reaction/getByPostAggregated": { "default": {  "access": "public" } },
-    "./domain/reaction/getByReactionAggregated": { "default": { "access": "public"} },
-    "./domain/reaction/remove": { "default": {  "access": "public" } },
-    "./domain/reaction/toggleRating": { "default": {  "access": "public" } },
-
     "./domain/relation/exploreAggregated": { "default": {  "access": "public" } },
-    "./domain/relation/establish": { "default": { "access": "public" }},
+    "./domain/relation/establish": { "default": { "access": "public" }, "subscribe": {  "access": "private" } },
     "./domain/relation/getAggregated": { "default": {  "access": "public" } },
     "./domain/relation/getFollowersAggregated": { "default": {  "access": "public" } },
     "./domain/relation/getFollowingAggregated": { "default": {  "access": "public" } }

segments/reads.json

@@ -8,20 +8,22 @@
     "./domain/creator/getByNickname": { "default": {  "access": "protected" } },
     "./domain/creator/getMe": { "default": {  "access": "protected" } },
 
+    "./domain/creator.metrics/getByCreator": { "default": {  "access": "protected" } },
+
     "./domain/image/getById": { "default": {  "access": "protected" } },
 
     "./domain/post/explore": { "default": {  "access": "protected" } },
-    "./domain/post/getAll": { "default": {  "access": "protected" } },
     "./domain/post/getByCreator": { "default": {  "access": "protected" } },
     "./domain/post/getByFollowing": { "default": {  "access": "protected" } },
     "./domain/post/getById": { "default": {  "access": "protected" } },
+    "./domain/post/getByParent": { "default": {  "access": "protected" } },
+    "./domain/post/getRecommended": { "default": {  "access": "protected" } },
 
-    "./domain/rating/exists": { "default": {  "access": "protected" } },
+    "./domain/post.metrics/getByPost": { "default": {  "access": "protected" } },
 
-    "./domain/reaction/getById": { "default": {  "access": "protected" } },
-    "./domain/reaction/getByPost": { "default": {  "access": "protected" } },
+    "./domain/rating/exists": { "default": {  "access": "protected" } },
 
-    "./domain/relation/establish": { "default": {  "access": "protected" } },
+    "./domain/relation/exists": { "default": {  "access": "protected" } },
     "./domain/relation/explore": { "default": {  "access": "protected" } },
     "./domain/relation/get": { "default": {  "access": "protected" } },
     "./domain/relation/getFollowers": { "default": {  "access": "protected" } },

segments/writes.json

@@ -8,20 +8,21 @@
     "./domain/creator/create": { "default": {  "access": "protected" } },
     "./domain/creator/update": { "default": {  "access": "protected" } },
 
+    "./domain/creator.metrics/create/insertData": { "default": {  "access": "protected" } },
+
     "./domain/image/save": { "default": {  "access": "protected" } },
     "./domain/image/erase": { "default": {  "access": "protected" } },
 
-    "./domain/post/create": { "default": {  "access": "protected" } },
+    "./domain/post/create/insertData": { "default": {  "access": "protected" } },
     "./domain/post/erase": { "default": {  "access": "protected" } },
     "./domain/post/remove/deleteData": { "default": { "access": "protected" }},
     "./domain/post/update": { "default": {  "access": "protected" } },
 
-    "./domain/rating/update": { "default": {  "access": "protected" } },
+    "./domain/post.metrics/create/insertData": { "default": {  "access": "protected" } },
 
-    "./domain/reaction/create": { "default": {  "access": "protected" } },
-    "./domain/reaction/remove/deleteData": { "default": {  "access": "protected" } },
-    "./domain/reaction/update": { "default": {  "access": "protected" } },
+    "./domain/rating/create": { "default": {  "access": "protected" } },
+    "./domain/rating/erase": { "default": {  "access": "protected" } },
 
-    "./domain/relation/establish/insertData": { "default": {  "access": "protected" } },
-    "./domain/relation/establish/eraseData": { "default": {  "access": "protected" } }
+    "./domain/relation/create": { "default": {  "access": "protected" } },
+    "./domain/relation/erase": { "default": {  "access": "protected" } }
 }

src/domain/creator.metrics/create/create.ts

@@ -0,0 +1,10 @@
+
+import createData from './createData';
+import insertData from './insertData';
+
+export default async function create(creatorId: string): Promise<string>
+{
+    const data = createData(creatorId);
+
+    return insertData(data);
+}

src/domain/creator.metrics/create/createData.ts

@@ -0,0 +1,16 @@
+
+import { generateId } from '^/integrations/utilities/crypto';
+
+import type { DataModel } from '../types';
+
+export default function createData(creatorId: string): DataModel
+{
+    return {
+        id: generateId(),
+        creatorId,
+        posts: 0,
+        followers: 0,
+        following: 0,
+        popularity: 0
+    };
+}

src/domain/creator.metrics/create/index.ts

@@ -0,0 +1,4 @@
+
+export { default } from './create';
+
+export { default as subscriptions } from './subscriptions';

src/domain/reaction/create/insertData.ts → src/domain/creator.metrics/create/insertData.ts

@@ -2,9 +2,9 @@
 import database from '^/integrations/database';
 
 import { RECORD_TYPE } from '../definitions';
-import { DataModel } from '../types';
+import type { DataModel } from '../types';
 
 export default async function insertData(data: DataModel): Promise<string>
 {
-    return database.createRecord(RECORD_TYPE, { ...data, deleted: false });
+    return database.createRecord(RECORD_TYPE, { ...data });
 }

src/domain/creator.metrics/create/subscriptions.ts

@@ -0,0 +1,13 @@
+
+import { subscribe as subscribeToCreatorRegistered } from '^/domain/creator/register';
+
+import create from './create';
+
+async function subscribe(): Promise<void>
+{
+    await Promise.all([
+        subscribeToCreatorRegistered(({ creatorId }) => create(creatorId)),
+    ]);
+}
+
+export default subscribe();

src/domain/creator.metrics/definitions.ts

@@ -0,0 +1,3 @@
+
+export const RECORD_TYPE = 'creator.metrics';
+export const EVENT_CHANNEL = 'creator.metrics';

src/domain/creator.metrics/getByCreator/CreatorMetricsNotFound.ts

@@ -0,0 +1,10 @@
+
+import { NotFound } from '^/integrations/runtime';
+
+export default class CreatorMetricsNotFound extends NotFound
+{
+    constructor()
+    {
+        super('Creator metrics not found');
+    }
+}

src/domain/creator.metrics/getByCreator/getByCreator.ts

@@ -0,0 +1,21 @@
+
+import database from '^/integrations/database';
+
+import { RECORD_TYPE } from '../definitions';
+import type { DataModel } from '../types';
+
+import CreatorMetricsNotFound from './CreatorMetricsNotFound';
+
+export default async function getByCreator(creatorId: string): Promise<DataModel>
+{
+    const query = { creatorId: { EQUALS: creatorId } };
+
+    const data = database.findRecord(RECORD_TYPE, query) as Promise<DataModel>;
+
+    if (data === undefined)
+    {
+        throw new CreatorMetricsNotFound();
+    }
+
+    return data;
+}

src/domain/creator.metrics/getByCreator/index.ts

@@ -0,0 +1,4 @@
+
+export { default } from './getByCreator';
+
+export { default as CreatorMetricsNotFound } from './CreatorMetricsNotFound';

src/domain/reaction/index.ts → src/domain/creator.metrics/index.ts

@@ -2,5 +2,3 @@
 export { RECORD_TYPE } from './definitions';
 
 export type { DataModel } from './types';
-
-export { default as ReactionNotFound } from './ReactionNotFound';

src/domain/creator.metrics/types.ts

@@ -0,0 +1,13 @@
+
+import { BaseDataModel, CountOperation } from '../types';
+
+type DataModel = BaseDataModel &
+{
+    readonly creatorId: string;
+    readonly posts: number;
+    readonly followers: number;
+    readonly following: number;
+    readonly popularity: number;
+};
+
+export type { CountOperation, DataModel };

src/domain/creator.metrics/updateFollowers/index.ts

@@ -0,0 +1,4 @@
+
+export { default } from './updateFollowers';
+
+export { default as subscriptions } from './subscriptions';

src/domain/creator.metrics/updateFollowers/subscriptions.ts

@@ -0,0 +1,13 @@
+
+import { subscribe as subscribeToRelationEstablished } from '^/domain/relation/establish';
+
+import updateFollowerCount from './updateFollowers';
+
+async function subscribe(): Promise<void>
+{
+    await Promise.all([
+        subscribeToRelationEstablished(({ followingId }) => updateFollowerCount(followingId, 'increase'))
+    ]);
+}
+
+export default subscribe();

src/domain/creator.metrics/updateFollowers/updateFollowers.ts

@@ -0,0 +1,18 @@
+
+import getByCreator from '../getByCreator';
+import update from '../update';
+
+import type { CountOperation } from '../types';
+
+export default async function updateFollowers(creatorId: string, operation: CountOperation): Promise<number>
+{
+    const data = await getByCreator(creatorId);
+
+    const followers = operation === 'increase'
+        ? data.followers + 1
+        : data.followers - 1;
+
+    await update(data.id, { followers });
+
+    return followers;
+}

src/domain/creator.metrics/updateFollowing/index.ts

@@ -0,0 +1,4 @@
+
+export { default } from './updateFollowing';
+
+export { default as subscriptions } from './subscriptions';

src/domain/creator.metrics/updateFollowing/subscriptions.ts

@@ -0,0 +1,13 @@
+
+import { subscribe as subscribeToRelationEstablished } from '^/domain/relation/establish';
+
+import updateFollowing from './updateFollowing';
+
+async function subscribe(): Promise<void>
+{
+    await Promise.all([
+        subscribeToRelationEstablished(({ followerId }) => updateFollowing(followerId, 'increase'))
+    ]);
+}
+
+export default subscribe();

src/domain/creator.metrics/updateFollowing/updateFollowing.ts

@@ -0,0 +1,18 @@
+
+import getByCreator from '../getByCreator';
+import update from '../update';
+
+import type { CountOperation } from '../types';
+
+export default async function updateFollowing(creatorId: string, operation: CountOperation): Promise<number>
+{
+    const data = await getByCreator(creatorId);
+
+    const following = operation === 'increase'
+        ? data.following + 1
+        : data.following - 1;
+
+    await update(data.id, { following });
+
+    return following;
+}

src/domain/creator.metrics/updatePosts/index.ts

@@ -0,0 +1,4 @@
+
+export { default } from './updatePosts';
+
+export { default as subscriptions } from './subscriptions';

src/domain/creator.metrics/updatePosts/subscriptions.ts

@@ -0,0 +1,28 @@
+
+import { subscribe as subscribeToPostCreated } from '^/domain/post/create';
+import { subscribe as subscribeToPostRemoved } from '^/domain/post/remove';
+
+import updatePosts from './updatePosts';
+
+async function subscribe(): Promise<void>
+{
+    await Promise.all([
+
+        subscribeToPostCreated(({ creatorId, parentId }) =>
+        {
+            if (parentId !== undefined) return;
+
+            return updatePosts(creatorId, 'increase');
+        }),
+
+        subscribeToPostRemoved(({ creatorId, parentId }) =>
+        {
+            if (parentId !== undefined) return;
+
+            return updatePosts(creatorId, 'decrease');
+        })
+
+    ]);
+}
+
+export default subscribe();

src/domain/creator.metrics/updatePosts/updatePosts.ts

@@ -0,0 +1,18 @@
+
+import getByCreator from '../getByCreator';
+import update from '../update';
+
+import type { CountOperation } from '../types';
+
+export default async function updatePosts(creatorId: string, operation: CountOperation): Promise<number>
+{
+    const data = await getByCreator(creatorId);
+
+    const posts = operation === 'increase'
+        ? data.posts + 1
+        : data.posts - 1;
+
+    await update(data.id, { posts });
+
+    return posts;
+}