app.js

const axios = require("axios");
const qs = require("query-string");
const morgan = require("morgan");
const express = require("express");
const rateLimit = require("express-rate-limit");
const helmet = require("helmet");
const mongosanitize = require("express-mongo-sanitize");
const bodyParser = require("body-parser");
const WorkOS = require("@workos-inc/node");
const catchAsync = require("./utils/catchAsync");
const jsforce = require("jsforce");
const passport = require("passport");
const xss = require("xss-clean");
const globalErrorHandler = require("./controllers/errController");
const cors = require("cors");
const cookieParser = require("cookie-parser");
const jwt = require("jsonwebtoken");
const session = require("cookie-session");
const Event = require("./models/eventModel");
var request = require("superagent");
const querystring = require("querystring");
const uploadRoutes = require("./routes/uploadRoutes");
const userRoutes = require("./routes/userRoutes");
const registrationRoutes = require("./routes/registrationRoutes");
const communityRoutes = require("./routes/communityRoutes");
const globalRoutes = require("./routes/globalRoutes");
const feedbackRoutes = require("./routes/feedbackRoutes");
const authRoutes = require("./routes/authRoutes");
const salesDepartmentRoutes = require("./routes/salesDepartmentRoutes");
const customPlanRoutes = require("./routes/customPlanRoutes");
const eventRoutes = require("./routes/eventRoutes");
const sessionRoutes = require("./routes/sessionRoutes");
const speakerRoutes = require("./routes/speakerRoutes");
const boothRoutes = require("./routes/boothRoutes");
const sponsorRoutes = require("./routes/sponsorRoutes");
const ticketRoutes = require("./routes/ticketRoutes");
const stripeRoutes = require("./routes/stripeRoutes");
const razorpayRoutes = require("./routes/razorpayRoutes.js");
const teamInvite = require("./routes/teamInviteRoutes");
const demoRoutes = require("./routes/demoRoutes");
const newsletterRoutes = require("./routes/newsletterRoutes");
const contactUsRoutes = require("./routes/contactUsRoutes");
const twillioRoutes = require("./routes/twillioRoutes");
const fundTransferRoutes = require("./routes/fundTransferRoutes");
const communityPlanRoutes = require("./routes/communityPlanRoutes");
const affiliateRoutes = require("./routes/affiliateRoutes");
const interestedPeopleRoutes = require("./routes/interestedPeopleRoutes");
const paypalRoutes = require("./routes/payPalRoutes");
const zapierRoutes = require("./routes/zapierRoutes");
const roleRoutes = require("./routes/roleRoutes");
const mailRoutes = require("./routes/mailRoutes");
const trackRoutes = require("./routes/trackRoutes");
const reviewRoutes = require("./routes/reviewRoutes");
const recordingRoutes = require("./routes/recordingRoutes");
const authController = require("./controllers/authController.js");

const MailChimp = require("./models/mailChimpModel");
const SalesForce = require("./models/salesForceModel");
const Hubspot = require("./models/hubspotModel");
const Community = require("./models/communityModel");

const { promisify } = require("util");
require("./services/passport");

const app = express();
const urlToGetLinkedInAccessToken =
  "https://www.linkedin.com/oauth/v2/accessToken";
const urlToGetUserProfile =
  "https://api.linkedin.com/v2/me?projection=(id,localizedFirstName,localizedLastName,profilePicture(displayImage~digitalmediaAsset:playableStreams))";
const urlToGetUserEmail =
  "https://api.linkedin.com/v2/clientAwareMemberHandles?q=members&projection=(elements*(primary,type,handle~))";

const MAILCHIMP_CLIENT_ID = "919814706970";
const MAILCHIMP_CLIENT_SECRET =
  "3837302297576b7845b5ced8bd4691bb69ac7b8c5f90645887";

const BASE_URL =
  process.env.NODE_ENV === "development"
    ? "http://127.0.0.1:3000"
    : "https://api.bluemeet.in";

const OAUTH_CALLBACK = `http://127.0.0.1:3001/bluemeet/redirect`;

app.use(
  cors({
    origin: [
      "http://127.0.0.1:3001",
      "http://localhost:3001",
      "https://www.bluemeet.in",
      "https://bluemeet.in",
      "https://zapier.com",
      "https://www.zapier.com",
    ],

    methods: ["GET", "PATCH", "POST", "DELETE", "PUT"],

    credentials: true,
  })
);

app.use(cookieParser());

// Use JSON parser for all non-webhook routes
app.use(
  express.json({
    verify: (req, res, buf) => {
      const url = req.originalUrl;
      if (
        url.startsWith("/api-eureka/eureka/v1/stripe/eventTicketPurchased") ||
        url.startsWith("/api-eureka/eureka/v1/stripe/eventPurchaseFailed")
      ) {
        req.rawBody = buf.toString();
      }
    },
  })
);

// Setup express response and body parser configurations
app.use(express.json());
app.use(bodyParser.json());
app.use(bodyParser.urlencoded({ extended: true }));

app.use(
  session({
    secret: "keyboard cat",
    proxy: true,
    resave: true,
    saveUnintialized: true,
    cookie: {
      secure: false,
    },
  })
);

