+ {JSON.stringify(Array.from(states.entries()), null, 2)}
+
+
+ {content || '(empty fragment)'}
+
+ {error.message}
+ + Set your artifact path to simulate being in an editor. Open multiple tabs to test awareness + visibility. +
+
+ {rawState}
+
+ + Open this page in two browser tabs. Edit different artifacts and verify cursors do NOT leak between + them. +
+ ++ Both editors show the same artifact. Open in two browser tabs to verify cursors are visible across + clients. +
+ +this is a code block in python in a bulleted list')
+
+ await applyEdit({
+ agent: createApplyAgent('in python', '', true),
+ oldString: 'in python',
+ newString: '',
+ replaceAll: true,
+ })
+ logToolCallCount('removing nested inline code text', toolCalls)
+
+ const codeContents = codeTagContents(fragment.toJSON())
+ expect(codeContents).toContain('this is a code block')
+ expect(codeContents).not.toContain('this is a code block in python')
+ expect(codeContents.some((content) => content.includes('in python'))).toBe(false)
+ expect(toolCalls.length).toBeGreaterThan(0)
+ })
+
+ test('edits text inside a nested ordered list item', async () => {
+ expect(fragment.toJSON()).toContain('(.*?)<\/code>/g)].map((match) => match[1] ?? '')
+}
+
+async function applyEdit(options: { agent: Agent; oldString: string; newString: string; replaceAll?: boolean }) {
+ const run = options.agent.run({
+ state: startState([
+ userMessage(
+ userInstructionForYXmlFragmentEditorAgent({
+ oldString: options.oldString,
+ newString: options.newString,
+ replaceAll: options.replaceAll,
+ }),
+ ),
+ ]),
+ })
+
+ await expect(run.result).resolves.not.toBeUndefined()
+}
+
+function createComplexDocumentNodes(): Array {
+ return [
+ element('heading', { level: '1' }, [
+ element(
+ 'link',
+ {
+ class: 'null',
+ href: 'http://README.md',
+ rel: 'noopener noreferrer nofollow',
+ target: '_blank',
+ title: 'null',
+ },
+ [text('README.md')],
+ ),
+ text(' '),
+ ]),
+ element('paragraph', {}, [text('This is an example file')]),
+ element('paragraph'),
+ element('paragraph'),
+ list('bulletList', ['this ', 'is a ', 'bulleted list']),
+ element('paragraph'),
+ element('paragraph'),
+ list('orderedList', ['This ', 'is ', 'a', 'numbered ', 'list'], { start: '1' }),
+ element('paragraph'),
+ element('codeBlock', {}, [text('this is a code block')]),
+ element('paragraph'),
+ element('paragraph'),
+ element('paragraph'),
+ element('paragraph', {}, [element('bold', {}, [text("i don't like code blocks")])]),
+ element('paragraph'),
+ element('codeBlock', { language: 'typescript' }, [text('this is a typescript code block')]),
+ element('paragraph'),
+ element('paragraph'),
+ element('bulletList', {}, [
+ element('listItem', {}, [
+ element('paragraph', {}, [
+ element('code', {}, [text('this is a code block in python')]),
+ text(' in a bulleted list'),
+ ]),
+ ]),
+ element('listItem', {}, [element('paragraph', {}, [text('this is a bulleted list item ')])]),
+ ]),
+ element('paragraph'),
+ element('paragraph'),
+ element('paragraph', {}, [
+ text('This '),
+ element('bold', {}, [text('is a bold')]),
+ text(' and '),
+ element('italic', {}, [text('italic')]),
+ text(' item in a paragraph'),
+ ]),
+ element('paragraph'),
+ ]
+}
+
+function list(nodeName: 'bulletList' | 'orderedList', items: string[], attributes: Record = {}) {
+ return element(
+ nodeName,
+ attributes,
+ items.map((item) => element('listItem', {}, [element('paragraph', {}, [text(item)])])),
+ )
+}
+
+function element(
+ name: string,
+ attributes: Record = {},
+ children: Array = [],
+) {
+ const node = new Y.XmlElement(name)
+ for (const [key, value] of Object.entries(attributes)) node.setAttribute(key, value)
+ if (children.length > 0) node.insert(0, children)
+ return node
+}
+
+function text(value: string) {
+ const node = new Y.XmlText()
+ node.insert(0, value)
+ return node
+}
diff --git a/packages/yjs-rich-markdown/test/artifact-read.test.ts b/packages/yjs-rich-markdown/test/artifact-read.test.ts
new file mode 100644
index 0000000..8a2a0dd
--- /dev/null
+++ b/packages/yjs-rich-markdown/test/artifact-read.test.ts
@@ -0,0 +1,57 @@
+import { describe, expect, test } from 'bun:test'
+import * as Y from 'yjs'
+import { artifactFragment, RichMarkdownArtifactStore, readArtifact } from '../src'
+
+function syncDoc(source: Y.Doc, target: Y.Doc): void {
+ Y.applyUpdate(target, Y.encodeStateAsUpdate(source))
+}
+
+describe('readArtifact', () => {
+ test('returns the XML fragment string for an artifact path', () => {
+ const doc = new Y.Doc()
+ const store = new RichMarkdownArtifactStore(doc)
+
+ store.createArtifact('/artifacts/plan.md')
+ const heading = new Y.XmlElement('heading')
+ heading.setAttribute('level', '1')
+ heading.insert(0, [new Y.XmlText('Plan')])
+ artifactFragment(doc, '/artifacts/plan.md').insert(0, [heading])
+
+ expect(readArtifact(doc, '/artifacts/plan.md')).toBe('Plan ')
+ })
+
+ test('reads only the requested path-keyed fragment', () => {
+ const doc = new Y.Doc()
+ const store = new RichMarkdownArtifactStore(doc)
+
+ store.createArtifact('/artifacts/a.md')
+ store.createArtifact('/artifacts/b.md')
+ artifactFragment(doc, '/artifacts/a.md').insert(0, [new Y.XmlText('Artifact A')])
+ artifactFragment(doc, '/artifacts/b.md').insert(0, [new Y.XmlText('Artifact B')])
+
+ expect(readArtifact(doc, '/artifacts/a.md')).toBe('Artifact A')
+ expect(readArtifact(doc, '/artifacts/b.md')).toBe('Artifact B')
+ })
+
+ test('returns an empty string for an empty artifact fragment', () => {
+ const doc = new Y.Doc()
+ const store = new RichMarkdownArtifactStore(doc)
+
+ store.createArtifact('/artifacts/empty.md')
+
+ expect(readArtifact(doc, '/artifacts/empty.md')).toBe('')
+ })
+
+ test('returns synced fragment content after a Yjs update round trip', () => {
+ const doc1 = new Y.Doc()
+ const doc2 = new Y.Doc()
+ const store1 = new RichMarkdownArtifactStore(doc1)
+
+ store1.createArtifact('/artifacts/synced.md')
+ artifactFragment(doc1, '/artifacts/synced.md').insert(0, [new Y.XmlText('Synced content')])
+
+ syncDoc(doc1, doc2)
+
+ expect(readArtifact(doc2, '/artifacts/synced.md')).toBe('Synced content')
+ })
+})
diff --git a/packages/yjs-rich-markdown/test/fragment-isolation.test.ts b/packages/yjs-rich-markdown/test/fragment-isolation.test.ts
new file mode 100644
index 0000000..8f7b12e
--- /dev/null
+++ b/packages/yjs-rich-markdown/test/fragment-isolation.test.ts
@@ -0,0 +1,31 @@
+import { describe, expect, test } from 'bun:test'
+import * as Y from 'yjs'
+import { artifactFragment, artifactFragmentName, RichMarkdownArtifactStore } from '../src'
+
+function syncDoc(source: Y.Doc, target: Y.Doc): void {
+ Y.applyUpdate(target, Y.encodeStateAsUpdate(source))
+}
+
+describe('rich markdown artifact fragments', () => {
+ test('stores multiple artifact fragments in one Y.Doc without cross-contamination', () => {
+ const doc1 = new Y.Doc()
+ const doc2 = new Y.Doc()
+ const store1 = new RichMarkdownArtifactStore(doc1)
+ const store2 = new RichMarkdownArtifactStore(doc2)
+
+ store1.createArtifact('/artifacts/a.md', { now: 1, title: 'A' })
+ store1.createArtifact('/artifacts/b.md', { now: 2, title: 'B' })
+
+ artifactFragment(doc1, '/artifacts/a.md').insert(0, [new Y.XmlText('Artifact A')])
+ artifactFragment(doc1, '/artifacts/b.md').insert(0, [new Y.XmlText('Artifact B')])
+
+ syncDoc(doc1, doc2)
+
+ expect(store2.listArtifacts().map((artifact) => artifact.path)).toEqual(['/artifacts/a.md', '/artifacts/b.md'])
+ expect(artifactFragment(doc2, '/artifacts/a.md').toString()).toBe('Artifact A')
+ expect(artifactFragment(doc2, '/artifacts/b.md').toString()).toBe('Artifact B')
+ expect(doc2.getXmlFragment(artifactFragmentName('/artifacts/a.md'))).not.toBe(
+ doc2.getXmlFragment(artifactFragmentName('/artifacts/b.md')),
+ )
+ })
+})
diff --git a/packages/yjs-rich-markdown/test/markdown-yxml-shapes.test.ts b/packages/yjs-rich-markdown/test/markdown-yxml-shapes.test.ts
new file mode 100644
index 0000000..49ca6f2
--- /dev/null
+++ b/packages/yjs-rich-markdown/test/markdown-yxml-shapes.test.ts
@@ -0,0 +1,74 @@
+import { describe, expect, test } from 'bun:test'
+import * as Y from 'yjs'
+import { RichMarkdownArtifactStore, writeArtifactMarkdown } from '../src'
+
+function xmlFor(markdown: string): string {
+ const doc = new Y.Doc()
+ const store = new RichMarkdownArtifactStore(doc)
+ const path = '/artifacts/shapes.md'
+ store.createArtifact(path)
+ writeArtifactMarkdown(doc, path, markdown)
+ return store.getFragment(path).toString()
+}
+
+describe('Markdown to YXml shapes', () => {
+ test('headings', () => {
+ expect(xmlFor('# H1\n\n## H2\n\n### H3')).toBe(
+ 'H1 H2 H3 ',
+ )
+ })
+
+ test('paragraph with inline marks', () => {
+ expect(xmlFor('Plain **bold** *italic* `code` [link](https://example.com).')).toBe(
+ 'Plain bold italic code link. ',
+ )
+ })
+
+ test('unordered and ordered lists', () => {
+ expect(xmlFor('- First\n- Second\n\n1. One\n2. Two')).toBe(
+ 'First Second One Two Parent Child Quote line
')
+ })
+
+ test('horizontal rule', () => {
+ expect(xmlFor('Before\n\n---\n\nAfter')).toBe(
+ 'Before After ',
+ )
+ })
+
+ test('hard break inside paragraph', () => {
+ expect(xmlFor('First line\\\nSecond line')).toBe(
+ 'First line ',
+ )
+ })
+
+ test('single-line fenced code block', () => {
+ expect(xmlFor('```ts\nconst value = 1\n```')).toBe('const value = 1 ')
+ })
+
+ test('multi-line fenced code block', () => {
+ expect(xmlFor('```ts\nconst value = 1\nconsole.log(value)\n```')).toBe(
+ 'const value = 1\nconsole.log(value) ',
+ )
+ })
+
+ test('indented code block', () => {
+ expect(xmlFor(' const value = 1\n console.log(value)')).toBe(
+ 'const value = 1\nconsole.log(value) ',
+ )
+ })
+
+ test('strikethrough', () => {
+ expect(xmlFor('~~deleted~~')).toBe('deletedPlan This is bold and useful . ',
+ )
+ expect(readArtifactMarkdown(doc, '/artifacts/plan.md')).toBe('# Plan\n\nThis is **bold** and *useful*.')
+ })
+
+ test('round trips representative markdown blocks and marks', () => {
+ const doc = new Y.Doc()
+ const store = new RichMarkdownArtifactStore(doc)
+ const markdown = [
+ '# Title',
+ '',
+ 'Paragraph with **bold**, *italic*, `code`, and [a link](https://example.com).',
+ '',
+ '- First',
+ '- Second',
+ '',
+ '1. One',
+ '2. Two',
+ '',
+ '> A quote',
+ '',
+ '```ts',
+ 'const value = 1',
+ '```',
+ ].join('\n')
+
+ store.createArtifact('/artifacts/rich.md')
+ writeArtifactMarkdown(doc, '/artifacts/rich.md', markdown)
+
+ expect(readArtifactMarkdown(doc, '/artifacts/rich.md')).toBe(markdown)
+ })
+
+ test('keeps markdown writes isolated by artifact path', () => {
+ const doc = new Y.Doc()
+ const store = new RichMarkdownArtifactStore(doc)
+
+ store.createArtifact('/artifacts/a.md')
+ store.createArtifact('/artifacts/b.md')
+ writeArtifactMarkdown(doc, '/artifacts/a.md', '# A')
+ writeArtifactMarkdown(doc, '/artifacts/b.md', '# B')
+
+ expect(readArtifactMarkdown(doc, '/artifacts/a.md')).toBe('# A')
+ expect(readArtifactMarkdown(doc, '/artifacts/b.md')).toBe('# B')
+ })
+
+ test('reads markdown after a Yjs update sync round trip', () => {
+ const doc1 = new Y.Doc()
+ const doc2 = new Y.Doc()
+ const store1 = new RichMarkdownArtifactStore(doc1)
+
+ store1.createArtifact('/artifacts/synced.md')
+ writeArtifactMarkdown(doc1, '/artifacts/synced.md', '## Synced\n\nShared content.')
+ syncDoc(doc1, doc2)
+
+ expect(readArtifactMarkdown(doc2, '/artifacts/synced.md')).toBe('## Synced\n\nShared content.')
+ })
+
+ test('write replaces existing fragment content from markdown', () => {
+ const doc = new Y.Doc()
+ const store = new RichMarkdownArtifactStore(doc)
+
+ store.createArtifact('/artifacts/rewrite.md')
+ writeArtifactMarkdown(doc, '/artifacts/rewrite.md', '# Old')
+ writeArtifactMarkdown(doc, '/artifacts/rewrite.md', '# New\n\nReplacement.')
+
+ expect(readArtifactMarkdown(doc, '/artifacts/rewrite.md')).toBe('# New\n\nReplacement.')
+ expect(store.getFragment('/artifacts/rewrite.md').toString()).toBe(
+ 'New Replacement. ',
+ )
+ })
+})
diff --git a/packages/yjs-rich-markdown/test/quickjs-code-mode-tool.test.ts b/packages/yjs-rich-markdown/test/quickjs-code-mode-tool.test.ts
new file mode 100644
index 0000000..cdab46b
--- /dev/null
+++ b/packages/yjs-rich-markdown/test/quickjs-code-mode-tool.test.ts
@@ -0,0 +1,56 @@
+import { beforeEach, describe, expect, test } from 'bun:test'
+import type { ToolContext } from '@humanlayer/agentlayer-core'
+import dedent from 'dedent'
+import * as Y from 'yjs'
+import { createCodeModeYXmlEditorTool } from '../src/tools'
+
+describe('QuickJS Code Mode Tool Tests', async () => {
+ let doc: Y.Doc
+ let fragment: Y.XmlFragment
+ let root: Y.XmlElement
+
+ beforeEach(() => {
+ doc = new Y.Doc()
+ fragment = doc.getXmlFragment('fragment')
+ root = new Y.XmlElement('root')
+ fragment.insert(0, [root])
+ expect(fragment.toJSON()).toEqual(' = []): Y.XmlElement {
+ const node = new Y.XmlElement(nodeName)
+ if (children.length > 0) node.insert(0, children)
+ return node
+}
+
+function jsonFor(fragment: Y.XmlFragment): JSONContent {
+ return yXmlFragmentToProsemirrorJSON(fragment) as JSONContent
+}
+
+describe('invalid or lossy YXml structures', () => {
+ test('unsupported block node type survives YXml but is dropped during markdown serialization', () => {
+ const doc = new Y.Doc()
+ const fragment = doc.getXmlFragment('invalid')
+ fragment.insert(0, [element('madeupblock', [text('Unknown block')])])
+
+ expect(fragment.toString()).toBe('Unknown block ')
+ expect(jsonFor(fragment)).toEqual({
+ type: 'doc',
+ content: [{ type: 'madeupblock', content: [{ type: 'text', text: 'Unknown block' }] }],
+ })
+ expect(tiptapJsonToMarkdown(jsonFor(fragment))).toBe('')
+ })
+
+ test('unsupported nested node type survives YXml but is dropped during markdown serialization', () => {
+ const doc = new Y.Doc()
+ const fragment = doc.getXmlFragment('invalid')
+ fragment.insert(0, [
+ element('paragraph', [text('Before '), element('custommark', [text('marked')]), text(' after')]),
+ ])
+
+ expect(fragment.toString()).toBe('Before marked after ')
+ expect(jsonFor(fragment)).toEqual({
+ type: 'doc',
+ content: [
+ {
+ type: 'paragraph',
+ content: [
+ { type: 'text', text: 'Before ' },
+ { type: 'custommark', content: [{ type: 'text', text: 'marked' }] },
+ { type: 'text', text: ' after' },
+ ],
+ },
+ ],
+ })
+ expect(tiptapJsonToMarkdown(jsonFor(fragment))).toBe('Before after')
+ })
+
+ test('schema-invalid paragraph nesting converts to JSON and flattens during markdown serialization', () => {
+ const doc = new Y.Doc()
+ const fragment = doc.getXmlFragment('invalid')
+ fragment.insert(0, [element('paragraph', [element('paragraph', [text('Nested paragraph')])])])
+
+ expect(fragment.toString()).toBe('Nested paragraph Original Heading ')
+
+ const first = proxy.get({ index: 0 })
+ proxy.insertAfter({
+ ref: first,
+ content: [
+ {
+ kind: 'element',
+ nodeName: 'paragraph',
+ children: [{ kind: 'text', text: 'Added paragraph.' }],
+ },
+ ],
+ })
+
+ expect(proxy.toString({})).toBe(
+ 'Original Heading Added paragraph. Original paragraph. Use scoped NodeRefs. Validate after mutation. Remove me. Implementation Notes ')
+ expect(proxy.toString({})).toContain(
+ 'The agent edits through bindings instead of direct Yjs objects. ',
+ )
+ expect(proxy.toString({})).toContain(
+ 'Bindings keep generated code sandbox-safe.
',
+ )
+ expect(proxy.toString({})).toContain('const root = bindings.root()\nconst xml = bindings.toString({}) ',
+ )
+ })
+
+ test('add a bullet to an existing list', () => {
+ const proxy = createPromptExampleProxy()
+
+ const rootChildren = proxy.children({})
+ const list = rootChildren.find((node) => proxy.summary({ node }).nodeName === 'bulletList')
+ if (!list) throw new Error('Could not find a bullet list')
+
+ proxy.append({
+ parent: list,
+ content: [
+ {
+ kind: 'element',
+ nodeName: 'listItem',
+ children: [
+ {
+ kind: 'element',
+ nodeName: 'paragraph',
+ children: [{ kind: 'text', text: 'New bullet' }],
+ },
+ ],
+ },
+ ],
+ })
+
+ expect(proxy.toString({})).toContain(
+ 'Use scoped NodeRefs. Validate after mutation. New bullet Original Heading ')
+ })
+
+ test('erase a section', () => {
+ const proxy = createPromptExampleProxy()
+
+ const section = proxy.children({}).find((node) => {
+ const summary = proxy.summary({ node })
+ return summary.nodeName === 'section' && summary.attributes?.id === 'obsolete'
+ })
+ if (!section) throw new Error('Could not find obsolete section')
+
+ proxy.remove({ node: section })
+
+ expect(proxy.toString({})).not.toContain('')
+ expect(proxy.toString({})).toBe(
+ 'Original Heading Original paragraph. Use scoped NodeRefs. Validate after mutation. Validate after mutation. this is an example this is a nested example This is another example ',
+ )
+ })
+
+ test('wrap one word inside text that already lives under an inline mark', () => {
+ const proxy = createInlineMarkedExampleProxy()
+
+ const paragraph = proxy.children({}).find((node) => proxy.summary({ node }).nodeName === 'paragraph')
+ if (!paragraph) throw new Error('Could not find paragraph')
+ const italic = proxy.children({ node: paragraph }).find((node) => proxy.summary({ node }).nodeName === 'italic')
+ if (!italic) throw new Error('Could not find italic mark')
+ const italicTextNode = proxy.children({ node: italic }).find((node) => proxy.summary({ node }).kind === 'text')
+ if (!italicTextNode) throw new Error('Could not find italic text node')
+
+ const italicText = proxy.text({ node: italicTextNode })
+ const start = italicText.indexOf('example')
+ if (start < 0) throw new Error('Could not find target word')
+
+ proxy.wrapTextRange({
+ node: italicTextNode,
+ start,
+ end: start + 'example'.length,
+ wrapper: { nodeName: 'bold' },
+ })
+
+ expect(proxy.toString({})).toBe(
+ 'Before nested example text after ',
+ )
+ })
+})
+
+function createPromptExampleProxy(): YXmlProxyBindings {
+ const doc = new Y.Doc()
+ const fragment = doc.getXmlFragment('artifact')
+ seedPromptExampleDocument(fragment)
+ return new YXmlProxyBindings(fragment)
+}
+
+function createInterleavedExampleProxy(): YXmlProxyBindings {
+ const doc = new Y.Doc()
+ const fragment = doc.getXmlFragment('artifact')
+ const example = new Y.XmlElement('example')
+ example.insert(0, [
+ text('this is an example '),
+ createElement('nestedExample', [text('this is a nested example')]),
+ text(' This is another example'),
+ ])
+ fragment.insert(0, [example])
+ return new YXmlProxyBindings(fragment)
+}
+
+function createInlineMarkedExampleProxy(): YXmlProxyBindings {
+ const doc = new Y.Doc()
+ const fragment = doc.getXmlFragment('artifact')
+ const paragraph = new Y.XmlElement('paragraph')
+ paragraph.insert(0, [text('Before '), createElement('italic', [text('nested example text')]), text(' after')])
+ fragment.insert(0, [paragraph])
+ return new YXmlProxyBindings(fragment)
+}
+
+function seedPromptExampleDocument(fragment: Y.XmlFragment): void {
+ const heading = new Y.XmlElement('heading')
+ heading.setAttribute('level', '2')
+ heading.insert(0, [text('Original Heading')])
+
+ const paragraph = new Y.XmlElement('paragraph')
+ paragraph.insert(0, [text('Original paragraph.')])
+
+ const list = new Y.XmlElement('bulletList')
+ list.insert(0, [listItem('Use scoped NodeRefs.'), listItem('Validate after mutation.')])
+
+ const section = new Y.XmlElement('section')
+ section.setAttribute('id', 'obsolete')
+ const sectionParagraph = new Y.XmlElement('paragraph')
+ sectionParagraph.insert(0, [text('Remove me.')])
+ section.insert(0, [sectionParagraph])
+
+ fragment.insert(0, [heading, paragraph, list, section])
+}
+
+function listItem(value: string): Y.XmlElement {
+ const item = new Y.XmlElement('listItem')
+ const paragraph = new Y.XmlElement('paragraph')
+ paragraph.insert(0, [text(value)])
+ item.insert(0, [paragraph])
+ return item
+}
+
+function createElement(name: string, children: Array): Y.XmlElement {
+ const element = new Y.XmlElement(name)
+ element.insert(0, children)
+ return element
+}
+
+function text(value: string): Y.XmlText {
+ const xmlText = new Y.XmlText()
+ xmlText.insert(0, value)
+ return xmlText
+}
diff --git a/packages/yjs-rich-markdown/test/yxml-proxy-quickjs.test.ts b/packages/yjs-rich-markdown/test/yxml-proxy-quickjs.test.ts
new file mode 100644
index 0000000..753f9ae
--- /dev/null
+++ b/packages/yjs-rich-markdown/test/yxml-proxy-quickjs.test.ts
@@ -0,0 +1,245 @@
+import { beforeEach, describe, expect, test } from 'bun:test'
+import { withQuickJsMode } from '@humanlayer/quickjs-exec'
+import * as Y from 'yjs'
+import { YXmlProxyBindings } from '../src'
+
+describe('Y.XMLFragment Proxy tests', () => {
+ describe('Operations through proxy should propagate to document', () => {
+ let doc: Y.Doc
+ let fragment: Y.XmlFragment
+ let proxy: YXmlProxyBindings
+ let root: Y.XmlElement
+
+ beforeEach(() => {
+ doc = new Y.Doc()
+ fragment = doc.getXmlFragment('artifact')
+ proxy = new YXmlProxyBindings(fragment)
+ root = new Y.XmlElement('root')
+ })
+
+ test('Adding fragment should succeed', () => {
+ fragment.insert(0, [root])
+ expect(fragment.toJSON()).toEqual('(`
+ const fragmentRef = bindings.root()
+ const rootRef = bindings.get({ node: fragmentRef, index: 0 })
+ bindings.append({
+ parent: rootRef,
+ content: [{ kind: 'element', nodeName: 'parent' }],
+ })
+ `)
+ })
+ expect(fragment.toJSON()).toEqual('(`
+ const fragmentRef = bindings.root()
+ const rootRef = bindings.get({ node: fragmentRef, index: 0 })
+ const parentRef = bindings.get({ node: rootRef, index: 0 })
+ bindings.append({
+ parent: parentRef,
+ content: [{ kind: 'element', nodeName: 'child' }],
+ })
+ `)
+ })
+
+ expect(fragment.toJSON()).toEqual('Alpha Intro First bullet Second bullet Beta intro Nested quote
Document Title Alpha Intro First bullet Second bullet Beta intro Nested quote
Second bullet Inserted after second bullet paragraph Nested quote Quote follow-up
',
+ )
+
+ proxy.prepend({
+ parent: betaSection,
+ content: [
+ {
+ kind: 'element',
+ nodeName: 'heading',
+ attributes: { level: '3' },
+ children: [{ kind: 'text', text: 'Beta heading' }],
+ },
+ ],
+ })
+ expect(proxy.toString({ node: betaSection })).toEqual(
+ 'Beta heading Beta intro Nested quote Quote follow-up
Document Title Alpha Intro First bullet Second bullet Inserted after second bullet paragraph Beta heading Beta intro Nested quote Quote follow-up
,
+ children: Array,
+): Y.XmlElement {
+ const element = new Y.XmlElement(name)
+ for (const [key, value] of Object.entries(attributes)) {
+ element.setAttribute(key, value)
+ }
+ if (children.length > 0) element.insert(0, children)
+ return element
+}
+
+function createText(value: string): Y.XmlText {
+ const text = new Y.XmlText()
+ text.insert(0, value)
+ return text
+}
diff --git a/packages/yjs-rich-markdown/test/yxml-proxy.test.ts b/packages/yjs-rich-markdown/test/yxml-proxy.test.ts
new file mode 100644
index 0000000..83aa3bb
--- /dev/null
+++ b/packages/yjs-rich-markdown/test/yxml-proxy.test.ts
@@ -0,0 +1,712 @@
+import { describe, expect, test } from 'bun:test'
+import * as Y from 'yjs'
+import {
+ DetachedYXmlNodeRefError,
+ UnknownYXmlNodeRefError,
+ YXmlChildIndexOutOfBoundsError,
+ YXmlInvalidNodeKindForOperationError,
+ YXmlNodeRefKindMismatchError,
+ YXmlProxyBindings,
+ YXmlRootOperationError,
+ YXmlTextRangeOutOfBoundsError,
+} from '../src'
+
+describe('YXml proxy', () => {
+ test('appends XML elements and nested children', () => {
+ const doc = new Y.Doc()
+ const fragment = doc.getXmlFragment('artifact')
+ const proxy = new YXmlProxyBindings(fragment)
+
+ const inserted = proxy.append({
+ content: [
+ {
+ kind: 'element',
+ nodeName: 'section',
+ attributes: { id: 'intro' },
+ children: [
+ {
+ kind: 'element',
+ nodeName: 'heading',
+ attributes: { level: '2' },
+ children: [{ kind: 'text', text: 'Intro' }],
+ },
+ {
+ kind: 'element',
+ nodeName: 'paragraph',
+ children: [{ kind: 'text', text: 'Nested content works.' }],
+ },
+ ],
+ },
+ ],
+ })
+
+ expect(inserted).toEqual([{ id: expect.any(String), kind: 'element' }])
+ expect(proxy.toString()).toBe(
+ 'Intro Nested content works. Via bindings ')
+ expect(proxy.toString()).toBe('Via bindings ')
+ })
+
+ test('inserts before and after refs without passing parent', () => {
+ const doc = new Y.Doc()
+ const fragment = doc.getXmlFragment('artifact')
+ const proxy = new YXmlProxyBindings(fragment)
+
+ const [middle] = proxy.append({
+ content: [{ kind: 'element', nodeName: 'paragraph', children: [{ kind: 'text', text: 'Middle' }] }],
+ })
+ if (!middle) throw new Error('Expected middle node')
+
+ proxy.insertBefore({
+ ref: middle,
+ content: [{ kind: 'element', nodeName: 'paragraph', children: [{ kind: 'text', text: 'Before' }] }],
+ })
+ proxy.insertAfter({
+ ref: middle,
+ content: [{ kind: 'element', nodeName: 'paragraph', children: [{ kind: 'text', text: 'After' }] }],
+ })
+
+ expect(proxy.toString()).toBe(
+ 'Before Middle After ',
+ )
+ })
+
+ test('appends nested content inside an element parent', () => {
+ const doc = new Y.Doc()
+ const fragment = doc.getXmlFragment('artifact')
+ const proxy = new YXmlProxyBindings(fragment)
+
+ const [list] = proxy.append({ content: [{ kind: 'element', nodeName: 'bulletList' }] })
+ if (!list) throw new Error('Expected list node')
+
+ proxy.append({
+ parent: list,
+ content: [
+ {
+ kind: 'element',
+ nodeName: 'listItem',
+ children: [{ kind: 'element', nodeName: 'paragraph', children: [{ kind: 'text', text: 'First' }] }],
+ },
+ {
+ kind: 'element',
+ nodeName: 'listItem',
+ children: [
+ { kind: 'element', nodeName: 'paragraph', children: [{ kind: 'text', text: 'Second' }] },
+ ],
+ },
+ ],
+ })
+
+ expect(proxy.toString()).toBe(
+ 'First Second Actually, this is an example this is a nested example another example ',
+ )
+ })
+
+ test('splits a text node into interleaved siblings', () => {
+ const doc = new Y.Doc()
+ const fragment = doc.getXmlFragment('artifact')
+ const proxy = new YXmlProxyBindings(fragment)
+
+ const [example] = proxy.append({
+ content: [
+ { kind: 'element', nodeName: 'example', children: [{ kind: 'text', text: 'this is an example' }] },
+ ],
+ })
+ if (!example) throw new Error('Expected example node')
+ const [textNode] = proxy.children({ node: example })
+ if (!textNode) throw new Error('Expected text node')
+
+ const split = proxy.splitText({ node: textNode, index: 8 })
+
+ expect(proxy.text({ node: split.left })).toBe('this is ')
+ expect(proxy.text({ node: split.right })).toBe('an example')
+ expect(proxy.children({ node: example })).toEqual([split.left, split.right])
+ })
+
+ test('wraps only part of a text node while preserving interleaved siblings', () => {
+ const doc = new Y.Doc()
+ const fragment = doc.getXmlFragment('artifact')
+ const proxy = new YXmlProxyBindings(fragment)
+
+ const [example] = proxy.append({
+ content: [
+ {
+ kind: 'element',
+ nodeName: 'example',
+ children: [
+ { kind: 'text', text: 'this is an example ' },
+ {
+ kind: 'element',
+ nodeName: 'nestedExample',
+ children: [{ kind: 'text', text: 'this is a nested example' }],
+ },
+ { kind: 'text', text: ' This is another example' },
+ ],
+ },
+ ],
+ })
+ if (!example) throw new Error('Expected example node')
+ const [firstText, nestedExample, secondText] = proxy.children({ node: example })
+ if (!firstText || !nestedExample || !secondText) throw new Error('Expected interleaved children')
+
+ const wrapped = proxy.wrapTextRange({ node: firstText, start: 11, end: 18, wrapper: { nodeName: 'bold' } })
+
+ const children = proxy.children({ node: example })
+ const [beforeText, boldNode, afterText, sameNestedExample, sameSecondText] = children
+ if (!beforeText || !boldNode || !afterText || !sameNestedExample || !sameSecondText)
+ throw new Error('Expected wrapped children')
+
+ expect(proxy.text({ node: beforeText })).toBe('this is an ')
+ expect(proxy.toString({ node: boldNode })).toBe('example ')
+ expect(proxy.text({ node: afterText })).toBe(' ')
+ expect(sameNestedExample).toEqual(nestedExample)
+ expect(sameSecondText).toEqual(secondText)
+ expect(wrapped.wrapper).toEqual(boldNode)
+ expect(proxy.toString()).toBe(
+ 'this is an example this is a nested example This is another example ',
+ )
+ })
+
+ test('wraps part of text inside an already marked inline element', () => {
+ const doc = new Y.Doc()
+ const fragment = doc.getXmlFragment('artifact')
+ const proxy = new YXmlProxyBindings(fragment)
+
+ const [paragraph] = proxy.append({
+ content: [
+ {
+ kind: 'element',
+ nodeName: 'paragraph',
+ children: [
+ { kind: 'text', text: 'prefix ' },
+ {
+ kind: 'element',
+ nodeName: 'italic',
+ children: [{ kind: 'text', text: 'nested example text' }],
+ },
+ { kind: 'text', text: ' suffix' },
+ ],
+ },
+ ],
+ })
+ if (!paragraph) throw new Error('Expected paragraph node')
+
+ const [, italic, suffix] = proxy.children({ node: paragraph })
+ if (!italic || !suffix) throw new Error('Expected italic and suffix nodes')
+ const [italicText] = proxy.children({ node: italic })
+ if (!italicText) throw new Error('Expected italic text node')
+
+ const wrapped = proxy.wrapTextRange({
+ node: italicText,
+ start: 7,
+ end: 14,
+ wrapper: { nodeName: 'bold' },
+ })
+
+ const italicChildren = proxy.children({ node: italic })
+ const [beforeText, boldNode, afterText] = italicChildren
+ if (!beforeText || !boldNode || !afterText) throw new Error('Expected split italic children')
+
+ expect(proxy.text({ node: beforeText })).toBe('nested ')
+ expect(proxy.toString({ node: boldNode })).toBe('example ')
+ expect(proxy.text({ node: afterText })).toBe(' text')
+ expect(wrapped.wrapper).toEqual(boldNode)
+ expect(proxy.toString({ node: italic })).toBe('nested example text ')
+ expect(proxy.text({ node: suffix })).toBe(' suffix')
+ expect(proxy.toString()).toBe(
+ 'prefix nested example text suffix ',
+ )
+ })
+
+ test('can combine splitText and wrapTextRange inside an existing inline mark', () => {
+ const doc = new Y.Doc()
+ const fragment = doc.getXmlFragment('artifact')
+ const proxy = new YXmlProxyBindings(fragment)
+
+ const [paragraph] = proxy.append({
+ content: [
+ {
+ kind: 'element',
+ nodeName: 'paragraph',
+ children: [
+ { kind: 'element', nodeName: 'italic', children: [{ kind: 'text', text: 'alpha beta gamma' }] },
+ ],
+ },
+ ],
+ })
+ if (!paragraph) throw new Error('Expected paragraph node')
+
+ const [italic] = proxy.children({ node: paragraph })
+ if (!italic) throw new Error('Expected italic node')
+ const [italicText] = proxy.children({ node: italic })
+ if (!italicText) throw new Error('Expected italic text node')
+
+ const firstSplit = proxy.splitText({ node: italicText, index: 6 })
+ expect(proxy.text({ node: firstSplit.left })).toBe('alpha ')
+ expect(proxy.text({ node: firstSplit.right })).toBe('beta gamma')
+
+ const secondSplit = proxy.splitText({ node: firstSplit.right, index: 4 })
+ expect(proxy.text({ node: secondSplit.left })).toBe('beta')
+ expect(proxy.text({ node: secondSplit.right })).toBe(' gamma')
+
+ proxy.wrap({ node: secondSplit.left, wrapper: { nodeName: 'bold' } })
+
+ expect(proxy.toString({ node: italic })).toBe('alpha beta gamma ')
+ expect(proxy.toString()).toBe('alpha beta gamma alpha [beta ] gamma ')
+ expect(proxy.toString()).toBe('alpha [beta ] gamma ! ')
+ expect(proxy.toString({ node: italic })).toBe(
+ 'alpha beta ! gamma ',
+ )
+ expect(proxy.toString()).toBe(
+ 'alpha beta ! gamma Title ')
+
+ proxy.removeAttribute({ node: heading, name: 'level' })
+ expect(proxy.summary({ node: heading }).attributes).toEqual({})
+ expect(proxy.toString()).toBe('Title ')
+ })
+
+ test('adds a bullet to an existing list', () => {
+ const doc = new Y.Doc()
+ const fragment = doc.getXmlFragment('artifact')
+ const proxy = new YXmlProxyBindings(fragment)
+
+ const [list] = proxy.append({
+ content: [
+ {
+ kind: 'element',
+ nodeName: 'bulletList',
+ children: [
+ {
+ kind: 'element',
+ nodeName: 'listItem',
+ children: [
+ {
+ kind: 'element',
+ nodeName: 'paragraph',
+ children: [{ kind: 'text', text: 'Existing bullet' }],
+ },
+ ],
+ },
+ ],
+ },
+ ],
+ })
+ if (!list) throw new Error('Expected list node')
+
+ proxy.append({
+ parent: list,
+ content: [
+ {
+ kind: 'element',
+ nodeName: 'listItem',
+ children: [
+ { kind: 'element', nodeName: 'paragraph', children: [{ kind: 'text', text: 'Added bullet' }] },
+ ],
+ },
+ ],
+ })
+
+ expect(proxy.toString()).toBe(
+ 'Existing bullet Added bullet Details ')
+ })
+
+ test('erases a section by removing its element ref', () => {
+ const doc = new Y.Doc()
+ const fragment = doc.getXmlFragment('artifact')
+ const proxy = new YXmlProxyBindings(fragment)
+
+ const [intro, obsolete, ending] = proxy.append({
+ content: [
+ {
+ kind: 'element',
+ nodeName: 'section',
+ attributes: { id: 'intro' },
+ children: [
+ { kind: 'element', nodeName: 'paragraph', children: [{ kind: 'text', text: 'Keep intro.' }] },
+ ],
+ },
+ {
+ kind: 'element',
+ nodeName: 'section',
+ attributes: { id: 'obsolete' },
+ children: [
+ {
+ kind: 'element',
+ nodeName: 'paragraph',
+ children: [{ kind: 'text', text: 'Delete this section.' }],
+ },
+ ],
+ },
+ {
+ kind: 'element',
+ nodeName: 'section',
+ attributes: { id: 'ending' },
+ children: [
+ { kind: 'element', nodeName: 'paragraph', children: [{ kind: 'text', text: 'Keep ending.' }] },
+ ],
+ },
+ ],
+ })
+ if (!intro || !obsolete || !ending) throw new Error('Expected section nodes')
+
+ proxy.remove({ node: obsolete })
+
+ expect(proxy.children()).toEqual([intro, ending])
+ expect(proxy.toString()).toBe(
+ 'Keep intro. Keep ending. Keep ')
+ expect(proxy.children()).toEqual([first])
+ })
+
+ test('rejects child insertion into text refs', () => {
+ const doc = new Y.Doc()
+ const fragment = doc.getXmlFragment('artifact')
+ const proxy = new YXmlProxyBindings(fragment)
+
+ const [paragraph] = proxy.append({
+ content: [{ kind: 'element', nodeName: 'paragraph', children: [{ kind: 'text', text: 'Text' }] }],
+ })
+ if (!paragraph) throw new Error('Expected paragraph node')
+ const [text] = proxy.children({ node: paragraph })
+ if (!text) throw new Error('Expected text node')
+
+ expect(() =>
+ proxy.append({
+ parent: text,
+ content: [{ kind: 'element', nodeName: 'paragraph', children: [{ kind: 'text', text: 'Nope' }] }],
+ }),
+ ).toThrow(YXmlInvalidNodeKindForOperationError)
+ })
+
+ test('throws for unknown node refs', () => {
+ const doc = new Y.Doc()
+ const fragment = doc.getXmlFragment('artifact')
+ const proxy = new YXmlProxyBindings(fragment)
+
+ expect(() => proxy.summary({ node: { id: 'missing', kind: 'element' } })).toThrow(UnknownYXmlNodeRefError)
+ })
+
+ test('throws for node ref kind mismatches', () => {
+ const doc = new Y.Doc()
+ const fragment = doc.getXmlFragment('artifact')
+ const proxy = new YXmlProxyBindings(fragment)
+ const [paragraph] = proxy.append({
+ content: [{ kind: 'element', nodeName: 'paragraph', children: [{ kind: 'text', text: 'Text' }] }],
+ })
+ if (!paragraph) throw new Error('Expected paragraph node')
+
+ expect(() => proxy.summary({ node: { ...paragraph, kind: 'text' } })).toThrow(YXmlNodeRefKindMismatchError)
+ })
+
+ test('throws for child index out of bounds', () => {
+ const doc = new Y.Doc()
+ const fragment = doc.getXmlFragment('artifact')
+ const proxy = new YXmlProxyBindings(fragment)
+
+ expect(() => proxy.get({ index: 0 })).toThrow(YXmlChildIndexOutOfBoundsError)
+ })
+
+ test('throws when setting attributes on non-element refs', () => {
+ const doc = new Y.Doc()
+ const fragment = doc.getXmlFragment('artifact')
+ const proxy = new YXmlProxyBindings(fragment)
+ const root = proxy.root()
+
+ expect(() => proxy.setAttribute({ node: root, name: 'id', value: 'root' })).toThrow(
+ YXmlInvalidNodeKindForOperationError,
+ )
+ })
+
+ test('throws for invalid text ranges', () => {
+ const doc = new Y.Doc()
+ const fragment = doc.getXmlFragment('artifact')
+ const proxy = new YXmlProxyBindings(fragment)
+ const [paragraph] = proxy.append({
+ content: [{ kind: 'element', nodeName: 'paragraph', children: [{ kind: 'text', text: 'Text' }] }],
+ })
+ if (!paragraph) throw new Error('Expected paragraph node')
+ const [text] = proxy.children({ node: paragraph })
+ if (!text) throw new Error('Expected text node')
+
+ expect(() => proxy.insertText({ node: text, index: 10, text: '!' })).toThrow(YXmlTextRangeOutOfBoundsError)
+ expect(() => proxy.deleteText({ node: text, index: 1, length: 10 })).toThrow(YXmlTextRangeOutOfBoundsError)
+ expect(() => proxy.splitText({ node: text, index: 0 })).toThrow(YXmlTextRangeOutOfBoundsError)
+ expect(() => proxy.wrapTextRange({ node: text, start: 2, end: 2, wrapper: { nodeName: 'bold' } })).toThrow(
+ YXmlTextRangeOutOfBoundsError,
+ )
+ })
+
+ test('throws when removing or inserting relative to the root fragment', () => {
+ const doc = new Y.Doc()
+ const fragment = doc.getXmlFragment('artifact')
+ const proxy = new YXmlProxyBindings(fragment)
+ const root = proxy.root()
+
+ expect(() => proxy.remove({ node: root })).toThrow(YXmlRootOperationError)
+ expect(() =>
+ proxy.insertAfter({
+ ref: root,
+ content: [{ kind: 'element', nodeName: 'paragraph', children: [{ kind: 'text', text: 'Nope' }] }],
+ }),
+ ).toThrow(YXmlRootOperationError)
+ })
+
+ test('throws for operations on detached node refs', () => {
+ const doc = new Y.Doc()
+ const fragment = doc.getXmlFragment('artifact')
+ const proxy = new YXmlProxyBindings(fragment)
+ const [paragraph] = proxy.append({
+ content: [{ kind: 'element', nodeName: 'paragraph', children: [{ kind: 'text', text: 'Delete me' }] }],
+ })
+ if (!paragraph) throw new Error('Expected paragraph node')
+
+ proxy.remove({ node: paragraph })
+
+ expect(() =>
+ proxy.insertAfter({
+ ref: paragraph,
+ content: [{ kind: 'element', nodeName: 'paragraph', children: [{ kind: 'text', text: 'Nope' }] }],
+ }),
+ ).toThrow(DetachedYXmlNodeRefError)
+ })
+})
diff --git a/packages/yjs-rich-markdown/tsconfig.build.json b/packages/yjs-rich-markdown/tsconfig.build.json
new file mode 100644
index 0000000..e043bc7
--- /dev/null
+++ b/packages/yjs-rich-markdown/tsconfig.build.json
@@ -0,0 +1,23 @@
+{
+ "extends": "./tsconfig.json",
+ "compilerOptions": {
+ "noEmit": false,
+ "declaration": true,
+ "declarationMap": true,
+ "emitDeclarationOnly": true,
+ "outDir": "./dist",
+ "rootDir": "./src"
+ },
+ "include": ["src"],
+ "exclude": [
+ "test",
+ "dist",
+ "node_modules",
+ "**/*.test.*",
+ "**/*.bench.*",
+ "**/*.test-d.ts",
+ "**/__tests__/**",
+ "**/__mocks__/**",
+ "**/__snapshots__/**"
+ ]
+}
diff --git a/agents/yjs-fs-agents/tsconfig.json b/packages/yjs-rich-markdown/tsconfig.json
similarity index 82%
rename from agents/yjs-fs-agents/tsconfig.json
rename to packages/yjs-rich-markdown/tsconfig.json
index b9457eb..7cb9983 100644
--- a/agents/yjs-fs-agents/tsconfig.json
+++ b/packages/yjs-rich-markdown/tsconfig.json
@@ -1,6 +1,5 @@
{
"compilerOptions": {
- // Environment setup & latest features
"lib": ["ESNext"],
"target": "ESNext",
"module": "Preserve",
@@ -8,19 +7,16 @@
"jsx": "react-jsx",
"allowJs": true,
"types": ["bun"],
- // Bundler mode
"moduleResolution": "bundler",
"customConditions": ["source"],
"allowImportingTsExtensions": true,
"verbatimModuleSyntax": true,
"noEmit": true,
- // Best practices
"strict": true,
"skipLibCheck": true,
"noFallthroughCasesInSwitch": true,
"noUncheckedIndexedAccess": true,
"noImplicitOverride": true,
- // Some stricter flags (disabled by default)
"noUnusedLocals": false,
"noUnusedParameters": false,
"noPropertyAccessFromIndexSignature": false
diff --git a/scripts/release/manifest.ts b/scripts/release/manifest.ts
index 2c2148d..515b1e6 100644
--- a/scripts/release/manifest.ts
+++ b/scripts/release/manifest.ts
@@ -1,7 +1,7 @@
import { dirname, join } from "node:path";
import { fileURLToPath } from "node:url";
-import type { PackageManifest } from '../build/package-build'
+import type { PackageManifest } from '../build/package-build';
export type WorkspaceReleaseEntry = {
name: string;
@@ -33,6 +33,10 @@ export const publishablePackages = [
name: "@humanlayer/agentlayer-provider-openai-codex",
dir: "packages/agentlayer-provider-openai-codex",
},
+ {
+ name: "@humanlayer/quickjs-exec",
+ dir: "packages/quickjs-exec",
+ },
{
name: "@humanlayer/yjs-fs",
dir: "packages/yjs-fs",