remove unnecessary argument from channelExists

also add some notes
pull/1/head
ansuz 5 years ago
parent 3513e437b6
commit fc9aaf0ecb

@ -27,6 +27,29 @@ var mkArchivePath = function (env, channelId) {
return Path.join(env.archiveRoot, 'datastore', channelId.slice(0, 2), channelId) + '.ndjson'; return Path.join(env.archiveRoot, 'datastore', channelId.slice(0, 2), channelId) + '.ndjson';
}; };
var mkMetadataPath = function (env, channelId) {
return Path.join(env.root, channelId.slice(0, 2), channelId) + '.metadata.ndjson';
};
var mkArchiveMetadataPath = function (env, channelId) {
return Path.join(env.archiveRoot, 'datastore', channelId.slice(0, 2), channelId) + '.metadata.ndjson';
};
// pass in the path so we can reuse the same function for archived files
var channelExists = function (filepath, cb) {
Fs.stat(filepath, function (err, stat) {
if (err) {
if (err.code === 'ENOENT') {
// no, the file doesn't exist
return void cb(void 0, false);
}
return void cb(err);
}
if (!stat.isFile()) { return void cb("E_NOT_FILE"); }
return void cb(void 0, true);
});
};
var getMetadataAtPath = function (Env, path, cb) { var getMetadataAtPath = function (Env, path, cb) {
var remainder = ''; var remainder = '';
var stream = Fs.createReadStream(path, { encoding: 'utf8' }); var stream = Fs.createReadStream(path, { encoding: 'utf8' });
@ -80,6 +103,7 @@ var closeChannel = function (env, channelName, cb) {
var clearChannel = function (env, channelId, cb) { var clearChannel = function (env, channelId, cb) {
var path = mkPath(env, channelId); var path = mkPath(env, channelId);
// FIXME METADATA
getMetadataAtPath(env, path, function (e, metadata) { getMetadataAtPath(env, path, function (e, metadata) {
if (e) { return cb(new Error(e)); } if (e) { return cb(new Error(e)); }
if (!metadata) { if (!metadata) {
@ -209,31 +233,21 @@ var checkPath = function (path, callback) {
}); });
}; };
// FIXME METADATA
// remove associated metadata as well
var removeChannel = function (env, channelName, cb) { var removeChannel = function (env, channelName, cb) {
var filename = mkPath(env, channelName); var filename = mkPath(env, channelName);
Fs.unlink(filename, cb); Fs.unlink(filename, cb);
}; };
// pass in the path so we can reuse the same function for archived files // FIXME
var channelExists = function (filepath, channelName, cb) { // remove associated metadata as well
Fs.stat(filepath, function (err, stat) {
if (err) {
if (err.code === 'ENOENT') {
// no, the file doesn't exist
return void cb(void 0, false);
}
return void cb(err);
}
if (!stat.isFile()) { return void cb("E_NOT_FILE"); }
return void cb(void 0, true);
});
};
var removeArchivedChannel = function (env, channelName, cb) { var removeArchivedChannel = function (env, channelName, cb) {
var filename = mkArchivePath(env, channelName); var filename = mkArchivePath(env, channelName);
Fs.unlink(filename, cb); Fs.unlink(filename, cb);
}; };
// TODO confirm that we're ignoring metadata files
var listChannels = function (root, handler, cb) { var listChannels = function (root, handler, cb) {
// do twenty things at a time // do twenty things at a time
var sema = Semaphore.create(20); var sema = Semaphore.create(20);
@ -364,6 +378,8 @@ var channelBytes = function (env, chanName, cb) {
}); });
}; };
// FIXME METADATA
// implement metadata bytes as well?
/*:: /*::
export type ChainPadServer_ChannelInternal_t = { export type ChainPadServer_ChannelInternal_t = {
atime: number, atime: number,
@ -618,13 +634,13 @@ module.exports.create = function (
if (!isValidChannelId(channelName)) { return void cb(new Error('EINVAL')); } if (!isValidChannelId(channelName)) { return void cb(new Error('EINVAL')); }
// construct the path // construct the path
var filepath = mkPath(env, channelName); var filepath = mkPath(env, channelName);
channelExists(filepath, channelName, cb); channelExists(filepath, cb);
}, },
isChannelArchived: function (channelName, cb) { isChannelArchived: function (channelName, cb) {
if (!isValidChannelId(channelName)) { return void cb(new Error('EINVAL')); } if (!isValidChannelId(channelName)) { return void cb(new Error('EINVAL')); }
// construct the path // construct the path
var filepath = mkArchivePath(env, channelName); var filepath = mkArchivePath(env, channelName);
channelExists(filepath, channelName, cb); channelExists(filepath, cb);
}, },
listArchivedChannels: function (handler, cb) { listArchivedChannels: function (handler, cb) {
listChannels(Path.join(env.archiveRoot, 'datastore'), handler, cb); listChannels(Path.join(env.archiveRoot, 'datastore'), handler, cb);

Loading…
Cancel
Save