app.use(passport.initialize());
app.use(passport.session());

app.use(helmet());

if (process.env.NODE_ENV === "development") {
  app.use(morgan("dev"));
}

const limiter = rateLimit({
  max: 100000,
  windowMs: 60 * 60 * 1000, // In one hour
  message: "Too many Requests from this IP, please try again in an hour!",
});

app.use("/eureka", limiter);

app.use(express.json({ limit: "10kb" }));

app.use(
  express.urlencoded({
    extended: true,
  })
);

app.use(mongosanitize());

app.use(xss());

app.get("/api-eureka/getUserCredentials", (req, res, next) => {
  const code = req.query.code;
  console.log(code);
  let userProfile = {};

  let accessToken = null;
  const config = {
    headers: { "Content-Type": "application/x-www-form-urlencoded" },
  };
  const parameters = {
    grant_type: "authorization_code",
    code: code,
    redirect_uri: "https://bluemeet.in/signin",
    client_id: "7761igbj4li3f2",
    client_secret: "aitQmTG7uYvSkaRZ",
  };
  console.log(urlToGetLinkedInAccessToken, qs.stringify(parameters), config);
  axios
    .post(urlToGetLinkedInAccessToken, qs.stringify(parameters), config)
    .then((response) => {
      accessToken = response.data.access_token;
      const config = {
        headers: {
          Authorization: `Bearer ${accessToken}`,
        },
      };
      axios
        .get(urlToGetUserProfile, config)
        .then((response) => {
          userProfile.firstName = response.data["localizedFirstName"];
          userProfile.lastName = response.data["localizedLastName"];
          userProfile.image =
            response.data.profilePicture[
              "displayImage~"
            ].elements[0].identifiers[0].identifier;
          userProfile.linkedinId = response.data.id;

          axios
            .get(urlToGetUserEmail, config)
            .then((response) => {
              userProfile.email =
                response.data.elements[0]["handle~"].emailAddress;

              res.status(200).json({ userProfile });
            })
            .catch((error) => next(error));
        })
        .catch((error) => next(error));
    })
    .catch((err) => {
      console.log(err);
      next(err);
    });
});

app.use("/api-eureka/eureka/v1/auth", authRoutes);
app.use("/api-eureka/eureka/v1/upload", uploadRoutes);
app.use("/api-eureka/eureka/v1/users", userRoutes);
app.use("/api-eureka/eureka/v1/registrations", registrationRoutes);
app.use("/api-eureka/eureka/v1/community", communityRoutes);
app.use("/api-eureka/eureka/v1/feedback", feedbackRoutes);
app.use("/api-eureka/eureka/v1/sales", salesDepartmentRoutes);
app.use("/api-eureka/eureka/v1/customPlan", customPlanRoutes);
app.use("/api-eureka/eureka/v1/events", eventRoutes);
app.use("/api-eureka/eureka/v1/sessions", sessionRoutes);
app.use("/api-eureka/eureka/v1/speakers", speakerRoutes);
app.use("/api-eureka/eureka/v1/booths", boothRoutes);
app.use("/api-eureka/eureka/v1/sponsors", sponsorRoutes);
app.use("/api-eureka/eureka/v1/stripe", stripeRoutes);
app.use("/api-eureka/eureka/v1/razorpay", razorpayRoutes);
app.use("/api-eureka/eureka/v1/tickets", ticketRoutes);
app.use("/api-eureka/eureka/v1/team-invites", teamInvite);
app.use("/api-eureka/eureka/v1/demo", demoRoutes);
app.use("/api-eureka/eureka/v1/newsletter", newsletterRoutes);
app.use("/api-eureka/eureka/v1/contactUs", contactUsRoutes);
app.use("/api-eureka/eureka/v1/twillio", twillioRoutes);
app.use("/api-eureka/eureka/v1/fund", fundTransferRoutes);
app.use("/api-eureka/eureka/v1/communityPlan", communityPlanRoutes);
app.use("/api-eureka/eureka/v1/affiliate", affiliateRoutes);
app.use("/api-eureka/eureka/v1/interestedPeople", interestedPeopleRoutes);
app.use("/api-eureka/eureka/v1/paypal", paypalRoutes);
app.use("/api-eureka/eureka/v1/zapier", zapierRoutes);
app.use("/api-eureka/eureka/v1/role", roleRoutes);
app.use("/api-eureka/eureka/v1/mail", mailRoutes);
app.use("/api-eureka/eureka/v1/track", trackRoutes);
app.use("/api-eureka/eureka/v1/review", reviewRoutes);
app.use("/api-eureka/eureka/v1/recording", recordingRoutes);

const signToken = (id) => jwt.sign({ id }, process.env.JWT_SECRET);

app.get("/api-eureka/eureka/v1/current_user", (req, res) => {
  const token = signToken(req.user._id);

  res.send({ user: req.user, token: token });
});

