syncing up to 6055abef14b2a67c957cd13c5bd552cd4d663a77

Co-authored-by: Joey Greco <[email protected]>
superblocksteam · Dec 9, 2024 · d21a094 · d21a094
1 parent 62da69f
commit d21a094
Show file tree

Hide file tree

Showing 15 changed files with 839 additions and 513 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -14,6 +14,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 - Allow branch name to be given in workflow HTTP requests as a header: `X-Superblocks-Branch` 
 - Add `last_updated` field to the `Resource` proto, and set last updated time in update signature requests to server
 - Fixed projection for findOne action in MongoDB integration
+- Added support for creating a worksheet in GSheets integration
 
 ## v1.16.0
 

diff --git a/internal/registration/registration.go b/internal/registration/registration.go
@@ -31,7 +31,7 @@ var SUPERBLOCKS_PLUGIN_VERSIONS = map[string][]string{
 	"email":              {"0.0.7"},
 	"gcs":                {"0.0.1"},
 	"graphql":            {"0.0.10"},
-	"gsheets":            {"0.0.18"},
+	"gsheets":            {"0.0.19"},
 	"kafka":              {"0.0.1"},
 	"javascript":         {"0.0.9"},
 	"kinesis":            {"0.0.1"},

diff --git a/internal/registration/registration_test.go b/internal/registration/registration_test.go
@@ -68,5 +68,5 @@ func TestRegistrationRequest(t *testing.T) {
 	assert.Equal(t, "https://foo.bar.com/api/v1/agents/register", request.URL.String())
 	assert.Equal(t, http.MethodPost, request.Method)
 	assert.Equal(t, expectedRequestHeaders, request.Header)
-	assert.Equal(t, "{\"pluginVersions\":{\"athena\":[\"0.0.1\"],\"bigquery\":[\"0.0.7\"],\"cockroachdb\":[\"0.0.2\"],\"confluent\":[\"0.0.1\"],\"cosmosdb\":[\"0.0.1\"],\"couchbase\":[\"0.0.1\"],\"databricks\":[\"0.0.2\"],\"dynamodb\":[\"0.0.7\"],\"email\":[\"0.0.7\"],\"gcs\":[\"0.0.1\"],\"graphql\":[\"0.0.10\"],\"gsheets\":[\"0.0.18\"],\"javascript\":[\"0.0.9\"],\"kafka\":[\"0.0.1\"],\"kinesis\":[\"0.0.1\"],\"mariadb\":[\"0.0.11\"],\"mongodb\":[\"0.0.7\"],\"mssql\":[\"0.0.10\"],\"mysql\":[\"0.0.11\"],\"openai\":[\"0.0.3\"],\"oracledb\":[\"0.0.1\"],\"postgres\":[\"0.0.11\"],\"python\":[\"0.0.7\"],\"redis\":[\"0.0.1\"],\"redpanda\":[\"0.0.1\"],\"redshift\":[\"0.0.7\"],\"restapi\":[\"0.0.13\"],\"restapiintegration\":[\"0.0.14\"],\"rockset\":[\"0.0.7\"],\"s3\":[\"0.0.11\"],\"salesforce\":[\"0.0.1\"],\"smtp\":[\"0.0.1\"],\"snowflake\":[\"0.0.8\"],\"superblocks-ocr\":[\"0.0.1\"],\"workflow\":[\"0.0.4\"]},\"type\":2,\"tags\":{\"foo\":[\"bar\"]},\"signingKeyId\":\"123\",\"verificationKeyIds\":[\"123\"],\"verificationKeys\":{\"123\":{\"algorithm\":\"ALGORITHM_RSA\",\"key\":\"key1\"}}}\n", string(body))
+	assert.Equal(t, "{\"pluginVersions\":{\"athena\":[\"0.0.1\"],\"bigquery\":[\"0.0.7\"],\"cockroachdb\":[\"0.0.2\"],\"confluent\":[\"0.0.1\"],\"cosmosdb\":[\"0.0.1\"],\"couchbase\":[\"0.0.1\"],\"databricks\":[\"0.0.2\"],\"dynamodb\":[\"0.0.7\"],\"email\":[\"0.0.7\"],\"gcs\":[\"0.0.1\"],\"graphql\":[\"0.0.10\"],\"gsheets\":[\"0.0.19\"],\"javascript\":[\"0.0.9\"],\"kafka\":[\"0.0.1\"],\"kinesis\":[\"0.0.1\"],\"mariadb\":[\"0.0.11\"],\"mongodb\":[\"0.0.7\"],\"mssql\":[\"0.0.10\"],\"mysql\":[\"0.0.11\"],\"openai\":[\"0.0.3\"],\"oracledb\":[\"0.0.1\"],\"postgres\":[\"0.0.11\"],\"python\":[\"0.0.7\"],\"redis\":[\"0.0.1\"],\"redpanda\":[\"0.0.1\"],\"redshift\":[\"0.0.7\"],\"restapi\":[\"0.0.13\"],\"restapiintegration\":[\"0.0.14\"],\"rockset\":[\"0.0.7\"],\"s3\":[\"0.0.11\"],\"salesforce\":[\"0.0.1\"],\"smtp\":[\"0.0.1\"],\"snowflake\":[\"0.0.8\"],\"superblocks-ocr\":[\"0.0.1\"],\"workflow\":[\"0.0.4\"]},\"type\":2,\"tags\":{\"foo\":[\"bar\"]},\"signingKeyId\":\"123\",\"verificationKeyIds\":[\"123\"],\"verificationKeys\":{\"123\":{\"algorithm\":\"ALGORITHM_RSA\",\"key\":\"key1\"}}}\n", string(body))
 }
diff --git a/types/api/api/v1/service.swagger.json b/types/api/api/v1/service.swagger.json
@@ -1524,6 +1524,20 @@
       },
       "title": "You can specify multiple values for a single query parameter in a URL"
     },
