app.ts

// express server
import express from "express";

// database
import mongoose from "mongoose";

// body parser for request payload
import bp = require("body-parser");

// handler imports
import {
  UsersRouter
} from "./src/api/user/entrypoint";

// dotenv
const dotenv = require("dotenv");
dotenv.config();

// Func to call people daily
import { InfoAPICronFunc } from "./src/pkg/outbound/cron";

import { MongoRepo } from "./src/pkg/user/mongodb";

// initializing express server 
const app : express.Application = express();

// request logging layer
const morgan = require("morgan");
app.use(morgan(process.env.LOGGING_FMT));

// handling json request payload
app.use(bp.json());

// health route
app.get("/ping", (req, res, next) => {
  return res.send({message: "Live!"}).status(200);
})

// application endpoint handlers
app.use(`${process.env.API_VERSION}/user`, UsersRouter);

// mongoDB connection promise
mongoose.connect(<string>process.env.DB_URI, {
  useNewUrlParser: true,
	useUnifiedTopology: true,
	useFindAndModify: false,
	useCreateIndex: true
}).then(() => {
  console.log("Connected to MongoDB")
}).catch((err: any) => {
  console.error(err);
  process.exit(1);
})


// not found handler
app.get("/*", (req: express.Request, res: express.Response, next: express.NextFunction) => {
  return res.json({message: "Hello world"})
})


// error handler
app.use((err: Error, req: express.Request, res: express.Response, next: express.NextFunction) => {
  return res.json({message: "Error occurred", error_log: err.message}).status(500);
})

// server hosting section
let port = process.env.PORT || 3000;
app.listen(port, () => {
  console.info(
    `Serving on port ${port}`
  );
  
	let userRepo = new MongoRepo();
  setInterval(async () => {
			console.log("Calling subscribers");
			userRepo.ShowAllPhoneNumbers(0, 0)
					.then(nums => {
							let numArray = [];
							for(let n of nums) {
									numArray.push(n.phoneNumber)
							}
							InfoAPICronFunc(numArray)
									.then(console.log)
							.catch(console.error)
					})
			.catch(console.error)
  }, 1000 * 60 * 60 * 24);
});