Updating search endpoint to have egress processing.
This commit is contained in:
parent
16c6e09c61
commit
e29d7512e4
|
@ -1,4 +1,6 @@
|
||||||
const { QueryBuilder, buildSearchUrl, search } = require("./utils")
|
const { QueryBuilder, buildSearchUrl, search } = require("./utils")
|
||||||
|
const CouchDB = require("../../../db")
|
||||||
|
const { outputProcessing } = require("../../../utilities/rowProcessor")
|
||||||
|
|
||||||
exports.rowSearch = async ctx => {
|
exports.rowSearch = async ctx => {
|
||||||
const appId = ctx.appId
|
const appId = ctx.appId
|
||||||
|
@ -12,6 +14,8 @@ exports.rowSearch = async ctx => {
|
||||||
sortOrder,
|
sortOrder,
|
||||||
sortType,
|
sortType,
|
||||||
} = ctx.request.body
|
} = ctx.request.body
|
||||||
|
const db = new CouchDB(appId)
|
||||||
|
|
||||||
let url
|
let url
|
||||||
if (query) {
|
if (query) {
|
||||||
url = new QueryBuilder(
|
url = new QueryBuilder(
|
||||||
|
@ -32,5 +36,10 @@ exports.rowSearch = async ctx => {
|
||||||
bookmark,
|
bookmark,
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
ctx.body = await search(url)
|
const response = await search(url)
|
||||||
|
const table = await db.get(tableId)
|
||||||
|
ctx.body = {
|
||||||
|
rows: await outputProcessing(appId, table, response.rows),
|
||||||
|
bookmark: response.bookmark,
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue