Upload folder using huggingface_hub (part 2)

apps/backend/dist/libraries/nestjs-libraries/src/3rdparties/thirdparty.module.js

@@ -0,0 +1,21 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+exports.ThirdPartyModule = void 0;
+const tslib_1 = require("tslib");
+const common_1 = require("@nestjs/common");
+const heygen_provider_1 = require("./heygen/heygen.provider");
+const reelfarm_provider_1 = require("./reelfarm/reelfarm.provider");
+const thirdparty_manager_1 = require("./thirdparty.manager");
+let ThirdPartyModule = class ThirdPartyModule {
+};
+exports.ThirdPartyModule = ThirdPartyModule;
+exports.ThirdPartyModule = ThirdPartyModule = tslib_1.__decorate([
+    (0, common_1.Global)(),
+    (0, common_1.Module)({
+        providers: [heygen_provider_1.HeygenProvider, reelfarm_provider_1.ReelFarmProvider, thirdparty_manager_1.ThirdPartyManager],
+        get exports() {
+            return this.providers;
+        },
+    })
+], ThirdPartyModule);
+//# sourceMappingURL=thirdparty.module.js.map

apps/backend/dist/libraries/nestjs-libraries/src/3rdparties/thirdparty.module.js.map

@@ -0,0 +1 @@
+{"version":3,"file":"thirdparty.module.js","sourceRoot":"","sources":["../../../../../../../libraries/nestjs-libraries/src/3rdparties/thirdparty.module.ts"],"names":[],"mappings":";;;;AAAA,2CAAgD;AAChD,8DAA6F;AAC7F,oEAAmG;AACnG,6DAA4F;AASrF,IAAM,gBAAgB,GAAtB,MAAM,gBAAgB;CAAG,CAAA;AAAnB,4CAAgB;2BAAhB,gBAAgB;IAP5B,IAAA,eAAM,GAAE;IACR,IAAA,eAAM,EAAC;QACN,SAAS,EAAE,CAAC,gCAAc,EAAE,oCAAgB,EAAE,sCAAiB,CAAC;QAChE,IAAI,OAAO;YACT,OAAO,IAAI,CAAC,SAAS,CAAC;QACxB,CAAC;KACF,CAAC;GACW,gBAAgB,CAAG"}

apps/backend/dist/libraries/nestjs-libraries/src/agent/agent.categories.d.ts

@@ -0,0 +1 @@
+export declare const agentCategories: string[];

apps/backend/dist/libraries/nestjs-libraries/src/agent/agent.categories.js

@@ -0,0 +1,36 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+exports.agentCategories = void 0;
+exports.agentCategories = [
+    'Educational',
+    'Inspirational',
+    'Promotional',
+    'Entertaining',
+    'Interactive',
+    'Behind The Scenes',
+    'Testimonial',
+    'Informative',
+    'Humorous',
+    'Seasonal',
+    'News',
+    'Challenge',
+    'Contest',
+    'Tips',
+    'Tutorial',
+    'Poll',
+    'Survey',
+    'Quote',
+    'Event',
+    'FAQ',
+    'Story',
+    'Meme',
+    'Review',
+    'Announcement',
+    'Highlight',
+    'Celebration',
+    'Reminder',
+    'Debate',
+    'Update',
+    'Trend',
+];
+//# sourceMappingURL=agent.categories.js.map

apps/backend/dist/libraries/nestjs-libraries/src/agent/agent.categories.js.map

@@ -0,0 +1 @@
+{"version":3,"file":"agent.categories.js","sourceRoot":"","sources":["../../../../../../../libraries/nestjs-libraries/src/agent/agent.categories.ts"],"names":[],"mappings":";;;AAAa,QAAA,eAAe,GAAG;IAC7B,aAAa;IACb,eAAe;IACf,aAAa;IACb,cAAc;IACd,aAAa;IACb,mBAAmB;IACnB,aAAa;IACb,aAAa;IACb,UAAU;IACV,UAAU;IACV,MAAM;IACN,WAAW;IACX,SAAS;IACT,MAAM;IACN,UAAU;IACV,MAAM;IACN,QAAQ;IACR,OAAO;IACP,OAAO;IACP,KAAK;IACL,OAAO;IACP,MAAM;IACN,QAAQ;IACR,cAAc;IACd,WAAW;IACX,aAAa;IACb,UAAU;IACV,QAAQ;IACR,QAAQ;IACR,OAAO;CACR,CAAC"}

apps/backend/dist/libraries/nestjs-libraries/src/agent/agent.graph.insert.service.d.ts

@@ -0,0 +1,27 @@
+import { BaseMessage } from '@langchain/core/messages';
+import { StateGraph } from '@langchain/langgraph';
+import { PostsService } from "../database/prisma/posts/posts.service";
+interface WorkflowChannelsState {
+    messages: BaseMessage[];
+    topic?: string;
+    category: string;
+    hook?: string;
+    content?: string;
+}
+export declare class AgentGraphInsertService {
+    private _postsService;
+    constructor(_postsService: PostsService);
+    static state: () => StateGraph<WorkflowChannelsState, WorkflowChannelsState, Partial<WorkflowChannelsState>, "__start__", import("@langchain/langgraph").StateDefinition, import("@langchain/langgraph").StateDefinition, import("@langchain/langgraph").StateDefinition, unknown, unknown, unknown>;
+    findCategory(state: WorkflowChannelsState): Promise<{
+        category?: string;
+    }>;
+    findTopic(state: WorkflowChannelsState): Promise<{
+        topic?: string;
+    }>;
+    findHook(state: WorkflowChannelsState): Promise<{
+        hook?: string;
+    }>;
+    savePost(state: WorkflowChannelsState): Promise<{}>;
+    newPost(post: string): Promise<import("@langchain/langgraph").StateType<import("@langchain/langgraph").StateDefinition>>;
+}
+export {};

apps/backend/dist/libraries/nestjs-libraries/src/agent/agent.graph.insert.service.js

@@ -0,0 +1,119 @@
+"use strict";
+var AgentGraphInsertService_1;
+Object.defineProperty(exports, "__esModule", { value: true });
+exports.AgentGraphInsertService = void 0;
+const tslib_1 = require("tslib");
+const common_1 = require("@nestjs/common");
+const messages_1 = require("@langchain/core/messages");
+const langgraph_1 = require("@langchain/langgraph");
+const openai_1 = require("@langchain/openai");
+const prompts_1 = require("@langchain/core/prompts");
+const agent_categories_1 = require("./agent.categories");
+const zod_1 = require("zod");
+const agent_topics_1 = require("./agent.topics");
+const posts_service_1 = require("../database/prisma/posts/posts.service");
+const model = new openai_1.ChatOpenAI({
+    apiKey: process.env.OPENAI_API_KEY || 'sk-proj-',
+    model: 'gpt-4o-2024-08-06',
+    temperature: 0,
+});
+const category = zod_1.z.object({
+    category: zod_1.z.string().describe('The category for the post'),
+});
+const topic = zod_1.z.object({
+    topic: zod_1.z.string().describe('The topic of the post'),
+});
+const hook = zod_1.z.object({
+    hook: zod_1.z.string().describe('The hook of the post'),
+});
+let AgentGraphInsertService = AgentGraphInsertService_1 = class AgentGraphInsertService {
+    constructor(_postsService) {
+        this._postsService = _postsService;
+    }
+    async findCategory(state) {
+        const { messages } = state;
+        const structuredOutput = model.withStructuredOutput(category);
+        return prompts_1.ChatPromptTemplate.fromTemplate(`
+You are an assistant that get a social media post and categorize it into to one from the following categories:
+{categories}
+Here is the post:
+{post}
+    `)
+            .pipe(structuredOutput)
+            .invoke({
+            post: messages[0].content,
+            categories: agent_categories_1.agentCategories.join(', '),
+        });
+    }
+    findTopic(state) {
+        const { messages } = state;
+        const structuredOutput = model.withStructuredOutput(topic);
+        return prompts_1.ChatPromptTemplate.fromTemplate(`
+You are an assistant that get a social media post and categorize it into one of the following topics:
+{topics}
+Here is the post:
+{post}
+    `)
+            .pipe(structuredOutput)
+            .invoke({
+            post: messages[0].content,
+            topics: agent_topics_1.agentTopics.join(', '),
+        });
+    }
+    findHook(state) {
+        const { messages } = state;
+        const structuredOutput = model.withStructuredOutput(hook);
+        return prompts_1.ChatPromptTemplate.fromTemplate(`
+You are an assistant that get a social media post and extract the hook, the hook is usually the first or second of both sentence of the post, but can be in a different place, make sure you don't change the wording of the post use the exact text:
+{post}
+    `)
+            .pipe(structuredOutput)
+            .invoke({
+            post: messages[0].content,
+        });
+    }
+    async savePost(state) {
+        await this._postsService.createPopularPosts({
+            category: state.category,
+            topic: state.topic,
+            hook: state.hook,
+            content: state.messages[0].content,
+        });
+        return {};
+    }
+    newPost(post) {
+        const state = AgentGraphInsertService_1.state();
+        const workflow = state
+            .addNode('find-category', this.findCategory)
+            .addNode('find-topic', this.findTopic)
+            .addNode('find-hook', this.findHook)
+            .addNode('save-post', this.savePost.bind(this))
+            .addEdge(langgraph_1.START, 'find-category')
+            .addEdge('find-category', 'find-topic')
+            .addEdge('find-topic', 'find-hook')
+            .addEdge('find-hook', 'save-post')
+            .addEdge('save-post', langgraph_1.END);
+        const app = workflow.compile();
+        return app.invoke({
+            messages: [new messages_1.HumanMessage(post)],
+        });
+    }
+};
+exports.AgentGraphInsertService = AgentGraphInsertService;
+AgentGraphInsertService.state = () => new langgraph_1.StateGraph({
+    channels: {
+        messages: {
+            reducer: (currentState, updateValue) => currentState.concat(updateValue),
+            default: () => [],
+        },
+        topic: null,
+        category: null,
+        hook: null,
+        content: null,
+    },
+});
+exports.AgentGraphInsertService = AgentGraphInsertService = AgentGraphInsertService_1 = tslib_1.__decorate([
+    (0, common_1.Injectable)(),
+    tslib_1.__metadata("design:paramtypes", [posts_service_1.PostsService])
+], AgentGraphInsertService);
+//# sourceMappingURL=agent.graph.insert.service.js.map

apps/backend/dist/libraries/nestjs-libraries/src/agent/agent.graph.insert.service.js.map

@@ -0,0 +1 @@
+{"version":3,"file":"agent.graph.insert.service.js","sourceRoot":"","sources":["../../../../../../../libraries/nestjs-libraries/src/agent/agent.graph.insert.service.ts"],"names":[],"mappings":";;;;;AAAA,2CAA4C;AAC5C,uDAAqE;AACrE,oDAA8D;AAC9D,8CAA+C;AAC/C,qDAA6D;AAC7D,yDAAmF;AACnF,6BAAwB;AACxB,iDAA2E;AAC3E,0EAA6F;AAE7F,MAAM,KAAK,GAAG,IAAI,mBAAU,CAAC;IAC3B,MAAM,EAAE,OAAO,CAAC,GAAG,CAAC,cAAc,IAAI,UAAU;IAChD,KAAK,EAAE,mBAAmB;IAC1B,WAAW,EAAE,CAAC;CACf,CAAC,CAAC;AAUH,MAAM,QAAQ,GAAG,OAAC,CAAC,MAAM,CAAC;IACxB,QAAQ,EAAE,OAAC,CAAC,MAAM,EAAE,CAAC,QAAQ,CAAC,2BAA2B,CAAC;CAC3D,CAAC,CAAC;AAEH,MAAM,KAAK,GAAG,OAAC,CAAC,MAAM,CAAC;IACrB,KAAK,EAAE,OAAC,CAAC,MAAM,EAAE,CAAC,QAAQ,CAAC,uBAAuB,CAAC;CACpD,CAAC,CAAC;AAEH,MAAM,IAAI,GAAG,OAAC,CAAC,MAAM,CAAC;IACpB,IAAI,EAAE,OAAC,CAAC,MAAM,EAAE,CAAC,QAAQ,CAAC,sBAAsB,CAAC;CAClD,CAAC,CAAC;AAGI,IAAM,uBAAuB,+BAA7B,MAAM,uBAAuB;IAClC,YAAoB,aAA2B;QAA3B,kBAAa,GAAb,aAAa,CAAc;IAAG,CAAC;IAgBnD,KAAK,CAAC,YAAY,CAAC,KAA4B;QAC7C,MAAM,EAAE,QAAQ,EAAE,GAAG,KAAK,CAAC;QAC3B,MAAM,gBAAgB,GAAG,KAAK,CAAC,oBAAoB,CAAC,QAAQ,CAAC,CAAC;QAC9D,OAAO,4BAAkB,CAAC,YAAY,CACpC;;;;;KAKD,CACA;aACE,IAAI,CAAC,gBAAgB,CAAC;aACtB,MAAM,CAAC;YACN,IAAI,EAAE,QAAQ,CAAC,CAAC,CAAC,CAAC,OAAO;YACzB,UAAU,EAAE,kCAAe,CAAC,IAAI,CAAC,IAAI,CAAC;SACvC,CAAC,CAAC;IACP,CAAC;IAED,SAAS,CAAC,KAA4B;QACpC,MAAM,EAAE,QAAQ,EAAE,GAAG,KAAK,CAAC;QAC3B,MAAM,gBAAgB,GAAG,KAAK,CAAC,oBAAoB,CAAC,KAAK,CAAC,CAAC;QAC3D,OAAO,4BAAkB,CAAC,YAAY,CACpC;;;;;KAKD,CACA;aACE,IAAI,CAAC,gBAAgB,CAAC;aACtB,MAAM,CAAC;YACN,IAAI,EAAE,QAAQ,CAAC,CAAC,CAAC,CAAC,OAAO;YACzB,MAAM,EAAE,0BAAW,CAAC,IAAI,CAAC,IAAI,CAAC;SAC/B,CAAC,CAAC;IACP,CAAC;IAED,QAAQ,CAAC,KAA4B;QACnC,MAAM,EAAE,QAAQ,EAAE,GAAG,KAAK,CAAC;QAC3B,MAAM,gBAAgB,GAAG,KAAK,CAAC,oBAAoB,CAAC,IAAI,CAAC,CAAC;QAC1D,OAAO,4BAAkB,CAAC,YAAY,CACpC;;;KAGD,CACA;aACE,IAAI,CAAC,gBAAgB,CAAC;aACtB,MAAM,CAAC;YACN,IAAI,EAAE,QAAQ,CAAC,CAAC,CAAC,CAAC,OAAO;SAC1B,CAAC,CAAC;IACP,CAAC;IAED,KAAK,CAAC,QAAQ,CAAC,KAA4B;QACzC,MAAM,IAAI,CAAC,aAAa,CAAC,kBAAkB,CAAC;YAC1C,QAAQ,EAAE,KAAK,CAAC,QAAQ;YACxB,KAAK,EAAE,KAAK,CAAC,KAAM;YACnB,IAAI,EAAE,KAAK,CAAC,IAAK;YACjB,OAAO,EAAE,KAAK,CAAC,QAAQ,CAAC,CAAC,CAAC,CAAC,OAAkB;SAC9C,CAAC,CAAC;QAEH,OAAO,EAAE,CAAC;IACZ,CAAC;IAED,OAAO,CAAC,IAAY;QAClB,MAAM,KAAK,GAAG,yBAAuB,CAAC,KAAK,EAAE,CAAC;QAC9C,MAAM,QAAQ,GAAG,KAAK;aACnB,OAAO,CAAC,eAAe,EAAE,IAAI,CAAC,YAAY,CAAC;aAC3C,OAAO,CAAC,YAAY,EAAE,IAAI,CAAC,SAAS,CAAC;aACrC,OAAO,CAAC,WAAW,EAAE,IAAI,CAAC,QAAQ,CAAC;aACnC,OAAO,CAAC,WAAW,EAAE,IAAI,CAAC,QAAQ,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC;aAC9C,OAAO,CAAC,iBAAK,EAAE,eAAe,CAAC;aAC/B,OAAO,CAAC,eAAe,EAAE,YAAY,CAAC;aACtC,OAAO,CAAC,YAAY,EAAE,WAAW,CAAC;aAClC,OAAO,CAAC,WAAW,EAAE,WAAW,CAAC;aACjC,OAAO,CAAC,WAAW,EAAE,eAAG,CAAC,CAAC;QAE7B,MAAM,GAAG,GAAG,QAAQ,CAAC,OAAO,EAAE,CAAC;QAC/B,OAAO,GAAG,CAAC,MAAM,CAAC;YAChB,QAAQ,EAAE,CAAC,IAAI,uBAAY,CAAC,IAAI,CAAC,CAAC;SACnC,CAAC,CAAC;IACL,CAAC;;AAhGU,0DAAuB;AAE3B,6BAAK,GAAG,GAAG,EAAE,CAClB,IAAI,sBAAU,CAAwB;IACpC,QAAQ,EAAE;QACR,QAAQ,EAAE;YACR,OAAO,EAAE,CAAC,YAAY,EAAE,WAAW,EAAE,EAAE,CACrC,YAAY,CAAC,MAAM,CAAC,WAAW,CAAC;YAClC,OAAO,EAAE,GAAG,EAAE,CAAC,EAAE;SAClB;QACD,KAAK,EAAE,IAAI;QACX,QAAQ,EAAE,IAAI;QACd,IAAI,EAAE,IAAI;QACV,OAAO,EAAE,IAAI;KACd;CACF,CAAC,AAbQ,CAaP;kCAfM,uBAAuB;IADnC,IAAA,mBAAU,GAAE;6CAEwB,4BAAY;GADpC,uBAAuB,CAiGnC"}

