added a default case to commit log search API

Author: neel1996

API/commitLogSearchApi.js

@@ -18,6 +18,9 @@ async function gitCommitLogDbSerchApi(repoId, searchCategory, searchKey) {
     case "user":
       searchQuery = `SELECT * FROM commitLog_${repoId} WHERE author LIKE "%${searchKey}%" LIMIT 10`;
       break;
+    default:
+      searchQuery = `SELECT * FROM commitLog_${repoId} WHERE commit_message LIKE "%${searchKey}%" LIMIT 10`;
+      break;
   }
 
   return new Promise((resolve, reject) => {

package.json

@@ -40,7 +40,7 @@
     "graphiql": "^0.17.5",
     "graphql": "^14.6.0",
     "sqlite3": "^5.0.0",
-    "forever-monitor": "^3.0.1"
+    "chokidar": "^3.4.2"
   },
   "devDependencies": {
     "@types/jest": "^26.0.7",

prettier.config.js

@@ -0,0 +1,6 @@
+module.exports = {
+    trailingComma: "es5",
+    tabWidth: 4,
+    semi: true,
+    singleQuote: true,
+};

server.js

@@ -5,7 +5,8 @@ const express = require("express");
 const path = require("path");
 const fs = require("fs");
 
-const { commitLogCrawler } = require("./utils/foreverProcess");
+const { gitCommitLogToDb } = require("./utils/sqliteDbAccess");
+const { gitRepoListener } = require("./utils/repoChangeListener");
 const app = globalAPI;
 const log = console.log;
 var envConfigFilename = "env_config.json";
@@ -76,7 +77,11 @@ function writeConfigFile(insertFlag = false, envData = {}) {
 
   if (insertFlag) {
     log("INFO: Inserting new data to config file");
-    configData = [{ ...envData }];
+    configData = [
+      {
+        ...envData,
+      },
+    ];
   } else {
     log(
       "INFO: Creating config file with default config -> " +
@@ -116,6 +121,21 @@ globalAPI.listen(getEnvData().GITCONVEX_PORT || 9001, async (err) => {
 
   var DATABASE_FILE = getEnvData().DATABASE_FILE;
 
+  if (!fs.existsSync(DATABASE_FILE)) {
+    log("INFO: Database directory is missing");
+    await fs.promises
+      .mkdir(path.join(__dirname, ".", "/database"))
+      .then(async () => {
+        log(
+          "INFO: Created database directory\nINFO: Setting up new data file in database directory"
+        );
+        await dataFileCreator();
+      })
+      .catch((err) => {
+        log("ERROR: database directory creation failed!");
+      });
+  }
+
   await fs.promises
     .access(DATABASE_FILE)
     .then(() => {
@@ -145,24 +165,10 @@ globalAPI.listen(getEnvData().GITCONVEX_PORT || 9001, async (err) => {
       );
 
       await dataFileCreator();
-
-      if (!fs.existsSync(DATABASE_FILE)) {
-        log("INFO: Database directory is missing");
-        await fs.promises
-          .mkdir(path.join(__dirname, ".", "/database"))
-          .then(async () => {
-            log(
-              "INFO: Created database directory\nINFO: Setting up new data file in database directory"
-            );
-            await dataFileCreator();
-          })
-          .catch((err) => {
-            log("ERROR: database directory creation failed!");
-          });
-      }
     });
 
-  commitLogCrawler();
+  gitCommitLogToDb();
+  gitRepoListener();
 
   log(
     `\n## Gitconvex is running on port ${getEnvData().GITCONVEX_PORT}

utils/repoChangeListener.js

@@ -0,0 +1,25 @@
+const chokidar = require("chokidar");
+const { fetchRepoHandler } = require("../API/fetchRepoApi");
+const { gitCommitLogToDb } = require("./sqliteDbAccess");
+
+async function gitRepoListener() {
+  console.log(
+    "INFO: Repo path listener initiated. All changes in the configured repos will be tracked till gitconvex is stopped"
+  );
+  const { repoPath } = await fetchRepoHandler();
+
+  repoPath.push(__dirname);
+
+  if (repoPath) {
+    repoPath.forEach((repo) => {
+      chokidar
+        .watch(repo, { interval: 1500, usePolling: true })
+        .on("change", (path, stats) => {
+          console.log("INFO: change noticed in ", path);
+          gitCommitLogToDb();
+        });
+    });
+  }
+}
+
+module.exports.gitRepoListener = gitRepoListener;

utils/sqliteDbAccess.js

@@ -157,6 +157,4 @@ async function inserToDbHandler(commitArray, db, repoId) {
     });
 }
 
-gitCommitLogToDb();
-
 module.exports.gitCommitLogToDb = gitCommitLogToDb;