Mirroristas/orbitdb
2
0
Fork 0
mirror of https://github.com/orbitdb/orbitdb.git synced 2025-06-15 02:26:37 +00:00
Code Issues Packages Projects Releases Wiki Activity

Remove obsolete code from OrbitDB AC

Browse Source
This commit is contained in:
haad 2023-04-13 08:26:19 +03:00
parent fca6439399
commit e687b51d96
1 changed files with 1 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/access-controllers/orbitdb.js
View File

@ -1,12 +1,9 @@
import { EventEmitter } from 'events'
import ensureACAddress from '../utils/ensure-ac-address.js' import ensureACAddress from '../utils/ensure-ac-address.js'
import IPFSAccessController from './ipfs.js' import IPFSAccessController from './ipfs.js'
const type = 'orbitdb' const type = 'orbitdb'
const OrbitDBAccessController = ({ write } = {}) => async ({ orbitdb, identities, address }) => { const OrbitDBAccessController = ({ write } = {}) => async ({ orbitdb, identities, address }) => {
const events = new EventEmitter()
address = address || 'default-access-controller' address = address || 'default-access-controller'
write = write || [orbitdb.identity.id] write = write || [orbitdb.identity.id]
@ -14,12 +11,6 @@ const OrbitDBAccessController = ({ write } = {}) => async ({ orbitdb, identities
const db = await orbitdb.open(ensureACAddress(address), { type: 'keyvalue', AccessController: IPFSAccessController({ write }) }) const db = await orbitdb.open(ensureACAddress(address), { type: 'keyvalue', AccessController: IPFSAccessController({ write }) })
address = db.address address = db.address
const onUpdate = (entry) => {
events.emit('update', entry)
}
db.events.on('update', onUpdate)
// Return true if entry is allowed to be added to the database // Return true if entry is allowed to be added to the database
const canAppend = async (entry) => { const canAppend = async (entry) => {
const writerIdentity = await identities.getIdentity(entry.identity) const writerIdentity = await identities.getIdentity(entry.identity)
@ -101,7 +92,7 @@ const OrbitDBAccessController = ({ write } = {}) => async ({ orbitdb, identities
grant, grant,
revoke, revoke,
close, close,
events events: db.events
} }
} }