Schopp/fixed fetch

examples/todo/client/client.ts

@@ -1,15 +1,17 @@
 /*
  * Jet client-server communications:
  */
-import { Fetcher, Peer, PublishMessage, ValueType } from '../../../lib'
+import { Fetcher, Peer, PublishMessage } from '../../../lib'
 import { Todo } from '../server/Todo'
 import './base.css'
 
 const todoList: Record<string, Todo> = {}
-const peer = new Peer({ url: `ws://localhost:8081/` })
+const peer = new Peer({
+  url: `ws://localhost:8081/`
+})
 
 const addTodo = (title: string) => {
-  peer.call('todo/add', [title])
+  peer.call('todo/add', [title]).catch(() => console.log('Failed to add'))
 }
 
 const removeTodo = (id: string) => {
@@ -127,9 +129,6 @@ document.getElementById('todo-form')!.addEventListener('submit', (event) => {
 peer
   .connect()
   .then(() => peer.authenticate('Admin', 'test'))
-  .then(() => peer.get({ path: { startsWith: 'test' } }))
-  .then((val) => console.log(val))
-  // .then(() => peer.authenticate('Operator', ''))
   .then(() => peer.fetch(todos))
   .then(() => renderTodos())
   .catch((ex) => console.log(ex))

examples/todo/server/index.ts

@@ -24,10 +24,6 @@ console.log('listening on port', port)
 var peer = new Peer({
   url: `ws://localhost:8081/`
 })
-// const peer2 = new jet.Peer({
-//   port: internalPort,log:{logCallbacks:[console.log],logname:"Peer 2",loglevel:jet.LogLevel.debug}
-
-// })
 
 var todoStates: Record<string, State<Todo>> = {}
 
@@ -46,8 +42,13 @@ addTodo.on('call', (args) => {
   todoState.on('set', (requestedTodo) => {
     todo.merge(requestedTodo)
   })
+  if (todo.id in todoStates) {
+    throw 'already existent'
+  }
   todoStates[todo.id] = todoState
-  peer.add(todoState)
+  peer.add(todoState).catch(() => {
+    console.log('State already existent')
+  })
 })
 
 // Provide a "todo/remove" method to delete a certain todo