2.0.2

nvms · nvms · commit 6971dd1d6ec8 · 2026-03-17T09:25:40.000-04:00
diff --git a/threads/package.json b/threads/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@threaded/ai",
-  "version": "2.0.1",
+  "version": "2.0.2",
   "description": "Composable LLM inference with multi-provider support, tool execution, streaming, and approval workflows",
   "type": "module",
   "main": "dist/index.js",
diff --git a/threads/src/approval.ts b/threads/src/approval.ts
@@ -1,5 +1,5 @@
 import { EventEmitter } from "events";
-import { ToolCall } from "./types";
+import { ToolCall } from "./types.js";
 
 export interface ApprovalRequest {
   id: string;
diff --git a/threads/src/composition/compose.ts b/threads/src/composition/compose.ts
@@ -1,4 +1,4 @@
-import { ComposedFunction, ConversationContext, StepFunction } from "../types";
+import { ComposedFunction, ConversationContext, StepFunction } from "../types.js";
 
 const enrichContext = (ctx: ConversationContext): ConversationContext => {
   const lastUserMessage = [...ctx.history]
diff --git a/threads/src/composition/model.ts b/threads/src/composition/model.ts
@@ -1,13 +1,13 @@
-import { callProvider } from "../providers";
-import { normalizeSchema } from "../schema";
+import { callProvider } from "../providers/index.js";
+import { normalizeSchema } from "../schema.js";
 import {
   ConversationContext,
   ToolCall,
   JsonSchema,
   StandardSchema,
   ComposedFunction,
-} from "../types";
-import { requestApproval } from "../approval";
+} from "../types.js";
+import { requestApproval } from "../approval.js";
 
 export const model = ({
   model = "openai/gpt-4o-mini",
diff --git a/threads/src/composition/retry.ts b/threads/src/composition/retry.ts
@@ -1,4 +1,4 @@
-import { StepFunction, ConversationContext, RetryOptions } from "../types";
+import { StepFunction, ConversationContext, RetryOptions } from "../types.js";
 
 /**
  * scope({}, retry({ times: 2 }, model(...)))
diff --git a/threads/src/composition/scope.ts b/threads/src/composition/scope.ts
@@ -1,11 +1,11 @@
-import { compose } from "./compose";
+import { compose } from "./compose.js";
 import {
   ConversationContext,
   Inherit,
   ScopeConfig,
   StepFunction,
-} from "../types";
-import { toolConfigToToolDefinition } from "../utils";
+} from "../types.js";
+import { toolConfigToToolDefinition } from "../utils.js";
 
 const scopeContext = (
   config: ScopeConfig,
diff --git a/threads/src/composition/tap.ts b/threads/src/composition/tap.ts
@@ -1,4 +1,4 @@
-import { ConversationContext, StepFunction } from "../types";
+import { ConversationContext, StepFunction } from "../types.js";
 
 export const tap = (
   fn: (ctx: ConversationContext) => Promise<void> | void,
diff --git a/threads/src/composition/when.ts b/threads/src/composition/when.ts
@@ -1,4 +1,4 @@
-import { ConversationContext, StepFunction } from "../types";
+import { ConversationContext, StepFunction } from "../types.js";
 
 export const when = (
   condition: (ctx: ConversationContext) => boolean,
diff --git a/threads/src/embed.ts b/threads/src/embed.ts
@@ -1,4 +1,4 @@
-import { getKey } from "./utils";
+import { getKey } from "./utils.js";
 
 const modelCache = new Map<string, any>();
 
diff --git a/threads/src/helpers.ts b/threads/src/helpers.ts
@@ -1,5 +1,5 @@
-import { ConversationContext, StepFunction } from "./types";
-import { when } from "./composition/when";
+import { ConversationContext, StepFunction } from "./types.js";
+import { when } from "./composition/when.js";
 
 /**
  * scope({ until: noToolsCalled() })
diff --git a/threads/src/image.ts b/threads/src/image.ts
@@ -1,5 +1,5 @@
-import { ImageConfig, ImageResult } from "./types";
-import { getKey, parseModelName } from "./utils";
+import { ImageConfig, ImageResult } from "./types.js";
+import { getKey, parseModelName } from "./utils.js";
 
 const providerKeyEnvVars: Record<string, string> = {
   openai: "OPENAI_API_KEY",
diff --git a/threads/src/index.ts b/threads/src/index.ts
@@ -1,16 +1,16 @@
-export * from "./mcp";
-export * from "./types";
-export * from "./utils";
-export * from "./embed";
-export * from "./image";
-export * from "./image-model-schema";
-export * from "./thread";
-export * from "./schema";
-export * from "./helpers";
-export * from "./approval";
-export * from "./composition/tap";
-export * from "./composition/when";
-export * from "./composition/model";
-export * from "./composition/retry";
-export * from "./composition/scope";
-export * from "./composition/compose";
+export * from "./mcp.js";
+export * from "./types.js";
+export * from "./utils.js";
+export * from "./embed.js";
+export * from "./image.js";
+export * from "./image-model-schema.js";
+export * from "./thread.js";
+export * from "./schema.js";
+export * from "./helpers.js";
+export * from "./approval.js";
+export * from "./composition/tap.js";
+export * from "./composition/when.js";
+export * from "./composition/model.js";
+export * from "./composition/retry.js";
+export * from "./composition/scope.js";
+export * from "./composition/compose.js";
diff --git a/threads/src/mcp.ts b/threads/src/mcp.ts
@@ -1,6 +1,6 @@
 import type { Client } from "@modelcontextprotocol/sdk/client/index.js";
-import { ToolConfig } from "./types";
-import { convertMCPSchemaToToolSchema } from "./schema";
+import { ToolConfig } from "./types.js";
+import { convertMCPSchemaToToolSchema } from "./schema.js";
 
 export interface MCPConnection {
   tools: ToolConfig[];
diff --git a/threads/src/providers/anthropic.ts b/threads/src/providers/anthropic.ts
@@ -1,5 +1,5 @@
-import { ProviderConfig, Message, ConversationContext } from "../types";
-import { addUsage, getKey } from "../utils";
+import { ProviderConfig, Message, ConversationContext } from "../types.js";
+import { addUsage, getKey } from "../utils.js";
 
 const getApiKey = (configApiKey?: string): string => {
   if (configApiKey) return configApiKey;
diff --git a/threads/src/providers/google.ts b/threads/src/providers/google.ts
@@ -1,5 +1,5 @@
-import { ConversationContext, Message, ProviderConfig } from "../types";
-import { addUsage, getKey } from "../utils";
+import { ConversationContext, Message, ProviderConfig } from "../types.js";
+import { addUsage, getKey } from "../utils.js";
 
 const getApiKey = (configApiKey?: string): string => {
   if (configApiKey) return configApiKey;
diff --git a/threads/src/providers/huggingface.ts b/threads/src/providers/huggingface.ts
@@ -1,5 +1,5 @@
-import { ConversationContext, Message, ProviderConfig } from "../types";
-import { addUsage } from "../utils";
+import { ConversationContext, Message, ProviderConfig } from "../types.js";
+import { addUsage } from "../utils.js";
 
 const modelCache = new Map<string, any>();
 
diff --git a/threads/src/providers/index.ts b/threads/src/providers/index.ts
@@ -1,10 +1,10 @@
-import { ConversationContext, ProviderConfig } from "../types";
-import { parseModelName } from "../utils";
-import { callOpenAI } from "./openai";
-import { callAnthropic } from "./anthropic";
-import { callGoogle } from "./google";
-import { callHuggingFace } from "./huggingface";
-import { callXAI } from "./xai";
+import { ConversationContext, ProviderConfig } from "../types.js";
+import { parseModelName } from "../utils.js";
+import { callOpenAI } from "./openai.js";
+import { callAnthropic } from "./anthropic.js";
+import { callGoogle } from "./google.js";
+import { callHuggingFace } from "./huggingface.js";
+import { callXAI } from "./xai.js";
 
 
 export const callProvider = async (
diff --git a/threads/src/providers/openai.ts b/threads/src/providers/openai.ts
@@ -1,5 +1,5 @@
-import { ConversationContext, Message, ProviderConfig } from "../types";
-import { addUsage, getKey } from "../utils";
+import { ConversationContext, Message, ProviderConfig } from "../types.js";
+import { addUsage, getKey } from "../utils.js";
 
 const getApiKey = (configApiKey?: string): string | undefined => {
   if (configApiKey) return configApiKey;
diff --git a/threads/src/providers/xai.ts b/threads/src/providers/xai.ts
@@ -1,5 +1,5 @@
-import { ConversationContext, Message, ProviderConfig } from "../types";
-import { addUsage, getKey } from "../utils";
+import { ConversationContext, Message, ProviderConfig } from "../types.js";
+import { addUsage, getKey } from "../utils.js";
 
 const appendToolCalls = (toolCalls: any[], tcchunklist: any[]): any[] => {
   for (const tcchunk of tcchunklist) {
diff --git a/threads/src/schema.ts b/threads/src/schema.ts
@@ -1,4 +1,4 @@
-import { JsonSchema, SchemaProperty, StandardSchema } from "./types";
+import { JsonSchema, SchemaProperty, StandardSchema } from "./types.js";
 import { z, type ZodType } from "zod";
 
 export const isStandardSchema = (schema: any): schema is StandardSchema => {
diff --git a/threads/src/thread.ts b/threads/src/thread.ts
@@ -4,8 +4,8 @@ import {
   StepFunction,
   ThreadStore,
   Thread,
-} from "./types";
-import { model } from "./composition/model";
+} from "./types.js";
+import { model } from "./composition/model.js";
 
 const createMemoryStore = (): ThreadStore => {
   const store = new Map<string, Message[]>();
diff --git a/threads/src/utils.ts b/threads/src/utils.ts
@@ -5,8 +5,8 @@ import {
   TokenUsage,
   ToolConfig,
   ToolDefinition,
-} from "./types";
-import { isStandardSchema, convertStandardSchemaToSchemaProperties } from "./schema";
+} from "./types.js";
+import { isStandardSchema, convertStandardSchemaToSchemaProperties } from "./schema.js";
 
 export const toolConfigToToolDefinition = (
   tool: ToolConfig,
diff --git a/threads/tsconfig.json b/threads/tsconfig.json
@@ -1,8 +1,8 @@
 {
   "compilerOptions": {
     "target": "ES2022",
-    "module": "ES2022",
-    "moduleResolution": "bundler",
+    "module": "nodenext",
+    "moduleResolution": "nodenext",
     "declaration": true,
     "declarationMap": true,
     "sourceMap": true,

Original file line number	Diff line number	Diff line change
`@@ -1,6 +1,6 @@`
`1`	`1`	`{`
`2`	`2`	`"name": "@threaded/ai",`
`3`		`- "version": "2.0.1",`
	`3`	`+ "version": "2.0.2",`
`4`	`4`	`"description": "Composable LLM inference with multi-provider support, tool execution, streaming, and approval workflows",`
`5`	`5`	`"type": "module",`
`6`	`6`	`"main": "dist/index.js",`
Original file line number	Diff line number	Diff line change
`@@ -1,4 +1,4 @@`
`1`		`-import { ComposedFunction, ConversationContext, StepFunction } from "../types";`
	`1`	`+import { ComposedFunction, ConversationContext, StepFunction } from "../types.js";`
`2`	`2`
`3`	`3`	`const enrichContext = (ctx: ConversationContext): ConversationContext => {`
`4`	`4`	`const lastUserMessage = [...ctx.history]`
Original file line number	Diff line number	Diff line change
`@@ -1,4 +1,4 @@`
`1`		`-import { StepFunction, ConversationContext, RetryOptions } from "../types";`
	`1`	`+import { StepFunction, ConversationContext, RetryOptions } from "../types.js";`
`2`	`2`
`3`	`3`	`/**`
`4`	`4`	`* scope({}, retry({ times: 2 }, model(...)))`
Original file line number	Diff line number	Diff line change
`@@ -1,4 +1,4 @@`
`1`		`-import { ConversationContext, StepFunction } from "../types";`
	`1`	`+import { ConversationContext, StepFunction } from "../types.js";`
`2`	`2`
`3`	`3`	`export const tap = (`
`4`	`4`	`fn: (ctx: ConversationContext) => Promise<void> \| void,`
Original file line number	Diff line number	Diff line change
`@@ -1,4 +1,4 @@`
`1`		`-import { getKey } from "./utils";`
	`1`	`+import { getKey } from "./utils.js";`
`2`	`2`
`3`	`3`	`const modelCache = new Map<string, any>();`
`4`	`4`