apunkt/dograh
1
0
Fork 0
mirror of https://github.com/dograh-hq/dograh.git synced 2026-06-07 07:55:16 +02:00
Code Issues Projects Releases Packages Wiki Activity

fix: fix db filters

Browse source
This commit is contained in:
Abhishek Kumar 2025-12-23 13:15:05 +05:30
parent 8b820c6d8a
commit de09f1c501
1 changed files with 23 additions and 33 deletions
Download patch file Download diff file Expand all files Collapse all files

56
api/db/filters.py
View file

@ -107,11 +107,13 @@ def apply_workflow_run_filters(
):
codes = value.get("codes", [])
if codes:
# Use ->> operator for compatibility with all PostgreSQL versions
# (subscript [] only works in PostgreSQL 14+)
filter_conditions.append(
cast(WorkflowRunModel.gathered_context, JSONB)[
cast(WorkflowRunModel.gathered_context, JSONB)
.op("->>")(
"mapped_call_disposition"
]
.as_string()
)
.in_(codes)
)
@ -142,9 +144,12 @@ def apply_workflow_run_filters(
# Filter by phone number (contains search)
phone = value.get("value", "").strip()
if phone:
# Use ->> operator for compatibility with all PostgreSQL versions
filter_conditions.append(
cast(WorkflowRunModel.initial_context, JSONB)["phone"]
.as_string()
cast(WorkflowRunModel.initial_context, JSONB)
.op("->>")(
"phone"
)
.contains(phone)
)
@ -153,47 +158,32 @@ def apply_workflow_run_filters(
max_val = value.get("max")
if field == "usage_info.call_duration_seconds":
# Use ->> operator for compatibility with all PostgreSQL versions
# (subscript [] only works in PostgreSQL 14+)
duration_text = cast(WorkflowRunModel.usage_info, JSONB).op("->>")(
"call_duration_seconds"
)
if min_val is not None:
filter_conditions.append(
cast(
cast(WorkflowRunModel.usage_info, JSONB)[
"call_duration_seconds"
],
Integer,
)
>= min_val
cast(duration_text, Integer) >= min_val
)
if max_val is not None:
filter_conditions.append(
cast(
cast(WorkflowRunModel.usage_info, JSONB)[
"call_duration_seconds"
],
Integer,
)
<= max_val
cast(duration_text, Integer) <= max_val
)
elif field == "cost_info.total_cost_usd":
# Use ->> operator for compatibility with all PostgreSQL versions
cost_text = cast(WorkflowRunModel.cost_info, JSONB).op("->>")(
"total_cost_usd"
)
if min_val is not None:
filter_conditions.append(
cast(
cast(WorkflowRunModel.cost_info, JSONB)[
"total_cost_usd"
],
Integer,
)
>= min_val
cast(cost_text, Integer) >= min_val
)
if max_val is not None:
filter_conditions.append(
cast(
cast(WorkflowRunModel.cost_info, JSONB)[
"total_cost_usd"
],
Integer,
)
<= max_val
cast(cost_text, Integer) <= max_val
)
if filter_conditions: