Source: factory.web/WebHooks.py
| Method | Signature | Description |
|---|---|---|
| set_bloom_guid | set_bloom_guid(guid: str) -> None |
|
| set_kafka | set_kafka(kafka) -> None |
|
| set_token | set_token(token) -> None |
|
| set_token_group | set_token_group(token_group: str) -> None |
|
| patch_param | patch_param(altquery: str, depth: int = 0) -> str |
|
| bloom_table_data | bloom_table_data(table_base: str = '', unpack_payload: bool = True) -> None |
Build table will take a set of dictionary and lists and turn them in a |
| clean | clean() -> None |
|
| Read | Read(webhook_code: str, build_yaml = '') -> None |
|
| create_guid | create_guid() -> str |
|
| bloom_payload | bloom_payload(bloom_guid: str = '', payload_type: str = '') -> None |
|
| get_hash | get_hash(guid: str, range: int = 100) -> int |
|
| stage_reflection | stage_reflection(mirror_code: str, mirror_delay: int, rdg: int, payload_type: str, lookup_sql: str = '', mirror_mode: str = '', mirror_remote: str = '', mirror_table: str = '') -> None |
|
| commit | commit(external_guid: str = '') -> None |
|
| fire_factory | fire_factory(Type, webhook_code = '', Payload = '', Param1 = '', Param2 = '', Param3 = '', Param4 = '', Param5 = '') |
|
| fire_workflow | fire_workflow() |
|
| GetParameters | GetParameters() |
|
| get_alt_parameters | get_alt_parameters() |
|
| set_parameter | set_parameter(Param: str, Value: Any) -> None |
Set a webhook parameter value. |
| set_payload | set_payload(value: str, payload_type: str = '', external_guid: str = '') -> None |
|
| Create | Create(WebhookCode) |
|
| Transform | Transform() |
|
| Update | Update() |
|
| RenderResult | RenderResult(noreturn: int = 0) -> tuple[JsonDict | str, int] |
Render final webhook result with validation. |
Batch processing for webhooks.
| Method | Signature | Description |
|---|---|---|
| Reset | Reset() -> None |
Reset webhook set state. |
| ProcessSet | ProcessSet(webhook: str, batch: JsonDict) -> None |
Process a batch of webhooks using thread pool. |
| ReadSet | ReadSet(webhook: str) -> None |
Read and process a batch set of webhook records. |
| Transform | Transform() -> None |
Transform all items in the webhook set. |
| Method | Signature | Description |
|---|---|---|
| setUp | setUp() |
|
| run_test | run_test() |
|
| test_payload_case1 | test_payload_case1() |
Fast JSON encoding using orjson when available (2-3x faster).
Process webhook for a subset of GUIDs concurrently.