Delete services

services/adminService.js

@@ -1,64 +0,0 @@
-
-import { db } from '@/backend/services/firebase';
-
-export const AdminService = {
-    async updateSettings(settings) {
-        await db.ref('system/settings').update(settings);
-        return { success: true };
-    },
-
-    async addUser(userData, referrerCode) {
-        const membershipId = userData.Active_Session_ID;
-        
-        const userPayload = { 
-            ...userData, 
-            Login_Key: membershipId,
-            Active_Session_ID: membershipId,
-            Referrer: referrerCode || "NONE", 
-            Status: 'ACTIVE', 
-            Usage: {}, 
-            Last_Usage_Date: new Date().toISOString().split('T')[0] 
-        };
-        
-        await db.ref(`users/${Date.now()}`).set(userPayload);
-        return { success: true };
-    },
-
-    async reactivateUser(nodeKey, userClass, credits) {
-        const today = new Date();
-        const expDate = new Date(today.getTime() + 30 * 86400000).toISOString().split('T')[0];
-        
-        const updates = {
-            Class: userClass,
-            Credits: credits,
-            Expired_Date: expDate,
-            Status: 'ACTIVE'
-        };
-        
-        await db.ref(`users/${nodeKey}`).update(updates);
-        return { success: true };
-    },
-
-    async updateUserClass(nodeKey, userClass, credits) {
-        const updates = {
-            Class: userClass,
-            Credits: credits
-        };
-        await db.ref(`users/${nodeKey}`).update(updates);
-        return { success: true };
-    },
-
-    async topUpCredits(sessionId, amount) {
-        const snapshot = await db.ref('users').orderByChild('Active_Session_ID').equalTo(sessionId).once('value');
-        if (!snapshot.exists()) throw new Error("User not found");
-        const userKey = Object.keys(snapshot.val())[0];
-        const currentCredits = snapshot.val()[userKey].Credits || 0;
-        await db.ref(`users/${userKey}`).update({ Credits: currentCredits + amount });
-        return { success: true };
-    },
-
-    async deleteUser(nodeKey) {
-        await db.ref(`users/${nodeKey}`).remove();
-        return { success: true };
-    }
-};

services/ai.js

@@ -1,2 +0,0 @@
-
-export { AIService } from '@/backend/services/ai/index';

services/ai/bookRecap.js

@@ -1,46 +0,0 @@
-
-import { tryModels, getPrompt, DEFAULT_SAFETY_SETTINGS } from '@/backend/services/ai/utils';
-
-export async function bookRecap(media, mimeType, targetLanguage, apiKey, isOwnApi = false) {
-    const models = ['gemini-3-flash-preview', 'gemini-flash-lite-latest'];
-    const isBurmese = targetLanguage.toLowerCase().includes('burm') || targetLanguage.includes('မြန်မာ');
-    
-    // Clean language name in case any legacy strings remain
-    const cleanLanguage = targetLanguage.split(' (')[0];
-    
-    let burmeseRules = isBurmese ? getPrompt('burmese_rules.txt') : "";
-    let template = getPrompt('book_recap.txt');
-    
-    const authorPersona = isBurmese 
-        ? `You are a world-class Literary Translator and Novelist. Your task is to translate the provided text into beautiful, natural Burmese.`
-        : `You are a professional Book Translator and Author. Provide a complete, high-quality translation of this document into ${cleanLanguage}.`;
-
-    let finalPrompt = template
-        .replace('{{targetLanguage}}', cleanLanguage)
-        .replace('{{burmeseRules}}', burmeseRules)
-        .replace('{{authorPersona}}', authorPersona);
-
-    return await tryModels(apiKey, models, async (ai, model) => {
-        const response = await ai.models.generateContent({
-            model: model,
-            contents: { 
-                parts: [
-                    { inlineData: { data: media, mimeType } }, 
-                    { text: `Translate this entire document COMPLETELY (100% length) into ${cleanLanguage}. Do not summarize or skip any content.` }
-                ] 
-            },
-            config: { 
-                temperature: 0.3, 
-                systemInstruction: finalPrompt, 
-                safetySettings: DEFAULT_SAFETY_SETTINGS,
-                thinkingConfig: { thinkingBudget: 0 }
-            }
-        });
-        
-        const text = response.text;
-        if (!text || text.trim().length < 50) {
-             throw new Error("MODEL_FAILED_TO_TRANSLATE_DOCUMENT");
-        }
-        return text;
-    });
-}

services/ai/comicTranslator.js