apps/backend/dist/libraries/nestjs-libraries/src/agent/agent.graph.service.d.ts

@@ -0,0 +1,113 @@
+import { BaseMessage, ToolMessage } from '@langchain/core/messages';
+import { StateGraph } from '@langchain/langgraph';
+import { PostsService } from "../database/prisma/posts/posts.service";
+import { MediaService } from "../database/prisma/media/media.service";
+import { GeneratorDto } from "../dtos/generator/generator.dto";
+interface WorkflowChannelsState {
+    messages: BaseMessage[];
+    orgId: string;
+    question: string;
+    hook?: string;
+    fresearch?: string;
+    category?: string;
+    topic?: string;
+    date?: string;
+    format: 'one_short' | 'one_long' | 'thread_short' | 'thread_long';
+    tone: 'personal' | 'company';
+    content?: {
+        content: string;
+        website?: string;
+        prompt?: string;
+        image?: string;
+    }[];
+    isPicture?: boolean;
+    popularPosts?: {
+        content: string;
+        hook: string;
+    }[];
+}
+export declare class AgentGraphService {
+    private _postsService;
+    private _mediaService;
+    private storage;
+    constructor(_postsService: PostsService, _mediaService: MediaService);
+    static state: () => StateGraph<WorkflowChannelsState, WorkflowChannelsState, Partial<WorkflowChannelsState>, "__start__", import("@langchain/langgraph").StateDefinition, import("@langchain/langgraph").StateDefinition, import("@langchain/langgraph").StateDefinition, unknown, unknown, unknown>;
+    startCall(state: WorkflowChannelsState): Promise<{
+        messages: import("@langchain/core/messages").AIMessageChunk<import("@langchain/core/messages").MessageStructure<import("@langchain/core/messages").MessageToolSet>>[];
+    }>;
+    saveResearch(state: WorkflowChannelsState): Promise<{
+        fresearch: ToolMessage<any>[];
+    }>;
+    findCategories(state: WorkflowChannelsState): Promise<{
+        category: string;
+    }>;
+    findTopic(state: WorkflowChannelsState): Promise<{
+        topic: string;
+    }>;
+    findPopularPosts(state: WorkflowChannelsState): Promise<{
+        popularPosts: {
+            content: string;
+            hook: string;
+        }[];
+    }>;
+    generateHook(state: WorkflowChannelsState): Promise<{
+        hook: string;
+    }>;
+    generateContent(state: WorkflowChannelsState): Promise<{
+        content: {
+            website?: string;
+            content?: string;
+            prompt?: string;
+        } | {
+            website?: string;
+            content?: string;
+            prompt?: string;
+        }[];
+    }>;
+    fixArray(state: WorkflowChannelsState): Promise<{
+        content: {
+            content: string;
+            website?: string;
+            prompt?: string;
+            image?: string;
+        }[][];
+    } | {
+        content?: undefined;
+    }>;
+    generatePictures(state: WorkflowChannelsState): Promise<{
+        content?: undefined;
+    } | {
+        content: {
+            image: any;
+            content: string;
+            website?: string;
+            prompt?: string;
+        }[];
+    }>;
+    uploadPictures(state: WorkflowChannelsState): Promise<{
+        content: ({
+            content: string;
+            website?: string;
+            prompt?: string;
+            image?: string;
+        } | {
+            image: {
+                id: string;
+                name: string;
+                originalName: string;
+                path: string;
+                thumbnail: string;
+                alt: string;
+            };
+            content: string;
+            website?: string;
+            prompt?: string;
+        })[];
+    }>;
+    isGeneratePicture(state: WorkflowChannelsState): Promise<"generate-picture" | "post-time">;
+    postDateTime(state: WorkflowChannelsState): Promise<{
+        date: string;
+    }>;
+    start(orgId: string, body: GeneratorDto): import("@langchain/core/utils/stream").IterableReadableStream<import("@langchain/core/tracers/log_stream").StreamEvent>;
+}
+export {};

apps/backend/dist/libraries/nestjs-libraries/src/agent/agent.graph.service.js

@@ -0,0 +1,328 @@
+"use strict";
+var AgentGraphService_1;
+Object.defineProperty(exports, "__esModule", { value: true });
+exports.AgentGraphService = void 0;
+const tslib_1 = require("tslib");
+const common_1 = require("@nestjs/common");
+const messages_1 = require("@langchain/core/messages");
+const langgraph_1 = require("@langchain/langgraph");
+const openai_1 = require("@langchain/openai");
+const tavily_1 = require("@langchain/tavily");
+const prebuilt_1 = require("@langchain/langgraph/prebuilt");
+const prompts_1 = require("@langchain/core/prompts");
+const dayjs_1 = tslib_1.__importDefault(require("dayjs"));
+const posts_service_1 = require("../database/prisma/posts/posts.service");
+const zod_1 = require("zod");
+const media_service_1 = require("../database/prisma/media/media.service");
+const upload_factory_1 = require("../upload/upload.factory");
+const generation_error_1 = require("../openai/generation.error");
+const tools = !process.env.TAVILY_API_KEY
+    ? []
+    : [new tavily_1.TavilySearch({ maxResults: 3 })];
+const toolNode = new prebuilt_1.ToolNode(tools);
+const model = new openai_1.ChatOpenAI({
+    apiKey: process.env.OPENAI_API_KEY || 'sk-proj-',
+    model: 'gpt-4.1',
+    temperature: 0.7,
+});
+const dalle = new openai_1.DallEAPIWrapper({
+    apiKey: process.env.OPENAI_API_KEY || 'sk-proj-',
+    model: 'chatgpt-image-latest',
+});
+const category = zod_1.z.object({
+    category: zod_1.z.string().describe('The category for the post'),
+});
+const topic = zod_1.z.object({
+    topic: zod_1.z.string().describe('The topic for the post'),
+});
+const hook = zod_1.z.object({
+    hook: zod_1.z
+        .string()
+        .describe('Hook for the new post, don\'t take it from "the request of the user"'),
+});
+const contentZod = (isPicture, format) => {
+    const content = zod_1.z.object({
+        content: zod_1.z.string().describe('Content for the new post'),
+        website: zod_1.z
+            .string()
+            .nullable()
+            .optional()
+            .describe("Website for the new post if exists, If one of the post present a brand, website link must be to the root domain of the brand or don't include it, website url should contain the brand name"),
+        ...(isPicture
+            ? {
+                prompt: zod_1.z
+                    .string()
+                    .describe("Prompt to generate a picture for this post later, make sure it doesn't contain brand names and make it very descriptive in terms of style"),
+            }
+            : {}),
+    });
+    return zod_1.z.object({
+        content: format === 'one_short' || format === 'one_long'
+            ? content
+            : zod_1.z.array(content).min(2).describe(`Content for the new post`),
+    });
+};
+let AgentGraphService = AgentGraphService_1 = class AgentGraphService {
+    constructor(_postsService, _mediaService) {
+        this._postsService = _postsService;
+        this._mediaService = _mediaService;
+        this.storage = upload_factory_1.UploadFactory.createStorage();
+    }
+    async startCall(state) {
+        const runTools = model.bindTools(tools);
+        const response = await prompts_1.ChatPromptTemplate.fromTemplate(`
+    Today is ${(0, dayjs_1.default)().format()}, You are an assistant that gets a social media post or requests for a social media post.
+    You research should be on the most possible recent data.
+    You concat the text of the request together with an internet research based on the text.
+    {text}
+    `)
+            .pipe(runTools)
+            .invoke({
+            text: state.messages[state.messages.length - 1].content,
+        });
+        return { messages: [response] };
+    }
+    async saveResearch(state) {
+        const content = state.messages.filter((f) => f instanceof messages_1.ToolMessage);
+        return { fresearch: content };
+    }
+    async findCategories(state) {
+        const allCategories = await this._postsService.findAllExistingCategories();
+        const structuredOutput = model.withStructuredOutput(category);
+        const { category: outputCategory } = await prompts_1.ChatPromptTemplate.fromTemplate(`
+        You are an assistant that gets a text that will be later summarized into a social media post
+        and classify it to one of the following categories: {categories}
+        text: {text}
+      `)
+            .pipe(structuredOutput)
+            .invoke({
+            categories: allCategories.map((p) => p.category).join(', '),
+            text: state.fresearch,
+        });
+        return {
+            category: outputCategory,
+        };
+    }
+    async findTopic(state) {
+        const allTopics = await this._postsService.findAllExistingTopicsOfCategory(state?.category);
+        if (allTopics.length === 0) {
+            return { topic: null };
+        }
+        const structuredOutput = model.withStructuredOutput(topic);
+        const { topic: outputTopic } = await prompts_1.ChatPromptTemplate.fromTemplate(`
+        You are an assistant that gets a text that will be later summarized into a social media post
+        and classify it to one of the following topics: {topics}
+        text: {text}
+      `)
+            .pipe(structuredOutput)
+            .invoke({
+            topics: allTopics.map((p) => p.topic).join(', '),
+            text: state.fresearch,
+        });
+        return {
+            topic: outputTopic,
+        };
+    }
+    async findPopularPosts(state) {
+        const popularPosts = await this._postsService.findPopularPosts(state.category, state.topic);
+        return { popularPosts };
+    }
+    async generateHook(state) {
+        const structuredOutput = model.withStructuredOutput(hook);
+        const { hook: outputHook } = await prompts_1.ChatPromptTemplate.fromTemplate(`
+        You are an assistant that gets content for a social media post, and generate only the hook.
+        The hook is the 1-2 sentences of the post that will be used to grab the attention of the reader.
+        You will be provided existing hooks you should use as inspiration.
+        - Avoid weird hook that starts with "Discover the secret...", "The best...", "The most...", "The top..."
+        - Make sure it sounds ${state.tone}
+        - Use ${state.tone === 'personal' ? '1st' : '3rd'} person mode
+        - Make sure it's engaging
+        - Don't be cringy
+        - Use simple english
+        - Make sure you add "\n" between the lines
+        - Don't take the hook from "request of the user"
+
+        <!-- BEGIN request of the user -->
+        {request}
+        <!-- END request of the user -->
+        
+        <!-- BEGIN existing hooks -->
+        {hooks}
+        <!-- END existing hooks -->
+        
+        <!-- BEGIN current content -->
+        {text}
+        <!-- END current content -->
+       
+      `)
+            .pipe(structuredOutput)
+            .invoke({
+            request: state.messages[0].content,
+            hooks: state.popularPosts.map((p) => p.hook).join('\n'),
+            text: state.fresearch,
+        });
+        return {
+            hook: outputHook,
+        };
+    }
+    async generateContent(state) {
+        const structuredOutput = model.withStructuredOutput(contentZod(!!state.isPicture, state.format));
+        const { content: outputContent } = await prompts_1.ChatPromptTemplate.fromTemplate(`
+        You are an assistant that gets existing hook of a social media, content and generate only the content.
+        - Don't add any hashtags
+        - Make sure it sounds ${state.tone}
+        - Use ${state.tone === 'personal' ? '1st' : '3rd'} person mode
+        - ${state.format === 'one_short' || state.format === 'thread_short'
+            ? 'Post should be maximum 200 chars to fit twitter'
+            : 'Post should be long'}
+        - ${state.format === 'one_short' || state.format === 'one_long'
+            ? 'Post should have only 1 item'
+            : 'Post should have minimum 2 items'}
+        - Use the hook as inspiration
+        - Make sure it's engaging
+        - Don't be cringy
+        - Use simple english
+        - The Content should not contain the hook
+        - Try to put some call to action at the end of the post
+        - Make sure you add "\n" between the lines
+        - Add "\n" after every "."
+        
+        Hook:
+        {hook}
+        
+        User request:
+        {request}
+        
+        current content information:
+        {information}
+      `)
+            .pipe(structuredOutput)
+            .invoke({
+            hook: state.hook,
+            request: state.messages[0].content,
+            information: state.fresearch,
+        });
+        return {
+            content: outputContent,
+        };
+    }
+    async fixArray(state) {
+        if (state.format === 'one_short' || state.format === 'one_long') {
+            return {
+                content: [state.content],
+            };
+        }
+        return {};
+    }
+    async generatePictures(state) {
+        if (!state.isPicture) {
+            return {};
+        }
+        try {
+            const newContent = await Promise.all((state.content || []).map(async (p) => {
+                const image = await dalle.invoke(p.prompt);
+                return {
+                    ...p,
+                    image,
+                };
+            }));
+            return {
+                content: newContent,
+            };
+        }
+        catch (err) {
+            throw (0, generation_error_1.generationError)(err);
+        }
+    }
+    async uploadPictures(state) {
+        const all = await Promise.all((state.content || []).map(async (p) => {
+            if (p.image) {
+                const upload = await this.storage.uploadSimple(p.image);
+                const name = upload.split('/').pop();
+                const uploadWithId = await this._mediaService.saveFile(state.orgId, name, upload);
+                return {
+                    ...p,
+                    image: uploadWithId,
+                };
+            }
+            return p;
+        }));
+        return { content: all };
+    }
+    async isGeneratePicture(state) {
+        if (state.isPicture) {
+            return 'generate-picture';
+        }
+        return 'post-time';
+    }
+    async postDateTime(state) {
+        return { date: await this._postsService.findFreeDateTime(state.orgId) };
+    }
+    start(orgId, body) {
+        const state = AgentGraphService_1.state();
+        const workflow = state
+            .addNode('agent', this.startCall.bind(this))
+            .addNode('research', toolNode)
+            .addNode('save-research', this.saveResearch.bind(this))
+            .addNode('find-category', this.findCategories.bind(this))
+            .addNode('find-topic', this.findTopic.bind(this))
+            .addNode('find-popular-posts', this.findPopularPosts.bind(this))
+            .addNode('generate-hook', this.generateHook.bind(this))
+            .addNode('generate-content', this.generateContent.bind(this))
+            .addNode('generate-content-fix', this.fixArray.bind(this))
+            .addNode('generate-picture', this.generatePictures.bind(this))
+            .addNode('upload-pictures', this.uploadPictures.bind(this))
+            .addNode('post-time', this.postDateTime.bind(this))
+            .addEdge(langgraph_1.START, 'agent')
+            .addEdge('agent', 'research')
+            .addEdge('research', 'save-research')
+            .addEdge('save-research', 'find-category')
+            .addEdge('find-category', 'find-topic')
+            .addEdge('find-topic', 'find-popular-posts')
+            .addEdge('find-popular-posts', 'generate-hook')
+            .addEdge('generate-hook', 'generate-content')
+            .addEdge('generate-content', 'generate-content-fix')
+            .addConditionalEdges('generate-content-fix', this.isGeneratePicture.bind(this))
+            .addEdge('generate-picture', 'upload-pictures')
+            .addEdge('upload-pictures', 'post-time')
+            .addEdge('post-time', langgraph_1.END);
+        const app = workflow.compile();
+        return app.streamEvents({
+            messages: [new messages_1.HumanMessage(body.research)],
+            isPicture: body.isPicture,
+            format: body.format,
+            tone: body.tone,
+            orgId,
+        }, {
+            streamMode: 'values',
+            version: 'v2',
+        });
+    }
+};
+exports.AgentGraphService = AgentGraphService;
+AgentGraphService.state = () => new langgraph_1.StateGraph({
+    channels: {
+        messages: {
+            reducer: (currentState, updateValue) => currentState.concat(updateValue),
+            default: () => [],
+        },
+        fresearch: null,
+        format: null,
+        tone: null,
+        question: null,
+        orgId: null,
+        hook: null,
+        content: null,
+        date: null,
+        category: null,
+        popularPosts: null,
+        topic: null,
+        isPicture: null,
+    },
+});
+exports.AgentGraphService = AgentGraphService = AgentGraphService_1 = tslib_1.__decorate([
+    (0, common_1.Injectable)(),
+    tslib_1.__metadata("design:paramtypes", [posts_service_1.PostsService,
+        media_service_1.MediaService])
+], AgentGraphService);
+//# sourceMappingURL=agent.graph.service.js.map

apps/backend/dist/libraries/nestjs-libraries/src/agent/agent.graph.service.js.map

