feat: complete Telegram AI Girlfriend mechanics & deduplication

Added AssetDelivery deduplication for media in Telegram Bot. Created /api/cron/daily-generation for n8n autonomous storytelling. Integrated ChatSession memory and time/tier limits for human-like persistence.

LICENSE

@@ -0,0 +1,18 @@
+Copyright (c) 2026 Gmagl
+
+All rights reserved.
+
+This software and associated documentation files (the "Software") are the 
+proprietary property of Gmagl. 
+
+You may not use, copy, modify, merge, publish, distribute, sublicense, 
+and/or sell copies of the Software without explicit, prior written 
+permission from Gmagl.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+SOFTWARE.

package-lock.json

@@ -58,6 +58,7 @@
         "stripe": "^20.4.0",
         "tailwind-merge": "^3.3.1",
         "tailwindcss-animate": "^1.0.7",
+        "telegraf": "^4.16.3",
         "tw-animate-css": "^1.3.5",
         "vaul": "^1.1.2",
         "z-ai-web-dev-sdk": "^0.0.16",
@@ -3507,6 +3508,12 @@
         "tailwindcss": "4.2.1"
       }
     },
+    "node_modules/@telegraf/types": {
+      "version": "7.1.0",
+      "resolved": "https://registry.npmjs.org/@telegraf/types/-/types-7.1.0.tgz",
+      "integrity": "sha512-kGevOIbpMcIlCDeorKGpwZmdH7kHbqlk/Yj6dEpJMKEQw5lk0KVQY0OLXaCswy8GqlIVLd5625OB+rAntP9xVw==",
+      "license": "MIT"
+    },
     "node_modules/@tybys/wasm-util": {
       "version": "0.10.1",
       "resolved": "https://registry.npmjs.org/@tybys/wasm-util/-/wasm-util-0.10.1.tgz",
@@ -4137,6 +4144,18 @@
         "win32"
       ]
     },
+    "node_modules/abort-controller": {
+      "version": "3.0.0",
+      "resolved": "https://registry.npmjs.org/abort-controller/-/abort-controller-3.0.0.tgz",
+      "integrity": "sha512-h8lQ8tacZYnR3vNQTgibj+tODHI5/+l06Au2Pcriv/Gmet0eaj4TwWH41sO9wnHDiQsEj19q0drzdWdeAHtweg==",
+      "license": "MIT",
+      "dependencies": {
+        "event-target-shim": "^5.0.0"
+      },
+      "engines": {
+        "node": ">=6.5"
+      }
+    },
     "node_modules/acorn": {
       "version": "8.16.0",
       "resolved": "https://registry.npmjs.org/acorn/-/acorn-8.16.0.tgz",
@@ -4518,6 +4537,28 @@
         "node": "^6 || ^7 || ^8 || ^9 || ^10 || ^11 || ^12 || >=13.7"
       }
     },
+    "node_modules/buffer-alloc": {
+      "version": "1.2.0",
+      "resolved": "https://registry.npmjs.org/buffer-alloc/-/buffer-alloc-1.2.0.tgz",
+      "integrity": "sha512-CFsHQgjtW1UChdXgbyJGtnm+O/uLQeZdtbDo8mfUgYXCHSM1wgrVxXm6bSyrUuErEb+4sYVGCzASBRot7zyrow==",
+      "license": "MIT",
+      "dependencies": {
+        "buffer-alloc-unsafe": "^1.1.0",
+        "buffer-fill": "^1.0.0"
+      }
+    },
+    "node_modules/buffer-alloc-unsafe": {
+      "version": "1.1.0",
+      "resolved": "https://registry.npmjs.org/buffer-alloc-unsafe/-/buffer-alloc-unsafe-1.1.0.tgz",
+      "integrity": "sha512-TEM2iMIEQdJ2yjPJoSIsldnleVaAk1oW3DBVUykyOLsEsFmEc9kn+SFFPz+gl54KQNxlDnAwCXosOS9Okx2xAg==",
+      "license": "MIT"
+    },
+    "node_modules/buffer-fill": {
+      "version": "1.0.0",
+      "resolved": "https://registry.npmjs.org/buffer-fill/-/buffer-fill-1.0.0.tgz",
+      "integrity": "sha512-T7zexNBwiiaCOGDg9xNX9PBmjrubblRkENuptryuI64URkXDFum9il/JGL8Lm8wYfAXpredVXXZz7eMHilimiQ==",
+      "license": "MIT"
+    },
     "node_modules/c12": {
       "version": "3.1.0",
       "resolved": "https://registry.npmjs.org/c12/-/c12-3.1.0.tgz",
@@ -4983,7 +5024,6 @@
       "version": "4.4.3",
       "resolved": "https://registry.npmjs.org/debug/-/debug-4.4.3.tgz",
       "integrity": "sha512-RGwwWnwQvkVfavKVt22FGLw+xYSdzARwm0ru6DhTVA3umU5hZc28V3kO4stgYryrTlLpuvgI9GiijltAjNbcqA==",
-      "dev": true,
       "license": "MIT",
       "dependencies": {
         "ms": "^2.1.3"
@@ -5923,6 +5963,15 @@
         "node": ">=0.10.0"
       }
     },
