Google Cloud Bucket ·
Google Cloud Bucket is node.js package to add objects to a Google Cloud Bucket.
Table of Contents
Install
npm i google-cloud-bucket --save
How To Use It
Prerequisite
Before using this package, you must first:
-
Have a Google Cloud Account.
-
Have a Service Account set up with the following 2 roles:
roles/storage.objectCreator
roles/storage.objectAdmin
(only if you want to update access to object or create/delete buckets)roles/storage.admin
(only if you want to update access to an entire bucket)
-
Get the JSON keys file for that Service Account above
-
Save that JSON key into a service-account.json
file. Make sure it is located under a path that is accessible to your app (the root folder usually).
Basics
const { join } = require('path')
const { client } = require('google-cloud-bucket')
const storage = client.new({
jsonKeyFile: join(__dirname, './service-account.json')
})
storage.list().then(console.log)
const someObject = {
firstname: 'Nicolas',
lastname: 'Dao',
company: 'Neap Pty Ltd',
city: 'Sydney'
}
storage.bucket('your-globally-unique-bucket-name').create()
.then(data => console.log(data))
storage.bucket('your-globally-unique-bucket-name').create({ location: 'australia-southeast1' })
.then(data => console.log(data))
storage.bucket('your-globally-unique-bucket-name').delete({ force:true })
.then(data => console.log(data))
storage.bucket('your-globally-unique-bucket-name').get()
.then(data => console.log(data))
storage.insert(someObject, 'your-bucket/a-path/filename.json')
.then(() => storage.get('your-bucket/a-path/filename.json'))
.then(res => console.log(JSON.stringify(res, null, ' ')))
const html = `
<!doctype html>
<html>
<body>
<h1>Hello Giiiiirls</h1>
</body>
</html>`
storage.insert(html, 'your-bucket/a-path/index.html')
storage.insert(imgBuffer, 'your-bucket/a-path/image.jpg')
storage.get('your-bucket/a-path/filename.json').then(obj => console.log(obj))
storage.get('your-bucket/a-path/index.html').then(htmlString => console.log(htmlString))
storage.get('your-bucket/a-path/image.jpg').then(imgBuffer => console.log(imgBuffer))
storage.get('your-bucket/a-path/image.jpg', { dst: 'some-path/image.jpg' })
.then(() => console.log(`Image successfully downloaded.`))
const { Writable } = require('stream')
const customReader = new Writable({
write(chunk, encoding, callback) {
console.log('Hello chunk of image')
callback()
}
})
storage.get('your-bucket/a-path/image.jpg', { streamReader: customReader })
.then(() => console.log(`Image successfully downloaded.`))
storage.exists('your-bucket/a-path/image.jpg')
.then(fileExists => fileExists ? console.log('File exists.') : console.log('File does not exist.'))
storage.list('your-bucket/a-path/')
.then(files => console.log(files))
Bucket API
The examples above demonstrate how to insert and query any storage. We've also included a variant of those APIs that are more focused on the bucket:
storage.insert(someObject, 'your-bucket/a-path/filename.json')
storage.bucket('your-bucket').object('a-path/filename.json').insert(someObject)
storage.get('your-bucket/a-path/filename.json').then(obj => console.log(obj))
storage.bucket('your-bucket').object('a-path/filename.json').get().then(obj => console.log(obj))
storage.exists('your-bucket/a-path/image.jpg')
.then(fileExists => fileExists ? console.log('File exists.') : console.log('File does not exist.'))
storage.bucket('your-bucket').object('a-path/image.jpg').exists()
.then(fileExists => fileExists ? console.log('File exists.') : console.log('File does not exist.'))
storage.list('your-bucket/a-path/')
.then(files => console.log(files))
storage.bucket('your-bucket').object('a-path/').list()
.then(files => console.log(files))
Configuring Your Bucket Or Your File
Publicly Readable Config
This allows to make any files publicly readable by anybody on the web. That's usefull if you want to host a website, or publish data (e.g., RSS feed).
Once your bucket is publicly readable, everyone can access it at this url: https://storage.googleapis.com/your-bucket/some-path/index.html
WARNING: If that bucket hosts files that hsould be accessible cross domain (e.g., an RSS feed), don't forget to also set up CORS (next section Configuring CORS On a Bucket).
const bucket = storage.bucket('your-bucket')
bucket.isPublic().then(isPublic => isPublic ? console.log(`Bucket '${bucket.name}' is public`) : console.log(`Bucket '${bucket.name}' is not public`))
bucket.addPublicAccess()
.then(({ publicUri }) => console.log(`Your web page is publicly available at: ${publicUri}`))
bucket.removePublicAccess()
bucket.object('a-path/private.html').addPublicAccess()
.then(({ publicUri }) => console.log(`Your web page is publicly available at: ${publicUri}`))
bucket.object('a-path/private.html').removePublicAccess()
Making A Single File Publicly Readable At Creation Time
It is also possible to make a single file publicly readable in a single command when the file is created:
storage.insert(html, 'your-bucket/a-path/index.html', { public: true })
.then(({ publicUri }) => console.log(`Your web page is publicly available at: ${publicUri}`))
Once your file is publicly readable, everyone can access it at this url: https://storage.googleapis.com/your-bucket/a-path/index.html
WARNING: If that bucket hosts files that hsould be accessible cross domain (e.g., an RSS feed), don't forget to also set up CORS (next section Configuring CORS On a Bucket).
Setting Single File Content Encoding At Creation Time
It is also possible to set a file's content encoding in a single command when the file is created:
storage.insert(html, 'your-bucket/a-path/index.html', { contentEncoding: 'gzip' })
.then(({ publicUri }) => console.log(`Your gzipped file is available at: ${publicUri}`))
Configuring CORS On a Bucket
If your files are publicly readable on the web, they might not be accessible when referenced from other websites. To enable other websites to access your files, you will have to configure CORS on your bucket:
bucket.cors.setup({
origin: ['*'],
method: ['GET', 'OPTIONS', 'HEAD', 'POST'],
responseHeader: ['Authorization', 'Origin', 'X-Requested-With', 'Content-Type', 'Accept'],
maxAgeSeconds: 3600
})
.then(() => console.log(`CORS successfully set up on your bucket.`))
If you want to check if CORS has already been set up on a bucket:
bucket.cors.exists().then(yes => yes
? console.log(`CORS already set up on bucket '${bucket.name}'.`)
: console.log(`CORS not set up yet on bucket '${bucket.name}'.`))
You can also check if a specific CORS config exists:
bucket.cors.exists({
origin: ['*'],
method: ['GET', 'OPTIONS', 'HEAD', 'POST'],
responseHeader: ['Authorization', 'Origin', 'X-Requested-With', 'Content-Type', 'Accept'],
maxAgeSeconds: 3600
}).then(yes => yes
? console.log(`CORS already set up on bucket '${bucket.name}'.`)
: console.log(`CORS not set up yet on bucket '${bucket.name}'.`))
To remove CORS from a bucket:
bucket.cors.disable().then(() => console.log(`CORS successfully disabled on bucket '${bucket.name}'.`))
Configuring A Bucket As A Static Website
To achieve this you need to setup 5 things:
-
You need to setup the service account that you've been using to manage your bucket (defined in your service-account.json
) as a domain owner. To achieve that, the first step is to prove your ownership using https://search.google.com/search-console/welcome. When that's done, open the settings and select User and permissions. There, you'll be able to add a new owner, which will allow you to add the email of your service account.
-
Create a bucket with a name matching your domain (e.g., www.your-domain-name.com
)
-
Make that bucket public. Refer to section Publicly Readable Config above.
-
Add a new CNAME record in your DNS similar to this:
Type | Name | Value |
---|
CNAME | www | c.storage.googleapis.com |
-
Configure the bucket so that each index.html and the 404.html page are the default pages (otherwise, you'll have to explicitly enter http://www.your-domain-name.com/index.html to reach your website instead of simply entering http://www.your-domain-name.com):
bucket.website.setup({
mainPageSuffix: 'index.html',
notFoundPage: '404.html'
}).then(console.log)
Zipping Files
const bucket = storage.bucket('your-bucket-name')
bucket.object('some-folder-path').zip({
to: {
local: 'some-path-on-your-local-machine',
bucket: {
name: 'another-existing-bucket-name',
path: 'some-folder-path.zip'
}
},
ignore:[/\.png$/, /\.jpg$/, /\.html$/]
})
.then(({ count, data }) => {
console.log(`${count} files have been zipped`)
if (data)
console.log(`The zip file's size is: ${data.length/1024} KB`)
})
Extra Options
You can also track the various steps of the zipping process with the optional on
object:
const bucket = storage.bucket('your-bucket-name')
bucket.object('some-folder-path').zip({
to: {
local: 'some-path-on-your-local-machine',
bucket: {
name: 'another-existing-bucket-name',
path: 'some-folder-path.zip'
}
},
on:{
'files-listed': (files) => {
console.log(`Total number of files to be zipped: ${files.count}`)
console.log(`Raw size: ${(files.size/1024/1024).toFixed(1)} MB`)
},
'file-received': ({ file, size }) => {
console.log(`File ${file} (byte size: ${size}) is being zipped`)
},
'finished': ({ size }) => {
console.log(`Zip process completed. The zip file's size is ${size} bytes`)
},
'saved': () => {
console.log('The zipped file has been saved')
},
'error': err => {
console.log(`${err.message}\n${err.stack}`)
}
}
})
.then(({ count, data }) => {
console.log(`${count} files have been zipped`)
if (data)
console.log(`The zip file's size is: ${data.length/1024} KB`)
})
3 Ways To Create a Client
1. Using A service-account.json
We assume that you have created a Service Account in your Google Cloud Account (using IAM) and that you've downloaded a service-account.json
(the name of the file does not matter as long as it is a valid json file). The first way to create a client is to provide the path to that service-account.json
as shown in the following example:
const storage = client.new({
jsonKeyFile: join(__dirname, './service-account.json')
})
2. Using a ClientEmail PrivateKey & ProjectId
This method is similar to the previous one. You should have dowloaded a service-account.json
, but instead of providing its path, you provide some of its details explicitly:
const storage = client.new({
clientEmail: 'some-client-email',
privateKey: 'some-secret-private-key',
projectId: 'your-project-id'
})
3. Using a ProjectId
If you're managing an Google Cloud OAuth2 token yourself (most likely using the google-auto-auth
library), you are not required to explicitly pass account details like what was done in the previous 2 approaches. You can simply specify the projectId
:
const storage = client.new({ projectId: 'your-project-id' })
Refer to the next section to see how to pass an OAuth2 token.
Avoiding Network Errors
Networks errors (e.g. socket hang up, connect ECONNREFUSED) are a fact of life. To deal with those undeterministic errors, this library uses a simple exponential back off retry strategy, which will reprocess your read or write request for 10 seconds by default. You can increase that retry period as follow:
storage.exists('your-bucket/a-path/image.jpg', { timeout: 30000 })
storage.insert(someObject, 'your-bucket/a-path/filename.json', { timeout: 30000 })
storage.get('your-bucket/a-path/filename.json', { timeout: 30000 })
Using An External OAuth2 Token
If you've used the 3rd method to create a client (i.e. 3. Using a ProjectId), then all the method you use require an explicit OAuth2 token:
storage.list({ token }).then(console.log)
All method accept a last optional argument object.
Full API Doc
Storage API
storage.get(filePath[, options]): <Promise<
GoogleBucketObject
>>
Gets an object located under the bucket's filePath
path.
storage.list([options]) or storage.list(filePath[, options]): <Promise<Array<
GoogleBucketBase
|GoogleBucketObject
>>>
Lists buckets for this project or objects under a specific filePath
.
filePath
<String>
options
<Object>
- Returns either
storage.insert(object, filePath[, options]): <Promise<
GoogleBucketObjectPlus
>>
Inserts a new object to filePath
.
object
<Object>
Object you want to upload.filePath
<String>
Storage's pathname destination where that object is uploaded, e.g., your-bucket-id/media/css/style.css
.options
<Object>
- Returns a GoogleBucketObjectPlus object.
storage.insertFile(localPath, filePath[, options]): <Promise<
GoogleBucketObjectPlus
>>
Inserts a file located at localPath
to filePath
.
localPath
<String>
Absolute path on your local machine of the file you want to upload.filePath
<String>
Storage's pathname destination where that object is uploaded, e.g., your-bucket-id/media/css/style.css
.options
<Object>
- Returns a GoogleBucketObjectPlus object.
storage.exists(filePath[, options]): <Promise<Boolean>>
Checks whether an object located under the filePath
path exists or not.
filePath
<String>
options
<Object>
storage.addPublicAccess(filePath[, options]): <Promise<Object>>
Grants public access to a file located under the filePath
path.
filePath
<String>
options
storage.removePublicAccess(filePath[, options]): <Promise<Object>>
Removes public access from a file located under the filePath
path.
filePath
<String>
options
<Object>
storage.bucket(bucketId): <Bucket>
Gets a bucket object. This object exposes a series of APIs described under the bucket API section below.
Bucket API
The bucket
object is created using a code snippet similar to the following:
const bucket = storage.bucket('your-bucket-id')
bucket.name: <String>
Gets the bucket's name
bucket.get([options]): <Promise<Object>>
Gets a bucket's metadata object.
bucket.exists([options]): <Promise<Boolean>>
Checks if a bucket exists.
bucket.create([options]): <Promise<Object>>
Creates a new bucket.
bucket.delete([options]): <Promise<Object>>
Deletes a bucket.
options
<Object>
force
<Boolean>
Default is false. When false, deleting a non-empty bucket throws a 409 error. When set to true, even a non-empty bucket is deleted. Behind the scene, the entire content is deleted first. That's why forcing a bucket deletion might take longer.
bucket.update(config,[options]): <Promise<Object>>
Updates a bucket.
config
<Object>
options
<Object>
bucket.addPublicAccess([options]): <Promise<Object>>
Grants public access to a bucket as well as all its files.
bucket.removePublicAccess([options]): <Promise<Object>>
Removes public access from a bucket as well as all its files.
bucket.isPublic([options]): <Promise<Boolean>>
Checks if a bucket is public or not.
bucket.zip([options]): <Promise<Object>>
Zips bucket.
bucket.cors.exists(corsConfig, [options]): <Promise<Boolean>>
Checks if a bucket has been configured with specific CORS setup.
corsConfig
<Object>
options
<Object>
Configures a bucket with a specific CORS setup.
corsConfig
<Object>
options
<Object>
bucket.cors.disable([options]): <Promise<Object>>
Removes any CORS setup from a bucket.
bucket.website.setup(webConfig, [options]): <Promise<Object>>
Configures a bucket with a specific website setup.
NOTE: This API does not change the bucket access state. You should make this bucket public first using the bucket.addPublicAccess
API described above.
webConfig
<Object>
mainPageSuffix
<String>
This is the file that would be served by default when the website's pathname does not specify any explicit file name (e.g., use index.html
so that https://your-domain.com is equivalent to http://your-domain.com/index.html).notFoundPage
<String>
This is the page that would be served if your user enter a URL that does not match any file (e.g., 404.html
).
options
<Object>
bucket.object(filePath): <BucketObject>
Gets a bucket's object reference. This object exposes a series of APIs detailed in the next section BucketObject API.
filePath
<String>
This path represents a file or a folder.
BucketObject API
The bucketObject
object is created using a code snippet similar to the following:
const bucket = storage.bucket('your-bucket-id')
const bucketObject = bucket.object('folder1/folder2/index.html')
bucketObject.file: <String>
Gets bucketObject file name.
bucketObject.get([options]): <Promise<<Object>>
Gets the bucket object.
bucketObject.list([options]): <Promise<<Array<Object>>>
Lists all the objects located under the bucket object (if that bucket object is a folder).
bucketObject.exists([options]): <Promise<Boolean>>
Checks if a bucket object exists or not.
bucketObject.insert(object[, options]): <Promise<GoogleBucketObjectPlus>>
Inserts a new object to that bucket object.
bucketObject.insertFile(localPath[, options]): <Promise<GoogleBucketObjectPlus>>
Inserts a file located at localPath
to that bucket object.
localPath
<String>
Absolute path on your local machine of the file you want to upload.options
<Object>
- Returns a GoogleBucketObjectPlus object.
bucketObject.delete([options]): <Promise<Object>>
Deletes an object or an entire folder.
NOTE: To delete a folder, the argument used to create the bucketObject
must be a folder (e.g., storage.bucket('your-bucket-id').object('folderA/folderB').delete()
)
bucketObject.zip([options]): <Promise<Object>>
Lists all the objects located under the bucket object (if that bucket object is a folder).
bucketObject.addPublicAccess([options]): <Promise<Object>>
Grants public access to a bucket object.
bucketObject.removePublicAccess([options]): <Promise<Object>>
Removes public access from
a bucket object.
Objects
GoogleBucketBase
kind
<String>
Always set to 'storage#bucket'.id
<String>
selfLink
<String>
projectNumber
<String>
name
<String>
timeCreated
<String>
UTC date, e.g., '2019-01-18T05:57:24.213Z'.updated
<String>
UTC date, e.g., '2019-01-18T05:57:32.548Z'.metageneration
<String>
iamConfiguration
<String>
{ bucketPolicyOnly: { enabled: false } },location
<String>
Valid values are described in section List Of All Google Cloud Platform Locations.website
<
GoogleBucketWebsite
>
cors
<Array<
GoogleBucketCORS
>>
storageClass
<String>
etag
<String>
GoogleBucketFull
Same as GoogleBucketBase with an extra property:
GoogleBucketWebsite
mainPageSuffix
<String>
Defines which is the default file served when none is explicitly specified un a URI. For example, setting this property to 'index.html' means that this content could be reached using https://your-domain.com instead of https://your-domain.com/index.html.notFoundPage
<String>
E.g., '404.html'. This means that all not found page are redirected to this page.
GoogleBucketCORS
origin
<Array<String>>
method
<Array<String>>
responseHeader
<Array<String>>
maxAgeSeconds
<Number>
GoogleBucketIAM
kind
<String>
Always set to 'storage#policy',resourceId
<String>
bindings
<Array<
GoogleBucketBindings
>>
etag
<String>
GoogleBucketBindings
role
<String>
E.g., 'roles/storage.objectViewer', ...members
<Array<String>>
E.g., 'allUsers', 'projectEditor:your-project-id', 'projectOwner:your-project-id', ...
GoogleBucketObject
kind
<String>
Always set to 'storage#object'.id
<String>
selfLink
<String>
name
<String>
Pathname to the object inside the bucket, e.g., 'new/css/line-icons.min.css'.bucket
<String>
Bucket's IDgeneration
<String>
Date stamp in milliseconds from epoc.metageneration
<String>
contentType
<String>
e.g., 'text/css'.timeCreated
<String>
UTC date, e.g., '2019-04-02T22:33:18.362Z'.updated
<String>
UTC date, e.g., '2019-04-02T22:33:18.362Z'.storageClass
<String>
Valid value are: 'STANDARD', 'MULTI-REGIONAL', 'NEARLINE', 'COLDLINE'.timeStorageClassUpdated
<String>
UTC date, e.g., '2019-04-02T22:33:18.362Z'.size
<String>
Size in bytes, e.g., '5862'.md5Hash
<String>
mediaLink
<String>
crc32c
<String>
etag
<String>
GoogleBucketObjectPlus
Same as GoogleBucketObject, but with the following extra property:
Annex
List Of All Google Cloud Platform Locations
Single Regions
Single reagions are bucket locations that indicate that your data are replicated in multiple servers in that single region. Though it is unlikely that you would loose your data because all servers fail, it is however possible that a network failure brings that region inaccessbile. At this stage, your data would not be lost, but they would be unavailable for the period of that network outage. This type of storage is the cheapest.
Use this type of location if your data:
- Are not highly critical.
- Do not have to be quickly delivered wherever your clients are located (choosing us-west2 means that the data access will be fast for clients in Los Angeles, but slower for clients in Belgium).
- Are so big (multiple terabytes) that the storage cost is a primary concern.
If the above limits are too strict for your use case, then you should probably use a Multi Regions.
Location | Description |
---|
northamerica-northeast1 | Canada - Montréal |
us-central1 | US - Iowa |
us-east1 | US - South Carolina |
us-east4 | US - Northern Virginia |
us-west1 | US - Oregon |
us-west2 | US - Los Angeles |
southamerica-east1 | South America - Brazil |
europe-north1 | Europe - Finland |
europe-west1 | Europe - Belgium |
europe-west2 | Europe - England |
europe-west3 | Europe - Germany |
europe-west4 | Europe - Netherlands |
asia-east1 | Asia - Taiwan |
asia-east2 | Asia - Hong Kong |
asia-northeast1 | Asia - Japan |
asia-south1 | Asia - Mumbai |
asia-southeast1 | Asia - Singapore |
australia-southeast1 | Asia - Australia |
asia | Asia |
us | US |
eu | Europe |
Multi Regions
Multi regions are bucket locations where your data are not only replicated in multiple servers in the same regions, but also replicated across multiple locations (e.g., asia
will replicate your data across Taiwan, Hong Kong, Japan, Mumbai, Singapore, Australia). That means that your data are:
- Quickly accessible wherever your clients are in that continent.
- Highly available. Even if a region goes down, the others will carry on serving your data.
- A bit more expensive.
Location | Description |
---|
asia | Asia |
us | US |
eu | Europe |
This Is What We re Up To
We are Neap, an Australian Technology consultancy powering the startup ecosystem in Sydney. We simply love building Tech and also meeting new people, so don't hesitate to connect with us at https://neap.co.
Our other open-sourced projects:
GraphQL
- graphql-s2s: Add GraphQL Schema support for type inheritance, generic typing, metadata decoration. Transpile the enriched GraphQL string schema into the standard string schema understood by graphql.js and the Apollo server client.
- schemaglue: Naturally breaks down your monolithic graphql schema into bits and pieces and then glue them back together.
- graphql-authorize: Authorization middleware for graphql-serverless. Add inline authorization straight into your GraphQl schema to restrict access to certain fields based on your user's rights.
React & React Native
Authentication & Authorization
- userin: UserIn let's App engineers to implement custom login/register feature using Identity Providers (IdPs) such as Facebook, Google, Github.
General Purposes
- core-async: JS implementation of the Clojure core.async library aimed at implementing CSP (Concurrent Sequential Process) programming style. Designed to be used with the npm package 'co'.
- jwt-pwd: Tiny encryption helper to manage JWT tokens and encrypt and validate passwords using methods such as md5, sha1, sha256, sha512, ripemd160.
Google Cloud Platform
- google-cloud-bucket: Nodejs package to manage Google Cloud Buckets and perform CRUD operations against them.
- google-cloud-bigquery: Nodejs package to manage Google Cloud BigQuery datasets, and tables and perform CRUD operations against them.
- google-cloud-tasks: Nodejs package to push tasks to Google Cloud Tasks. Include pushing batches.
License
Copyright (c) 2018, Neap Pty Ltd.
All rights reserved.
Redistribution and use in source and binary forms, with or without modification, are permitted provided that the following conditions are met:
- Redistributions of source code must retain the above copyright notice, this list of conditions and the following disclaimer.
- Redistributions in binary form must reproduce the above copyright notice, this list of conditions and the following disclaimer in the documentation and/or other materials provided with the distribution.
- Neither the name of Neap Pty Ltd nor the names of its contributors may be used to endorse or promote products derived from this software without specific prior written permission.
THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND
ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
DISCLAIMED. IN NO EVENT SHALL NEAP PTY LTD BE LIABLE FOR ANY
DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
(INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
(INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.