Class Resend

integrations/resend/src/index.ts:55–194

export type ResendRunTask = InstanceType<typeof Resend>["runTask"];

export class Resend implements TriggerIntegration {
  /**
   * @internal
   */
  private _options: ResendIntegrationOptions;
  /**
   * @internal
   */
  private _client?: ResendClient;
  /**
   * @internal
   */
  private _io?: IO;

  // @internal
  private _connectionKey?: string;

  constructor(options: ResendIntegrationOptions) {
    this._options = options;
  }

  get authSource() {
    return this._options.apiKey ? ("LOCAL" as const) : ("HOSTED" as const);
  }

  cloneForRun(io: IO, connectionKey: string, auth?: ConnectionAuth) {
    const apiKey = this._options.apiKey ?? auth?.accessToken;

    if (!apiKey) {
      throw new Error(
        `Can't create Resend integration (${this._options.id}) as apiKey was undefined`
      );
    }

    const resend = new Resend(this._options);
    resend._io = io;
    resend._connectionKey = connectionKey;
    resend._client = new ResendClient(apiKey);
    return resend;
  }

  get id() {
    return this._options.id;
  }

  get metadata() {
    return { id: "resend", name: "Resend.com" };
  }

  runTask<T, TResult extends Json<T> | void>(
    key: IntegrationTaskKey,
    callback: (client: ResendClient, task: IOTask, io: IO) => Promise<TResult>,
    options?: RunTaskOptions,
    errorCallback?: RunTaskErrorCallback
  ): Promise<TResult> {
    if (!this._io) throw new Error("No IO");
    if (!this._connectionKey) throw new Error("No connection key");