verdnatura-mirror
/
loopback-component-storage
mirror of https://github.com/strongloop/loopback-component-storage.git
0
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Reformat code

This commit is contained in:
Raymond Feng 2014-01-24 09:44:58 -08:00
parent 5db8da8c23
commit 70f5d6dc35
10 changed files with 538 additions and 539 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

87
example/app-cloud.js
View File

@ -2,26 +2,26 @@ var StorageService = require('../').StorageService;
var path = require('path'); var path = require('path');
var rs = StorageService({ var rs = StorageService({
provider: 'rackspace', provider: 'rackspace',
username: 'strongloop', username: 'strongloop',
apiKey: 'your-rackspace-api-key' apiKey: 'your-rackspace-api-key'
}); });
// Container // Container
rs.getContainers(function (err, containers) { rs.getContainers(function (err, containers) {
if (err) { if (err) {
console.error(err); console.error(err);
return; return;
} }
containers.forEach(function (c) { containers.forEach(function (c) {
console.log('rackspace: ', c.name); console.log('rackspace: ', c.name);
c.getFiles(function (err, files) { c.getFiles(function (err, files) {
files.forEach(function (f) { files.forEach(function (f) {
console.log('....', f.name); console.log('....', f.name);
}); });
});
}); });
});
}); });
/* /*
@ -38,54 +38,51 @@ rs.getContainers(function (err, containers) {
client.removeFile(container, file, function (err) { }); client.removeFile(container, file, function (err) { });
*/ */
var s3 = StorageService({ var s3 = StorageService({
provider: 'amazon', provider: 'amazon',
key: 'your-amazon-key', key: 'your-amazon-key',
keyId: 'your-amazon-key-id' keyId: 'your-amazon-key-id'
}); });
s3.getContainers(function (err, containers) { s3.getContainers(function (err, containers) {
if (err) { if (err) {
console.error(err); console.error(err);
return; return;
} }
containers.forEach(function (c) { containers.forEach(function (c) {
console.log('amazon: ', c.name); console.log('amazon: ', c.name);
c.getFiles(function (err, files) { c.getFiles(function (err, files) {
files.forEach(function (f) { files.forEach(function (f) {
console.log('....', f.name); console.log('....', f.name);
}); });
});
}); });
});
}); });
var fs = require('fs'); var fs = require('fs');
var path = require('path'); var path = require('path');
var stream = s3.uploadStream('con1','test.jpg'); var stream = s3.uploadStream('con1', 'test.jpg');
var input = fs.createReadStream(path.join(__dirname, 'test.jpg')).pipe(stream); var input = fs.createReadStream(path.join(__dirname, 'test.jpg')).pipe(stream);
var local = StorageService({ var local = StorageService({
provider: 'filesystem', provider: 'filesystem',
root: path.join(__dirname, 'storage') root: path.join(__dirname, 'storage')
}); });
// Container // Container
local.getContainers(function (err, containers) { local.getContainers(function (err, containers) {
if (err) { if (err) {
console.error(err); console.error(err);
return; return;
} }
containers.forEach(function (c) { containers.forEach(function (c) {
console.log('filesystem: ', c.name); console.log('filesystem: ', c.name);
c.getFiles(function (err, files) { c.getFiles(function (err, files) {
files.forEach(function (f) { files.forEach(function (f) {
console.log('....', f.name); console.log('....', f.name);
}); });
});
}); });
});
}); });

32
example/app.js
View File