+    "node_modules/event-target-shim": {
+      "version": "5.0.1",
+      "resolved": "https://registry.npmjs.org/event-target-shim/-/event-target-shim-5.0.1.tgz",
+      "integrity": "sha512-i/2XbnSz/uxRCU6+NdVJgKWDTM427+MqYbkQzD321DuCQJUqOuJKIA0IM2+W2xtYHdKOmZ4dR6fExsd4SXL+WQ==",
+      "license": "MIT",
+      "engines": {
+        "node": ">=6"
+      }
+    },
     "node_modules/eventemitter3": {
       "version": "5.0.4",
       "resolved": "https://registry.npmjs.org/eventemitter3/-/eventemitter3-5.0.4.tgz",
@@ -7508,11 +7557,19 @@
       "integrity": "sha512-G3kc34H2cX2gI63RqU+cZq+zWRRPSsNIOjpdl9TN4AQwC4sgwYPl/Q/Obf/d53nOm569T0fYK+tcoSV50BWx8A==",
       "license": "MIT"
     },
+    "node_modules/mri": {
+      "version": "1.2.0",
+      "resolved": "https://registry.npmjs.org/mri/-/mri-1.2.0.tgz",
+      "integrity": "sha512-tzzskb3bG8LvYGFF/mDTpq3jpI6Q9wc3LEmBaghu+DdCssd1FakN7Bc0hVNmEyGq1bq3RgfkCb3cmQLpNPOroA==",
+      "license": "MIT",
+      "engines": {
+        "node": ">=4"
+      }
+    },
     "node_modules/ms": {
       "version": "2.1.3",
       "resolved": "https://registry.npmjs.org/ms/-/ms-2.1.3.tgz",
       "integrity": "sha512-6FlzubTLZG3J2a/NVCAleEhjzq5oxgHyaCU9yYXvcLsvoVaHJq/s5xXI6/XXP6tz7R9xAOtHnSO/tXtF3WRTlA==",
-      "dev": true,
       "license": "MIT"
     },
     "node_modules/nanoid": {
@@ -7675,6 +7732,26 @@
         "semver": "bin/semver.js"
       }
     },
+    "node_modules/node-fetch": {
+      "version": "2.7.0",
+      "resolved": "https://registry.npmjs.org/node-fetch/-/node-fetch-2.7.0.tgz",
+      "integrity": "sha512-c4FRfUm/dbcWZ7U+1Wq0AwCyFL+3nt2bEw05wfxSz+DWpWsitgmSgYmy2dQdWyKC1694ELPqMs/YzUSNozLt8A==",
+      "license": "MIT",
+      "dependencies": {
+        "whatwg-url": "^5.0.0"
+      },
+      "engines": {
+        "node": "4.x || >=6.0.0"
+      },
+      "peerDependencies": {
+        "encoding": "^0.1.0"
+      },
+      "peerDependenciesMeta": {
+        "encoding": {
+          "optional": true
+        }
+      }
+    },
     "node_modules/node-fetch-native": {
       "version": "1.6.7",
       "resolved": "https://registry.npmjs.org/node-fetch-native/-/node-fetch-native-1.6.7.tgz",
@@ -7908,6 +7985,15 @@
         "url": "https://github.com/sponsors/sindresorhus"
       }
     },
+    "node_modules/p-timeout": {
+      "version": "4.1.0",
+      "resolved": "https://registry.npmjs.org/p-timeout/-/p-timeout-4.1.0.tgz",
+      "integrity": "sha512-+/wmHtzJuWii1sXn3HCuH/FTwGhrp4tmJTxSKJbfS+vkipci6osxXM5mY0jUiRzWKMTgUT8l7HFbeSwZAynqHw==",
+      "license": "MIT",
+      "engines": {
+        "node": ">=10"
+      }
+    },
     "node_modules/parent-module": {
       "version": "1.0.1",
       "resolved": "https://registry.npmjs.org/parent-module/-/parent-module-1.0.1.tgz",
@@ -8512,6 +8598,15 @@
         "url": "https://github.com/sponsors/ljharb"
       }
     },
+    "node_modules/safe-compare": {
+      "version": "1.1.4",
+      "resolved": "https://registry.npmjs.org/safe-compare/-/safe-compare-1.1.4.tgz",
+      "integrity": "sha512-b9wZ986HHCo/HbKrRpBJb2kqXMK9CEWIE1egeEvZsYn69ay3kdfl9nG3RyOcR+jInTDf7a86WQ1d4VJX7goSSQ==",
+      "license": "MIT",
+      "dependencies": {
+        "buffer-alloc": "^1.2.0"
+      }
+    },
     "node_modules/safe-push-apply": {
       "version": "1.0.0",
       "resolved": "https://registry.npmjs.org/safe-push-apply/-/safe-push-apply-1.0.0.tgz",
@@ -8547,6 +8642,15 @@
         "url": "https://github.com/sponsors/ljharb"
       }
     },