@@ -1,68 +0,0 @@
-
-import { Type } from '@google/genai';
-import { tryModels, getPrompt, DEFAULT_SAFETY_SETTINGS, cleanJson } from '@/backend/services/ai/utils';
-
-export async function comicTranslate(media, mimeType, targetLanguage, apiKey, isOwnApi = false) {
-    const models = ['gemini-3-flash-preview', 'gemini-flash-lite-latest'];
-    const isBurmese = targetLanguage.toLowerCase().includes('burm') || targetLanguage.includes('မြန်မာ');
-    
-    let burmeseRules = isBurmese ? getPrompt('burmese_rules.txt') : "";
-    let template = getPrompt('comic_translator.txt');
-    
-    let finalPrompt = template
-        .replace('{{targetLanguage}}', targetLanguage)
-        .replace('{{burmeseRules}}', burmeseRules);
-
-    // AI identifies text locations and translations
-    return await tryModels(apiKey, models, async (ai, model) => {
-        const response = await ai.models.generateContent({
-            model: model,
-            contents: { 
-                parts: [
-                    { inlineData: { data: media, mimeType } }, 
-                    { text: "TASK: Process this document page by page. For each page, identify all text bubbles. Provide their [ymin, xmin, ymax, xmax] coordinates and the translated text in " + targetLanguage + ". Output ONLY valid JSON." }
-                ] 
-            },
-            config: { 
-                temperature: 0.1, 
-                systemInstruction: finalPrompt, 
-                safetySettings: DEFAULT_SAFETY_SETTINGS,
-                responseMimeType: "application/json",
-                responseSchema: {
-                    type: Type.OBJECT,
-                    properties: {
-                        pages: {
-                            type: Type.ARRAY,
-                            items: {
-                                type: Type.OBJECT,
-                                properties: {
-                                    page_number: { type: Type.INTEGER },
-                                    text_blocks: {
-                                        type: Type.ARRAY,
-                                        items: {
-                                            type: Type.OBJECT,
-                                            properties: {
-                                                translated_text: { type: Type.STRING },
-                                                box_2d: { 
-                                                    type: Type.ARRAY, 
-                                                    items: { type: Type.NUMBER },
-                                                    description: "[ymin, xmin, ymax, xmax] coordinates normalized 0-1000"
-                                                },
-                                                background_color: { type: Type.STRING }
-                                            }
-                                        }
-                                    }
-                                }
-                            }
-                        }
-                    },
-                    required: ['pages']
-                }
-            }
-        });
-        
-        // The backend server will receive this JSON and perform the heavy image manipulation
-        // returning a final processed URL or Base64 to the client.
-        return JSON.parse(cleanJson(response.text));
-    });
-}

services/ai/creator.js

@@ -1,54 +0,0 @@
-
-import { tryModels, getPrompt, DEFAULT_SAFETY_SETTINGS } from '@/backend/services/ai/utils';
-
-export async function contentCreator(topic, category, subTopics, contentType, gender, targetLang, apiKey, isOwnApi = false) {
-    const models = ['gemini-3-flash-preview', 'gemini-flash-lite-latest'];
-    const isBurmese = targetLang.toLowerCase().includes('burm') || targetLang.includes('မြန်မာ');
-    let burmeseRules = "";
-    if (isBurmese) {
-        const pronoun = gender === 'male' ? "ကျွန်တော်" : "ကျွန်မ";
-        burmeseRules = getPrompt('creator_burmese_rules.txt').replace('{{pronoun}}', pronoun).replace('{{topic}}', topic).replace('{{category}}', category).replace('{{subTopics}}', subTopics.join(', '));
-    }
-    const template = getPrompt('content_creator.txt');
-    const finalPrompt = template.replace('{{contentType}}', contentType).replace('{{topic}}', topic).replace('{{category}}', category).replace('{{targetLang}}', targetLang).replace('{{burmeseRules}}', burmeseRules);
-    return await tryModels(apiKey, models, async (ai, model) => {
-        const response = await ai.models.generateContent({ 
-            model, 
-            contents: [{ parts: [{ text: `Topic: ${topic}. Category: ${category}.` }] }], 
-            config: { temperature: 0.8, systemInstruction: finalPrompt, safetySettings: DEFAULT_SAFETY_SETTINGS } 
-        });
-        return response.text;
-    });
-}
-
-export async function generateImage(prompt, apiKey, isOwnApi = false) {
-    const models = ['gemini-2.5-flash-image', 'gemini-3-pro-image-preview'];
-    
-    // Improved visual prompt for better generation
-    const visualPrompt = `High-quality cinematic illustrative 3D character design or scene showing: ${prompt}. Vivid colors, detailed environment, 8k resolution style.`;
-
-    return await tryModels(apiKey, models, async (ai, model) => {
-        const response = await ai.models.generateContent({
-            model: model,
-            contents: { 
-                parts: [
-                    { text: visualPrompt }
-                ] 
-            },
-            config: { 
-                imageConfig: { aspectRatio: "1:1" }
-            }
-        });
-
-        // Thoroughly check all candidates and parts for inlineData
-        for (const candidate of response.candidates || []) {
-            for (const part of candidate.content?.parts || []) {
-                if (part.inlineData) {
-                    return `data:image/png;base64,${part.inlineData.data}`;
-                }
-            }
-        }
-        
-        throw new Error("EMPTY_IMAGE_DATA_RESPONSE");
-    });
-}

services/ai/index.js

@@ -1,23 +0,0 @@
-
-import { transcribe } from '@/backend/services/ai/transcribe';
-import { recap } from '@/backend/services/ai/recap';
-import { bookRecap } from '@/backend/services/ai/bookRecap';
-import { comicTranslate } from '@/backend/services/ai/comicTranslator';
-import { translate } from '@/backend/services/ai/translate';
-import { srtTranslate } from '@/backend/services/ai/srtTranslate';
-import { tts } from '@/backend/services/ai/tts';
-import { subtitle } from '@/backend/services/ai/subtitle';
-import { contentCreator, generateImage } from '@/backend/services/ai/creator';
-
-export const AIService = {
-    transcribe,
-    recap,
-    bookRecap,
-    comicTranslate,
-    translate,
-    srtTranslate,
-    tts,
-    subtitle,
-    contentCreator,
-    generateImage
-};

services/ai/recap.js

