Created
August 25, 2020 06:07
-
-
Save rabbah/4390135e2b858e20d0dda14e548eb514 to your computer and use it in GitHub Desktop.
Nimbella Node SDK
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| /* | |
| * Copyright 2018 - present Nimbella Corp | |
| * All Rights Reserved. | |
| * | |
| */ | |
| var redis = require("redis") | |
| var bluebird = require("bluebird") | |
| function makeRedisClient() { | |
| bluebird.promisifyAll(redis.RedisClient.prototype) | |
| bluebird.promisifyAll(redis.Multi.prototype) | |
| const redisHost = process.env['__NIM_REDIS_IP'] | |
| if (!redisHost || redisHost.length == 0) { | |
| throw new Error("Key-Value store is not available") | |
| } | |
| const redisPassword = process.env['__NIM_REDIS_PASSWORD'] | |
| if (!redisPassword || redisPassword.length == 0) { | |
| throw new Error("Key-Value store password is not available") | |
| } | |
| const redisParam = { port: 6379, host: redisHost } | |
| const client = redis.createClient(redisParam) | |
| if (client == null) { | |
| throw new Error("Error creating redis client") | |
| } | |
| client.auth(redisPassword, function(err, reply) { | |
| if (err) { | |
| throw new Error("Error authenticaing redis client" + reply) | |
| } | |
| }); | |
| return client | |
| } | |
| async function makeStorageClient(web=false) { | |
| let StorageClass = undefined | |
| try { | |
| const { Storage } = require('@google-cloud/storage') | |
| StorageClass = Storage | |
| } catch (err) { | |
| throw new Error("No object store client is available in this action runtime") | |
| } | |
| const creds = process.env['__NIM_STORAGE_KEY'] | |
| if (!creds || creds.length == 0) { | |
| throw new Error("Objectstore credentials are not available") | |
| } | |
| const namespace = process.env['__OW_NAMESPACE'] | |
| const apiHost = process.env['__OW_API_HOST'] | |
| if (!namespace || !apiHost) { | |
| throw new Error("Not enough information in the environment to determine the object store bucket name") | |
| } | |
| const hostpart = apiHost.replace('https://', '').split('.').join('-') | |
| const datapart = web ? '' : 'data-' | |
| const bucket = `gs://${datapart}${namespace}-${hostpart}` | |
| let parsedCreds = undefined | |
| try { | |
| parsedCreds = JSON.parse(creds) | |
| } catch {} | |
| if (parsedCreds) { | |
| const { client_email, project_id, private_key } = parsedCreds | |
| if (client_email && project_id && private_key) { | |
| const storageOptions = { project_id, credentials: { client_email, private_key }} | |
| const storage = new StorageClass(storageOptions) | |
| return storage.bucket(bucket) // a promise, since the function is async | |
| } | |
| } | |
| throw new Error("Insufficient information in provided credentials or credentials were invalid") | |
| } | |
| module.exports = { | |
| redis: makeRedisClient, | |
| storage: makeStorageClient | |
| } |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment