hubspot_chat_gtp_sdk.ts

// This was generated with ChatGTP as an expiriment. If you find this, don't trust that the 
// code works. I didn't test this or anything. See: https://twitter.com/ntotten/status/1657012479942066177
class HubspotSDK {
  private apiKey: string;
  private baseUrl: string = 'https://api.hubapi.com';

  constructor(apiKey: string) {
    this.apiKey = apiKey;
  }

  private async request(
    path: string,
    method: string,
    body?: Record<string, any>
  ): Promise<any> {
    const url = `${this.baseUrl}${path}?hapikey=${this.apiKey}`;
    const options: RequestInit = {
      method,
      headers: {
        'Content-Type': 'application/json',
      },
    };

    if (body) {
      options.body = JSON.stringify(body);
    }

    const response = await fetch(url, options);

    if (!response.ok) {
      throw new Error(`HTTP error: ${response.status} - ${response.statusText}`);
    }

    return await response.json();
  }

  private async backoffRetry(fn: () => Promise<any>, delay: number): Promise<any> {
    await new Promise(resolve => setTimeout(resolve, delay));
    return await fn();
  }

  public async createContact(contact: Record<string, any>): Promise<any> {
    try {
      return await this.request('/contacts/v1/contact', 'POST', contact);
    } catch (error) {
      // Retry after 100ms
      return this.backoffRetry(() => this.createContact(contact), 100);
    }
  }

  public async updateContact(contactId: string, contact: Record<string, any>): Promise<any> {
    try {
      return await this.request(`/contacts/v1/contact/vid/${contactId}/profile`, 'POST', contact);
    } catch (error) {
      // Retry after 100ms
      return this.backoffRetry(() => this.updateContact(contactId, contact), 100);
    }
  }

  public async deleteContact(contactId: string): Promise<void> {
    try {
      await this.request(`/contacts/v1/contact/vid/${contactId}`, 'DELETE');
    } catch (error) {
      // Retry after 100ms
      await this.backoffRetry(() => this.deleteContact(contactId), 100);
    }
  }

  public async createCompany(company: Record<string, any>): Promise<any> {
    try {
      return await this.request('/companies/v1/companies', 'POST', company);
    } catch (error) {
      // Retry after 500ms
      return this.backoffRetry(() => this.createCompany(company), 500);
    }
  }

  public async updateCompany(companyId: string, company: Record<string, any>): Promise<any> {
    try {
      return await this.request(`/companies/v1/companies/${companyId}`, 'PUT', company);
    } catch (error) {
      // Retry after 500ms
      return this.backoffRetry(() => this.updateCompany(companyId, company), 500);
    }
  }

  public async deleteCompany(companyId: string): Promise<void> {
    try {
      await this.request(`/companies/v1/companies/${companyId}`, 'DELETE');
    } catch (error) {
      // Retry after 500ms
      await this.backoffRetry(() => this.deleteCompany(companyId), 500);
    }
  }
}