Scuttlebutt stream of messages and off-chain content.
This plugin exposes a method that wraps createHistoryStream and returns all
off-chain content referenced by those messages. This gives us the ability to
do deletion and feed replication without using the blob system.
const server = require('ssb-server')
.use(require('ssb-master'))
.use(require('./'))
const config = Object.assign({}, require('ssb-config'), {
keys: require('ssb-keys').generate() // Random key for testing!
})
const ssb = server(config)
ssb.contentStream.publish({ type: 'test', randomNumber: 42 }, (err, msg) => {
if (err) throw err
console.log(msg.value.content)
}){ type: 'content',
href:
'ssb:content:sha256:rWqRaMb0dfFmss2xan936taWQFfJ_1GGOeckZrFUit8=',
mediaType: 'text/json' }Wrapper for createHistoryStream() that prepends all off-chain content to the
stream. Since createHistoryStream() only returns public and unencrypted messages
this function will only return public messages and its content.
Creates a through-stream that filters content out of the stream, adds them to the content store, and only passes the original metadata message through the stream.
Takes a full message ({ key, value: { previous, sequence, ... } }) and
returns the extracted content from that message in msg.value.content as if
it wasn't a message with off-chain content.
Passes createSource() through createHandler() and getContent().
Wraps ssb.publish() to publish off-chain messages that can be accessed with
content streams. Message schema is:
{
"href": "ssb:content:sha256:rWqRaMb0dfFmss2xan936taWQFfJ_1GGOeckZrFUit8=",
"mediaType": "text/json",
"type": "content"
}With npm:
npm install ssb-content-streamWith yarn:
yarn add ssb-content-streamISC