index.js

'use strict';

// # S3 storage module for Ghost blog http://ghost.org/
var fs = require('fs');
var path = require('path');
var nodefn = require('when/node/function');
var when = require('when');
var readFile = nodefn.lift(fs.readFile);
var unlink = nodefn.lift(fs.unlink);
var AWS = require('aws-sdk');
var config;


module.exports = function(options) {
    options = options || {};

    if (options.config) {
        config = options.config;
        AWS.config.update(config);
    }
    if (options.errors) errors = options.errors;

    return module.exports;
};


// ### Save
// Saves the image to S3
// - image is the express image object
// - returns a promise which ultimately returns the full url to the uploaded image
module.exports.save = function(image) {
    if (!config) return when.reject('ghost-s3 is not configured');

    var targetDir = getTargetDir();
    var targetFilename = getTargetName(image, targetDir);
    var awsPath = 'https://' + config.bucket + '.s3.amazonaws.com/';

    return readFile(image.path)
    .then(function(buffer) {
        var s3 = new AWS.S3();

        return nodefn.call(s3.putObject.bind(s3), {
            Bucket: config.bucket,
            Key: targetFilename,
            Body: buffer,
            ContentType: image.type,
            CacheControl: 'maxage=' + (30 * 24 * 60 * 60) // 30 days
        });
    })
    .then(function(result) {
        return unlink(image.path);
    })
    .then(function() {
        return when.resolve(awsPath + targetFilename);
    })
    .catch(function(err) {
        unlink(image.path);
        errors.logError(err);
        throw err;
    });
};


// middleware for serving the files
module.exports.serve = function() {
    // a no-op, these are absolute URLs
    return function(){};
};


var MONTHS = [
    'Jan', 'Feb', 'Mar', 'Apr', 'May', 'Jun',
    'Jul', 'Aug', 'Sep', 'Oct', 'Nov', 'Dec'
];
var getTargetDir = function() {
    var now = new Date();
    return path.join(now.getFullYear() + '', MONTHS[now.getMonth()]) + '/';
};


var getTargetName = function(image, targetDir) {
    var ext = path.extname(image.name),
        name = path.basename(image.name, ext).replace(/\W/g, '_');

    return targetDir + name + '-' + Date.now() + ext;
};


// default error handler
var errors = {
    logError: function(error) {
        console.log('error in ghost-s3', error);
    }
};