为 Reddit API 构建 Nodejs 包装器：分步指南

export class reddit {
  private baseurl: string;
  private clientid: string;
  private clientsecret: string;
  private useragent: string;
  private token?: string;

  constructor() {
    this.clientid = getenvironmentvariable('reddit_client_id')!;
    this.clientsecret = getenvironmentvariable('reddit_secret')!;
    this.useragent = getenvironmentvariable('reddit_user_agent')!;
    this.baseurl = getenvironmentvariable('reddit_base_url')!;
  }
}

private buildurl(endpoint: string, options?: redditsearchoptions): string {
  const preparedparams: [string, string][] = object.entries({ ...options })
    .filter(
      ([key, value]) =>
        value !== undefined && value !== null && key !== 'apikey',
    )
    .map(([key, value]) => [key, `${value}`]);

  const searchparams = new urlsearchparams(preparedparams);
  return `${this.baseurl}/${endpoint}?${searchparams}`;
}

private async getaccesstoken(): promise<string> {
  if (this.token) return this.token;

  const auth = buffer.from(`${this.clientid}:${this.clientsecret}`).tostring(
    'base64',
  );

  const headers = new headers();
  headers.append('authorization', `basic ${auth}`);
  headers.append('content-type', 'application/x-www-form-urlencoded');

  const response = await fetch(`${this.baseurl}/api/v1/access_token`, {
    method: 'post',
    headers,
    body: 'grant_type=client_credentials',
  });

  if (!response.ok) {
    throw new error(`error fetching access token: ${response.statustext}`);
  }

  const data = (await response.json()) as {
    access_token: string;
  };

  this.token = data.access_token;
  return this.token;
}

private async invoke<t = any>(
  endpoint: string,
  options?: redditsearchoptions,
): promise<t> {
  const token = await this.getaccesstoken();

  const headers = new headers();
  headers.append('authorization', `bearer ${token}`);
  headers.append('user-agent', this.useragent);

  const response = await fetch(this.buildurl(endpoint, options), {
    method: 'get',
    headers,
  });
  if (!response.ok) {
    throw new error(`error fetching data: ${response.statustext}`);
  }

  return (await response.json()) as t;
}

public async findMany(
  q: string,
  options: RedditSearchOptions = {},
): Promise<any> {
  return this.invoke('/search', { ...options, q });
}