-
-
-
-
-
+ ))}
+
);
};
diff --git a/libraries/nestjs-libraries/src/database/prisma/database.module.ts b/libraries/nestjs-libraries/src/database/prisma/database.module.ts
index c015ed8e..736c49b1 100644
--- a/libraries/nestjs-libraries/src/database/prisma/database.module.ts
+++ b/libraries/nestjs-libraries/src/database/prisma/database.module.ts
@@ -25,6 +25,8 @@ import { ItemUserService } from '@gitroom/nestjs-libraries/database/prisma/marke
import { MessagesService } from '@gitroom/nestjs-libraries/database/prisma/marketplace/messages.service';
import { MessagesRepository } from '@gitroom/nestjs-libraries/database/prisma/marketplace/messages.repository';
import { StripeService } from '@gitroom/nestjs-libraries/services/stripe.service';
+import { ExtractContentService } from '@gitroom/nestjs-libraries/openai/extract.content.service';
+import { OpenaiService } from '@gitroom/nestjs-libraries/openai/openai.service';
@Global()
@Module({
@@ -57,6 +59,8 @@ import { StripeService } from '@gitroom/nestjs-libraries/services/stripe.service
MessagesService,
CommentsService,
IntegrationManager,
+ ExtractContentService,
+ OpenaiService,
EmailService,
],
get exports() {
diff --git a/libraries/nestjs-libraries/src/database/prisma/posts/posts.repository.ts b/libraries/nestjs-libraries/src/database/prisma/posts/posts.repository.ts
index 46efc3ad..dc979553 100644
--- a/libraries/nestjs-libraries/src/database/prisma/posts/posts.repository.ts
+++ b/libraries/nestjs-libraries/src/database/prisma/posts/posts.repository.ts
@@ -38,6 +38,7 @@ export class PostsRepository {
name: true,
providerIdentifier: true,
picture: true,
+ type: true,
},
},
},
@@ -62,9 +63,10 @@ export class PostsRepository {
getPosts(orgId: string, query: GetPostsDto) {
const date = dayjs().year(query.year).isoWeek(query.week);
- const startDate = date.startOf('isoWeek').toDate();
- const endDate = date.endOf('isoWeek').toDate();
+ const startDate = date.startOf('week').toDate();
+ const endDate = date.endOf('week').toDate();
+ console.log(startDate, endDate);
return this._post.model.post.findMany({
where: {
OR: [
diff --git a/libraries/nestjs-libraries/src/database/prisma/posts/posts.service.ts b/libraries/nestjs-libraries/src/database/prisma/posts/posts.service.ts
index cf19893b..c7b0dcbb 100644
--- a/libraries/nestjs-libraries/src/database/prisma/posts/posts.service.ts
+++ b/libraries/nestjs-libraries/src/database/prisma/posts/posts.service.ts
@@ -7,9 +7,15 @@ import { IntegrationManager } from '@gitroom/nestjs-libraries/integrations/integ
import { Integration, Post, Media, From } from '@prisma/client';
import { GetPostsDto } from '@gitroom/nestjs-libraries/dtos/posts/get.posts.dto';
import { NotificationService } from '@gitroom/nestjs-libraries/database/prisma/notifications/notification.service';
-import { capitalize } from 'lodash';
+import { capitalize, chunk, shuffle } from 'lodash';
import { MessagesService } from '@gitroom/nestjs-libraries/database/prisma/marketplace/messages.service';
import { StripeService } from '@gitroom/nestjs-libraries/services/stripe.service';
+import { GeneratorDto } from '@gitroom/nestjs-libraries/dtos/generator/generator.dto';
+import { ExtractContentService } from '@gitroom/nestjs-libraries/openai/extract.content.service';
+import { OpenaiService } from '@gitroom/nestjs-libraries/openai/openai.service';
+import { CreateGeneratedPostsDto } from '@gitroom/nestjs-libraries/dtos/generator/create.generated.posts.dto';
+import { IntegrationService } from '@gitroom/nestjs-libraries/database/prisma/integrations/integration.service';
+import { makeId } from '@gitroom/nestjs-libraries/services/make.is';
type PostWithConditionals = Post & {
integration?: Integration;
@@ -24,7 +30,10 @@ export class PostsService {
private _integrationManager: IntegrationManager,
private _notificationService: NotificationService,
private _messagesService: MessagesService,
- private _stripeService: StripeService
+ private _stripeService: StripeService,
+ private _extractContentService: ExtractContentService,
+ private _openAiService: OpenaiService,
+ private _integrationService: IntegrationService
) {}
async getPostsRecursively(
@@ -257,7 +266,11 @@ export class PostsService {
throw new Error('You can not add a post to this publication');
}
const getOrgByOrder = await this._messagesService.getOrgByOrder(order);
- const submit = await this._postRepository.submit(id, order, getOrgByOrder?.messageGroup?.buyerOrganizationId!);
+ const submit = await this._postRepository.submit(
+ id,
+ order,
+ getOrgByOrder?.messageGroup?.buyerOrganizationId!
+ );
const messageModel = await this._messagesService.createNewMessage(
submit?.submittedForOrder?.messageGroupId || '',
From.SELLER,
@@ -432,4 +445,101 @@ export class PostsService {
);
}
}
+
+ async loadPostContent(postId: string) {
+ const post = await this._postRepository.getPostById(postId);
+ if (!post) {
+ return '';
+ }
+
+ return post.content;
+ }
+
+ async generatePosts(orgId: string, body: GeneratorDto) {
+ const content = body.url
+ ? await this._extractContentService.extractContent(body.url)
+ : await this.loadPostContent(body.post);
+
+ const value = body.url
+ ? await this._openAiService.extractWebsiteText(content!)
+ : await this._openAiService.generatePosts(content!);
+ return { list: value };
+ }
+
+ async generatePostsDraft(orgId: string, body: CreateGeneratedPostsDto) {
+ const getAllIntegrations = (
+ await this._integrationService.getIntegrationsList(orgId)
+ ).filter((f) => !f.disabled && f.providerIdentifier !== 'reddit');
+
+ // const posts = chunk(body.posts, getAllIntegrations.length);
+ const allDates = dayjs()
+ .isoWeek(body.week)
+ .year(body.year)
+ .startOf('isoWeek');
+
+ const dates = [...new Array(7)].map((_, i) => {
+ return allDates.add(i, 'day').format('YYYY-MM-DD');
+ });
+
+ const findTime = (): string => {
+ const totalMinutes = Math.floor(Math.random() * 144) * 10;
+
+ // Convert total minutes to hours and minutes
+ const hours = Math.floor(totalMinutes / 60);
+ const minutes = totalMinutes % 60;
+
+ // Format hours and minutes to always be two digits
+ const formattedHours = hours.toString().padStart(2, '0');
+ const formattedMinutes = minutes.toString().padStart(2, '0');
+ const randomDate =
+ shuffle(dates)[0] + 'T' + `${formattedHours}:${formattedMinutes}:00`;
+
+ if (dayjs(randomDate).isBefore(dayjs())) {
+ return findTime();
+ }
+
+ return randomDate;
+ };
+
+ for (const integration of getAllIntegrations) {
+ for (const toPost of body.posts) {
+ const group = makeId(10);
+ const randomDate = findTime();
+
+ await this.createPost(orgId, {
+ type: 'draft',
+ date: randomDate,
+ order: '',
+ posts: [
+ {
+ group,
+ integration: {
+ id: integration.id,
+ },
+ settings: {
+ subtitle: '',
+ title: '',
+ tags: [],
+ subreddit: [],
+ },
+ value: [
+ ...toPost.list.map((l) => ({
+ id: '',
+ content: l.post,
+ image: [],
+ })),
+ {
+ id: '',
+ content: `Check out the full story here:\n${
+ body.postId || body.url
+ }`,
+ image: [],
+ },
+ ],
+ },
+ ],
+ });
+ }
+ }
+ }
}
diff --git a/libraries/nestjs-libraries/src/dtos/generator/create.generated.posts.dto.ts b/libraries/nestjs-libraries/src/dtos/generator/create.generated.posts.dto.ts
new file mode 100644
index 00000000..da639677
--- /dev/null
+++ b/libraries/nestjs-libraries/src/dtos/generator/create.generated.posts.dto.ts
@@ -0,0 +1,52 @@
+import {
+ ArrayMinSize,
+ IsArray,
+ IsDefined,
+ IsNumber,
+ IsString,
+ ValidateIf,
+ ValidateNested,
+} from 'class-validator';
+import { Type } from 'class-transformer';
+
+class InnerPost {
+ @IsString()
+ @IsDefined()
+ post: string;
+}
+
+class PostGroup {
+ @IsArray()
+ @ArrayMinSize(1)
+ @ValidateNested({ each: true })
+ @Type(() => InnerPost)
+ @IsDefined()
+ list: InnerPost[];
+}
+
+export class CreateGeneratedPostsDto {
+ @IsArray()
+ @ArrayMinSize(1)
+ @ValidateNested({ each: true })
+ @Type(() => PostGroup)
+ @IsDefined()
+ posts: PostGroup[];
+
+ @IsNumber()
+ @IsDefined()
+ week: number;
+
+ @IsNumber()
+ @IsDefined()
+ year: number;
+
+ @IsString()
+ @IsDefined()
+ @ValidateIf((o) => !o.url)
+ url: string;
+
+ @IsString()
+ @IsDefined()
+ @ValidateIf((o) => !o.url)
+ postId: string;
+}
diff --git a/libraries/nestjs-libraries/src/dtos/generator/generator.dto.ts b/libraries/nestjs-libraries/src/dtos/generator/generator.dto.ts
new file mode 100644
index 00000000..2921ac87
--- /dev/null
+++ b/libraries/nestjs-libraries/src/dtos/generator/generator.dto.ts
@@ -0,0 +1,24 @@
+import {
+ IsDefined,
+ IsInt,
+ IsString,
+ IsUrl,
+ ValidateIf,
+ ValidateNested,
+} from 'class-validator';
+
+export class GeneratorDto {
+ @IsString()
+ @ValidateIf((o) => !o.post)
+ @IsUrl(
+ {},
+ {
+ message: 'Invalid URL',
+ }
+ )
+ url: string;
+
+ @ValidateIf((o) => !o.url)
+ @IsString()
+ post: string;
+}
diff --git a/libraries/nestjs-libraries/src/openai/extract.content.service.ts b/libraries/nestjs-libraries/src/openai/extract.content.service.ts
new file mode 100644
index 00000000..bf763cc2
--- /dev/null
+++ b/libraries/nestjs-libraries/src/openai/extract.content.service.ts
@@ -0,0 +1,90 @@
+import { Injectable } from '@nestjs/common';
+import { JSDOM } from 'jsdom';
+
+function findDepth(element: Element) {
+ let depth = 0;
+ let elementer = element;
+ while (elementer.parentNode) {
+ depth++;
+ // @ts-ignore
+ elementer = elementer.parentNode;
+ }
+ return depth;
+}
+
+@Injectable()
+export class ExtractContentService {
+ async extractContent(url: string) {
+ const load = await (await fetch(url)).text();
+ const dom = new JSDOM(load);
+
+ // only element that has a title
+ const allTitles = Array.from(dom.window.document.querySelectorAll('*'))
+ .filter((f) => {
+ return (
+ f.querySelector('h1') ||
+ f.querySelector('h2') ||
+ f.querySelector('h3') ||
+ f.querySelector('h4') ||
+ f.querySelector('h5') ||
+ f.querySelector('h6')
+ );
+ })
+ .reverse();
+
+ const findTheOneWithMostTitles = allTitles.reduce(
+ (all, current) => {
+ const depth = findDepth(current);
+ const calculate = ['h1', 'h2', 'h3', 'h4', 'h5', 'h6'].reduce(
+ (total, tag) => {
+ if (current.querySelector(tag)) {
+ return total + 1;
+ }
+ return total;
+ },
+ 0
+ );
+
+ if (calculate > all.total) {
+ return { total: calculate, depth, element: current };
+ }
+
+ if (depth > all.depth) {
+ return { total: calculate, depth, element: current };
+ }
+
+ return all;
+ },
+ { total: 0, depth: 0, element: null as Element | null }
+ );
+
+ return findTheOneWithMostTitles?.element?.textContent?.replace(/\n/g, ' ').replace(/ {2,}/g, ' ');
+ //
+ // const allElements = Array.from(
+ // dom.window.document.querySelectorAll('*')
+ // ).filter((f) => f.tagName !== 'SCRIPT');
+ // const findIndex = allElements.findIndex((element) => {
+ // return (
+ // ['h1', 'h2', 'h3', 'h4', 'h5', 'h6'].indexOf(
+ // element.tagName.toLowerCase()
+ // ) > -1
+ // );
+ // });
+ //
+ // if (!findIndex) {
+ // return false;
+ // }
+ //
+ // return allElements
+ // .slice(findIndex)
+ // .map((element) => element.textContent)
+ // .filter((f) => {
+ // const trim = f?.trim();
+ // return (trim?.length || 0) > 0 && trim !== '\n';
+ // })
+ // .map((f) => f?.trim())
+ // .join('')
+ // .replace(/\n/g, ' ')
+ // .replace(/ {2,}/g, ' ');
+ }
+}
diff --git a/libraries/nestjs-libraries/src/openai/openai.service.ts b/libraries/nestjs-libraries/src/openai/openai.service.ts
new file mode 100644
index 00000000..718e8185
--- /dev/null
+++ b/libraries/nestjs-libraries/src/openai/openai.service.ts
@@ -0,0 +1,90 @@
+import { Injectable } from '@nestjs/common';
+import OpenAI from 'openai';
+import { shuffle } from 'lodash';
+
+const openai = new OpenAI({
+ apiKey: process.env.OPENAI_API_KEY,
+});
+
+@Injectable()
+export class OpenaiService {
+ async generatePosts(content: string) {
+ const posts = (
+ await Promise.all([
+ openai.chat.completions.create({
+ messages: [
+ {
+ role: 'assistant',
+ content:
+ 'Generate a Twitter post from the content without emojis in the following JSON format: { "post": string } put it in an array with one element',
+ },
+ {
+ role: 'user',
+ content: content!,
+ },
+ ],
+ n: 5,
+ temperature: 1,
+ model: 'gpt-4o',
+ }),
+ openai.chat.completions.create({
+ messages: [
+ {
+ role: 'assistant',
+ content:
+ 'Generate a thread for social media in the following JSON format: Array<{ "post": string }> without emojis',
+ },
+ {
+ role: 'user',
+ content: content!,
+ },
+ ],
+ n: 5,
+ temperature: 1,
+ model: 'gpt-4o',
+ }),
+ ])
+ ).flatMap((p) => p.choices);
+
+ return shuffle(
+ posts.map((choice) => {
+ const { content } = choice.message;
+ const start = content?.indexOf('[')!;
+ const end = content?.lastIndexOf(']')!;
+ try {
+ return JSON.parse(
+ '[' +
+ content
+ ?.slice(start + 1, end)
+ .replace(/\n/g, ' ')
+ .replace(/ {2,}/g, ' ') +
+ ']'
+ );
+ } catch (e) {
+ console.log(content);
+ return [];
+ }
+ })
+ );
+ }
+ async extractWebsiteText(content: string) {
+ const websiteContent = await openai.chat.completions.create({
+ messages: [
+ {
+ role: 'assistant',
+ content:
+ 'Your take a full website text, and extract only the article content',
+ },
+ {
+ role: 'user',
+ content,
+ },
+ ],
+ model: 'gpt-4o',
+ });
+
+ const { content: articleContent } = websiteContent.choices[0].message;
+
+ return this.generatePosts(articleContent!);
+ }
+}
diff --git a/libraries/react-shared-libraries/src/form/select.tsx b/libraries/react-shared-libraries/src/form/select.tsx
index 61db635a..546fe9cf 100644
--- a/libraries/react-shared-libraries/src/form/select.tsx
+++ b/libraries/react-shared-libraries/src/form/select.tsx
@@ -1,24 +1,43 @@
-"use client";
+'use client';
-import {DetailedHTMLProps, FC, SelectHTMLAttributes, useMemo} from "react";
-import {clsx} from "clsx";
-import {useFormContext} from "react-hook-form";
+import { DetailedHTMLProps, FC, SelectHTMLAttributes, useMemo } from 'react';
+import { clsx } from 'clsx';
+import { useFormContext } from 'react-hook-form';
import interClass from '../helpers/inter.font';
+import { RegisterOptions } from 'react-hook-form/dist/types/validator';
-export const Select: FC
, HTMLSelectElement> & {error?: any, disableForm?: boolean, label: string, name: string}> = (props) => {
- const {label, className, disableForm, error, ...rest} = props;
- const form = useFormContext();
- const err = useMemo(() => {
- if (error) return error;
- if (!form || !form.formState.errors[props?.name!]) return;
- return form?.formState?.errors?.[props?.name!]?.message! as string;
- }, [form?.formState?.errors?.[props?.name!]?.message, error]);
+export const Select: FC<
+ DetailedHTMLProps<
+ SelectHTMLAttributes,
+ HTMLSelectElement
+ > & {
+ error?: any;
+ extraForm?: RegisterOptions;
+ disableForm?: boolean;
+ label: string;
+ name: string;
+ }
+> = (props) => {
+ const { label, className, disableForm, error, extraForm, ...rest } = props;
+ const form = useFormContext();
+ const err = useMemo(() => {
+ if (error) return error;
+ if (!form || !form.formState.errors[props?.name!]) return;
+ return form?.formState?.errors?.[props?.name!]?.message! as string;
+ }, [form?.formState?.errors?.[props?.name!]?.message, error]);
- return (
-
-
{label}
-
-
{err || <> }
-
+
{label}
+
+
{err || <> }
+
+ Your posts have been scheduled as drafts.
+