@@ -0,0 +1 @@
+{"version":3,"file":"agent.graph.service.js","sourceRoot":"","sources":["../../../../../../../libraries/nestjs-libraries/src/agent/agent.graph.service.ts"],"names":[],"mappings":";;;;;AAAA,2CAA4C;AAC5C,uDAIkC;AAClC,oDAA8D;AAC9D,8CAAgE;AAChE,8CAAiD;AACjD,4DAAyD;AACzD,qDAA6D;AAC7D,0DAA0B;AAC1B,0EAA6F;AAC7F,6BAAwB;AACxB,0EAA6F;AAC7F,6DAAgF;AAEhF,iEAAoF;AAEpF,MAAM,KAAK,GAAG,CAAC,OAAO,CAAC,GAAG,CAAC,cAAc;IACvC,CAAC,CAAC,EAAE;IACJ,CAAC,CAAC,CAAC,IAAI,qBAAY,CAAC,EAAE,UAAU,EAAE,CAAC,EAAE,CAAC,CAAC,CAAC;AAC1C,MAAM,QAAQ,GAAG,IAAI,mBAAQ,CAAC,KAAK,CAAC,CAAC;AAErC,MAAM,KAAK,GAAG,IAAI,mBAAU,CAAC;IAC3B,MAAM,EAAE,OAAO,CAAC,GAAG,CAAC,cAAc,IAAI,UAAU;IAChD,KAAK,EAAE,SAAS;IAChB,WAAW,EAAE,GAAG;CACjB,CAAC,CAAC;AAEH,MAAM,KAAK,GAAG,IAAI,wBAAe,CAAC;IAChC,MAAM,EAAE,OAAO,CAAC,GAAG,CAAC,cAAc,IAAI,UAAU;IAChD,KAAK,EAAE,sBAAsB;CAC9B,CAAC,CAAC;AAuBH,MAAM,QAAQ,GAAG,OAAC,CAAC,MAAM,CAAC;IACxB,QAAQ,EAAE,OAAC,CAAC,MAAM,EAAE,CAAC,QAAQ,CAAC,2BAA2B,CAAC;CAC3D,CAAC,CAAC;AAEH,MAAM,KAAK,GAAG,OAAC,CAAC,MAAM,CAAC;IACrB,KAAK,EAAE,OAAC,CAAC,MAAM,EAAE,CAAC,QAAQ,CAAC,wBAAwB,CAAC;CACrD,CAAC,CAAC;AAEH,MAAM,IAAI,GAAG,OAAC,CAAC,MAAM,CAAC;IACpB,IAAI,EAAE,OAAC;SACJ,MAAM,EAAE;SACR,QAAQ,CACP,sEAAsE,CACvE;CACJ,CAAC,CAAC;AAEH,MAAM,UAAU,GAAG,CACjB,SAAkB,EAClB,MAAiE,EACjE,EAAE;IACF,MAAM,OAAO,GAAG,OAAC,CAAC,MAAM,CAAC;QACvB,OAAO,EAAE,OAAC,CAAC,MAAM,EAAE,CAAC,QAAQ,CAAC,0BAA0B,CAAC;QACxD,OAAO,EAAE,OAAC;aACP,MAAM,EAAE;aACR,QAAQ,EAAE;aACV,QAAQ,EAAE;aACV,QAAQ,CACP,6LAA6L,CAC9L;QACH,GAAG,CAAC,SAAS;YACX,CAAC,CAAC;gBACE,MAAM,EAAE,OAAC;qBACN,MAAM,EAAE;qBACR,QAAQ,CACP,2IAA2I,CAC5I;aACJ;YACH,CAAC,CAAC,EAAE,CAAC;KACR,CAAC,CAAC;IAEH,OAAO,OAAC,CAAC,MAAM,CAAC;QACd,OAAO,EACL,MAAM,KAAK,WAAW,IAAI,MAAM,KAAK,UAAU;YAC7C,CAAC,CAAC,OAAO;YACT,CAAC,CAAC,OAAC,CAAC,KAAK,CAAC,OAAO,CAAC,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC,QAAQ,CAAC,0BAA0B,CAAC;KACnE,CAAC,CAAC;AACL,CAAC,CAAC;AAGK,IAAM,iBAAiB,yBAAvB,MAAM,iBAAiB;IAE5B,YACU,aAA2B,EAC3B,aAA2B;QAD3B,kBAAa,GAAb,aAAa,CAAc;QAC3B,kBAAa,GAAb,aAAa,CAAc;QAH7B,YAAO,GAAG,8BAAa,CAAC,aAAa,EAAE,CAAC;IAI7C,CAAC;IAwBJ,KAAK,CAAC,SAAS,CAAC,KAA4B;QAC1C,MAAM,QAAQ,GAAG,KAAK,CAAC,SAAS,CAAC,KAAK,CAAC,CAAC;QACxC,MAAM,QAAQ,GAAG,MAAM,4BAAkB,CAAC,YAAY,CACpD;eACS,IAAA,eAAK,GAAE,CAAC,MAAM,EAAE;;;;KAI1B,CACA;aACE,IAAI,CAAC,QAAQ,CAAC;aACd,MAAM,CAAC;YACN,IAAI,EAAE,KAAK,CAAC,QAAQ,CAAC,KAAK,CAAC,QAAQ,CAAC,MAAM,GAAG,CAAC,CAAC,CAAC,OAAO;SACxD,CAAC,CAAC;QAEL,OAAO,EAAE,QAAQ,EAAE,CAAC,QAAQ,CAAC,EAAE,CAAC;IAClC,CAAC;IAED,KAAK,CAAC,YAAY,CAAC,KAA4B;QAC7C,MAAM,OAAO,GAAG,KAAK,CAAC,QAAQ,CAAC,MAAM,CAAC,CAAC,CAAC,EAAE,EAAE,CAAC,CAAC,YAAY,sBAAW,CAAC,CAAC;QACvE,OAAO,EAAE,SAAS,EAAE,OAAO,EAAE,CAAC;IAChC,CAAC;IAED,KAAK,CAAC,cAAc,CAAC,KAA4B;QAC/C,MAAM,aAAa,GAAG,MAAM,IAAI,CAAC,aAAa,CAAC,yBAAyB,EAAE,CAAC;QAC3E,MAAM,gBAAgB,GAAG,KAAK,CAAC,oBAAoB,CAAC,QAAQ,CAAC,CAAC;QAC9D,MAAM,EAAE,QAAQ,EAAE,cAAc,EAAE,GAAG,MAAM,4BAAkB,CAAC,YAAY,CACxE;;;;OAIC,CACF;aACE,IAAI,CAAC,gBAAgB,CAAC;aACtB,MAAM,CAAC;YACN,UAAU,EAAE,aAAa,CAAC,GAAG,CAAC,CAAC,CAAC,EAAE,EAAE,CAAC,CAAC,CAAC,QAAQ,CAAC,CAAC,IAAI,CAAC,IAAI,CAAC;YAC3D,IAAI,EAAE,KAAK,CAAC,SAAS;SACtB,CAAC,CAAC;QAEL,OAAO;YACL,QAAQ,EAAE,cAAc;SACzB,CAAC;IACJ,CAAC;IAED,KAAK,CAAC,SAAS,CAAC,KAA4B;QAC1C,MAAM,SAAS,GAAG,MAAM,IAAI,CAAC,aAAa,CAAC,+BAA+B,CACxE,KAAK,EAAE,QAAS,CACjB,CAAC;QACF,IAAI,SAAS,CAAC,MAAM,KAAK,CAAC,EAAE,CAAC;YAC3B,OAAO,EAAE,KAAK,EAAE,IAAI,EAAE,CAAC;QACzB,CAAC;QAED,MAAM,gBAAgB,GAAG,KAAK,CAAC,oBAAoB,CAAC,KAAK,CAAC,CAAC;QAC3D,MAAM,EAAE,KAAK,EAAE,WAAW,EAAE,GAAG,MAAM,4BAAkB,CAAC,YAAY,CAClE;;;;OAIC,CACF;aACE,IAAI,CAAC,gBAAgB,CAAC;aACtB,MAAM,CAAC;YACN,MAAM,EAAE,SAAS,CAAC,GAAG,CAAC,CAAC,CAAC,EAAE,EAAE,CAAC,CAAC,CAAC,KAAK,CAAC,CAAC,IAAI,CAAC,IAAI,CAAC;YAChD,IAAI,EAAE,KAAK,CAAC,SAAS;SACtB,CAAC,CAAC;QAEL,OAAO;YACL,KAAK,EAAE,WAAW;SACnB,CAAC;IACJ,CAAC;IAED,KAAK,CAAC,gBAAgB,CAAC,KAA4B;QACjD,MAAM,YAAY,GAAG,MAAM,IAAI,CAAC,aAAa,CAAC,gBAAgB,CAC5D,KAAK,CAAC,QAAS,EACf,KAAK,CAAC,KAAK,CACZ,CAAC;QACF,OAAO,EAAE,YAAY,EAAE,CAAC;IAC1B,CAAC;IAED,KAAK,CAAC,YAAY,CAAC,KAA4B;QAC7C,MAAM,gBAAgB,GAAG,KAAK,CAAC,oBAAoB,CAAC,IAAI,CAAC,CAAC;QAC1D,MAAM,EAAE,IAAI,EAAE,UAAU,EAAE,GAAG,MAAM,4BAAkB,CAAC,YAAY,CAChE;;;;;gCAK0B,KAAK,CAAC,IAAI;gBAC1B,KAAK,CAAC,IAAI,KAAK,UAAU,CAAC,CAAC,CAAC,KAAK,CAAC,CAAC,CAAC,KAAK;;;;;;;;;;;;;;;;;;;OAmBlD,CACF;aACE,IAAI,CAAC,gBAAgB,CAAC;aACtB,MAAM,CAAC;YACN,OAAO,EAAE,KAAK,CAAC,QAAQ,CAAC,CAAC,CAAC,CAAC,OAAO;YAClC,KAAK,EAAE,KAAK,CAAC,YAAa,CAAC,GAAG,CAAC,CAAC,CAAC,EAAE,EAAE,CAAC,CAAC,CAAC,IAAI,CAAC,CAAC,IAAI,CAAC,IAAI,CAAC;YACxD,IAAI,EAAE,KAAK,CAAC,SAAS;SACtB,CAAC,CAAC;QAEL,OAAO;YACL,IAAI,EAAE,UAAU;SACjB,CAAC;IACJ,CAAC;IAED,KAAK,CAAC,eAAe,CAAC,KAA4B;QAChD,MAAM,gBAAgB,GAAG,KAAK,CAAC,oBAAoB,CACjD,UAAU,CAAC,CAAC,CAAC,KAAK,CAAC,SAAS,EAAE,KAAK,CAAC,MAAM,CAAC,CAC5C,CAAC;QACF,MAAM,EAAE,OAAO,EAAE,aAAa,EAAE,GAAG,MAAM,4BAAkB,CAAC,YAAY,CACtE;;;gCAG0B,KAAK,CAAC,IAAI;gBAC1B,KAAK,CAAC,IAAI,KAAK,UAAU,CAAC,CAAC,CAAC,KAAK,CAAC,CAAC,CAAC,KAAK;YAE/C,KAAK,CAAC,MAAM,KAAK,WAAW,IAAI,KAAK,CAAC,MAAM,KAAK,cAAc;YAC7D,CAAC,CAAC,iDAAiD;YACnD,CAAC,CAAC,qBACN;YAEE,KAAK,CAAC,MAAM,KAAK,WAAW,IAAI,KAAK,CAAC,MAAM,KAAK,UAAU;YACzD,CAAC,CAAC,8BAA8B;YAChC,CAAC,CAAC,kCACN;;;;;;;;;;;;;;;;;;OAkBD,CACF;aACE,IAAI,CAAC,gBAAgB,CAAC;aACtB,MAAM,CAAC;YACN,IAAI,EAAE,KAAK,CAAC,IAAI;YAChB,OAAO,EAAE,KAAK,CAAC,QAAQ,CAAC,CAAC,CAAC,CAAC,OAAO;YAClC,WAAW,EAAE,KAAK,CAAC,SAAS;SAC7B,CAAC,CAAC;QAEL,OAAO;YACL,OAAO,EAAE,aAAa;SACvB,CAAC;IACJ,CAAC;IAED,KAAK,CAAC,QAAQ,CAAC,KAA4B;QACzC,IAAI,KAAK,CAAC,MAAM,KAAK,WAAW,IAAI,KAAK,CAAC,MAAM,KAAK,UAAU,EAAE,CAAC;YAChE,OAAO;gBACL,OAAO,EAAE,CAAC,KAAK,CAAC,OAAO,CAAC;aACzB,CAAC;QACJ,CAAC;QAED,OAAO,EAAE,CAAC;IACZ,CAAC;IAED,KAAK,CAAC,gBAAgB,CAAC,KAA4B;QACjD,IAAI,CAAC,KAAK,CAAC,SAAS,EAAE,CAAC;YACrB,OAAO,EAAE,CAAC;QACZ,CAAC;QAED,IAAI,CAAC;YACH,MAAM,UAAU,GAAG,MAAM,OAAO,CAAC,GAAG,CAClC,CAAC,KAAK,CAAC,OAAO,IAAI,EAAE,CAAC,CAAC,GAAG,CAAC,KAAK,EAAE,CAAC,EAAE,EAAE;gBACpC,MAAM,KAAK,GAAG,MAAM,KAAK,CAAC,MAAM,CAAC,CAAC,CAAC,MAAO,CAAC,CAAC;gBAC5C,OAAO;oBACL,GAAG,CAAC;oBACJ,KAAK;iBACN,CAAC;YACJ,CAAC,CAAC,CACH,CAAC;YAEF,OAAO;gBACL,OAAO,EAAE,UAAU;aACpB,CAAC;QACJ,CAAC;QAAC,OAAO,GAAG,EAAE,CAAC;YACb,MAAM,IAAA,kCAAe,EAAC,GAAG,CAAC,CAAC;QAC7B,CAAC;IACH,CAAC;IAED,KAAK,CAAC,cAAc,CAAC,KAA4B;QAC/C,MAAM,GAAG,GAAG,MAAM,OAAO,CAAC,GAAG,CAC3B,CAAC,KAAK,CAAC,OAAO,IAAI,EAAE,CAAC,CAAC,GAAG,CAAC,KAAK,EAAE,CAAC,EAAE,EAAE;YACpC,IAAI,CAAC,CAAC,KAAK,EAAE,CAAC;gBACZ,MAAM,MAAM,GAAG,MAAM,IAAI,CAAC,OAAO,CAAC,YAAY,CAAC,CAAC,CAAC,KAAK,CAAC,CAAC;gBACxD,MAAM,IAAI,GAAG,MAAM,CAAC,KAAK,CAAC,GAAG,CAAC,CAAC,GAAG,EAAG,CAAC;gBACtC,MAAM,YAAY,GAAG,MAAM,IAAI,CAAC,aAAa,CAAC,QAAQ,CACpD,KAAK,CAAC,KAAK,EACX,IAAI,EACJ,MAAM,CACP,CAAC;gBAEF,OAAO;oBACL,GAAG,CAAC;oBACJ,KAAK,EAAE,YAAY;iBACpB,CAAC;YACJ,CAAC;YAED,OAAO,CAAC,CAAC;QACX,CAAC,CAAC,CACH,CAAC;QAEF,OAAO,EAAE,OAAO,EAAE,GAAG,EAAE,CAAC;IAC1B,CAAC;IAED,KAAK,CAAC,iBAAiB,CAAC,KAA4B;QAClD,IAAI,KAAK,CAAC,SAAS,EAAE,CAAC;YACpB,OAAO,kBAAkB,CAAC;QAC5B,CAAC;QAED,OAAO,WAAW,CAAC;IACrB,CAAC;IAED,KAAK,CAAC,YAAY,CAAC,KAA4B;QAC7C,OAAO,EAAE,IAAI,EAAE,MAAM,IAAI,CAAC,aAAa,CAAC,gBAAgB,CAAC,KAAK,CAAC,KAAK,CAAC,EAAE,CAAC;IAC1E,CAAC;IAED,KAAK,CAAC,KAAa,EAAE,IAAkB;QACrC,MAAM,KAAK,GAAG,mBAAiB,CAAC,KAAK,EAAE,CAAC;QACxC,MAAM,QAAQ,GAAG,KAAK;aACnB,OAAO,CAAC,OAAO,EAAE,IAAI,CAAC,SAAS,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC;aAC3C,OAAO,CAAC,UAAU,EAAE,QAAQ,CAAC;aAC7B,OAAO,CAAC,eAAe,EAAE,IAAI,CAAC,YAAY,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC;aACtD,OAAO,CAAC,eAAe,EAAE,IAAI,CAAC,cAAc,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC;aACxD,OAAO,CAAC,YAAY,EAAE,IAAI,CAAC,SAAS,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC;aAChD,OAAO,CAAC,oBAAoB,EAAE,IAAI,CAAC,gBAAgB,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC;aAC/D,OAAO,CAAC,eAAe,EAAE,IAAI,CAAC,YAAY,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC;aACtD,OAAO,CAAC,kBAAkB,EAAE,IAAI,CAAC,eAAe,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC;aAC5D,OAAO,CAAC,sBAAsB,EAAE,IAAI,CAAC,QAAQ,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC;aACzD,OAAO,CAAC,kBAAkB,EAAE,IAAI,CAAC,gBAAgB,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC;aAC7D,OAAO,CAAC,iBAAiB,EAAE,IAAI,CAAC,cAAc,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC;aAC1D,OAAO,CAAC,WAAW,EAAE,IAAI,CAAC,YAAY,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC;aAClD,OAAO,CAAC,iBAAK,EAAE,OAAO,CAAC;aACvB,OAAO,CAAC,OAAO,EAAE,UAAU,CAAC;aAC5B,OAAO,CAAC,UAAU,EAAE,eAAe,CAAC;aACpC,OAAO,CAAC,eAAe,EAAE,eAAe,CAAC;aACzC,OAAO,CAAC,eAAe,EAAE,YAAY,CAAC;aACtC,OAAO,CAAC,YAAY,EAAE,oBAAoB,CAAC;aAC3C,OAAO,CAAC,oBAAoB,EAAE,eAAe,CAAC;aAC9C,OAAO,CAAC,eAAe,EAAE,kBAAkB,CAAC;aAC5C,OAAO,CAAC,kBAAkB,EAAE,sBAAsB,CAAC;aACnD,mBAAmB,CAClB,sBAAsB,EACtB,IAAI,CAAC,iBAAiB,CAAC,IAAI,CAAC,IAAI,CAAC,CAClC;aACA,OAAO,CAAC,kBAAkB,EAAE,iBAAiB,CAAC;aAC9C,OAAO,CAAC,iBAAiB,EAAE,WAAW,CAAC;aACvC,OAAO,CAAC,WAAW,EAAE,eAAG,CAAC,CAAC;QAE7B,MAAM,GAAG,GAAG,QAAQ,CAAC,OAAO,EAAE,CAAC;QAE/B,OAAO,GAAG,CAAC,YAAY,CACrB;YACE,QAAQ,EAAE,CAAC,IAAI,uBAAY,CAAC,IAAI,CAAC,QAAQ,CAAC,CAAC;YAC3C,SAAS,EAAE,IAAI,CAAC,SAAS;YACzB,MAAM,EAAE,IAAI,CAAC,MAAM;YACnB,IAAI,EAAE,IAAI,CAAC,IAAI;YACf,KAAK;SACN,EACD;YACE,UAAU,EAAE,QAAQ;YACpB,OAAO,EAAE,IAAI;SACd,CACF,CAAC;IACJ,CAAC;;AA/TU,8CAAiB;AAMrB,uBAAK,GAAG,GAAG,EAAE,CAClB,IAAI,sBAAU,CAAwB;IACpC,QAAQ,EAAE;QACR,QAAQ,EAAE;YACR,OAAO,EAAE,CAAC,YAAY,EAAE,WAAW,EAAE,EAAE,CACrC,YAAY,CAAC,MAAM,CAAC,WAAW,CAAC;YAClC,OAAO,EAAE,GAAG,EAAE,CAAC,EAAE;SAClB;QACD,SAAS,EAAE,IAAI;QACf,MAAM,EAAE,IAAI;QACZ,IAAI,EAAE,IAAI;QACV,QAAQ,EAAE,IAAI;QACd,KAAK,EAAE,IAAI;QACX,IAAI,EAAE,IAAI;QACV,OAAO,EAAE,IAAI;QACb,IAAI,EAAE,IAAI;QACV,QAAQ,EAAE,IAAI;QACd,YAAY,EAAE,IAAI;QAClB,KAAK,EAAE,IAAI;QACX,SAAS,EAAE,IAAI;KAChB;CACF,CAAC,AArBQ,CAqBP;4BA3BM,iBAAiB;IAD7B,IAAA,mBAAU,GAAE;6CAIc,4BAAY;QACZ,4BAAY;GAJ1B,iBAAiB,CAgU7B"}

