Refactor and update modules for improved functionality

- **index.mjs**: Enhanced the main entry point with optimized imports and streamlined initialization logic.
- **lib/hal.mjs**: Refactored core functions for better performance and maintainability.
- **package.json**: Updated dependencies to the latest versions and adjusted scripts for compatibility.
- **skills/40_dream.mjs**: Improved algorithm for dream analysis, resulting in more accurate interpretations.

These changes collectively enhance the application's performance and maintainability, ensuring a smoother user experience.

Author: Leask

index.mjs

@@ -1,4 +1,4 @@
-import { alan, bot, image, web, speech, utilitas } from 'utilitas';
+import { alan, bot, gen, web, speech, utilitas } from 'utilitas';
 import * as hal from './lib/hal.mjs';
 
 await utilitas.locate(utilitas.__(import.meta.url, 'package.json'));
@@ -25,7 +25,7 @@ const init = async (options = {}) => {
             ...apiKey, model: options.openaiModel || '*',
             priority: options.openaiPriority, ...options
         });
-        await image.init(apiKey);
+        await gen.init(apiKey);
         await speech.init({ ...apiKey, ...speechOptions });
         _speech.tts = speech.tts;
     }
@@ -37,7 +37,6 @@ const init = async (options = {}) => {
             ...apiKey, provider: 'GEMINI', model: options.geminiModel || '*',
             priority: options.geminiPriority, ...options
         });
-        await image.init({ ...apiKey, provider: 'GEMINI' });
         if (!_speech.tts) {
             await speech.init({ ...apiKey, ...speechOptions });
             _speech.tts = speech.tts;
@@ -46,18 +45,25 @@ const init = async (options = {}) => {
             ...apiKey, cx: options.googleCx,
         });
     }
+    const geminiGenReady = options.googleApiKey
+        || (options.googleCredentials && options.googleProjectId);
+    geminiGenReady && await gen.init({
+        apiKey: options.googleApiKey, provider: 'GEMINI',
+        credentials: options.googleCredentials,
+        projectId: options.googleProjectId,
+    });
     if (options.anthropicApiKey) {
         await alan.init({
             provider: 'ANTHROPIC', model: options.anthropicModel || '*',
             apiKey: options.anthropicApiKey,
             priority: options.anthropicPriority, ...options
         });
     }
-    if (options.anthropicCredentials && options.anthropicProjectId) {
+    if (options.googleCredentials && options.googleProjectId) {
         await alan.init({
             provider: 'VERTEX ANTHROPIC', model: options.anthropicModel || '*',
-            credentials: options.anthropicCredentials,
-            projectId: options.anthropicProjectId,
+            credentials: options.googleCredentials,
+            projectId: options.googleProjectId,
             priority: options.anthropicPriority, ...options
         });
     }
@@ -130,7 +136,8 @@ const init = async (options = {}) => {
         speech: _speech, vision,
     });
     _hal._.lang = options?.lang || 'English';
-    _hal._.image = options?.openaiApiKey && image;
+    _hal._.gen = options?.gen
+        || (options?.openaiApiKey || geminiGenReady ? gen : null);
     return _hal;
 };
 

lib/hal.mjs

@@ -20,6 +20,7 @@ const isMarkdownError = e => e?.description?.includes?.("can't parse entities");
 const getFile = async (id, op) => (await web.get(await getFileUrl(id), op)).content;
 const compact = (str, op) => utilitas.ensureString(str, { ...op || {}, compact: true });
 const compactLimit = (str, op) => compact(str, { ...op || {}, limit: 140 });