@@ -1,32 +0,0 @@
-
-import { tryModels, getPrompt, DEFAULT_SAFETY_SETTINGS } from '@/backend/services/ai/utils';
-
-export async function recap(media, mimeType, targetLanguage, apiKey, isOwnApi = false) {
-    // UPDATED: Aligned with the 'no Pro' preference
-    const models = ['gemini-3-flash-preview', 'gemini-flash-lite-latest'];
-    const template = getPrompt('recap.txt');
-    const finalPrompt = template.replace('{{targetLanguage}}', targetLanguage);
-    return await tryModels(apiKey, models, async (ai, model) => {
-        const response = await ai.models.generateContent({
-            model: model,
-            contents: { 
-                parts: [
-                    { inlineData: { data: media, mimeType } }, 
-                    { text: "Narrate an extremely detailed cinematic recap." }
-                ] 
-            },
-            config: { 
-                temperature: 0.4, 
-                systemInstruction: finalPrompt, 
-                safetySettings: DEFAULT_SAFETY_SETTINGS,
-                thinkingConfig: { thinkingBudget: 0 }
-            }
-        });
-        
-        const text = response.text;
-        if (!text || text.trim().length < 10) {
-             throw new Error("MODEL_FAILED_TO_GENERATE_RECAP");
-        }
-        return text;
-    });
-}

services/ai/srtTranslate.js

@@ -1,82 +0,0 @@
-import { tryModels, getPrompt, cleanSRTOutput, DEFAULT_SAFETY_SETTINGS } from '@/backend/services/ai/utils';
-
-/**
- * Counts the number of SRT blocks in a given text.
- */
-function countSrtBlocks(text) {
-    if (!text) return 0;
-    // Improved regex to count standard SRT blocks accurately
-    const matches = text.match(/^\d+\s*\r?\n\d{2}:\d{2}:\d{2},\d{3}/gm);
-    return matches ? matches.length : 0;
-}
-
-export async function srtTranslate(srtContent, sourceLanguage, targetLanguage, apiKey, isOwnApi = false) {
-    const models = ['gemini-3-flash-preview', 'gemini-flash-lite-latest'];
-    const template = getPrompt('srt_translation.txt');
-    const finalPrompt = template.replace('{{sourceLanguage}}', sourceLanguage).replace(/{{targetLanguage}}/g, targetLanguage);
-    
-    // Normalize line endings and split into blocks
-    const blocks = srtContent.replace(/\r\n/g, '\n').split(/\n\s*\n/).filter(b => b.trim().length > 0);
-    
-    const CHUNK_SIZE = 120; // Increased to 120 as requested for higher throughput
-    const BATCH_SIZE = 2;   // Enabled Parallel processing (2 at a time)
-    const COOLDOWN = 1000;  // Minimal cooldown between parallel batches
-    
-    console.log(`[AI-SRT-SAFE-MAX] Segment Blocks: ${blocks.length}. Chunks: ${Math.ceil(blocks.length/CHUNK_SIZE)}.`);
-
-    const chunkTexts = [];
-    const chunkBlockCounts = [];
-    for (let i = 0; i < blocks.length; i += CHUNK_SIZE) {
-        const slice = blocks.slice(i, i + CHUNK_SIZE);
-        chunkTexts.push(slice.join('\n\n'));
-        chunkBlockCounts.push(slice.length);
-    }
-
-    const results = [];
-    for (let i = 0; i < chunkTexts.length; i += BATCH_SIZE) {
-        const currentBatchIndices = Array.from({ length: Math.min(BATCH_SIZE, chunkTexts.length - i) }, (_, k) => i + k);
-        
-        const batchPromises = currentBatchIndices.map(idx => 
-            tryModels(apiKey, models, async (ai, model) => {
-                const inputText = chunkTexts[idx];
-                const expectedCount = chunkBlockCounts[idx];
-                
-                let response = await ai.models.generateContent({
-                    model: model,
-                    contents: [{ parts: [{ text: `Translate these ${expectedCount} blocks now. Maintain all IDs:\n\n${inputText}` }] }],
-                    config: { 
-                        temperature: 0.1, 
-                        systemInstruction: finalPrompt, 
-                        safetySettings: DEFAULT_SAFETY_SETTINGS,
-                        thinkingConfig: { thinkingBudget: 0 } 
-                    }
-                });
-
-                let translatedText = cleanSRTOutput(response.text);
-                let actualCount = countSrtBlocks(translatedText);
-
-                // --- INTEGRITY AUTO-RECOVERY ---
-                if (actualCount < expectedCount) {
-                    console.warn(`[AI-SRT] Gap detected in chunk ${idx} (${actualCount}/${expectedCount}). Retrying with max precision...`);
-                    response = await ai.models.generateContent({
-                        model: model,
-                        contents: [{ parts: [{ text: `CRITICAL: Do not skip lines. You MUST return exactly ${expectedCount} blocks. Translate ALL now:\n\n${inputText}` }] }],
-                        config: { temperature: 0.0, systemInstruction: finalPrompt, safetySettings: DEFAULT_SAFETY_SETTINGS }
-                    });
-                    translatedText = cleanSRTOutput(response.text);
-                }
-
-                return translatedText;
-            })
-        );
-
-        const batchResults = await Promise.all(batchPromises);
-        results.push(...batchResults);
-
-        if (i + BATCH_SIZE < chunkTexts.length) {
-            await new Promise(r => setTimeout(r, COOLDOWN));
-        }
-    }
-
-    return results.join('\n\n').trim();
-}

services/ai/subtitle.js

@@ -1,53 +0,0 @@
-
-import { tryModels, getPrompt, cleanSRTOutput, DEFAULT_SAFETY_SETTINGS } from '@/backend/services/ai/utils';
-import { transcribe } from '@/backend/services/ai/transcribe';
-
-const formatMsToSRT = (ms) => {
-    const hours = Math.floor(ms / 3600000);
-    const mins = Math.floor((ms % 3600000) / 60000);
-    const secs = Math.floor((ms % 60000) / 1000);
-    const mms = Math.floor(ms % 1000);
-    return `${hours.toString().padStart(2, '0')}:${mins.toString().padStart(2, '0')}:${secs.toString().padStart(2, '0')},${mms.toString().padStart(3, '0')}`;
-};
-
-export async function subtitle(mediaBase64, mimeType, fullScript, apiKey, isOwnApi = false, sourceLanguage = 'English', startOffsetMs = 0, lastScriptIndex = 0) {
-    let scriptToProcess = fullScript || "";
-
-    // If script is empty, transcribe the whole media
-    if (!scriptToProcess) {
-        scriptToProcess = await transcribe(mediaBase64, mimeType, apiKey, isOwnApi);
-    }
-
-    const isBurmese = sourceLanguage.toLowerCase().includes('burm') || sourceLanguage.includes('မြန်မာ');
-    const promptTemplate = getPrompt('subtitle.txt');
-    
-    // REMOVED: 15-second restriction logic.
-    // ADDED: Explicit instruction to process the ENTIRE audio.
-    const finalPrompt = promptTemplate
-        .replace('{{script}}', scriptToProcess)
-        .replace('{{language}}', isBurmese ? "Burmese (Conversational)" : sourceLanguage)
-        .replace('15-second audio input', 'the provided audio file') 
-        .replace('Align the script', 'Align the COMPLETE script from start to finish');
-
-    const rawSRT = await tryModels(apiKey, ['gemini-3-flash-preview'], async (ai, model) => {
-        const response = await ai.models.generateContent({
-            model,
-            contents: { 
-                parts: [
-                    { inlineData: { data: mediaBase64, mimeType: 'audio/wav' } }, 
-                    { text: `GENERATE FULL SRT: Listen to this entire file and align every word from the reference script. Return the complete SRT.` }
-                ] 
-            },
-            config: { 
-                temperature: 0, 
-                systemInstruction: finalPrompt, 
-                safetySettings: DEFAULT_SAFETY_SETTINGS
-            }
-        });
-        return cleanSRTOutput(response.text);
-    });
-
-    return { 
-        srt: rawSRT || "" 
-    };
-}

services/ai/transcribe.js

@@ -1,30 +0,0 @@
-
-import { tryModels, getPrompt, DEFAULT_SAFETY_SETTINGS } from '@/backend/services/ai/utils';
-
-export async function transcribe(media, mimeType, apiKey, isOwnApi = false) {
-    const models = ['gemini-3-flash-preview', 'gemini-flash-lite-latest'];
-    const systemPrompt = getPrompt('transcription.txt');
-    return await tryModels(apiKey, models, async (ai, model) => {
-        const response = await ai.models.generateContent({
-            model: model,
-            contents: { 
-                parts: [
-                    { inlineData: { data: media, mimeType } }, 
-                    { text: "Transcribe accurately and completely. Do not skip any dialogue." }
-                ] 
-            },
-            config: { 
-                temperature: 0.1, 
-                systemInstruction: systemPrompt, 
-                safetySettings: DEFAULT_SAFETY_SETTINGS,
-                thinkingConfig: { thinkingBudget: 0 }
-            }
-        });
-
-        const text = response.text;
-        if (!text || text.trim().length < 2) {
-             throw new Error("EMPTY_RESPONSE_FROM_MODEL");
-        }
-        return text;
-    });
-}

services/ai/translate.js

@@ -1,34 +0,0 @@
-
-import { Type } from '@google/genai';
-import { tryModels, getPrompt, cleanJson, DEFAULT_SAFETY_SETTINGS } from '@/backend/services/ai/utils';
-
-export async function translate(text, targetLanguage, options, apiKey, isOwnApi = false) {
-    const models = ['gemini-3-flash-preview', 'gemini-flash-lite-latest'];
-    const isBurmese = targetLanguage.toLowerCase().includes('burm') || targetLanguage.includes('မြန်မာ');
-    let burmeseRules = isBurmese ? getPrompt('burmese_rules.txt') : "";
-    let template = getPrompt('translation.txt');
-    let finalPrompt = template.replace('{{targetLanguage}}', targetLanguage).replace('{{burmeseRules}}', burmeseRules).replace('{{deepMeaningRules}}', options.includes('meaning') ? "REQUESTED" : "NULL").replace('{{suggestionRules}}', options.includes('suggestions') ? "REQUESTED" : "NULL");
-
-    return await tryModels(apiKey, models, async (ai, model) => {
-        const response = await ai.models.generateContent({
-            model: model,
-            contents: [{ parts: [{ text: `CONTENT: ${text}` }] }],
-            config: {
-                temperature: 0.7,
-                systemInstruction: finalPrompt,
-                responseMimeType: "application/json",
-                safetySettings: DEFAULT_SAFETY_SETTINGS,
-                responseSchema: {
-                    type: Type.OBJECT,
-                    properties: {
-                        translation: { type: Type.STRING },
-                        deepMeaning: { type: Type.STRING, nullable: true },
-                        suggestions: { type: Type.OBJECT, nullable: true, properties: { videoTitles: { type: Type.ARRAY, items: { type: Type.STRING } }, thumbnailTexts: { type: Type.ARRAY, items: { type: Type.STRING } } } }
-                    },
-                    required: ['translation']
-                }
-            }
-        });
-        return JSON.parse(cleanJson(response.text));
-    });
-}

