From 95e90b5cf6cb7d9d01fc9c6c099e5d58ac6f64a3 Mon Sep 17 00:00:00 2001
From: "sigonasr2, Sig, Sigo" <sigonasr2@gmail.com>
Date: Wed, 11 Aug 2021 06:30:22 +0000
Subject: [PATCH] Add ability to import csv using name or ID value.

---
 server.js | 62 +++++++++++++++++++++++++++++++++++++++++++++++++++++--
 1 file changed, 60 insertions(+), 2 deletions(-)

diff --git a/server.js b/server.js
index 9c3bc1f..56870bb 100644
--- a/server.js
+++ b/server.js
@@ -458,7 +458,10 @@ function CreateDynamicEndpoints() {
 						var all_filled_fields=combinedfields.filter((field)=>(field in req.body))
 						var requiresInsert=true
 						if (endpoint.requiredfields.includes("name")) {
-							await db.query('update '+endpoint.endpoint+' set '+all_filled_fields.map((field,i)=>field+"=$"+(i+1)).join(",")+' where name=$'+(all_filled_fields.length+1)+' returning *',[...all_filled_fields.map((field)=>req.body[field]),req.body["name"]])
+							await db.query('update '+endpoint.endpoint+' set '+all_filled_fields.map((field,i)=>{
+							if (!field.includes("_id")) {return field+"=$"+(i+1)}else{
+								if (Number.isNaN(Number(req.body[field]))) {return field+"=(select id from "+field.replace("_id","")+" where name=$"+(i+1)+")"} else {return field+"=$"+(i+1)}
+							}}).join(",")+' where name=$'+(all_filled_fields.length+1)+' returning *',[...all_filled_fields.map((field)=>req.body[field]),req.body["name"]])
 							.then((data)=>{
 								if (data.rows.length===0) {
 									requiresInsert=true
@@ -472,14 +475,69 @@ function CreateDynamicEndpoints() {
 							})
 						}
 						if (requiresInsert) {
-							db.query('insert into '+endpoint.endpoint+"("+all_filled_fields.join(',')+") values("+all_filled_fields.map((field,i)=>"$"+(i+1)).join(",")+") returning *",all_filled_fields.map((field)=>req.body[field]))
+							db.query('insert into '+endpoint.endpoint+"("+all_filled_fields.join(',')+") values("+all_filled_fields.map((field,i)=>{
+								if (!field.includes("_id")) {return "$"+(i+1)}else{
+									if (Number.isNaN(Number(req.body[field]))) {return "(select id from "+field.replace("_id","")+" where name=$"+(i+1)+")"} else {return "$"+(i+1)}
+								}}).join(",")+") returning *",all_filled_fields.map((field)=>req.body[field]))
 							.then((data)=>{
 								res.status(200).json(data.rows)
 							})
 							.catch((err)=>{
 								res.status(500).send(err.message)
 							})
+						}app.post(PREFIX+"/"+endpoint.endpoint,async(req,res)=>{
+				db4.query('select * from password where password=$1',[req.body.pass])
+				.then(async(data)=>{
+					if (data.rows.length>0) {
+						var allExist=true
+						endpoint.requiredfields.forEach((field)=>{
+							if (!(field in req.body)) {
+								allExist=false;
+							}
+						})
+						if (!allExist) {
+							res.status(300).send("Required fields are: "+endpoint.requiredfields.filter((field)=>!(field in req.body)).join(','))
+							return
 						}
+						
+						var combinedfields = [...endpoint.requiredfields,...endpoint.optionalfields,...endpoint.excludedfields]
+						//console.log(combinedfields)
+						var all_filled_fields=combinedfields.filter((field)=>(field in req.body))
+						var requiresInsert=true
+						if (endpoint.requiredfields.includes("name")) {
+							await db.query('update '+endpoint.endpoint+' set '+all_filled_fields.map((field,i)=>{
+							if (!field.includes("_id")) {return field+"=$"+(i+1)}else{
+								if (Number.isNaN(Number(req.body[field]))) {return field+"=(select id from "+field.replace("_id","")+" where name=$"+(i+1)+")"} else {return field+"=$"+(i+1)}
+							}}).join(",")+' where name=$'+(all_filled_fields.length+1)+' returning *',[...all_filled_fields.map((field)=>req.body[field]),req.body["name"]])
+							.then((data)=>{
+								if (data.rows.length===0) {
+									requiresInsert=true
+								} else {
+									requiresInsert=false
+									res.status(200).json(data.rows)
+								}
+							})
+							.catch((err)=>{
+								res.status(500).send(err.message)
+							})
+						}
+						if (requiresInsert) {
+							db.query('insert into '+endpoint.endpoint+"("+all_filled_fields.join(',')+") values("+all_filled_fields.map((field,i)=>{
+								if (!field.includes("_id")) {return "$"+(i+1)}else{
+									if (Number.isNaN(Number(req.body[field]))) {return "(select id from "+field.replace("_id","")+" where name=$"+(i+1)+")"} else {return "$"+(i+1)}
+								}}).join(",")+") returning *",all_filled_fields.map((field)=>req.body[field]))
+							.then((data)=>{
+								res.status(200).json(data.rows)
+							})
+							.catch((err)=>{
+								res.status(500).send(err.message)
+							})
+						}
+					} else {
+						res.status(500).send("Could not authenticate!")
+					}
+				})
+			})
 					} else {
 						res.status(500).send("Could not authenticate!")
 					}