Tidy up examples

Author: samwillis

examples/basic.ts

@@ -1,5 +1,4 @@
-import { D2 } from '../packages/d2ts/src/index.js'
-import { map, filter, debug } from '../packages/d2ts/src/operators/index.js'
+import { D2, map, filter, debug } from '@electric-sql/d2ts'
 
 // Create a new D2 graph with an initial frontier of 0
 // This is the lower bound of the version space
@@ -27,15 +26,15 @@ graph.finalize()
 // The graph will process the data and frontier updates in a single step
 for (let i = 1; i <= 10; i++) {
   // Sending a frontier is informing the graph what the new lower bound of the version
-  // space is *on that input*. Each input essentially can have its own lower bound. 
+  // space is *on that input*. Each input essentially can have its own lower bound.
   // These are then passed through all the operators
   input.sendFrontier(i)
 
   // Sending data to the graph
   // The first param is the version of the data
-  // The second param is a MultiSetArray of *changes in the collection*, where the first 
-  // element is the record and the second is the multiplicity. A positive multiplicity 
-  // means that the record is added to the collection at that version. A negative 
+  // The second param is a MultiSetArray of *changes in the collection*, where the first
+  // element is the record and the second is the multiplicity. A positive multiplicity
+  // means that the record is added to the collection at that version. A negative
   // multiplicity means that the record is removed from the collection at that version.
   input.sendData(i, [
     [i + 1, 1],

examples/fruit-processed.ts

@@ -1,5 +1,5 @@
-import { map, reduce, consolidate } from '../packages/d2ts/src/operators/index.js'
-import { Store } from '../packages/d2ts/src/store.js'
+import { map, reduce, consolidate } from '@electric-sql/d2ts'
+import { Store } from '@electric-sql/d2ts/store'
 
 type FruitOrder = {
   name: string

examples/includes.ts

@@ -1,6 +1,13 @@
-import { D2 } from '../packages/d2ts/src/index.js'
-import { map, filter, join, concat, distinct, debug } from '../packages/d2ts/src/operators/index.js'
-import { v } from '../packages/d2ts/src/order.js'
+import {
+  D2,
+  map,
+  filter,
+  join,
+  concat,
+  distinct,
+  debug,
+  v,
+} from '@electric-sql/d2ts'
 
 type Issue = {
   type: 'issue'
@@ -31,46 +38,44 @@ const inputComments = graph.newInput<[number, Comment]>()
 
 // Transform comments into [issue_id, comment] pairs for joining
 const commentsByIssue = inputComments.pipe(
-  map(([id, comment]) => [comment.issue_id, comment] as [number, Comment])
+  map(([id, comment]) => [comment.issue_id, comment] as [number, Comment]),
 )
 
 // Issues for our project
 const issuesForProject = inputIssues.pipe(
-  filter(([id, issue]) => issue.project_id === 1)
+  filter(([id, issue]) => issue.project_id === 1),
 )
 
 // Issues ids for joining with comments
 const issueIds = issuesForProject.pipe(
-  map(([id, issue]) => [issue.id, undefined] as [number, undefined])
+  map(([id, issue]) => [issue.id, undefined] as [number, undefined]),
 )
 
 // Join comments and map back to just the comment
 const commentsForProject = commentsByIssue.pipe(
   join(issueIds),
-  map(([id, [comment, _]]) => [comment.id, comment] as [number, Comment])
+  map(([id, [comment, _]]) => [comment.id, comment] as [number, Comment]),
 )
 
 // Users
 const usersIdsForIssues = issuesForProject.pipe(
-  map(([id, issue]) => [issue.owner_id, undefined] as [number, undefined])
+  map(([id, issue]) => [issue.owner_id, undefined] as [number, undefined]),
 )
 const usersIdsForComments = commentsForProject.pipe(
-  map(([id, comment]) => [comment.owner_id, undefined] as [number, undefined])
-)
-const usersIds = usersIdsForIssues.pipe(
-  concat(usersIdsForComments)
+  map(([id, comment]) => [comment.owner_id, undefined] as [number, undefined]),
 )
+const usersIds = usersIdsForIssues.pipe(concat(usersIdsForComments))
 const users = usersIds.pipe(
   join(inputUsers),
   map(([id, [_, user]]) => [id, user] as [number, User]),
-  distinct()
+  distinct(),
 )
 
 // Concat comments and issues and output the result
 const output = commentsForProject.pipe(
   concat(issuesForProject),
   concat(users),
-  debug('output', true)
+  debug('output', true),
 )
 
 graph.finalize()
@@ -84,19 +89,64 @@ inputUsers.sendData(v([1, 0]), [
 
 // Add some issues
 inputIssues.sendData(v([1, 0]), [
-  [[1, { type: 'issue', id: 1, project_id: 1, title: 'Issue 1', owner_id: 1 }], 1],
-  [[2, { type: 'issue', id: 2, project_id: 2, title: 'Issue 2', owner_id: 2 }], 1],
-  [[3, { type: 'issue', id: 3, project_id: 1, title: 'Issue 3', owner_id: 3 }], 1],
+  [
+    [1, { type: 'issue', id: 1, project_id: 1, title: 'Issue 1', owner_id: 1 }],
+    1,
+  ],
+  [
+    [2, { type: 'issue', id: 2, project_id: 2, title: 'Issue 2', owner_id: 2 }],
+    1,
+  ],
+  [
+    [3, { type: 'issue', id: 3, project_id: 1, title: 'Issue 3', owner_id: 3 }],
+    1,
+  ],
 ])
 
 // Add some comments
 inputComments.sendData(v([1, 0]), [
-  [[1, { type: 'comment', id: 1, issue_id: 1, text: 'Comment 1', owner_id: 1 }], 1],
-  [[2, { type: 'comment', id: 2, issue_id: 1, text: 'Comment 2', owner_id: 3 }], 1],
-  [[3, { type: 'comment', id: 3, issue_id: 2, text: 'Comment 3', owner_id: 1 }], 1],
-  [[4, { type: 'comment', id: 4, issue_id: 2, text: 'Comment 4', owner_id: 3 }], 1],
-  [[5, { type: 'comment', id: 5, issue_id: 3, text: 'Comment 5', owner_id: 1 }], 1],
-  [[6, { type: 'comment', id: 6, issue_id: 3, text: 'Comment 6', owner_id: 3 }], 1],
+  [
+    [
+      1,
+      { type: 'comment', id: 1, issue_id: 1, text: 'Comment 1', owner_id: 1 },
+    ],
+    1,
+  ],
+  [
+    [
+      2,
+      { type: 'comment', id: 2, issue_id: 1, text: 'Comment 2', owner_id: 3 },
+    ],
+    1,
+  ],
+  [
+    [
+      3,
+      { type: 'comment', id: 3, issue_id: 2, text: 'Comment 3', owner_id: 1 },
+    ],
+    1,
+  ],
+  [
+    [
+      4,
+      { type: 'comment', id: 4, issue_id: 2, text: 'Comment 4', owner_id: 3 },
+    ],
+    1,
+  ],
+  [
+    [
+      5,
+      { type: 'comment', id: 5, issue_id: 3, text: 'Comment 5', owner_id: 1 },
+    ],
+    1,
+  ],
+  [
+    [
+      6,
+      { type: 'comment', id: 6, issue_id: 3, text: 'Comment 6', owner_id: 3 },
+    ],
+    1,
+  ],
 ])
 
 // Send frontiers
@@ -107,7 +157,13 @@ graph.run()
 
 // Add a new Comment to an issue in project 1
 inputComments.sendData(v([2, 0]), [
-  [[7, { type: 'comment', id: 7, issue_id: 1, text: 'Comment 7', owner_id: 1 }], 1],
+  [
+    [
+      7,
+      { type: 'comment', id: 7, issue_id: 1, text: 'Comment 7', owner_id: 1 },
+    ],
+    1,
+  ],
 ])
 inputUsers.sendFrontier(v([3, 0]))
 inputIssues.sendFrontier(v([3, 0]))
@@ -116,7 +172,13 @@ graph.run()
 
 // Add a new Comment to an issue in project 2
 inputComments.sendData(v([3, 0]), [
-  [[8, { type: 'comment', id: 8, issue_id: 2, text: 'Comment 8', owner_id: 1 }], 1],
+  [
+    [
+      8,
+      { type: 'comment', id: 8, issue_id: 2, text: 'Comment 8', owner_id: 1 },
+    ],
+    1,
+  ],
 ])
 inputUsers.sendFrontier(v([4, 0]))
 inputIssues.sendFrontier(v([4, 0]))
@@ -126,8 +188,14 @@ console.log('> Comment 8 should not be included in the output above')
 
 // Move issue 2 to project 1
 inputIssues.sendData(v([4, 0]), [
-  [[2, { type: 'issue', id: 2, project_id: 2, title: 'Issue 2', owner_id: 2 }], -1],
-  [[2, { type: 'issue', id: 2, project_id: 1, title: 'Issue 2', owner_id: 2 }], 1],
+  [
+    [2, { type: 'issue', id: 2, project_id: 2, title: 'Issue 2', owner_id: 2 }],
+    -1,
+  ],
+  [
+    [2, { type: 'issue', id: 2, project_id: 1, title: 'Issue 2', owner_id: 2 }],
+    1,
+  ],
 ])
 inputUsers.sendFrontier(v([5, 0]))
 inputIssues.sendFrontier(v([5, 0]))
@@ -137,14 +205,22 @@ console.log('> Issue 2 and its comments should be included in the output above')
 
 // Move issue 2 back to project 2
 inputIssues.sendData(v([5, 0]), [
-  [[2, { type: 'issue', id: 2, project_id: 1, title: 'Issue 2', owner_id: 2 }], -1],
-  [[2, { type: 'issue', id: 2, project_id: 2, title: 'Issue 2', owner_id: 2 }], 1],
+  [
+    [2, { type: 'issue', id: 2, project_id: 1, title: 'Issue 2', owner_id: 2 }],
+    -1,
+  ],
+  [
+    [2, { type: 'issue', id: 2, project_id: 2, title: 'Issue 2', owner_id: 2 }],
+    1,
+  ],
 ])
 inputUsers.sendFrontier(v([6, 0]))
 inputIssues.sendFrontier(v([6, 0]))
 inputComments.sendFrontier(v([6, 0]))
 graph.run()
-console.log('> Issue 2 and its comments should have a multiplicity of -1 in the output above')
+console.log(
+  '> Issue 2 and its comments should have a multiplicity of -1 in the output above',
+)
 
 /*
 Output looks like this:
@@ -413,4 +489,4 @@ debug output data: version: Version([5,0]) collection: MultiSet([
 debug output notification: frontier Antichain([[6,0]])
 > Issue 2 and its comments should have a multiplicity of -1 in the output above
 
-*/
+*/

examples/iterate.ts

@@ -1,15 +1,16 @@
-import { D2 } from '../packages/d2ts/src/index.js'
-import { MultiSet } from '../packages/d2ts/src/multiset.js'
-import { Antichain, v } from '../packages/d2ts/src/order.js'
 import {
-  iterate,
-  debug,
-  map,
+  D2,
+  Antichain,
+  concat,
   consolidate,
+  debug,
   distinct,
   filter,
-  concat,
-} from '../packages/d2ts/src/operators/index.js'
+  iterate,
+  map,
+  MultiSet,
+  v,
+} from '@electric-sql/d2ts'
 
 const graph = new D2({ initialFrontier: new Antichain([v(0)]) })