apps/backend/dist/libraries/nestjs-libraries/src/agent/agent.module.d.ts

@@ -0,0 +1,2 @@
+export declare class AgentModule {
+}

apps/backend/dist/libraries/nestjs-libraries/src/agent/agent.module.js

@@ -0,0 +1,20 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+exports.AgentModule = void 0;
+const tslib_1 = require("tslib");
+const common_1 = require("@nestjs/common");
+const agent_graph_service_1 = require("./agent.graph.service");
+const agent_graph_insert_service_1 = require("./agent.graph.insert.service");
+let AgentModule = class AgentModule {
+};
+exports.AgentModule = AgentModule;
+exports.AgentModule = AgentModule = tslib_1.__decorate([
+    (0, common_1.Global)(),
+    (0, common_1.Module)({
+        providers: [agent_graph_service_1.AgentGraphService, agent_graph_insert_service_1.AgentGraphInsertService],
+        get exports() {
+            return this.providers;
+        },
+    })
+], AgentModule);
+//# sourceMappingURL=agent.module.js.map

apps/backend/dist/libraries/nestjs-libraries/src/agent/agent.module.js.map

@@ -0,0 +1 @@
+{"version":3,"file":"agent.module.js","sourceRoot":"","sources":["../../../../../../../libraries/nestjs-libraries/src/agent/agent.module.ts"],"names":[],"mappings":";;;;AAAA,2CAAgD;AAChD,+DAAwF;AACxF,6EAAqG;AAS9F,IAAM,WAAW,GAAjB,MAAM,WAAW;CAAG,CAAA;AAAd,kCAAW;sBAAX,WAAW;IAPvB,IAAA,eAAM,GAAE;IACR,IAAA,eAAM,EAAC;QACN,SAAS,EAAE,CAAC,uCAAiB,EAAE,oDAAuB,CAAC;QACvD,IAAI,OAAO;YACT,OAAO,IAAI,CAAC,SAAS,CAAC;QACxB,CAAC;KACF,CAAC;GACW,WAAW,CAAG"}

apps/backend/dist/libraries/nestjs-libraries/src/agent/agent.topics.d.ts

@@ -0,0 +1 @@
+export declare const agentTopics: string[];

apps/backend/dist/libraries/nestjs-libraries/src/agent/agent.topics.js

@@ -0,0 +1,86 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+exports.agentTopics = void 0;
+exports.agentTopics = [
+    'Business',
+    'Marketing',
+    'Finance',
+    'Startups',
+    'Networking',
+    'Leadership',
+    'Strategy',
+    'Branding',
+    'Analytics',
+    'Growth',
+    'Drawing',
+    'Painting',
+    'Design',
+    'Photography',
+    'Writing',
+    'Sculpting',
+    'Animation',
+    'Sketching',
+    'Crafting',
+    'Calligraphy',
+    'Mindset',
+    'Productivity',
+    'Motivation',
+    'Education',
+    'Learning',
+    'Skills',
+    'Success',
+    'Wellness',
+    'Goals',
+    'Inspiration',
+    'Fashion',
+    'Travel',
+    'Food',
+    'Fitness',
+    'Health',
+    'Beauty',
+    'Home',
+    'Decor',
+    'Hobbies',
+    'Parenting',
+    'Tech',
+    'Gadgets',
+    'AI',
+    'Coding',
+    'Software',
+    'Innovation',
+    'Apps',
+    'Gaming',
+    'Robotics',
+    'Security',
+    'Music',
+    'Movies',
+    'Sports',
+    'Books',
+    'Theater',
+    'Comedy',
+    'Dance',
+    'Celebrities',
+    'Culture',
+    'Gaming',
+    'Environment',
+    'Equality',
+    'Activism',
+    'Justice',
+    'Diversity',
+    'Sustainability',
+    'Inclusion',
+    'Awareness',
+    'Charity',
+    'Peace',
+    'Holidays',
+    'Festivities',
+    'Seasons',
+    'Trends',
+    'Celebrations',
+    'Anniversaries',
+    'Milestones',
+    'Memories',
+    'Promotions',
+    'Updates',
+];
+//# sourceMappingURL=agent.topics.js.map

apps/backend/dist/libraries/nestjs-libraries/src/agent/agent.topics.js.map

@@ -0,0 +1 @@
+{"version":3,"file":"agent.topics.js","sourceRoot":"","sources":["../../../../../../../libraries/nestjs-libraries/src/agent/agent.topics.ts"],"names":[],"mappings":";;;AAAa,QAAA,WAAW,GAAG;IACzB,UAAU;IACV,WAAW;IACX,SAAS;IACT,UAAU;IACV,YAAY;IACZ,YAAY;IACZ,UAAU;IACV,UAAU;IACV,WAAW;IACX,QAAQ;IACR,SAAS;IACT,UAAU;IACV,QAAQ;IACR,aAAa;IACb,SAAS;IACT,WAAW;IACX,WAAW;IACX,WAAW;IACX,UAAU;IACV,aAAa;IACb,SAAS;IACT,cAAc;IACd,YAAY;IACZ,WAAW;IACX,UAAU;IACV,QAAQ;IACR,SAAS;IACT,UAAU;IACV,OAAO;IACP,aAAa;IACb,SAAS;IACT,QAAQ;IACR,MAAM;IACN,SAAS;IACT,QAAQ;IACR,QAAQ;IACR,MAAM;IACN,OAAO;IACP,SAAS;IACT,WAAW;IACX,MAAM;IACN,SAAS;IACT,IAAI;IACJ,QAAQ;IACR,UAAU;IACV,YAAY;IACZ,MAAM;IACN,QAAQ;IACR,UAAU;IACV,UAAU;IACV,OAAO;IACP,QAAQ;IACR,QAAQ;IACR,OAAO;IACP,SAAS;IACT,QAAQ;IACR,OAAO;IACP,aAAa;IACb,SAAS;IACT,QAAQ;IACR,aAAa;IACb,UAAU;IACV,UAAU;IACV,SAAS;IACT,WAAW;IACX,gBAAgB;IAChB,WAAW;IACX,WAAW;IACX,SAAS;IACT,OAAO;IACP,UAAU;IACV,aAAa;IACb,SAAS;IACT,QAAQ;IACR,cAAc;IACd,eAAe;IACf,YAAY;IACZ,UAAU;IACV,YAAY;IACZ,SAAS;CACV,CAAC"}

apps/backend/dist/libraries/nestjs-libraries/src/chat/agent.tool.interface.d.ts

@@ -0,0 +1,6 @@
+import type { ToolAction } from '@mastra/core/tools';
+export type ToolReturn = ToolAction<any, any, any, any, any, any>;
+export interface AgentToolInterface {
+    name: string;
+    run(): ToolReturn;
+}

apps/backend/dist/libraries/nestjs-libraries/src/chat/agent.tool.interface.js

@@ -0,0 +1,3 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+//# sourceMappingURL=agent.tool.interface.js.map

apps/backend/dist/libraries/nestjs-libraries/src/chat/agent.tool.interface.js.map

@@ -0,0 +1 @@
+{"version":3,"file":"agent.tool.interface.js","sourceRoot":"","sources":["../../../../../../../libraries/nestjs-libraries/src/chat/agent.tool.interface.ts"],"names":[],"mappings":""}

apps/backend/dist/libraries/nestjs-libraries/src/chat/async.storage.d.ts

@@ -0,0 +1,9 @@
+type Ctx = {
+    requestId: string;
+    auth: any;
+};
+export declare function runWithContext<T>(ctx: Ctx, fn: () => Promise<T> | T): T | Promise<T>;
+export declare function getContext(): Ctx | undefined;
+export declare function getAuth<T = any>(): T | undefined;
+export declare function getRequestId(): string | undefined;
+export {};

apps/backend/dist/libraries/nestjs-libraries/src/chat/async.storage.js

@@ -0,0 +1,21 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+exports.runWithContext = runWithContext;
+exports.getContext = getContext;
+exports.getAuth = getAuth;
+exports.getRequestId = getRequestId;
+const node_async_hooks_1 = require("node:async_hooks");
+const als = new node_async_hooks_1.AsyncLocalStorage();
+function runWithContext(ctx, fn) {
+    return als.run(ctx, fn);
+}
+function getContext() {
+    return als.getStore();
+}
+function getAuth() {
+    return als.getStore()?.auth;
+}
+function getRequestId() {
+    return als.getStore()?.requestId;
+}
+//# sourceMappingURL=async.storage.js.map

apps/backend/dist/libraries/nestjs-libraries/src/chat/async.storage.js.map

@@ -0,0 +1 @@
+{"version":3,"file":"async.storage.js","sourceRoot":"","sources":["../../../../../../../libraries/nestjs-libraries/src/chat/async.storage.ts"],"names":[],"mappings":";;AAUA,wCAEC;AAED,gCAEC;AAED,0BAEC;AAED,oCAEC;AAvBD,uDAAqD;AAOrD,MAAM,GAAG,GAAG,IAAI,oCAAiB,EAAO,CAAC;AAEzC,SAAgB,cAAc,CAAI,GAAQ,EAAE,EAAwB;IAClE,OAAO,GAAG,CAAC,GAAG,CAAC,GAAG,EAAE,EAAE,CAAC,CAAC;AAC1B,CAAC;AAED,SAAgB,UAAU;IACxB,OAAO,GAAG,CAAC,QAAQ,EAAE,CAAC;AACxB,CAAC;AAED,SAAgB,OAAO;IACrB,OAAO,GAAG,CAAC,QAAQ,EAAE,EAAE,IAAqB,CAAC;AAC/C,CAAC;AAED,SAAgB,YAAY;IAC1B,OAAO,GAAG,CAAC,QAAQ,EAAE,EAAE,SAAS,CAAC;AACnC,CAAC"}

apps/backend/dist/libraries/nestjs-libraries/src/chat/auth.context.d.ts

@@ -0,0 +1 @@
+export declare const checkAuth: (inputData: any, context: any) => void;

apps/backend/dist/libraries/nestjs-libraries/src/chat/auth.context.js

@@ -0,0 +1,14 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+exports.checkAuth = void 0;
+const async_storage_1 = require("./async.storage");
+const checkAuth = (inputData, context) => {
+    const auth = (0, async_storage_1.getAuth)();
+    const authInfo = context?.mcp?.extra?.authInfo || auth;
+    if (authInfo && context?.requestContext) {
+        context.requestContext.set('organization', JSON.stringify(authInfo));
+        context.requestContext.set('ui', 'false');
+    }
+};
+exports.checkAuth = checkAuth;
+//# sourceMappingURL=auth.context.js.map

apps/backend/dist/libraries/nestjs-libraries/src/chat/auth.context.js.map

@@ -0,0 +1 @@
+{"version":3,"file":"auth.context.js","sourceRoot":"","sources":["../../../../../../../libraries/nestjs-libraries/src/chat/auth.context.ts"],"names":[],"mappings":";;;AAAA,mDAAuE;AAEhE,MAAM,SAAS,GAAG,CACvB,SAAc,EACd,OAAY,EACZ,EAAE;IACF,MAAM,IAAI,GAAG,IAAA,uBAAO,GAAE,CAAC;IACvB,MAAM,QAAQ,GAAG,OAAO,EAAE,GAAG,EAAE,KAAK,EAAE,QAAQ,IAAI,IAAI,CAAC;IACvD,IAAI,QAAQ,IAAI,OAAO,EAAE,cAAc,EAAE,CAAC;QACvC,OAAO,CAAC,cAAsB,CAAC,GAAG,CACjC,cAAc,EACd,IAAI,CAAC,SAAS,CAAC,QAAQ,CAAC,CACzB,CAAC;QACD,OAAO,CAAC,cAAsB,CAAC,GAAG,CAAC,IAAI,EAAE,OAAO,CAAC,CAAC;IACrD,CAAC;AACH,CAAC,CAAC;AAbW,QAAA,SAAS,aAapB"}

apps/backend/dist/libraries/nestjs-libraries/src/chat/chat.module.d.ts

@@ -0,0 +1,2 @@
+export declare class ChatModule {
+}

apps/backend/dist/libraries/nestjs-libraries/src/chat/chat.module.js

@@ -0,0 +1,21 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+exports.ChatModule = void 0;
+const tslib_1 = require("tslib");
+const common_1 = require("@nestjs/common");
+const load_tools_service_1 = require("./load.tools.service");
+const mastra_service_1 = require("./mastra.service");
+const tool_list_1 = require("./tools/tool.list");
+let ChatModule = class ChatModule {
+};
+exports.ChatModule = ChatModule;
+exports.ChatModule = ChatModule = tslib_1.__decorate([
+    (0, common_1.Global)(),
+    (0, common_1.Module)({
+        providers: [mastra_service_1.MastraService, load_tools_service_1.LoadToolsService, ...tool_list_1.toolList],
+        get exports() {
+            return this.providers;
+        },
+    })
+], ChatModule);
+//# sourceMappingURL=chat.module.js.map

apps/backend/dist/libraries/nestjs-libraries/src/chat/chat.module.js.map

@@ -0,0 +1 @@
+{"version":3,"file":"chat.module.js","sourceRoot":"","sources":["../../../../../../../libraries/nestjs-libraries/src/chat/chat.module.ts"],"names":[],"mappings":";;;;AAAA,2CAAgD;AAChD,6DAAqF;AACrF,qDAA8E;AAC9E,iDAA0E;AASnE,IAAM,UAAU,GAAhB,MAAM,UAAU;CAAG,CAAA;AAAb,gCAAU;qBAAV,UAAU;IAPtB,IAAA,eAAM,GAAE;IACR,IAAA,eAAM,EAAC;QACN,SAAS,EAAE,CAAC,8BAAa,EAAE,qCAAgB,EAAE,GAAG,oBAAQ,CAAC;QACzD,IAAI,OAAO;YACT,OAAO,IAAI,CAAC,SAAS,CAAC;QACxB,CAAC;KACF,CAAC;GACW,UAAU,CAAG"}

apps/backend/dist/libraries/nestjs-libraries/src/chat/load.tools.service.d.ts

@@ -0,0 +1,15 @@
+import { Agent } from '@mastra/core/agent';
+import { ModuleRef } from '@nestjs/core';
+export declare const AgentState: import("zod").ZodObject<{
+    proverbs: import("zod").ZodDefault<import("zod").ZodArray<import("zod").ZodString, "many">>;
+}, "strip", import("zod").ZodTypeAny, {
+    proverbs?: string[];
+}, {
+    proverbs?: string[];
+}>;
+export declare class LoadToolsService {
+    private _moduleRef;
+    constructor(_moduleRef: ModuleRef);
+    loadTools(): Promise<Record<string, any>>;
+    agent(): Promise<Agent<"postiz", Record<string, any>, undefined, unknown>>;
+}

apps/backend/dist/libraries/nestjs-libraries/src/chat/load.tools.service.js

