Wire the prompt across from UI to worker to LLM.

package.json

@@ -1,6 +1,6 @@
 {
   "name": "localm",
-  "version": "1.0.9",
+  "version": "1.1.0",
   "description": "",
   "main": "chat-full.js",
   "scripts": {

src/app/boot-app.js

@@ -26,7 +26,7 @@ export async function bootApp() {
   const { chatLogEditor: chatLogEditorInstance, chatInputEditor: chatInputEditorInstance } = await initMilkdown({
     chatLog,
     chatInput,
-    inputPlugins: makeEnterPlugins()
+    inputPlugins: makeEnterPlugins({ workerConnection: worker })
   });
   chatLogEditor = chatLogEditorInstance;
   chatInputEditor = chatInputEditorInstance;

src/app/enter-key.js

@@ -10,7 +10,7 @@ import { $command, $useKeymap } from '@milkdown/utils';
 
 import { handlePrompt } from './handle-prompt';
 
-export function makeEnterPlugins() {
+export function makeEnterPlugins({ workerConnection }) {
   // Create a command that sends the current input content to the chat log
   const myEnterCommand = $command('MyEnterCommand', (ctx) => {
     return () => (state, dispatch) => {
@@ -20,7 +20,7 @@ export function makeEnterPlugins() {
       const markdown = (toMarkdown(view.state.doc) || '').trim();
 
       if (markdown) {
-        handlePrompt(markdown);
+        handlePrompt({ promptMarkdown: markdown, workerConnection });
       }
 
       // Clear input

src/app/handle-prompt.js

@@ -2,14 +2,21 @@
 
 import { outputMessage } from './output-message';
 
-export async function handlePrompt(promptMarkdown) {
-  const formatted = `user typed:\n> ${promptMarkdown.replaceAll('\n', '\n> ')}`;
+/**
+ * @param {{
+ *  promptMarkdown: string,
+ *  workerConnection: ReturnType<import('./worker-connection').workerConnection>
+ * }} _
+ */
+export async function handlePrompt({ promptMarkdown, workerConnection }) {
+  const formatted = `**Question:**\n> ${promptMarkdown.replaceAll('\n', '\n> ')}`;
   outputMessage(formatted);
 
-  await new Promise(resolve => setTimeout(resolve, 100));
-
   outputMessage('Processing your request...');
-
-  await new Promise(resolve => setTimeout(resolve, 1000));
-  outputMessage(`This is a simulated response to your prompt [${promptMarkdown.length}].`);
+  try {
+    const promptOutput = await workerConnection.runPrompt(promptMarkdown);
+    outputMessage('**Reply:**\n' + promptOutput);
+  } catch (error) {
+    outputMessage('**Error:** ' + error.message);
+  }
 }

src/app/worker-connection.js

@@ -84,7 +84,7 @@ export function workerConnection() {
    */
   async function runPrompt(promptText, modelName) {
     await workerLoaded;
-  const { send } = await workerLoaded;
-  return send({ type: 'runPrompt', prompt: promptText, modelName });
+    const { send } = await workerLoaded;
+    return send({ type: 'runPrompt', prompt: promptText, modelName });
   }
 }