Knox

var crypto = require('crypto');

exports.authorization = function(options){
  return 'AWS ' + options.key + ':' + exports.sign(options);
};

exports.sign = function(options){
  var str = exports.stringToSign(options);
  return crypto.createHmac('sha1', options.secret).update(str).digest('base64');
};

exports.stringToSign = function(options){
  var headers = options.amazonHeaders || '';
  if (headers) headers += '\n';
  return [
      options.verb
    , options.md5
    , options.contentType
    , options.date.toUTCString()
    , headers + options.resource
  ].join('\n');
};

exports.canonicalizeHeaders = function(headers){
  var buf = []
    , fields = Object.keys(headers);
  for (var i = 0, len = fields.length; i < len; ++i) {
    var field = fields[i]
      , val = headers[field]
      , field = field.toLowerCase();
    if (0 !== field.indexOf('x-amz')) continue;
    buf.push(field + ':' + val);
  }
  return buf.sort().join('\n');
};

var utils = require('./utils')
  , auth = require('./auth')
  , http = require('http')
  , join = require('path').join;

var Client = module.exports = exports = function Client(options) {
  this.host = 's3.amazonaws.com';
  utils.merge(this, options);
  if (!this.key) throw new Error('aws "key" required');
  if (!this.secret) throw new Error('aws "secret" required');
  if (!this.bucket) throw new Error('aws "bucket" required');
};

Client.prototype.request = function(method, filename, headers){
  var client = http.createClient(80, this.host)
    , path = join('/', this.bucket, filename)
    , date = new Date
    , headers = headers || {};

  // Default headers
  utils.merge(headers, {
      Date: date.toUTCString()
    , Host: this.host
  });

  // Authorization header
  headers.Authorization = auth.authorization({
      key: this.key
    , secret: this.secret
    , verb: method
    , date: date
    , resource: path
    , contentType: headers['Content-Type']
    , amazonHeaders: auth.canonicalizeHeaders(headers)
  });

  var req = client.request(method, path, headers);
  req.url = this.url(filename);
  return req;
};

Client.prototype.put = function(filename, headers){
  headers = utils.merge({
      Expect: '100-continue'
    , 'x-amz-acl': 'public-read'
  }, headers || {});
  return this.request('PUT', filename, headers);
};

Client.prototype.get = function(filename, headers){
  return this.request('GET', filename, headers);
};

Client.prototype.head = function(filename, headers){
  return this.request('HEAD', filename, headers);
};

Client.prototype.del = function(filename, headers){
  return this.request('DELETE', filename, headers);
};

Client.prototype.url = function(filename){
  return 'http://' + this.bucket + '.' + this.host + join('/', filename);
};

exports.createClient = function(options){
  return new Client(options);
};

exports = module.exports = require('./client');

exports.version = '0.0.1';

exports.utils = require('./utils');

exports.auth = require('./auth');

exports.merge = function(a, b){
  var keys = Object.keys(b);
  for (var i = 0, len = keys.length; i < len; ++i) {
    var key = keys[i];
    a[key] = b[key]
  }
  return a;
};

exports.base64 = {

encode: function(str){
    return new Buffer(str).toString('base64');
  },

decode: function(str){
    return new Buffer(str, 'base64').toString();
  }
};