gaarf-js: added debug logging for raw objects from API response via env var GAARF_DUMP_API_ROW, GAARF_DUMP_ROW

version updated to 3.1.1

Change-Id: I8d317ee86035ab5f751a87badc64dd1aac9acdea

Author: evil-shrike

js/CHANGELOG.md

@@ -1,5 +1,10 @@
 # Changelog
 
+## 3.1.1 - 2025-04-17
+
+- Fix: added `override:true` while importing user functions into mathjs
+- added debug logging for raw objects from API response via env var GAARF_DUMP_API_ROW
+
 ## 3.1.0 - 2025-04-08
 
 - support Google Ads API v19 (updated google-ads-api to v19)

js/dist/cli.js

@@ -1,6 +1,6 @@
 {
   "name": "google-ads-api-report-fetcher",
-  "version": "3.1.0",
+  "version": "3.1.1",
   "description": "Google Ads API Report Fetcher (gaarf)",
   "main": "./dist/index.js",
   "types": "./src/index.ts",
@@ -22,6 +22,7 @@
   "scripts": {
     "clean": "shx rm -rf dist/*",
     "tsc": "tsc",
+    "compile": "tsc",
     "start": "node -r ts-node/register src/cli.ts $@",
     "gts": "gts",
     "lint": "gts lint",

js/dist/lib/ads-api-client.js

@@ -77,11 +77,11 @@ export interface IGoogleAdsApiClient {
 
 export type GoogleAdsApiConfig = {
   // ClientOptions:
-  client_id: string;
-  client_secret: string;
+  client_id?: string;
+  client_secret?: string;
   developer_token: string;
   // CustomerOptions:
-  refresh_token: string;
+  refresh_token?: string;
   login_customer_id?: string;
   linked_customer_id?: string;
   customer_id?: string[] | string;
@@ -167,8 +167,8 @@ export class GoogleAdsRpcApiClient
   constructor(adsConfig: GoogleAdsApiConfig) {
     super(adsConfig, ApiType.gRPC);
     this.client = new GoogleAdsApi({
-      client_id: adsConfig.client_id,
-      client_secret: adsConfig.client_secret,
+      client_id: adsConfig.client_id!,
+      client_secret: adsConfig.client_secret!,
       developer_token: adsConfig.developer_token,
     });
     this.customers = {};
@@ -184,7 +184,7 @@ export class GoogleAdsRpcApiClient
       customer = this.client.Customer({
         customer_id: customerId,
         login_customer_id: this.adsConfig.login_customer_id,
-        refresh_token: this.adsConfig.refresh_token,
+        refresh_token: this.adsConfig.refresh_token!,
       });
       this.customers[customerId] = customer;
     }
@@ -309,10 +309,6 @@ export class GoogleAdsRpcApiClient
       // NOTE: we're iterating over the stream instead of returning it
       // for the sake of error handling
       const stream = customer.queryStream(query);
-      // this.logger.debug('Created AsyncGenerator from queryStream', {
-      //   customerId,
-      //   query,
-      // });
       for await (const row of stream) {
         yield row as Record<string, unknown>;
       }
@@ -405,9 +401,9 @@ export class GoogleAdsRestApiClient
       // working under a user account (with refreshToken)
       // Refresh if within 5 minutes of expiration
       const {access_token, expires_in} = await this.refreshAccessToken(
-        this.adsConfig.client_id,
-        this.adsConfig.client_secret,
-        this.adsConfig.refresh_token
+        this.adsConfig.client_id!,
+        this.adsConfig.client_secret!,
+        this.adsConfig.refresh_token!
       );
       this.currentToken = access_token;
       this.tokenExpiration = Date.now() + expires_in * 1000;

js/dist/lib/ads-api-client.js.map

@@ -372,6 +372,8 @@ export class AdsQueryExecutor {
   ): Promise<QueryResult> {
     return executeWithRetry(
       async () => {
+        const dumpRawRow = process.env.GAARF_DUMP_API_ROW;
+        const dumpRow = process.env.GAARF_DUMP_ROW;
         const stream = this.executeNativeQuery(query, customerId);
         if (process.env.DUMP_MEMORY) {
           this.logger.debug(getMemoryUsage('Query executed'));
@@ -382,9 +384,15 @@ export class AdsQueryExecutor {
         // NOTE: as we're iterating over an AsyncGenerator any error if happens
         // will be thrown on iterating not on creating of the generator
         for await (const row of stream) {
+          if (dumpRawRow) {
+            console.log(row);
+          }
           const parsedRow = <unknown[]>this.parser.parseRow(row, query, false);
+          if (dumpRow) {
+            console.log(parsedRow);
+          }
           rowCount++;
-          // NOTE: to descrease memory consumption we won't accumulate data if a writer was supplied
+          // NOTE: to decrease memory consumption we won't accumulate data if a writer was supplied
           if (writer) {
             await writer.addRow(customerId, parsedRow, row);
             if (process.env.DUMP_MEMORY && rowCount % 10 === 0) {