-
Notifications
You must be signed in to change notification settings - Fork 1.4k
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge branch 'main' of github.com:juspay/hyperswitch into env_split
* 'main' of github.com:juspay/hyperswitch: fix(connector): [Stripe] Deserialization Error while parsing Dispute Webhook Body (#3256) refactor(euclid_wasm): Update wasm config (#3222) fix(analytics): added response to the connector outgoing event (#3129) fix(analytics): fixed response code to 501 (#3119) fix(connector): [NMI] Populating `ErrorResponse` with required fields and Mapping `connector_response_reference_id` (#3214) feat(merchant_account): Add list multiple merchants in `MerchantAccountInterface` (#3220) feat: include version number in response headers and on application startup (#3045) chore: address Rust 1.75 clippy lints (#3231) feat: add deep health check (#3210) feat(analytics): adding outgoing webhooks kafka event (#3140) refactor: address panics due to indexing and slicing (#3233) fix(users): Fix wrong redirection url in magic link (#3217) fix(user): add integration_completed enum in metadata type (#3245) chore(version): v1.106.1 fix(connector): [iatapay] change refund amount (#3244) chore(version): v1.106.0 test(postman): update postman collection files fix(core): fix recurring mandates flow for cyber source (#3224) chore: fix channel handling for consumer workflow loop (#3223)
- Loading branch information
Showing
117 changed files
with
7,639 additions
and
1,759 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.
Oops, something went wrong.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
97 changes: 97 additions & 0 deletions
97
crates/analytics/docs/clickhouse/scripts/connector_events.sql
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,97 @@ | ||
| CREATE TABLE connector_events_queue ( | ||
| `merchant_id` String, | ||
| `payment_id` Nullable(String), | ||
| `connector_name` LowCardinality(String), | ||
| `request_id` String, | ||
| `flow` LowCardinality(String), | ||
| `request` String, | ||
| `response` Nullable(String), | ||
| `error` Nullable(String), | ||
| `status_code` UInt32, | ||
| `created_at` DateTime64(3), | ||
| `latency` UInt128, | ||
| `method` LowCardinality(String) | ||
| ) ENGINE = Kafka SETTINGS kafka_broker_list = 'kafka0:29092', | ||
| kafka_topic_list = 'hyperswitch-connector-api-events', | ||
| kafka_group_name = 'hyper-c1', | ||
| kafka_format = 'JSONEachRow', | ||
| kafka_handle_error_mode = 'stream'; | ||
|
|
||
|
|
||
| CREATE TABLE connector_events_dist ( | ||
| `merchant_id` String, | ||
| `payment_id` Nullable(String), | ||
| `connector_name` LowCardinality(String), | ||
| `request_id` String, | ||
| `flow` LowCardinality(String), | ||
| `request` String, | ||
| `response` Nullable(String), | ||
| `error` Nullable(String), | ||
| `status_code` UInt32, | ||
| `created_at` DateTime64(3), | ||
| `inserted_at` DateTime64(3), | ||
| `latency` UInt128, | ||
| `method` LowCardinality(String), | ||
| INDEX flowIndex flowTYPE bloom_filter GRANULARITY 1, | ||
| INDEX connectorIndex connector_name TYPE bloom_filter GRANULARITY 1, | ||
| INDEX statusIndex status_code TYPE bloom_filter GRANULARITY 1 | ||
| ) ENGINE = MergeTree | ||
| PARTITION BY toStartOfDay(created_at) | ||
| ORDER BY | ||
| (created_at, merchant_id, flow_type, status_code, api_flow) | ||
| TTL created_at + toIntervalMonth(6) | ||
| ; | ||
|
|
||
| CREATE MATERIALIZED VIEW connector_events_mv TO connector_events_dist ( | ||
| `merchant_id` String, | ||
| `payment_id` Nullable(String), | ||
| `connector_name` LowCardinality(String), | ||
| `request_id` String, | ||
| `flow` LowCardinality(String), | ||
| `request` String, | ||
| `response` Nullable(String), | ||
| `error` Nullable(String), | ||
| `status_code` UInt32, | ||
| `created_at` DateTime64(3), | ||
| `latency` UInt128, | ||
| `method` LowCardinality(String) | ||
| ) AS | ||
| SELECT | ||
| merchant_id, | ||
| payment_id, | ||
| connector_name, | ||
| request_id, | ||
| flow, | ||
| request, | ||
| response, | ||
| error, | ||
| status_code, | ||
| created_at, | ||
| now() as inserted_at, | ||
| latency, | ||
| method, | ||
| FROM | ||
| connector_events_queue | ||
| where length(_error) = 0; | ||
|
|
||
|
|
||
| CREATE MATERIALIZED VIEW connector_events_parse_errors | ||
| ( | ||
| `topic` String, | ||
| `partition` Int64, | ||
| `offset` Int64, | ||
| `raw` String, | ||
| `error` String | ||
| ) | ||
| ENGINE = MergeTree | ||
| ORDER BY (topic, partition, offset) | ||
| SETTINGS index_granularity = 8192 AS | ||
| SELECT | ||
| _topic AS topic, | ||
| _partition AS partition, | ||
| _offset AS offset, | ||
| _raw_message AS raw, | ||
| _error AS error | ||
| FROM connector_events_queue | ||
| WHERE length(_error) > 0 | ||
| ; |
Oops, something went wrong.