Plugins support

apps/chat/next.config.js

@@ -2,6 +2,7 @@
 
 const path = require('path');
 const webpack = require('webpack');
+const { builtinModules } = require('module');
 
 module.exports = {
   // experimental: {
@@ -14,6 +15,48 @@ module.exports = {
     'react-agents-client',
     'ecctrl',
     'ucom',
+    '@elizaos/core',
+    '@elizaos/client-farcaster',
+    '@elizaos/client-github',
+    '@elizaos/client-lens',
+    '@elizaos/client-slack',
+    '@elizaos/client-telegram',
+    '@elizaos/client-twitter',
+    '@elizaos/plugin-0g',
+    '@elizaos/plugin-3d-generation',
+    '@elizaos/plugin-abstract',
+    '@elizaos/plugin-aptos',
+    '@elizaos/plugin-avalanche',
+    '@elizaos/plugin-bootstrap',
+    '@elizaos/plugin-coinbase',
+    '@elizaos/plugin-conflux',
+    '@elizaos/plugin-cronoszkevm',
+    '@elizaos/plugin-echochambers',
+    '@elizaos/plugin-evm',
+    '@elizaos/plugin-ferepro',
+    '@elizaos/plugin-flow',
+    '@elizaos/plugin-fuel',
+    '@elizaos/plugin-gitbook',
+    '@elizaos/plugin-goat',
+    '@elizaos/plugin-icp',
+    '@elizaos/plugin-image-generation',
+    '@elizaos/plugin-intiface',
+    '@elizaos/plugin-multiversx',
+    '@elizaos/plugin-near',
+    '@elizaos/plugin-nft-generation',
+    '@elizaos/plugin-node',
+    '@elizaos/plugin-solana',
+    '@elizaos/plugin-starknet',
+    '@elizaos/plugin-story',
+    '@elizaos/plugin-sui',
+    '@elizaos/plugin-tee',
+    '@elizaos/plugin-ton',
+    '@elizaos/plugin-trustdb',
+    '@elizaos/plugin-twitter',
+    '@elizaos/plugin-video-generation',
+    '@elizaos/plugin-web-search',
+    '@elizaos/plugin-whatsapp',
+    '@elizaos/plugin-zksync-era',
   ],
   async redirects() {
     return [
@@ -88,28 +131,42 @@ module.exports = {
       use: [options.defaultLoaders.babel],
     }); */
 
+    config.plugins.push(
+      new webpack.NormalModuleReplacementPlugin(/^node:(.*)$/, (resource) => {
+        resource.request = resource.request.replace(/^node:/, '');
+      })
+    );
+
     // fix react resolution in sdk subpackage
     const usdkPath = path.resolve(__dirname, '../../packages/usdk');
     const upstreetAgentPath = path.resolve(__dirname, '../../packages/usdk/packages/upstreet-agent');
     const reactAgentsPath = path.resolve(__dirname, '../../packages/usdk/packages/upstreet-agent/packages/react-agents');
     const reactAgentsClientPath = path.resolve(__dirname, '../../packages/usdk/packages/upstreet-agent/packages/react-agents-client');
     const reactAgentsBrowserPath = path.resolve(__dirname, '../../packages/usdk/packages/upstreet-agent/packages/react-agents-browser');
-    const replacePlugin = (scopePath, moduleRegexp) => {
+    const replacePlugin = (scopePath, moduleRegexp, importPath) => {
       return new webpack.NormalModuleReplacementPlugin(moduleRegexp, (resource) => {
-        if (resource.context.includes(scopePath)) {
+        if (
+          (typeof scopePath == 'string' && resource.context.includes(scopePath)) ||
+          (scopePath instanceof RegExp && scopePath.test(resource.context))
+        ) {
+          if (builtinModules.includes(resource.request)) {
+            resource.request = path.join(importPath, 'node_modules', resource.request);
+          }
           const p = require.resolve(resource.request, {
-            paths: [scopePath],
+            paths: [importPath],
           });
           resource.request = p;
         }
       });
     };
+    const modulesRegex = /^react|^fs$|^child_process$/;
     config.plugins.push(
-      replacePlugin(reactAgentsPath, /^react/),
-      replacePlugin(reactAgentsClientPath, /^react/),
-      replacePlugin(reactAgentsBrowserPath, /^react/),
-      replacePlugin(upstreetAgentPath, /^react/),
-      replacePlugin(usdkPath, /^react/),
+      replacePlugin(reactAgentsPath, modulesRegex, upstreetAgentPath),
+      replacePlugin(reactAgentsClientPath, modulesRegex, upstreetAgentPath),
+      replacePlugin(reactAgentsBrowserPath, modulesRegex, upstreetAgentPath),
+      replacePlugin(upstreetAgentPath, modulesRegex, upstreetAgentPath),
+      replacePlugin(usdkPath, modulesRegex, upstreetAgentPath),
+      replacePlugin(/\/path-scurry\/|\/0g-ts-sdk\//, modulesRegex, upstreetAgentPath),
     );
 
     // config.experiments = {
@@ -123,6 +180,11 @@ module.exports = {
       type: 'asset/resource',
     });
 
+    config.module.rules.push({
+      test: /\.cdc$/,
+      type: 'asset/source'
+    });
+
     return config;
   },
   async headers() {

packages/usdk/package.json

@@ -130,7 +130,6 @@
     "web-worker": "1.2.0",
     "webp-wasm": "^1.0.6",
     "winston": "^3.16.0",
-    "wrangler": "^3.95.0",
     "ws": "^8.17.0",
     "yjs": "^13.6.18",
     "zjs": "file:./packages/upstreet-agent/packages/react-agents-client/packages/multiplayer/packages/zjs",

packages/usdk/packages/upstreet-agent/durable-object.tsx

@@ -1,3 +1,5 @@
+import './init.ts';
+import './main.jsx';
 import React from 'react';
 import dotenv from 'dotenv';
 import { createRoot, Root } from 'react-agents/root.ts';
@@ -6,8 +8,6 @@ import App from './agent.tsx';
 import agentJsonSource from './agent.json';
 import envTxt from './.env.txt';
 
-Error.stackTraceLimit = 300;
-
 const alarmTimeout = 10 * 1000;
 
 const parseAgentJson = (agentJsonSource) => {

packages/usdk/packages/upstreet-agent/init.ts

@@ -0,0 +1,7 @@
+Error.stackTraceLimit = 300;
+globalThis.__filename = 'node.js';
+globalThis.__dirname = '/';
+(globalThis.process as any).version = '20.0.0';
+if (typeof import.meta.url === 'undefined') {
+  import.meta.url = `file://localhost/${globalThis.__filename}`;
+}

packages/usdk/packages/upstreet-agent/main.jsx

@@ -1,9 +1,8 @@
+import './init.ts';
 export { DurableObject } from './durable-object.tsx';
 import { headers } from 'react-agents/constants.mjs';
 import agentJsonSource from './agent.json';
 
-Error.stackTraceLimit = 300;
-
 const parseAgentJson = (agentJsonSource) => {
   try {
     if (typeof agentJsonSource === 'string') {

packages/usdk/packages/upstreet-agent/package.json

@@ -4,21 +4,65 @@
   "dependencies": {
     "@aws-sdk/util-format-url": "^3.577.0",
     "@electric-sql/pglite": "^0.2.15",
+    "@elizaos/core": "file:./packages/elizaos-core-proxy",
+    "@elizaos/client-farcaster": "file:./packages/react-agents/components/clients/client-farcaster",
+    "@elizaos/client-github": "file:./packages/react-agents/components/clients/client-github",
+    "@elizaos/client-lens": "file:./packages/react-agents/components/clients/client-lens",
+    "@elizaos/client-slack": "file:./packages/react-agents/components/clients/client-slack",
+    "@elizaos/client-telegram": "file:./packages/react-agents/components/clients/client-telegram",
+    "@elizaos/client-twitter": "file:./packages/react-agents/components/clients/client-twitter",
+    "@elizaos/plugin-0g": "file:./packages/react-agents/components/plugins/plugin-0g",
+    "@elizaos/plugin-3d-generation": "file:./packages/react-agents/components/plugins/plugin-3d-generation",
+    "@elizaos/plugin-abstract": "file:./packages/react-agents/components/plugins/plugin-abstract",
+    "@elizaos/plugin-aptos": "file:./packages/react-agents/components/plugins/plugin-aptos",
+    "@elizaos/plugin-bootstrap": "file:./packages/react-agents/components/plugins/plugin-bootstrap",
+    "@elizaos/plugin-coinbase": "file:./packages/react-agents/components/plugins/plugin-coinbase",
+    "@elizaos/plugin-conflux": "file:./packages/react-agents/components/plugins/plugin-conflux",
+    "@elizaos/plugin-cronoszkevm": "file:./packages/react-agents/components/plugins/plugin-cronoszkevm",
+    "@elizaos/plugin-echochambers": "file:./packages/react-agents/components/plugins/plugin-echochambers",
+    "@elizaos/plugin-evm": "file:./packages/react-agents/components/plugins/plugin-evm",
+    "@elizaos/plugin-avalanche": "file:./packages/react-agents/components/plugins/plugin-avalanche",
+    "@elizaos/plugin-ferePro": "file:./packages/react-agents/components/plugins/plugin-ferePro",
+    "@elizaos/plugin-flow": "file:./packages/react-agents/components/plugins/plugin-flow",
+    "@elizaos/plugin-fuel": "file:./packages/react-agents/components/plugins/plugin-fuel",
+    "@elizaos/plugin-gitbook": "file:./packages/react-agents/components/plugins/plugin-gitbook",
+    "@elizaos/plugin-goat": "file:./packages/react-agents/components/plugins/plugin-goat",
+    "@elizaos/plugin-icp": "file:./packages/react-agents/components/plugins/plugin-icp",
+    "@elizaos/plugin-image-generation": "file:./packages/react-agents/components/plugins/plugin-image-generation",
+    "@elizaos/plugin-intiface": "file:./packages/react-agents/components/plugins/plugin-intiface",
+    "@elizaos/plugin-near": "file:./packages/react-agents/components/plugins/plugin-near",
+    "@elizaos/plugin-nft-generation": "file:./packages/react-agents/components/plugins/plugin-nft-generation",
+    "@elizaos/plugin-multiversx": "file:./packages/react-agents/components/plugins/plugin-multiversx",
+    "@elizaos/plugin-solana": "file:./packages/react-agents/components/plugins/plugin-solana",
+    "@elizaos/plugin-starknet": "file:./packages/react-agents/components/plugins/plugin-starknet",
+    "@elizaos/plugin-story": "file:./packages/react-agents/components/plugins/plugin-story",
+    "@elizaos/plugin-sui": "file:./packages/react-agents/components/plugins/plugin-sui",
+    "@elizaos/plugin-tee": "file:./packages/react-agents/components/plugins/plugin-tee",
+    "@elizaos/plugin-ton": "file:./packages/react-agents/components/plugins/plugin-ton",
+    "@elizaos/plugin-trustdb": "file:./packages/react-agents/components/plugins/plugin-trustdb",
+    "@elizaos/plugin-twitter": "file:./packages/react-agents/components/plugins/plugin-twitter",
+    "@elizaos/plugin-video-generation": "file:./packages/react-agents/components/plugins/plugin-video-generation",
+    "@elizaos/plugin-web-search": "file:./packages/react-agents/components/plugins/plugin-web-search",
+    "@elizaos/plugin-whatsapp": "file:./packages/react-agents/components/plugins/plugin-whatsapp",
+    "@elizaos/plugin-zksync-era": "file:./packages/react-agents/components/plugins/plugin-zksync-era",
     "@iarna/toml": "^2.2.5",
     "@supabase/postgrest-js": "^1.17.7",
     "@supabase/supabase-js": "^2.47.1",
     "@tsndr/cloudflare-worker-jwt": "2.5.3",
     "@types/jest": "^29.5.13",
     "browser-util-inspect": "^0.2.0",
+    "child_process": "file:./packages/fs-proxy",
     "codecs": "file:./packages/codecs",
     "debouncer": "file:./packages/debouncer",
     "dedent": "^1.5.3",
     "dotenv": "^16.4.5",
     "ethers": "^6.12.0",
     "format-util": "^1.0.5",
+    "fs": "file:./packages/fs-proxy",
     "javascript-time-ago": "^2.5.11",
     "jest": "^29.0.0",
     "jimp": "^1.6.0",
+    "memfs": "^4.15.1",
     "memoize-one": "^6.0.0",
     "minimatch": "^9.0.4",
     "openai": "^4.56.0",
@@ -31,6 +75,7 @@
     "react-agents-node": "file:./packages/react-agents-node",
     "react-reconciler": "file:./packages/react-reconciler",
     "stripe": "^16.10.0",
+    "tls": "file:./packages/tls-proxy",
     "together-ai": "^0.6.0-alpha.4",
     "ts-jest": "^29.2.5",
     "twitter-api-sdk": "^1.2.1",

packages/usdk/packages/upstreet-agent/packages/child-process-proxy/child-process.mjs

@@ -0,0 +1,7 @@
+export const spawn = () => {
+  throw new Error('not implemented');
+};
+const childProcess = {
+  spawn,
+};
+export default childProcess;

packages/usdk/packages/upstreet-agent/packages/child-process-proxy/package.json

@@ -0,0 +1,4 @@
+{
+  "name": "child_process",
+  "main": "child-process.mjs"
+}

packages/usdk/packages/upstreet-agent/packages/elizaos-core-proxy/context.ts

@@ -0,0 +1,104 @@
+import handlebars from "handlebars";
+import { type State } from "./types.ts";
+import { names, uniqueNamesGenerator } from "unique-names-generator";
+
+/**
+ * Composes a context string by replacing placeholders in a template with corresponding values from the state.
+ *
+ * This function takes a template string with placeholders in the format `{{placeholder}}` and a state object.
+ * It replaces each placeholder with the value from the state object that matches the placeholder's name.
+ * If a matching key is not found in the state object for a given placeholder, the placeholder is replaced with an empty string.
+ *
+ * By default, this function uses a simple string replacement approach. However, when `templatingEngine` is set to `'handlebars'`, it uses Handlebars templating engine instead, compiling the template into a reusable function and evaluating it with the provided state object.
+ *
+ * @param {Object} params - The parameters for composing the context.
+ * @param {State} params.state - The state object containing values to replace the placeholders in the template.
+ * @param {string} params.template - The template string containing placeholders to be replaced with state values.
+ * @param {"handlebars" | undefined} [params.templatingEngine] - The templating engine to use for compiling and evaluating the template (optional, default: `undefined`).
+ * @returns {string} The composed context string with placeholders replaced by corresponding state values.
+ *
+ * @example
+ * // Given a state object and a template
+ * const state = { userName: "Alice", userAge: 30 };
+ * const template = "Hello, {{userName}}! You are {{userAge}} years old";
+ *
+ * // Composing the context with simple string replacement will result in:
+ * // "Hello, Alice! You are 30 years old."
+ * const contextSimple = composeContext({ state, template });
+ */
+export const composeContext = ({
+    state,
+    template,
+    templatingEngine,
+}: {
+    state: State;
+    template: string;
+    templatingEngine?: "handlebars";
+}) => {
+    if (templatingEngine === "handlebars") {
+        const templateFunction = handlebars.compile(template);
+        return templateFunction(state);
+    }
+
+    // @ts-expect-error match isn't working as expected
+    const out = template.replace(/{{\w+}}/g, (match) => {
+        const key = match.replace(/{{|}}/g, "");
+        return state[key] ?? "";
+    });
+    return out;
+};
+
+/**
+ * Adds a header to a body of text.
+ *
+ * This function takes a header string and a body string and returns a new string with the header prepended to the body.
+ * If the body string is empty, the header is returned as is.
+ *
+ * @param {string} header - The header to add to the body.
+ * @param {string} body - The body to which to add the header.
+ * @returns {string} The body with the header prepended.
+ *
+ * @example
+ * // Given a header and a body
+ * const header = "Header";
+ * const body = "Body";
+ *
+ * // Adding the header to the body will result in:
+ * // "Header\nBody"
+ * const text = addHeader(header, body);
+ */
+export const addHeader = (header: string, body: string) => {
+    return body.length > 0 ? `${header ? header + "\n" : header}${body}\n` : "";
+};
+
+/**
+ * Generates a string with random user names populated in a template.
+ *
+ * This function generates a specified number of random user names and populates placeholders
+ * in the provided template with these names. Placeholders in the template should follow the format `{{userX}}`
+ * where `X` is the position of the user (e.g., `{{user1}}`, `{{user2}}`).
+ *
+ * @param {string} params.template - The template string containing placeholders for random user names.
+ * @param {number} params.length - The number of random user names to generate.
+ * @returns {string} The template string with placeholders replaced by random user names.
+ *
+ * @example
+ * // Given a template and a length
+ * const template = "Hello, {{user1}}! Meet {{user2}} and {{user3}}.";
+ * const length = 3;
+ *
+ * // Composing the random user string will result in:
+ * // "Hello, John! Meet Alice and Bob."
+ * const result = composeRandomUser({ template, length });
+ */
+export const composeRandomUser = (template: string, length: number) => {
+    const exampleNames = Array.from({ length }, () =>
+        uniqueNamesGenerator({ dictionaries: [names] })
+    );
+    let result = template;
+    for (let i = 0; i < exampleNames.length; i++) {
+        result = result.replaceAll(`{{user${i + 1}}}`, exampleNames[i]);
+    }
+
+    return result;
+};