app.get("/api-eureka/eureka/v1/auth/mailchimp", (req, res, next) => {
  res.redirect(
    `https://login.mailchimp.com/oauth2/authorize?${querystring.stringify({
      response_type: "code",
      client_id: MAILCHIMP_CLIENT_ID,
      redirect_uri: OAUTH_CALLBACK,
    })}`
  );
});

app.get("/api-eureka/eureka/v1/oauth/mailchimp/callback", (req, res, next) => {
  const communityId = req.query.communityId;

  let accessToken = null;
  const config = {
    headers: { "Content-Type": "application/x-www-form-urlencoded" },
  };
  const parameters = {
    grant_type: "authorization_code",
    code: req.query.code,
    client_id: MAILCHIMP_CLIENT_ID,
    client_secret: MAILCHIMP_CLIENT_SECRET,
    redirect_uri: OAUTH_CALLBACK,
  };

  axios
    .post(
      "https://login.mailchimp.com/oauth2/token",
      qs.stringify(parameters),
      config
    )
    .then((response) => {
      accessToken = response.data.access_token;

      axios
        .get("https://login.mailchimp.com/oauth2/metadata", {
          headers: {
            Authorization: `OAuth ${accessToken}`,
          },
        })
        .then((metadataResponse) => {
          Community.findById(communityId)
            .then((community) => {
              const isConnectedMailChimp = community.isConnectedMailChimp;

              if (isConnectedMailChimp) {
                //
                res.status(200).json({
                  status: "success",
                  data: community,
                });
              } else {
                MailChimp.create({
                  communityId: community._id,
                  accessToken,
                  server: metadataResponse.data.dc,

                  apiEndPoint: metadataResponse.data.api_endpoint,
                })
                  .then(async () => {
                    community.isConnectedMailChimp = true;
                    // const [a] = community;
                    const updatedCommunity = await community.save({
                      new: true,

                      validateModifiedOnly: true,
                    });

                    res.status(200).json({
                      status: "success",
                      data: updatedCommunity,
                    });
                  })
                  .catch((error) => next(error));
              }
            })
            .catch((error) => next(error));
        })
        .catch((error) => next(error));
    });
});

app.get(
  "/api-eureka/eureka/v1/fetchMailChimpAudiences",
  async (req, res, next) => {
    // 1. find by community id by event id
    console.log(req.query, "i am counting on you eventid");
    const eventData = await Event.findById(req.query.eventId);

    //2. find the mailchimp account with community id

    const communityId = eventData.communityId;
    console.log(communityId, "i am counting on you communityId");
    const mailChimpData = await MailChimp.findOne({ communityId });

    //3. dynamically form request for fetching list

    //  fetch(`https://${mailChimpData.server}.api.mailchimp.com/3.0/lists`)
    // https://us5.api.mailchimp.com
    request
      .get(mailChimpData.apiEndPoint + "/3.0/lists")
      .set("Accept", "application/json")
      .set("Authorization", "OAuth " + mailChimpData.accessToken)
      .end((err, result) => {
        if (err) {
          res.status(500).json(err);
        } else {
          res.json(result.body.lists);
        }
      });
  }
);

app.get("/api-eureka/eureka/v1/logout", (req, res) => {
  req.logout();
  res.redirect("/");
});
app.use("/api-eureka/eureka/v1", globalRoutes);
app.use(globalErrorHandler);

app.get("/api-eureka/eureka/v1/auth/salesforce", function (req, res, next) {
  const oauth2 = new jsforce.OAuth2({
    clientId: process.env.SALESFORCE_CLIENT_ID,
    clientSecret: process.env.SALESFORCE_CLIENT_SECRET_ID,
    redirectUri: "http://localhost:3001/bluemeet/salesforce/redirect",
  });
  res.redirect(oauth2.getAuthorizationUrl({}));
});

app.get(
  "/api-eureka/eureka/v1/oauth/salesforce/callback",
  (req, response, next) => {
    const oauth2 = new jsforce.OAuth2({
      clientId: process.env.SALESFORCE_CLIENT_ID,
      clientSecret: process.env.SALESFORCE_CLIENT_SECRET_ID,
      redirectUri: "http://localhost:3001/bluemeet/salesforce/redirect",
    });
    const conn = new jsforce.Connection({ oauth2: oauth2 });
    conn.authorize(req.query.code, function (err, userInfo) {
      if (err) {
        return console.error(err);
      }
      const conn2 = new jsforce.Connection({
        instanceUrl: conn.instanceUrl,
        accessToken: conn.accessToken,
      });

      conn2.identity(function (err, res) {
        if (err) {
          return console.error(err);
        }
        Community.findById(req.query.communityId)
          .then((community) => {
            SalesForce.create({
              communityId: req.query.communityId,
              accessToken: conn.accessToken,
              instanceUrl: conn.instanceUrl,
              refreshToken: conn.refreshToken,
            })
              .then(async () => {
                community.isConnectedSalesforce = true;
                const updatedCommunity = await community.save({
                  new: true,
                  validateModifiedOnly: true,
                });

                response.status(200).json({
                  status: "success",
                  data: updatedCommunity,
                });
              })
              .catch((err) => next(err));
          })
          .catch((err) => next(err));
      });
    });
  }
);

module.exports = app;