From fbc9edd795328bb7f7a0dc99210b5aeac4dd13e1 Mon Sep 17 00:00:00 2001
From: ansuz <ansuz@transitiontech.ca>
Date: Tue, 20 Oct 2020 17:12:26 +0530
Subject: [PATCH] rename latest admin commands and implement metadata
 getter/remover

---
 lib/commands/admin-rpc.js | 29 +++++++++++++++++++++++++----
 1 file changed, 25 insertions(+), 4 deletions(-)

diff --git a/lib/commands/admin-rpc.js b/lib/commands/admin-rpc.js
index b7c5dfa52..d7f22825d 100644
--- a/lib/commands/admin-rpc.js
+++ b/lib/commands/admin-rpc.js
@@ -175,7 +175,7 @@ var restoreArchivedDocument = function (Env, Server, cb) {
     cb("NOT_IMPLEMENTED");
 };
 
-// CryptPad_AsyncStore.rpc.send('ADMIN', ['CLEAR_CHANNEL_INDEX', documentID], console.log)
+// CryptPad_AsyncStore.rpc.send('ADMIN', ['CLEAR_CACHED_CHANNEL_INDEX', documentID], console.log)
 var clearChannelIndex = function (Env, Server, cb, data) {
     var id = Array.isArray(data) && data[1];
     if (typeof(id) !== 'string' || id.length < 32) { return void cb("EINVAL"); }
@@ -183,7 +183,7 @@ var clearChannelIndex = function (Env, Server, cb, data) {
     cb();
 };
 
-// CryptPad_AsyncStore.rpc.send('ADMIN', ['GET_CHANNEL_INDEX', documentID], console.log)
+// CryptPad_AsyncStore.rpc.send('ADMIN', ['GET_CACHED_CHANNEL_INDEX', documentID], console.log)
 var getChannelIndex = function (Env, Server, cb, data) {
     var id = Array.isArray(data) && data[1];
     if (typeof(id) !== 'string' || id.length < 32) { return void cb("EINVAL"); }
@@ -193,6 +193,24 @@ var getChannelIndex = function (Env, Server, cb, data) {
     cb(void 0, index);
 };
 
+// CryptPad_AsyncStore.rpc.send('ADMIN', ['CLEAR_CACHED_CHANNEL_METADATA', documentID], console.log)
+var clearChannelMetadata = function (Env, Server, cb, data) {
+    var id = Array.isArray(data) && data[1];
+    if (typeof(id) !== 'string' || id.length < 32) { return void cb("EINVAL"); }
+    delete Env.metadata_cache[id];
+    cb();
+};
+
+// CryptPad_AsyncStore.rpc.send('ADMIN', ['GET_CACHED_CHANNEL_METADATA', documentID], console.log)
+var getChannelMetadata = function (Env, Server, cb, data) {
+    var id = Array.isArray(data) && data[1];
+    if (typeof(id) !== 'string' || id.length < 32) { return void cb("EINVAL"); }
+
+    var index = Util.find(Env, ['metadata_cache', id]);
+    if (!index) { return void cb("ENOENT"); }
+    cb(void 0, index);
+};
+
 // CryptPad_AsyncStore.rpc.send('ADMIN', [ 'ADMIN_DECREE', ['RESTRICT_REGISTRATION', [true]]], console.log)
 var adminDecree = function (Env, Server, cb, data, unsafeKey) {
     var value = data[1];
@@ -287,8 +305,11 @@ var commands = {
     ARCHIVE_DOCUMENT: archiveDocument,
     RESTORE_ARCHIVED_DOCUMENT: restoreArchivedDocument,
 
-    CLEAR_CHANNEL_INDEX: clearChannelIndex,
-    GET_CHANNEL_INDEX: getChannelIndex,
+    CLEAR_CACHED_CHANNEL_INDEX: clearChannelIndex,
+    GET_CACHED_CHANNEL_INDEX: getChannelIndex,
+
+    CLEAR_CACHED_CHANNEL_METADATA: clearChannelMetadata,
+    GET_CACHED_CHANNEL_METADATA: getChannelMetadata,
 
     ADMIN_DECREE: adminDecree,
     INSTANCE_STATUS: instanceStatus,