feat: added buffering to query input

src/manual_mode/manualMode.ts

@@ -9,44 +9,28 @@ const rl = createInterface({
   output: process.stdout,
 });
 
-/*
-* Queries to the database with the provided cypher query
-*/
 async function manualQuery(
   cypherQuery: string,
   outputFile: string,
-  dbConnection: DbConnection, // Use DbConnection type here
+  dbConnection: DbConnection,
 ) {
-  // Use queryService to execute the query
   const result = await queryService(dbConnection, cypherQuery);
 
   const outputPath = path.join(__dirname, outputFile);
-
-  // Write result to JSON file with pretty printing
   fs.writeFileSync(outputPath, JSON.stringify(result, null, 2));
 
   console.log(`Query results written to ${outputPath}`);
 }
 
-
-
-
 if (require.main === module) {
-  // Command-line args:
-  // 1st uri,
-  // 2nd username
-  // 3rd password
-  // 4th output file name
   const uri: string = process.argv[2] || "bolt://localhost:7687";
   const username: string = process.argv[3] || "neo4j";
   const password: string = process.argv[4] || "password";
   const outputFile: string = process.argv[5] || "output.json";
 
-  // splits up the url in order to agree with the api
   const [protocol, ...rest] = uri.split("://");
   const url = `://${rest.join("://")}`;
 
-  // Create the DbConnection object
   const dbConfig: DbConnection = {
     id: 1,
     internalDatabaseName: "neo4j",
@@ -58,28 +42,26 @@ if (require.main === module) {
     type: "neo4j",
   };
 
-  console.log('Type a Cypher query to query or type "exit" to exit');
-
-  // Recursive function that asks for queries to execute
-  const promptQuery = () => {
-    rl.question("query: ", async (cypherQuery) => {
-      if (cypherQuery.toLowerCase() === "exit") {
-        console.log("Connection closed. Exiting...");
-        rl.close();
-        process.exit();
-      }
-
+  console.log('Type a Cypher query line by line. Type "RUN" on a new line to execute the query.');
+  
+  let queryBuffer: string[] = []; // Buffer to store multi-line queries
+
+  rl.on("line", async (line: string) => {
+    if (line.trim().toLowerCase() === "exit") {
+      console.log("Exiting...");
+      rl.close();
+      process.exit();
+    } else if (line.trim().toLowerCase() === "run") {
+      const fullQuery = queryBuffer.join("\n");
+      queryBuffer = []; // Clear buffer for next input
       try {
-        // Perform query and write output to file
-        await manualQuery(cypherQuery, outputFile, dbConfig);
-
+        await manualQuery(fullQuery, outputFile, dbConfig);
       } catch (err) {
         console.error("Error executing query:", err);
       }
-
-      promptQuery(); // Await next prompt
-    });
-  };
-
-  promptQuery();
+    } else {
+      queryBuffer.push(line);
+    }
+  });
 }
+

src/manual_mode/output.json

+{
+  "nodes": [],
+  "edges": []
+}
\ No newline at end of file