waku-org
/
nwaku
mirror of https://github.com/waku-org/nwaku.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

postgres_driver: simple reformat with nph (#2785)

This commit is contained in:
Ivan FB 2024-06-06 12:04:40 +02:00 committed by GitHub
parent 3a93437300
commit dbe79250da
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 26 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

35
waku/waku_archive/driver/postgres_driver/postgres_driver.nim
View File

@ -34,8 +34,11 @@ const InsertRowStmtDefinition = # TODO: get the sql queries from a file
version, timestamp, meta) VALUES ($1, $2, $3, $4, $5, $6, $7, $8, CASE WHEN $9 = '' THEN NULL ELSE $9 END) ON CONFLICT DO NOTHING;"""
const SelectNoCursorAscStmtName = "SelectWithoutCursorAsc"
const SelectClause = """SELECT storedAt, contentTopic, payload, pubsubTopic, version, timestamp, id, messageHash, meta FROM messages """
const SelectNoCursorAscStmtDef = SelectClause & """
const SelectClause =
"""SELECT storedAt, contentTopic, payload, pubsubTopic, version, timestamp, id, messageHash, meta FROM messages """
const SelectNoCursorAscStmtDef =
SelectClause &
"""
WHERE contentTopic IN ($1) AND
messageHash IN ($2) AND
pubsubTopic = $3 AND
@ -44,7 +47,9 @@ const SelectNoCursorAscStmtDef = SelectClause & """
ORDER BY storedAt ASC, messageHash ASC LIMIT $6;"""
const SelectNoCursorDescStmtName = "SelectWithoutCursorDesc"
const SelectNoCursorDescStmtDef = SelectClause & """
const SelectNoCursorDescStmtDef =
SelectClause &
"""
WHERE contentTopic IN ($1) AND
messageHash IN ($2) AND
pubsubTopic = $3 AND
@ -53,7 +58,9 @@ const SelectNoCursorDescStmtDef = SelectClause & """
ORDER BY storedAt DESC, messageHash DESC LIMIT $6;"""
const SelectWithCursorDescStmtName = "SelectWithCursorDesc"
const SelectWithCursorDescStmtDef = SelectClause & """
const SelectWithCursorDescStmtDef =
SelectClause &
"""
WHERE contentTopic IN ($1) AND
messageHash IN ($2) AND
pubsubTopic = $3 AND
@ -63,7 +70,9 @@ const SelectWithCursorDescStmtDef = SelectClause & """
ORDER BY storedAt DESC, messageHash DESC LIMIT $8;"""
const SelectWithCursorAscStmtName = "SelectWithCursorAsc"
const SelectWithCursorAscStmtDef = SelectClause & """
const SelectWithCursorAscStmtDef =
SelectClause &
"""
WHERE contentTopic IN ($1) AND
messageHash IN ($2) AND
pubsubTopic = $3 AND
@ -76,7 +85,9 @@ const SelectMessageByHashName = "SelectMessageByHash"
const SelectMessageByHashDef = SelectClause & """WHERE messageHash = $1"""
const SelectNoCursorV2AscStmtName = "SelectWithoutCursorV2Asc"
const SelectNoCursorV2AscStmtDef = SelectClause & """
const SelectNoCursorV2AscStmtDef =
SelectClause &
"""
WHERE contentTopic IN ($1) AND
pubsubTopic = $2 AND
storedAt >= $3 AND
@ -84,7 +95,9 @@ const SelectNoCursorV2AscStmtDef = SelectClause & """
ORDER BY storedAt ASC LIMIT $5;"""
const SelectNoCursorV2DescStmtName = "SelectWithoutCursorV2Desc"
const SelectNoCursorV2DescStmtDef = SelectClause & """
const SelectNoCursorV2DescStmtDef =
SelectClause &
"""
WHERE contentTopic IN ($1) AND
pubsubTopic = $2 AND
storedAt >= $3 AND
@ -92,7 +105,9 @@ const SelectNoCursorV2DescStmtDef = SelectClause & """
ORDER BY storedAt DESC LIMIT $5;"""
const SelectWithCursorV2DescStmtName = "SelectWithCursorV2Desc"
const SelectWithCursorV2DescStmtDef = SelectClause & """
const SelectWithCursorV2DescStmtDef =
SelectClause &
"""
WHERE contentTopic IN ($1) AND
pubsubTopic = $2 AND
(storedAt, id) < ($3,$4) AND
@ -101,7 +116,9 @@ const SelectWithCursorV2DescStmtDef = SelectClause & """
ORDER BY storedAt DESC LIMIT $7;"""
const SelectWithCursorV2AscStmtName = "SelectWithCursorV2Asc"
const SelectWithCursorV2AscStmtDef = SelectClause & """
const SelectWithCursorV2AscStmtDef =
SelectClause &
"""
WHERE contentTopic IN ($1) AND
pubsubTopic = $2 AND
(storedAt, id) > ($3,$4) AND