@ -1,5 +1,5 @@
var loopback = require('loopback') var loopback = require('loopback')
, app = module.exports = loopback(); , app = module.exports = loopback();
var path = require('path'); var path = require('path');
@ -9,13 +9,13 @@ app.use(app.router);
app.use(loopback.rest()); app.use(loopback.rest());
app.configure(function () { app.configure(function () {
app.set('port', process.env.PORT || 3000); app.set('port', process.env.PORT || 3000);
}); });
var ds = loopback.createDataSource({ var ds = loopback.createDataSource({
connector: require('../index'), connector: require('../index'),
provider: 'filesystem', provider: 'filesystem',
root: path.join(__dirname, 'storage') root: path.join(__dirname, 'storage')
}); });
var container = ds.createModel('container'); var container = ds.createModel('container');
@ -23,17 +23,17 @@ var container = ds.createModel('container');
app.model(container); app.model(container);
app.get('/', function (req, res, next) { app.get('/', function (req, res, next) {
res.setHeader('Content-Type', 'text/html'); res.setHeader('Content-Type', 'text/html');
var form = "<html><body><h1>Storage Service Demo</h1>" + var form = "<html><body><h1>Storage Service Demo</h1>" +
"<a href='/containers'>List all containers</a><p>" + "<a href='/containers'>List all containers</a><p>" +
"Upload to container c1: <p>" + "Upload to container c1: <p>" +
"<form method='POST' enctype='multipart/form-data' action='/containers/container1/upload'>" "<form method='POST' enctype='multipart/form-data' action='/containers/container1/upload'>"
+ "File to upload: <input type=file name=uploadedFiles multiple=true><br>" + "File to upload: <input type=file name=uploadedFiles multiple=true><br>"
+ "Notes about the file: <input type=text name=note><br>" + "Notes about the file: <input type=text name=note><br>"
+ "<input type=submit value=Upload></form>" + + "<input type=submit value=Upload></form>" +
"</body></html>"; "</body></html>";
res.send(form); res.send(form);
res.end(); res.end();
}); });
app.listen(app.get('port')); app.listen(app.get('port'));

94
example/upload-amazon.js
View File

@ -4,75 +4,75 @@ var express = require('express');
var app = express(); var app = express();
app.configure(function () { app.configure(function () {
app.set('port', process.env.PORT || 3001); app.set('port', process.env.PORT || 3001);
app.set('views', __dirname + '/views'); app.set('views', __dirname + '/views');
app.set('view engine', 'ejs'); app.set('view engine', 'ejs');
app.use(express.favicon()); app.use(express.favicon());
// app.use(express.logger('dev')); // app.use(express.logger('dev'));
app.use(express.methodOverride()); app.use(express.methodOverride());
app.use(app.router); app.use(app.router);
}); });
var handler = new StorageService( var handler = new StorageService(
{ {
provider: 'amazon', provider: 'amazon',
key: 'your-amazon-key', key: 'your-amazon-key',
keyId: 'your-amazon-key-id' keyId: 'your-amazon-key-id'
}); });
app.get('/', function (req, res, next) { app.get('/', function (req, res, next) {
res.setHeader('Content-Type', 'text/html'); res.setHeader('Content-Type', 'text/html');
var form = "<html><body><h1>Storage Service Demo</h1>" + var form = "<html><body><h1>Storage Service Demo</h1>" +
"<a href='/download'>List all containers</a><p>" + "<a href='/download'>List all containers</a><p>" +
"Upload to container con1: <p>" + "Upload to container con1: <p>" +
"<form method='POST' enctype='multipart/form-data' action='/upload/con1'>" "<form method='POST' enctype='multipart/form-data' action='/upload/con1'>"
+ "File to upload: <input type=file name=uploadedFiles multiple=true><br>" + "File to upload: <input type=file name=uploadedFiles multiple=true><br>"
+ "Notes about the file: <input type=text name=note><br>" + "Notes about the file: <input type=text name=note><br>"
+ "<input type=submit value=Upload></form>" + + "<input type=submit value=Upload></form>" +
"</body></html>"; "</body></html>";
res.send(form); res.send(form);
res.end(); res.end();
}); });
app.post('/upload/:container', function (req, res, next) { app.post('/upload/:container', function (req, res, next) {
handler.upload(req, res, function (err, result) { handler.upload(req, res, function (err, result) {
if (!err) { if (!err) {
res.setHeader('Content-Type', 'application/json'); res.setHeader('Content-Type', 'application/json');
res.send(200, result); res.send(200, result);
} else { } else {
res.send(500, err); res.send(500, err);
} }
}); });
}); });
app.get('/download', function (req, res, next) { app.get('/download', function (req, res, next) {
handler.getContainers(function (err, containers) { handler.getContainers(function (err, containers) {
var html = "<html><body><h1>Containers</h1><ul>"; var html = "<html><body><h1>Containers</h1><ul>";
containers.forEach(function (f) { containers.forEach(function (f) {
html += "<li><a href='/download/" + f.name + "'>" + f.name + "</a></li>" html += "<li><a href='/download/" + f.name + "'>" + f.name + "</a></li>"
});
html += "</ul><p><a href='/'>Home</a></p></body></html>";
res.send(200, html);
}); });
html += "</ul><p><a href='/'>Home</a></p></body></html>";
res.send(200, html);
});
}); });
app.get('/download/:container', function (req, res, next) { app.get('/download/:container', function (req, res, next) {
handler.getFiles(req.params.container, function (err, files) { handler.getFiles(req.params.container, function (err, files) {
var html = "<html><body><h1>Files in container " + req.params.container + "</h1><ul>"; var html = "<html><body><h1>Files in container " + req.params.container + "</h1><ul>";
files.forEach(function (f) { files.forEach(function (f) {
html += "<li><a href='/download/" + f.container + "/" + f.name + "'>" + f.container + "/" + f.name + "</a></li>" html += "<li><a href='/download/" + f.container + "/" + f.name + "'>" + f.container + "/" + f.name + "</a></li>"
});
html += "</ul><p><a href='/'>Home</a></p></body></html>";
res.send(200, html);
}); });
html += "</ul><p><a href='/'>Home</a></p></body></html>";
res.send(200, html);
});
}); });
app.get('/download/:container/:file', function (req, res, next) { app.get('/download/:container/:file', function (req, res, next) {
handler.download(req, res, function (err, result) { handler.download(req, res, function (err, result) {
if (err) { if (err) {
res.send(500, err); res.send(500, err);
} }
}); });
}); });
app.listen(app.get('port')); app.listen(app.get('port'));

