Quentin01/node-riakcs

a npm package for NodeJS to talk to riak cloud storage

node-riakcs

npm-package for riak cloud storage

Install

  npm install node-riakcs

Configure your client

Request is designed to be the simplest way possible to make http calls. It supports HTTP.

var S3, riakcs, s3;
riakcs = require('node-riakcs');
S3 = riakcs.load('s3').S3;

var s3 = new S3({
    'accessKeyId' : "<YOUR_KEY_ID>", //required
    'secretAccessKey' : "<YOUR_SECRET>", //required
    'hostname' : "<YOUR_HOST>", //required
    'protocol' : "http", //optional
    'proxy' : "http://localhost:8080", //optional
});

Examples (coffeescript + fmt)

Get Buckets

require 'fmt'
s3.ListBuckets (err, data)->
  if err?
    fmt.dump err, 'err'
  if data?
    fmt.dump data, 'data'

Create a bucket

require 'fmt'

bucketArgs = {
  BucketName : 'myBucket',
}

s3.CreateBucket bucketArgs , (err, data)->
  if err?
    fmt.dump err, 'err'
  else  
    fmt.dump data, 'data'

Delete a bucket

require 'fmt'

bucketArgs = {
  BucketName : 'myBucket'
}

s3.DeleteBucket bucketArgs , (err, data)->
  if err?
    fmt.dump err, 'err'
  else  
    fmt.dump data, 'data'

Put an object (file)

fmt = require 'fmt'
fs = require 'fs'

__filename ='my_local_song.mp3'

fs.stat __filename, (err, file_info)->
  data = fs.readFileSync( __filename )
  createArgs = {
    BucketName    : 'mybucket',
    ObjectName    : 'my_bucket_song.mp3',
    ContentLength : file_info.size,
    Body          : data
  } 
  
  s3.PutObject createArgs, (error, result)->
    if error?
      fmt.dump error, 'err'
    else          
      fmt.dump result, 'data'

Delete an object

require 'fmt'

args = {
  ObjectName : 'myObject',
  BucketName : 'myBucket'
}

s3.DeleteObject Args , (err, data)->
  if err?
    fmt.dump err, 'err'
  else  
    fmt.dump data, 'data'

Create a user (as admin user)

require 'fmt'

userArgs = {
  Email: 'myname@mydomain.com',
  Name: 'my name',
  ContentType: 'application/json',
  UserPath : 'riak-cs/user'
}

s3.CreateUser userArgs, (err, data)->
  if err?
    fmt.dump err, 'err'
  if data?
    fmt.dump data, 'data'

Get user information (as admin user for every user, or for oneself)

require 'fmt'

s3.GetUser { ObjectName : "<USER_KEYS>", UserPath : 'riak-cs/user/'}, (err, data)->
  if err? 
    fmt.dump err, 'err'
  if data?
    fmt.dump data, 'data'