services/ai/tts.js

@@ -1,43 +0,0 @@
-
-import { tryModels, getPrompt, DEFAULT_SAFETY_SETTINGS } from '@/backend/services/ai/utils';
-import { Modality } from '@google/genai';
-
-export async function tts(text, voiceName, tone, apiKey, isOwnApi = false) {
-    // Strict requirement: Max 3500 characters
-    const ABSOLUTE_MAX_LENGTH = 3500;
-    if (text && text.length > ABSOLUTE_MAX_LENGTH) {
-        throw new Error(`Text is too long (${text.length} chars). Maximum allowed is ${ABSOLUTE_MAX_LENGTH} characters.`);
-    }
-
-    const models = ['gemini-2.5-flash-preview-tts', 'gemini-2.5-pro-preview-tts']; 
-    const promptTemplate = getPrompt('ai_voice.txt');
-    
-    // For TTS models, prepending the tone instructions to the text is more stable than systemInstruction
-    const textWithInstructions = `${promptTemplate.replace('{{tone}}', tone)}\n\nSCRIPT TO SPEAK:\n${text}`;
-
-    console.log(`[TTS] Generating content... Length: ${text?.length || 0}`);
-
-    const chunkBase64 = await tryModels(apiKey, models, async (ai, model) => {
-        const response = await ai.models.generateContent({
-            model: model,
-            contents: [{ parts: [{ text: textWithInstructions }] }],
-            config: { 
-                responseModalities: [Modality.AUDIO], 
-                safetySettings: DEFAULT_SAFETY_SETTINGS,
-                speechConfig: { 
-                    voiceConfig: { 
-                        prebuiltVoiceConfig: { 
-                            voiceName: voiceName || 'Zephyr' 
-                        } 
-                    } 
-                } 
-            }
-        });
-
-        const part = response.candidates?.[0]?.content?.parts.find(p => p.inlineData);
-        if (part?.inlineData?.data) return part.inlineData.data;
-        throw new Error("EMPTY_AUDIO_DATA_FROM_GEMINI");
-    });
-
-    return chunkBase64;
-}

services/ai/utils.js

@@ -1,73 +0,0 @@
-
-import { GoogleGenAI } from '@google/genai';
-import fs from 'fs';
-import path from 'path';
-import { fileURLToPath } from 'url';
-
-const __dirname = path.dirname(fileURLToPath(import.meta.url));
-
-export const getPrompt = (filename) => {
-    try {
-        const filePath = path.resolve(__dirname, '..', '..', 'prompts', filename);
-        if (fs.existsSync(filePath)) {
-            return fs.readFileSync(filePath, 'utf8');
-        } else {
-            const internalPath = path.resolve(__dirname, '..', '..', '..', 'prompts', filename);
-            return fs.existsSync(internalPath) ? fs.readFileSync(internalPath, 'utf8') : "";
-        }
-    } catch (e) { 
-        console.error(`[AI-ENGINE] Prompt Load Error (${filename}):`, e.message);
-        return ""; 
-    }
-};
-
-export function cleanJson(raw) {
-    if (!raw) return "";
-    return raw.replace(/```json/gi, '').replace(/```/gi, '').trim();
-}
-
-export function cleanSRTOutput(text) {
-    if (!text) return "";
-    let cleaned = text.replace(/```srt/gi, '').replace(/```/gi, '').trim();
-    const firstIndex = cleaned.search(/^\d+\s*\r?\n\d{2}:\d{2}:\d{2},\d{3}/m);
-    if (firstIndex !== -1) {
-        cleaned = cleaned.substring(firstIndex);
-    }
-    return cleaned;
-}
-
-export const DEFAULT_SAFETY_SETTINGS = [
-    { category: 'HARM_CATEGORY_HARASSMENT', threshold: 'BLOCK_ONLY_HIGH' },
-    { category: 'HARM_CATEGORY_HATE_SPEECH', threshold: 'BLOCK_ONLY_HIGH' },
-    { category: 'HARM_CATEGORY_SEXUALLY_EXPLICIT', threshold: 'BLOCK_ONLY_HIGH' },
-    { category: 'HARM_CATEGORY_DANGEROUS_CONTENT', threshold: 'BLOCK_ONLY_HIGH' },
-    { category: 'HARM_CATEGORY_CIVIC_INTEGRITY', threshold: 'BLOCK_ONLY_HIGH' }
-];
-
-export async function tryModels(apiKey, modelList, taskFn) {
-    let lastError = null;
-    const ai = new GoogleGenAI({ apiKey });
-    const MAX_RETRIES_PER_MODEL = 2;
-
-    for (const modelName of modelList) {
-        for (let attempt = 0; attempt <= MAX_RETRIES_PER_MODEL; attempt++) {
-            try {
-                return await taskFn(ai, modelName);
-            } catch (e) {
-                const rawError = (e.message || "Unknown error").toLowerCase();
-                const isRateLimit = rawError.includes('429') || rawError.includes('quota') || rawError.includes('limit');
-                
-                if (isRateLimit && attempt < MAX_RETRIES_PER_MODEL) {
-                    const waitTime = (attempt + 1) * 5000;
-                    console.warn(`[AI-ENGINE] Rate limit on ${modelName}. Retry in ${waitTime}ms...`);
-                    await new Promise(r => setTimeout(r, waitTime));
-                    continue;
-                }
-                console.error(`[AI-ENGINE] Error on ${modelName}:`, rawError);
-                lastError = e;
-                break;
-            }
-        }
-    }
-    throw lastError;
-}

