pt/tps
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

add nodes

Browse Source
This commit is contained in:
fleetside72 2018-09-04 15:06:27 -04:00
parent ba9ef9e3b4
commit 5c89910cb0
1 changed files with 17 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
server.js
View File

@ -27,7 +27,7 @@ var Postgres = new pg.Client({
host: process.env.host, host: process.env.host,
port: process.env.port, port: process.env.port,
database: process.env.database, database: process.env.database,
ssl: true, ssl: false,
application_name: "tps_etl_api" application_name: "tps_etl_api"
}); });
Postgres.FirstRow = function(inSQL,args, inResponse) Postgres.FirstRow = function(inSQL,args, inResponse)
@ -76,12 +76,19 @@ server.post("/regex", bodyParser.json(), function (inReq, inRes)
//------------------------------------------------------------mappings--------------------------------------------------------------------------------------------------------------------------------- //------------------------------------------------------------mappings---------------------------------------------------------------------------------------------------------------------------------
//list unmapped items flagged to be mapped ?srce= //list unmapped items flagged to be mapped ?srce=
server.get("/unmapped", function (inReq, inRes) server.get("/unmapped_all", function (inReq, inRes)
{ {
var sql = "SELECT jsonb_agg(row_to_json(x)::jsonb) regex FROM tps.report_unmapped_recs($1::text) x"; var sql = "SELECT jsonb_agg(row_to_json(x)::jsonb) regex FROM tps.report_unmapped_recs($1::text) x";
Postgres.FirstRow(sql,[inReq.query.srce], inRes); Postgres.FirstRow(sql,[inReq.query.srce], inRes);
}); });
//list unmapped items flagged to be mapped ?srce=
server.get("/unmapped", function (inReq, inRes)
{
var sql = "SELECT jsonb_agg(row_to_json(x)::jsonb) regex FROM tps.report_unmapped($1::text) x";
Postgres.FirstRow(sql,[inReq.query.srce], inRes);
});
//add entries to lookup table //add entries to lookup table
server.post("/mapping", bodyParser.json(), function (inReq, inRes) server.post("/mapping", bodyParser.json(), function (inReq, inRes)
{ {
@ -89,6 +96,14 @@ server.post("/mapping", bodyParser.json(), function (inReq, inRes)
Postgres.FirstRow(sql,[JSON.stringify( inReq.body)], inRes); Postgres.FirstRow(sql,[JSON.stringify( inReq.body)], inRes);
}); });
//---------------------------------------------------------list imports--------------------------------------------------------------------------------------------------------------------------------
server.get("/import_log", function (inReq, inRes)
{
var sql = "SELECT jsonb_agg(row_to_json(l)::jsonb) regex FROM tps.trans_log l";
Postgres.FirstRow(sql,[], inRes);
});
//-------------------------------------------------------------import data----------------------------------------------------------------------------------------------------------------------------- //-------------------------------------------------------------import data-----------------------------------------------------------------------------------------------------------------------------