disable metrics

Author: jaspermayone

src/functions/domain.ts

@@ -1,18 +1,18 @@
 import puppeteer from "puppeteer";
 
-import metrics from "../metrics";
+// import metrics from "../metrics";
 import { prisma } from "../prisma";
 import {
-  walshyService,
-  ipQualityScoreService,
   googleSafebrowsingService,
-  sinkingYahtsService,
-  virusTotalService,
+  ipQualityScoreService,
   phishermanService,
   phishObserverService,
-  urlScanService,
-  securityTrailsService,
   phishReportService,
+  securityTrailsService,
+  sinkingYahtsService,
+  urlScanService,
+  virusTotalService,
+  walshyService,
 } from "../services/_index";
 
 /**
@@ -23,12 +23,13 @@ import {
  */
 export async function domainCheck(domain: string) {
   const tsStart = Date.now();
-  metrics.increment("functions.domainCheck");
+  // metrics.increment("functions.domainCheck");
 
   let walshyData = await walshyService.domain.check(domain);
   let ipQualityScoreData = await ipQualityScoreService.domain.check(domain);
-  let googleSafebrowsingData =
-    await googleSafebrowsingService.domain.check(domain);
+  let googleSafebrowsingData = await googleSafebrowsingService.domain.check(
+    domain
+  );
   let sinkingYahtsData = await sinkingYahtsService.domain.check(domain);
   let virusTotalData = await virusTotalService.domain.check(domain);
   let phishermanData = await phishermanService.domain.check(domain);
@@ -81,7 +82,7 @@ export async function domainCheck(domain: string) {
   });
 
   await browser.close();
