diff --git a/server.js b/server.js index 6cc88bd..85f1a06 100644 --- a/server.js +++ b/server.js @@ -62,7 +62,7 @@ server.post("/source", bodyParser.json(), function (inReq, inRes)// remove body { x = inReq.body; var sql = "SELECT\ - jsonb_agg(x.message) message\ + jsonb_agg(jsonb_build_object('name',d.def->>'name')||x.message) \ FROM\ jsonb_array_elements($1::jsonb) d(def)\ JOIN LATERAL tps.srce_set(d.def) x(message) ON TRUE";