lint

Author: grypez

packages/nodejs/scripts/call-ollama.js

@@ -2,8 +2,9 @@ import { readFile } from 'fs/promises';
 import ollama from 'ollama';
 
 /**
+ * Streams the response from Ollama to the console.
  *
- * @param response
+ * @param {*} response - The response from Ollama.
  */
 async function streamResponse(response) {
   const thinkEndToken = '</think>';

packages/nodejs/src/demo/console/run.ts

@@ -4,22 +4,22 @@ import { Kernel } from '@ocap/kernel';
 import type { ClusterConfig } from '@ocap/kernel';
 import { MessageChannel as NodeMessageChannel } from 'node:worker_threads';
 
-import { makeKernel } from '../../kernel/make-kernel.js';
-import { makeSubclusterConfig } from './subclusterConfig.js';
+import { makeSubclusterConfig } from './subclusterConfig.ts';
+import { makeKernel } from '../../kernel/make-kernel.ts';
 
 const args = {
   verbose: process.argv.includes('--verbose'),
-}
+};
 
 main(args).catch(console.error);
 
 /**
  * The main function for the demo.
  *
- * @param options0
- * @param options0.verbose
+ * @param options0 - The options for the demo.
+ * @param options0.verbose - Whether to run the demo in verbose mode.
  */
-async function main({ verbose }: { verbose: boolean }) {
+async function main({ verbose }: { verbose: boolean }): Promise<void> {
   // This port does nothing; we don't talk to the Kernel via a console (yet).
   const kernelPort = new NodeMessageChannel().port1;
 

packages/nodejs/src/demo/console/subclusterConfig.ts

@@ -1,6 +1,7 @@
 import type { ClusterConfig } from '@ocap/kernel';
 
-const makeBundleSpec = (name: string) => `http://localhost:3000/${name}.bundle`;
+const makeBundleSpec = (name: string): string =>
+  `http://localhost:3000/${name}.bundle`;
 
 export const makeSubclusterConfig = (verbose: boolean): ClusterConfig => ({
   bootstrap: 'boot',

packages/nodejs/src/demo/console/vats/asyncGenerator.js

@@ -1,4 +1,5 @@
 import { Far } from '@endo/marshal';
+
 import { makeLogger } from '../../../../dist/demo/logger.mjs';
 import { makeStreamMaker } from '../../../../dist/demo/stream.mjs';
 
@@ -25,7 +26,7 @@ export function buildRootObject(vatPowers, parameters, _baggage) {
   const makeCounter = (start = 0, ms = 100) => {
     const { id, writer } = makeStream();
     let count = start;
-  
+
     const interval = setInterval(async () => {
       const thisCount = count;
       count += 1;
@@ -40,15 +41,15 @@ export function buildRootObject(vatPowers, parameters, _baggage) {
 
     counters.set(id, harden({ stop }));
     return id;
-  }
+  };
 
   const getCounter = (id) => {
     const counter = counters.get(id);
     if (!counter) {
       throw new Error(`No such counterId ${id}`, { cause: id });
     }
     return counter;
-  }
+  };
 
   return Far('root', {
     async ping() {

packages/nodejs/src/demo/console/vats/boot.js

@@ -50,7 +50,7 @@ export function buildRootObject(_vatPowers, parameters, _baggage) {
           }
           display(count);
         }
-      }
+      };
 
       await Promise.all([
         readCounter(counterReader0, 10, counter0),

packages/nodejs/src/demo/rag/documents/root.ts

@@ -1,5 +1,5 @@
-import { resolve } from "path";
+import { resolve } from 'path';
 
 export const documentRoot = resolve(
-  new URL('content', import.meta.url).pathname
+  new URL('content', import.meta.url).pathname,
 ).replace(/\/dist\//u, '/src/');

packages/nodejs/src/demo/rag/run.ts

@@ -4,23 +4,23 @@ import { Kernel } from '@ocap/kernel';
 import type { ClusterConfig } from '@ocap/kernel';
 import { MessageChannel as NodeMessageChannel } from 'node:worker_threads';
 
-import { makeKernel } from '../../kernel/make-kernel.js';
-import { makeSubclusterConfig } from './subclusterConfig.js';
-import { documentRoot } from './documents/root.js';
+import { documentRoot } from './documents/root.ts';
+import { makeSubclusterConfig } from './subclusterConfig.ts';
+import { makeKernel } from '../../kernel/make-kernel.ts';
 
 const args = {
   verbose: process.argv.includes('--verbose'),
-}
+};
 
 main(args).catch(console.error);
 
 /**
  * The main function for the demo.
  *
- * @param options0
- * @param options0.verbose
+ * @param options0 - The options for the demo.
+ * @param options0.verbose - Whether to run the demo in verbose mode.
  */
-async function main({ verbose }: { verbose: boolean }) {
+async function main({ verbose }: { verbose: boolean }): Promise<void> {
   // This port does nothing; we don't talk to the Kernel via a console (yet).
   const kernelPort = new NodeMessageChannel().port1;
 
@@ -29,7 +29,7 @@ async function main({ verbose }: { verbose: boolean }) {
     port: kernelPort,
     vatWorkerServiceOptions: {
       makeDocumentRoot: async () => documentRoot,
-    }
+    },
   });
   const config: ClusterConfig = makeSubclusterConfig(verbose);
   await kernel.launchSubcluster(config);

packages/nodejs/src/demo/rag/subclusterConfig.ts

@@ -3,7 +3,8 @@ import type { ClusterConfig, VatConfig } from '@ocap/kernel';
 type ModelSize = '1.5b' | '7b' | '8b' | '14b' | '32b' | '70b' | '671b';
 type Model = `deepseek-r1:${ModelSize}${string}`;
 
-const makeBundleSpec = (name: string) => `http://localhost:3000/${name}.bundle`;
+const makeBundleSpec = (name: string): string =>
+  `http://localhost:3000/${name}.bundle`;
 
 type UserConfig = {
   model: Model;
@@ -107,4 +108,4 @@ export const makeSubclusterConfig = (verbose: boolean): ClusterConfig => {
       ...eveConfig,
     },
   };
-}
+};

packages/nodejs/src/demo/rag/user.ts

@@ -12,10 +12,7 @@ export const makeInitUser = (
     logger.debug('initUser:user', user);
     const languageModel = vats[`${user}.llm`];
     const vectorStore = vats[`${user}.vectorStore`];
-    await Promise.all([
-      E(languageModel).init(),
-      E(vectorStore).init(),
-    ]);
+    await Promise.all([E(languageModel).init(), E(vectorStore).init()]);
     const defaultDocumentView = await E(vectorStore).makeDocumentView();
     const response = await E(vats[user]).init(
       languageModel,

packages/nodejs/src/demo/rag/vats/boot.js

@@ -33,9 +33,14 @@ export function buildRootObject(_vatPowers, parameters, _baggage) {
 
     console.time('bootstrap');
     const initUser = makeInitUser(vats, logger);
-    await Promise.all(users.map(
-      (user) => initUser(user, users.filter(peer => peer !== user)),
-    ));
+    await Promise.all(
+      users.map((user) =>
+        initUser(
+          user,
+          users.filter((peer) => peer !== user),
+        ),
+      ),
+    );
     console.timeEnd('bootstrap');
 
     display('Initialized');