99import { getModel } from "./utils/model-manager.js" ;
1010import { systemFields } from "./utils/dico.js" ;
1111import sqls from "./utils/sql-select.js" ;
12- import query from "./utils/query.js" ;
13- import errors from "./utils/errors.js" ;
12+ import { runQuery , promiseQuery } from "./utils/query.js" ;
13+ import { badRequest } from "./utils/errors.js" ;
1414import logger from "./utils/logger.js" ;
1515import config from "../config.js" ;
1616
@@ -39,7 +39,7 @@ function SQLgetOne(id, m, res) {
3939 sql += " WHERE t1." + m . pKey + "=$1" ;
4040 } else {
4141 const invalidID = 'Invalid id: "' + id + '".' ;
42- return res ? errors . badRequest ( res , invalidID ) : "ERROR: " + invalidID ;
42+ return res ? badRequest ( res , invalidID ) : "ERROR: " + invalidID ;
4343 }
4444 sql += " LIMIT 1;" ;
4545 return {
@@ -63,9 +63,9 @@ function getOne(req, res) {
6363 }
6464 if ( m . collections && ! req . query . shallow ) {
6565 const qCollecs = m . collections . map ( ( collec ) =>
66- query . promiseQuery ( SQLCollecOne ( collec ) , [ id ] , false )
66+ promiseQuery ( SQLCollecOne ( collec ) , [ id ] , false )
6767 ) ;
68- qCollecs . unshift ( query . promiseQuery ( sql , sqlParams , true ) ) ;
68+ qCollecs . unshift ( promiseQuery ( sql , sqlParams , true ) ) ;
6969 Promise . all ( qCollecs )
7070 . then ( ( data ) => {
7171 if ( data && data . length ) {
@@ -86,10 +86,10 @@ function getOne(req, res) {
8686 res . json ( err ) ;
8787 } ) ;
8888 } else {
89- query . runQuery ( res , sql , sqlParams , true ) ;
89+ runQuery ( res , sql , sqlParams , true ) ;
9090 }
9191 } else {
92- errors . badRequest ( res , 'Invalid model: "' + mid + '".' ) ;
92+ badRequest ( res , 'Invalid model: "' + mid + '".' ) ;
9393 }
9494}
9595
@@ -102,7 +102,7 @@ function insertOne(req, res) {
102102 logger . logReq ( "INSERT ONE" , req ) ;
103103 const m = getModel ( req . params . entity ) ;
104104 if ( ! m ) {
105- return errors . badRequest ( res ) ;
105+ return badRequest ( res ) ;
106106 } else {
107107 const pKey = m . pKey || "id" ,
108108 q = sqls . namedValues ( m , req , "insert" ) ;
@@ -125,9 +125,9 @@ function insertOne(req, res) {
125125 sqls . select ( m . fields , false , null , "C" ) +
126126 ";" ;
127127
128- query . runQuery ( res , sql , q . values , true ) ;
128+ runQuery ( res , sql , q . values , true ) ;
129129 } else {
130- errors . badRequest ( res ) ;
130+ badRequest ( res ) ;
131131 }
132132 }
133133}
@@ -171,9 +171,9 @@ function updateOne(req, res) {
171171 " as id, " +
172172 sqls . select ( m . fields , false , null , "U" ) +
173173 ";" ;
174- query . runQuery ( res , sql , q . values , true ) ;
174+ runQuery ( res , sql , q . values , true ) ;
175175 } else {
176- errors . badRequest ( res ) ;
176+ badRequest ( res ) ;
177177 }
178178}
179179
@@ -206,13 +206,13 @@ function deleteX(req, res) {
206206 "::integer AS id" ;
207207 params = ids ;
208208 } else {
209- errors . badRequest ( res ) ;
209+ badRequest ( res ) ;
210210 return ;
211211 }
212212 }
213- query . runQuery ( res , sql , params , ids . length === 1 ) ;
213+ runQuery ( res , sql , params , ids . length === 1 ) ;
214214 } else {
215- errors . badRequest ( res ) ;
215+ badRequest ( res ) ;
216216 }
217217}
218218
@@ -236,9 +236,9 @@ function collecOne(req, res) {
236236
237237 if ( m && collec ) {
238238 const sqlParams = [ parseInt ( req . query . id , 10 ) ] ;
239- query . runQuery ( res , SQLCollecOne ( collec ) , sqlParams , false ) ;
239+ runQuery ( res , SQLCollecOne ( collec ) , sqlParams , false ) ;
240240 } else {
241- errors . badRequest ( res ) ;
241+ badRequest ( res ) ;
242242 }
243243}
244244
0 commit comments