90
example/upload.js
View File

@ -4,13 +4,13 @@ var express = require('express');
var app = express(); var app = express();
app.configure(function () { app.configure(function () {
app.set('port', process.env.PORT || 3001); app.set('port', process.env.PORT || 3001);
app.set('views', __dirname + '/views'); app.set('views', __dirname + '/views');
app.set('view engine', 'ejs'); app.set('view engine', 'ejs');
app.use(express.favicon()); app.use(express.favicon());
// app.use(express.logger('dev')); // app.use(express.logger('dev'));
app.use(express.methodOverride()); app.use(express.methodOverride());
app.use(app.router); app.use(app.router);
}); });
// Create the container // Create the container
@ -20,58 +20,58 @@ mkdirp.sync('/tmp/storage/con1');
var handler = new StorageService({provider: 'filesystem', root: '/tmp/storage'}); var handler = new StorageService({provider: 'filesystem', root: '/tmp/storage'});
app.get('/', function (req, res, next) { app.get('/', function (req, res, next) {
res.setHeader('Content-Type', 'text/html'); res.setHeader('Content-Type', 'text/html');
var form = "<html><body><h1>Storage Service Demo</h1>" + var form = "<html><body><h1>Storage Service Demo</h1>" +
"<a href='/download'>List all containers</a><p>" + "<a href='/download'>List all containers</a><p>" +
"Upload to container con1: <p>" + "Upload to container con1: <p>" +
"<form method='POST' enctype='multipart/form-data' action='/upload/con1'>" "<form method='POST' enctype='multipart/form-data' action='/upload/con1'>"
+ "File to upload: <input type=file name=uploadedFiles multiple=true><br>" + "File to upload: <input type=file name=uploadedFiles multiple=true><br>"
+ "Notes about the file: <input type=text name=note><br>" + "Notes about the file: <input type=text name=note><br>"
+ "<input type=submit value=Upload></form>" + + "<input type=submit value=Upload></form>" +
"</body></html>"; "</body></html>";
res.send(form); res.send(form);
res.end(); res.end();
}); });
app.post('/upload/:container', function (req, res, next) { app.post('/upload/:container', function (req, res, next) {
handler.upload(req, res, function (err, result) { handler.upload(req, res, function (err, result) {
if (!err) { if (!err) {
res.setHeader('Content-Type', 'application/json'); res.setHeader('Content-Type', 'application/json');
res.send(200, result); res.send(200, result);
} else { } else {
res.send(500, err); res.send(500, err);
} }
}); });
}); });
app.get('/download', function (req, res, next) { app.get('/download', function (req, res, next) {
handler.getContainers(function (err, containers) { handler.getContainers(function (err, containers) {
var html = "<html><body><h1>Containers</h1><ul>"; var html = "<html><body><h1>Containers</h1><ul>";
containers.forEach(function (f) { containers.forEach(function (f) {
html += "<li><a href='/download/" + f.name + "'>" + f.name + "</a></li>" html += "<li><a href='/download/" + f.name + "'>" + f.name + "</a></li>"
});
html += "</ul><p><a href='/'>Home</a></p></body></html>";
res.send(200, html);
}); });
html += "</ul><p><a href='/'>Home</a></p></body></html>";
res.send(200, html);
});
}); });
app.get('/download/:container', function (req, res, next) { app.get('/download/:container', function (req, res, next) {
handler.getFiles(req.params.container, function (err, files) { handler.getFiles(req.params.container, function (err, files) {
var html = "<html><body><h1>Files in container " + req.params.container + "</h1><ul>"; var html = "<html><body><h1>Files in container " + req.params.container + "</h1><ul>";
files.forEach(function (f) { files.forEach(function (f) {
html += "<li><a href='/download/" + f.container + "/" + f.name + "'>" + f.container + "/" + f.name + "</a></li>" html += "<li><a href='/download/" + f.container + "/" + f.name + "'>" + f.container + "/" + f.name + "</a></li>"
});
html += "</ul><p><a href='/'>Home</a></p></body></html>";
res.send(200, html);
}); });
html += "</ul><p><a href='/'>Home</a></p></body></html>";
res.send(200, html);
});
}); });
app.get('/download/:container/:file', function (req, res, next) { app.get('/download/:container/:file', function (req, res, next) {
handler.download(req, res, function (err, result) { handler.download(req, res, function (err, result) {
if (err) { if (err) {
res.send(500, err); res.send(500, err);
} }
}); });
}); });
app.listen(app.get('port')); app.listen(app.get('port'));

36
lib/factory.js
View File

@ -4,19 +4,19 @@
* @returns {*} * @returns {*}
*/ */
function createClient(options) { function createClient(options) {
options = options || {}; options = options || {};
var provider = options.provider || 'filesystem'; var provider = options.provider || 'filesystem';
var handler; var handler;
try { try {
// Try to load the provider from providers folder // Try to load the provider from providers folder
handler = require('./providers/' + provider); handler = require('./providers/' + provider);
} catch (err) { } catch (err) {
// Fall back to pkgcloud // Fall back to pkgcloud
handler = require('pkgcloud').storage; handler = require('pkgcloud').storage;
} }
return handler.createClient(options); return handler.createClient(options);
} }
/** /**
@ -25,13 +25,13 @@ function createClient(options) {
* @returns {*} * @returns {*}
*/ */
function getProvider(provider) { function getProvider(provider) {
try { try {
// Try to load the provider from providers folder // Try to load the provider from providers folder
return require('./providers/' + provider); return require('./providers/' + provider);
} catch (err) { } catch (err) {
// Fall back to pkgcloud // Fall back to pkgcloud
return require('pkgcloud').providers[provider]; return require('pkgcloud').providers[provider];
} }
} }
module.exports.createClient = createClient; module.exports.createClient = createClient;

30
lib/storage-connector.js
View File

@ -5,22 +5,24 @@ var StorageService = require('./storage-service');
* @param callback * @param callback
*/ */
exports.initialize = function (dataSource, callback) { exports.initialize = function (dataSource, callback) {
var settings = dataSource.settings || {}; var settings = dataSource.settings || {};
var connector = new StorageService(settings); var connector = new StorageService(settings);
dataSource.connector = connector; dataSource.connector = connector;
dataSource.connector.dataSource = dataSource; dataSource.connector.dataSource = dataSource;
connector.DataAccessObject = function() {}; connector.DataAccessObject = function () {
for (var m in StorageService.prototype) { };
var method = StorageService.prototype[m]; for (var m in StorageService.prototype) {
if ('function' === typeof method) { var method = StorageService.prototype[m];
connector.DataAccessObject[m] = method.bind(connector); if ('function' === typeof method) {
for(var k in method) { connector.DataAccessObject[m] = method.bind(connector);
connector.DataAccessObject[m][k] = method[k]; for (var k in method) {
} connector.DataAccessObject[m][k] = method[k];
} }
} }
}
connector.define = function(model, properties, settings) {}; connector.define = function (model, properties, settings) {
};
}; };

178
lib/storage-handler.js
View File

