SMS Middleware

smsMiddleware.js

import 'isomorphic-fetch';
import gql from 'graphql-tag';
import { ApolloClient } from 'apollo-client';
import { InMemoryCache } from 'apollo-cache-inmemory';
import { HttpLink } from 'apollo-link-http';
import url from 'url';
import { normalizeRequest } from './sms-middleware.util';
import log from '../../../common/log';

/**
 * SMS Middleware
 * @param {Object} req Incoming Request
 * @return Twilio Response XML
 */

// Prepare new ApolloClient instance
const { protocol, hostname, port, pathname } = url.parse(__BACKEND_URL__);
const apiUrl = `${protocol}//${hostname}:${process.env.PORT || port}${pathname}`;

const client = new ApolloClient({
  link: new HttpLink({ uri: apiUrl }),
  cache: new InMemoryCache()
});

export default async (req, res, next) => {
  try {
    // Normalize incoming data to match schema
    req.body = normalizeRequest(req);

    // Create incoming text message mutation
    const mutation = gql`
      mutation handleIncomingTextMessage($input: IncomingTextMessageRequestInput) {
        handleIncomingTextMessage(input: $input) {
          status
        }
      }
    `;

    // Send mutation
    const response = await client.mutate({
      mutation,
      variables: {
        input: {
          ...req.body
        }
      }
    });

    // Return response XML to Twilio
    return `
      <Response>
        <Message>
          ${response}
        </Message>
      </Response>
    `;
  } catch (e) {
    log(e.message);
    next(e);
  }
};

smsSchema.graphql

input TextMessageMediaAttachment {
  contentType: String!
  url: String!
}

input IncomingTextMessageRequestInput {
  sid: String!
  to: String!
  from: String!
  body: String!
  numMedia: Int!
  status: String

  fromCity: String
  fromState: String
  fromZip: String
  fromCountry: String

  toCity: String
  toState: String
  toZip: String
  toCountry: String

  accountSid: String
  mediaAttachmments: [TextMessageMediaAttachment]
}

type TextMessagePayloadResponse {
  sid: String!
  to: String!
  from: String!
  body: String!
  status: String!
  numMedia: Int!

  errorCode: Int
  errorMessage: String
  dateCreated: Date
  dateUpdated: Date
  dateSent: Date
  numSegments: Int
  price: Float
  priceUnit: String
}

extend type Query {
  getTextMessage(sid: String!): TextMessagePayloadResponse
  getTextMessages(limit: Int, pageSize: Int): [TextMessagePayloadResponse]
}

extend type Mutation {
  handleIncomingTextMessage(
    input: IncomingTextMessageRequestInput
  ): TextMessagePayloadResponse
  sendTextMessage(
    to: String!
    from: String
    body: String!
    mediaUrl: String
  ): TextMessagePayloadResponse
}

extend type Subscription {
}