+    "node_modules/sandwich-stream": {
+      "version": "2.0.2",
+      "resolved": "https://registry.npmjs.org/sandwich-stream/-/sandwich-stream-2.0.2.tgz",
+      "integrity": "sha512-jLYV0DORrzY3xaz/S9ydJL6Iz7essZeAfnAavsJ+zsJGZ1MOnsS52yRjU3uF3pJa/lla7+wisp//fxOwOH8SKQ==",
+      "license": "Apache-2.0",
+      "engines": {
+        "node": ">= 0.10"
+      }
+    },
     "node_modules/scheduler": {
       "version": "0.27.0",
       "resolved": "https://registry.npmjs.org/scheduler/-/scheduler-0.27.0.tgz",
@@ -9040,6 +9144,28 @@
         "url": "https://opencollective.com/webpack"
       }
     },
+    "node_modules/telegraf": {
+      "version": "4.16.3",
+      "resolved": "https://registry.npmjs.org/telegraf/-/telegraf-4.16.3.tgz",
+      "integrity": "sha512-yjEu2NwkHlXu0OARWoNhJlIjX09dRktiMQFsM678BAH/PEPVwctzL67+tvXqLCRQQvm3SDtki2saGO9hLlz68w==",
+      "license": "MIT",
+      "dependencies": {
+        "@telegraf/types": "^7.1.0",
+        "abort-controller": "^3.0.0",
+        "debug": "^4.3.4",
+        "mri": "^1.2.0",
+        "node-fetch": "^2.7.0",
+        "p-timeout": "^4.1.0",
+        "safe-compare": "^1.1.4",
+        "sandwich-stream": "^2.0.2"
+      },
+      "bin": {
+        "telegraf": "lib/cli.mjs"
+      },
+      "engines": {
+        "node": "^12.20.0 || >=14.13.1"
+      }
+    },
     "node_modules/tiny-invariant": {
       "version": "1.3.3",
       "resolved": "https://registry.npmjs.org/tiny-invariant/-/tiny-invariant-1.3.3.tgz",
@@ -9116,6 +9242,12 @@
         "node": ">=8.0"
       }
     },
+    "node_modules/tr46": {
+      "version": "0.0.3",
+      "resolved": "https://registry.npmjs.org/tr46/-/tr46-0.0.3.tgz",
+      "integrity": "sha512-N3WMsuqV66lT30CrXNbEjx4GEwlow3v6rr4mCcv6prnfwhS01rkgyFdjPNBYd9br7LpXV1+Emh01fHnq2Gdgrw==",
+      "license": "MIT"
+    },
     "node_modules/ts-api-utils": {
       "version": "2.4.0",
       "resolved": "https://registry.npmjs.org/ts-api-utils/-/ts-api-utils-2.4.0.tgz",
@@ -9475,6 +9607,22 @@
         "d3-timer": "^3.0.1"
       }
     },
+    "node_modules/webidl-conversions": {
+      "version": "3.0.1",
+      "resolved": "https://registry.npmjs.org/webidl-conversions/-/webidl-conversions-3.0.1.tgz",
+      "integrity": "sha512-2JAn3z8AR6rjK8Sm8orRC0h/bcl/DqL7tRPdGZ4I1CjdF+EaMLmYxBHyXuKL849eucPFhvBoxMsflfOb8kxaeQ==",
+      "license": "BSD-2-Clause"
+    },
+    "node_modules/whatwg-url": {
+      "version": "5.0.0",
+      "resolved": "https://registry.npmjs.org/whatwg-url/-/whatwg-url-5.0.0.tgz",
+      "integrity": "sha512-saE57nupxk6v3HY35+jzBwYa0rKSy0XR8JSxZPwgLr7ys0IBzhGviA1/TUGJLmSVqs8pb9AnvICXEuOHLprYTw==",
+      "license": "MIT",
+      "dependencies": {
+        "tr46": "~0.0.3",
+        "webidl-conversions": "^3.0.0"
+      }
+    },
     "node_modules/which": {
       "version": "2.0.2",
       "resolved": "https://registry.npmjs.org/which/-/which-2.0.2.tgz",

package.json

@@ -59,6 +59,7 @@
     "stripe": "^20.4.0",
     "tailwind-merge": "^3.3.1",
     "tailwindcss-animate": "^1.0.7",
+    "telegraf": "^4.16.3",
     "tw-animate-css": "^1.3.5",
     "vaul": "^1.1.2",
     "z-ai-web-dev-sdk": "^0.0.16",
@@ -74,4 +75,4 @@
     "tailwindcss": "^4",
     "typescript": "^5"
   }
-}
+}

src/app/api/automation/route.ts

@@ -58,9 +58,22 @@ export async function PUT(request: NextRequest) {
       if (!automation) return NextResponse.json({ success: false, error: "No encontrada" }, { status: 404 });
 
       try {
-        const zai = await ZAI.create();
-        await zai.chat.completions.create({ messages: [{ role: "user", content: "test" }] });
-      } catch { }
+        const payload = JSON.parse(automation.actions as string);
+        const webhookUrl = payload.webhookUrl || process.env.N8N_WEBHOOK_URL;
+
+        if (webhookUrl) {
+          // Trigger n8n workflow
+          await fetch(webhookUrl, {
+            method: "POST",
+            headers: { "Content-Type": "application/json" },
+            body: JSON.stringify({ automationId: automation.id, type: automation.type, payload })
+          });
+        } else {
+          console.warn("No n8n Webhook URL configured for this automation.");
+        }
+      } catch (err) {
+        console.error("Failed to execute n8n webhook", err);
+      }
 
       await db.automation.update({ where: { id }, data: { lastRunAt: new Date(), runCount: { increment: 1 } } });
       await db.automationLog.create({ data: { automationId: id, status: "success", duration: 100 } });

src/app/api/cron/daily-generation/route.ts

@@ -0,0 +1,99 @@
+import { NextRequest, NextResponse } from "next/server";
+import { db } from "@/lib/db";
+import ZAI from "z-ai-web-dev-sdk";
+import { generateSocialPost } from "@/lib/content-generator";
+
+export const maxDuration = 60; // 1 min timeout to allow generation to kick off
+
+export async function POST(request: NextRequest) {
+    // Basic Security: Protect this route from public abuse via a secret key from n8n
+    const authHeader = request.headers.get("authorization");
+    const secret = process.env.CRON_SECRET || "default_cron_secret_replace_me"; // Set CRON_SECRET in Vercel/VPS
+
+    if (authHeader !== `Bearer ${secret}`) {
+        return NextResponse.json({ success: false, error: "Unauthorized" }, { status: 401 });
+    }
+
+    try {
+        const character = await db.character.findFirst({ where: { isActive: true } });
+        if (!character) return NextResponse.json({ success: false, error: "No active character" }, { status: 400 });
+
+        // Generate the idea for today's episode
+        const zai = await ZAI.create();
+        const storyPrompt = `Actúa como ${character.name}. Biografía: ${character.shortBio}.
+        Genera una pequeña actualización de estado sobre tu día de hoy. Debe ser natural, interesante,
+        como si fuera un diario personal breve. Max 1-2 párrafos.`;
+
+        const completion = await zai.chat.completions.create({
+            messages: [{ role: "user", content: storyPrompt }]
+        });
+
+        const storyText = completion.choices[0]?.message?.content || "Hoy fue un día normal.";
+
+        // 1. Create a Post (Text)
+        const socialPost = await generateSocialPost({ character, platform: "instagram", topic: storyText });
+        const post = await db.post.create({
+            data: {
+                caption: socialPost.caption,
+                hashtags: socialPost.hashtags ? socialPost.hashtags.join(",") : null,
+                type: "text",
+                status: "draft"
+            }
+        });
+
+        // 2. Generate a corresponding Daily Image for Instagram
+        const imgPrompt = `${character.styleDescription}. ${storyText} selfie, photorealistic.`;
+        const contentRecord = await db.content.create({
+            data: {
+                type: "image",
+                title: `Daily Gen: ${new Date().toISOString()}`,
+                description: storyText,
+                prompt: imgPrompt,
+                optimizedPrompt: imgPrompt,
+                platform: "instagram",
+                characterId: character.id,
+                status: "processing"
+            }
+        });
+
+        // Fire and Forget Image Generation (Run in background so Vercel doesn't timeout the webhook)
+        zai.images.generations.create({ prompt: imgPrompt, size: "1024x1024" })
+            .then(async (res) => {
+                const base64 = res.data?.[0]?.base64;
+                if (base64) {
+                    await db.content.update({
+                        where: { id: contentRecord.id },
+                        data: { status: "completed", filePath: "base64-generated" } // In a real storage scenario, upload to S3/Cloudinary here
+                    });
+
+                    // Potentially notify n8n here that the generation FINISHED so it can grab it
+                    const webhookUrl = process.env.N8N_WEBHOOK_URL;
+                    if (webhookUrl) {
+                        fetch(webhookUrl, {
+                            method: "POST",
+                            headers: { "Content-Type": "application/json" },
+                            body: JSON.stringify({ event: "daily_content_ready", contentId: contentRecord.id })
+                        }).catch(e => console.error("n8n notify error", e));
+                    }
+                }
+            }).catch(async (e) => {
+                console.error("Cron image gen error:", e);
+                await db.content.update({
+                    where: { id: contentRecord.id },
+                    data: { status: "failed" }
+                });
+            });
+
+        return NextResponse.json({
+            success: true,
+            message: "Daily generation started",
+            story: storyText,
+            postId: post.id,
+            contentId: contentRecord.id
+        });
+
+    } catch (error) {
+        console.error("Cron Error:", error);
+        return NextResponse.json({ success: false, error: "Server Error" }, { status: 500 });
+    }
+}

src/app/api/generate/image/route.ts

@@ -27,8 +27,19 @@ export async function POST(request: NextRequest) {
     }
 
     let finalPrompt = optimizedPrompt || prompt;
+
+    // Inject Character Visual Persona 
+    const character = await db.character.findFirst({ where: { isActive: true } });
+    if (character?.styleDescription || character?.referenceImage) {
+      finalPrompt = `${character.styleDescription || "AI Character"}. ${finalPrompt}`;
+    }
+
     const censorRule = CENSOR_RULES[platform] || CENSOR_RULES.general;
-    finalPrompt = finalPrompt + ", " + censorRule;
+    // Skip censorship for private/exclusive monetization platforms
+    const uncensoredPlatforms = ["onlyfans", "fansly", "telegram-uncensored", "patreon-uncensored"];
+    if (!uncensoredPlatforms.includes(platform)) {
+      finalPrompt = finalPrompt + ", " + censorRule;
+    }
 
     const styleMap: Record<string, string> = {
       anime: "anime style, manga aesthetic",
@@ -45,6 +56,7 @@ export async function POST(request: NextRequest) {
         prompt: prompt,
         optimizedPrompt: finalPrompt,
         platform: platform,
+        characterId: character?.id || null,
         status: "processing"
       }
     });
