backend implementation for message pagination

This commit is contained in:
Ulf Gebhardt 2023-07-12 13:36:16 +02:00
parent 481158f815
commit 0cce43500a
Signed by: ulfgebhardt
GPG Key ID: DA6B843E748679C9

View File

@ -13,11 +13,32 @@ export default {
id: context.user.id,
},
}
// this does not work
// params.orderBy = ['createdAt_desc']
const resolved = await neo4jgraphql(object, params, context, resolveInfo)
if (resolved) {
resolved.forEach((message) => {
message._id = message.id
const session = context.driver.session()
const countMessageTxPromise = session.readTransaction(async (transaction) => {
const countMessageCypher = `
MATCH((message:Message)-[:INSIDE]->(:Room { id: $roomId })) RETURN COUNT(message) AS count
`
const countMessageTxResponse = await transaction.run(countMessageCypher, {
roomId,
})
return await countMessageTxResponse.records[0].get('count')
})
try {
const count = await countMessageTxPromise
for (let i = 0; i < resolved.length; i++) {
resolved[i]._id = resolved[i].id
resolved[i].indexId = count - 1 - params.offset - i
}
} catch (error) {
throw new Error(error)
} finally {
session.close()
}
}
return resolved
},