services/authService.js

@@ -1,39 +0,0 @@
-import { db } from '@/backend/services/firebase';
-
-export const AuthService = {
-    async saveCustomKey(sessionId, apiKey) {
-        const snapshot = await db.ref('users').orderByChild('Active_Session_ID').equalTo(sessionId).once('value');
-        if (!snapshot.exists()) throw new Error("User not found.");
-        const userKey = Object.keys(snapshot.val())[0];
-        await db.ref(`users/${userKey}`).update({ Private_API_Key: apiKey });
-        return { success: true };
-    },
-
-    async updateActiveSession(userId, newSessionId) {
-        if (!userId) throw new Error("Membership ID is required.");
-
-        // Find user by their PERMANENT Login_Key first
-        let snapshot = await db.ref('users').orderByChild('Login_Key').equalTo(userId).once('value');
-        
-        // Fallback: If not found, try searching by Active_Session_ID (for legacy users)
-        if (!snapshot.exists()) {
-            snapshot = await db.ref('users').orderByChild('Active_Session_ID').equalTo(userId).once('value');
-        }
-
-        if (!snapshot.exists()) throw new Error("Membership ID not found in records.");
-        
-        const userKey = Object.keys(snapshot.val())[0];
-        const userData = snapshot.val()[userKey];
-        
-        const updates = { Active_Session_ID: newSessionId };
-        
-        // If this was a legacy user without a Login_Key, set it now to stabilize their account
-        if (!userData.Login_Key) {
-            updates.Login_Key = userId;
-        }
-        
-        await db.ref(`users/${userKey}`).update(updates);
-        
-        return { success: true };
-    }
-};

services/credit.js

@@ -1,123 +0,0 @@
-
-import { db } from '@/backend/services/firebase';
-
-export async function checkEligibility(sessionId, toolKey, isOwnKey) {
-    if (!sessionId) throw new Error("Authentication failed. No session ID provided.");
-
-    const now = new Date();
-    const today = now.toLocaleDateString('en-CA'); // Robust YYYY-MM-DD
-    
-    // Map toolKey to prefix-aware usage key
-    const usageKey = isOwnKey ? `own_${toolKey}` : `app_${toolKey}`;
-
-    // 1. Fetch System Tier Settings
-    const sysSnapshot = await db.ref('system/settings/tiers').once('value');
-    const tiers = sysSnapshot.val() || {};
-
-    const toolMapper = {
-        'count_transcript': 'transcript',
-        'count_translate': 'translate',
-        'count_srt_translate': 'srt_translator',
-        'count_tts': 'tts',
-        'count_subtitle': 'subtitle_gen',
-        'count_creator_text': 'content_creator',
-        'count_creator_image': 'ai_image'
-    };
-    const tierToolKey = toolMapper[toolKey] || toolKey;
-
-    let userKey, userData, userClass;
-
-    if (sessionId === 'free_access') {
-        userClass = 'FREE';
-        userData = { Usage: {}, Credits: 0, Class: 'FREE' };
-    } else {
-        const snapshot = await db.ref('users').orderByChild('Active_Session_ID').equalTo(sessionId).once('value');
-        if (!snapshot.exists()) throw new Error("Invalid Membership ID. Please login again.");
-        userKey = Object.keys(snapshot.val())[0];
-        userData = snapshot.val()[userKey];
-        if (userData.Status !== 'ACTIVE') throw new Error("Account suspended. Please contact admin.");
-        userClass = userData.Class === 'MEMBER+' ? 'MEMBER_PLUS' : 'MEMBER';
-    }
-
-    const tierConfig = tiers[userClass] || { tools: {}, ownTools: {}, limits: {}, ownLimits: {}, apiAccess: { app: true, own: true } };
-
-    // 2. CHECK API ACCESS PERMISSIONS
-    if (isOwnKey && tierConfig.apiAccess?.own === false) {
-        throw new Error(`OWN_API_RESTRICTED: Your ${userClass} class is not allowed to use private API keys.`);
-    }
-    if (!isOwnKey && tierConfig.apiAccess?.app === false) {
-        throw new Error(`APP_API_RESTRICTED: Shared App API is currently disabled for your class.`);
-    }
-
-    // 3. CHECK SPECIFIC TOOL STATUS FOR TIER (Mode Specific)
-    const toolMap = isOwnKey ? (tierConfig.ownTools || {}) : (tierConfig.tools || {});
-    if (toolMap[tierToolKey] === false) {
-        throw new Error(`TOOL_DISABLED: This tool is disabled in ${isOwnKey ? 'Own API' : 'App API'} mode for ${userClass} class.`);
-    }
-
-    const usage = (userData.Last_Usage_Date === today) ? (userData.Usage || {}) : {};
-    
-    // 4. CHECK LIMITS (Mode Specific)
-    const limit = isOwnKey ? (tierConfig.ownLimits?.[tierToolKey] ?? -1) : (tierConfig.limits?.[tierToolKey] ?? -1);
-    
-    if (limit !== -1) {
-        const currentCount = parseInt(usage[usageKey] || 0);
-        if (currentCount >= limit) {
-            throw new Error(`DAILY_QUOTA_REACHED: Your ${userClass} daily limit for ${isOwnKey ? 'Own' : 'App'} API has been reached.`);
-        }
-    }
-
-    // 5. CHECK CREDITS (Only if using App API)
-    let cost = 0;
-    if (!isOwnKey) {
-        const costMap = {
-            'count_transcript': 1, 'count_translate': 1, 'count_srt_translate': 5,
-            'count_tts': 3, 'count_subtitle': 1, 'count_creator_text': 1, 'count_creator_image': 5
-        };
-        cost = costMap[toolKey] || 1;
-        
-        if (userClass === 'MEMBER_PLUS') {
-            const freeTools = ['count_transcript', 'count_translate', 'count_subtitle', 'count_creator_text'];
-            if (freeTools.includes(toolKey)) cost = 0;
-        }
-        if (userClass === 'FREE') cost = 0;
-
-        const currentCredits = userData.Credits || 0;
-        if (cost > 0 && currentCredits < cost) {
-            throw new Error(`INSUFFICIENT_BALANCE: This task costs ${cost} credits. Your balance is ${currentCredits}.`);
-        }
-    }
-
-    return { userKey, userData, usageKey, cost, today, isGuest: (userClass === 'FREE'), isOwnKey };
-}
-
-export async function commitDeduction(eligibilityData, toolKey) {
-    if (!eligibilityData) return; 
-    const { userKey, userData, usageKey, cost, today, isGuest } = eligibilityData;
-    
-    if (isGuest) return;
-
-    const updates = {};
-    if (cost > 0) {
-        const newBalance = (userData.Credits || 0) - cost;
-        updates[`users/${userKey}/Credits`] = newBalance >= 0 ? newBalance : 0;
-    }
-
-    if (userData.Last_Usage_Date !== today) {
-        updates[`users/${userKey}/Last_Usage_Date`] = today;
-        updates[`users/${userKey}/Usage`] = { [usageKey]: 1 };
-    } else {
-        const currentUsage = (userData.Usage && userData.Usage[usageKey]) || 0;
-        updates[`users/${userKey}/Usage/${usageKey}`] = currentUsage + 1;
-    }
-
-    await db.ref().update(updates);
-}
-
-export async function processFreePool(toolKey) {
-    const today = new Date().toLocaleDateString('en-CA');
-    const poolPath = `system/daily_pool/${today}/app_${toolKey}`; // Default to app prefix for free pool
-    const snapshot = await db.ref(poolPath).once('value');
-    const current = snapshot.val() || 0;
-    await db.ref(poolPath).set(current + 1);
-}

