diff --git a/server.js b/server.js index 398546e..cab8033 100644 --- a/server.js +++ b/server.js @@ -52,13 +52,22 @@ server.get("/source", function (inReq, inRes) Postgres.FirstRow(sql,[], inRes); }); //returns message about status and error description +server.post("/sourc_single", bodyParser.json(), function (inReq, inRes)// remove body parsing, just pass post body to the sql string build +{ + for (var i =0; i < x.length; i++) { + var sql = "SELECT x.message FROM tps.srce_set($1::jsonb) as x(message)"; + } + Postgres.FirstRow(sql,inReq.body, inRes); +}); server.post("/source", bodyParser.json(), function (inReq, inRes)// remove body parsing, just pass post body to the sql string build { x = inReq.body; - for (var i =0; i < x.length; i++) { - var sql = "SELECT x.message FROM tps.srce_set($1::jsonb) as x(message)"; - Postgres.FirstRow(sql,[JSON.stringify(x[i])], inRes); - } + var sql = "SELECT\ + jsonb_agg(x.message) message\ + FROM\ + jsonb_array_elements($1::jsonb) d(def)\ + JOIN LATERAL tps.srce_set(d.def) x(message) ON TRUE"; + Postgres.FirstRow(sql,[JSON.stringify(x[i])], inRes); }); //----------------------------------------------------------regex instrUctions-------------------------------------------------------------------------------------------------------------------------