Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
33 changes: 17 additions & 16 deletions package.json
Original file line number Diff line number Diff line change
Expand Up @@ -13,34 +13,35 @@
"devDependencies": {
"@graphai/agents": "^2.0.15",
"@graphai/vanilla": "^2.0.12",
"@rollup/plugin-commonjs": "^29.0.0",
"@rollup/plugin-commonjs": "^29.0.3",
"@rollup/plugin-node-resolve": "^16.0.3",
"@rollup/plugin-terser": "^0.4.4",
"@rollup/plugin-terser": "^1.0.0",
"@rollup/plugin-typescript": "^12.3.0",
"@tailwindcss/vite": "^4.1.18",
"@tailwindcss/vite": "^4.3.1",
"@types/express": "^5.0.6",
"@types/node": "^25.2.2",
"@types/node": "^26.0.0",
"@types/sinon": "^21.0.0",
"@types/sinon-express-mock": "^1.3.12",
"autoprefixer": "^10.4.24",
"eslint": "^10.0.0",
"eslint": "^10.5.0",
"eslint-config-prettier": "^10.1.8",
"eslint-plugin-react-hooks": "^5.2.0",
"eslint-plugin-react-refresh": "^0.4.26",
"eslint-plugin-vue": "^10.7.0",
"eslint-plugin-react-hooks": "^7.1.1",
"eslint-plugin-react-refresh": "^0.5.3",
"eslint-plugin-vue": "^10.9.2",
"firebase": "^12.9.0",
"firebase-functions": "^7.0.5",
"globals": "^17.3.0",
"graphai": "^2.0.16",
"prettier": "^3.8.1",
"rollup": "^4.59.0",
"globals": "^17.6.0",
"graphai": "^2.0.18",
"prettier": "^3.8.4",
"rollup": "^4.62.2",
"ts-node": "^10.9.2",
"tsc-alias": "^1.8.16",
"tsc-alias": "^1.8.17",
"tsconfig-paths": "^4.2.0",
"tslib": "^2.8.1",
"typescript": "^5.9.3",
"typescript-eslint": "^8.54.0",
"vue-eslint-parser": "^10.2.0"
"tsx": "^4.22.4",
"typescript": "^6.0.3",
"typescript-eslint": "^8.61.1",
"vue-eslint-parser": "^10.4.1"
},
"workspaces": [
"packages/*"
Expand Down
77 changes: 15 additions & 62 deletions packages/event_agent_generator/lib/event_agent_generator.js
Original file line number Diff line number Diff line change
@@ -1,70 +1,23 @@
"use strict";
var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
return new (P || (P = Promise))(function (resolve, reject) {
function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
step((generator = generator.apply(thisArg, _arguments || [])).next());
});
};
var __generator = (this && this.__generator) || function (thisArg, body) {
var _ = { label: 0, sent: function() { if (t[0] & 1) throw t[1]; return t[1]; }, trys: [], ops: [] }, f, y, t, g = Object.create((typeof Iterator === "function" ? Iterator : Object).prototype);
return g.next = verb(0), g["throw"] = verb(1), g["return"] = verb(2), typeof Symbol === "function" && (g[Symbol.iterator] = function() { return this; }), g;
function verb(n) { return function (v) { return step([n, v]); }; }
function step(op) {
if (f) throw new TypeError("Generator is already executing.");
while (g && (g = 0, op[0] && (_ = 0)), _) try {
if (f = 1, y && (t = op[0] & 2 ? y["return"] : op[0] ? y["throw"] || ((t = y["return"]) && t.call(y), 0) : y.next) && !(t = t.call(y, op[1])).done) return t;
if (y = 0, t) op = [op[0] & 2, t.value];
switch (op[0]) {
case 0: case 1: t = op; break;
case 4: _.label++; return { value: op[1], done: false };
case 5: _.label++; y = op[1]; op = [0]; continue;
case 7: op = _.ops.pop(); _.trys.pop(); continue;
default:
if (!(t = _.trys, t = t.length > 0 && t[t.length - 1]) && (op[0] === 6 || op[0] === 2)) { _ = 0; continue; }
if (op[0] === 3 && (!t || (op[1] > t[0] && op[1] < t[3]))) { _.label = op[1]; break; }
if (op[0] === 6 && _.label < t[1]) { _.label = t[1]; t = op; break; }
if (t && _.label < t[2]) { _.label = t[2]; _.ops.push(op); break; }
if (t[2]) _.ops.pop();
_.trys.pop(); continue;
}
op = body.call(thisArg, _);
} catch (e) { op = [6, e]; y = 0; } finally { f = t = 0; }
if (op[0] & 5) throw op[1]; return { value: op[0] ? op[1] : void 0, done: true };
}
};
Object.defineProperty(exports, "__esModule", { value: true });
exports.eventAgentGenerator = void 0;
var graphai_1 = require("graphai");
var eventAgentGenerator = function (onStart) {
var eventPromise = function (context) {
var id = Math.random().toString(32).substring(2);
return new Promise(function (resolved, reject) {
var onEnd = function (data) {
import { agentInfoWrapper } from "graphai";
export const eventAgentGenerator = (onStart) => {
const eventPromise = (context) => {
const id = Math.random().toString(32).substring(2);
return new Promise((resolved, reject) => {
const onEnd = (data) => {
resolved(data);
};
var params = context.params, namedInputs = context.namedInputs;
var _a = context.debugInfo, nodeId = _a.nodeId, agentId = _a.agentId;
var type = params.type;
var data = { onEnd: onEnd, id: id, nodeId: nodeId, agentId: agentId, type: type, params: params, namedInputs: namedInputs, reject: reject };
const { params, namedInputs } = context;
const { nodeId, agentId } = context.debugInfo;
const { type } = params;
const data = { onEnd, id, nodeId, agentId, type, params, namedInputs, reject };
onStart(id, data);
});
};
var eventAgent = function (context) { return __awaiter(void 0, void 0, void 0, function () {
var result;
return __generator(this, function (_a) {
switch (_a.label) {
case 0: return [4 /*yield*/, eventPromise(context)];
case 1:
result = _a.sent();
return [2 /*return*/, result];
}
});
}); };
const eventAgent = async (context) => {
const result = await eventPromise(context);
return result;
};
return {
eventAgent: (0, graphai_1.agentInfoWrapper)(eventAgent),
eventAgent: agentInfoWrapper(eventAgent),
};
};
exports.eventAgentGenerator = eventAgentGenerator;
10 changes: 3 additions & 7 deletions packages/event_agent_generator/lib/index.js
Original file line number Diff line number Diff line change
@@ -1,7 +1,3 @@
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.eventAgentGenerator = exports.textInputAgentGenerator = void 0;
var text_input_agent_generator_1 = require("./text_input_agent_generator");
Object.defineProperty(exports, "textInputAgentGenerator", { enumerable: true, get: function () { return text_input_agent_generator_1.textInputAgentGenerator; } });
var event_agent_generator_1 = require("./event_agent_generator");
Object.defineProperty(exports, "eventAgentGenerator", { enumerable: true, get: function () { return event_agent_generator_1.eventAgentGenerator; } });
import { textInputAgentGenerator } from "./text_input_agent_generator";
import { eventAgentGenerator } from "./event_agent_generator";
export { textInputAgentGenerator, eventAgentGenerator };
87 changes: 20 additions & 67 deletions packages/event_agent_generator/lib/text_input_agent_generator.js
Original file line number Diff line number Diff line change
@@ -1,47 +1,8 @@
"use strict";
var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) {
function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); }
return new (P || (P = Promise))(function (resolve, reject) {
function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } }
function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } }
function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); }
step((generator = generator.apply(thisArg, _arguments || [])).next());
});
};
var __generator = (this && this.__generator) || function (thisArg, body) {
var _ = { label: 0, sent: function() { if (t[0] & 1) throw t[1]; return t[1]; }, trys: [], ops: [] }, f, y, t, g = Object.create((typeof Iterator === "function" ? Iterator : Object).prototype);
return g.next = verb(0), g["throw"] = verb(1), g["return"] = verb(2), typeof Symbol === "function" && (g[Symbol.iterator] = function() { return this; }), g;
function verb(n) { return function (v) { return step([n, v]); }; }
function step(op) {
if (f) throw new TypeError("Generator is already executing.");
while (g && (g = 0, op[0] && (_ = 0)), _) try {
if (f = 1, y && (t = op[0] & 2 ? y["return"] : op[0] ? y["throw"] || ((t = y["return"]) && t.call(y), 0) : y.next) && !(t = t.call(y, op[1])).done) return t;
if (y = 0, t) op = [op[0] & 2, t.value];
switch (op[0]) {
case 0: case 1: t = op; break;
case 4: _.label++; return { value: op[1], done: false };
case 5: _.label++; y = op[1]; op = [0]; continue;
case 7: op = _.ops.pop(); _.trys.pop(); continue;
default:
if (!(t = _.trys, t = t.length > 0 && t[t.length - 1]) && (op[0] === 6 || op[0] === 2)) { _ = 0; continue; }
if (op[0] === 3 && (!t || (op[1] > t[0] && op[1] < t[3]))) { _.label = op[1]; break; }
if (op[0] === 6 && _.label < t[1]) { _.label = t[1]; t = op; break; }
if (t && _.label < t[2]) { _.label = t[2]; _.ops.push(op); break; }
if (t[2]) _.ops.pop();
_.trys.pop(); continue;
}
op = body.call(thisArg, _);
} catch (e) { op = [6, e]; y = 0; } finally { f = t = 0; }
if (op[0] & 5) throw op[1]; return { value: op[0] ? op[1] : void 0, done: true };
}
};
Object.defineProperty(exports, "__esModule", { value: true });
exports.textInputAgentGenerator = void 0;
var graphai_1 = require("graphai");
var textInputAgentGenerator = function (inputEvents) {
var submit = function (id, value, success) {
import { agentInfoWrapper } from "graphai";
export const textInputAgentGenerator = (inputEvents) => {
const submit = (id, value, success) => {
if (inputEvents.length > 0) {
var index = inputEvents.findIndex(function (inp) { return inp.id === id; });
const index = inputEvents.findIndex((inp) => inp.id === id);
if (index > -1) {
inputEvents[index].task(value);
inputEvents.splice(index, 1);
Expand All @@ -51,34 +12,26 @@ var textInputAgentGenerator = function (inputEvents) {
}
}
};
var textPromise = function (context) {
var id = Math.random().toString(32).substring(2);
return new Promise(function (resolved) {
var task = function (message) {
const textPromise = (context) => {
const id = Math.random().toString(32).substring(2);
return new Promise((resolved) => {
const task = (message) => {
resolved(message);
};
var params = context.params;
var _a = context.debugInfo, nodeId = _a.nodeId, agentId = _a.agentId;
inputEvents.push({ task: task, id: id, nodeId: nodeId, agentId: agentId, params: params });
const { params } = context;
const { nodeId, agentId } = context.debugInfo;
inputEvents.push({ task, id, nodeId, agentId, params });
});
};
var textInputAgent = function (context) { return __awaiter(void 0, void 0, void 0, function () {
var result;
return __generator(this, function (_a) {
switch (_a.label) {
case 0: return [4 /*yield*/, textPromise(context)];
case 1:
result = _a.sent();
return [2 /*return*/, {
text: result,
message: { role: "user", content: result },
}];
}
});
}); };
const textInputAgent = async (context) => {
const result = await textPromise(context);
return {
text: result,
message: { role: "user", content: result },
};
};
return {
textInputAgent: (0, graphai_1.agentInfoWrapper)(textInputAgent),
submit: submit,
textInputAgent: agentInfoWrapper(textInputAgent),
submit,
};
};
exports.textInputAgentGenerator = textInputAgentGenerator;
12 changes: 6 additions & 6 deletions packages/event_agent_generator/package.json
Original file line number Diff line number Diff line change
Expand Up @@ -8,7 +8,7 @@
],
"scripts": {
"dev": "vite",
"build": "tsc --esModuleInterop --declaration --outDir lib/ src/text_input_agent_generator.ts src/event_agent_generator.ts src/index.ts",
"build": "tsc -p tsconfig.build.json",
"preview": "vite preview",
"build-only": "vite build",
"rollup": " npx rollup -c",
Expand All @@ -29,11 +29,11 @@
"homepage": "https://github.com/receptron/graphai_utils/tree/main/packages/vue-text-input-agent-generator#readme",
"dependencies": {},
"devDependencies": {
"@vitejs/plugin-vue": "^6.0.4",
"@vue/tsconfig": "^0.8.1",
"vite": "^7.3.5",
"vue": "^3.5.27",
"vue-tsc": "^3.2.4"
"@vitejs/plugin-vue": "^6.0.7",
"@vue/tsconfig": "^0.9.1",
"vite": "^8.0.16",
"vue": "^3.5.38",
"vue-tsc": "^3.3.5"
},
"types": "./lib/index.d.ts",
"directories": {
Expand Down
13 changes: 13 additions & 0 deletions packages/event_agent_generator/tsconfig.build.json
Original file line number Diff line number Diff line change
@@ -0,0 +1,13 @@
{
"compilerOptions": {
"strict": false,
"target": "es2022",
"module": "esnext",
"moduleResolution": "bundler",
"esModuleInterop": true,
"declaration": true,
"outDir": "lib",
"rootDir": "src"
},
"files": ["src/text_input_agent_generator.ts", "src/event_agent_generator.ts", "src/index.ts"]
}
8 changes: 4 additions & 4 deletions packages/express/package.json
Original file line number Diff line number Diff line change
Expand Up @@ -9,10 +9,10 @@
"scripts": {
"build": "tsc && tsc-alias",
"eslint": "eslint --fix",
"server": "ts-node -r tsconfig-paths/register test/express.ts",
"test_stream": "ts-node -r tsconfig-paths/register test/test_stream_client.ts",
"test_stream2": "ts-node -r tsconfig-paths/register test/test_stream_graph.ts",
"test": "node --test -r tsconfig-paths/register --require ts-node/register ./test/test_*.ts",
"server": "tsx test/express.ts",
"test_stream": "tsx test/test_stream_client.ts",
"test_stream2": "tsx test/test_stream_graph.ts",
"test": "node --import tsx --test ./test/test_*.ts",
"format": "prettier --write '{src,test}/**/*.{yaml,ts,json}'",
"ci": "yarn run format && yarn run eslint && yarn run build"
},
Expand Down
1 change: 1 addition & 0 deletions packages/express/tsconfig.json
Original file line number Diff line number Diff line change
Expand Up @@ -28,6 +28,7 @@
"module": "commonjs", /* Specify what module code is generated. */
"rootDir": "./src/", /* Specify the root folder within your source files. */
// "moduleResolution": "node10", /* Specify how TypeScript looks up a file from a given module specifier. */
"ignoreDeprecations": "6.0",
"baseUrl": "./", /* Specify the base directory to resolve non-relative module names. */
"paths": {
"@/*": ["./src/*"],
Expand Down
1 change: 1 addition & 0 deletions packages/firebase-tools/tsconfig.json
Original file line number Diff line number Diff line change
Expand Up @@ -28,6 +28,7 @@
"module": "commonjs", /* Specify what module code is generated. */
"rootDir": "./src/", /* Specify the root folder within your source files. */
// "moduleResolution": "node10", /* Specify how TypeScript looks up a file from a given module specifier. */
"ignoreDeprecations": "6.0",
"baseUrl": "./", /* Specify the base directory to resolve non-relative module names. */
"paths": {
"@/*": ["./src/*"],
Expand Down
1 change: 1 addition & 0 deletions packages/firebase_functions/tsconfig.json
Original file line number Diff line number Diff line change
Expand Up @@ -28,6 +28,7 @@
"module": "commonjs", /* Specify what module code is generated. */
"rootDir": "./src/", /* Specify the root folder within your source files. */
// "moduleResolution": "node10", /* Specify how TypeScript looks up a file from a given module specifier. */
"ignoreDeprecations": "6.0",
"baseUrl": "./", /* Specify the base directory to resolve non-relative module names. */
"paths": {
"@/*": ["./src/*"],
Expand Down
4 changes: 4 additions & 0 deletions packages/react-cytoscape/eslint.config.js
Original file line number Diff line number Diff line change
Expand Up @@ -19,6 +19,10 @@ export default tseslint.config(
},
rules: {
...reactHooks.configs.recommended.rules,
// react-hooks v7 promoted these React Compiler rules to errors; they flag this hook's
// intentional mutable-cytoscape pattern. Re-enable after an immutable refactor.
'react-hooks/immutability': 'off',
'react-hooks/set-state-in-effect': 'off',
'react-refresh/only-export-components': [
'warn',
{ allowConstantExport: true },
Expand Down
Loading
Loading