services/creditService.js

@@ -1,153 +0,0 @@
-
-import { db } from '@/backend/services/firebase';
-
-export const CreditService = {
-    async checkEligibility(sessionId, guestId, toolKey, isOwnKey, creditCostOverride = null) {
-        if (!sessionId) throw new Error("Authentication failed.");
-
-        const now = new Date();
-        const today = now.toLocaleDateString('en-CA'); 
-        const usageKey = isOwnKey ? `own_${toolKey}` : `app_${toolKey}`;
-
-        // 1. Fetch System Tier Settings
-        const sysSnapshot = await db.ref('system/settings/tiers').once('value');
-        const tiers = sysSnapshot.val() || {};
-
-        const toolMapper = {
-            'count_transcript': 'transcript',
-            'count_translate': 'translate',
-            'count_srt_translate': 'srt_translator',
-            'count_tts': 'tts',
-            'count_subtitle': 'subtitle_gen',
-            'count_creator_text': 'content_creator',
-            'count_creator_image': 'ai_image',
-            'downloader': 'downloader',
-            'book_recap': 'book_recap'
-        };
-        const tierToolKey = toolMapper[toolKey] || toolKey;
-
-        let userKey, userData, userClass, storagePath;
-
-        if (sessionId === 'free_access') {
-            userClass = 'FREE';
-            if (!guestId || guestId === 'anonymous') {
-                // Return generic guest data for free mode
-                userData = { Usage: {}, Credits: 0, Class: 'FREE', Last_Usage_Date: today };
-                storagePath = `guests/temp_guest`;
-            } else {
-                storagePath = `guests/${guestId}/${today}`;
-                const usageSnapshot = await db.ref(storagePath).once('value');
-                const currentUsage = usageSnapshot.val() || {};
-                userData = { Usage: currentUsage, Credits: 0, Class: 'FREE', Last_Usage_Date: today };
-            }
-        } else {
-            // Find user by temporary session ID
-            const snapshot = await db.ref('users').orderByChild('Active_Session_ID').equalTo(sessionId).once('value');
-            if (!snapshot.exists()) throw new Error("Invalid Session. Please login again.");
-            
-            userKey = Object.keys(snapshot.val())[0];
-            userData = snapshot.val()[userKey];
-            if (userData.Status !== 'ACTIVE') throw new Error("Account suspended.");
-            
-            userClass = userData.Class === 'MEMBER+' ? 'MEMBER_PLUS' : (userData.Class === 'BASIC' ? 'BASIC' : 'MEMBER');
-            storagePath = `users/${userKey}`;
-        }
-
-        const tierConfig = tiers[userClass] || { apiAccess: { app: true, own: true } };
-
-        // Check if user is trying to use their own API but it's disabled for their class
-        if (isOwnKey && tierConfig.apiAccess?.own === false) throw new Error("OWN_API_RESTRICTED");
-        if (!isOwnKey && tierConfig.apiAccess?.app === false) throw new Error("APP_API_RESTRICTED");
-
-        // Check Specific Tool Toggle (Mode Specific)
-        const toolToggleMap = isOwnKey ? (tierConfig.ownTools || {}) : (tierConfig.tools || {});
-        if (toolToggleMap[tierToolKey] === false) throw new Error("TOOL_DISABLED");
-
-const usage = (userData.Last_Usage_Date === today) ? (userData.Usage || {}) : {};
-        
-        // 1. Declare the limit variable based on the tier settings
-        let limit = isOwnKey 
-            ? (tierConfig.ownLimits?.[tierToolKey] ?? -1) 
-            : (tierConfig.limits?.[tierToolKey] ?? -1);
-        
-        // 2. Override: If using Own API Key, force the limit to -1 (Unlimited)
-        if (isOwnKey) {
-            limit = -1; 
-        }
-        
-        // 3. Perform the check only if a limit exists
-        if (limit !== -1) {
-            const currentCount = parseInt(usage[usageKey] || 0);
-            if (currentCount >= limit) {
-                throw new Error("DAILY_LIMIT_REACHED");
-            }
-        }
-
-        if (isOwnKey) {
-            limit = -1; // -1 means "No Limit" or "Unlimited" in your logic (LOL kyaw Gyi)
-        }        
-        
-        // Check Daily Frequency Limit (Mode Specific)
- //       let limit = isOwnKey ? (tierConfig.ownLimits?.[tierToolKey] ?? -1) : (tierConfig.limits?.[tierToolKey] ?? -1);
-        
-        
-        if (limit !== -1) {
-            const currentCount = parseInt(usage[usageKey] || 0);
-            if (currentCount >= limit) throw new Error("DAILY_LIMIT_REACHED");
-        }
-
-        let cost = 0;
-        if (userClass !== 'FREE' && !isOwnKey) {
-            const costMap = {
-                'count_transcript': 4, 
-                'count_translate': 4, 
-                'count_srt_translate': 7,
-                'count_tts': 3, 
-                'count_subtitle': 2, 
-                'count_creator_text': 3, 
-                'count_creator_image': 5,
-                'downloader': 2,
-                'book_recap': 8
-            };
-            
-            cost = (creditCostOverride !== null) ? creditCostOverride : (costMap[toolKey] || 1);
-
-            if (cost > 0 && (userData.Credits || 0) < cost) {
-                throw new Error(`INSUFFICIENT_BALANCE: Needs ${cost} credits.`);
-            }
-        }
-
-        return { userKey, storagePath, userData, usageKey, cost, today, isGuest: (userClass === 'FREE'), isOwnKey };
-    },
-
-    async commitDeduction(eligibilityData) {
-        if (!eligibilityData) return;
-        const { storagePath, userData, usageKey, cost, today, isGuest, isOwnKey } = eligibilityData;
-        
-        // Own API mode records usage but never deducts credits
-        const finalCost = isOwnKey ? 0 : cost;
-
-        const updates = {};
-        if (isGuest) {
-            if (storagePath === 'guests/temp_guest') return;
-            const currentUsage = (userData.Usage?.[usageKey]) || 0;
-            updates[`${storagePath}/${usageKey}`] = currentUsage + 1;
-            await db.ref().update(updates);
-            return;
-        }
-
-        if (finalCost > 0) {
-            const newBalance = (userData.Credits || 0) - finalCost;
-            updates[`${storagePath}/Credits`] = Math.max(0, newBalance);
-        }
-
-        if (userData.Last_Usage_Date !== today) {
-            updates[`${storagePath}/Last_Usage_Date`] = today;
-            updates[`${storagePath}/Usage`] = { [usageKey]: 1 };
-        } else {
-            const currentUsage = (userData.Usage?.[usageKey]) || 0;
-            updates[`${storagePath}/Usage/${usageKey}`] = currentUsage + 1;
-        }
-        await db.ref().update(updates);
-    }
-};

