run prettier

opspotes · Oct 13, 2023 · 47b703f · 47b703f
1 parent 58a6aa6
commit 47b703f
Show file tree

Hide file tree

Showing 185 changed files with 9,068 additions and 8,119 deletions.
diff --git a/.prettierignore b/.prettierignore
@@ -0,0 +1,5 @@
+.github/
+public/
+build/
+node_modules/
+backend/node_modules
diff --git a/.prettierrc b/.prettierrc
@@ -0,0 +1 @@
+{}
diff --git a/backend/create_database.js b/backend/create_database.js
@@ -1,37 +1,33 @@
-const { Client } = require('pg');
+const { Client } = require("pg");
 
-const _POSTGRES_USER=process.env.POSTGRES_USER;
+const _POSTGRES_USER = process.env.POSTGRES_USER;
 const _POSTGRES_PASSWORD = process.env.POSTGRES_PASSWORD;
-const _POSTGRES_IP=process.env.POSTGRES_IP;
+const _POSTGRES_IP = process.env.POSTGRES_IP;
 const _POSTGRES_PORT = process.env.POSTGRES_PORT;
 
-
 const client = new Client({
-    host: _POSTGRES_IP,
-    user: _POSTGRES_USER,
-    password: _POSTGRES_PASSWORD,
-    port: _POSTGRES_PORT,
+  host: _POSTGRES_IP,
+  user: _POSTGRES_USER,
+  password: _POSTGRES_PASSWORD,
+  port: _POSTGRES_PORT,
 });
 
 const createDatabase = async () => {
-    try {
-        await client.connect();                            // gets connection
-        await client.query('CREATE DATABASE jfstat'); // sends queries
-        return true;
-    } catch (error) {
-        if(!error.stack.includes('already exists'))
-        {
-            console.error(error.stack);
-        }
-
-        return false;
-    } finally {
-        await client.end();                                // closes connection
+  try {
+    await client.connect(); // gets connection
+    await client.query("CREATE DATABASE jfstat"); // sends queries
+    return true;
+  } catch (error) {
+    if (!error.stack.includes("already exists")) {
+      console.error(error.stack);
     }
-};
 
+    return false;
+  } finally {
+    await client.end(); // closes connection
+  }
+};
 
 module.exports = {
-    createDatabase:createDatabase,
-  };
-
+  createDatabase: createDatabase,
+};
diff --git a/backend/db.js b/backend/db.js
@@ -1,137 +1,136 @@
-const { Pool } = require('pg');
+const { Pool } = require("pg");
 const pgp = require("pg-promise")();
-const {update_query : update_query_map} = require("./models/bulk_insert_update_handler");
+const {
+  update_query: update_query_map,
+} = require("./models/bulk_insert_update_handler");
 
-
-const _POSTGRES_USER=process.env.POSTGRES_USER;
+const _POSTGRES_USER = process.env.POSTGRES_USER;
 const _POSTGRES_PASSWORD = process.env.POSTGRES_PASSWORD;
-const _POSTGRES_IP=process.env.POSTGRES_IP;
+const _POSTGRES_IP = process.env.POSTGRES_IP;
 const _POSTGRES_PORT = process.env.POSTGRES_PORT;
 
