You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
127 lines
3.3 KiB
JavaScript
127 lines
3.3 KiB
JavaScript
var Meta = module.exports;
|
|
|
|
var deduplicate = require("./deduplicate");
|
|
|
|
/* Metadata fields:
|
|
|
|
* channel <STRING>
|
|
* validateKey <STRING>
|
|
* owners <ARRAY>
|
|
* ADD_OWNERS
|
|
* RM_OWNERS
|
|
* expire <NUMBER>
|
|
|
|
*/
|
|
|
|
var commands = {};
|
|
|
|
// ["ADD_OWNERS", ["7eEqelGso3EBr5jHlei6av4r9w2B9XZiGGwA1EgZ-5I="], 1561623438989]
|
|
commands.ADD_OWNERS = function (meta, args) {
|
|
// bail out if args isn't an array
|
|
if (!Array.isArray(args)) {
|
|
throw new Error('METADATA_INVALID_OWNERS');
|
|
}
|
|
|
|
// you shouldn't be able to get here if there are no owners
|
|
// because only an owner should be able to change the owners
|
|
if (!Array.isArray(meta.owners)) {
|
|
throw new Error("METADATA_NONSENSE_OWNERS");
|
|
}
|
|
|
|
args.forEach(function (owner) {
|
|
if (meta.owners.indexOf(owner) >= 0) { return; }
|
|
meta.owners.push(owner);
|
|
});
|
|
};
|
|
|
|
// ["RM_OWNERS", ["CrufexqXcY-z+eKJlEbNELVy5Sb7E-EAAEFI8GnEtZ0="], 1561623439989]
|
|
commands.RM_OWNERS = function (meta, args) {
|
|
// what are you doing if you don't have owners to remove?
|
|
if (!Array.isArray(args)) {
|
|
throw new Error('METADATA_INVALID_OWNERS');
|
|
}
|
|
// if there aren't any owners to start, this is also pointless
|
|
if (!Array.isArray(meta.owners)) {
|
|
throw new Error("METADATA_NONSENSE_OWNERS");
|
|
}
|
|
|
|
// remove owners one by one
|
|
// we assume there are no duplicates
|
|
args.forEach(function (owner) {
|
|
var index = meta.owners.indexOf(owner);
|
|
if (index < 0) { return; }
|
|
meta.owners.splice(index, 1);
|
|
});
|
|
};
|
|
|
|
// ["RESET_OWNERS", ["7eEqelGso3EBr5jHlei6av4r9w2B9XZiGGwA1EgZ-5I="], 1561623439989]
|
|
commands.RESET_OWNERS = function (meta, args) {
|
|
// expect a new array, even if it's empty
|
|
if (!Array.isArray(args)) {
|
|
throw new Error('METADATA_INVALID_OWNERS');
|
|
}
|
|
// assume there are owners to start
|
|
if (!Array.isArray(meta.owners)) {
|
|
throw new Error("METADATA_NONSENSE_OWNERS");
|
|
}
|
|
|
|
// overwrite the existing owners with the new one
|
|
meta.owners = deduplicate(args);
|
|
};
|
|
|
|
commands.UPDATE_EXPIRATION = function () {
|
|
|
|
};
|
|
|
|
var handleCommand = function (meta, line) {
|
|
var command = line[0];
|
|
var args = line[1];
|
|
//var time = line[2];
|
|
|
|
if (typeof(commands[command]) !== 'function') {
|
|
throw new Error("METADATA_UNSUPPORTED_COMMAND");
|
|
}
|
|
|
|
commands[command](meta, args);
|
|
};
|
|
|
|
Meta.createLineHandler = function (ref, errorHandler) {
|
|
ref.meta = {};
|
|
ref.index = 0;
|
|
|
|
return function (err, line) {
|
|
if (err) {
|
|
return void errorHandler('METADATA_HANDLER_LINE_ERR', {
|
|
error: err,
|
|
index: ref.index,
|
|
line: JSON.stringify(line),
|
|
});
|
|
}
|
|
|
|
if (Array.isArray(line)) {
|
|
try {
|
|
handleCommand(ref.meta, line);
|
|
ref.index++;
|
|
} catch (err2) {
|
|
errorHandler("METADATA_COMMAND_ERR", {
|
|
error: err2.stack,
|
|
line: line,
|
|
});
|
|
}
|
|
return;
|
|
}
|
|
|
|
if (ref.index === 0 && typeof(line) === 'object') {
|
|
ref.index++;
|
|
// special case!
|
|
ref.meta = line;
|
|
return;
|
|
}
|
|
|
|
errorHandler("METADATA_HANDLER_WEIRDLINE", {
|
|
line: line,
|
|
index: ref.index++,
|
|
});
|
|
};
|
|
};
|