server.js

//jshint esversion:6
import dotenv from "dotenv";
dotenv.config();
import express from "express";
import bodyParser from "body-parser";
import ejs from "ejs";
import mongoose from "mongoose";
import session from 'express-session';
import passport from "passport";
import passportLocalMongoose from "passport-local-mongoose";
import GoogleStrategy from 'passport-google-oauth20';
GoogleStrategy.Strategy
import findOrCreate from 'mongoose-findorcreate';
import jwt from "jsonwebtoken";
import cors from "cors";
import request from "node-fetch";
import fs from "fs";
import FormData from "form-data";
import openurl from "openurl";
import open from "open";

const app = express();

app.use(express.static("public"));
app.set('view engine', 'ejs');
app.use(bodyParser.urlencoded({
    extended: true
}));

app.use(session({
    secret: "Our liitle secret.",
    resave: false,
    saveUninitialized: false
}));

app.use(passport.initialize());
app.use(passport.session());
app.use(cors());
app.use(express.json());
app.use(express.urlencoded({ extended: true }));


mongoose.connect(process.env.MONGO, { useNewUrlParser: true, useUnifiedTopology: true });
// mongoose.set("useCreateIndex", true);

const userSchema = new mongoose.Schema({
    googleId: String,
    username: String,
    picture: String,
    fname: String,
});

userSchema.plugin(passportLocalMongoose);
userSchema.plugin(findOrCreate);

const User = new mongoose.model("User", userSchema);
var currentid = "";

passport.use(User.createStrategy());

passport.serializeUser(function (user, done) {
    done(null, user.id);
});

passport.deserializeUser(function (id, done) {
    User.findById(id, function (err, user) {
        done(err, user);
    });
});

passport.use(new GoogleStrategy({
    clientID: process.env.CLIENT_ID,
    clientSecret: process.env.CLIENT_SECRET,
    callbackURL: "https://chillflix-india.herokuapp.com/auth/google/chillflix",
    //  callbackURL: "http://localhost:3003/auth/google/chillflix",
    userProfileURL: "https://www.googleapis.com/oauth2/v3/userinfo"
},
    function (accessToken, refreshToken, profile, cb) {
        console.log(profile);
        currentid = profile.id;

        User.findOrCreate({ username: profile.emails[0].value, googleId: profile.id, picture: profile.photos[0].value, fname: profile.displayName }, function (err, user) {
            return cb(err, user);
        });
    }
));

app.get("/get-token", (req, res) => {
  const API_KEY = process.env.ZUJONOW_API_KEY;
  const SECRET_KEY = process.env.ZUJONOW_SECRET_KEY;
  const options = { expiresIn: "10m", algorithm: "HS256" };
  const payload = {
    apikey: API_KEY,
  };
  const token = jwt.sign(payload, SECRET_KEY, options);
  console.log(token);
  req.session.token=token;
  res.json({ token });
});


  app.route("/")
    .get((req, res) => {
         res.render('home');
    });


app.get('/auth/google',
    passport.authenticate('google', { scope: ['profile', "email"] }));

app.get("/auth/google/chillflix",
    passport.authenticate('google', { failureRedirect: "/" }),
    function (req, res) {
        res.redirect("/main");
    });

app.route("/main")
.get((req, res) => {
  res.render('main');
});


app.route("/video")
.get((req, res) => {
  const API_KEY = process.env.ZUJONOW_API_KEY;
  const SECRET_KEY = process.env.ZUJONOW_SECRET_KEY;
  const option = { expiresIn: "10m", algorithm: "HS256" };
  const payload = {
    apikey: API_KEY,
  };
  let token = jwt.sign(payload, SECRET_KEY, option);


const formData = new FormData();
formData.append("file", fs.createReadStream("hello.mp4"));

const url = "https://storage-api.zujonow.com/v1/files";
var options = {
  method: "POST",
  headers: {
    Authorization: `${token}`,
  },
  body: formData,
};

request(url, options)
  .then((res) => res.json())
  .then((json) => console.log(json))
  .catch((err) => console.error("error:" + err));



  const url2 = "https://api.zujonow.com/v1/files/?page=1&perPage=20";
  const options2 = {
    method: "GET",
    headers: { Accept: "application/json", Authorization: `${token}` },
    redirect: 'follow'
  };
  
  request(url2, options2)
    .then((res) => res.json())
    .then((json) => {
       let url = json.data[0].fileUrl;
       console.log(url)
      res.redirect(url)})
    .catch((err) => console.error("error:" + err));

 
});


app.route("/meet")
.get((req, res) => {
  const API_KEY = process.env.ZUJONOW_API_KEY;
  const SECRET_KEY = process.env.ZUJONOW_SECRET_KEY;
  const option = { expiresIn: "10m", algorithm: "HS256" };
  const payload = {
    apikey: API_KEY,
  };
  let token = jwt.sign(payload, SECRET_KEY, option);

  const url = "https://api.zujonow.com/v1/meetings";

  var options = {
    method: "POST",
    headers: {
      Authorization: `${token}`,
      Accept: "application/json",
      "Content-Type": "application/json",
    },
  };
  
  request(url, options)
    .then((res) => res.json())
    .then((json) => res.redirect("http://www.videosdk.live/prebuilt/"+json.meetingId))
    .catch((err) => console.error("error:" + err));
    
  
    
});

var a;
var b;

app.route("/livestream")
.get((req, res) => {
  const API_KEY = process.env.ZUJONOW_API_KEY;
  const SECRET_KEY = process.env.ZUJONOW_SECRET_KEY;
  const option = { expiresIn: "10m", algorithm: "HS256" };
  const payload = {
    apikey: API_KEY,
  };
  let token = jwt.sign(payload, SECRET_KEY, option);

  const url = "https://api.zujonow.com/v1/livestreams";
var options = {
  method: "POST",
  headers: {
    Authorization: `${token}`,
    Accept: "application/json",
    "Content-Type": "application/json",
  },
  body: JSON.stringify({
    name: "Nickname for livestream", record: true,
    restream: [
      {
          "url": "rtmp://x.rtmp.youtube.com/live2",
          "streamKey": "0tjp-h6a2-8c9d-vusv-01uu"
      }
    ]
    }),
};

request(url, options)
  .then((res) => res.json())
  .then((json) => {
    console.log(json.upstreamUrl);
    console.log(json.streamKey)
    res.render("livestream", { Url: json.upstreamUrl, Key: json.streamKey})
  })
  
  .catch((err) => console.error("error:" + err));
  

});

app.route("/livevideo")
.post((req, res) => {

  let key="https://live.zujonow.com/live/"+req.body.key+"/index.m3u8";

  res.render('livevideo',{key:key});
});

app.listen(process.env.PORT || 3003, () => {
  console.log('CONNECTION ESTABLISHED ON PORT 3003')
});