Feature/extend ai

packages/plugins/.setup/catalog.json

@@ -24,7 +24,7 @@
     "packageName": "@magmacomputing/tempo-plugin-batch",
     "plan": "community",
     "status": "active",
-    "version": "1.0.2"
+    "version": "1.1.0"
   },
   {
     "id": "finance",
@@ -60,7 +60,7 @@
     "packageName": "@magmacomputing/tempo-plugin-ai",
     "plan": "community",
     "status": "active",
-    "version": "1.2.1"
+    "version": "2.0.0"
   },
   {
     "id": "ticker",
@@ -78,7 +78,7 @@
     "packageName": "@magmacomputing/tempo-plugin-geo",
     "plan": "community",
     "status": "active",
-    "version": "0.1.0"
+    "version": "1.0.0"
   },
   {
     "id": "_std",

packages/plugins/ai/CHANGELOG.md

@@ -5,13 +5,15 @@ All notable changes to the `@magmacomputing/tempo-plugin-ai` project will be doc
 The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
 and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
-## [1.2.1] - 2026-09-07
+## [2.0.0] - 2026-09-08
 
-### Security & Reliability
+### Breaking Changes & Major Release
+- **Standardized on Tempo v4.1.0+ Community Core**:
+  - Requires `@magmacomputing/tempo` `^4.1.0`.
+  - Migrated configuration discovery to the dedicated `pluginOptions.ai` configuration slot introduced in Tempo v4.1.0, deprecating legacy `plugins.ai` dictionary passing.
 - **Self-Contained Network Transport (`fetch.ts`)**:
-  - Decoupled network request utilities from `@magmacomputing/tempo/library` into a self-contained local transport helper.
-  - Added chunk-by-chunk stream consumption via `res.body.getReader()` with proactive byte accounting and immediate reader cancellation (`await reader.cancel()`).
-  - Enforced upfront `Content-Length` checks against `maxBytes` and strictly bounded stream reads to prevent unbounded memory allocation and OS thread starvation.
+  - Decoupled network transport entirely from `@magmacomputing/tempo/library` (removing reliance on core internal `HttpError` and `fetchRequest`).
+  - Implemented proactive stream consumption via `res.body.getReader()` with strict byte accounting and upfront `Content-Length` enforcement against `maxBytes` to prevent memory exhaustion.
 
 ## [1.2.0] - 2026-09-06
 

packages/plugins/ai/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@magmacomputing/tempo-plugin-ai",
-  "version": "1.2.1",
+  "version": "2.0.0",
   "description": "Tempo community plugin for LLM-powered natural language parsing.",
   "main": "dist/index.js",
   "types": "dist/index.d.ts",

packages/plugins/batch/CHANGELOG.md

@@ -2,6 +2,15 @@
 
 All notable changes to the `@magmacomputing/tempo-plugin-batch` project will be documented in this file.
 
+## [1.1.0] - 2026-09-08
+
+### Added & Enhanced
+- **Worker Thread Runtime Flag Inheritance (`execArgv`)**:
+  - Configured `BatchOrchestrator` to forward `process.execArgv` to spawned worker threads.
+  - Workers automatically inherit native runtime flags (such as `--harmony-temporal`) or custom loader configurations (`--import`) without bundling or depending on a polyfill, strictly preserving Tempo's zero-dependency, native-first Temporal philosophy.
+- **Shorthand Mutation Parsing**:
+  - Added support for relative duration shorthand strings (e.g. `+1d`, `+1w`, `+1h`, `+1m`) alongside `{ Term: Value }` mutation objects.
+
 ## [1.0.2] - 2026-08-20
 
 ### Fixed

packages/plugins/batch/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@magmacomputing/tempo-plugin-batch",
-  "version": "1.0.2",
+  "version": "1.1.0",
   "description": "Tempo community plugin bringing C-level parallelization to massive date arrays via SharedArrayBuffer and Worker Threads.",
   "main": "dist/index.js",
   "types": "dist/index.d.ts",

packages/plugins/batch/src/BatchOrchestrator.ts

@@ -36,9 +36,8 @@ export class BatchOrchestrator {
 		if (epochs.length === 0) return [];
 
 		if (options.threads !== undefined) {
-			if (!Number.isInteger(options.threads) || options.threads <= 0) {
+			if (!Number.isInteger(options.threads) || options.threads <= 0)
 				throw new Error("options.threads must be a positive integer");
-			}
 		}
 
 		const threadCount = options.threads ?? os.cpus().length;
@@ -82,6 +81,10 @@ export class BatchOrchestrator {
 		const workers: Promise<void>[] = [];
 		const actualThreads = Math.min(threadCount, Math.ceil(epochs.length / chunkSize));
 
+		const execArgv = (process.execArgv || []).filter(
+			arg => !arg.startsWith('--input-type') && !arg.startsWith('--eval') && !arg.startsWith('-e') && !arg.startsWith('--print') && !arg.startsWith('-p')
+		);
+
 		for (let i = 0; i < actualThreads; i++) {
 			const startIdx = i * chunkSize;
 			const endIdx = Math.min((i + 1) * chunkSize, epochs.length);
@@ -94,8 +97,9 @@ export class BatchOrchestrator {
 						outputBuffer,
 						startIdx,
 						endIdx,
-						operation
-					}
+						operation,
+					},
+					execArgv,
 				});
 				worker.on('message', (msg: any) => {
 					if (msg.status === 'done') resolve();
@@ -135,6 +139,9 @@ export class BatchOrchestrator {
 	private static async _transformWithPostMessage(epochs: number[], operation: string, threadCount: number, chunkSize: number, options: BatchOptions): Promise<any[]> {
 		const workers: Promise<any[]>[] = [];
 		const actualThreads = Math.min(threadCount, Math.ceil(epochs.length / chunkSize));
+		const execArgv = (process.execArgv || []).filter(
+			arg => !arg.startsWith('--input-type') && !arg.startsWith('--eval') && !arg.startsWith('-e') && !arg.startsWith('--print') && !arg.startsWith('-p')
+		);
 
 		for (let i = 0; i < actualThreads; i++) {
 			const startIdx = i * chunkSize;
@@ -146,8 +153,9 @@ export class BatchOrchestrator {
 					workerData: {
 						mode: 'postMessage',
 						chunk,
-						operation
-					}
+						operation,
+					},
+					execArgv,
 				});
 				worker.on('message', (msg: any) => {
 					if (msg.status === 'done') resolve(msg.result);

packages/plugins/batch/src/worker.ts

@@ -1,6 +1,30 @@
 import { workerData, parentPort } from 'node:worker_threads';
 import { Tempo } from '@magmacomputing/tempo';
 
+function applyMutation(t: any, op: any) {
+	if (typeof op === 'string') {
+		const match = op.trim().match(/^([+-]?\d+)\s*([a-zA-Z]+)$/);
+		if (match) {
+			const count = parseInt(match[1], 10);
+			const unit = match[2].toLowerCase();
+			const unitMap: Record<string, string> = {
+				d: 'days', day: 'days', days: 'days',
+				w: 'weeks', week: 'weeks', weeks: 'weeks',
+				m: 'minutes', min: 'minutes', mins: 'minutes', minute: 'minutes', minutes: 'minutes',
+				h: 'hours', hr: 'hours', hrs: 'hours', hour: 'hours', hours: 'hours',
+				s: 'seconds', sec: 'seconds', secs: 'seconds', second: 'seconds', seconds: 'seconds',
+				mo: 'months', month: 'months', months: 'months',
+				y: 'years', yr: 'years', yrs: 'years', year: 'years', years: 'years'
+			};
+			const mappedUnit = unitMap[unit];
+			if (mappedUnit) {
+				return t.add({ [mappedUnit]: count });
+			}
+		}
+	}
+	return t.add(op);
+}
+
 async function run() {
 	if (!parentPort) return;
 
@@ -14,11 +38,8 @@ async function run() {
 
 			for (let i = startIdx; i < endIdx; i++) {
 				const epoch = inputView[i];
-				// Using Tempo to mutate. In a full implementation, we'd have robust parsing of the 'operation' string.
-				// For this prototype, we assume the operation is an add operation (e.g. "+1w").
-				// We get the mutated epoch number and put it back into the buffer.
 				const t = new Tempo(epoch);
-				const resultT = t.add(operation);
+				const resultT = applyMutation(t, operation);
 				outputView[i] = resultT.epoch.ms;
 			}
 			parentPort.postMessage({ status: 'done' });
@@ -30,7 +51,7 @@ async function run() {
 			for (let i = 0; i < chunk.length; i++) {
 				const epoch = chunk[i];
 				const t = new Tempo(epoch);
-				const resultT = t.add(operation);
+				const resultT = applyMutation(t, operation);
 				result[i] = resultT.epoch.ms;
 			}
 

packages/plugins/geo/CHANGELOG.md

@@ -5,6 +5,13 @@ All notable changes to the `@magmacomputing/tempo-plugin-geo` project will be do
 The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
 and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
+## [1.0.0] - 2026-09-07
+
+### Added
+- **Stable Community Release**:
+  - Official 1.0.0 release of `@magmacomputing/tempo-plugin-geo`.
+  - Configured npm Trusted Publisher automation for CI/CD publishing.
+
 ## [0.1.0] - 2026-09-07
 
 ### Added

packages/plugins/geo/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@magmacomputing/tempo-plugin-geo",
-  "version": "0.1.0",
+  "version": "1.0.0",
   "description": "Tempo community plugin for IP geolocation lookup, browser hardware location services, and coordinate resolution.",
   "main": "dist/index.js",
   "types": "dist/index.d.ts",
@@ -53,4 +53,4 @@
       "default": "./dist/index.js"
     }
   }
-}
+}

packages/tempo/.vitepress/theme/data/catalog.json

@@ -78,7 +78,7 @@
     "packageName": "@magmacomputing/tempo-plugin-geo",
     "plan": "community",
     "status": "active",
-    "version": "0.1.0"
+    "version": "1.0.0"
   },
   {
     "id": "_std",