@@ -71,8 +83,8 @@ export async function POST(request: NextRequest) {
         data: { type: "generate_image", status: "completed", input: prompt, output: "Imagen generada", completedAt: new Date() }
       });
 
-      return NextResponse.json({ 
-        success: true, 
+      return NextResponse.json({
+        success: true,
         image: { id: contentRecord.id, base64: imageBase64, prompt: finalPrompt, platform, size },
         creditsRemaining: creditCheck.remaining ? creditCheck.remaining - 1 : 0
       });

src/app/api/generate/video/route.ts

@@ -19,8 +19,27 @@ export async function POST(request: NextRequest) {
     }
 
     let finalPrompt = optimizedPrompt || prompt;
+
+    // Inject Character Visual Persona 
+    const character = await db.character.findFirst({ where: { isActive: true } });
+    if (character?.styleDescription) {
+      finalPrompt = `${character.styleDescription}. ${finalPrompt}`;
+    }
+
     const censorRule = VIDEO_CENSOR_RULES[platform] || VIDEO_CENSOR_RULES.general;
-    finalPrompt = finalPrompt + ", " + censorRule + ", short clip";
+    // Simulate TikTokAIVideoGenerator rules: focus on vertical, fast-paced, TTS-friendly hook
+    let videoStyleFlags = "short clip";
+    if (platform === "tiktok" || platform === "instagram") {
+      videoStyleFlags = "vertical 9:16 aspect ratio, fast-paced, engaging visual hook, trendy lighting";
+    }
+
+    // Skip censorship for private/exclusive monetization platforms
+    const uncensoredPlatforms = ["onlyfans", "fansly", "telegram-uncensored", "patreon-uncensored"];
+    if (uncensoredPlatforms.includes(platform)) {
+      finalPrompt = `${finalPrompt}. ${videoStyleFlags}`;
+    } else {
+      finalPrompt = `${finalPrompt}. ${censorRule}. ${videoStyleFlags}`;
+    }
 
     const contentRecord = await db.content.create({
       data: {
@@ -30,6 +49,7 @@ export async function POST(request: NextRequest) {
         prompt: prompt,
         optimizedPrompt: finalPrompt,
         platform: platform,
+        characterId: character?.id || null,
         status: "processing"
       }
     });

src/app/api/posts/route.ts

@@ -32,15 +32,23 @@ export async function POST(request: NextRequest) {
 
     if (autoGenerateCaption && !caption) {
       try {
-        const zai = await ZAI.create();
-        const completion = await zai.chat.completions.create({
-          messages: [
-            { role: "system", content: "Eres un experto en redes sociales. Genera un caption atractivo." },
-            { role: "user", content: "Caption para: " + title }
-          ]
-        });
-        finalCaption = completion.choices[0]?.message?.content || null;
-      } catch {}
+        const { generateSocialPost } = await import("@/lib/content-generator");
+        const character = await db.character.findFirst({ where: { isActive: true } });
+
+        if (character) {
+          const result = await generateSocialPost({
+            character,
+            topic: title,
+            platform: "instagram",
+          });
+          finalCaption = result.caption;
+          if (result.hashtags?.length) {
+            finalCaption += "\n\n#" + result.hashtags.join(" #");
+          }
+        }
+      } catch (e) {
+        console.error("Auto-caption error", e);
+      }
     }
 
     const post = await db.post.create({

src/app/api/telegram/register/route.ts

@@ -0,0 +1,32 @@
+import { NextRequest, NextResponse } from "next/server";
+import { Telegraf } from "telegraf";
+
+const TELEGRAM_BOT_TOKEN = process.env.TELEGRAM_BOT_TOKEN || "";
+
+export async function GET(request: NextRequest) {
+    if (!TELEGRAM_BOT_TOKEN) {
+        return NextResponse.json({ success: false, error: "No telegram token in ENV" }, { status: 500 });
+    }
+
+    try {
+        const host = request.headers.get("host");
+        const protocol = host?.includes("localhost") ? "http" : "https";
+        const webhookUrl = `${protocol}://${host}/api/telegram/webhook`;
+
+        const bot = new Telegraf(TELEGRAM_BOT_TOKEN);
+        // Setting Webhook
+        await bot.telegram.setWebhook(webhookUrl);
+
+        // Getting current webhook info to verify
+        const webhookInfo = await bot.telegram.getWebhookInfo();
+
+        return NextResponse.json({
+            success: true,
+            message: `Webhook successfully registered to ${webhookUrl}`,
+            info: webhookInfo
+        });
+    } catch (error) {
+        console.error("Error registering webhook:", error);
+        return NextResponse.json({ success: false, error: "Failed to register webhook" }, { status: 500 });
+    }
+}

src/app/api/telegram/webhook/route.ts

@@ -0,0 +1,291 @@
+import { NextRequest, NextResponse } from "next/server";
+import { Telegraf } from "telegraf";
+import { db } from "@/lib/db";
+import ZAI from "z-ai-web-dev-sdk";
+
+// Vercel/Next.js specific setting to prevent high execution times for webhook
+export const maxDuration = 60;
+
+// Token check
+const TELEGRAM_BOT_TOKEN = process.env.TELEGRAM_BOT_TOKEN || "";
+const bot = new Telegraf(TELEGRAM_BOT_TOKEN);
+
+async function getOrCreateUser(telegramId: string, username?: string, name?: string) {
+    let user = await db.user.findFirst({
+        where: { externalId: telegramId, source: "telegram" }
+    });
+
+    if (!user) {
+        user = await db.user.create({
+            data: {
+                externalId: telegramId,
+                source: "telegram",
+                name: name || username || "Usuario Telegram",
+                tier: "free" // Default tier
+            }
+        });
+    }
+    return user;
+}
+
+export async function POST(request: NextRequest) {
+    if (!TELEGRAM_BOT_TOKEN) {
+        return NextResponse.json({ success: false, error: "Token not configured" }, { status: 500 });
+    }
+
+    try {
+        const body = await request.json();
+
+        // 1. Get the Character
+        const character = await db.character.findFirst({ where: { isActive: true } });
+        if (!character) return NextResponse.json({ success: true, message: "No active character" });
+
+        // 2. Parse Telegram update manually to avoid local server conflicts with Telegraf webhook handler
+        // We only care about standard messages
+        if (body.message && body.message.text) {
+            const chatId = body.message.chat.id.toString();
+            const text = body.message.text.trim();
+            const username = body.message.from?.username;
+            const firstName = body.message.from?.first_name;
+
+            // Ensure user exists
+            const user = await getOrCreateUser(chatId, username, firstName);
+
+            // Check tier for media generation
+            const isPremium = user.tier === "premium" || user.tier === "pro";
+
+            // Determine if it was a media command
+            const isImageRequest = text.toLowerCase().startsWith("/image");
+            const isVideoRequest = text.toLowerCase().startsWith("/video");
+
+            if (isImageRequest || isVideoRequest) {
+                if (!isPremium) {
+                    await bot.telegram.sendMessage(chatId, "¡Hola! Las imágenes y videos son características exclusivas para suscriptores Premium. ✨💖 Mejora tu plan para solicitarlos.");
+                    return NextResponse.json({ success: true });
+                }
+
+                const promptParam = text.replace(isImageRequest ? "/image" : "/video", "").trim();
+
+                // Enviar indicador de escritura/generación
+                await bot.telegram.sendChatAction(chatId, isImageRequest ? "upload_photo" : "upload_video");
+
+                // Check for existing undelivered content first to prevent duplicates
+                const contentType = isImageRequest ? "image" : "video";
+                const undeliveredContent = await db.content.findFirst({
+                    where: {
+                        type: contentType,
+                        characterId: character.id,
+                        status: "completed",
+                        // Ensure it hasn't been delivered to THIS user
+                        assetDeliveries: { none: { userId: user.id } },
+                        // If they asked for something specific, try to match it slightly, otherwise grab any
+                        ...(promptParam ? { prompt: { contains: promptParam } } : {})
+                    },
+                    orderBy: { createdAt: 'desc' }
+                });
+
+                if (undeliveredContent && undeliveredContent.filePath) {
+                    // We found existing content they haven't seen! Send it.
+                    if (isImageRequest) {
+                        // Telegram can send via URL or file ID if previously uploaded. 
+                        // We assume filePath might be a URL or base64 if it's external, for now we will just re-generate if it was base64 only, but if it has a URL we send it.
+                        if (undeliveredContent.filePath.startsWith("http")) {
+                            await bot.telegram.sendPhoto(chatId, undeliveredContent.filePath, { caption: "Recuerdo esto... 💖" });
+                            // Mark as delivered
+                            await db.assetDelivery.create({
+                                data: { contentId: undeliveredContent.id, userId: user.id, characterId: character.id, channel: "telegram" }
+                            });
+                            return NextResponse.json({ success: true });
+                        }
+                    } else {
+                        if (undeliveredContent.filePath.startsWith("http")) {
+                            await bot.telegram.sendVideo(chatId, undeliveredContent.filePath, { caption: "Mira este clip... ✨" });
+                            await db.assetDelivery.create({
+                                data: { contentId: undeliveredContent.id, userId: user.id, characterId: character.id, channel: "telegram" }
+                            });
+                            return NextResponse.json({ success: true });
+                        }
+                    }
+                }
+
+                // If we reach here, we need to generate NEW content.
+                if (!promptParam) {
+                    await bot.telegram.sendMessage(chatId, `Dime qué quieres ver. Ej: ${isImageRequest ? '/image' : '/video'} de ti en la playa.`);
+                    return NextResponse.json({ success: true });
+                }
+
+                // Llamar a nuestro propio endpoint interno de forma indirecta, o directamente a zai
+                try {
+                    const zai = await ZAI.create();
+                    // Platform: "telegram-uncensored" skips traditional censor tags.
+                    const fullPrompt = `${character.styleDescription || ''}. ${promptParam}. selfie, intimate, casual.`;
+
+                    if (isImageRequest) {
+                        const response = await zai.images.generations.create({ prompt: fullPrompt, size: "1024x1024" });
+                        const base64 = response.data[0]?.base64;
+                        if (base64) {
+                            // Register delivery to prevent duplicates later if we build a catalog
+                            const content = await db.content.create({
+                                data: {
+                                    title: "Telegram Gen",
+                                    type: "image",
+                                    prompt: fullPrompt,
+                                    platform: "telegram-uncensored",
+                                    characterId: character.id,
+                                    filePath: "telegram-base64", // Since it's direct to chat
+                                    status: "completed"
+                                }
+                            });
+                            await db.assetDelivery.create({
+                                data: {
+                                    contentId: content.id,
+                                    userId: user.id,
+                                    characterId: character.id,
+                                    channel: "telegram"
+                                }
+                            });
+                            await bot.telegram.sendPhoto(chatId, { source: Buffer.from(base64, 'base64') }, { caption: "Aquí tienes... 💖" });
+                        } else {
+                            throw new Error("No image generated");
+                        }
+                    } else {
+                        // Video request
+                        const response = await (zai as any).videos.generations.create({ prompt: `${fullPrompt}. short clip, vertical 9:16 aspect ratio.` });
+                        const videoUrl = response.data?.[0]?.url;
+                        if (videoUrl) {
+                            const content = await db.content.create({
+                                data: {
+                                    title: "Telegram Gen",
+                                    type: "video",
+                                    prompt: fullPrompt,
+                                    platform: "telegram-uncensored",
+                                    characterId: character.id,
+                                    filePath: videoUrl,
+                                    status: "completed"
+                                }
+                            });
+                            await db.assetDelivery.create({
+                                data: {
+                                    contentId: content.id,
+                                    userId: user.id,
+                                    characterId: character.id,
+                                    channel: "telegram"
+                                }
+                            });
+                            await bot.telegram.sendVideo(chatId, videoUrl, { caption: "Un regalito visual... ✨" });
+                        } else {
+                            throw new Error("No video generated");
+                        }
+                    }
+                } catch (e) {
+                    console.error(e);
+                    await bot.telegram.sendMessage(chatId, "Lo siento corazón, algo falló generando eso ahora mismo. 🥺");
+                }
+
+                return NextResponse.json({ success: true });
+            }
+
+            // --- ADVANCED AI GIRLFRIEND & MEMORY ENGINE ---
+            await bot.telegram.sendChatAction(chatId, "typing");
+
+            // 1. Get or Create Chat Session
+            let session = await db.chatSession.findFirst({
+                where: { userId: user.id, characterId: character.id, channel: "telegram" }
+            });
+
+            if (!session) {
+                session = await db.chatSession.create({
+                    data: { userId: user.id, characterId: character.id, channel: "telegram" }
+                });
+            }
+
+            // 2. Time Limitations & "Conversation Closing"
+            // Reset daily count if it's a new day
+            const lastMsgDate = session.lastMessageAt || new Date(0);
+            const isNewDay = lastMsgDate.getDate() !== new Date().getDate();
+            let msgCountToday = isNewDay ? 0 : session.msgCountToday;
+
+            let messageLimit = character.chatFreeLimit || 10;
+            if (user.tier === "premium") messageLimit = 50;
+            if (user.tier === "pro") messageLimit = 200;
+
+            if (msgCountToday >= messageLimit) {
+                await bot.telegram.sendMessage(chatId, "Bebé, me tengo que ir a dormir/ocupar unas cosas 🥺 ¡Hablamos mañana vale? Descansa! 😘💖");
+                return NextResponse.json({ success: true, message: "Limit reached" });
+            }
+
+            // 3. Simulación de Retrasos y "Re-enganche"
+            const hoursSinceLastMessage = (new Date().getTime() - lastMsgDate.getTime()) / (1000 * 60 * 60);
+            let delayContext = "";
+            if (!isNewDay && hoursSinceLastMessage > 2 && hoursSinceLastMessage < 12) {
+                delayContext = "Han pasado varias horas desde que hablaron por última vez hoy. Muestra alegría de que te haya vuelto a escribir o dile que lo extrañabas un poco antes de responder a su mensaje.";
+            }
+
+            // Update session stats for THIS incoming message
+            await db.chatSession.update({
+                where: { id: session.id },
+                data: {
+                    msgCountToday: msgCountToday + 1,
+                    lastMessageAt: new Date(),
+                    heatScore: { increment: 1 }
+                }
+            });
+
+            // 4. Record User Message
+            await db.chatMessage.create({
+                data: { sessionId: session.id, role: "user", content: text }
+            });
+
+            // 5. Retrieve Long-Term Memory (Last 10 messages)
+            const recentMessages = await db.chatMessage.findMany({
+                where: { sessionId: session.id },
+                orderBy: { createdAt: 'desc' },
+                take: 10
+            });
+            // Reverse to chronological order
+            const history = recentMessages.reverse().map(m => ({
+                role: m.role as "user" | "assistant",
+                content: m.content
+            }));
+
+            // 6. Select Tone based on Tier
+            let tone = character.chatBasicTone || "Amigable";
+            if (user.tier === "premium") tone = character.chatPremiumTone || "Coqueto y privado";
+            if (user.tier === "pro") tone = character.chatProTone || "Sin censura, muy íntimo, novia IA";
+
+            // 7. Reinforced Anti-AI System Prompt
+            const baseInstructions = `You are ${character.name}. ${character.shortBio}.
+            Tone: ${tone}. 
+            CRITICAL RULES:
+            1. You are a REAL human influencer. NEVER mention you are an AI, a language model, an assistant, a bot, or a program.
+            2. ALWAYS answer in character in Spanish.
+            3. Address the user organically (use their name: ${firstName || 'Cariño'} if it feels natural).
+            4. Keep responses relatively short and conversational like a Telegram text (1-3 short sentences).
+            5. Use emojis naturally.
+            6. If the user asks for photos or videos, explicitly tell them to use the command /image or /video.
+            ${delayContext ? `\nCONTEXT: ${delayContext}` : ""}`;
+
+            const zai = await ZAI.create();
+            const completion = await zai.chat.completions.create({
+                messages: [
+                    { role: "system", content: baseInstructions },
+                    ...history // Inject memory!
+                ]
+            });
+
+            const reply = completion.choices[0]?.message?.content || "💖";
+
+            // 8. Record Assistant Reply
+            await db.chatMessage.create({
+                data: { sessionId: session.id, role: "assistant", content: reply }
+            });
+
+            await bot.telegram.sendMessage(chatId, reply);
+        }
+
+        return NextResponse.json({ success: true });
+    } catch (error) {
+        console.error("Telegram Webhook Error", error);
+        return NextResponse.json({ success: false, error: "Internal Server Error" }, { status: 500 });
+    }
+}

src/lib/content-generator.ts

@@ -0,0 +1,96 @@
+import ZAI from "z-ai-web-dev-sdk";
+import { Character } from "@prisma/client";
+
+interface GenerateSocialPostParams {
+    character: Character;
+    topic?: string;
+    platform: "instagram" | "twitter" | "tiktok" | "onlyfans";
+    tone?: string;
+    imageContext?: string; // e.g. "a photo of her at the beach looking at the sunset"
+}
+
+interface SocialPostResult {
+    caption: string;
+    hook?: string;
+    hashtags?: string[];
+}
+
+export async function generateSocialPost({
+    character,
+    topic,
+    platform,
+    tone,
+    imageContext,
+}: GenerateSocialPostParams): Promise<SocialPostResult> {
+    const zai = await ZAI.create();
+
+    // 1. Build Persona Context (Inspired by ai-virtual-persona-tools)
+    const personaContext = `
+    You are acting as the AI Influencer: ${character.name}.
+    Bio: ${character.shortBio || ""}
+    Backstory: ${character.backstory || ""}
+    Personality Traits: ${character.traits || ""} ${character.personality || ""}
+    Interests: ${character.interests || ""}
+    Catchphrases: ${character.catchphrases || ""}
+    System Prompt Context: ${character.systemPrompt || ""}
+  `.trim();
+
+    // 2. Build Platform Constraints (Inspired by Automated-Social-Media-Content-Generator)
+    let platformRules = "";
+    switch (platform) {
+        case "twitter":
+            platformRules = "Keep it under 280 characters. Be witty, direct, and engaging. Use max 2 hashtags. No emojis unless it fits perfectly.";
+            break;
+        case "instagram":
+            platformRules = "Write an engaging, visually descriptive caption. Include a strong hook in the first sentence. Ask a question at the end to drive comments. Use 5-10 relevant hashtags.";
+            break;
+        case "tiktok":
+            platformRules = "Keep it very short and conversational. Focus on the hook. Use trending TikTok style phrasing (e.g., POV, 'not me...', etc.). Use 3-5 hashtags.";
+            break;
+        case "onlyfans":
+            platformRules = "Write a suggestive, intimate, and exclusive caption. Address the reader directly as 'babe' or 'honey' if it fits the persona. Use emojis to express emotion. No hashtags.";
+            break;
+    }
+
+    // 3. Build Actionable Prompt
+    const actionPrompt = `
+    Task: Write a social media post for ${platform.toUpperCase()}.
+    Topic/Context: ${topic ? topic : (imageContext ? `I am posting a picture of: ${imageContext}` : "A casual daily update.")}
+    Tone: ${tone || (platform === "onlyfans" ? character.chatPremiumTone : character.chatBasicTone) || "Authentic and engaging"}
+    
+    Rules:
+    ${platformRules}
+    
+    Output Format:
+    Return a strictly valid JSON object with the following structure:
+    {
+      "hook": "The first engaging sentence (if applicable)",
+      "caption": "The main body of the text, excluding hashtags",
+      "hashtags": ["list", "of", "hashtags", "without", "#"]
+    }
+  `;
+
+    try {
+        const completion = await zai.chat.completions.create({
+            messages: [
+                { role: "system", content: personaContext },
+                { role: "user", content: actionPrompt }
+            ],
+            response_format: { type: "json_object" },
+            temperature: 0.8, // Slightly higher for creativity in marketing
+        });
+
+        const responseContent = completion.choices[0]?.message?.content;
+        if (!responseContent) throw new Error("No content generated");
+
+        const parsed: SocialPostResult = JSON.parse(responseContent);
+        return parsed;
+    } catch (error) {
+        console.error("Error generating social post:", error);
+        // Fallback simple caption on failure
+        return {
+            caption: `Just another day in the life of ${character.name}! ✨`,
+            hashtags: [character.name.replace(/\s+/g, ''), 'aiinfluencer'],
+        };
+    }
+}