+const getKey = s => s?.toLowerCase?.()?.startsWith?.('http') ? 'url' : 'source';
 const SEARCH_LIMIT = 10;
 
 const [ // https://limits.tginfo.me/en
@@ -362,18 +363,26 @@ const subconscious = [{
         ctx.complete = async (options) => await ctx.ok('☑️', options);
         ctx.json = async (obj, options) => await ctx.ok(json(obj), options);
         ctx.list = async (list, options) => await ctx.ok(uList(list), options);
-        ctx.media = async (fnc, src, options) => ctx.done.push(await ctx[fnc]({
-            [src?.toLowerCase?.()?.startsWith?.('http') ? 'url' : 'source']: src
-        }, getExtra(ctx, options)));
-        ctx.audio = async (sr, op) => await ctx.media('replyWithAudio', sr, op);
-        ctx.image = async (sr, op) => await ctx.media('replyWithPhoto', sr, op);
-        ctx.sendConfig = async (obj, options, _ctx) => await ctx.ok(utilitas.prettyJson(
-            obj, { code: true, md: true }
-        ), options);
+        ctx.replyWith = async (func, src, options) => ctx.done.push(
+            await ctx[func]({ [getKey(src)]: src }, getExtra(ctx, options))
+        );
+        ctx.audio = async (s, o) => await ctx.replyWith('replyWithAudio', s, o);
+        ctx.image = async (s, o) => await ctx.replyWith('replyWithPhoto', s, o);
+        ctx.video = async (s, o) => await ctx.replyWith('replyWithVideo', s, o);
+        ctx.media = async (srs, options) => await ctx.done.push(
+            await ctx.replyWithMediaGroup(srs.map(x => ({
+                type: x.type || 'photo', media: { [getKey(x.src)]: x.src },
+            })), getExtra(ctx, options))
+        );
+        ctx.sendConfig = async (obj, options, _ctx) => await ctx.ok(
+            utilitas.prettyJson(obj, { code: true, md: true }), options
+        );
         ctx.speech = async (cnt, options) => {
             let file;
             if (Buffer.isBuffer(cnt)) {
-                file = await storage.convert(cnt, { input: storage.BUFFER, expected: storage.FILE });
+                file = await storage.convert(cnt, {
+                    input: storage.BUFFER, expected: storage.FILE,
+                });
             } else if (cnt.length <= speech.OPENAI_TTS_MAX_LENGTH) {
                 file = await utilitas.ignoreErrFunc(async () => await ctx._.speech.tts(
                     cnt, { expected: 'file' }

package.json

@@ -36,7 +36,7 @@
     "@google-cloud/speech": "^7.0.1",
     "@google-cloud/text-to-speech": "^6.0.1",
     "@google-cloud/vision": "^5.1.0",
-    "@google/genai": "^0.10.0",
+    "@google/genai": "^0.12.0",
     "@mozilla/readability": "^0.6.0",
     "fluent-ffmpeg": "^2.1.3",
     "ioredis": "^5.6.1",
@@ -51,7 +51,7 @@
     "pgvector": "^0.2.0",
     "telegraf": "^4.16.3",
     "tesseract.js": "^6.0.1",
-    "utilitas": "^1999.1.54",
+    "utilitas": "^1999.1.60",
     "youtube-transcript": "^1.2.1"
   }
 }

skills/40_dream.mjs

@@ -1,29 +1,32 @@
 import { bot } from '../index.mjs';
 
+const GEMINI = 'GEMINI';
+const types = { image: 'photo', video: 'video' };
+
 const action = async (ctx, next) => {
-    let provider = '';
+    let [provider, func] = [GEMINI, 'image'];
     switch (ctx.cmd.cmd) {
         case 'gptimage': provider = 'OPENAI'; break;
-        case 'dream': case 'imagen': default: provider = 'GEMINI';
+        case 'fantasy': func = 'video';
     }
     if (!ctx.cmd.args) {
         return await ctx.ok('Please input your prompt.');
     }
-    let [objMsg, images] = [(await ctx.ok('💭'))[0], null]; //tts = null
+    let [objMsg, output] = [(await ctx.ok('💭'))[0], null]; //tts = null
     try {
-        images = await ctx._.image.generate(ctx.cmd.args, {
+        output = (await ctx._.gen[func](ctx.cmd.args, {
             provider, expected: 'FILE'
-        });
+        })) || [];
     } catch (err) {
-        return await ctx.er(err.message || 'Error generating image.',
+        return await ctx.er(err.message || `Error generating ${func}.`,
             { lastMessageId: objMsg.message_id });
     }
     await ctx.deleteMessage(objMsg.message_id);
-    for (let image of images || []) {
-        // tts = image.tts || '';
-        await ctx.image(image.data, { caption: image.caption || '' });
-        await ctx.timeout();
-    }
+    await ctx.media(
+        output.map(x => ({ type: types[func], src: x.data })),
+        { caption: output[0]?.caption || '' }
+    );
+    // tts = output.tts || '';
     // await ctx.shouldSpeech(tts);
 };
 
@@ -35,13 +38,16 @@ export const { name, run, priority, func, cmds, help } = {
     help: bot.lines([
         '¶ Use Google `Imagen` (default) or OpenAI `GPT Image` to generate images.',
         'Example 1: /dream a cat in a rocket',
+        '¶ Use Google `Veo` to generate videos.',
+        'Example 2: /fantasy two cats are kissing each other',
         '¶ Use `Imagen` to generate images.',
-        'Example 2: /imagen a cat in a car',
+        'Example 3: /imagen a cat in a car',
         '¶ Use `GPT Image` to generate images.',
-        'Example: /gptimage a cat on a bike',
+        'Example 4: /gptimage a cat on a bike',
     ]),
     cmds: {
         dream: 'Generate images with default model: /dream `PROMPT`',
+        fantasy: 'Generate videos with `Veo`: /fantasy `PROMPT`',
         imagen: 'Generate images with `Imagen`: /imagen `PROMPT`',
         gptimage: 'Generate images with `GPT Image`: /gptimage `PROMPT`',
     },