@ -10,96 +10,96 @@ var StringDecoder = require('string_decoder').StringDecoder;
* @param {Function} cb The callback * @param {Function} cb The callback
*/ */
exports.upload = function (provider, req, res, container, cb) { exports.upload = function (provider, req, res, container, cb) {
var form = new IncomingForm(this.options); var form = new IncomingForm(this.options);
container = container || req.params.container; container = container || req.params.container;
var fields = {}, files = {}; var fields = {}, files = {};
form.handlePart = function (part) { form.handlePart = function (part) {
var self = this; var self = this;
if (part.filename === undefined) { if (part.filename === undefined) {
var value = '' var value = ''
, decoder = new StringDecoder(this.encoding); , decoder = new StringDecoder(this.encoding);
part.on('data', function (buffer) { part.on('data', function (buffer) {
self._fieldsSize += buffer.length; self._fieldsSize += buffer.length;
if (self._fieldsSize > self.maxFieldsSize) { if (self._fieldsSize > self.maxFieldsSize) {
self._error(new Error('maxFieldsSize exceeded, received ' + self._fieldsSize + ' bytes of field data')); self._error(new Error('maxFieldsSize exceeded, received ' + self._fieldsSize + ' bytes of field data'));
return; return;
}
value += decoder.write(buffer);
});
part.on('end', function () {
var values = fields[part.name];
if(values === undefined) {
values = [value];
fields[part.name] = values;
} else {
values.push(value);
}
self.emit('field', part.name, value);
});
return;
} }
value += decoder.write(buffer);
});
this._flushing++; part.on('end', function () {
var values = fields[part.name];
var file = { if (values === undefined) {
container: container, values = [value];
name: part.filename, fields[part.name] = values;
type: part.mime } else {
}; values.push(value);
self.emit('fileBegin', part.name, file);
var headers = {};
if('content-type' in part.headers) {
headers['content-type'] = part.headers['content-type'];
} }
var writer = provider.upload({container: container, remote: part.filename}); self.emit('field', part.name, value);
});
return;
}
var endFunc = function () { this._flushing++;
self._flushing--;
var values = files[part.name];
if(values === undefined) {
values = [file];
files[part.name] = values;
} else {
values.push(file);
}
self.emit('file', part.name, file);
self._maybeEnd();
};
/* var file = {
part.on('data', function (buffer) { container: container,
self.pause(); name: part.filename,
writer.write(buffer, function () { type: part.mime
// pkgcloud stream doesn't make callbacks
});
self.resume();
});
part.on('end', function () {
writer.end(); // pkgcloud stream doesn't make callbacks
endFunc();
});
*/
part.pipe(writer, { end: false });
part.on("end", function() {
writer.end();
endFunc();
});
}; };
form.parse(req, function (err, _fields, _files) { self.emit('fileBegin', part.name, file);
if(err) {
console.error(err); var headers = {};
} if ('content-type' in part.headers) {
cb && cb(err, {files: files, fields: fields}); headers['content-type'] = part.headers['content-type'];
}
var writer = provider.upload({container: container, remote: part.filename});
var endFunc = function () {
self._flushing--;
var values = files[part.name];
if (values === undefined) {
values = [file];
files[part.name] = values;
} else {
values.push(file);
}
self.emit('file', part.name, file);
self._maybeEnd();
};
/*
part.on('data', function (buffer) {
self.pause();
writer.write(buffer, function () {
// pkgcloud stream doesn't make callbacks
});
self.resume();
});
part.on('end', function () {
writer.end(); // pkgcloud stream doesn't make callbacks
endFunc();
});
*/
part.pipe(writer, { end: false });
part.on("end", function () {
writer.end();
endFunc();
}); });
};
form.parse(req, function (err, _fields, _files) {
if (err) {
console.error(err);
}
cb && cb(err, {files: files, fields: fields});
});
} }
/** /**
@ -111,15 +111,15 @@ exports.upload = function (provider, req, res, container, cb) {
* @param {String} file The file name * @param {String} file The file name
* @param {Function} cb The callback * @param {Function} cb The callback
*/ */
exports.download = function(provider, req, res, container, file, cb) { exports.download = function (provider, req, res, container, file, cb) {
var reader = provider.download({ var reader = provider.download({
container: container || req && req.params.container, container: container || req && req.params.container,
remote: file || req && req.params.file remote: file || req && req.params.file
}); });
reader.pipe(res); reader.pipe(res);
reader.on('error', function(err) { reader.on('error', function (err) {
res.send(500, { error: err }); res.send(500, { error: err });
}); });
} }

32
lib/storage-service.js
View File

@ -24,22 +24,22 @@ function StorageService(options) {
function map(obj) { function map(obj) {
return obj; return obj;
/* /*
if (!obj || typeof obj !== 'object') { if (!obj || typeof obj !== 'object') {
return obj; return obj;
} }
var data = {}; var data = {};
for (var i in obj) { for (var i in obj) {
if (obj.hasOwnProperty(i) && typeof obj[i] !== 'function' if (obj.hasOwnProperty(i) && typeof obj[i] !== 'function'
&& typeof obj[i] !== 'object') { && typeof obj[i] !== 'object') {
if (i === 'newListener' || i === 'delimiter' || i === 'wildcard') { if (i === 'newListener' || i === 'delimiter' || i === 'wildcard') {
// Skip properties from the base class // Skip properties from the base class
continue; continue;
} }
data[i] = obj[i]; data[i] = obj[i];
} }
} }
return data; return data;
*/ */
} }
StorageService.prototype.getContainers = function (cb) { StorageService.prototype.getContainers = function (cb) {

268
test/fs.test.js
View File

@ -5,143 +5,143 @@ var path = require('path');
describe('FileSystem based storage provider', function () { describe('FileSystem based storage provider', function () {
describe('container apis', function () { describe('container apis', function () {
var client = null; var client = null;
it('should require an existing directory as the root', function (done) { it('should require an existing directory as the root', function (done) {
client = new FileSystemProvider({root: path.join(__dirname, 'storage')}); client = new FileSystemProvider({root: path.join(__dirname, 'storage')});
process.nextTick(done); process.nextTick(done);
});
it('should complain if the root directory doesn\'t exist', function (done) {
try {
client = new FileSystemProvider({root: path.join(__dirname, '_storage')});
process.nextTick(done.bind(null, 'Error'));
} catch (err) {
// Should be here
process.nextTick(done);
}
});
it('should return an empty list of containers', function (done) {
client.getContainers(function (err, containers) {
assert(!err);
assert.equal(0, containers.length);
done(err, containers);
});
});
it('should create a new container', function (done) {
client.createContainer({name: 'c1'}, function (err, container) {
assert(!err);
done(err, container);
});
});
it('should get a container c1', function (done) {
client.getContainer('c1', function (err, container) {
assert(!err);
done(err, container);
});
});
it('should not get a container c2', function (done) {
client.getContainer('c2', function (err, container) {
assert(err);
done(null, container);
});
});
it('should return one container', function (done) {
client.getContainers(function (err, containers) {
assert(!err);
assert.equal(1, containers.length);
done(err, containers);
});
});
it('should destroy a container c1', function (done) {
client.destroyContainer('c1', function (err, container) {
assert(!err);
done(err, container);
});
});
it('should not get a container c1 after destroy', function (done) {
client.getContainer('c1', function (err, container) {
assert(err);
done(null, container);
});
});
}); });
describe('file apis', function () { it('should complain if the root directory doesn\'t exist', function (done) {
var fs = require('fs'); try {
var client = new FileSystemProvider({root: path.join(__dirname, 'storage')}); client = new FileSystemProvider({root: path.join(__dirname, '_storage')});
process.nextTick(done.bind(null, 'Error'));
it('should create a new container', function (done) { } catch (err) {
client.createContainer({name: 'c1'}, function (err, container) { // Should be here
assert(!err); process.nextTick(done);
done(err, container); }
});
});
it('should upload a file', function (done) {
var writer = client.upload({container: 'c1', remote: 'f1.txt'});
fs.createReadStream(path.join(__dirname, 'files/f1.txt')).pipe(writer);
writer.on('finish', done);
writer.on('error', done);
});
it('should download a file', function (done) {
var reader = client.download({
container: 'c1',
remote: 'f1.txt'
});
reader.pipe(fs.createWriteStream(path.join(__dirname, 'files/f1_downloaded.txt')));
reader.on('end', done);
reader.on('error', done);
});
it('should get files for a container', function (done) {
client.getFiles('c1', function (err, files) {
assert(!err);
assert.equal(1, files.length);
done(err, files);
});
});
it('should get a file', function (done) {
client.getFile('c1', 'f1.txt', function (err, f) {
assert(!err);
assert.ok(f);
done(err, f);
});
});
it('should remove a file', function (done) {
client.removeFile('c1', 'f1.txt', function (err) {
assert(!err);
done(err);
});
});
it('should get no files from a container', function (done) {
client.getFiles('c1', function (err, files) {
assert(!err);
assert.equal(0, files.length);
done(err, files);
});
});
it('should destroy a container c1', function (done) {
client.destroyContainer('c1', function (err, container) {
// console.error(err);
assert(!err);
done(err, container);
});
});
}); });
it('should return an empty list of containers', function (done) {
client.getContainers(function (err, containers) {
assert(!err);
assert.equal(0, containers.length);
done(err, containers);
});
});
it('should create a new container', function (done) {
client.createContainer({name: 'c1'}, function (err, container) {
assert(!err);
done(err, container);
});
});
it('should get a container c1', function (done) {
client.getContainer('c1', function (err, container) {
assert(!err);
done(err, container);
});
});
it('should not get a container c2', function (done) {
client.getContainer('c2', function (err, container) {
assert(err);
done(null, container);
});
});
it('should return one container', function (done) {
client.getContainers(function (err, containers) {
assert(!err);
assert.equal(1, containers.length);
done(err, containers);
});
});
it('should destroy a container c1', function (done) {
client.destroyContainer('c1', function (err, container) {
assert(!err);
done(err, container);
});
});
it('should not get a container c1 after destroy', function (done) {
client.getContainer('c1', function (err, container) {
assert(err);
done(null, container);
});
});
});
describe('file apis', function () {
var fs = require('fs');
var client = new FileSystemProvider({root: path.join(__dirname, 'storage')});
it('should create a new container', function (done) {
client.createContainer({name: 'c1'}, function (err, container) {
assert(!err);
done(err, container);
});
});
it('should upload a file', function (done) {
var writer = client.upload({container: 'c1', remote: 'f1.txt'});
fs.createReadStream(path.join(__dirname, 'files/f1.txt')).pipe(writer);
writer.on('finish', done);
writer.on('error', done);
});
it('should download a file', function (done) {
var reader = client.download({
container: 'c1',
remote: 'f1.txt'
});
reader.pipe(fs.createWriteStream(path.join(__dirname, 'files/f1_downloaded.txt')));
reader.on('end', done);
reader.on('error', done);
});
it('should get files for a container', function (done) {
client.getFiles('c1', function (err, files) {
assert(!err);
assert.equal(1, files.length);
done(err, files);
});
});
it('should get a file', function (done) {
client.getFile('c1', 'f1.txt', function (err, f) {
assert(!err);
assert.ok(f);
done(err, f);
});
});
it('should remove a file', function (done) {
client.removeFile('c1', 'f1.txt', function (err) {
assert(!err);
done(err);
});
});
it('should get no files from a container', function (done) {
client.getFiles('c1', function (err, files) {
assert(!err);
assert.equal(0, files.length);
done(err, files);
});
});
it('should destroy a container c1', function (done) {
client.destroyContainer('c1', function (err, container) {
// console.error(err);
assert(!err);
done(err, container);
});
});
});
}); });

228
test/storage-service.test.js
View File

@ -7,124 +7,124 @@ var storageService = new StorageService({root: path.join(__dirname, 'storage'),
describe('Storage service', function () { describe('Storage service', function () {
describe('container apis', function () { describe('container apis', function () {
it('should return an empty list of containers', function (done) { it('should return an empty list of containers', function (done) {
storageService.getContainers(function (err, containers) { storageService.getContainers(function (err, containers) {
assert(!err); assert(!err);
assert.equal(0, containers.length); assert.equal(0, containers.length);
done(err, containers); done(err, containers);
}); });
});
it('should create a new container', function (done) {
storageService.createContainer({name: 'c1'}, function (err, container) {
assert(!err);
done(err, container);
});
});
it('should get a container c1', function (done) {
storageService.getContainer('c1', function (err, container) {
assert(!err);
done(err, container);
});
});
it('should not get a container c2', function (done) {
storageService.getContainer('c2', function (err, container) {
assert(err);
done(null, container);
});
});
it('should return one container', function (done) {
storageService.getContainers(function (err, containers) {
assert(!err);
assert.equal(1, containers.length);
done(err, containers);
});
});
it('should destroy a container c1', function (done) {
storageService.destroyContainer('c1', function (err, container) {
assert(!err);
done(err, container);
});
});
it('should not get a container c1 after destroy', function (done) {
storageService.getContainer('c1', function (err, container) {
assert(err);
done(null, container);
});
});
}); });
describe('file apis', function () { it('should create a new container', function (done) {
var fs = require('fs'); storageService.createContainer({name: 'c1'}, function (err, container) {
assert(!err);
it('should create a new container', function (done) { done(err, container);
storageService.createContainer({name: 'c1'}, function (err, container) { });
assert(!err);
done(err, container);
});
});
it('should upload a file', function (done) {
var writer = storageService.uploadStream('c1', 'f1.txt');
fs.createReadStream(path.join(__dirname, 'files/f1.txt')).pipe(writer);
writer.on('finish', done);
writer.on('error', done);
});
it('should download a file', function (done) {
var reader = storageService.downloadStream('c1','f1.txt');
reader.pipe(fs.createWriteStream(path.join(__dirname, 'files/f1_downloaded.txt')));
reader.on('end', done);
reader.on('error', done);
});
it('should get files for a container', function (done) {
storageService.getFiles('c1', function (err, files) {
assert(!err);
assert.equal(1, files.length);
done(err, files);
});
});
it('should get a file', function (done) {
storageService.getFile('c1', 'f1.txt', function (err, f) {
assert(!err);
assert.ok(f);
done(err, f);
});
});
it('should remove a file', function (done) {
storageService.removeFile('c1', 'f1.txt', function (err) {
assert(!err);
done(err);
});
});
it('should get no files from a container', function (done) {
storageService.getFiles('c1', function (err, files) {
assert(!err);
assert.equal(0, files.length);
done(err, files);
});
});
it('should destroy a container c1', function (done) {
storageService.destroyContainer('c1', function (err, container) {
// console.error(err);
assert(!err);
done(err, container);
});
});
}); });
it('should get a container c1', function (done) {
storageService.getContainer('c1', function (err, container) {
assert(!err);
done(err, container);
});
});
it('should not get a container c2', function (done) {
storageService.getContainer('c2', function (err, container) {
assert(err);
done(null, container);
});
});
it('should return one container', function (done) {
storageService.getContainers(function (err, containers) {
assert(!err);
assert.equal(1, containers.length);
done(err, containers);
});
});
it('should destroy a container c1', function (done) {
storageService.destroyContainer('c1', function (err, container) {
assert(!err);
done(err, container);
});
});
it('should not get a container c1 after destroy', function (done) {
storageService.getContainer('c1', function (err, container) {
assert(err);
done(null, container);
});
});
});
describe('file apis', function () {
var fs = require('fs');
it('should create a new container', function (done) {
storageService.createContainer({name: 'c1'}, function (err, container) {
assert(!err);
done(err, container);
});
});
it('should upload a file', function (done) {
var writer = storageService.uploadStream('c1', 'f1.txt');
fs.createReadStream(path.join(__dirname, 'files/f1.txt')).pipe(writer);
writer.on('finish', done);
writer.on('error', done);
});
it('should download a file', function (done) {
var reader = storageService.downloadStream('c1', 'f1.txt');
reader.pipe(fs.createWriteStream(path.join(__dirname, 'files/f1_downloaded.txt')));
reader.on('end', done);
reader.on('error', done);
});
it('should get files for a container', function (done) {
storageService.getFiles('c1', function (err, files) {
assert(!err);
assert.equal(1, files.length);
done(err, files);
});
});
it('should get a file', function (done) {
storageService.getFile('c1', 'f1.txt', function (err, f) {
assert(!err);
assert.ok(f);
done(err, f);
});
});
it('should remove a file', function (done) {
storageService.removeFile('c1', 'f1.txt', function (err) {
assert(!err);
done(err);
});
});
it('should get no files from a container', function (done) {
storageService.getFiles('c1', function (err, files) {
assert(!err);
assert.equal(0, files.length);
done(err, files);
});
});
it('should destroy a container c1', function (done) {
storageService.destroyContainer('c1', function (err, container) {
// console.error(err);
assert(!err);
done(err, container);
});
});
});
}); });