<!-- generated by tools/source-reference.py -->
backend/db.py
Postgres data layer (asyncpg) — local DB on the prod box.
| Symbol | Kind | Source |
|---|---|---|
_check_cols |
FunctionDef | L48 |
_init_conn |
AsyncFunctionDef | L54 |
_backfill_order_tenants |
AsyncFunctionDef | L66 |
heal_order_tenants |
AsyncFunctionDef | L98 |
init |
AsyncFunctionDef | L110 |
close |
AsyncFunctionDef | L128 |
_open_runtime_pool |
AsyncFunctionDef | L148 |
_fell_back_to_owner |
FunctionDef | L170 |
_open_control_pool |
AsyncFunctionDef | L182 |
rls_status |
AsyncFunctionDef | L198 |
control_pool |
FunctionDef | L218 |
scoped_tx |
FunctionDef | L227 |
scoped_tx._ScopedTx |
ClassDef | L242 |
scoped_tx._ScopedTx.__aenter__ |
AsyncFunctionDef | L243 |
scoped_tx._ScopedTx.__aexit__ |
AsyncFunctionDef | L257 |
get_pool |
FunctionDef | L269 |
now_iso |
FunctionDef | L276 |
_ser |
FunctionDef | L280 |
insert_message |
AsyncFunctionDef | L288 |
update_message |
AsyncFunctionDef | L298 |
get_messages |
AsyncFunctionDef | L307 |
message_by_wamid |
AsyncFunctionDef | L346 |
recent_messages_for_phone |
AsyncFunctionDef | L368 |
recent_messages |
AsyncFunctionDef | L384 |
get_message |
AsyncFunctionDef | L398 |
search |
AsyncFunctionDef | L405 |
search._clean |
FunctionDef | L417 |
find_call_transcript_by_sid |
AsyncFunctionDef | L430 |
get_pending |
AsyncFunctionDef | L451 |
profiles_map |
AsyncFunctionDef | L462 |
upsert_profile |
AsyncFunctionDef | L468 |
get_elevenlabs_enabled |
AsyncFunctionDef | L484 |
set_elevenlabs_enabled |
AsyncFunctionDef | L498 |
get_customer_settings |
AsyncFunctionDef | L506 |
set_auto_windows |
AsyncFunctionDef | L528 |
in_auto_window |
FunctionDef | L541 |
register_token |
AsyncFunctionDef | L563 |
get_tokens |
AsyncFunctionDef | L572 |
delete_token |
AsyncFunctionDef | L578 |
call_start |
AsyncFunctionDef | L597 |
call_update |
AsyncFunctionDef | L611 |
call_set_lines |
AsyncFunctionDef | L621 |
call_takeover |
AsyncFunctionDef | L629 |
call_end |
AsyncFunctionDef | L640 |
call_get |
AsyncFunctionDef | L648 |
call_active |
AsyncFunctionDef | L654 |
call_sweep_orphans |
AsyncFunctionDef | L663 |
_tenant_or_default |
FunctionDef | L700 |
order_insert |
AsyncFunctionDef | L707 |
order_get |
AsyncFunctionDef | L719 |
order_list |
AsyncFunctionDef | L730 |
orders_storefront |
AsyncFunctionDef | L771 |
order_set_status |
AsyncFunctionDef | L792 |
order_set_lines |
AsyncFunctionDef | L802 |
orders_for_dispatch |
AsyncFunctionDef | L810 |
orders_pending_review_count |
AsyncFunctionDef | L827 |
erp_code_set |
AsyncFunctionDef | L846 |
erp_code_get |
AsyncFunctionDef | L861 |
erp_codes_for |
AsyncFunctionDef | L869 |
orders_mark_sent |
AsyncFunctionDef | L886 |
order_set_value_snapshot |
AsyncFunctionDef | L897 |
order_count_since_dispatch |
AsyncFunctionDef | L909 |
settings_get |
AsyncFunctionDef | L925 |
settings_set |
AsyncFunctionDef | L931 |
subs_row |
AsyncFunctionDef | L942 |
subs_get_customer_id |
AsyncFunctionDef | L949 |
subs_set_customer_id |
AsyncFunctionDef | L955 |
subs_set_ecommerce_enabled |
AsyncFunctionDef | L966 |
demo_lead_insert |
AsyncFunctionDef | L992 |
demo_lead_update |
AsyncFunctionDef | L1008 |
demo_lead_get |
AsyncFunctionDef | L1020 |
demo_leads_count_since |
AsyncFunctionDef | L1026 |
demo_lead_count_for_phone |
AsyncFunctionDef | L1034 |