fix(api): create social post endpoint

Author: ascariandrea

compose.reverse-proxy.yml

@@ -19,14 +19,12 @@ services:
   telegram-bot-api:
     image: aiogram/telegram-bot-api:latest
     env_file:
-      - ./services/api/.env.local
+      - ./services/worker/.env.local
     environment:
       # TELEGRAM_STAT: 1
       TELEGRAM_VERBOSITY: 1
       TELEGRAM_LOCAL: 1
       TELEGRAM_HTTP_IP_ADDRESS: "[::]"
-      # VIRTUAL_HOST: telegram.liexp.dev
-      # VIRTUAL_PORT: 8081
     tty: false
     stdin_open: true
     volumes:

packages/@liexp/backend/src/flows/social-post/fetchSocialPostRelations.flow.ts

@@ -41,20 +41,20 @@ export const fetchSocialPostRelations = <
         groups: pipe(
           sp.groups,
           O.fromNullable,
-          O.filter((g) => g.length > 0),
           O.map((a) => (Schema.is(Schema.Array(UUID))(a) ? a : [])),
+          O.filter((g) => g.length > 0),
         ),
         keywords: pipe(
           sp.keywords,
           O.fromNullable,
-          O.filter((k) => k.length > 0),
           O.map((a) => (Schema.is(Schema.Array(UUID))(a) ? a : [])),
+          O.filter((k) => k.length > 0),
         ),
         media: pipe(
           sp.media,
           O.fromNullable,
-          O.filter((m) => m.length > 0),
           O.map((a) => (Schema.is(Schema.Array(UUID))(a) ? a : [])),
+          O.filter((k) => k.length > 0),
         ),
         links: O.none(),
         groupsMembers: O.none(),

packages/@liexp/backend/src/flows/social-post/getSocialPostById.flow.ts

@@ -47,6 +47,12 @@ export const getSocialPostById =
         content: {
           ...sp.content,
           ...relations,
+          media: relations.media.map((m) => ({
+            ...m,
+            links: [],
+            areas: [],
+            events: [],
+          })),
         },
         id,
       })),

packages/@liexp/backend/src/io/socialPost.io.ts