@@ -0,0 +1,101 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+exports.LoadToolsService = exports.AgentState = void 0;
+const tslib_1 = require("tslib");
+const common_1 = require("@nestjs/common");
+const agent_1 = require("@mastra/core/agent");
+const openai_1 = require("@ai-sdk/openai");
+const memory_1 = require("@mastra/memory");
+const mastra_store_1 = require("./mastra.store");
+const zod_1 = require("zod");
+const core_1 = require("@nestjs/core");
+const tool_list_1 = require("./tools/tool.list");
+const dayjs_1 = tslib_1.__importDefault(require("dayjs"));
+exports.AgentState = (0, zod_1.object)({
+    proverbs: (0, zod_1.array)((0, zod_1.string)()).default([]),
+});
+const renderArray = (list, show) => {
+    if (!show)
+        return '';
+    return list.map((p) => `- ${p}`).join('\n');
+};
+let LoadToolsService = class LoadToolsService {
+    constructor(_moduleRef) {
+        this._moduleRef = _moduleRef;
+    }
+    async loadTools() {
+        return (await Promise.all(tool_list_1.toolList
+            .map((p) => this._moduleRef.get(p, { strict: false }))
+            .map(async (p) => ({
+            name: p.name,
+            tool: await p.run(),
+        })))).reduce((all, current) => ({
+            ...all,
+            [current.name]: current.tool,
+        }), {});
+    }
+    async agent() {
+        const tools = await this.loadTools();
+        return new agent_1.Agent({
+            id: 'postiz',
+            name: 'postiz',
+            description: 'Agent that helps manage and schedule social media posts for users',
+            instructions: ({ requestContext }) => {
+                const ui = requestContext.get('ui');
+                return `
+      Global information:
+        - Date (UTC): ${(0, dayjs_1.default)().format('YYYY-MM-DD HH:mm:ss')}
+
+      You are an agent that helps manage and schedule social media posts for users, you can:
+        - Schedule posts into the future, or now, adding texts, images and videos
+        - Generate pictures for posts
+        - Generate videos for posts
+        - Generate text for posts
+        - Show global analytics about socials
+        - List integrations (channels)
+        - List groups (customers) and filter the channels by a group
+
+      - We schedule posts to different integration like facebook, instagram, etc. but to the user we don't say integrations we say channels as integration is the technical name
+      - When scheduling a post, you must follow the social media rules and best practices.
+      - When scheduling a post, you can pass an array for list of posts for a social media platform, But it has different behavior depending on the platform.
+        - For platforms like Threads, Bluesky and X (Twitter), each post in the array will be a separate post in the thread.
+        - For platforms like LinkedIn and Facebook, second part of the array will be added as "comments" to the first post.
+        - If the social media platform has the concept of "threads", we need to ask the user if they want to create a thread or one long post.
+        - For X, if you don't have Premium, don't suggest a long post because it won't work.
+        - Platform format will also be passed can be "normal", "markdown", "html", make sure you use the correct format for each platform.
+      
+      - Sometimes 'integrationSchema' will return rules, make sure you follow them (these rules are set in stone, even if the user asks to ignore them)
+      - Each socials media platform has different settings and rules, you can get them by using the integrationSchema tool.
+      - Always make sure you use this tool before you schedule any post.
+      - In every message I will send you the list of needed social medias (id and platform), if you already have the information use it, if not, use the integrationSchema tool to get it.
+      - Make sure you always take the last information I give you about the socials, it might have changed.
+      - Before scheduling a post, always make sure you ask the user confirmation by providing all the details of the post (text, images, videos, date, time, social media platform, account).
+      - Between tools, we will reference things like: [output:name] and [input:name] to set the information right.
+      - When outputting a date for the user, make sure it's human readable with time
+      - The content of the post, HTML, Each line must be wrapped in <p> here is the possible tags: h1, h2, h3, u, strong, li, ul, p (you can\'t have u and strong together), don't use a "code" box
+      ${renderArray([
+                    'If the user confirm, ask if they would like to get a modal with populated content without scheduling the post yet or if they want to schedule it right away.',
+                ], !!ui)}
+`;
+            },
+            model: (0, openai_1.openai)('gpt-5.2'),
+            tools,
+            memory: new memory_1.Memory({
+                storage: mastra_store_1.pStore,
+                options: {
+                    generateTitle: true,
+                    workingMemory: {
+                        enabled: true,
+                        schema: exports.AgentState,
+                    },
+                },
+            }),
+        });
+    }
+};
+exports.LoadToolsService = LoadToolsService;
+exports.LoadToolsService = LoadToolsService = tslib_1.__decorate([
+    (0, common_1.Injectable)(),
+    tslib_1.__metadata("design:paramtypes", [core_1.ModuleRef])
+], LoadToolsService);
+//# sourceMappingURL=load.tools.service.js.map

apps/backend/dist/libraries/nestjs-libraries/src/chat/load.tools.service.js.map

@@ -0,0 +1 @@
+{"version":3,"file":"load.tools.service.js","sourceRoot":"","sources":["../../../../../../../libraries/nestjs-libraries/src/chat/load.tools.service.ts"],"names":[],"mappings":";;;;AAAA,2CAA4C;AAC5C,8CAA2C;AAC3C,2CAAwC;AACxC,2CAAwC;AACxC,iDAAqE;AACrE,6BAA4C;AAC5C,uCAAyC;AACzC,iDAA0E;AAC1E,0DAA0B;AAEb,QAAA,UAAU,GAAG,IAAA,YAAM,EAAC;IAC/B,QAAQ,EAAE,IAAA,WAAK,EAAC,IAAA,YAAM,GAAE,CAAC,CAAC,OAAO,CAAC,EAAE,CAAC;CACtC,CAAC,CAAC;AAEH,MAAM,WAAW,GAAG,CAAC,IAAc,EAAE,IAAa,EAAE,EAAE;IACpD,IAAI,CAAC,IAAI;QAAE,OAAO,EAAE,CAAC;IACrB,OAAO,IAAI,CAAC,GAAG,CAAC,CAAC,CAAC,EAAE,EAAE,CAAC,KAAK,CAAC,EAAE,CAAC,CAAC,IAAI,CAAC,IAAI,CAAC,CAAC;AAC9C,CAAC,CAAC;AAGK,IAAM,gBAAgB,GAAtB,MAAM,gBAAgB;IAC3B,YAAoB,UAAqB;QAArB,eAAU,GAAV,UAAU,CAAW;IAAG,CAAC;IAE7C,KAAK,CAAC,SAAS;QACb,OAAO,CACL,MAAM,OAAO,CAAC,GAAG,CACf,oBAAQ;aACL,GAAG,CAAC,CAAC,CAAC,EAAE,EAAE,CAAC,IAAI,CAAC,UAAU,CAAC,GAAG,CAAC,CAAC,EAAE,EAAE,MAAM,EAAE,KAAK,EAAE,CAAC,CAAC;aACrD,GAAG,CAAC,KAAK,EAAE,CAAC,EAAE,EAAE,CAAC,CAAC;YACjB,IAAI,EAAE,CAAC,CAAC,IAAc;YACtB,IAAI,EAAE,MAAM,CAAC,CAAC,GAAG,EAAE;SACpB,CAAC,CAAC,CACN,CACF,CAAC,MAAM,CACN,CAAC,GAAG,EAAE,OAAO,EAAE,EAAE,CAAC,CAAC;YACjB,GAAG,GAAG;YACN,CAAC,OAAO,CAAC,IAAI,CAAC,EAAE,OAAO,CAAC,IAAI;SAC7B,CAAC,EACF,EAAyB,CAC1B,CAAC;IACJ,CAAC;IAED,KAAK,CAAC,KAAK;QACT,MAAM,KAAK,GAAG,MAAM,IAAI,CAAC,SAAS,EAAE,CAAC;QACrC,OAAO,IAAI,aAAK,CAAC;YACf,EAAE,EAAE,QAAQ;YACZ,IAAI,EAAE,QAAQ;YACd,WAAW,EAAE,mEAAmE;YAChF,YAAY,EAAE,CAAC,EAAE,cAAc,EAAE,EAAE,EAAE;gBACnC,MAAM,EAAE,GAAW,cAAc,CAAC,GAAG,CAAC,IAAa,CAAC,CAAC;gBACrD,OAAO;;wBAES,IAAA,eAAK,GAAE,CAAC,MAAM,CAAC,qBAAqB,CAAC;;;;;;;;;;;;;;;;;;;;;;;;;;;;;QA6BrD,WAAW,CACX;oBACE,8JAA8J;iBAC/J,EACD,CAAC,CAAC,EAAE,CACL;CACN,CAAC;YACI,CAAC;YACD,KAAK,EAAE,IAAA,eAAM,EAAC,SAAS,CAAC;YACxB,KAAK;YACL,MAAM,EAAE,IAAI,eAAM,CAAC;gBACjB,OAAO,EAAE,qBAAM;gBACf,OAAO,EAAE;oBACP,aAAa,EAAE,IAAI;oBACnB,aAAa,EAAE;wBACb,OAAO,EAAE,IAAI;wBACb,MAAM,EAAE,kBAAU;qBACnB;iBACF;aACF,CAAC;SACH,CAAC,CAAC;IACL,CAAC;CACF,CAAA;AAnFY,4CAAgB;2BAAhB,gBAAgB;IAD5B,IAAA,mBAAU,GAAE;6CAEqB,gBAAS;GAD9B,gBAAgB,CAmF5B"}

apps/backend/dist/libraries/nestjs-libraries/src/chat/mastra.service.d.ts

@@ -0,0 +1,8 @@
+import { Mastra } from '@mastra/core/mastra';
+import { LoadToolsService } from "./load.tools.service";
+export declare class MastraService {
+    private _loadToolsService;
+    static mastra: Mastra;
+    constructor(_loadToolsService: LoadToolsService);
+    mastra(): Promise<Mastra<Record<string, import("@mastra/core/agent").Agent<any, import("@mastra/core/agent").ToolsInput, undefined, unknown>>, Record<string, import("@mastra/core/workflows").AnyWorkflow>, Record<string, import("@mastra/core/vector").MastraVector<any>>, Record<string, import("@mastra/core/dist/tts").MastraTTS>, import("@mastra/core/logger").IMastraLogger, Record<string, import("@mastra/core/mcp").MCPServerBase<any>>, Record<string, import("@mastra/core/evals").MastraScorer<any, any, any, any>>, Record<string, import("@mastra/core/tools").ToolAction<any, any, any, any, any, any, unknown>>, Record<string, import("@mastra/core/processors").Processor<any, unknown>>, Record<string, import("@mastra/core/memory").MastraMemory>>>;
+}

apps/backend/dist/libraries/nestjs-libraries/src/chat/mastra.service.js

@@ -0,0 +1,35 @@
+"use strict";
+var MastraService_1;
+Object.defineProperty(exports, "__esModule", { value: true });
+exports.MastraService = void 0;
+const tslib_1 = require("tslib");
+const mastra_1 = require("@mastra/core/mastra");
+const logger_1 = require("@mastra/core/logger");
+const mastra_store_1 = require("./mastra.store");
+const common_1 = require("@nestjs/common");
+const load_tools_service_1 = require("./load.tools.service");
+let MastraService = MastraService_1 = class MastraService {
+    constructor(_loadToolsService) {
+        this._loadToolsService = _loadToolsService;
+    }
+    async mastra() {
+        MastraService_1.mastra =
+            MastraService_1.mastra ||
+                new mastra_1.Mastra({
+                    storage: mastra_store_1.pStore,
+                    agents: {
+                        postiz: await this._loadToolsService.agent(),
+                    },
+                    logger: new logger_1.ConsoleLogger({
+                        level: 'info',
+                    }),
+                });
+        return MastraService_1.mastra;
+    }
+};
+exports.MastraService = MastraService;
+exports.MastraService = MastraService = MastraService_1 = tslib_1.__decorate([
+    (0, common_1.Injectable)(),
+    tslib_1.__metadata("design:paramtypes", [load_tools_service_1.LoadToolsService])
+], MastraService);
+//# sourceMappingURL=mastra.service.js.map

apps/backend/dist/libraries/nestjs-libraries/src/chat/mastra.service.js.map

@@ -0,0 +1 @@
+{"version":3,"file":"mastra.service.js","sourceRoot":"","sources":["../../../../../../../libraries/nestjs-libraries/src/chat/mastra.service.ts"],"names":[],"mappings":";;;;;AAAA,gDAA6C;AAC7C,gDAAoD;AACpD,iDAAqE;AACrE,2CAA4C;AAC5C,6DAAqF;AAG9E,IAAM,aAAa,qBAAnB,MAAM,aAAa;IAExB,YAAoB,iBAAmC;QAAnC,sBAAiB,GAAjB,iBAAiB,CAAkB;IAAG,CAAC;IAC3D,KAAK,CAAC,MAAM;QACV,eAAa,CAAC,MAAM;YAClB,eAAa,CAAC,MAAM;gBACpB,IAAI,eAAM,CAAC;oBACT,OAAO,EAAE,qBAAM;oBACf,MAAM,EAAE;wBACN,MAAM,EAAE,MAAM,IAAI,CAAC,iBAAiB,CAAC,KAAK,EAAE;qBAC7C;oBACD,MAAM,EAAE,IAAI,sBAAa,CAAC;wBACxB,KAAK,EAAE,MAAM;qBACd,CAAC;iBACH,CAAC,CAAC;QAEL,OAAO,eAAa,CAAC,MAAM,CAAC;IAC9B,CAAC;CACF,CAAA;AAlBY,sCAAa;wBAAb,aAAa;IADzB,IAAA,mBAAU,GAAE;6CAG4B,qCAAgB;GAF5C,aAAa,CAkBzB"}

apps/backend/dist/libraries/nestjs-libraries/src/chat/mastra.store.d.ts

@@ -0,0 +1,2 @@
+import { PostgresStore } from '@mastra/pg';
+export declare const pStore: PostgresStore;

apps/backend/dist/libraries/nestjs-libraries/src/chat/mastra.store.js

@@ -0,0 +1,9 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+exports.pStore = void 0;
+const pg_1 = require("@mastra/pg");
+exports.pStore = new pg_1.PostgresStore({
+    id: 'postiz-store',
+    connectionString: process.env.DATABASE_URL,
+});
+//# sourceMappingURL=mastra.store.js.map

apps/backend/dist/libraries/nestjs-libraries/src/chat/mastra.store.js.map

@@ -0,0 +1 @@
+{"version":3,"file":"mastra.store.js","sourceRoot":"","sources":["../../../../../../../libraries/nestjs-libraries/src/chat/mastra.store.ts"],"names":[],"mappings":";;;AAAA,mCAA2C;AAE9B,QAAA,MAAM,GAAG,IAAI,kBAAa,CAAC;IACtC,EAAE,EAAE,cAAc;IAClB,gBAAgB,EAAE,OAAO,CAAC,GAAG,CAAC,YAAa;CAC5C,CAAC,CAAC"}

apps/backend/dist/libraries/nestjs-libraries/src/chat/oauth-middleware.d.ts

@@ -0,0 +1,22 @@
+import type * as http from 'node:http';
+import type { MCPServerOAuthConfig, TokenValidationResult } from './oauth-types';
+interface OAuthMiddlewareLogger {
+    debug?: (message: string, ...args: unknown[]) => void;
+}
+export interface OAuthMiddlewareOptions {
+    oauth: MCPServerOAuthConfig;
+    mcpPath?: string;
+    logger?: OAuthMiddlewareLogger;
+}
+export interface OAuthMiddlewareResult {
+    proceed: boolean;
+    handled: boolean;
+    tokenValidation?: TokenValidationResult;
+}
+export declare function createOAuthMiddleware(options: OAuthMiddlewareOptions): (req: http.IncomingMessage, res: http.ServerResponse, url: URL) => Promise<OAuthMiddlewareResult>;
+export declare function createStaticTokenValidator(validTokens: string[]): MCPServerOAuthConfig['validateToken'];
+export declare function createIntrospectionValidator(introspectionEndpoint: string, clientCredentials?: {
+    clientId: string;
+    clientSecret: string;
+}): MCPServerOAuthConfig['validateToken'];
+export {};

apps/backend/dist/libraries/nestjs-libraries/src/chat/oauth-middleware.js

@@ -0,0 +1,168 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+exports.createOAuthMiddleware = createOAuthMiddleware;
+exports.createStaticTokenValidator = createStaticTokenValidator;
+exports.createIntrospectionValidator = createIntrospectionValidator;
+const oauth_types_1 = require("./oauth-types");
+function createOAuthMiddleware(options) {
+    const { oauth, mcpPath = '/mcp', logger } = options;
+    const protectedResourceMetadata = (0, oauth_types_1.generateProtectedResourceMetadata)(oauth);
+    const wellKnownPath = '/.well-known/oauth-protected-resource';
+    const resourceMetadataUrl = new URL(wellKnownPath, oauth.resource).toString();
+    return async function oauthMiddleware(req, res, url) {
+        logger?.debug?.(`OAuth middleware: ${req.method} ${url.pathname}`);
+        if (url.pathname === wellKnownPath && req.method === 'GET') {
+            logger?.debug?.('OAuth middleware: Serving Protected Resource Metadata');
+            res.writeHead(200, {
+                'Content-Type': 'application/json',
+                'Cache-Control': 'max-age=3600',
+                'Access-Control-Allow-Origin': '*',
+            });
+            res.end(JSON.stringify(protectedResourceMetadata));
+            return { proceed: false, handled: true };
+        }
+        if (url.pathname === wellKnownPath && req.method === 'OPTIONS') {
+            res.writeHead(204, {
+                'Access-Control-Allow-Origin': '*',
+                'Access-Control-Allow-Methods': 'GET, OPTIONS',
+                'Access-Control-Allow-Headers': 'Content-Type',
+                'Access-Control-Max-Age': '86400',
+            });
+            res.end();
+            return { proceed: false, handled: true };
+        }
+        if (!url.pathname.startsWith(mcpPath)) {
+            return { proceed: true, handled: false };
+        }
+        const authHeader = req.headers['authorization'];
+        const token = (0, oauth_types_1.extractBearerToken)(authHeader);
+        if (!token) {
+            logger?.debug?.('OAuth middleware: No bearer token provided');
+            res.writeHead(401, {
+                'Content-Type': 'application/json',
+                'WWW-Authenticate': (0, oauth_types_1.generateWWWAuthenticateHeader)({ resourceMetadataUrl }),
+            });
+            res.end(JSON.stringify({
+                error: 'unauthorized',
+                error_description: 'Bearer token required',
+            }));
+            return { proceed: false, handled: true };
+        }
+        if (oauth.validateToken) {
+            logger?.debug?.('OAuth middleware: Validating token');
+            const validationResult = await oauth.validateToken(token, oauth.resource);
+            if (!validationResult.valid) {
+                logger?.debug?.(`OAuth middleware: Token validation failed: ${validationResult.error}`);
+                res.writeHead(401, {
+                    'Content-Type': 'application/json',
+                    'WWW-Authenticate': (0, oauth_types_1.generateWWWAuthenticateHeader)({
+                        resourceMetadataUrl,
+                        additionalParams: {
+                            error: validationResult.error || 'invalid_token',
+                            ...(validationResult.errorDescription && {
+                                error_description: validationResult.errorDescription,
+                            }),
+                        },
+                    }),
+                });
+                res.end(JSON.stringify({
+                    error: validationResult.error || 'invalid_token',
+                    error_description: validationResult.errorDescription || 'Token validation failed',
+                }));
+                return { proceed: false, handled: true, tokenValidation: validationResult };
+            }
+            logger?.debug?.('OAuth middleware: Token validated successfully');
+            return { proceed: true, handled: false, tokenValidation: validationResult };
+        }
+        logger?.debug?.('OAuth middleware: No token validation configured, accepting token');
+        return {
+            proceed: true,
+            handled: false,
+            tokenValidation: { valid: true },
+        };
+    };
+}
+function createStaticTokenValidator(validTokens) {
+    const tokenSet = new Set(validTokens);
+    return async (token) => {
+        if (tokenSet.has(token)) {
+            return { valid: true, scopes: ['mcp:read', 'mcp:write'] };
+        }
+        return {
+            valid: false,
+            error: 'invalid_token',
+            errorDescription: 'Token not recognized',
+        };
+    };
+}
+function createIntrospectionValidator(introspectionEndpoint, clientCredentials) {
+    return async (token, resource) => {
+        try {
+            const headers = {
+                'Content-Type': 'application/x-www-form-urlencoded',
+            };
+            if (clientCredentials) {
+                if (clientCredentials.clientId.includes(':')) {
+                    return {
+                        valid: false,
+                        error: 'invalid_request',
+                        errorDescription: 'clientId cannot contain a colon character per RFC 7617',
+                    };
+                }
+                const credentials = Buffer.from(`${clientCredentials.clientId}:${clientCredentials.clientSecret}`).toString('base64');
+                headers['Authorization'] = `Basic ${credentials}`;
+            }
+            const response = await fetch(introspectionEndpoint, {
+                method: 'POST',
+                headers,
+                body: new URLSearchParams({
+                    token,
+                    token_type_hint: 'access_token',
+                }),
+            });
+            if (!response.ok) {
+                return {
+                    valid: false,
+                    error: 'server_error',
+                    errorDescription: `Introspection failed: ${response.status}`,
+                };
+            }
+            const data = (await response.json());
+            if (!data.active) {
+                return {
+                    valid: false,
+                    error: 'invalid_token',
+                    errorDescription: 'Token is not active',
+                };
+            }
+            if (data.aud) {
+                const audiences = Array.isArray(data.aud) ? data.aud : [data.aud];
+                if (!audiences.includes(resource)) {
+                    return {
+                        valid: false,
+                        error: 'invalid_token',
+                        errorDescription: 'Token audience does not match this resource',
+                    };
+                }
+            }
+            return {
+                valid: true,
+                scopes: data.scope
+                    ?.trim()
+                    .split(' ')
+                    .filter(s => s !== '') || [],
+                subject: data.sub,
+                expiresAt: data.exp,
+                claims: data,
+            };
+        }
+        catch (error) {
+            return {
+                valid: false,
+                error: 'server_error',
+                errorDescription: error instanceof Error ? error.message : 'Introspection failed',
+            };
+        }
+    };
+}
+//# sourceMappingURL=oauth-middleware.js.map

