@frando/corestore v1.2.2
@Frando/corestore
Experimental fork of @andrewosh/corestore:
- Makes all primary resources (storage, discovery, level) pluggable to make corestore run in both node and the browser.
- Include sensible defaults for both node and browers. Just
require('corestore')and depending on the environment either the browser or node defaults will be used.- Adds support for other hypercore-based datastructures (like hyperdrives) by swapping the hypercore constructor for a factory.
Manages and seeds a library of Hypercore-based data structures (e.g. hypercore, hyperdrive, hyperdb and multifeed). Note: So far only tested with hypercore and hyperdrive.
Networking code lightly modified from Beaker's implementation.
Installation
npm i @frando/corestore --saveExample
npm run example, and then open both http://localhost:8080 and http://localhost:8081 in the browser. You should be able to create both hyperdrives and hypercores, with persistent in-browser storage and automatically working synchronization between the two instances. The code (it's simple!) is in /example and has choo as the only other dependency apart from corestore.
Usage
All examples here work both in the browser and in node.
Hypercore-only store.
let store = corestore('my-storage-dir')
await store.ready()
// Create a new hypercore, seeded by default.
let core = await store.get()
await core.ready()
// Create a new hypercore with non-default options.
let core = store.get({ valueEncoding: 'utf-8', seed: false })
await core.ready()
// Get an existing hypercore by key (will automatically replicate in the background).
let core = await store.get('my-dat-key')
// Stop seeding a hypercore by key (assuming it was already seeding).
await store.update(core.key, { seed: false })
// Delete and unseed a hypercore.
await store.delete(core.key)
// Get the metadata for a stored hypercore.
await store.info(core.key)
// Stop seeding and shut down
await store.close()A store for both hypercores and hyperdrives
let store = corestore('my-storage-dir', {
factories: {
hyperdrive: require('hyperdrive'),
hypercore: require('hypercore')
}
})
await store.ready()
const hyperdrive = await store.get({ type: 'hyperdrive' })
hyperdrive.writeFile('/foo/bar', Buffer.from('hello, world!'), (err) => {
console.log('File was written!')
})
// Everything else works as above.API
const store = corestore(path, opts)
The path parameter is interpreted as a file system path in node (when using the default random-access-file storage), and as a namespace when running in the browser.
Options include:
level: A leveldown-compliant leveldb wrapper. Default is leveldown in node, level.js in browsers.storage: Arandom-access-storageinstance. Defaults torandom-access-filein node,random-access-webin browsers.swarm: Adiscovery-swarm. Defaults todiscovery-swarmin node anddiscovery-swarm-webin browsers.factories: An object of factories. Key names are types, values should be constructors for abstract-dat compliant data structures (see below). Example:```js const opts = { factories: { hypercore: require('hypercore'), hyperdrive: require('hyperdrive'), hypertrie: require('hypertrie') } }factory: Instead of passing an object of factories, you can also pass afactorycallback. It will be invoked when a new data structure is to be created:function factory (path, key, opts, store) { ... }, wherepathis a string that should be used as storage location,keyis the public key,storeis a reference to the corestore andoptsare opts that are passed with thestore.getcall (or are retrieved from the metadata db for already tracked structures). If the structure needs primary resources, arandom-access-storageconstructor is available onstore.storage(path)and a level-db that could besubleveledonstore.levelnetwork: Network options, are passed to thediscovery-swarmconstructor. Setnetwork.disabletotrueto completely disable swarming.
async get([key], [opts])
Either load a hypercore by key, or create a new one.
If a core was previously created locally, then it will be writable.
Opts can contain:
type: string: The type of the structure. May be required whengetting a so-far untracked structure and using afactoriesobject.valueEncoding: string | codec// Default value encoding for new hypercores.seed: bool: Seed (share) the structure in the p2p swarm.sparse: bool: Enable sparse replication by default.name: string: A name, will be stored in the metadata db.description: stringkeyPair: { publicKey, secretKey }
async update(key, opts)
Update the metadata associated with a hypercore. If the given hypercore has already been initialized, then its valueEncoding or sparse options will not be modified.
Updating the seed value will enable/disable seeding.
opts should match the get options.
async info(key)
Return the metadata associated with the specified hypercore. The metadata schema matches the get options.
async list()
List all hypercores being stored. The result is a Map of the form:
Map {
key1 => metadata1,
key2 => metadata2,
...
}async delete(key)
Unseed and delete the specified hypercore, if it's currently being stored.
Throws if the key has not been previously stored.
License
MIT
7 years ago