93 lines
2.5 KiB
JavaScript
93 lines
2.5 KiB
JavaScript
|
'use strict';
|
||
|
|
|
||
|
|
exports = module.exports = {
|
||
|
|
add: add,
|
||
|
|
del: del,
|
||
|
|
get: get,
|
||
|
|
getAll: getAll
|
||
|
|
};
|
||
|
|
|
||
|
|
var assert = require('assert'),
|
||
|
|
DatabaseError = require('./databaseerror.js'),
|
||
|
|
mailboxdb = require('./mailboxdb.js'),
|
||
|
|
util = require('util');
|
||
|
|
|
||
|
|
function MailboxError(reason, errorOrMessage) {
|
||
|
|
assert.strictEqual(typeof reason, 'string');
|
||
|
|
assert(errorOrMessage instanceof Error || typeof errorOrMessage === 'string' || typeof errorOrMessage === 'undefined');
|
||
|
|
|
||
|
|
Error.call(this);
|
||
|
|
Error.captureStackTrace(this, this.constructor);
|
||
|
|
|
||
|
|
this.name = this.constructor.name;
|
||
|
|
this.reason = reason;
|
||
|
|
if (typeof errorOrMessage === 'undefined') {
|
||
|
|
this.message = reason;
|
||
|
|
} else if (typeof errorOrMessage === 'string') {
|
||
|
|
this.message = errorOrMessage;
|
||
|
|
} else {
|
||
|
|
this.message = 'Internal error';
|
||
|
|
this.nestedError = errorOrMessage;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
util.inherits(MailboxError, Error);
|
||
|
|
MailboxError.ALREADY_EXISTS = 'already exists';
|
||
|
|
MailboxError.BAD_NAME = 'bad name';
|
||
|
|
MailboxError.INTERNAL_ERROR = 'internal error';
|
||
|
|
|
||
|
|
function validateName(name) {
|
||
|
|
return null;
|
||
|
|
}
|
||
|
|
|
||
|
|
function add(name, callback) {
|
||
|
|
assert.strictEqual(typeof name, 'string');
|
||
|
|
assert.strictEqual(typeof callback, 'function');
|
||
|
|
|
||
|
|
var error = validateName(name);
|
||
|
|
if (error) return callback(error);
|
||
|
|
|
||
|
|
mailboxdb.add(name /* id */, name, function (error) {
|
||
|
|
if (error && error.reason === MailboxError.ALREADY_EXISTS) return callback(new MailboxError(MailboxError.ALREADY_EXISTS));
|
||
|
|
if (error) return callback(new MailboxError(MailboxError.INTERNAL_ERROR, error));
|
||
|
|
|
||
|
|
var mailbox = {
|
||
|
|
id: name,
|
||
|
|
name: name
|
||
|
|
};
|
||
|
|
|
||
|
|
callback(null, mailbox);
|
||
|
|
});
|
||
|
|
}
|
||
|
|
|
||
|
|
function del(id, callback) {
|
||
|
|
assert.strictEqual(typeof name, 'string');
|
||
|
|
assert.strictEqual(typeof callback, 'function');
|
||
|
|
|
||
|
|
mailboxdb.del(name, function (error) {
|
||
|
|
if (error) return callback(new MailboxError(MailboxError.INTERNAL_ERROR, error));
|
||
|
|
|
||
|
|
callback();
|
||
|
|
});
|
||
|
|
}
|
||
|
|
|
||
|
|
function get(id, callback) {
|
||
|
|
assert.strictEqual(typeof id, 'string');
|
||
|
|
assert.strictEqual(typeof callback, 'function');
|
||
|
|
|
||
|
|
mailboxdb.get(id, function (error, mailbox) {
|
||
|
|
if (error) return callback(new MailboxError(MailboxError.INTERNAL_ERROR, error));
|
||
|
|
|
||
|
|
callback(null, mailbox);
|
||
|
|
});
|
||
|
|
}
|
||
|
|
|
||
|
|
function getAll(callback) {
|
||
|
|
assert.strictEqual(typeof callback, 'function');
|
||
|
|
|
||
|
|
mailboxdb.getAll(function (error, results) {
|
||
|
|
if (error) return callback(new MailboxError(MailboxError.INTERNAL_ERROR, error));
|
||
|
|
|
||
|
|
callback(null, results);
|
||
|
|
});
|
||
|
|
}
|