import path from 'path';
import { fileURLToPath } from 'url';

import vfs from 'vinyl-fs';
import through from 'through2';
import glob from 'fast-glob';
import { rimraf } from 'rimraf';

const currentDir = path.dirname(fileURLToPath(import.meta.url));
const exampleDir = path.join(currentDir, 'examples');
const snippetsDir = path.join(currentDir, 'snippets', 'examples');
const extMap = {
    '.dart': 'dart',
    '.js': 'javascript',
    '.json': 'json',
    '.py': 'python',
    '.sh': 'bash',
    '.ts': 'typescript',
    '.yml': 'yaml',
};
const ignore = [
    `${exampleDir}/**/node_modules`,
    `${exampleDir}/**/package.json`,
    `${exampleDir}/**/package-lock.json`,
    `${exampleDir}/**/yarn.lock`,
    `${exampleDir}/**/*.test.*`,
    `${exampleDir}/**/*.spec.*`,
    `${exampleDir}/**/*.mdx`, // Ignore existing MDX files
];

const map = through.obj((file, enc, cb) => {
    const parsed = path.parse(file.path);
    const type = extMap[parsed.ext];

    if (!type) {
        throw new Error(`Unsupported file type: ${parsed.ext}`);
    }

    const tabname = type.charAt(0).toUpperCase() + type.slice(1);

    parsed.base = `${parsed.name}.mdx`;
    parsed.ext = '.mdx';

    file.path = path.format(parsed);
    file.contents = Buffer.from(
        `\`\`\`${type} ${tabname}\n${file.contents.toString('utf-8')}\n\`\`\``
    );

    cb(null, file);
});

async function main() {
    try {
        await rimraf(snippetsDir);

        const entries = await glob(`${exampleDir}/**/*`, { ignore });

        vfs
            .src(entries, { base: exampleDir })
            .pipe(map)
            .pipe(vfs.dest(snippetsDir));

    } catch (error) {
        console.error('Error processing examples:', error);
    }
}

main();


import express from 'express';

// This mimics the "ask_model" logic in Python.
function computeSum(input) {
  return {
    result: input.a + input.b,
  };
}

async function main() {
  const app = express();

  // Middleware to parse JSON bodies
  app.use(express.json());

  // POST endpoint to handle requests
  app.post('/sum', (req, res) => {
    try {
      // We expect an object with { a: number, b: number }
      const input = req.body;
      const output = computeSum(input);
      return res.status(200).json(output);
    } catch (err) {
      return res.status(400).json({ error: 'Invalid request', details: err });
    }
  });

  // Start the server
  const port = 8080;
  app.listen(port, () => {
    console.log(`Listening on http://localhost:${port}/`);
  });
}

// Run the main function
main().catch((err) => {
  console.error(err);
  process.exit(1);
});


import { RoomClient, websocketProtocol } from "meshagent-ts";

async function main() {
    try {
        // Define a unique room name and chose your participant name
        const roomName = "my-room";
        const participantName = "participant-name";

        // Document name (the extension identifies the schema)
        const path = "hello-world.document";

        // Establish communication channel using participant token
        const protocol = await websocketProtocol({
            roomName,
            participantName,
        });

        // Instantiate a new RoomClient for interacting with the room
        const room = new RoomClient({protocol});

        // Connect to the room
        await room.start();

        // Open our document
        const meshDocument = await room.sync.open(path);

        // Wait for the document to sync from the server
        await meshDocument.synchronized;

        // Append body with text
        meshDocument.root.createChildElement("body", {
            text: "hello world!"
        });

        // sleep 2 seconds
        await new Promise((resolve) => setTimeout(resolve, 2000));

        // Close the document 
        await room.sync.close(path);

    } catch (error) {
        console.error("Error:", error);
    }
}

main();



import { RoomClient, websocketProtocol } from 'meshagent-ts';

async function main() {
    try {
        const roomName = 'quickstart';
        const participantName = 'my user';

        // Document path in the MeshAgent environment
        const path = 'sample-agent.document';

        const protocol = await websocketProtocol({roomName, participantName});

        const room = new RoomClient({protocol});

        // Connect to the room (automatically creating it if it doesn't exist)
        await room.start();

        // Add Agents to the room
        await room.agents.call({
            name: 'meshagent.document-writer',
            url: 'https://api.meshagent.life/agents/meshagent.document-writer',
            arguments: { },
        });

        // Ask an agent to do some work in the document.
        // The "meshagent.document-writer" agent writes content to the document.
        await room.agents.ask({
            agentName: 'meshagent.document-writer',
            arguments: {
                path,
                prompt: 'write a paragraph about AI and how agents are shaping the future',
            },
        });

        console.log(
            'Take a look at it at',
            `https://studio.meshagent.com/projects/${projectId}/rooms/${roomName}?p=${path}`
        );

        // Always disconnect when done
        await room.disconnect();

    } catch (error) {
        console.error('Error:', error);
    }
}

main();



import { RoomClient, websocketProtocol } from 'meshagent-ts';

