New Case Study:See how Anthropic automated 95% of dependency reviews with Socket.Learn More →
dexie-relay
Advanced tools
dexie-relay - npm Package Compare versions
Comparing version 3.0.5 to 3.0.6
255
index.js
@@ -59,36 +59,42 @@ import {Client} from 'relay-to-relay' | ||
| }, this.timer.redo) | ||
| } | ||
| #routine | ||
| #adds = new Set() | ||
| #edits = new Map() | ||
| #subs = new Set() | ||
| this.#adds = new Set() | ||
| this.#edits = new Map() | ||
| this.#subs = new Set() | ||
| async #message(data, nick){ | ||
| try { | ||
| if(this.debug){ | ||
| console.log('Received Message: ', typeof(data), data) | ||
| } | ||
| const datas = JSON.parse(data) | ||
| const dataTab = this.db.table(datas.name) | ||
| if(dataTab){ | ||
| if(datas.status){ | ||
| if(datas.user === this.user){ | ||
| return | ||
| } | ||
| if(datas.status === 'add'){ | ||
| if(this.#adds.has(datas.iden)){ | ||
| this.#message = async (data, nick) => { | ||
| try { | ||
| if(this.debug){ | ||
| console.log('Received Message: ', typeof(data), data) | ||
| } | ||
| const datas = JSON.parse(data) | ||
| const dataTab = this.db.table(datas.name) | ||
| if(dataTab){ | ||
| if(datas.status){ | ||
| if(datas.user === this.user){ | ||
| return | ||
| } | ||
| await dataTab.add(datas.data) | ||
| this.emit('add', datas.iden) | ||
| this.#adds.add(datas.iden) | ||
| this.client.onMesh(data, nick) | ||
| } else if(datas.status === 'edit'){ | ||
| if(this.#edits.has(datas.iden)){ | ||
| const test = this.#edits.get(datas.iden) | ||
| if(datas.edit > test){ | ||
| if(datas.status === 'add'){ | ||
| if(this.#adds.has(datas.iden)){ | ||
| return | ||
| } | ||
| await dataTab.add(datas.data) | ||
| this.emit('add', datas.iden) | ||
| this.#adds.add(datas.iden) | ||
| this.client.onMesh(data, nick) | ||
| } else if(datas.status === 'edit'){ | ||
| if(this.#edits.has(datas.iden)){ | ||
| const test = this.#edits.get(datas.iden) | ||
| if(datas.edit > test){ | ||
| await dataTab.update(datas.iden, datas.data) | ||
| this.emit('edit', datas.iden) | ||
| this.#edits.set(datas.iden, datas.edit) | ||
| this.client.onMesh(data, nick) | ||
| } else { | ||
| return | ||
| } | ||
| } else { | ||
| await dataTab.update(datas.iden, datas.data) | ||
@@ -98,80 +104,75 @@ this.emit('edit', datas.iden) | ||
| this.client.onMesh(data, nick) | ||
| } else { | ||
| } | ||
| } else if(datas.status === 'sub'){ | ||
| if(this.#subs.has(datas.iden)){ | ||
| return | ||
| } | ||
| if(!this.keep){ | ||
| await dataTab.delete(datas.iden) | ||
| this.emit('sub', datas.iden) | ||
| } | ||
| this.#subs.add(datas.iden) | ||
| this.client.onMesh(data, nick) | ||
| } else { | ||
| await dataTab.update(datas.iden, datas.data) | ||
| this.emit('edit', datas.iden) | ||
| this.#edits.set(datas.iden, datas.edit) | ||
| this.client.onMesh(data, nick) | ||
| } | ||
| } else if(datas.status === 'sub'){ | ||
| if(this.#subs.has(datas.iden)){ | ||
| return | ||
| } | ||
| if(!this.keep){ | ||
| await dataTab.delete(datas.iden) | ||
| this.emit('sub', datas.iden) | ||
| } | ||
| this.#subs.add(datas.iden) | ||
| this.client.onMesh(data, nick) | ||
| } else { | ||
| return | ||
| } | ||
| } else if(datas.session){ | ||
| if(datas.session === 'request'){ | ||
| let stamp | ||
| let edit | ||
| try { | ||
| stamp = datas.stamp ? await dataTab.where('stamp').above(datas.stamp).toArray() : await dataTab.where('stamp').toArray() | ||
| } catch { | ||
| stamp = [] | ||
| } | ||
| while(stamp.length){ | ||
| datas.session = 'response' | ||
| datas.edit = null | ||
| datas.stamp = stamp.splice(stamp.length - 50, 50) | ||
| this.client.onSend(JSON.stringify(datas), nick) | ||
| } | ||
| try { | ||
| edit = datas.edit ? await dataTab.where('edit').above(datas.edit).toArray() : await dataTab.where('edit').toArray() | ||
| } catch { | ||
| edit = [] | ||
| } | ||
| while(edit.length){ | ||
| datas.session = 'response' | ||
| datas.stamp = null | ||
| datas.edit = edit.splice(edit.length - 50, 50) | ||
| this.client.onSend(JSON.stringify(datas), nick) | ||
| } | ||
| } else if(datas.session === 'response'){ | ||
| if(datas.stamp){ | ||
| let hasStamp | ||
| } else if(datas.session){ | ||
| if(datas.session === 'request'){ | ||
| let stamp | ||
| let edit | ||
| try { | ||
| hasStamp = await dataTab.where('stamp').notEqual(0).last() | ||
| stamp = datas.stamp ? await dataTab.where('stamp').above(datas.stamp).toArray() : await dataTab.where('stamp').toArray() | ||
| } catch { | ||
| hasStamp = {} | ||
| stamp = [] | ||
| } | ||
| const stamps = hasStamp?.stamp ? datas.stamp.filter((e) => {return e.stamp > hasStamp.stamp && e.user !== this.user}) : datas.stamp | ||
| try { | ||
| await dataTab.bulkPut(stamps) | ||
| } catch (error) { | ||
| console.error(error) | ||
| while(stamp.length){ | ||
| datas.session = 'response' | ||
| datas.edit = null | ||
| datas.stamp = stamp.splice(stamp.length - 50, 50) | ||
| this.client.onSend(JSON.stringify(datas), nick) | ||
| } | ||
| this.emit('bulk', stamps.map((data) => {return data.iden})) | ||
| } | ||
| if(datas.edit){ | ||
| let hasEdit | ||
| try { | ||
| hasEdit = await dataTab.where('edit').notEqual(0).last() | ||
| edit = datas.edit ? await dataTab.where('edit').above(datas.edit).toArray() : await dataTab.where('edit').toArray() | ||
| } catch { | ||
| hasEdit = {} | ||
| edit = [] | ||
| } | ||
| const edits = hasEdit?.edit ? datas.edit.filter((e) => {return e.edit > hasEdit.edit && e.user !== this.user}) : datas.edit | ||
| try { | ||
| await dataTab.bulkPut(edits) | ||
| } catch (error) { | ||
| console.error(error) | ||
| while(edit.length){ | ||
| datas.session = 'response' | ||
| datas.stamp = null | ||
| datas.edit = edit.splice(edit.length - 50, 50) | ||
| this.client.onSend(JSON.stringify(datas), nick) | ||
| } | ||
| this.emit('bulk', edits.map((data) => {return data.iden})) | ||
| } else if(datas.session === 'response'){ | ||
| if(datas.stamp){ | ||
| let hasStamp | ||
| try { | ||
| hasStamp = await dataTab.where('stamp').notEqual(0).last() | ||
| } catch { | ||
| hasStamp = {} | ||
| } | ||
| const stamps = hasStamp?.stamp ? datas.stamp.filter((e) => {return e.stamp > hasStamp.stamp && e.user !== this.user}) : datas.stamp | ||
| try { | ||
| await dataTab.bulkPut(stamps) | ||
| } catch (error) { | ||
| console.error(error) | ||
| } | ||
| this.emit('bulk', stamps.map((data) => {return data.iden})) | ||
| } | ||
| if(datas.edit){ | ||
| let hasEdit | ||
| try { | ||
| hasEdit = await dataTab.where('edit').notEqual(0).last() | ||
| } catch { | ||
| hasEdit = {} | ||
| } | ||
| const edits = hasEdit?.edit ? datas.edit.filter((e) => {return e.edit > hasEdit.edit && e.user !== this.user}) : datas.edit | ||
| try { | ||
| await dataTab.bulkPut(edits) | ||
| } catch (error) { | ||
| console.error(error) | ||
| } | ||
| this.emit('bulk', edits.map((data) => {return data.iden})) | ||
| } | ||
| } else { | ||
| return | ||
| } | ||
@@ -184,38 +185,42 @@ } else { | ||
| } | ||
| } else { | ||
| } catch { | ||
| return | ||
| } | ||
| } catch { | ||
| return | ||
| } | ||
| this.#disconnect = (chan) => { | ||
| console.log('disconnected: ' + chan) | ||
| } | ||
| this.#err = (e, chan) => { | ||
| console.error(e, chan) | ||
| } | ||
| this.#connect = (chan) => { | ||
| console.log('connected: ' + chan) | ||
| this.db.tables.forEach(async (table) => { | ||
| let useStamp | ||
| let useEdit | ||
| try { | ||
| useStamp = await table.where('stamp').notEqual(0).last() | ||
| } catch { | ||
| useStamp = {} | ||
| } | ||
| try { | ||
| useEdit = await table.where('edit').notEqual(0).last() | ||
| } catch { | ||
| useEdit = {} | ||
| } | ||
| this.client.onSend(JSON.stringify({name: table.name, stamp: useStamp?.stamp, edit: useEdit?.edit, session: 'request'}), chan) | ||
| }) | ||
| } | ||
| } | ||
| #disconnect(chan){ | ||
| console.log('disconnected: ' + chan) | ||
| } | ||
| #routine | ||
| #adds | ||
| #edits | ||
| #subs | ||
| #message | ||
| #disconnect | ||
| #err | ||
| #connect | ||
| #err(e, chan){ | ||
| console.error(e, chan) | ||
| } | ||
| #connect(chan){ | ||
| console.log('connected: ' + chan) | ||
| this.db.tables.forEach(async (table) => { | ||
| let useStamp | ||
| let useEdit | ||
| try { | ||
| useStamp = await table.where('stamp').notEqual(0).last() | ||
| } catch { | ||
| useStamp = {} | ||
| } | ||
| try { | ||
| useEdit = await table.where('edit').notEqual(0).last() | ||
| } catch { | ||
| useEdit = {} | ||
| } | ||
| this.client.onSend(JSON.stringify({name: table.name, stamp: useStamp?.stamp, edit: useEdit?.edit, session: 'request'}), chan) | ||
| }) | ||
| } | ||
| id(){return crypto.randomUUID()} | ||
@@ -222,0 +227,0 @@ |
| { | ||
| "name": "dexie-relay", | ||
| "version": "3.0.5", | ||
| "version": "3.0.6", | ||
| "main": "index.js", | ||
@@ -5,0 +5,0 @@ "scripts": { |
No alert changes
Improved metrics
- Total package byte prevSize
- increased by6.2%
12802
- Lines of code
- increased by2.42%
296
No dependency changes