Ephemeral returns

README.md

@@ -46,6 +46,9 @@ This will attempt to recombine the decrypted shards included in reply messages a
 
 This also works for forwarded shards, you just need to provide the root from on of the fwds.
 
+#### `darkCrystal.recover.async.deleteKeyPairs(rootId, callback)`
+
+Deletes the ephemeral keypairs for all returned shards associated with the given rootId (effectively deleting the shards). If successful, no errors will be returned in the callback.
 
 ### Root methods
 

index.js

@@ -1,7 +1,7 @@
 const inject = require('scuttle-inject')
 
 const raw = require('./methods')
-const PLUGIN_DEPS = ['private', 'query', 'backlinks']
+const PLUGIN_DEPS = ['private', 'query', 'backlinks', 'ephemeral']
 
 const niceMappings = {}
 

isReply.js

@@ -1,6 +1,7 @@
 const { isReply: _isReply } = require('ssb-dark-crystal-schema')
 const getContent = require('ssb-msg-content')
 const { validateShard } = require('./lib/secrets-wrapper')
+const isString = require('./lib/isString')
 
 module.exports = function isReply (msg) {
   const {
@@ -11,10 +12,21 @@ module.exports = function isReply (msg) {
   const errors = []
 
   if (!_isReply(msg)) errors.push(new Error('invalid reply'))
-  if (!validateShard(shard, shareVersion)) errors.push(new Error('invalid shard'))
+  if (!isString(shard)) {
+    errors.push(new Error('body must contain a string'))
+  } else {
+    if (!isBoxedMessage(shard) || shareVersion === '1.0.0') {
+      if (!validateShard(shard, shareVersion)) errors.push(new Error('invalid shard'))
+    }
+  }
 
   if (!errors.length) return true
 
   isReply.errors = errors
   return false
 }
+
+// TODO: should we use isCanonicalBase64 ?
+function isBoxedMessage (message) {
+  return /\.box$/.test(message)
+}

methods.js

@@ -7,7 +7,8 @@ module.exports = {
     async: {
       recombine: require('./recover/async/recombine'),
       reply: require('./recover/async/reply'),
-      request: require('./recover/async/request')
+      request: require('./recover/async/request'),
+      deleteKeyPairs: require('./recover/async/deleteKeyPairs')
     },
     pull: {
       requests: require('./recover/pull/requests'),