Sample flow for email processing

emailProcessor.js

'use strict';

const functions = require('firebase-functions');
const admin = require('firebase-admin');
const functions = require('firebase-functions');

exports.emailProcessor = functions.database.ref('/email/raw/{emailId}').onWrite(event => {
if (event.data.exists()) {
    let rawEmail = event.data.val();

    return findMatchingEntity(rawEmail)
          .then((matched) => {
              if (!matched) return Promise.reject("No found", rawEmail);
              return convertEmail(rawEmail, matched);
          })
          .then((convertedEmail) => saveConverted(convertedEmail))
          .then((convertedEmail) => deleteRawEmail(convertedEmail, rawEmail))
          .then((convertedEmail) => convertedEmail)
          .catch((err) => console.error(err));
  }
});