InitSettings

Author: alexanderkirtzel

packages/server/destinations/gcp/src/bigquery/push.ts

@@ -4,10 +4,16 @@ import { isObject, isArray } from '@walkeros/core';
 
 export const push: PushFn = async function (
   event,
-  { config, mapping: _mapping, data, collector, env },
+  { config, mapping: _mapping, data },
 ) {
   const { client, datasetId, tableId } = config.settings!;
 
+  if (!client || !datasetId || !tableId) {
+    throw new Error(
+      'Missing required BigQuery configuration. Ensure init() was called successfully.',
+    );
+  }
+
   let row: WalkerOS.AnyObject | undefined;
 
   if (isObject(data)) {

packages/server/destinations/gcp/src/bigquery/types/index.ts

@@ -14,7 +14,14 @@ export interface Settings {
   bigquery?: BigQueryOptions;
 }
 
-export type InitSettings = Partial<Settings>;
+export interface InitSettings {
+  projectId: string;
+  client?: BigQuery;
+  datasetId?: string;
+  tableId?: string;
+  location?: string;
+  bigquery?: BigQueryOptions;
+}
 
 export interface Mapping {}