initial commit

Thanith · Thanith · commit 0d437ac9daaa · 2018-11-27T18:13:17.000+01:00
diff --git a/.babelrc b/.babelrc
@@ -0,0 +1,13 @@
+{
+  "presets": [
+    [
+      "env",
+      {
+        "targets": {
+          "node": "8.10"
+        }
+      }
+    ]
+  ],
+  "plugins": ["transform-object-rest-spread"]
+}
diff --git a/.gitignore b/.gitignore
@@ -0,0 +1,2 @@
+lib/
+node_modules/
diff --git a/LICENSE b/LICENSE
diff --git a/README.md b/README.md
@@ -0,0 +1,112 @@
+# Aws Apollo Tools
+
+[![Node version](https://img.shields.io/badge/nodejs-8.10.0-blue.svg)](https://nodejs.org/en/blog/release/v8.10.0/)
+
+
+## Table of Contents
+
+* [Prerequisites](#prerequisites)
+* [Getting Started](#getting-started)
+* [Usage](#usage)
+  * [LambdaRequest](#lambdarequest)
+  * [HttpRequest](#httprequest)
+  
+
+
+## Prerequisites
+
+in `serverless.yml`
+```yml
+...
+provider:
+  ...
+  environment:
+    SLS_STAGE: ${self:provider.stage} 
+  iamRoleStatements:
+    - Effect: Allow
+      Action:
+        - execute-api:*
+      Resource: '*'
+...
+```
+
+## Getting Started
+
+* Run `yarn add @nutshelllab/aws-apollo-tools`
+* `import * from '@nutshelllab/aws-apollo-tools'`
+
+## Usage
+
+### LambdaRequest
+
+`import graphqlLambdaRequest from '@nutshelllab/aws-apollo-tools/lambda-request'`
+
+```js
+const request = gql`
+  query getItem($id: ID!) {
+    getItem(id: $id) {
+      id
+    }
+  }
+`
+
+const variables = {
+  id: '110e8400-e29b-11d4-a716-446655440000'
+}
+
+const test = await graphqlLambdaRequest({
+  lambdaName: 'my-lambda-name',
+  region: 'eu-west-1',
+  request,
+  variables
+})
+
+```
+
+#### Options
+
+|name|required|type|info|
+|---|---|---|---|---|
+|lambdaName|true|string|The lambda endpoint must provide an apollo server|
+|region|true|string|   |
+|request|true|string|It must be a GraphQL query [graphql-tag](https://github.com/apollographql/graphql-tag#readme)|
+|variables|false|object|   |
+|headers|false|object|   |
+
+### HttpRequest
+
+`import graphqlHttpRequest from '@nutshelllab/aws-apollo-tools/http-request'`
+
+```js
+const request = gql`
+  query getItem($id: ID!) {
+    getItem(id: $id) {
+      id
+    }
+  }
+`
+
+const variables = {
+  id: '110e8400-e29b-11d4-a716-446655440000'
+}
+
+const test = await graphqlHttpRequest({
+  uri: 'https://my-apollo-server-endpoint.com',
+  region: 'eu-west-1',
+  request,
+  variables,
+  signed: true
+})
+
+```
+
+#### Options
+
+|name|required|type|info|
+|---|---|---|---|---|
+|uri|true|string|The http endpoint must provide an apollo server|
+|region|true|string|   |
+|request|true|string|It must be a GraphQL query [graphql-tag](https://github.com/apollographql/graphql-tag#readme)|
+|signed|false|bool|Setting to `true` enable aws signature v4, be sure that your http endpoint as `authorizer: aws_iam`|
+|variables|false|object|   |
+|headers|false|object|   |
diff --git a/package.json b/package.json
@@ -0,0 +1,44 @@
+{
+  "name": "@nutshelllab/aws-appolo-tools",
+  "version": "0.0.1",
+  "description": "Initialize graphQl Client and Sign request for IAM authentication",
+  "main": "lib/aws-appolo-tools.js",
+  "scripts": {
+    "build": "webpack --config webpack.config.js"
+  },
+  "repository": {
+    "type": "git",
+    "url": "git+https://github.com/nutshelllab/aws-appolo-tools.git"
+  },
+  "keywords": [
+    "graphql",
+    "sign",
+    "aws"
+  ],
+  "author": "Nutshell",
+  "license": "GNU GENERAL PUBLIC LICENSE Version 3",
+  "bugs": {
+    "url": "https://github.com/nutshelllab/aws-appolo-tools/issues"
+  },
+  "homepage": "https://github.com/nutshelllab/aws-appolo-tools#readme",
+  "dependencies": {
+    "apollo-cache-inmemory": "^1.3.11",
+    "apollo-client": "^2.4.7",
+    "apollo-link": "^1.2.4",
+    "apollo-link-http": "^1.5.7",
+    "aws-sdk": "^2.363.0",
+    "aws4": "^1.8.0",
+    "graphql": "^14.0.2",
+    "node-fetch": "^2.3.0",
+    "url": "^0.11.0"
+  },
+  "devDependencies": {
+    "babel-loader": "^7.1.4",
+    "babel-plugin-transform-object-rest-spread": "^6.26.0",
+    "babel-polyfill": "^6.26.0",
+    "babel-preset-env": "^1.7.0",
+    "webpack": "^4.8.2",
+    "webpack-cli": "^2.1.3",
+    "webpack-node-externals": "^1.7.2"
+  }
+}
diff --git a/src/aws4-signer.js b/src/aws4-signer.js
@@ -0,0 +1,31 @@
+import urlNode from 'url'
+import aws4 from 'aws4'
+import fetch from 'node-fetch'
+import AWS from 'aws-sdk'
+
+const sign = ({ method, url, headers: { region, ...headers }, body }) => {
+  const { path, host } = urlNode.parse(url)
+  return aws4.sign(
+    {
+      body,
+      headers,
+      method,
+      url,
+      service: 'execute-api',
+      path,
+      host,
+      region
+    },
+    {
+      accessKeyId: AWS.config.credentials.accessKeyId,
+      secretAccessKey: AWS.config.credentials.secretAccessKey,
+      sessionToken: AWS.config.credentials.sessionToken
+    }
+  )
+}
+
+export default async (url, options) => {
+  const { method, headers, body } = options
+  const signedRequest = await sign({ method, url, headers, body })
+  return fetch(signedRequest.url, signedRequest)
+}
diff --git a/src/core/graphql-request.js b/src/core/graphql-request.js
@@ -0,0 +1,46 @@
+import { InMemoryCache } from 'apollo-cache-inmemory'
+import ApolloClient from 'apollo-client'
+
+const cache = new InMemoryCache()
+
+const operate = (graphqlClient, operation) => (request, variables) =>
+  operation === 'query'
+    ? query(graphqlClient, request, variables)
+    : mutate(graphqlClient, request, variables)
+const query = (graphqlClient, request, variables) =>
+  graphqlClient.query({
+    query: request,
+    variables,
+    fetchPolicy: 'network-only'
+  })
+const mutate = (graphqlClient, request, variables) =>
+  graphqlClient.mutate({
+    mutation: request,
+    variables,
+    fetchPolicy: 'no-cache'
+  })
+
+export const graphqlRequest = async ({
+  name,
+  link,
+  request,
+  variables = {}
+}) => {
+  const graphqlClient = new ApolloClient({
+    link,
+    cache
+  })
+  if (!request.definitions)
+    throw new Error(
+      `[Apollo Tools] - GraphQL request does not contain any operation`
+    )
+  const { operation = 'query' } = request.definitions[0] || {}
+  const { data } = await operate(graphqlClient, operation)(
+    request,
+    variables
+  ).catch(error => {
+    throw new Error(`(from ${name}) - ${error.message}`)
+  })
+  const key = Object.keys(data)[0]
+  return data[key]
+}
diff --git a/src/format-error.js b/src/format-error.js
@@ -0,0 +1,5 @@
+export default options => error => {
+  console.log(JSON.stringify(error))
+  if (options.noExtensions) delete error.extensions
+  return error
+}
diff --git a/src/http-request.js b/src/http-request.js
@@ -0,0 +1,23 @@
+import { createHttpLink } from 'apollo-link-http'
+import fetch from 'node-fetch'
+import hmacfetch from './aws4-signer'
+import { graphqlRequest } from './core/graphql-request'
+
+export default ({
+  uri,
+  region,
+  request,
+  signed = true,
+  variables,
+  headers = {}
+}) => {
+  const link = createHttpLink({
+    uri,
+    headers: {
+      ...headers,
+      region
+    },
+    fetch: signed ? hmacfetch : fetch
+  })
+  return graphqlRequest({ name: uri, link, request, variables })
+}
diff --git a/src/index.js b/src/index.js
@@ -0,0 +1,5 @@
+export { default as graphqlHttpRequest } from './http-request'
+export { default as graphqlLambdaRequest } from './lambda-request'
+export { default as createLambdaLink } from './lambda-link'
+export { default as hmacfetch } from './aws4-signer'
+export { default as formatError } from './format-error'
diff --git a/src/lambda-link.js b/src/lambda-link.js
@@ -0,0 +1,33 @@
+import { ApolloLink, Observable } from 'apollo-link'
+import { print } from 'graphql/language/printer'
+import AWS from 'aws-sdk'
+
+export default ({ lambdaName, region, ...options }) => {
+  return new ApolloLink(operation => {
+    const lambda = new AWS.Lambda({ region })
+    const { variables } = operation
+    const query = print(operation.query)
+    const params = {
+      FunctionName: lambdaName,
+      Payload: JSON.stringify({
+        httpMethod: 'POST',
+        body: JSON.stringify({ query, variables }),
+        ...options
+      })
+    }
+    return new Observable(observer => {
+      lambda
+        .invoke(params)
+        .promise()
+        .then(({ Payload }) => {
+          const { body } = JSON.parse(Payload)
+          const parsedBody = JSON.parse(body)
+          observer.next(parsedBody)
+          observer.complete()
+        })
+        .catch(error => {
+          observer.error(error)
+        })
+    })
+  })
+}
diff --git a/src/lambda-request.js b/src/lambda-request.js
@@ -0,0 +1,11 @@
+import { graphqlRequest } from './core/graphql-request'
+import createLambdaLink from './lambda-link'
+
+export default ({ lambdaName, region, request, variables, headers = {} }) => {
+  const link = createLambdaLink({
+    lambdaName,
+    region,
+    headers
+  })
+  return graphqlRequest({ name: lambdaName, link, request, variables })
+}
diff --git a/webpack.config.js b/webpack.config.js
@@ -0,0 +1,28 @@
+const path = require('path')
+const nodeExternals = require('webpack-node-externals')
+const libraryName = 'graph-client'
+const outputfile = libraryName + '.js'
+
+module.exports = {
+  entry: './src/index.js',
+  mode: 'production',
+  target: 'node',
+  externals: [nodeExternals()],
+  output: {
+    path: path.resolve(__dirname, 'lib'),
+    filename: outputfile,
+    library: libraryName,
+    libraryTarget: 'umd',
+    umdNamedDefine: true
+  },
+  module: {
+    rules: [
+      { 
+        test: /\.js$/,
+        include: path.resolve(__dirname, 'src'),
+        exclude: /node_modules/,
+        loader: 'babel-loader'
+      }
+    ]
+  }
+}
diff --git a/yarn-error.log b/yarn-error.log
diff --git a/yarn.lock b/yarn.lock
