pipe-to-storage

Saves stuff (strings, readable streams, functions yielding readable streams) in a Google Storage bucket, with less typing. Handles retries, mime-types for you. Returns Promise


Keywords
google-cloud-storage, nodejs, promise-wrapper, stream
License
MIT
Install
npm install pipe-to-storage@0.4.0

Documentation

pipe-to-storage

Build Status Known Vulnerabilities Language grade: JavaScript Total alerts

Importing and Setup

On Google platforms:

// storage version 2.x

const {Storage} = require('@google-cloud/storage');
const storage = new Storage();

// storage version 1.x

const storage = require('@google-cloud/storage')(); // storage 1.x

On other platforms: set up your API key, see relevant docs

Pass the storage object when setting up pipeToStorage for usage

const pipeToStorage = require('pipe-to-storage')(storage);

Usage

pipeToStorage(source, bucketName, fileName , optional )
.then(function(what){ 
   console.log("hooray! I wrote "+what.file+" to bucket "+what.bucket+" and it should have md5 "+what.md5);
 })
 .catch(function(e){
   console.log("oh no! an error occurred. here it is:");
   console.log(e);
 });

source must be either:

  • a string, which will be sent as-is to the new file [retry will use the same string]
  • a function that returns a readable stream [retry will call the function to get a fresh readable stream]
  • a readable stream [can not retry]

npm:promise-retry will be used to retry failed storage promises in the first two cases. A retry strategy is used that is appropriate for a cloud back-end environment: up to 3 retries per call within 30 seconds, then fail.

bucketname and filename are the Google Cloud Storage[tm] bucket and file names. gs:// is not needed in bucketName

optional is optional and may be:

  • absent or undefined -- pipeToStorage should try to look up the content-type from the fileName extension
  • the string 'json' -- shorthand to set metadata content-type: application/json
  • other strings -- sets the metadata content-type manually
  • an object, to set any writeStream.options in the internal storage createWriteStream call

returns a Promise that resolves to {bucket, file, md5, length} after saving the contents of source to storage.bucket(bucketName).file(fileName) or rejects with any errors not caught in retrys

md5 is in base64

Tests

This module is tested on Travis CI, but you won't be able to run the same tests yourself without some adjustments.

To run the tests in your own environment, change the storage API credentials (projectId, keyFilename) and the bucket name referenced in ./test/index.js.

Copyright

Copyright 2017 Paul Brewer, Economic and Financial Technology Consulting LLC drpaulbrewer@eaftc.com

License

The MIT License

No relationship to Google, Inc.

This is third party software, not a product of Google Inc.

The author(s) have no relationship to Google, Inc.