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 options = {};
var moment = require('moment');

function S3Store(config) {
  options = config || {};
}

S3Store.prototype.save = function(image) {
    var self = this;
    if (!options) return when.reject('ghost-s3 is not configured');

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

    return readFile(image.path)
    .then(function(buffer) {
        var s3 = new AWS.S3({
          accessKeyId: options.accessKeyId,
          secretAccessKey: options.secretAccessKey,
          bucket: options.bucket,
          region: options.region
        });

        return nodefn.call(s3.putObject.bind(s3), {
            ACL: 'public-read',
            Bucket: options.bucket,
            Key: targetFilename,
            Body: buffer,
            ContentType: image.type,
            CacheControl: 'max-age=' + (30 * 24 * 60 * 60) // 30 days
        });
    })
    .then(function(result) {
        self.logInfo('ghost-s3', 'Temp uploaded file path: ' + image.path);
    })
    .then(function() {
        return when.resolve(awsPath + targetFilename);
    })
    .catch(function(err) {
        // fs.unlink(image.path, function (err) {
        //     if (err) throw err;
        //     errors.logInfo('ghost-s3', 'Successfully deleted temp file uploaded');
        // });
        self.logError(err);
        throw err;
    });
};

// middleware for serving the files
S3Store.prototype.serve = function() {
    // a no-op, these are absolute URLs
    return function (req, res, next) {
      next();
    };
};

S3Store.prototype.getTargetDir = function() {
    // var MONTHS = [
    //     'Jan', 'Feb', 'Mar', 'Apr', 'May', 'Jun',
    //     'Jul', 'Aug', 'Sep', 'Oct', 'Nov', 'Dec'
    // ];
    var now = new Date();
    return options.prefix + '/' + moment(now).format('YYYY/MM')
    // return now.getFullYear() + '/' + now.getMonth() + '/';
};

S3Store.prototype.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;
    return targetDir + '/' + Date.now() + ext;
};

S3Store.prototype.logError = function(error) {
    console.log('error in ghost-s3', error);
};

S3Store.prototype.logInfo = function(info) {
    console.log('info in ghost-s3', info);
};

module.exports = S3Store;