app.js

const express = require('express')
const path = require("path");
require('dotenv').config()
var bodyParser = require('body-parser')
const moesif = require('moesif-nodejs');
const Stripe = require('stripe');
// npm i --save node-fetch@2.6.5
const fetch = require('node-fetch');

const app = express();
app.use(express.static(path.join(__dirname)));
const port = 5000;
const stripe = Stripe(process.env.STRIPE_KEY);
var jsonParser = bodyParser.json();

const moesifMiddleware = moesif({
  applicationId: process.env.MOESIF_APPLICATION_ID
});

app.use(moesifMiddleware);

app.post('/register', jsonParser,
 async (req, res) => {
    // create Stripe customer
    const customer = await stripe.customers.create({
      email: req.body.email,
      name: `${req.body.firstname} ${req.body.lastname}`,
      description: 'Customer created through /register endpoint',
    });

    // create Stripe subscription
    const subscription = await stripe.subscriptions.create({
      customer: customer.id,
      items: [
        { price: process.env.STRIPE_PRICE_KEY },
      ],
    });

    // create user, company, and subscription in Moesif
    var company = { companyId: customer.id };
    moesifMiddleware.updateCompany(company);

    var user = {
      userId: customer.id,
      companyId: customer.id,
      metadata: {
        email: req.body.email,
        firstName: req.body.firstname,
        lastName: req.body.lastname,
      }
    };
    moesifMiddleware.updateUser(user);

    var subscription = {
      subscriptionId: subscription.id,
      companyId: customer.id,
      status: "active",
    }
    moesifMiddleware.updateSubscription(subscription).then((result) => { 
      console.log("subscription updated successfully");
    }).catch((err) => {
      console.error("Error updating subscription", err);
    } );

    // send back a new API key for use
    var body = {
      alias: customer.id,
      last_check: 0,
      allowance: 1000,
      rate: 1000,
      per: 60,
      expires: 0,
      quota_max: 10000,
      quota_renews: 1424543479,
      quota_remaining: 10000,
      quota_renewal_rate: 2520000,
      access_rights: {
        [process.env.TYK_API_ID]: {
          api_id: process.env.TYK_API_ID,
          api_name: process.env.TYK_API_NAME,
          versions: [
            "Default"
          ]
        }
      }
    }
    var response = await fetch(`${process.env.TYK_URL}/api/keys`, {
      method: 'post',
      body: JSON.stringify(body),
      headers: {
        'Content-Type': 'application/json',
        "Authorization": process.env.TYK_AUTH_KEY
      }
    });
    var data = await response.json();
    var tykAPIKey = data.key_id;

    var user = {
      userId: customer.id,
      metadata: {
        apikey: tykAPIKey,
      }
    };
    moesifMiddleware.updateUser(user);

    res.status(200)
    res.send({ apikey: tykAPIKey });
 }
)

app.get("/", function (_req, res) {
  res.sendFile(path.join(__dirname, "index.html"));
  res.sendFile(path.join(__dirname, "index.js"));
});

app.listen(port, () => {
  console.log(`Example app listening at http://localhost:${port}`);
})