services/firebase.js

@@ -1,36 +0,0 @@
-
-import admin from 'firebase-admin';
-import fs from 'fs';
-import path from 'path';
-
-// Service Account file path - MUST be from transcript-master project
-const serviceAccountPath = path.resolve(process.cwd(), 'service-account.json');
-
-try {
-    if (!admin.apps.length) {
-        // Explicitly using transcript-master project details
-        const config = {
-            databaseURL: "https://klingwatermark-default-rtdb.asia-southeast1.firebasedatabase.app",
-            projectId: "klingwatermark"
-        };
-
-        if (fs.existsSync(serviceAccountPath)) {
-            const serviceAccount = JSON.parse(fs.readFileSync(serviceAccountPath, 'utf8'));
-            // Safety check: ensure the file matches the database project
-            if (serviceAccount.project_id !== "transcript-master") {
-                console.error(`❌ CRITICAL: service-account.json is for project "${serviceAccount.project_id}", but database is "transcript-master". Please download the correct key.`);
-            }
-            config.credential = admin.credential.cert(serviceAccount);
-            console.log("✅ Firebase Admin: Using service-account.json for transcript-master");
-        } else {
-            console.warn("ℹ️ Firebase Admin: service-account.json NOT FOUND. DB access will fail.");
-        }
-
-        admin.initializeApp(config);
-        console.log("🚀 Firebase Admin Service Initialized for transcript-master");
-    }
-} catch (error) {
-    console.error("❌ Firebase Init Error:", error.message);
-}
-
-export const db = admin.database();