-if([_POSTGRES_USER,_POSTGRES_PASSWORD,_POSTGRES_IP,_POSTGRES_PORT].includes(undefined))
-{
-  console.log('Error: Postgres details not defined');
+if (
+  [_POSTGRES_USER, _POSTGRES_PASSWORD, _POSTGRES_IP, _POSTGRES_PORT].includes(
+    undefined,
+  )
+) {
+  console.log("Error: Postgres details not defined");
   return;
-
 }
 
 const pool = new Pool({
-  user: (_POSTGRES_USER),
-  host:(_POSTGRES_IP),
-  database: 'jfstat',
-  password:(_POSTGRES_PASSWORD),
-  port: (_POSTGRES_PORT),
+  user: _POSTGRES_USER,
+  host: _POSTGRES_IP,
+  database: "jfstat",
+  password: _POSTGRES_PASSWORD,
+  port: _POSTGRES_PORT,
 });
 
-pool.on('error', (err, client) => {
-  console.error('Unexpected error on idle client', err);
+pool.on("error", (err, client) => {
+  console.error("Unexpected error on idle client", err);
   return;
-  //process.exit(-1);
 });
 
 async function deleteBulk(table_name, data) {
   const client = await pool.connect();
-  let result='SUCCESS';
-  let message='';
+  let result = "SUCCESS";
+  let message = "";
   try {
-    await client.query('BEGIN');
+    await client.query("BEGIN");
 
     if (data && data.length !== 0) {
-
       const deleteQuery = {
-        text: `DELETE FROM ${table_name} WHERE "Id" IN (${pgp.as.csv(
-          data
-        )})`
+        text: `DELETE FROM ${table_name} WHERE "Id" IN (${pgp.as.csv(data)})`,
       };
       //  console.log(deleteQuery);
       await client.query(deleteQuery);
-    } 
-
-
-    await client.query('COMMIT');
-    message=(data.length + " Rows removed.");
+    }
 
+    await client.query("COMMIT");
+    message = data.length + " Rows removed.";
   } catch (error) {
-    await client.query('ROLLBACK');
-    message=('Bulk delete error: '+ error);
-    result='ERROR';
+    await client.query("ROLLBACK");
+    message = "Bulk delete error: " + error;
+    result = "ERROR";
   } finally {
     client.release();
   }
-  return ({Result:result,message:''+message});
+  return { Result: result, message: "" + message };
 }
 
-async function insertBulk(table_name, data,columns) {
+async function insertBulk(table_name, data, columns) {
   //dedupe data
 
-if (Array.isArray(data)) {
-  data= data.reduce((accumulator, currentItem) => {
-      const isDuplicate = accumulator.some(item =>  currentItem.Id ? (item.Id === currentItem.Id) : (item.rowid === currentItem.rowid));
-
+  if (Array.isArray(data)) {
+    data = data.reduce((accumulator, currentItem) => {
+      const isDuplicate = accumulator.some((item) =>
+        currentItem.Id
+          ? item.Id === currentItem.Id
+          : item.rowid === currentItem.rowid,
+      );
+
       if (!isDuplicate) {
         accumulator.push(currentItem);
       }
-    
+
       return accumulator;
     }, []);
   }
 
-
   //
   const client = await pool.connect();
-  let result='SUCCESS';
-  let message='';
+  let result = "SUCCESS";
+  let message = "";
   try {
-      await client.query("BEGIN");
-      const update_query= update_query_map.find(query => query.table === table_name).query;
-      await client.query("COMMIT");
-      const cs = new pgp.helpers.ColumnSet(columns, { table: table_name });
-      const query = pgp.helpers.insert(data, cs) + update_query; // Update the column names accordingly
-      await client.query(query);
-
+    await client.query("BEGIN");
+    const update_query = update_query_map.find(
+      (query) => query.table === table_name,
+    ).query;
+    await client.query("COMMIT");
+    const cs = new pgp.helpers.ColumnSet(columns, { table: table_name });
+    const query = pgp.helpers.insert(data, cs) + update_query; // Update the column names accordingly
+    await client.query(query);
   } catch (error) {
-    await client.query('ROLLBACK');
-    message=(''+ error);
-    result='ERROR';
+    await client.query("ROLLBACK");
+    message = "" + error;
+    result = "ERROR";
   } finally {
     client.release();
   }
-  return ({Result:result,message:message?'Bulk insert error: '+message:''});
+  return {
+    Result: result,
+    message: message ? "Bulk insert error: " + message : "",
+  };
 }
 
-async function query(text, params)  {
+async function query(text, params) {
   try {
-    const result = await pool.query(text, params);
-    return result;
+    return await pool.query(text, params);
   } catch (error) {
-
-    if(error?.routine==='auth_failed')
-    {
-     console.log('Error 401: Unable to Authenticate with Postgres DB');
-    }else
-    if(error?.code==='ENOTFOUND')
-    {
-     console.log('Error: Unable to Connect to Postgres DB');
-    }else
-    if(error?.code==='ERR_SOCKET_BAD_PORT')
-    {
-     console.log('Error: Invalid Postgres DB Port Range. Port should be >= 0 and < 65536.');
-    }else
-    if(error?.code==='ECONNREFUSED')
-    {
-     console.log('Error: Postgres DB Connection refused at '+error.address+':'+error.port);
-    }else
-    {
-     console.error('Error occurred while executing query:', error);
+    if (error?.routine === "auth_failed") {
+      console.log("Error 401: Unable to Authenticate with Postgres DB");
+    } else if (error?.code === "ENOTFOUND") {
+      console.log("Error: Unable to Connect to Postgres DB");
+    } else if (error?.code === "ERR_SOCKET_BAD_PORT") {
+      console.log(
+        "Error: Invalid Postgres DB Port Range. Port should be >= 0 and < 65536.",
+      );
+    } else if (error?.code === "ECONNREFUSED") {
+      console.log(
+        "Error: Postgres DB Connection refused at " +
+          error.address +
+          ":" +
+          error.port,
+      );
+    } else {
+      console.error("Error occurred while executing query:", error);
     }
     return [];
-    // throw error;
   }
 }
 
 module.exports = {
-  query:query,
+  query: query,
   deleteBulk: deleteBulk,
   insertBulk: insertBulk,
-  // initDB: initDB,
 };
diff --git a/backend/logging/taskName.js b/backend/logging/taskName.js
@@ -1,8 +1,8 @@
 const task = {
-    sync: 'Jellyfin Sync',
-    backup: 'Backup',
-    restore: 'Restore',
-    import: 'Jellyfin Playback Reporting Plugin Sync',
-  };
-  
-  module.exports = task;
+  sync: "Jellyfin Sync",
+  backup: "Backup",
+  restore: "Restore",
+  import: "Jellyfin Playback Reporting Plugin Sync",
+};
+
+module.exports = task;
diff --git a/backend/logging/taskstate.js b/backend/logging/taskstate.js
@@ -1,7 +1,7 @@
 const taskstate = {
-    SUCCESS: 'Success',
-    FAILED: 'Failed',
-    RUNNING: 'Running',
-  };
-  
-  module.exports = taskstate;
+  SUCCESS: "Success",
+  FAILED: "Failed",
+  RUNNING: "Running",
+};
+
+module.exports = taskstate;
diff --git a/backend/logging/triggertype.js b/backend/logging/triggertype.js
@@ -1,6 +1,6 @@
 const triggertype = {
-    Automatic: 'Automatic',
-    Manual: 'Manual'
-  };
-  
-  module.exports = triggertype;
+  Automatic: "Automatic",
+  Manual: "Manual",
+};
+
+module.exports = triggertype;