lib/client/googleSoap.service.ts

import type { Client } from "soap";
import { BearerSecurity, createClientAsync } from "soap";
import { SERVICE_MAP } from "../common/constants";
import type { GoogleSoapServiceOptions, ImportClass } from "../common/types";
import { promiseFromCallback } from "../common/utils";

export class GoogleSoapService<T extends keyof typeof SERVICE_MAP> {
  private networkCode: number;
  private applicationName: string;
  private apiVersion: string;
  private service: T;
  private token: string;
  private _client?: Client;

  constructor(service: T, options: GoogleSoapServiceOptions) {
    this.service = service;
    this.applicationName = options.applicationName;
    this.networkCode = options.networkCode;
    this.token = options.token;
    this.apiVersion = options.apiVersion;
  }

  public async createClient(
    logRequests = false,
    logResponses = false,
  ): Promise<ImportClass<typeof SERVICE_MAP, T>> {
    const serviceUrl = `https://ads.google.com/apis/ads/publisher/${this.apiVersion}/${this.service}?wsdl`;
    const client = await createClientAsync(serviceUrl);
    client.addSoapHeader(this.getSoapHeaders());
    client.setToken = function setToken(token: string) {
      client.setSecurity(new BearerSecurity(token));
    };

    if (this.token) client.setToken(this.token);

    if (logRequests) {
      client.addListener("request", (req: unknown) => {
        console.info("SOAP Request:", req);
      });
    }

    if (logResponses) {
      client.addListener("response", (res: unknown) => {
        console.info("SOAP Response:", res);
      });
    }

    this._client = new Proxy(client, {
      get: function get(target, propertyKey) {
        const method = propertyKey.toString();

        if (target.hasOwnProperty(method) && !["setToken"].includes(method)) {
          return async function run(dto: any = {}) {
            const res = await promiseFromCallback((cb) =>
              client[method](dto, cb),
            );

            return res?.rval || null;
          };
        }
        return target[method];
      },
    });

    const services = SERVICE_MAP as any;

    return new services[this.service](this._client);
  }

  private getSoapHeaders(): any {
    return {
      RequestHeader: {
        attributes: {
          "soapenv:actor": "http://schemas.xmlsoap.org/soap/actor/next",
          "soapenv:mustUnderstand": 0,
          "xsi:type": "ns1:SoapRequestHeader",
          "xmlns:ns1":
            "https://www.google.com/apis/ads/publisher/" + this.apiVersion,
          "xmlns:xsi": "http://www.w3.org/2001/XMLSchema-instance",
          "xmlns:soapenv": "http://schemas.xmlsoap.org/soap/envelope/",
        },
        "ns1:networkCode": this.networkCode,
        "ns1:applicationName": this.applicationName,
      },
    };
  }
}