feat(gemini): impl connector

camunda · Nov 26, 2024 · b0c1791 · b0c1791
1 parent 99ddaef
commit b0c1791
Show file tree

Hide file tree

Showing 34 changed files with 2,821 additions and 12 deletions.
diff --git a/bundle/default-bundle/pom.xml b/bundle/default-bundle/pom.xml
@@ -117,6 +117,10 @@
       <groupId>io.camunda.connector</groupId>
       <artifactId>connector-aws-comprehend</artifactId>
     </dependency>
+    <dependency>
+    <groupId>io.camunda.connector</groupId>
+    <artifactId>connector-google-gemini</artifactId>
+  </dependency>
   </dependencies>
 
   <build>

diff --git a/bundle/pom.xml b/bundle/pom.xml
@@ -159,6 +159,11 @@
         <artifactId>connector-aws-comprehend</artifactId>
         <version>${project.version}</version>
       </dependency>
+      <dependency>
+        <groupId>io.camunda.connector</groupId>
+        <artifactId>connector-google-gemini</artifactId>
+        <version>${project.version}</version>
+      </dependency>
     </dependencies>
   </dependencyManagement>
 

diff --git a/.../google-base/src/main/java/io/camunda/google/supplier/util/GoogleServiceSupplierUtil.java b/.../google-base/src/main/java/io/camunda/google/supplier/util/GoogleServiceSupplierUtil.java
@@ -24,24 +24,27 @@ public final class GoogleServiceSupplierUtil {
   private GoogleServiceSupplierUtil() {}
 
   public static HttpCredentialsAdapter getHttpHttpCredentialsAdapter(final Authentication auth) {
-    Credentials creds = null;
+    Credentials creds = getCredentials(auth);
     if (auth.authType() == AuthenticationType.BEARER) {
-      AccessToken accessToken = new AccessToken(auth.bearerToken(), null);
-      creds = new GoogleCredentials(accessToken).createScoped(DriveScopes.DRIVE);
-    }
-
-    if (auth.authType() == AuthenticationType.REFRESH) {
-      creds =
-          UserCredentials.newBuilder()
-              .setClientId(auth.oauthClientId())
-              .setClientSecret(auth.oauthClientSecret())
-              .setRefreshToken(auth.oauthRefreshToken())
-              .build();
+      creds = ((GoogleCredentials) creds).createScoped(DriveScopes.DRIVE);
     }
 
     return new HttpCredentialsAdapter(creds);
   }
 
+  public static Credentials getCredentials(Authentication auth) {
+    if (auth.authType() == AuthenticationType.BEARER) {
+      AccessToken accessToken = new AccessToken(auth.bearerToken(), null);
+      GoogleCredentials googleCredentials = new GoogleCredentials(accessToken);
+      return googleCredentials;
+    }
+    return UserCredentials.newBuilder()
+        .setClientId(auth.oauthClientId())
+        .setClientSecret(auth.oauthClientSecret())
+        .setRefreshToken(auth.oauthRefreshToken())
+        .build();
+  }
+
   public static NetHttpTransport getNetHttpTransport() {
     try {
       return GoogleNetHttpTransport.newTrustedTransport();