+    "PluginAddSheet": {
+      "type": "object",
+      "properties": {
+        "sheetTitle": {
+          "type": "string"
+        },
+        "rowCount": {
+          "type": "string"
+        },
+        "columnCount": {
+          "type": "string"
+        }
+      }
+    },
     "PluginAdlsConnection": {
       "type": "object",
       "properties": {
@@ -3708,6 +3722,9 @@
         },
         "superblocksMetadata": {
           "$ref": "#/definitions/pluginsgsheetsv1SuperblocksMetadata"
+        },
+        "addSheet": {
+          "$ref": "#/definitions/PluginAddSheet"
         }
       }
     },

diff --git a/types/gen/go/plugins/gsheets/v1/plugin.pb.go b/types/gen/go/plugins/gsheets/v1/plugin.pb.go
diff --git a/types/gen/go/plugins/gsheets/v1/plugin.pb.validate.go b/types/gen/go/plugins/gsheets/v1/plugin.pb.validate.go
diff --git a/types/gen/js/plugins/gsheets/v1/plugin_pb.d.ts b/types/gen/js/plugins/gsheets/v1/plugin_pb.d.ts
@@ -29,7 +29,10 @@ export namespace SuperblocksMetadata {
 export class Plugin extends jspb.Message { 
     getSpreadsheetid(): string;
     setSpreadsheetid(value: string): Plugin;
-    getSheettitle(): string;
+
+    hasSheettitle(): boolean;
+    clearSheettitle(): void;
+    getSheettitle(): string | undefined;
     setSheettitle(value: string): Plugin;
 
     hasRange(): boolean;
@@ -83,6 +86,11 @@ export class Plugin extends jspb.Message {
     getSuperblocksmetadata(): SuperblocksMetadata | undefined;
     setSuperblocksmetadata(value?: SuperblocksMetadata): Plugin;
 
+    hasAddsheet(): boolean;
+    clearAddsheet(): void;
+    getAddsheet(): Plugin.AddSheet | undefined;
+    setAddsheet(value?: Plugin.AddSheet): Plugin;
+
     serializeBinary(): Uint8Array;
     toObject(includeInstance?: boolean): Plugin.AsObject;
     static toObject(includeInstance: boolean, msg: Plugin): Plugin.AsObject;
@@ -96,7 +104,7 @@ export class Plugin extends jspb.Message {
 export namespace Plugin {
     export type AsObject = {
         spreadsheetid: string,
-        sheettitle: string,
+        sheettitle?: string,
         range?: string,
         rownumber?: string,
         extractfirstrowheader: boolean,
@@ -109,5 +117,40 @@ export namespace Plugin {
         writetodestinationtype?: string,
         body?: string,
         superblocksmetadata?: SuperblocksMetadata.AsObject,
+        addsheet?: Plugin.AddSheet.AsObject,
+    }
+
+
+    export class AddSheet extends jspb.Message { 
+        getSheettitle(): string;
+        setSheettitle(value: string): AddSheet;
+
+        hasRowcount(): boolean;
+        clearRowcount(): void;
+        getRowcount(): string | undefined;
+        setRowcount(value: string): AddSheet;
+
+        hasColumncount(): boolean;
+        clearColumncount(): void;
+        getColumncount(): string | undefined;
+        setColumncount(value: string): AddSheet;
+
+        serializeBinary(): Uint8Array;
+        toObject(includeInstance?: boolean): AddSheet.AsObject;
+        static toObject(includeInstance: boolean, msg: AddSheet): AddSheet.AsObject;
+        static extensions: {[key: number]: jspb.ExtensionFieldInfo<jspb.Message>};
+        static extensionsBinary: {[key: number]: jspb.ExtensionFieldBinaryInfo<jspb.Message>};
+        static serializeBinaryToWriter(message: AddSheet, writer: jspb.BinaryWriter): void;
+        static deserializeBinary(bytes: Uint8Array): AddSheet;
+        static deserializeBinaryFromReader(message: AddSheet, reader: jspb.BinaryReader): AddSheet;
+    }
+
+    export namespace AddSheet {
+        export type AsObject = {
+            sheettitle: string,
+            rowcount?: string,
+            columncount?: string,
+        }
     }
+
 }