-  metrics.timing("functions.timing.domainCheck", Date.now() - tsStart);
+  // metrics.timing("functions.timing.domainCheck", Date.now() - tsStart);
 
   return {
     walshyData,

src/functions/jwt.ts

@@ -1,6 +1,6 @@
 import * as jwt from "jsonwebtoken";
 
-import metrics from "../metrics";
+// import metrics from "../metrics";
 import { prisma } from "../prisma";
 
 /**
@@ -11,7 +11,7 @@ import { prisma } from "../prisma";
  * @returns void
  */
 export async function authenticateToken(req: any, res: any, next: any) {
-  metrics.increment("functions.jwt.authenticateToken");
+  // metrics.increment("functions.jwt.authenticateToken");
 
   const authHeader = req.headers["authorization"];
   const token = authHeader && authHeader.split(" ")[1];
@@ -28,7 +28,7 @@ export async function authenticateToken(req: any, res: any, next: any) {
       } else {
         return user;
       }
-    },
+    }
   );
 
   let user = await prisma.user.findUnique({
@@ -46,7 +46,7 @@ export async function authenticateToken(req: any, res: any, next: any) {
     return res
       .status(403)
       .json(
-        "Your user has been deleted. Please contact support if you believe this is an error or need to reactivate your account.",
+        "Your user has been deleted. Please contact support if you believe this is an error or need to reactivate your account."
       );
   }
 
@@ -61,17 +61,17 @@ export async function authenticateToken(req: any, res: any, next: any) {
  */
 export async function generateAccessToken(user: any) {
   const tsStart = Date.now();
-  metrics.increment("functions.jwt.generateAccessToken");
+  // metrics.increment("functions.jwt.generateAccessToken");
 
   let token = jwt.sign(
     {
       id: user.id,
       uuid: user.uuid,
     },
-    process.env.JWT_SECRET!,
+    process.env.JWT_SECRET!
   );
   const tsEnd = Date.now();
-  metrics.timing("functions.jwt.generateAccessToken", tsEnd - tsStart);
+  // metrics.timing("functions.jwt.generateAccessToken", tsEnd - tsStart);
   return token;
 }
 
@@ -84,7 +84,7 @@ export async function generateAccessToken(user: any) {
  */
 export async function getUserInfo(prisma: any, res: any, req: any) {
   const tsStart = Date.now();
-  metrics.increment("functions.jwt.getUserInfo");
+  // metrics.increment("functions.jwt.getUserInfo");
 
   const authHeader = req.headers["authorization"];
   const token = authHeader && authHeader.split(" ")[1];
@@ -104,18 +104,18 @@ export async function getUserInfo(prisma: any, res: any, req: any) {
   });
 
   const tsEnd = Date.now();
-  metrics.timing("functions.jwt.getUserInfo", tsEnd - tsStart);
+  // metrics.timing("functions.jwt.getUserInfo", tsEnd - tsStart);
 
   return user;
 }
 
 export async function getPermissionLevel(prisma: any, res: any, req: any) {
   const tsStart = Date.now();
-  metrics.increment("functions.jwt.getPermissionLevel");
+  // metrics.increment("functions.jwt.getPermissionLevel");
 
   const info = await getUserInfo(prisma, res, req);
   // console.log(info);
 
   const tsEnd = Date.now();
-  metrics.timing("functions.jwt.getPermissionLevel", tsEnd - tsStart);
+  // metrics.timing("functions.jwt.getPermissionLevel", tsEnd - tsStart);
 }

src/functions/parseData.ts

@@ -1,5 +1,3 @@
-import metrics from "../metrics";
-
 /**
  * parses the data from the different sources and returns a boolean value
  * @param walshyData - Data from Walshy API
@@ -29,7 +27,7 @@ export async function parseData(
   // return true;
 
   const tsStart = Date.now();
-  metrics.increment("functions.domain.parseData");
+  // metrics.increment("functions.domain.parseData");
 
   let verdict: boolean;
 

src/index.ts

@@ -4,12 +4,11 @@ import expressJSDocSwagger from "express-jsdoc-swagger";
 import helmet from "helmet";
 
 import { app } from "./app";
-import { server } from "./server";
-import { prisma } from "./prisma";
 import router from "./router";
-import metrics from "./metrics";
-import { swaggerOptions as mainSwagOptions } from "./swaggerOptions";
+import { server } from "./server";
+// import metrics from "./metrics";
 import { swaggerOptions as adminSwagOptions } from "./routes/admin/swaggerOptions";
+import { swaggerOptions as mainSwagOptions } from "./swaggerOptions";
 import * as logger from "./utils/logger";
 
 dotenv.config();
@@ -46,7 +45,7 @@ app.use(
       preload: true,
     },
     xPoweredBy: false,
-  }),
+  })
 );
 
 // Add metric interceptors for axios
@@ -64,11 +63,11 @@ axios.interceptors.response.use((res: any) => {
   const httpCode = res.status;
   const timingStatKey = `http.request.${stat}`;
   const codeStatKey = `http.request.${stat}.${httpCode}`;
-  metrics.timing(
-    timingStatKey,
-    performance.now() - res.config.metadata.startTs,
-  );
-  metrics.increment(codeStatKey, 1);
+  // metrics.timing(
+  //   timingStatKey,
+  //   performance.now() - res.config.metadata.startTs
+  // );
+  // // metrics.increment(codeStatKey, 1);
 
   return res;
 });
@@ -103,7 +102,7 @@ app.use("/", router);
 //   "* * * * * *",
 //   async function () {
 //     console.log("Thump Thump");
-//     metrics.increment("heartbeat");
+//     // metrics.increment("heartbeat");
 //   },
 //   null,
 //   true,
@@ -115,7 +114,7 @@ app.use("/", router);
 //   "0 * * * * *",
 //   async function () {
 //     console.log("Thump Thump");
-//     metrics.increment("heartbeat");
+//     // metrics.increment("heartbeat");
 //   },
 //   null,
 //   true,
@@ -124,6 +123,6 @@ app.use("/", router);
 //
 
 server.listen(port, () => {
-  metrics.increment("app.startup");
+  // metrics.increment("app.startup");
   logger.info(`Server is running on port ${port}`);
 });

src/metrics.ts

@@ -1,15 +1,15 @@
-import "dotenv/config";
-import { StatsD } from "node-statsd";
+// import "dotenv/config";
+// import { StatsD } from "node-statsd";
 
-const environment = process.env.NODE_ENV;
-const graphite = process.env.GRAPHITE_HOST;
+// const environment = process.env.NODE_ENV;
+// const graphite = process.env.GRAPHITE_HOST;
 
-if (graphite === null) throw new Error("Graphite host is not configured");
+// if (graphite === null) throw new Error("Graphite host is not configured");
 
-const metrics = new StatsD({
-  host: graphite,
-  port: 8125,
-  prefix: `${environment}.phishdirectory.api.`,
-});
+// const metrics = new StatsD({
+//   host: graphite,
+//   port: 8125,
+//   prefix: `${environment}.phishdirectory.api.`,
+// });
 
-export default metrics;
+// export default metrics;

src/middleware/logRequest.ts

@@ -4,7 +4,6 @@ import requestIp from "request-ip";
 import { getUserInfo } from "../functions/jwt";
 import { prisma } from "../prisma";
 import { log } from "../utils/logger";
-import metrics from "../metrics";
 
 /**
  * Middleware to log requests to the console
@@ -16,9 +15,9 @@ import metrics from "../metrics";
 export const logRequest = async (
   req: Request,
   res: Response,
-  next: NextFunction,
+  next: NextFunction
 ): Promise<void> => {
-  metrics.increment("api.requests");
+  // metrics.increment("api.requests");
 
   let userAgent = req.headers["user-agent"];
   if (userAgent) {

src/middleware/stripeMeter.ts

@@ -14,7 +14,7 @@ export const stripeMeter = async (
 ): Promise<void> => {
   next();
   // if (process.env.NODE_ENV === "production") {
-  //   metrics.increment("stripeMeter.requests");
+  //   // metrics.increment("stripeMeter.requests");
   //   let userInfo = await getUserInfo(prisma, res, req);
 
   //   if (!userInfo) {

src/router.ts

@@ -1,7 +1,7 @@
 import * as express from "express";
 import responseTime from "response-time";
 
-import metrics from "./metrics";
+// import metrics from "./metrics";
 import { logRequest } from "./middleware/logRequest";
 import adminRouter from "./routes/admin/router";
 import domainRouter from "./routes/domain";
@@ -22,9 +22,9 @@ router.use(
     const httpCode = res.statusCode;
     const timingStatKey = `http.response.${stat}`;
     const codeStatKey = `http.response.${stat}.${httpCode}`;
-    metrics.timing(timingStatKey, time);
-    metrics.increment(codeStatKey, 1);
-  }),
+    // metrics.timing(timingStatKey, time);
+    // // metrics.increment(codeStatKey, 1);
+  })
 );
 
 /**
@@ -35,7 +35,7 @@ router.use(
  *  "Redirecting to /docs"
  */
 router.get("/", logRequest, (req, res) => {
-  metrics.increment("http.request.root");
+  // // metrics.increment("http.request.root");
   res.status(301).redirect("/docs");
 });
 
@@ -49,7 +49,7 @@ router.get("/", logRequest, (req, res) => {
  * }
  */
 router.get("/up", logRequest, (req, res) => {
-  metrics.increment("http.request.up");
+  // // metrics.increment("http.request.up");
   res.status(200).json({
     status: "up",
   });

src/routes/admin/router.ts

@@ -3,7 +3,6 @@ import moment from "moment";
 
 import { getPackageVersion, getVersion } from "../../functions/getVersion";
 import { authenticateToken, getUserInfo } from "../../functions/jwt";
-import metrics from "../../metrics";
 import { logRequest } from "../../middleware/logRequest";
 import { prisma } from "../../prisma";
 import domainRouter from "./routes/domain";
@@ -80,7 +79,7 @@ router.use(async (req, res, next) => {
  * }
  */
 router.get("/metrics", logRequest, async (req, res) => {
-  metrics.increment("endpoint.misc.metrics");
+  // // metrics.increment("endpoint.misc.metrics");
 
   let uptime = process.uptime();
   // format the uptime

src/routes/admin/routes/user.ts

@@ -1,7 +1,6 @@
 import bcrypt from "bcrypt";
-import express, { Request, Response } from "express";
+import express from "express";
 
-import metrics from "../../../metrics";
 import { prisma } from "../../../prisma";
 import { createCustomer } from "../../../stripe";
 
@@ -53,7 +52,7 @@ export type UserLogin = {
  * ]
  */
 router.get("/", async (req, res) => {
-  metrics.increment("endpoint.admin.users.get");
+  // metrics.increment("endpoint.admin.users.get");
   try {
     const users = await prisma.user.findMany({
       orderBy: {
@@ -85,7 +84,7 @@ router.get("/", async (req, res) => {
  * }
  */
 router.get("/user/:id", async (req, res) => {
-  metrics.increment("endpoint.admin.user.get");
+  // metrics.increment("endpoint.admin.user.get");
   try {
     const { id } = req.params;
 
@@ -117,7 +116,7 @@ router.get("/user/:id", async (req, res) => {
  * }
  */
 router.patch("/user/:id", async (req, res) => {
-  metrics.increment("endpoint.admin.user.patch");
+  // metrics.increment("endpoint.admin.user.patch");
   try {
     const { id } = req.params;
     const { email, password, permission } = req.body;
@@ -220,7 +219,7 @@ router.post("/user/new", async (req, res) => {
  * }
  */
 router.delete("/user/:id", async (req, res) => {
-  metrics.increment("endpoint.admin.user.delete");
+  // metrics.increment("endpoint.admin.user.delete");
   try {
     const { id } = req.params;
 
@@ -258,7 +257,7 @@ router.delete("/user/:id", async (req, res) => {
  * }
  */
 router.patch("/role/:id/:permission", async (req, res) => {
-  metrics.increment("endpoint.admin.user.role.patch");
+  // metrics.increment("endpoint.admin.user.role.patch");
 
   try {
     const { id, permission } = req.params;