/* * ThunderAI [https://micz.it/thunderbird-addon-thunderai/] * Copyright (C) 2024 Mic (m@micz.it) * This program is free software: you can redistribute it and/or modify * it under the terms of the GNU General Public License as published by * the Free Software Foundation, either version 3 of the License, or * (at your option) any later version. * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU General Public License for more details. * You should have received a copy of the GNU General Public License * along with this program. If not, see . */ // Some original methods are derived from https://github.com/ali-raheem/Aify/blob/cfadf52f576b7be3720b5b73af7c8d3129c054da/plugin/html/actions.js import { getPrompts } from './mzta-prompts.js'; import { getLanguageDisplayName, getMenuContextCompose, getMenuContextDisplay, i18nConditionalGet, getMailSubject, getTagsList, transformTagsLabels } from './mzta-utils.js' import { taLogger } from './mzta-logger.js'; import { placeholdersUtils } from './mzta-placeholders.js'; import { mzta_specialCommand_AddTags } from './special_commands/mzta-add-tags.js'; export class mzta_Menus { allPrompts = []; openChatGPT = null; menu_context_compose = null; menu_context_display = null; menu_listeners = {}; logger = null; rootMenu = [ //{ id: 'ItemC', act: (info, tab) => { console.log('ItemC', info, tab, info.menuItemId); alert('ItemC') } }, ]; shortcutMenu = [ //{ id: 'ItemD', label: 'LabelD' }, ]; constructor(openChatGPT, do_debug = false) { this.menu_context_compose = getMenuContextCompose(); this.menu_context_display = getMenuContextDisplay(); this.openChatGPT = openChatGPT; this.allPrompts = []; this.listener = this.listener.bind(this); this.logger = new taLogger('mzta_Menus', do_debug); } async initialize(also_special = false) { this.allPrompts = []; this.rootMenu = []; this.shortcutMenu = []; this.menu_listeners = {}; this.allPrompts = await getPrompts(true,also_special); this.allPrompts.sort((a, b) => a.name.localeCompare(b.name)); this.allPrompts.forEach((prompt) => { this.addAction(prompt) }); } async reload(also_special = false) { await browser.menus.removeAll().catch(error => { console.error("[ThunderAI] ERROR removing the menus: ", error); }); this.removeClickListener(); this.loadMenus(also_special); } addAction = (curr_prompt) => { let curr_menu_entry = {id: curr_prompt.id, is_default: curr_prompt.is_default, name: curr_prompt.name}; let curr_message = null; const getMailBody = async (tabs) => { //const tabs = await browser.tabs.query({ active: true, currentWindow: true }); return {tabId: tabs[0].id, selection: await browser.tabs.sendMessage(tabs[0].id, { command: "getSelectedText" }), text: await browser.tabs.sendMessage(tabs[0].id, { command: "getTextOnly" }), html: await browser.tabs.sendMessage(tabs[0].id, { command: "getFullHtml" }), }; }; curr_menu_entry.act = async () => { const tabs = await browser.tabs.query({ active: true, currentWindow: true }); const msg_text = await getMailBody(tabs); //check if a selection is needed if(String(curr_prompt.need_selected) == "1" && (msg_text.selection==='')){ //A selection is needed, but nothing is selected! //alert(browser.i18n.getMessage('prompt_selection_needed')); browser.tabs.sendMessage(tabs[0].id, { command: "sendAlert", curr_tab_type: tabs[0].type, message : browser.i18n.getMessage('prompt_selection_needed') }); return {ok:'0'}; } let body_text = ''; let selection_text = ''; selection_text = msg_text.selection.replace(/\s+/g, ' ').trim(); body_text = msg_text.text.replace(/\s+/g, ' ').trim(); //open chatgpt window //console.log("Click menu item..."); let chatgpt_lang = ''; if(String(curr_prompt.define_response_lang) == "1"){ let prefs = await browser.storage.sync.get({default_chatgpt_lang: ''}); chatgpt_lang = prefs.default_chatgpt_lang; //console.log(" >>>>>>>>>>>> chatgpt_lang: " + chatgpt_lang); if(chatgpt_lang === ''){ chatgpt_lang = browser.i18n.getMessage("reply_same_lang"); }else{ chatgpt_lang = browser.i18n.getMessage("prompt_lang") + " " + chatgpt_lang + "."; } } let fullPrompt = ''; let full_tags_list = await getTagsList(); if(!placeholdersUtils.hasPlaceholder(curr_prompt.text)){ // no placeholders, do as usual fullPrompt = curr_prompt.text + (String(curr_prompt.need_signature) == "1" ? " " + await this.getDefaultSignature():"") + " " + chatgpt_lang + " \"" + (selection_text=='' ? body_text : selection_text) + "\" "; }else{ // we have at least a placeholder, do the magic! let currPHs = await placeholdersUtils.extractPlaceholders(curr_prompt.text); // console.log(">>>>>>>>>> currPHs: " + JSON.stringify(currPHs)); let finalSubs = {}; let curr_messages = null; switch(tabs[0].type){ case 'mail': curr_messages = await browser.mailTabs.getSelectedMessages(); curr_message = curr_messages.messages[0]; break; case 'messageDisplay': curr_messages = await messenger.messageDisplay.getDisplayedMessage(tabs[0].id); curr_message = curr_messages; break; case 'messageCompose': curr_messages = await browser.compose.getComposeDetails(tabs[0].id); curr_message = curr_messages; break; } for(let currPH of currPHs){ switch(currPH.id){ case 'mail_text_body': finalSubs['mail_text_body'] = body_text; break; case 'mail_html_body': finalSubs['mail_html_body'] = msg_text.html; break; case 'mail_subject': let mail_subject = await getMailSubject(tabs[0]); finalSubs['mail_subject'] = mail_subject; break; case 'selected_text': finalSubs['selected_text'] = selection_text; break; case 'author': finalSubs['author'] = curr_message.author; break; case 'recipients': finalSubs['recipients'] = curr_message.recipients.join(", "); break; case 'cc_list': finalSubs['cc_list'] = curr_message.ccList.join(", "); break; case 'junk_score': finalSubs['junk_score'] = curr_message.junkScore; break; case 'mail_tags': let mail_tags_array = await transformTagsLabels(curr_message.tags, full_tags_list[1]); finalSubs['mail_tags'] = mail_tags_array.join(", "); break; case 'full_tags_list': finalSubs['full_tags_list'] = full_tags_list[0]; break; default: // TODO Manage custom placeholders https://github.com/micz/ThunderAI/issues/156 break; } } // console.log(">>>>>>>>>> finalSubs: " + JSON.stringify(finalSubs)); let prefs_ph = await browser.storage.sync.get({placeholders_use_default_value: false}); fullPrompt = placeholdersUtils.replacePlaceholders(curr_prompt.text, finalSubs, prefs_ph.placeholders_use_default_value, true) + (String(curr_prompt.need_signature) == "1" ? " " + await this.getDefaultSignature():"") + " " + chatgpt_lang; } switch(curr_prompt.id){ case 'prompt_translate_this': let prefs2 = await browser.storage.sync.get({default_chatgpt_lang: getLanguageDisplayName(browser.i18n.getUILanguage())}); let chatgpt_lang2 = prefs2.default_chatgpt_lang; if(chatgpt_lang2 === ''){ chatgpt_lang2 = getLanguageDisplayName(browser.i18n.getUILanguage()); } fullPrompt = curr_prompt.text + " " + chatgpt_lang2 + ". \"" + body_text + "\" "; break; case 'prompt_reply': fullPrompt += browser.i18n.getMessage("prompt_reply_additional_text"); break; default: break; } // const tabs = await browser.tabs.query({ active: true, currentWindow: true }); // add custom text if needed //browser.runtime.sendMessage({command: "chatgpt_open", prompt: fullPrompt, action: curr_prompt.action, tabId: tabs[0].id}); if(curr_prompt.is_special == '1'){ // Special prompts switch(curr_prompt.id){ case 'prompt_add_tags': // Add tags to the email let mail_tags = ''; let prefs_at = await browser.storage.sync.get({add_tags_maxnum: 3, connection_type: ''}); if((prefs_at.connection_type === '')||(prefs_at.connection_type === null)||(prefs_at.connection_type === undefined)||(prefs_at.connection_type === 'chatgpt_web')){ console.error("[ThunderAI | AddTags] Invalid connection type: " + prefs_at.connection_type); return {ok:'0'}; } let add_tags_maxnum = prefs_at.add_tags_maxnum; if(add_tags_maxnum > 0){ fullPrompt += " " + browser.i18n.getMessage("prompt_add_tags_maxnum") + " " + add_tags_maxnum +"."; } this.logger.log("fullPrompt: " + fullPrompt); // TODO: use the current API, abort if using chatgpt web // COMMENTED TO DO TESTS mail_tags = "recipients, test, home, work, car, light"; // let cmd_addTags = new mzta_specialCommand_AddTags(fullPrompt,prefs_at.connection_type,true); // await cmd_addTags.initWorker(); // try{ // mail_tags = await cmd_addTags.sendPrompt(); // // console.log(">>>>>>>>>>> mail_tags: " + mail_tags); // }catch(err){ // console.error("[ThunderAI] Error getting tags: ", err); // browser.tabs.sendMessage(tabs[0].id, { command: "sendAlert", curr_tab_type: tabs[0].type, message: "Error getting tags: " + err }); // return {ok:'0'}; // } this.logger.log("mail_tags: " + mail_tags); console.log(">>>>>>>>>>>> full_tags_list: " + JSON.stringify(full_tags_list)); browser.tabs.sendMessage(tabs[0].id, {command: "getTags", tags: mail_tags, messageId: curr_message.id}); return {ok:'1'}; break; default: console.error("[ThunderAI] Unknown special prompt id: " + curr_prompt.id); break; } }else{ // Classic prompts for the API webchat this.openChatGPT(fullPrompt, curr_prompt.action, tabs[0].id, curr_prompt.name, curr_prompt.need_custom_text); return {ok:'1'}; } }; this.rootMenu.push(curr_menu_entry); }; async getDefaultSignature(){ let prefs = await browser.storage.sync.get({default_sign_name: ''}); if(prefs.default_sign_name===''){ return ''; }else{ return browser.i18n.getMessage("sign_msg_as") + " " + prefs.default_sign_name + "."; } } loadShortcutMenu() { this.shortcutMenu = []; this.allPrompts.forEach((prompt) => { this.addShortcutMenu(prompt); }); } addShortcutMenu(prompt) { let curr_menu_entry = {id: prompt.id, label: i18nConditionalGet(prompt.name), type: prompt.type}; this.shortcutMenu.push(curr_menu_entry); } async loadMenus(also_special = false) { await this.initialize(also_special); await this.addMenu(this.rootMenu); this.addClickListener(); this.loadShortcutMenu(); this.logger.log("Menus loaded"); } listener(info, tab) { let listeners = this.menu_listeners; if (listeners[info.menuItemId]) { listeners[info.menuItemId](info, tab); } } addClickListener() { browser.menus.onClicked.addListener(this.listener); } removeClickListener() { browser.menus.onClicked.removeListener(this.listener); } addMenu = async (menu, root = null) => { for (let item of menu) { let {id, is_default, name, menu, act} = item; this.logger.log("addMenu: " + id); await new Promise(resolve => browser.menus.create({ id: id, title: this.getCustomTextAttribute(id) + is_default == 1 ? (browser.i18n.getMessage(id) || name) : name, contexts: this.getContexts(id), parentId: root }, resolve ) ); if (act) { this.menu_listeners[id] = act; } if (menu) { await this.addMenu(menu, id); } } }; getContexts(id){ //console.log(">>>>>>>>> id: " + id); const curr_prompt = this.allPrompts.find(p => p.id === id); //console.log(">>>>>>>>>> curr_prompt: " + JSON.stringify(curr_prompt)); if (!curr_prompt) { return []; } switch(String(curr_prompt.type)){ case "0": return [this.menu_context_compose, this.menu_context_display]; case "1": return [this.menu_context_display]; case "2": return [this.menu_context_compose]; default: return []; } } getCustomTextAttribute(id){ const curr_prompt = this.allPrompts.find(p => p.id === id); if (!curr_prompt) { return ""; } if(String(curr_prompt.need_custom_text) === "1"){ return "*"; }else{ return ""; } } async executeMenuAction(id) { // Retrieve the action callback from the menu listeners using the provided ID const action = this.menu_listeners[id]; if (action) { try { // Execute the action callback return await action(); } catch (error) { // Log any errors that occur during execution console.error(`Error executing action for menu item ${id}:`, error); } } else { // Warn if no action is found for the provided ID console.warn(`No action found for menu item ID: ${id}`); } return false; } }