Restore Pipedream client files

Author: jverce

.fernignore

@@ -14,6 +14,10 @@ src/main/java/com/pipedream/api/AsyncBaseClientBuilder.java
 src/main/java/com/pipedream/api/BaseClientBuilder.java
 
 # Custom Pipedream client files
+src/main/java/com/pipedream/api/AsyncPipedreamClient.java
+src/main/java/com/pipedream/api/AsyncPipedreamClientBuilder.java
+src/main/java/com/pipedream/api/PipedreamClient.java
+src/main/java/com/pipedream/api/PipedreamClientBuilder.java
 
 # Custom Proxy files
 

src/main/java/com/pipedream/api/AsyncPipedreamClient.java

@@ -0,0 +1,44 @@
+package com.pipedream.api;
+
+import com.pipedream.api.core.ClientOptions;
+import com.pipedream.api.core.Environment;
+import com.pipedream.api.core.Suppliers;
+import com.pipedream.api.resources.workflows.WorkflowsClient;
+import java.util.Optional;
+import java.util.function.Supplier;
+
+public class AsyncPipedreamClient extends AsyncBaseClient {
+    private final Supplier<WorkflowsClient> workflowsClient;
+
+    public AsyncPipedreamClient(final ClientOptions clientOptions) {
+        super(clientOptions);
+        this.workflowsClient = Suppliers.memoize(() -> new WorkflowsClient(clientOptions));
+    }
+
+    public static AsyncPipedreamClientBuilder builder() {
+        return new AsyncPipedreamClientBuilder()
+                .clientId(System.getenv("PIPEDREAM_CLIENT_ID"))
+                .clientSecret(System.getenv("PIPEDREAM_CLIENT_SECRET"))
+                .environment(Environment.PROD)
+                .projectEnvironment(System.getenv("PIPEDREAM_PROJECT_ENVIRONMENT"))
+                .projectId(System.getenv("PIPEDREAM_PROJECT_ID"));
+    }
+
+    /**
+     * Returns an access token that can be used to authenticate API requests
+     *
+     * @return the access token string (if available)
+     */
+    public Optional<String> rawAccessToken() {
+        final String authorizationHeader = this.clientOptions.headers(null).get("Authorization");
+
+        // The header might not be defined, so we wrap it as an Optional to
+        // further process it. The processing consists of removing the `Bearer`
+        // or `Basic` prefix from the header value.
+        return Optional.ofNullable(authorizationHeader).map(h -> h.replaceFirst("^.*?\\s+", ""));
+    }
+
+    public WorkflowsClient workflows() {
+        return this.workflowsClient.get();
+    }
+}

src/main/java/com/pipedream/api/AsyncPipedreamClientBuilder.java

@@ -0,0 +1,40 @@
+package com.pipedream.api;
+
+import com.pipedream.api.core.ClientOptions;
+import com.pipedream.api.core.Environment;
+import org.apache.commons.text.StringSubstitutor;
+import org.apache.commons.text.lookup.StringLookupFactory;
+
+/**
+ * Builder for creating AsyncPipedreamClient instances.
+ */
+public final class AsyncPipedreamClientBuilder extends AsyncBaseClientBuilder<AsyncPipedreamClientBuilder> {
+    private String projectId;
+
+    public AsyncPipedreamClient build() {
+        return new AsyncPipedreamClient(buildClientOptions());
+    }
+
+    public AsyncPipedreamClientBuilder environment(final Environment environment) {
+        final String patchedUrl = patchUrl(environment.getUrl());
+        final Environment withPatchedUrl = Environment.custom(patchedUrl);
+        super.environment(withPatchedUrl);
+        return this;
+    }
+
+    public AsyncPipedreamClientBuilder projectId(final String projectId) {
+        this.projectId = projectId;
+        return this;
+    }
+
+    @Override
+    public void setVariables(ClientOptions.Builder builder) {
+        builder.projectId(this.projectId);
+    }
+
+    private static String patchUrl(final String templateUrl) {
+        StringSubstitutor sub = new StringSubstitutor(StringLookupFactory.INSTANCE.environmentVariableStringLookup());
+
+        return sub.replace(templateUrl);
+    }
+}

src/main/java/com/pipedream/api/PipedreamClient.java

@@ -0,0 +1,44 @@
+package com.pipedream.api;
+
+import com.pipedream.api.core.ClientOptions;
+import com.pipedream.api.core.Environment;
+import com.pipedream.api.core.Suppliers;
+import com.pipedream.api.resources.workflows.WorkflowsClient;
+import java.util.Optional;
+import java.util.function.Supplier;
+
+public class PipedreamClient extends BaseClient {
+    private final Supplier<WorkflowsClient> workflowsClient;
+
+    public PipedreamClient(final ClientOptions clientOptions) {
+        super(clientOptions);
+        this.workflowsClient = Suppliers.memoize(() -> new WorkflowsClient(clientOptions));
+    }
+
+    public static PipedreamClientBuilder builder() {
+        return new PipedreamClientBuilder()
+                .clientId(System.getenv("PIPEDREAM_CLIENT_ID"))
+                .clientSecret(System.getenv("PIPEDREAM_CLIENT_SECRET"))
+                .environment(Environment.PROD)
+                .projectEnvironment(System.getenv("PIPEDREAM_PROJECT_ENVIRONMENT"))
+                .projectId(System.getenv("PIPEDREAM_PROJECT_ID"));
+    }
+
+    /**
+     * Returns an access token that can be used to authenticate API requests
+     *
+     * @return the access token string (if available)
+     */
+    public Optional<String> rawAccessToken() {
+        final String authorizationHeader = this.clientOptions.headers(null).get("Authorization");
+
+        // The header might not be defined, so we wrap it as an Optional to
+        // further process it. The processing consists of removing the `Bearer`
+        // or `Basic` prefix from the header value.
+        return Optional.ofNullable(authorizationHeader).map(h -> h.replaceFirst("^.*?\\s+", ""));
+    }
+
+    public WorkflowsClient workflows() {
+        return this.workflowsClient.get();
+    }
+}

src/main/java/com/pipedream/api/PipedreamClientBuilder.java

@@ -0,0 +1,40 @@
+package com.pipedream.api;
+
+import com.pipedream.api.core.ClientOptions;
+import com.pipedream.api.core.Environment;
+import org.apache.commons.text.StringSubstitutor;
+import org.apache.commons.text.lookup.StringLookupFactory;
+
+/**
+ * Builder for creating PipedreamClient instances.
+ */
+public final class PipedreamClientBuilder extends BaseClientBuilder<PipedreamClientBuilder> {
+    private String projectId;
+
+    public PipedreamClient build() {
+        return new PipedreamClient(buildClientOptions());
+    }
+
+    public PipedreamClientBuilder environment(final Environment environment) {
+        final String patchedUrl = patchUrl(environment.getUrl());
+        final Environment withPatchedUrl = Environment.custom(patchedUrl);
+        super.environment(withPatchedUrl);
+        return this;
+    }
+
+    public PipedreamClientBuilder projectId(final String projectId) {
+        this.projectId = projectId;
+        return this;
+    }
+
+    @Override
+    public void setVariables(ClientOptions.Builder builder) {
+        builder.projectId(this.projectId);
+    }
+
+    private static String patchUrl(final String templateUrl) {
+        StringSubstitutor sub = new StringSubstitutor(StringLookupFactory.INSTANCE.environmentVariableStringLookup());
+
+        return sub.replace(templateUrl);
+    }
+}