feat: kronos implementation

Author: mahatoankitkumar

Cargo.lock

@@ -100,6 +100,8 @@ tracing-actix-web = "0.7.21"
 url = "2.5.0"
 uuid = { version = "1.20.0", features = ["v4", "serde", "js"] }
 uniffi = { version = "0.29.3", features = ["cli"] }
+kronos-worker = { git = "https://github.com/juspay/kronos.git", rev = "b77d3a6a44dec158f7e83798d1c804e7ded8b15d" }
+kronos-common = { git = "https://github.com/juspay/kronos.git", rev = "b77d3a6a44dec158f7e83798d1c804e7ded8b15d" }
 superposition = { path = "crates/superposition", version = "0.114.0" }
 superposition_types = { path = "crates/superposition_types", version = "0.114.0" }
 superposition_derives = { path = "crates/superposition_derives", version = "0.114.0" }

Cargo.toml

@@ -839,6 +839,7 @@ pub async fn create_webhook(
     payload_version: PayloadVersion,
     custom_headers: CustomHeaders,
     events: Vec<WebhookEvent>,
+    max_retries: i32,
     change_reason: String,
     workspace: &str,
     org_id: &str,
@@ -852,6 +853,7 @@ pub async fn create_webhook(
         payload_version: Some(payload_version),
         custom_headers: Some(custom_headers),
         events,
+        max_retries: Some(max_retries),
         change_reason: ChangeReason::try_from(change_reason)?,
     };
     let host = use_host_server();

crates/frontend/src/api.rs

@@ -43,6 +43,7 @@ fn try_update_payload(
     payload_version: PayloadVersion,
     custom_headers: CustomHeaders,
     events: Vec<WebhookEvent>,
+    max_retries: i32,
     description: String,
     change_reason: String,
 ) -> Result<UpdateWebhookRequest, String> {
@@ -53,6 +54,7 @@ fn try_update_payload(
         payload_version: Some(payload_version),
         custom_headers: Some(custom_headers),
         events: Some(events),
+        max_retries: Some(max_retries),
         description: Some(Description::try_from(description)?),
         change_reason: ChangeReason::try_from(change_reason)?,
     })
@@ -69,6 +71,7 @@ pub fn WebhookForm(
     #[prop(default = PayloadVersion::default())] payload_version: PayloadVersion,
     #[prop(default = CustomHeaders::default())] custom_headers: CustomHeaders,
     #[prop(default = Vec::new())] events: Vec<WebhookEvent>,
+    #[prop(default = 3)] max_retries: i32,
     #[prop(into)] handle_submit: Callback<()>,
 ) -> impl IntoView {
     let workspace = use_context::<Signal<Workspace>>().unwrap();
@@ -83,6 +86,7 @@ pub fn WebhookForm(
     let (custom_headers_rs, custom_headers_ws) = create_signal(custom_headers);
     let (change_reason_rs, change_reason_ws) = create_signal(String::new());
     let (events_rs, events_ws) = create_signal(events);
+    let (max_retries_rs, max_retries_ws) = create_signal(max_retries);
     let (req_inprogess_rs, req_inprogress_ws) = create_signal(false);
     let update_request_rws = RwSignal::new(None);
 
@@ -108,6 +112,7 @@ pub fn WebhookForm(
         let custom_headers = custom_headers_rs.get_untracked();
         let change_reason = change_reason_rs.get_untracked();
         let events = events_rs.get_untracked();
+        let max_retries = max_retries_rs.get_untracked();
         let workspace = workspace.get_untracked().0;
         let org_id = org.get_untracked().0;
 
@@ -132,6 +137,7 @@ pub fn WebhookForm(
                             payload_version,
                             custom_headers,
                             events,
+                            max_retries,
                             description,
                             change_reason,
                         );
@@ -152,6 +158,7 @@ pub fn WebhookForm(
                         payload_version,
                         custom_headers,
                         events,
+                        max_retries,
                         change_reason,
                         &workspace,
                         &org_id,
@@ -295,6 +302,22 @@ pub fn WebhookForm(
                 />
             </div>
 
+            <div class="form-control">
+                <Label title="Max Retries" description="Number of retry attempts on failure." />
+                <Input
+                    placeholder="Max Retries"
+                    class="input input-bordered w-full max-w-md"
+                    value=Value::Number(serde_json::Number::from(max_retries_rs.get_untracked()))
+                    schema_type=Single(JsonSchemaType::Integer)
+                    r#type=InputType::Integer
+                    on_change=Callback::new(move |value: Value| {
+                        if let Some(n) = value.as_i64().and_then(|n| i32::try_from(n).ok()) {
+                            max_retries_ws.set(n);
+                        }
+                    })
+                />
+            </div>
+
             <div class="form-control gap-3">
                 <Label
                     title="Custom Headers"

crates/frontend/src/components/webhook_form.rs

@@ -219,6 +219,7 @@ pub fn Webhook() -> impl IntoView {
                                         custom_headers=webhook_st
                                             .with_value(|w| w.custom_headers.clone())
                                         events=webhook_st.with_value(|w| w.events.clone())
+                                        max_retries=webhook_st.with_value(|w| w.max_retries)
                                         handle_submit=move |_| {
                                             webhook_resource.refetch();
                                             action_rws.set(Action::None);

crates/frontend/src/pages/webhook.rs

@@ -34,6 +34,8 @@ opentelemetry-instrumentation-actix-web = { workspace = true }
 prometheus = { workspace = true }
 rand = "0.8"
 tokio = { workspace = true }
+kronos-worker = { workspace = true }
+kronos-common = { workspace = true }
 tracing = { workspace = true }
 regex = { workspace = true }
 reqwest = { workspace = true }