async function main() {
    try {
        const roomName = 'quickstart';
        const participantName = 'my user';

        const protocol = await websocketProtocol({ roomName, participantName });
        const room = new RoomClient({ protocol });

        // Connect to the room
        await room.start();

        // Document path in the MeshAgent environment
        const path = 'sample.document';

        // the document will be automatically created if it does not already exist
        // open the document and start synchronizing it
        const document = await room.sync.open(path, { create: true });

        // the document will be automatically created if it does not already exist
        // open the document and start synchronizing it
        document.root.createChildElement('body', { text: 'hello world!' });

        // Always disconnect when done
        console.log('Disconnecting from room...');

        // Close the document and stop synchronizing it
        await room.sync.close(path);

        // Dispose of the room to clean up resources
        room.dispose();

    } catch (error) {
        console.error('Error:', error);
    }
}

main();


import { RoomClient, websocketProtocol } from "meshagent-ts";

async function main() {
    try {
        // Define a unique room name and chose your participant name
        const roomName = "my-room";
        const participantName = "participant-name";

        // Initialize the communication protocol
        const protocol = await websocketProtocol({roomName, participantName});

        // Instantiate a new RoomClient for interacting with the room
        const room = new RoomClient({protocol});

        // Connect to the room
        await room.start();

        // Sleep for 5 seconds to allow the connection to establish
        await new Promise(resolve => setTimeout(resolve, 5000));

        room.dispose();

    } catch (error) {
        console.error("Error starting the room client:", error);
    }
}
main();


import {
  SchemaRegistry,
  SchemaRegistration,
  MeshSchema,
  ElementType,
  ChildProperty,
  ValueProperty,
} from 'meshagent';

// Define the schema
const sample = new MeshSchema({
  rootTagName: 'sample',
  elements: [
    new ElementType({
      tagName: 'sample',
      description: 'test',
      properties: [
        new ChildProperty({
          name: 'children',
          description: 'desc',
          childTagNames: ['child'],
        }),
      ],
    }),
    new ElementType({
      tagName: 'child',
      description: 'child',
      properties: [
        new ValueProperty({
          name: 'prop',
          description: 'desc',
          type: 'number',
        }),
      ],
    }),
  ],
});

// Main async function to run the server
async function main() {
  const server = new SchemaRegistry({
    schemas: [
      new SchemaRegistration({
        name: 'sample',
        schema: sample,
      }),
    ],
  });

  // Start the server
  await server.run();
}

// Entry point
if (require.main === module) {
  try {
    main();
  } catch (error) {
    console.error('Error:', error);
  }
}


import {
  MeshSchema,
  ElementType,
  ChildProperty,
  ValueProperty,
} from 'meshagent-ts';

// Create the schema
const schema = new MeshSchema({
  rootTagName: 'html',
  elements: [
    new ElementType({
      tagName: 'html',
      properties: [
        // A ChildProperty describes the type of children that an element allows.
        // There can be at most one child property for each element type, but
        // the child property can allow multiple types of child elements.
        new ChildProperty({
          name: 'children',
          childTagNames: ['body'],
        }),
      ],
    }),
    new ElementType({
      tagName: 'body',
      properties: [
        // Our body can only contain paragraph elements.
        new ChildProperty({
          name: 'children',
          childTagNames: ['p'],
        }),
      ],
    }),
    new ElementType({
      tagName: 'p',
      properties: [
        // A ValueProperty describes an attribute that contains a single value.
        new ValueProperty({
          name: 'class',
          type: 'string',
        }),
      ],
    }),
  ],
});



// Check existence
const exists = await room.storage.exists("example.txt");
if (!exists) {
    // Create it
    const handle = await room.storage.open("example.txt");
    await room.storage.write(handle, new TextEncoder().encode("Hello, Storage!"));
    await room.storage.close(handle);
}

// Download content
const response = await room.storage.download("example.txt");
console.log("Downloaded content:", response.data);

// Delete it
await room.storage.delete("example.txt");


// index.js
const express = require('express');
const bodyParser = require('body-parser');
const { websocketRoomUrl, participantToken } = require('meshagent');

const app = express();

app.use(bodyParser.json());

// Example of user "database"
const users = [
  {
    id: 1,
    username: 'john',
    password: 'password123'
  },
  {
    id: 2,
    username: 'jane',
    password: 'mypassword'
  },
];

/**
 * POST /authorize-meshagent-user
 *
 * This route simulates user authentication. 
 *
 * On successful validation of username and password,
 * it returns a JWT token for the user.
 */
app.post('/authorize-user', (req, res) => {
  const {
      username,
      password,
      roomName,
      participantName,
  } = req.body;

  // Find a matching user in our "database"
  const user = users.find((u) => u.username === username && u.password === password);

  if (!user) {
    return res.status(401).json({ error: 'Invalid credentials' });
  }

  const url = websocketRoomUrl({roomName});
  const jwt = participantToken({participantName, roomName});

  return res.json({url, jwt});
});

// Start the Express server
const PORT = process.env.PORT || 3000;
app.listen(PORT, () => {
  console.log(`Client service running on http://localhost:${PORT}`);
});



Documentation

Meshagent Setup

Installing client

Set Environment Variables

Let’s connect to a room

How Rooms Work

Documentation

​Installing client

​Set Environment Variables

​Let’s connect to a room

​How Rooms Work

Installing client

Set Environment Variables

Let’s connect to a room

How Rooms Work