@@ -1,4 +1,4 @@
-import { pipe, fp, flow } from "@liexp/core/lib/fp/index.js";
+import { flow, fp, pipe } from "@liexp/core/lib/fp/index.js";
 import {
   type _DecodeError,
   DecodeError,
@@ -88,6 +88,8 @@ const decodeSocialPost = (
         ig: socialPost.result?.ig ?? undefined,
       },
       scheduledAt: socialPost.scheduledAt?.toISOString(),
+      createdAt: socialPost.createdAt.toISOString(),
+      updatedAt: socialPost.updatedAt.toISOString(),
     })),
     E.chain(
       flow(

packages/@liexp/backend/src/providers/tg/tg.provider.ts

@@ -95,6 +95,7 @@ export const TGBotProvider = (
       ),
     )
     .join(":");
+
   logger.debug.log("tg bot provider %O", {
     ...opts,
     token: encryptedToken,

packages/@liexp/backend/src/utils/data-source.ts

@@ -89,9 +89,6 @@ export const getDataSource = (
 ): TE.TaskEither<DBError, DataSource> => {
   return TE.tryCatch(async () => {
     const dataSource = new DataSource(config);
-    // if (!dataSource.isInitialized) {
-    //   await dataSource.initialize();
-    // }
     return Promise.resolve(dataSource);
   }, toDBError());
 };

packages/@liexp/shared/src/io/http/SocialPost.ts

@@ -110,7 +110,7 @@ export const CreateSocialPost = Schema.Struct({
   useReply: Schema.Boolean,
   media: SocialPostContentMedia,
   actors: Schema.Array(Actor.omit("excerpt", "body")),
-  groups: Schema.Array(Group),
+  groups: Schema.Array(Group.omit("excerpt", "body")),
   keywords: Schema.Array(Keyword.omit("socialPosts")),
   platforms: Schema.Record({ key: SocialPlatform, value: Schema.Boolean }),
   schedule: Schema.Union(Schema.Number, Schema.Undefined),
@@ -136,6 +136,8 @@ export const SocialPost = Schema.Struct({
   status: SocialPostStatus,
   result: SocialPostPublishResult,
   scheduledAt: Schema.Date,
+  createdAt: Schema.Date,
+  updatedAt: Schema.Date,
 }).annotations({
   title: "SocialPost",
 });

packages/@liexp/shared/src/io/http/index.ts

@@ -18,6 +18,7 @@ import * as Query from "./Query/index.js";
 import * as Queue from "./Queue/index.js";
 import { ResourcesNames } from "./ResourcesNames.js";
 import * as Setting from "./Setting.js";
+import * as SocialPost from "./SocialPost.js";
 import * as Stats from "./Stats.js";
 import * as Story from "./Story.js";
 import * as User from "./User.js";
@@ -44,6 +45,7 @@ export {
   Query,
   Queue,
   ResourcesNames,
+  SocialPost,
   Stats,
   Story,
   User,

packages/@liexp/test/src/arbitrary/SocialPost.arbitrary.ts

@@ -0,0 +1,18 @@
+import * as http from "@liexp/shared/lib/io/http/index.js";
+import { Arbitrary } from "effect";
+import fc from "fast-check";
+import { UUIDArb } from "./common/UUID.arbitrary.js";
+
+export const CreateSocialPostArb = Arbitrary.make(
+  http.SocialPost.CreateSocialPost.omit("actors", "groups", "keywords"),
+).map((post) => ({ ...post, actors: [], groups: [], keywords: [], media: [] }));
+
+export const SocialPostArb = Arbitrary.make(
+  http.SocialPost.SocialPost.omit("id"),
+).map((p) => ({
+  ...p,
+  id: fc.sample(UUIDArb, 1)[0],
+  createdAt: new Date(),
+  updatedAt: new Date(),
+  deletedAt: undefined,
+}));

services/admin-web/src/pages/actors/ActorEdit.tsx

@@ -41,7 +41,7 @@ import { type Option } from "effect/Option";
 import * as O from "fp-ts/lib/Option.js";
 import { pipe } from "fp-ts/lib/function.js";
 import * as React from "react";
-import { transformActor } from "./ActorCreate";
+import { transformActor } from "./ActorCreate.js";
 
 const EditTitle: React.FC = () => {
   const record = useRecordContext();

services/api/.env.test

@@ -1,6 +1,7 @@
 TZ=UTC
 
 # DEBUG="-@liexp:*,-@liexp:*:debug" # "-"
+# DEBUG="@liexp:*,-@liexp:test-db-manager:*"
 DEBUG="-"
 
 NODE_ENV=test
@@ -50,4 +51,4 @@ TG_BOT_BASE_API_URL=http://localhost:9876
 IG_USERNAME=invalid
 IG_PASSWORD=invalid
 
-OPENAI_URL=http://invalid-openai-url/v1
+OPENAI_URL=http://invalid-openai-url/v1

services/api/src/app/index.ts

@@ -25,7 +25,6 @@ export const makeApp = (ctx: ServerContext): express.Express => {
   );
 
   app.use(
-    // eslint-disable-next-line @typescript-eslint/no-misused-promises
     jwt({ secret: ctx.env.JWT_SECRET, algorithms: ["HS256"] }).unless({
       path: [
         { url: "/v1/links/submit", method: "POST" },

services/api/src/routes/social-posts/__tests__/createSocialPost.e2e.ts

@@ -0,0 +1,121 @@
+import { MediaEntity } from "@liexp/backend/lib/entities/Media.entity.js";
+import { toMediaEntity } from "@liexp/backend/lib/test/utils/entities/index.js";
+import { uuid } from "@liexp/shared/lib/io/http/Common/UUID.js";
+import { ImageType } from "@liexp/shared/lib/io/http/Media/MediaType.js";
+import {
+  type CreateSocialPost,
+  TO_PUBLISH,
+} from "@liexp/shared/lib/io/http/SocialPost.js";
+import { throwTE } from "@liexp/shared/lib/utils/task.utils.js";
+import * as tests from "@liexp/test";
+import { MediaArb } from "@liexp/test/lib/arbitrary/Media.arbitrary.js";
+import { CreateSocialPostArb } from "@liexp/test/lib/arbitrary/SocialPost.arbitrary.js";
+import { differenceInMinutes, parseISO } from "date-fns";
+import { describe, beforeAll, test, expect } from "vitest";
+import { type AppTest, GetAppTest } from "../../../../test/AppTest.js";
+
+describe("Create Social Post", () => {
+  let Test: AppTest,
+    authorizationToken: string,
+    socialPostData: CreateSocialPost;
+
+  beforeAll(async () => {
+    Test = await GetAppTest();
+    authorizationToken = `Bearer ${Test.ctx.jwt.signUser({
+      id: "1",
+    } as any)()}`;
+  });
+
+  beforeEach(() => {
+    [socialPostData] = tests.fc
+      .sample(CreateSocialPostArb, 1)
+      .map((post) => ({ ...post, schedule: undefined }));
+  });
+
+  test("Should create a social post with scheduledAt", async () => {
+    const now = new Date();
+    const type = "events";
+    const id = uuid();
+
+    const response = await Test.req
+      .post(`/v1/social-posts/${type}/${id}`)
+      .set("Authorization", authorizationToken)
+      .send(socialPostData);
+
+    expect(response.status).toEqual(201);
+
+    const { schedule, content, ...expectedSocialPostData } = socialPostData;
+    expect(response.body.data).toMatchObject({
+      ...expectedSocialPostData,
+      status: TO_PUBLISH.literals[0],
+    });
+    expect(
+      differenceInMinutes(parseISO(response.body.data.scheduledAt), now),
+    ).toBe(0);
+  });
+
+  test("Should create a social post to publish on TG", async () => {
+    const type = "events";
+    const id = uuid();
+
+    const response = await Test.req
+      .post(`/v1/social-posts/${type}/${id}`)
+      .set("Authorization", authorizationToken)
+      .send({
+        ...socialPostData,
+        platforms: {
+          IG: false,
+          TG: true,
+        },
+      });
+
+    expect(response.status).toEqual(201);
+    expect(response.body.data.platforms).toMatchObject({
+      TG: true,
+      IG: false,
+    });
+  });
+
+  test("Should create a social post with single media", async () => {
+    const type = "events";
+    const id = uuid();
+
+    const [media] = tests.fc.sample(MediaArb, 1).map((m) => ({
+      ...m,
+      type: ImageType.members[0].literals[0],
+      events: [],
+      links: [],
+      keywords: [],
+      areas: [],
+      featuredInStories: [],
+      socialPosts: [],
+    }));
+
+    await throwTE(Test.ctx.db.save(MediaEntity, [media]));
+
+    const response = await Test.req
+      .post(`/v1/social-posts/${type}/${id}`)
+      .set("Authorization", authorizationToken)
+      .send({
+        ...socialPostData,
+        media: [
+          {
+            id: media.id,
+            type: "photo",
+            media: media.location,
+            thumbnail: media.thumbnail,
+          },
+        ],
+      });
+
+    expect(response.status).toEqual(201);
+    expect(response.body.data).toMatchObject({
+      media: [
+        {
+          id: media.id,
+          type: "photo",
+        },
+      ],
+    });
+  });
+});