Azure adapters for API and GraphQL

packages/framework-provider-azure/package.json

@@ -20,6 +20,7 @@
     "url": "git+https://github.com/boostercloud/booster.git"
   },
   "dependencies": {
+    "@azure/functions": "^1.2.2",
     "@boostercloud/framework-types": "^0.3.3"
   },
   "scripts": {

packages/framework-provider-azure/src/index.ts

@@ -1,5 +1,7 @@
 /* eslint-disable @typescript-eslint/no-explicit-any */
 import { ProviderInfrastructure, ProviderLibrary } from '@boostercloud/framework-types'
+import { requestFailed, requestSucceeded } from './library/api-adapter'
+import { rawGraphQLRequestToEnvelope } from './library/graphql-adapter'
 
 export const Provider: ProviderLibrary = {
   // ProviderEventsLibrary
@@ -22,17 +24,17 @@ export const Provider: ProviderLibrary = {
   // ProviderGraphQLLibrary
   graphQL: {
     authorizeRequest: undefined as any,
-    rawToEnvelope: undefined as any,
-    handleResult: undefined as any,
+    rawToEnvelope: rawGraphQLRequestToEnvelope,
+    handleResult: requestSucceeded,
   },
   // ProviderAuthLibrary
   auth: {
     rawToEnvelope: undefined as any,
   },
   // ProviderAPIHandling
   api: {
-    requestSucceeded: undefined as any,
-    requestFailed: undefined as any,
+    requestSucceeded,
+    requestFailed,
   },
   // ProviderInfrastructureGetter
   infrastructure: () =>

packages/framework-provider-azure/src/library/api-adapter.ts

@@ -0,0 +1,39 @@
+import { Cookie } from '@azure/functions'
+import { httpStatusCodeFor, toClassTitle } from '@boostercloud/framework-types'
+
+/**
+ * See https://docs.microsoft.com/es-es/azure/azure-functions/functions-reference-node#response-object
+ */
+export interface ContextResponse {
+  body: string
+  headers: object
+  isRaw?: boolean
+  status: number
+  cookies?: Cookie[]
+}
+
+// eslint-disable-next-line @typescript-eslint/no-explicit-any
+export async function requestSucceeded(body?: any): Promise<ContextResponse> {
+  return {
+    headers: {
+      'Access-Control-Allow-Origin': '*',
+    },
+    status: 200,
+    body: body ? JSON.stringify(body) : '',
+  }
+}
+
+export async function requestFailed(error: Error): Promise<ContextResponse> {
+  const status = httpStatusCodeFor(error)
+  return {
+    headers: {
+      'Access-Control-Allow-Origin': '*',
+    },
+    status,
+    body: JSON.stringify({
+      status,
+      title: toClassTitle(error),
+      reason: error.message,
+    }),
+  }
+}

packages/framework-provider-azure/src/library/graphql-adapter.ts

@@ -0,0 +1,19 @@
+import { GraphQLRequestEnvelope, Logger } from '@boostercloud/framework-types'
+import { Context } from '@azure/functions'
+
+export async function rawGraphQLRequestToEnvelope(context: Context, logger: Logger): Promise<GraphQLRequestEnvelope> {
+  logger.debug('Received GraphQL request: ', context.req)
+  let graphQLBody = undefined
+  let graphQLVariables = undefined
+  if (context.req) {
+    graphQLBody = context.req.body.query
+    graphQLVariables = context.req.body.variables
+  }
+
+  return {
+    requestID: context.executionContext.invocationId,
+    eventType: 'MESSAGE',
+    value: graphQLBody,
+    variables: graphQLVariables,
+  }
+}

packages/framework-provider-azure/test/expect.ts

@@ -0,0 +1,6 @@
+import * as chai from 'chai'
+
+chai.use(require('sinon-chai'))
+chai.use(require('chai-as-promised'))
+
+export const expect = chai.expect

packages/framework-provider-azure/test/library/api-adapter.test.ts

@@ -0,0 +1,59 @@
+import { expect } from '../expect'
+import {
+  InvalidVersionError,
+  InvalidParameterError,
+  NotAuthorizedError,
+  NotFoundError,
+} from '@boostercloud/framework-types'
+import { requestFailed } from '../../src/library/api-adapter'
+
+describe('the requestFailed method', () => {
+  interface TestCase {
+    input: Error
+    expectedOutput: {
+      status: number
+      title: string
+    }
+  }
+
+  it('returns a proper body with several errors', async () => {
+    const testCases: Array<TestCase> = [
+      {
+        input: new InvalidParameterError('error message'),
+        expectedOutput: {
+          status: 400,
+          title: 'Invalid Parameter Error',
+        },
+      },
+      {
+        input: new NotAuthorizedError('error message'),
+        expectedOutput: {
+          status: 401,
+          title: 'Not Authorized Error',
+        },
+      },
+      {
+        input: new NotFoundError('error message'),
+        expectedOutput: {
+          status: 404,
+          title: 'Not Found Error',
+        },
+      },
+      {
+        input: new InvalidVersionError('error message'),
+        expectedOutput: {
+          status: 422,
+          title: 'Invalid Version Error',
+        },
+      },
+    ]
+
+    for (const testCase of testCases) {
+      const testDescription = `In test case '${testCase.input.constructor.name}'`
+      const got = await requestFailed(testCase.input)
+      expect(got.status).to.be.equal(testCase.expectedOutput.status, testDescription)
+      const body = JSON.parse(got.body)
+      expect(body.title).to.be.equal(testCase.expectedOutput.title, testDescription)
+    }
+  })
+})

packages/framework-provider-azure/test/library/graphql-adapter.test.ts

@@ -0,0 +1,38 @@
+/* eslint-disable @typescript-eslint/no-explicit-any */
+import { expect } from '../expect'
+import { GraphQLRequestEnvelope } from '@boostercloud/framework-types'
+import { rawGraphQLRequestToEnvelope } from '../../src/library/graphql-adapter'
+import { Context } from '@azure/functions'
+
+describe('the graphql-adapter', () => {
+  describe('the `rawGraphQLRequestToEnvelope`', () => {
+    it('generates an envelope correctly from an Azure event', async () => {
+      const expectedQuery = 'GraphQL query'
+      const expectedVariables = {
+        varOne: 3,
+        varTwo: 'test',
+      }
+      const request: Context = {
+        req: {
+          body: {
+            query: expectedQuery,
+            variables: expectedVariables,
+          },
+        },
+        executionContext: {
+          invocationId: '123',
+        },
+      } as any
+
+      const expectedOutput: GraphQLRequestEnvelope = {
+        requestID: '123',
+        eventType: 'MESSAGE',
+        value: expectedQuery,
+        variables: expectedVariables,
+      }
+      const gotOutput = await rawGraphQLRequestToEnvelope(request, console)
+
+      expect(gotOutput).to.be.deep.equal(expectedOutput)
+    })
+  })
+})