Skip to content

Commit d5672fb

Browse files
committed
fix(integrations): fixed issue with pg-promise not using parametrized queries
Signed-off-by: Uroš Marolt <uros@marolt.me>
1 parent 4eaf653 commit d5672fb

2 files changed

Lines changed: 6 additions & 3 deletions

File tree

scripts/services/script-executor-worker.yaml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -57,7 +57,7 @@ services:
5757
- ../../services/libs/telemetry/src:/usr/crowd/app/services/libs/telemetry/src
5858
- ../../services/libs/temporal/src:/usr/crowd/app/services/libs/temporal/src
5959
- ../../services/libs/types/src:/usr/crowd/app/services/libs/types/src
60-
- ../../services/apps/script-executor_worker/src:/usr/crowd/app/services/apps/script-executor_worker/src
60+
- ../../services/apps/script_executor_worker/src:/usr/crowd/app/services/apps/script_executor_worker/src
6161

6262
networks:
6363
crowd-bridge:

services/libs/data-access-layer/src/activities/sql.ts

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -621,9 +621,12 @@ export async function queryActivities(
621621
activities = await queryOverHttp(formatted)
622622
count = 0
623623
} else {
624+
const formattedQuery = formatQuery(query, params)
625+
const formattedCountQuery = formatQuery(countQuery, params)
626+
624627
const [results, countResults] = await Promise.all([
625-
qdbConn.any(query, params),
626-
arg.noCount === true ? Promise.resolve([{ count: 0 }]) : qdbConn.query(countQuery, params),
628+
qdbConn.any(formattedQuery),
629+
arg.noCount === true ? Promise.resolve([{ count: 0 }]) : qdbConn.query(formattedCountQuery),
627630
])
628631

629632
activities = results

0 commit comments

Comments
 (0)