Added API n ConflictException

Author: Shailesh Jagannath Padave

conductor-client/src/main/java/com/netflix/conductor/client/http/IncomingWebhookClient.java

@@ -0,0 +1,97 @@
+/*
+ * Copyright 2020 Conductor Authors.
+ * <p>
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ * <p>
+ * http://www.apache.org/licenses/LICENSE-2.0
+ * <p>
+ * Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on
+ * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations under the License.
+ */
+package com.netflix.conductor.client.http;
+
+import java.util.Map;
+
+import org.apache.commons.lang3.Validate;
+
+import com.netflix.conductor.client.http.ConductorClientRequest.Method;
+
+import com.fasterxml.jackson.core.type.TypeReference;
+
+/**
+ * Client for incoming webhook operations in Conductor
+ */
+public final class IncomingWebhookClient {
+
+    private ConductorClient client;
+
+    /** Creates a default incoming webhook client */
+    public IncomingWebhookClient() {
+    }
+
+    public IncomingWebhookClient(ConductorClient client) {
+        this.client = client;
+    }
+
+    /**
+     * Kept only for backwards compatibility
+     *
+     * @param rootUri basePath for the ApiClient
+     */
+    @Deprecated
+    public void setRootURI(String rootUri) {
+        if (client != null) {
+            client.shutdown();
+        }
+        client = new ConductorClient(rootUri);
+    }
+
+    /**
+     * Handle incoming webhook with POST method
+     *
+     * @param id           The webhook ID
+     * @param payload      The webhook payload as string
+     * @return The response from the webhook handler
+     */
+    public String handleWebhook(String id, String payload) {
+        Validate.notBlank(id, "Webhook ID cannot be blank");
+        Validate.notNull(payload, "Payload cannot be null");
+
+        ConductorClientRequest.Builder requestBuilder = ConductorClientRequest.builder()
+                .method(Method.POST)
+                .path("/webhook/{id}")
+                .addPathParam("id", id)
+                .body(payload);
+
+        ConductorClientRequest request = requestBuilder.build();
+
+        ConductorClientResponse<String> resp = client.execute(request, new TypeReference<>() {
+        });
+
+        return resp.getData();
+    }
+
+    /**
+     * Handle incoming webhook with GET method (typically for ping/health checks)
+     *
+     * @param id           The webhook ID
+     * @return The response from the webhook handler
+     */
+    public String handlePing(String id) {
+        Validate.notBlank(id, "Webhook ID cannot be blank");
+
+        ConductorClientRequest.Builder requestBuilder = ConductorClientRequest.builder()
+                .method(Method.GET)
+                .path("/webhook/{id}")
+                .addPathParam("id", id);
+
+        ConductorClientRequest request = requestBuilder.build();
+
+        ConductorClientResponse<String> resp = client.execute(request, new TypeReference<>() {
+        });
+
+        return resp.getData();
+    }
+}

orkes-client/src/main/java/io/orkes/conductor/client/OrkesClientException.java

@@ -0,0 +1,34 @@
+/*
+ * Copyright 2022 Orkes, Inc.
+ * <p>
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ * <p>
+ * http://www.apache.org/licenses/LICENSE-2.0
+ * <p>
+ * Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on
+ * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations under the License.
+ */
+package io.orkes.conductor.client;
+
+import com.netflix.conductor.client.exception.ConductorClientException;
+
+public class OrkesClientException extends ConductorClientException {
+
+    public OrkesClientException() {
+        super("Orkes client error");
+    }
+
+    public OrkesClientException(String message) {
+        super(message);
+    }
+
+    public OrkesClientException(String message, Throwable cause) {
+        super(message, cause);
+    }
+
+    public OrkesClientException(int status, String message) {
+        super(status, message);
+    }
+}

orkes-client/src/main/java/io/orkes/conductor/client/http/ConflictException.java

@@ -0,0 +1,68 @@
+/*
+ * Copyright 2022 Orkes, Inc.
+ * <p>
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ * <p>
+ * http://www.apache.org/licenses/LICENSE-2.0
+ * <p>
+ * Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on
+ * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations under the License.
+ */
+package io.orkes.conductor.client.http;
+
+import io.orkes.conductor.client.OrkesClientException;
+import org.apache.commons.lang3.StringUtils;
+
+import java.util.List;
+import java.util.Map;
+
+public class ConflictException extends OrkesClientException {
+    private int code;
+    private final Map<String, List<String>> responseHeaders;
+    private String responseBody;
+    private String message;
+
+    public ConflictException(String message, Throwable throwable, int code, Map<String, List<String>> responseHeaders, String responseBody) {
+        super(message, throwable);
+        super.setCode(String.valueOf(code));
+        super.setStatus(code);
+        this.code = code;
+        this.responseHeaders = responseHeaders;
+        this.responseBody = responseBody;
+        this.message = message;
+    }
+
+    public ConflictException(String message, int code, Map<String, List<String>> responseHeaders, String responseBody) {
+        this(message, null, code, responseHeaders, responseBody);
+        super.setCode(String.valueOf(code));
+        super.setStatus(code);
+        this.code = code;
+        this.message = message;
+        this.responseBody = responseBody;
+    }
+
+    public int getStatusCode() {
+        return this.code;
+    }
+
+    public Map<String, List<String>> getResponseHeaders() {
+        return this.responseHeaders;
+    }
+
+    @Override
+    public String getMessage() {
+        int statusCode = this.getStatusCode();
+        return statusCode + ":" + (StringUtils.isBlank(this.responseBody) ? super.getMessage() : this.responseBody);
+    }
+
+    @Override
+    public String toString() {
+        return this.responseBody;
+    }
+
+    public boolean isClientError() {
+        return this.code > 399 && this.code < 499;
+    }
+}