apps/backend/dist/libraries/nestjs-libraries/src/chat/oauth-middleware.js.map

@@ -0,0 +1 @@
+{"version":3,"file":"oauth-middleware.js","sourceRoot":"","sources":["../../../../../../../libraries/nestjs-libraries/src/chat/oauth-middleware.ts"],"names":[],"mappings":";;AAmCA,sDAsGC;AAED,gEAYC;AAkBD,oEAiFC;AA7OD,+CAIuB;AAkBvB,SAAgB,qBAAqB,CAAC,OAA+B;IACnE,MAAM,EAAE,KAAK,EAAE,OAAO,GAAG,MAAM,EAAE,MAAM,EAAE,GAAG,OAAO,CAAC;IAEpD,MAAM,yBAAyB,GAAG,IAAA,+CAAiC,EAAC,KAAK,CAAC,CAAC;IAC3E,MAAM,aAAa,GAAG,uCAAuC,CAAC;IAC9D,MAAM,mBAAmB,GAAG,IAAI,GAAG,CAAC,aAAa,EAAE,KAAK,CAAC,QAAQ,CAAC,CAAC,QAAQ,EAAE,CAAC;IAE9E,OAAO,KAAK,UAAU,eAAe,CACnC,GAAyB,EACzB,GAAwB,EACxB,GAAQ;QAER,MAAM,EAAE,KAAK,EAAE,CAAC,qBAAqB,GAAG,CAAC,MAAM,IAAI,GAAG,CAAC,QAAQ,EAAE,CAAC,CAAC;QAGnE,IAAI,GAAG,CAAC,QAAQ,KAAK,aAAa,IAAI,GAAG,CAAC,MAAM,KAAK,KAAK,EAAE,CAAC;YAC3D,MAAM,EAAE,KAAK,EAAE,CAAC,uDAAuD,CAAC,CAAC;YACzE,GAAG,CAAC,SAAS,CAAC,GAAG,EAAE;gBACjB,cAAc,EAAE,kBAAkB;gBAClC,eAAe,EAAE,cAAc;gBAC/B,6BAA6B,EAAE,GAAG;aACnC,CAAC,CAAC;YACH,GAAG,CAAC,GAAG,CAAC,IAAI,CAAC,SAAS,CAAC,yBAAyB,CAAC,CAAC,CAAC;YACnD,OAAO,EAAE,OAAO,EAAE,KAAK,EAAE,OAAO,EAAE,IAAI,EAAE,CAAC;QAC3C,CAAC;QAGD,IAAI,GAAG,CAAC,QAAQ,KAAK,aAAa,IAAI,GAAG,CAAC,MAAM,KAAK,SAAS,EAAE,CAAC;YAC/D,GAAG,CAAC,SAAS,CAAC,GAAG,EAAE;gBACjB,6BAA6B,EAAE,GAAG;gBAClC,8BAA8B,EAAE,cAAc;gBAC9C,8BAA8B,EAAE,cAAc;gBAC9C,wBAAwB,EAAE,OAAO;aAClC,CAAC,CAAC;YACH,GAAG,CAAC,GAAG,EAAE,CAAC;YACV,OAAO,EAAE,OAAO,EAAE,KAAK,EAAE,OAAO,EAAE,IAAI,EAAE,CAAC;QAC3C,CAAC;QAGD,IAAI,CAAC,GAAG,CAAC,QAAQ,CAAC,UAAU,CAAC,OAAO,CAAC,EAAE,CAAC;YACtC,OAAO,EAAE,OAAO,EAAE,IAAI,EAAE,OAAO,EAAE,KAAK,EAAE,CAAC;QAC3C,CAAC;QAGD,MAAM,UAAU,GAAG,GAAG,CAAC,OAAO,CAAC,eAAe,CAAC,CAAC;QAChD,MAAM,KAAK,GAAG,IAAA,gCAAkB,EAAC,UAAgC,CAAC,CAAC;QAEnE,IAAI,CAAC,KAAK,EAAE,CAAC;YACX,MAAM,EAAE,KAAK,EAAE,CAAC,4CAA4C,CAAC,CAAC;YAC9D,GAAG,CAAC,SAAS,CAAC,GAAG,EAAE;gBACjB,cAAc,EAAE,kBAAkB;gBAClC,kBAAkB,EAAE,IAAA,2CAA6B,EAAC,EAAE,mBAAmB,EAAE,CAAC;aAC3E,CAAC,CAAC;YACH,GAAG,CAAC,GAAG,CACL,IAAI,CAAC,SAAS,CAAC;gBACb,KAAK,EAAE,cAAc;gBACrB,iBAAiB,EAAE,uBAAuB;aAC3C,CAAC,CACH,CAAC;YACF,OAAO,EAAE,OAAO,EAAE,KAAK,EAAE,OAAO,EAAE,IAAI,EAAE,CAAC;QAC3C,CAAC;QAGD,IAAI,KAAK,CAAC,aAAa,EAAE,CAAC;YACxB,MAAM,EAAE,KAAK,EAAE,CAAC,oCAAoC,CAAC,CAAC;YACtD,MAAM,gBAAgB,GAAG,MAAM,KAAK,CAAC,aAAa,CAAC,KAAK,EAAE,KAAK,CAAC,QAAQ,CAAC,CAAC;YAE1E,IAAI,CAAC,gBAAgB,CAAC,KAAK,EAAE,CAAC;gBAC5B,MAAM,EAAE,KAAK,EAAE,CAAC,8CAA8C,gBAAgB,CAAC,KAAK,EAAE,CAAC,CAAC;gBACxF,GAAG,CAAC,SAAS,CAAC,GAAG,EAAE;oBACjB,cAAc,EAAE,kBAAkB;oBAClC,kBAAkB,EAAE,IAAA,2CAA6B,EAAC;wBAChD,mBAAmB;wBACnB,gBAAgB,EAAE;4BAChB,KAAK,EAAE,gBAAgB,CAAC,KAAK,IAAI,eAAe;4BAChD,GAAG,CAAC,gBAAgB,CAAC,gBAAgB,IAAI;gCACvC,iBAAiB,EAAE,gBAAgB,CAAC,gBAAgB;6BACrD,CAAC;yBACH;qBACF,CAAC;iBACH,CAAC,CAAC;gBACH,GAAG,CAAC,GAAG,CACL,IAAI,CAAC,SAAS,CAAC;oBACb,KAAK,EAAE,gBAAgB,CAAC,KAAK,IAAI,eAAe;oBAChD,iBAAiB,EAAE,gBAAgB,CAAC,gBAAgB,IAAI,yBAAyB;iBAClF,CAAC,CACH,CAAC;gBACF,OAAO,EAAE,OAAO,EAAE,KAAK,EAAE,OAAO,EAAE,IAAI,EAAE,eAAe,EAAE,gBAAgB,EAAE,CAAC;YAC9E,CAAC;YAED,MAAM,EAAE,KAAK,EAAE,CAAC,gDAAgD,CAAC,CAAC;YAClE,OAAO,EAAE,OAAO,EAAE,IAAI,EAAE,OAAO,EAAE,KAAK,EAAE,eAAe,EAAE,gBAAgB,EAAE,CAAC;QAC9E,CAAC;QAGD,MAAM,EAAE,KAAK,EAAE,CAAC,mEAAmE,CAAC,CAAC;QACrF,OAAO;YACL,OAAO,EAAE,IAAI;YACb,OAAO,EAAE,KAAK;YACd,eAAe,EAAE,EAAE,KAAK,EAAE,IAAI,EAAE;SACjC,CAAC;IACJ,CAAC,CAAC;AACJ,CAAC;AAED,SAAgB,0BAA0B,CAAC,WAAqB;IAC9D,MAAM,QAAQ,GAAG,IAAI,GAAG,CAAC,WAAW,CAAC,CAAC;IACtC,OAAO,KAAK,EAAE,KAAa,EAAkC,EAAE;QAC7D,IAAI,QAAQ,CAAC,GAAG,CAAC,KAAK,CAAC,EAAE,CAAC;YACxB,OAAO,EAAE,KAAK,EAAE,IAAI,EAAE,MAAM,EAAE,CAAC,UAAU,EAAE,WAAW,CAAC,EAAE,CAAC;QAC5D,CAAC;QACD,OAAO;YACL,KAAK,EAAE,KAAK;YACZ,KAAK,EAAE,eAAe;YACtB,gBAAgB,EAAE,sBAAsB;SACzC,CAAC;IACJ,CAAC,CAAC;AACJ,CAAC;AAkBD,SAAgB,4BAA4B,CAC1C,qBAA6B,EAC7B,iBAA8D;IAE9D,OAAO,KAAK,EAAE,KAAa,EAAE,QAAgB,EAAkC,EAAE;QAC/E,IAAI,CAAC;YACH,MAAM,OAAO,GAA2B;gBACtC,cAAc,EAAE,mCAAmC;aACpD,CAAC;YAEF,IAAI,iBAAiB,EAAE,CAAC;gBACtB,IAAI,iBAAiB,CAAC,QAAQ,CAAC,QAAQ,CAAC,GAAG,CAAC,EAAE,CAAC;oBAC7C,OAAO;wBACL,KAAK,EAAE,KAAK;wBACZ,KAAK,EAAE,iBAAiB;wBACxB,gBAAgB,EAAE,wDAAwD;qBAC3E,CAAC;gBACJ,CAAC;gBACD,MAAM,WAAW,GAAG,MAAM,CAAC,IAAI,CAAC,GAAG,iBAAiB,CAAC,QAAQ,IAAI,iBAAiB,CAAC,YAAY,EAAE,CAAC,CAAC,QAAQ,CACzG,QAAQ,CACT,CAAC;gBACF,OAAO,CAAC,eAAe,CAAC,GAAG,SAAS,WAAW,EAAE,CAAC;YACpD,CAAC;YAED,MAAM,QAAQ,GAAG,MAAM,KAAK,CAAC,qBAAqB,EAAE;gBAClD,MAAM,EAAE,MAAM;gBACd,OAAO;gBACP,IAAI,EAAE,IAAI,eAAe,CAAC;oBACxB,KAAK;oBACL,eAAe,EAAE,cAAc;iBAChC,CAAC;aACH,CAAC,CAAC;YAEH,IAAI,CAAC,QAAQ,CAAC,EAAE,EAAE,CAAC;gBACjB,OAAO;oBACL,KAAK,EAAE,KAAK;oBACZ,KAAK,EAAE,cAAc;oBACrB,gBAAgB,EAAE,yBAAyB,QAAQ,CAAC,MAAM,EAAE;iBAC7D,CAAC;YACJ,CAAC;YAED,MAAM,IAAI,GAAG,CAAC,MAAM,QAAQ,CAAC,IAAI,EAAE,CAA0B,CAAC;YAE9D,IAAI,CAAC,IAAI,CAAC,MAAM,EAAE,CAAC;gBACjB,OAAO;oBACL,KAAK,EAAE,KAAK;oBACZ,KAAK,EAAE,eAAe;oBACtB,gBAAgB,EAAE,qBAAqB;iBACxC,CAAC;YACJ,CAAC;YAED,IAAI,IAAI,CAAC,GAAG,EAAE,CAAC;gBACb,MAAM,SAAS,GAAG,KAAK,CAAC,OAAO,CAAC,IAAI,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC,IAAI,CAAC,GAAG,CAAC,CAAC,CAAC,CAAC,IAAI,CAAC,GAAG,CAAC,CAAC;gBAClE,IAAI,CAAC,SAAS,CAAC,QAAQ,CAAC,QAAQ,CAAC,EAAE,CAAC;oBAClC,OAAO;wBACL,KAAK,EAAE,KAAK;wBACZ,KAAK,EAAE,eAAe;wBACtB,gBAAgB,EAAE,6CAA6C;qBAChE,CAAC;gBACJ,CAAC;YACH,CAAC;YAED,OAAO;gBACL,KAAK,EAAE,IAAI;gBACX,MAAM,EACJ,IAAI,CAAC,KAAK;oBACR,EAAE,IAAI,EAAE;qBACP,KAAK,CAAC,GAAG,CAAC;qBACV,MAAM,CAAC,CAAC,CAAC,EAAE,CAAC,CAAC,KAAK,EAAE,CAAC,IAAI,EAAE;gBAChC,OAAO,EAAE,IAAI,CAAC,GAAG;gBACjB,SAAS,EAAE,IAAI,CAAC,GAAG;gBACnB,MAAM,EAAE,IAA+B;aACxC,CAAC;QACJ,CAAC;QAAC,OAAO,KAAK,EAAE,CAAC;YACf,OAAO;gBACL,KAAK,EAAE,KAAK;gBACZ,KAAK,EAAE,cAAc;gBACrB,gBAAgB,EAAE,KAAK,YAAY,KAAK,CAAC,CAAC,CAAC,KAAK,CAAC,OAAO,CAAC,CAAC,CAAC,sBAAsB;aAClF,CAAC;QACJ,CAAC;IACH,CAAC,CAAC;AACJ,CAAC"}

apps/backend/dist/libraries/nestjs-libraries/src/chat/oauth-types.d.ts

@@ -0,0 +1,32 @@
+export interface MCPServerOAuthConfig {
+    resource: string;
+    authorizationServers: string[];
+    scopesSupported?: string[];
+    resourceName?: string;
+    resourceDocumentation?: string;
+    validateToken?: (token: string, resource: string) => Promise<TokenValidationResult>;
+}
+export interface TokenValidationResult {
+    valid: boolean;
+    error?: string;
+    errorDescription?: string;
+    scopes?: string[];
+    subject?: string;
+    expiresAt?: number;
+    claims?: Record<string, unknown>;
+}
+export interface OAuthResponseOptions {
+    resourceMetadataUrl?: string;
+    additionalParams?: Record<string, string>;
+}
+export interface OAuthProtectedResourceMetadata {
+    resource: string;
+    authorization_servers: string[];
+    scopes_supported?: string[];
+    bearer_methods_supported?: string[];
+    resource_name?: string;
+    resource_documentation?: string;
+}
+export declare function generateWWWAuthenticateHeader(options?: OAuthResponseOptions): string;
+export declare function generateProtectedResourceMetadata(config: MCPServerOAuthConfig): OAuthProtectedResourceMetadata;
+export declare function extractBearerToken(authHeader: string | null | undefined): string | undefined;

apps/backend/dist/libraries/nestjs-libraries/src/chat/oauth-types.js

@@ -0,0 +1,47 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+exports.generateWWWAuthenticateHeader = generateWWWAuthenticateHeader;
+exports.generateProtectedResourceMetadata = generateProtectedResourceMetadata;
+exports.extractBearerToken = extractBearerToken;
+function escapeHeaderValue(value) {
+    return value.replace(/\\/g, '\\\\').replace(/"/g, '\\"');
+}
+function generateWWWAuthenticateHeader(options = {}) {
+    const params = [];
+    if (options.resourceMetadataUrl) {
+        params.push(`resource_metadata="${escapeHeaderValue(options.resourceMetadataUrl)}"`);
+    }
+    if (options.additionalParams) {
+        for (const [key, value] of Object.entries(options.additionalParams)) {
+            params.push(`${key}="${escapeHeaderValue(value)}"`);
+        }
+    }
+    if (params.length === 0) {
+        return 'Bearer';
+    }
+    return `Bearer ${params.join(', ')}`;
+}
+function generateProtectedResourceMetadata(config) {
+    return {
+        resource: config.resource,
+        authorization_servers: config.authorizationServers,
+        scopes_supported: config.scopesSupported ?? ['mcp:read', 'mcp:write'],
+        bearer_methods_supported: ['header'],
+        ...(config.resourceName && { resource_name: config.resourceName }),
+        ...(config.resourceDocumentation && {
+            resource_documentation: config.resourceDocumentation,
+        }),
+    };
+}
+function extractBearerToken(authHeader) {
+    if (!authHeader)
+        return undefined;
+    const prefix = 'bearer ';
+    if (authHeader.length <= prefix.length)
+        return undefined;
+    if (authHeader.slice(0, prefix.length).toLowerCase() !== prefix)
+        return undefined;
+    const token = authHeader.slice(prefix.length).trim();
+    return token || undefined;
+}
+//# sourceMappingURL=oauth-types.js.map

apps/backend/dist/libraries/nestjs-libraries/src/chat/oauth-types.js.map

@@ -0,0 +1 @@
+{"version":3,"file":"oauth-types.js","sourceRoot":"","sources":["../../../../../../../libraries/nestjs-libraries/src/chat/oauth-types.ts"],"names":[],"mappings":";;AA6DA,sEAkBC;AAED,8EAWC;AAED,gDASC;AA9CD,SAAS,iBAAiB,CAAC,KAAa;IACtC,OAAO,KAAK,CAAC,OAAO,CAAC,KAAK,EAAE,MAAM,CAAC,CAAC,OAAO,CAAC,IAAI,EAAE,KAAK,CAAC,CAAC;AAC3D,CAAC;AAED,SAAgB,6BAA6B,CAAC,UAAgC,EAAE;IAC9E,MAAM,MAAM,GAAa,EAAE,CAAC;IAE5B,IAAI,OAAO,CAAC,mBAAmB,EAAE,CAAC;QAChC,MAAM,CAAC,IAAI,CAAC,sBAAsB,iBAAiB,CAAC,OAAO,CAAC,mBAAmB,CAAC,GAAG,CAAC,CAAC;IACvF,CAAC;IAED,IAAI,OAAO,CAAC,gBAAgB,EAAE,CAAC;QAC7B,KAAK,MAAM,CAAC,GAAG,EAAE,KAAK,CAAC,IAAI,MAAM,CAAC,OAAO,CAAC,OAAO,CAAC,gBAAgB,CAAC,EAAE,CAAC;YACpE,MAAM,CAAC,IAAI,CAAC,GAAG,GAAG,KAAK,iBAAiB,CAAC,KAAK,CAAC,GAAG,CAAC,CAAC;QACtD,CAAC;IACH,CAAC;IAED,IAAI,MAAM,CAAC,MAAM,KAAK,CAAC,EAAE,CAAC;QACxB,OAAO,QAAQ,CAAC;IAClB,CAAC;IAED,OAAO,UAAU,MAAM,CAAC,IAAI,CAAC,IAAI,CAAC,EAAE,CAAC;AACvC,CAAC;AAED,SAAgB,iCAAiC,CAAC,MAA4B;IAC5E,OAAO;QACL,QAAQ,EAAE,MAAM,CAAC,QAAQ;QACzB,qBAAqB,EAAE,MAAM,CAAC,oBAAoB;QAClD,gBAAgB,EAAE,MAAM,CAAC,eAAe,IAAI,CAAC,UAAU,EAAE,WAAW,CAAC;QACrE,wBAAwB,EAAE,CAAC,QAAQ,CAAC;QACpC,GAAG,CAAC,MAAM,CAAC,YAAY,IAAI,EAAE,aAAa,EAAE,MAAM,CAAC,YAAY,EAAE,CAAC;QAClE,GAAG,CAAC,MAAM,CAAC,qBAAqB,IAAI;YAClC,sBAAsB,EAAE,MAAM,CAAC,qBAAqB;SACrD,CAAC;KACH,CAAC;AACJ,CAAC;AAED,SAAgB,kBAAkB,CAAC,UAAqC;IACtE,IAAI,CAAC,UAAU;QAAE,OAAO,SAAS,CAAC;IAElC,MAAM,MAAM,GAAG,SAAS,CAAC;IACzB,IAAI,UAAU,CAAC,MAAM,IAAI,MAAM,CAAC,MAAM;QAAE,OAAO,SAAS,CAAC;IACzD,IAAI,UAAU,CAAC,KAAK,CAAC,CAAC,EAAE,MAAM,CAAC,MAAM,CAAC,CAAC,WAAW,EAAE,KAAK,MAAM;QAAE,OAAO,SAAS,CAAC;IAElF,MAAM,KAAK,GAAG,UAAU,CAAC,KAAK,CAAC,MAAM,CAAC,MAAM,CAAC,CAAC,IAAI,EAAE,CAAC;IACrD,OAAO,KAAK,IAAI,SAAS,CAAC;AAC5B,CAAC"}

apps/backend/dist/libraries/nestjs-libraries/src/chat/rules.description.decorator.d.ts

@@ -0,0 +1,2 @@
+import 'reflect-metadata';
+export declare function Rules(description: string): (target: any) => void;

apps/backend/dist/libraries/nestjs-libraries/src/chat/rules.description.decorator.js

@@ -0,0 +1,10 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+exports.Rules = Rules;
+require("reflect-metadata");
+function Rules(description) {
+    return function (target) {
+        Reflect.defineMetadata('custom:rules:description', description, target);
+    };
+}
+//# sourceMappingURL=rules.description.decorator.js.map

apps/backend/dist/libraries/nestjs-libraries/src/chat/rules.description.decorator.js.map

@@ -0,0 +1 @@
+{"version":3,"file":"rules.description.decorator.js","sourceRoot":"","sources":["../../../../../../../libraries/nestjs-libraries/src/chat/rules.description.decorator.ts"],"names":[],"mappings":";;AAEA,sBASC;AAXD,4BAA0B;AAE1B,SAAgB,KAAK,CAAC,WAAmB;IACvC,OAAO,UAAU,MAAW;QAE1B,OAAO,CAAC,cAAc,CACpB,0BAA0B,EAC1B,WAAW,EACX,MAAM,CACP,CAAC;IACJ,CAAC,CAAC;AACJ,CAAC"}

apps/backend/dist/libraries/nestjs-libraries/src/chat/start.mcp.d.ts

@@ -0,0 +1,2 @@
+import { INestApplication } from '@nestjs/common';
+export declare const startMcp: (app: INestApplication) => Promise<void>;

apps/backend/dist/libraries/nestjs-libraries/src/chat/start.mcp.js

@@ -0,0 +1,219 @@
+"use strict";
+Object.defineProperty(exports, "__esModule", { value: true });
+exports.startMcp = void 0;
+const mastra_service_1 = require("./mastra.service");
+const mcp_1 = require("@mastra/mcp");
+const crypto_1 = require("crypto");
+const organization_service_1 = require("../database/prisma/organizations/organization.service");
+const oauth_service_1 = require("../database/prisma/oauth/oauth.service");
+const async_storage_1 = require("./async.storage");
+const oauth_middleware_1 = require("./oauth-middleware");
+const fixAcceptHeader = (req) => {
+    const value = 'application/json, text/event-stream';
+    req.headers.accept = value;
+    const idx = req.rawHeaders.findIndex((h) => h.toLowerCase() === 'accept');
+    if (idx !== -1) {
+        req.rawHeaders[idx + 1] = value;
+    }
+    else {
+        req.rawHeaders.push('Accept', value);
+    }
+};
+const startMcp = async (app) => {
+    const mastraService = app.get(mastra_service_1.MastraService, { strict: false });
+    const organizationService = app.get(organization_service_1.OrganizationService, { strict: false });
+    const oauthService = app.get(oauth_service_1.OAuthService, { strict: false });
+    const resolveAuth = async (token) => {
+        if (token.startsWith('pos_')) {
+            const authorization = await oauthService.getOrgByOAuthToken(token);
+            if (!authorization)
+                return null;
+            return authorization.organization;
+        }
+        return organizationService.getOrgByApiKey(token);
+    };
+    const mastra = await mastraService.mastra();
+    const agent = mastra.getAgent('postiz');
+    const tools = await agent.listTools();
+    const serverConfig = {
+        name: 'Postiz MCP',
+        version: '1.0.0',
+        tools,
+        agents: { postiz: agent },
+    };
+    const server = new mcp_1.MCPServer(serverConfig);
+    const oauthMiddleware = (0, oauth_middleware_1.createOAuthMiddleware)({
+        oauth: {
+            resource: new URL('/mcp-oauth', process.env.NEXT_PUBLIC_BACKEND_URL).toString(),
+            authorizationServers: [process.env.NEXT_PUBLIC_BACKEND_URL],
+            validateToken: async (token) => {
+                const org = await resolveAuth(token);
+                if (!org) {
+                    return { valid: false, error: 'invalid_token', errorDescription: 'Invalid API Key or OAuth token' };
+                }
+                return { valid: true, subject: token };
+            },
+        },
+        mcpPath: '/mcp-oauth',
+    });
+    if (process.env.OPENAI_APP_CHALLANGE) {
+        app.use('/.well-known/openai-apps-challenge', (req, res) => {
+            res.setHeader('Content-Type', 'text/plain');
+            res.send(process.env.OPENAI_APP_CHALLANGE);
+        });
+    }
+    app.use('/.well-known/oauth-protected-resource', async (req, res) => {
+        const url = new URL('/.well-known/oauth-protected-resource', process.env.NEXT_PUBLIC_BACKEND_URL);
+        await oauthMiddleware(req, res, url);
+    });
+    app.use('/.well-known/oauth-authorization-server', async (req, res) => {
+        res.setHeader('Access-Control-Allow-Origin', '*');
+        if (req.method === 'OPTIONS') {
+            res.setHeader('Access-Control-Allow-Methods', 'GET, OPTIONS');
+            res.setHeader('Access-Control-Allow-Headers', 'Content-Type');
+            res.writeHead(204);
+            res.end();
+            return;
+        }
+        res.setHeader('Content-Type', 'application/json');
+        res.setHeader('Cache-Control', 'max-age=3600');
+        res.json({
+            issuer: process.env.NEXT_PUBLIC_BACKEND_URL,
+            authorization_endpoint: `${process.env.FRONTEND_URL}/oauth/authorize`,
+            token_endpoint: `${process.env.NEXT_PUBLIC_OVERRIDE_BACKEND_URL || process.env.NEXT_PUBLIC_BACKEND_URL}/oauth/token`,
+            response_types_supported: ['code'],
+            grant_types_supported: ['authorization_code'],
+            code_challenge_methods_supported: ['S256'],
+            scopes_supported: ['mcp:read', 'mcp:write'],
+        });
+    });
+    app.use('/mcp-oauth', async (req, res, next) => {
+        if (req.path !== '/' && req.path !== '') {
+            next();
+            return;
+        }
+        const url = new URL('/mcp-oauth', process.env.NEXT_PUBLIC_BACKEND_URL);
+        const result = await oauthMiddleware(req, res, url);
+        if (!result.proceed)
+            return;
+        const token = result.tokenValidation?.subject;
+        const auth = await resolveAuth(token);
+        if (!auth) {
+            res.status(401).json({ error: 'invalid_token', error_description: 'Could not resolve organization' });
+            return;
+        }
+        fixAcceptHeader(req);
+        await (0, async_storage_1.runWithContext)({ requestId: token, auth }, async () => {
+            await server.startHTTP({
+                url: url,
+                httpPath: url.pathname,
+                options: {
+                    sessionIdGenerator: () => {
+                        return (0, crypto_1.randomUUID)();
+                    },
+                    enableJsonResponse: true,
+                },
+                req,
+                res,
+            });
+        });
+    });
+    app.use('/mcp', async (req, res, next) => {
+        if (req.path !== '/' && req.path !== '') {
+            next();
+            return;
+        }
+        res.setHeader('Access-Control-Allow-Origin', '*');
+        res.setHeader('Access-Control-Allow-Methods', '*');
+        res.setHeader('Access-Control-Allow-Headers', '*');
+        res.setHeader('Access-Control-Expose-Headers', '*');
+        if (req.method === 'OPTIONS') {
+            res.sendStatus(200);
+            return;
+        }
+        const token = req.headers.authorization?.replace('Bearer ', '');
+        if (!token) {
+            res.status(401).send('Missing Authorization header');
+            return;
+        }
+        req.auth = await resolveAuth(token);
+        if (!req.auth) {
+            res.status(401).send('Invalid API Key or OAuth token');
+            return;
+        }
+        const url = new URL('/mcp', process.env.NEXT_PUBLIC_BACKEND_URL);
+        fixAcceptHeader(req);
+        await (0, async_storage_1.runWithContext)({ requestId: token, auth: req.auth }, async () => {
+            await server.startHTTP({
+                url,
+                httpPath: url.pathname,
+                options: {
+                    sessionIdGenerator: () => {
+                        return (0, crypto_1.randomUUID)();
+                    },
+                    enableJsonResponse: true,
+                },
+                req,
+                res,
+            });
+        });
+    });
+    app.use('/mcp/:id', async (req, res) => {
+        res.setHeader('Access-Control-Allow-Origin', '*');
+        res.setHeader('Access-Control-Allow-Methods', '*');
+        res.setHeader('Access-Control-Allow-Headers', '*');
+        res.setHeader('Access-Control-Expose-Headers', '*');
+        if (req.method === 'OPTIONS') {
+            res.sendStatus(200);
+            return;
+        }
+        req.auth = await organizationService.getOrgByApiKey(req.params.id);
+        if (!req.auth) {
+            res.status(400).send('Invalid API Key');
+            return;
+        }
+        const url = new URL(`/mcp/${req.params.id}`, process.env.NEXT_PUBLIC_BACKEND_URL);
+        fixAcceptHeader(req);
+        await (0, async_storage_1.runWithContext)({ requestId: req.params.id, auth: req.auth }, async () => {
+            await server.startHTTP({
+                url,
+                httpPath: url.pathname,
+                options: {
+                    sessionIdGenerator: () => {
+                        return (0, crypto_1.randomUUID)();
+                    },
+                    enableJsonResponse: true,
+                },
+                req,
+                res,
+            });
+        });
+    });
+    app.use(['/sse/:id', '/message/:id'], async (req, res) => {
+        res.setHeader('Access-Control-Allow-Origin', '*');
+        res.setHeader('Access-Control-Allow-Methods', '*');
+        res.setHeader('Access-Control-Allow-Headers', '*');
+        res.setHeader('Access-Control-Expose-Headers', '*');
+        if (req.method === 'OPTIONS') {
+            res.sendStatus(200);
+            return;
+        }
+        req.auth = await organizationService.getOrgByApiKey(req.params.id);
+        if (!req.auth) {
+            res.status(400).send('Invalid API Key');
+            return;
+        }
+        const url = new URL(req.originalUrl, process.env.NEXT_PUBLIC_BACKEND_URL);
+        await (0, async_storage_1.runWithContext)({ requestId: req.params.id, auth: req.auth }, async () => {
+            await new mcp_1.MCPServer(serverConfig).startSSE({
+                url,
+                ssePath: `/sse/${req.params.id}`,
+                messagePath: `/message/${req.params.id}`,
+                req,
+                res,
+            });
+        });
+    });
+};
+exports.startMcp = startMcp;
+//# sourceMappingURL=start.mcp.js.map

apps/backend/dist/libraries/nestjs-libraries/src/chat/start.mcp.js.map

@@ -0,0 +1 @@
+{"version":3,"file":"start.mcp.js","sourceRoot":"","sources":["../../../../../../../libraries/nestjs-libraries/src/chat/start.mcp.ts"],"names":[],"mappings":";;;AAEA,qDAA8E;AAC9E,qCAAwC;AACxC,mCAAoC;AACpC,gGAAmH;AACnH,0EAA6F;AAC7F,mDAAiD;AACjD,yDAA2D;AAC3D,MAAM,eAAe,GAAG,CAAC,GAAY,EAAE,EAAE;IACvC,MAAM,KAAK,GAAG,qCAAqC,CAAC;IACpD,GAAG,CAAC,OAAO,CAAC,MAAM,GAAG,KAAK,CAAC;IAC3B,MAAM,GAAG,GAAG,GAAG,CAAC,UAAU,CAAC,SAAS,CAAC,CAAC,CAAC,EAAE,EAAE,CAAC,CAAC,CAAC,WAAW,EAAE,KAAK,QAAQ,CAAC,CAAC;IAC1E,IAAI,GAAG,KAAK,CAAC,CAAC,EAAE,CAAC;QACf,GAAG,CAAC,UAAU,CAAC,GAAG,GAAG,CAAC,CAAC,GAAG,KAAK,CAAC;IAClC,CAAC;SAAM,CAAC;QACN,GAAG,CAAC,UAAU,CAAC,IAAI,CAAC,QAAQ,EAAE,KAAK,CAAC,CAAC;IACvC,CAAC;AACH,CAAC,CAAC;AAEK,MAAM,QAAQ,GAAG,KAAK,EAAE,GAAqB,EAAE,EAAE;IACtD,MAAM,aAAa,GAAG,GAAG,CAAC,GAAG,CAAC,8BAAa,EAAE,EAAE,MAAM,EAAE,KAAK,EAAE,CAAC,CAAC;IAChE,MAAM,mBAAmB,GAAG,GAAG,CAAC,GAAG,CAAC,0CAAmB,EAAE,EAAE,MAAM,EAAE,KAAK,EAAE,CAAC,CAAC;IAC5E,MAAM,YAAY,GAAG,GAAG,CAAC,GAAG,CAAC,4BAAY,EAAE,EAAE,MAAM,EAAE,KAAK,EAAE,CAAC,CAAC;IAE9D,MAAM,WAAW,GAAG,KAAK,EAAE,KAAa,EAAE,EAAE;QAC1C,IAAI,KAAK,CAAC,UAAU,CAAC,MAAM,CAAC,EAAE,CAAC;YAC7B,MAAM,aAAa,GAAG,MAAM,YAAY,CAAC,kBAAkB,CAAC,KAAK,CAAC,CAAC;YACnE,IAAI,CAAC,aAAa;gBAAE,OAAO,IAAI,CAAC;YAChC,OAAO,aAAa,CAAC,YAAY,CAAC;QACpC,CAAC;QACD,OAAO,mBAAmB,CAAC,cAAc,CAAC,KAAK,CAAC,CAAC;IACnD,CAAC,CAAC;IAEF,MAAM,MAAM,GAAG,MAAM,aAAa,CAAC,MAAM,EAAE,CAAC;IAC5C,MAAM,KAAK,GAAG,MAAM,CAAC,QAAQ,CAAC,QAAQ,CAAC,CAAC;IACxC,MAAM,KAAK,GAAG,MAAM,KAAK,CAAC,SAAS,EAAE,CAAC;IAEtC,MAAM,YAAY,GAAG;QACnB,IAAI,EAAE,YAAY;QAClB,OAAO,EAAE,OAAO;QAChB,KAAK;QACL,MAAM,EAAE,EAAE,MAAM,EAAE,KAAK,EAAE;KAC1B,CAAC;IAEF,MAAM,MAAM,GAAG,IAAI,eAAS,CAAC,YAAY,CAAC,CAAC;IAE3C,MAAM,eAAe,GAAG,IAAA,wCAAqB,EAAC;QAC5C,KAAK,EAAE;YACL,QAAQ,EAAE,IAAI,GAAG,CAAC,YAAY,EAAE,OAAO,CAAC,GAAG,CAAC,uBAAwB,CAAC,CAAC,QAAQ,EAAE;YAChF,oBAAoB,EAAE,CAAC,OAAO,CAAC,GAAG,CAAC,uBAAwB,CAAC;YAC5D,aAAa,EAAE,KAAK,EAAE,KAAa,EAAE,EAAE;gBACrC,MAAM,GAAG,GAAG,MAAM,WAAW,CAAC,KAAK,CAAC,CAAC;gBACrC,IAAI,CAAC,GAAG,EAAE,CAAC;oBACT,OAAO,EAAE,KAAK,EAAE,KAAK,EAAE,KAAK,EAAE,eAAe,EAAE,gBAAgB,EAAE,gCAAgC,EAAE,CAAC;gBACtG,CAAC;gBACD,OAAO,EAAE,KAAK,EAAE,IAAI,EAAE,OAAO,EAAE,KAAK,EAAE,CAAC;YACzC,CAAC;SACF;QACD,OAAO,EAAE,YAAY;KACtB,CAAC,CAAC;IAEH,IAAI,OAAO,CAAC,GAAG,CAAC,oBAAoB,EAAE,CAAC;QACrC,GAAG,CAAC,GAAG,CAAC,oCAAoC,EAAE,CAAC,GAAY,EAAE,GAAa,EAAE,EAAE;YAC5E,GAAG,CAAC,SAAS,CAAC,cAAc,EAAE,YAAY,CAAC,CAAC;YAC5C,GAAG,CAAC,IAAI,CAAC,OAAO,CAAC,GAAG,CAAC,oBAAoB,CAAC,CAAC;QAC7C,CAAC,CAAC,CAAC;IACL,CAAC;IAED,GAAG,CAAC,GAAG,CAAC,uCAAuC,EAAE,KAAK,EAAE,GAAY,EAAE,GAAa,EAAE,EAAE;QACrF,MAAM,GAAG,GAAG,IAAI,GAAG,CAAC,uCAAuC,EAAE,OAAO,CAAC,GAAG,CAAC,uBAAuB,CAAC,CAAC;QAClG,MAAM,eAAe,CAAC,GAAG,EAAE,GAAG,EAAE,GAAG,CAAC,CAAC;IACvC,CAAC,CAAC,CAAC;IAEH,GAAG,CAAC,GAAG,CAAC,yCAAyC,EAAE,KAAK,EAAE,GAAY,EAAE,GAAa,EAAE,EAAE;QACvF,GAAG,CAAC,SAAS,CAAC,6BAA6B,EAAE,GAAG,CAAC,CAAC;QAClD,IAAI,GAAG,CAAC,MAAM,KAAK,SAAS,EAAE,CAAC;YAC7B,GAAG,CAAC,SAAS,CAAC,8BAA8B,EAAE,cAAc,CAAC,CAAC;YAC9D,GAAG,CAAC,SAAS,CAAC,8BAA8B,EAAE,cAAc,CAAC,CAAC;YAC9D,GAAG,CAAC,SAAS,CAAC,GAAG,CAAC,CAAC;YACnB,GAAG,CAAC,GAAG,EAAE,CAAC;YACV,OAAO;QACT,CAAC;QACD,GAAG,CAAC,SAAS,CAAC,cAAc,EAAE,kBAAkB,CAAC,CAAC;QAClD,GAAG,CAAC,SAAS,CAAC,eAAe,EAAE,cAAc,CAAC,CAAC;QAC/C,GAAG,CAAC,IAAI,CAAC;YACP,MAAM,EAAE,OAAO,CAAC,GAAG,CAAC,uBAAuB;YAC3C,sBAAsB,EAAE,GAAG,OAAO,CAAC,GAAG,CAAC,YAAY,kBAAkB;YACrE,cAAc,EAAE,GAAG,OAAO,CAAC,GAAG,CAAC,gCAAgC,IAAI,OAAO,CAAC,GAAG,CAAC,uBAAuB,cAAc;YACpH,wBAAwB,EAAE,CAAC,MAAM,CAAC;YAClC,qBAAqB,EAAE,CAAC,oBAAoB,CAAC;YAC7C,gCAAgC,EAAE,CAAC,MAAM,CAAC;YAC1C,gBAAgB,EAAE,CAAC,UAAU,EAAE,WAAW,CAAC;SAC5C,CAAC,CAAC;IACL,CAAC,CAAC,CAAC;IAEH,GAAG,CAAC,GAAG,CAAC,YAAY,EAAE,KAAK,EAAE,GAAY,EAAE,GAAa,EAAE,IAAgB,EAAE,EAAE;QAE5E,IAAI,GAAG,CAAC,IAAI,KAAK,GAAG,IAAI,GAAG,CAAC,IAAI,KAAK,EAAE,EAAE,CAAC;YACxC,IAAI,EAAE,CAAC;YACP,OAAO;QACT,CAAC;QAED,MAAM,GAAG,GAAG,IAAI,GAAG,CAAC,YAAY,EAAE,OAAO,CAAC,GAAG,CAAC,uBAAuB,CAAC,CAAC;QAEvE,MAAM,MAAM,GAAG,MAAM,eAAe,CAAC,GAAG,EAAE,GAAG,EAAE,GAAG,CAAC,CAAC;QACpD,IAAI,CAAC,MAAM,CAAC,OAAO;YAAE,OAAO;QAE5B,MAAM,KAAK,GAAG,MAAM,CAAC,eAAe,EAAE,OAAO,CAAC;QAC9C,MAAM,IAAI,GAAG,MAAM,WAAW,CAAC,KAAM,CAAC,CAAC;QACvC,IAAI,CAAC,IAAI,EAAE,CAAC;YACV,GAAG,CAAC,MAAM,CAAC,GAAG,CAAC,CAAC,IAAI,CAAC,EAAE,KAAK,EAAE,eAAe,EAAE,iBAAiB,EAAE,gCAAgC,EAAE,CAAC,CAAC;YACtG,OAAO;QACT,CAAC;QAED,eAAe,CAAC,GAAG,CAAC,CAAC;QACrB,MAAM,IAAA,8BAAc,EAAC,EAAE,SAAS,EAAE,KAAM,EAAE,IAAI,EAAE,EAAE,KAAK,IAAI,EAAE;YAC3D,MAAM,MAAM,CAAC,SAAS,CAAC;gBACrB,GAAG,EAAE,GAAG;gBACR,QAAQ,EAAE,GAAG,CAAC,QAAQ;gBACtB,OAAO,EAAE;oBACP,kBAAkB,EAAE,GAAG,EAAE;wBACvB,OAAO,IAAA,mBAAU,GAAE,CAAC;oBACtB,CAAC;oBACD,kBAAkB,EAAE,IAAI;iBACzB;gBACD,GAAG;gBACH,GAAG;aACJ,CAAC,CAAC;QACL,CAAC,CAAC,CAAC;IACL,CAAC,CAAC,CAAC;IAEH,GAAG,CAAC,GAAG,CAAC,MAAM,EAAE,KAAK,EAAE,GAAY,EAAE,GAAa,EAAE,IAAgB,EAAE,EAAE;QAEtE,IAAI,GAAG,CAAC,IAAI,KAAK,GAAG,IAAI,GAAG,CAAC,IAAI,KAAK,EAAE,EAAE,CAAC;YACxC,IAAI,EAAE,CAAC;YACP,OAAO;QACT,CAAC;QAGD,GAAG,CAAC,SAAS,CAAC,6BAA6B,EAAE,GAAG,CAAC,CAAC;QAClD,GAAG,CAAC,SAAS,CAAC,8BAA8B,EAAE,GAAG,CAAC,CAAC;QACnD,GAAG,CAAC,SAAS,CAAC,8BAA8B,EAAE,GAAG,CAAC,CAAC;QACnD,GAAG,CAAC,SAAS,CAAC,+BAA+B,EAAE,GAAG,CAAC,CAAC;QAEpD,IAAI,GAAG,CAAC,MAAM,KAAK,SAAS,EAAE,CAAC;YAC7B,GAAG,CAAC,UAAU,CAAC,GAAG,CAAC,CAAC;YACpB,OAAO;QACT,CAAC;QAED,MAAM,KAAK,GAAG,GAAG,CAAC,OAAO,CAAC,aAAa,EAAE,OAAO,CAAC,SAAS,EAAE,EAAE,CAAC,CAAC;QAChE,IAAI,CAAC,KAAK,EAAE,CAAC;YACX,GAAG,CAAC,MAAM,CAAC,GAAG,CAAC,CAAC,IAAI,CAAC,8BAA8B,CAAC,CAAC;YACrD,OAAO;QACT,CAAC;QAGD,GAAG,CAAC,IAAI,GAAG,MAAM,WAAW,CAAC,KAAK,CAAC,CAAC;QAEpC,IAAI,CAAC,GAAG,CAAC,IAAI,EAAE,CAAC;YACd,GAAG,CAAC,MAAM,CAAC,GAAG,CAAC,CAAC,IAAI,CAAC,gCAAgC,CAAC,CAAC;YACvD,OAAO;QACT,CAAC;QAED,MAAM,GAAG,GAAG,IAAI,GAAG,CAAC,MAAM,EAAE,OAAO,CAAC,GAAG,CAAC,uBAAuB,CAAC,CAAC;QAEjE,eAAe,CAAC,GAAG,CAAC,CAAC;QAErB,MAAM,IAAA,8BAAc,EAAC,EAAE,SAAS,EAAE,KAAK,EAAE,IAAI,EAAE,GAAG,CAAC,IAAI,EAAE,EAAE,KAAK,IAAI,EAAE;YACpE,MAAM,MAAM,CAAC,SAAS,CAAC;gBACrB,GAAG;gBACH,QAAQ,EAAE,GAAG,CAAC,QAAQ;gBACtB,OAAO,EAAE;oBACP,kBAAkB,EAAE,GAAG,EAAE;wBACvB,OAAO,IAAA,mBAAU,GAAE,CAAC;oBACtB,CAAC;oBACD,kBAAkB,EAAE,IAAI;iBACzB;gBACD,GAAG;gBACH,GAAG;aACJ,CAAC,CAAC;QACL,CAAC,CAAC,CAAC;IACL,CAAC,CAAC,CAAC;IAEH,GAAG,CAAC,GAAG,CAAC,UAAU,EAAE,KAAK,EAAE,GAAY,EAAE,GAAa,EAAE,EAAE;QAExD,GAAG,CAAC,SAAS,CAAC,6BAA6B,EAAE,GAAG,CAAC,CAAC;QAClD,GAAG,CAAC,SAAS,CAAC,8BAA8B,EAAE,GAAG,CAAC,CAAC;QACnD,GAAG,CAAC,SAAS,CAAC,8BAA8B,EAAE,GAAG,CAAC,CAAC;QACnD,GAAG,CAAC,SAAS,CAAC,+BAA+B,EAAE,GAAG,CAAC,CAAC;QAEpD,IAAI,GAAG,CAAC,MAAM,KAAK,SAAS,EAAE,CAAC;YAC7B,GAAG,CAAC,UAAU,CAAC,GAAG,CAAC,CAAC;YACpB,OAAO;QACT,CAAC;QAGD,GAAG,CAAC,IAAI,GAAG,MAAM,mBAAmB,CAAC,cAAc,CAAC,GAAG,CAAC,MAAM,CAAC,EAAE,CAAC,CAAC;QAEnE,IAAI,CAAC,GAAG,CAAC,IAAI,EAAE,CAAC;YACd,GAAG,CAAC,MAAM,CAAC,GAAG,CAAC,CAAC,IAAI,CAAC,iBAAiB,CAAC,CAAC;YACxC,OAAO;QACT,CAAC;QAED,MAAM,GAAG,GAAG,IAAI,GAAG,CACjB,QAAQ,GAAG,CAAC,MAAM,CAAC,EAAE,EAAE,EACvB,OAAO,CAAC,GAAG,CAAC,uBAAuB,CACpC,CAAC;QAEF,eAAe,CAAC,GAAG,CAAC,CAAC;QACrB,MAAM,IAAA,8BAAc,EAElB,EAAE,SAAS,EAAE,GAAG,CAAC,MAAM,CAAC,EAAE,EAAE,IAAI,EAAE,GAAG,CAAC,IAAI,EAAE,EAC5C,KAAK,IAAI,EAAE;YACT,MAAM,MAAM,CAAC,SAAS,CAAC;gBACrB,GAAG;gBACH,QAAQ,EAAE,GAAG,CAAC,QAAQ;gBACtB,OAAO,EAAE;oBACP,kBAAkB,EAAE,GAAG,EAAE;wBACvB,OAAO,IAAA,mBAAU,GAAE,CAAC;oBACtB,CAAC;oBACD,kBAAkB,EAAE,IAAI;iBACzB;gBACD,GAAG;gBACH,GAAG;aACJ,CAAC,CAAC;QACL,CAAC,CACF,CAAC;IACJ,CAAC,CAAC,CAAC;IAEH,GAAG,CAAC,GAAG,CAAC,CAAC,UAAU,EAAE,cAAc,CAAC,EAAE,KAAK,EAAE,GAAY,EAAE,GAAa,EAAE,EAAE;QAE1E,GAAG,CAAC,SAAS,CAAC,6BAA6B,EAAE,GAAG,CAAC,CAAC;QAClD,GAAG,CAAC,SAAS,CAAC,8BAA8B,EAAE,GAAG,CAAC,CAAC;QACnD,GAAG,CAAC,SAAS,CAAC,8BAA8B,EAAE,GAAG,CAAC,CAAC;QACnD,GAAG,CAAC,SAAS,CAAC,+BAA+B,EAAE,GAAG,CAAC,CAAC;QAEpD,IAAI,GAAG,CAAC,MAAM,KAAK,SAAS,EAAE,CAAC;YAC7B,GAAG,CAAC,UAAU,CAAC,GAAG,CAAC,CAAC;YACpB,OAAO;QACT,CAAC;QAGD,GAAG,CAAC,IAAI,GAAG,MAAM,mBAAmB,CAAC,cAAc,CAAC,GAAG,CAAC,MAAM,CAAC,EAAE,CAAC,CAAC;QAEnE,IAAI,CAAC,GAAG,CAAC,IAAI,EAAE,CAAC;YACd,GAAG,CAAC,MAAM,CAAC,GAAG,CAAC,CAAC,IAAI,CAAC,iBAAiB,CAAC,CAAC;YACxC,OAAO;QACT,CAAC;QAED,MAAM,GAAG,GAAG,IAAI,GAAG,CAAC,GAAG,CAAC,WAAW,EAAE,OAAO,CAAC,GAAG,CAAC,uBAAuB,CAAC,CAAC;QAE1E,MAAM,IAAA,8BAAc,EAElB,EAAE,SAAS,EAAE,GAAG,CAAC,MAAM,CAAC,EAAE,EAAE,IAAI,EAAE,GAAG,CAAC,IAAI,EAAE,EAC5C,KAAK,IAAI,EAAE;YACT,MAAM,IAAI,eAAS,CAAC,YAAY,CAAC,CAAC,QAAQ,CAAC;gBACzC,GAAG;gBACH,OAAO,EAAE,QAAQ,GAAG,CAAC,MAAM,CAAC,EAAE,EAAE;gBAChC,WAAW,EAAE,YAAY,GAAG,CAAC,MAAM,CAAC,EAAE,EAAE;gBACxC,GAAG;gBACH,GAAG;aACJ,CAAC,CAAC;QACL,CAAC,CACF,CAAC;IACJ,CAAC,CAAC,CAAC;AACL,CAAC,CAAC;AAtPW,QAAA,QAAQ,YAsPnB"}