kopia lustrzana https://github.com/transitive-bullshit/chatgpt-api
pull/643/head^2
Travis Fischer
rodzic
c763bfa1f0
commit
19706bfe18
|
|
@ -45,6 +45,7 @@
|
|||
},
|
||||
"dependencies": {
|
||||
"@dexaai/dexter": "^2.0.0",
|
||||
"delay": "^6.0.0",
|
||||
"dotenv": "^16.4.5",
|
||||
"execa": "^8.0.1",
|
||||
"exit-hook": "^4.0.0",
|
||||
|
|
@ -53,6 +54,7 @@
|
|||
"openai": "^4.47.1",
|
||||
"p-map": "^7.0.2",
|
||||
"p-retry": "^6.2.0",
|
||||
"p-throttle": "^6.1.0",
|
||||
"tiny-invariant": "^1.3.3",
|
||||
"type-fest": "^4.16.0",
|
||||
"zod": "^3.23.3"
|
||||
|
|
|
|||
|
|
@ -8,6 +8,9 @@ dependencies:
|
|||
'@dexaai/dexter':
|
||||
specifier: ^2.0.0
|
||||
version: 2.0.2
|
||||
delay:
|
||||
specifier: ^6.0.0
|
||||
version: 6.0.0
|
||||
dotenv:
|
||||
specifier: ^16.4.5
|
||||
version: 16.4.5
|
||||
|
|
@ -32,6 +35,9 @@ dependencies:
|
|||
p-retry:
|
||||
specifier: ^6.2.0
|
||||
version: 6.2.0
|
||||
p-throttle:
|
||||
specifier: ^6.1.0
|
||||
version: 6.1.0
|
||||
tiny-invariant:
|
||||
specifier: ^1.3.3
|
||||
version: 1.3.3
|
||||
|
|
@ -2056,6 +2062,11 @@ packages:
|
|||
slash: 4.0.0
|
||||
dev: true
|
||||
|
||||
/delay@6.0.0:
|
||||
resolution: {integrity: sha512-2NJozoOHQ4NuZuVIr5CWd0iiLVIRSDepakaovIN+9eIDHEhdCAEvSy2cuf1DCrPPQLvHmbqTHODlhHg8UCy4zw==}
|
||||
engines: {node: '>=16'}
|
||||
dev: false
|
||||
|
||||
/delayed-stream@1.0.0:
|
||||
resolution: {integrity: sha512-ZySD7Nf91aLB0RxL4KGrKHBXl7Eds1DAmEdcoVawXnLD7SDhpNgtuII2aAkg7a7QS41jxPSZ17p4VdGnMHk3MQ==}
|
||||
engines: {node: '>=0.4.0'}
|
||||
|
|
|
|||
|
|
@ -0,0 +1,660 @@
|
|||
import defaultKy from 'ky'
|
||||
import pThrottle from 'p-throttle'
|
||||
|
||||
import type * as types from '../types.js'
|
||||
import { assert, delay, getEnv, throttleKy } from '../utils.js'
|
||||
|
||||
const clearbitAPIThrottle = pThrottle({
|
||||
limit: 20,
|
||||
interval: 60 * 1000,
|
||||
strict: true
|
||||
})
|
||||
|
||||
export interface CompanyEnrichmentOptions {
|
||||
domain: string
|
||||
webhook_url?: string
|
||||
company_name?: string
|
||||
linkedin?: string
|
||||
twitter?: string
|
||||
facebook?: string
|
||||
}
|
||||
|
||||
type CompanyNullableProps = {
|
||||
name: string
|
||||
legalName: string
|
||||
domain: string
|
||||
domainAliases: string[]
|
||||
site: {
|
||||
phoneNumbers: string[]
|
||||
emailAddresses: string[]
|
||||
}
|
||||
category: {
|
||||
sector: string
|
||||
industryGroup: string
|
||||
industry: string
|
||||
subIndustry: string
|
||||
gicsCode: string
|
||||
sicCode: string
|
||||
sic4Codes: string[]
|
||||
naicsCode: string
|
||||
naics6Codes: string[]
|
||||
naics6Codes2022: string[]
|
||||
}
|
||||
tags: string[]
|
||||
description: string
|
||||
foundedYear: number
|
||||
location: string
|
||||
timeZone: string
|
||||
utcOffset: number
|
||||
geo: {
|
||||
streetNumber: string
|
||||
streetName: string
|
||||
subPremise: string
|
||||
streetAddress: string
|
||||
city: string
|
||||
postalCode: string
|
||||
state: string
|
||||
stateCode: string
|
||||
country: string
|
||||
countryCode: string
|
||||
lat: number
|
||||
lng: number
|
||||
}
|
||||
logo: string
|
||||
facebook: {
|
||||
handle: string
|
||||
likes: number
|
||||
}
|
||||
linkedin: {
|
||||
handle: string
|
||||
}
|
||||
twitter: {
|
||||
handle: string
|
||||
id: string
|
||||
bio: string
|
||||
followers: number
|
||||
following: number
|
||||
location: string
|
||||
site: string
|
||||
avatar: string
|
||||
}
|
||||
crunchbase: {
|
||||
handle: string
|
||||
}
|
||||
emailProvider: boolean
|
||||
type: string
|
||||
ticker: string
|
||||
identifiers: {
|
||||
usEIN: string
|
||||
usCIK: string
|
||||
}
|
||||
phone: string
|
||||
metrics: {
|
||||
alexaUsRank: number
|
||||
alexaGlobalRank: number
|
||||
trafficRank: string
|
||||
employees: number
|
||||
employeesRange: string
|
||||
marketCap: string
|
||||
raised: number
|
||||
annualRevenue: string
|
||||
estimatedAnnualRevenue: string
|
||||
fiscalYearEnd: string
|
||||
}
|
||||
indexedAt: string
|
||||
tech: string[]
|
||||
techCategories: string[]
|
||||
parent: {
|
||||
domain: string
|
||||
}
|
||||
ultimateParent: {
|
||||
domain: string
|
||||
}
|
||||
}
|
||||
|
||||
type EmailLookupResponse = DeepNullable<{
|
||||
id: string
|
||||
name: {
|
||||
fullName: string
|
||||
givenName: string
|
||||
familyName: string
|
||||
}
|
||||
email: string
|
||||
location: string
|
||||
timeZone: string
|
||||
utcOffset: number
|
||||
geo: {
|
||||
city: string
|
||||
state: string
|
||||
stateCode: string
|
||||
country: string
|
||||
countryCode: string
|
||||
lat: number
|
||||
lng: number
|
||||
}
|
||||
bio: string
|
||||
site: string
|
||||
avatar: string
|
||||
employment: {
|
||||
domain: string
|
||||
name: string
|
||||
title: string
|
||||
role: string
|
||||
subRole: string
|
||||
seniority: string
|
||||
}
|
||||
facebook: {
|
||||
handle: string
|
||||
}
|
||||
github: {
|
||||
handle: string
|
||||
id: string
|
||||
avatar: string
|
||||
company: string
|
||||
blog: string
|
||||
followers: number
|
||||
following: number
|
||||
}
|
||||
twitter: {
|
||||
handle: string
|
||||
id: string
|
||||
bio: string
|
||||
followers: number
|
||||
following: number
|
||||
statuses: number
|
||||
favorites: number
|
||||
location: string
|
||||
site: string
|
||||
avatar: string
|
||||
}
|
||||
linkedin: {
|
||||
handle: string
|
||||
}
|
||||
googleplus: {
|
||||
handle: null
|
||||
}
|
||||
gravatar: {
|
||||
handle: string
|
||||
urls: {
|
||||
value: string
|
||||
title: string
|
||||
}[]
|
||||
avatar: string
|
||||
avatars: {
|
||||
url: string
|
||||
type: string
|
||||
}[]
|
||||
}
|
||||
fuzzy: boolean
|
||||
emailProvider: boolean
|
||||
indexedAt: string
|
||||
phone: string
|
||||
activeAt: string
|
||||
inactiveAt: string
|
||||
}>
|
||||
|
||||
export type CompanyResponse = {
|
||||
id: string
|
||||
} & DeepNullable<CompanyNullableProps>
|
||||
|
||||
export interface CompanySearchOptions {
|
||||
/**
|
||||
* See clearbit docs: https://dashboard.clearbit.com/docs?shell#discovery-api-tech-queries
|
||||
* Examples:
|
||||
* tech:google_apps
|
||||
* or:(twitter_followers:10000~ type:nonprofit)
|
||||
*/
|
||||
query: string
|
||||
page?: number
|
||||
page_size?: number
|
||||
limit?: number
|
||||
sort?: string
|
||||
}
|
||||
|
||||
export interface CompanySearchResponse {
|
||||
total: number
|
||||
page: number
|
||||
results: CompanyResponse[]
|
||||
}
|
||||
|
||||
export interface BasicCompanyResponse {
|
||||
domain: string
|
||||
logo: string
|
||||
name: string
|
||||
}
|
||||
|
||||
export interface PeopleSearchOptionsV2 {
|
||||
domains?: string[]
|
||||
names?: string[]
|
||||
roles?: string[]
|
||||
seniorities?: string[]
|
||||
titles?: string[]
|
||||
locations?: string[]
|
||||
employees_ranges?: string[]
|
||||
company_tags?: string[]
|
||||
company_tech?: string[]
|
||||
company_types?: string[]
|
||||
industries?: string[]
|
||||
revenue_ranges?: string[]
|
||||
linkedin_profile_handles?: string[]
|
||||
page?: number
|
||||
page_size?: number
|
||||
suppression?: string
|
||||
}
|
||||
|
||||
// Prospector types
|
||||
export interface ProspectorResponseV2 {
|
||||
page: number
|
||||
page_size: number
|
||||
total: number
|
||||
results: PersonAttributesV2[]
|
||||
}
|
||||
|
||||
export interface EmploymentAttributes {
|
||||
company: string
|
||||
domain: string
|
||||
linkedin: string
|
||||
title: string
|
||||
role: string
|
||||
subRole: string
|
||||
seniority: string
|
||||
startDate: string
|
||||
endDate: string
|
||||
present: boolean
|
||||
highlight: boolean
|
||||
}
|
||||
|
||||
export interface EmailAttributes {
|
||||
address: string
|
||||
type: string
|
||||
}
|
||||
|
||||
export interface PhoneAttributes {
|
||||
number: string
|
||||
type: string
|
||||
}
|
||||
|
||||
interface Name {
|
||||
givenName: string
|
||||
familyName: string
|
||||
fullName: string
|
||||
}
|
||||
|
||||
export type PersonAttributesV2 = {
|
||||
id: string
|
||||
} & DeepNullable<{
|
||||
name: Name
|
||||
avatar: string
|
||||
location: string
|
||||
linkedin: string
|
||||
employments: EmploymentAttributes[]
|
||||
emails: EmailAttributes[]
|
||||
phones: PhoneAttributes[]
|
||||
}>
|
||||
|
||||
type PeopleSearchOptionsV1 = {
|
||||
domain: string
|
||||
role?: string
|
||||
roles?: string[]
|
||||
seniority?: string
|
||||
seniorities?: string[]
|
||||
title?: string
|
||||
titles?: string[]
|
||||
city?: string
|
||||
cities?: string[]
|
||||
state?: string
|
||||
states?: string[]
|
||||
country?: string
|
||||
countries?: string[]
|
||||
name?: string
|
||||
query?: string
|
||||
page?: number
|
||||
page_size?: number
|
||||
suppression?: string
|
||||
}
|
||||
|
||||
interface Company {
|
||||
name: string
|
||||
}
|
||||
|
||||
interface PeopleSearchResponseV1 {
|
||||
id: string
|
||||
name: Name
|
||||
title: string
|
||||
role: string
|
||||
subRole: string
|
||||
seniority: string
|
||||
company: Company
|
||||
email: string
|
||||
verified: boolean
|
||||
phone: string
|
||||
}
|
||||
|
||||
export interface ProspectorResponseV1 {
|
||||
page: number
|
||||
page_size: number
|
||||
total: number
|
||||
results: PeopleSearchResponseV1[]
|
||||
}
|
||||
|
||||
interface GeoIP {
|
||||
city: string
|
||||
state: string
|
||||
stateCode: string
|
||||
country: string
|
||||
countryCode: string
|
||||
}
|
||||
|
||||
interface CompanyRevealResponse {
|
||||
ip: string
|
||||
fuzzy: boolean
|
||||
domain: string
|
||||
type: string
|
||||
company?: CompanyResponse
|
||||
geoIP: GeoIP
|
||||
confidenceScore: 'very_high' | 'high' | 'medium' | 'low'
|
||||
role: string
|
||||
seniority: string
|
||||
}
|
||||
|
||||
export class ClearbitClient {
|
||||
api: typeof defaultKy
|
||||
apiKey: string
|
||||
_maxPageSize = 100
|
||||
|
||||
static PersonRoles = [
|
||||
'communications',
|
||||
'customer_service',
|
||||
'education',
|
||||
'engineering',
|
||||
'finance',
|
||||
'health_professional',
|
||||
'human_resources',
|
||||
'information_technology',
|
||||
'leadership',
|
||||
'legal',
|
||||
'marketing',
|
||||
'operations',
|
||||
'product',
|
||||
'public_relations',
|
||||
'real_estate',
|
||||
'recruiting',
|
||||
'research',
|
||||
'sales'
|
||||
]
|
||||
|
||||
static SenioritiesV2 = [
|
||||
'Executive',
|
||||
'VP',
|
||||
'Owner',
|
||||
'Partner',
|
||||
'Director',
|
||||
'Manager',
|
||||
'Senior',
|
||||
'Entry'
|
||||
]
|
||||
|
||||
static Seniorities = ['executive', 'director', 'manager']
|
||||
|
||||
static SubIndustries: string[] = [
|
||||
'Automotive',
|
||||
'Consumer Discretionary',
|
||||
'Consumer Goods',
|
||||
'Consumer Electronics',
|
||||
'Household Appliances',
|
||||
'Photography',
|
||||
'Sporting Goods',
|
||||
'Apparel, Accessories & Luxury Goods',
|
||||
'Textiles',
|
||||
'Textiles, Apparel & Luxury Goods',
|
||||
'Consumer Services',
|
||||
'Education Services',
|
||||
'Specialized Consumer Services',
|
||||
'Casinos & Gaming',
|
||||
'Hotels, Restaurants & Leisure',
|
||||
'Leisure Facilities',
|
||||
'Restaurants',
|
||||
'Education',
|
||||
'Family Services',
|
||||
'Legal Services',
|
||||
'Advertising',
|
||||
'Broadcasting',
|
||||
'Media',
|
||||
'Movies & Entertainment',
|
||||
'Public Relations',
|
||||
'Publishing',
|
||||
'Distributors',
|
||||
'Retailing',
|
||||
'Home Improvement Retail',
|
||||
'Homefurnishing Retail',
|
||||
'Specialty Retail',
|
||||
'Consumer Staples',
|
||||
'Food Retail',
|
||||
'Beverages',
|
||||
'Agricultural Products',
|
||||
'Food',
|
||||
'Food Production',
|
||||
'Packaged Foods & Meats',
|
||||
'Tobacco',
|
||||
'Cosmetics',
|
||||
'Oil & Gas',
|
||||
'Banking & Mortgages',
|
||||
'Accounting',
|
||||
'Finance',
|
||||
'Financial Services',
|
||||
'Asset Management & Custody Banks',
|
||||
'Diversified Capital Markets',
|
||||
'Fundraising',
|
||||
'Investment Banking & Brokerage',
|
||||
'Payments',
|
||||
'Insurance',
|
||||
'Real Estate',
|
||||
'Eyewear',
|
||||
'Health & Wellness',
|
||||
'Health Care',
|
||||
'Health Care Services',
|
||||
'Biotechnology',
|
||||
'Life Sciences Tools & Services',
|
||||
'Pharmaceuticals',
|
||||
'Aerospace & Defense',
|
||||
'Capital Goods',
|
||||
'Civil Engineering',
|
||||
'Construction',
|
||||
'Construction & Engineering',
|
||||
'Mechanical Engineering',
|
||||
'Electrical',
|
||||
'Electrical Equipment',
|
||||
'Industrials & Manufacturing',
|
||||
'Industrial Machinery',
|
||||
'Machinery',
|
||||
'Trading Companies & Distributors',
|
||||
'Business Supplies',
|
||||
'Commercial Printing',
|
||||
'Corporate & Business',
|
||||
'Architecture',
|
||||
'Automation',
|
||||
'Consulting',
|
||||
'Design',
|
||||
'Human Resource & Employment Services',
|
||||
'Professional Services',
|
||||
'Research & Consulting Services',
|
||||
'Industrials',
|
||||
'Shipping & Logistics',
|
||||
'Airlines',
|
||||
'Marine',
|
||||
'Ground Transportation',
|
||||
'Transportation',
|
||||
'Semiconductors',
|
||||
'Cloud Services',
|
||||
'Internet',
|
||||
'Internet Software & Services',
|
||||
'Data Processing & Outsourced Services',
|
||||
'Graphic Design',
|
||||
'Communications',
|
||||
'Computer Networking',
|
||||
'Nanotechnology',
|
||||
'Computer Hardware',
|
||||
'Technology Hardware, Storage & Peripherals',
|
||||
'Building Materials',
|
||||
'Chemicals',
|
||||
'Commodity Chemicals',
|
||||
'Containers & Packaging',
|
||||
'Gold',
|
||||
'Metals & Mining',
|
||||
'Paper Products',
|
||||
'Integrated Telecommunication Services',
|
||||
'Wireless Telecommunication Services',
|
||||
'Renewable Energy',
|
||||
'Energy',
|
||||
'Utilities'
|
||||
]
|
||||
|
||||
constructor({
|
||||
apiKey = getEnv('CLEARBIT_KEY'),
|
||||
timeoutMs = 30_000,
|
||||
ky = defaultKy
|
||||
}: {
|
||||
apiKey?: string
|
||||
apiBaseUrl?: string
|
||||
timeoutMs?: number
|
||||
ky?: typeof defaultKy
|
||||
} = {}) {
|
||||
assert(apiKey, 'Error clearbit client missing required "apiKey"')
|
||||
|
||||
this.apiKey = apiKey
|
||||
|
||||
const throttledKy = throttleKy(ky, clearbitAPIThrottle)
|
||||
|
||||
this.api = throttledKy.extend({
|
||||
timeout: timeoutMs,
|
||||
headers: {
|
||||
Authorization: `Basic ${Buffer.from(`${apiKey}:`).toString('base64')}`
|
||||
}
|
||||
})
|
||||
}
|
||||
|
||||
async companyEnrichment(options: CompanyEnrichmentOptions) {
|
||||
return this.api
|
||||
.get('https://company-stream.clearbit.com/v2/companies/find', {
|
||||
searchParams: { ...options }
|
||||
})
|
||||
.json<CompanyResponse>()
|
||||
.catch((_) => undefined)
|
||||
}
|
||||
|
||||
async companySearch(options: CompanySearchOptions) {
|
||||
return this.api
|
||||
.get('https://discovery.clearbit.com/v1/companies/search', {
|
||||
searchParams: { ...options }
|
||||
})
|
||||
.json<CompanySearchResponse>()
|
||||
}
|
||||
|
||||
async companyAutocomplete(name: string) {
|
||||
return this.api
|
||||
.get('https://autocomplete.clearbit.com/v1/companies/suggest', {
|
||||
searchParams: { query: name }
|
||||
})
|
||||
.json<BasicCompanyResponse[]>()
|
||||
}
|
||||
|
||||
async prospectorPeopleV2(options: PeopleSearchOptionsV2) {
|
||||
return this.api
|
||||
.get('https://prospector.clearbit.com/v2/people/search', {
|
||||
// @ts-expect-error location is a string[] and searchparams shows a TS error heres
|
||||
searchParams: {
|
||||
...options,
|
||||
page_size: Math.min(
|
||||
this._maxPageSize,
|
||||
options.page_size || this._maxPageSize
|
||||
)
|
||||
}
|
||||
})
|
||||
.json<ProspectorResponseV2>()
|
||||
}
|
||||
|
||||
async prospectorPeopleV1(options: PeopleSearchOptionsV1, loadEmail = false) {
|
||||
return this.api
|
||||
.get('https://prospector.clearbit.com/v1/people/search', {
|
||||
// @ts-expect-error location is a string[] and searchparams shows a TS error heres
|
||||
searchParams: {
|
||||
...options,
|
||||
page_size: Math.min(
|
||||
this._maxPageSize,
|
||||
options.page_size || this._maxPageSize
|
||||
),
|
||||
email: loadEmail
|
||||
}
|
||||
})
|
||||
.json<ProspectorResponseV1>()
|
||||
}
|
||||
|
||||
// TODO Status code = 202 means the response was queued.
|
||||
// Implement webhook when needed. The polling works well, in most cases we need to try
|
||||
// again once to get a 200 response.
|
||||
async emailLookup({
|
||||
email,
|
||||
maxRetries
|
||||
}: {
|
||||
email: string
|
||||
maxRetries?: number
|
||||
}) {
|
||||
const url = 'https://person.clearbit.com/v2/people/find'
|
||||
let response = await this.api.get(url, {
|
||||
searchParams: { email }
|
||||
})
|
||||
|
||||
if (response.status !== 202 || !maxRetries) {
|
||||
return response.json<EmailLookupResponse>()
|
||||
}
|
||||
|
||||
if (maxRetries && response.status === 202) {
|
||||
let count = 0
|
||||
let running = true
|
||||
while (running && count < maxRetries) {
|
||||
console.log(`Email Lookup was queued, retry ${count + 1}.`)
|
||||
await delay(1000)
|
||||
response = await this.api.get(url, {
|
||||
searchParams: { email }
|
||||
})
|
||||
count++
|
||||
running = response.status === 202
|
||||
}
|
||||
return response.json<EmailLookupResponse>()
|
||||
}
|
||||
}
|
||||
|
||||
async nameToDomain(name: string) {
|
||||
return this.api
|
||||
.get('https://company.clearbit.com/v1/domains/find', {
|
||||
searchParams: { name }
|
||||
})
|
||||
.json<BasicCompanyResponse>()
|
||||
.catch((_) => undefined)
|
||||
}
|
||||
|
||||
async revealCompanyFromIp(ip: string) {
|
||||
return this.api
|
||||
.get('https://reveal.clearbit.com/v1/companies/find', {
|
||||
searchParams: { ip }
|
||||
})
|
||||
.json<CompanyRevealResponse>()
|
||||
.catch((_) => undefined)
|
||||
}
|
||||
|
||||
static filterEmploymentProspectorV2(
|
||||
companyName: string,
|
||||
employments: Array<DeepNullable<EmploymentAttributes> | null> | null
|
||||
) {
|
||||
if (employments && employments.length > 0) {
|
||||
// We filter by employment endDate because some people could have multiple jobs at the same time.
|
||||
// Here we want to filter by people that actively works at a specific company.
|
||||
return employments
|
||||
.filter((item) => !item?.endDate)
|
||||
.some((item) =>
|
||||
item?.company?.toLowerCase().includes(companyName.toLowerCase())
|
||||
)
|
||||
}
|
||||
return false
|
||||
}
|
||||
}
|
||||
|
|
@ -1,8 +1,8 @@
|
|||
import defaultKy, { type KyInstance } from 'ky'
|
||||
import { z } from 'zod'
|
||||
|
||||
import { getEnv } from '../../utils/helpers.js'
|
||||
import { aiFunction, AIToolsProvider } from '../fns.js'
|
||||
import { assert, getEnv } from '../utils.js'
|
||||
|
||||
export namespace weatherapi {
|
||||
export const BASE_URL = 'https://api.weatherapi.com/v1'
|
||||
|
|
@ -88,10 +88,7 @@ export class WeatherClient extends AIToolsProvider {
|
|||
apiBaseUrl?: string
|
||||
ky?: KyInstance
|
||||
} = {}) {
|
||||
if (!apiKey) {
|
||||
throw new Error(`Error WeatherClient missing required "apiKey"`)
|
||||
}
|
||||
|
||||
assert(apiKey, 'WEATHER_API_KEY is required')
|
||||
super()
|
||||
|
||||
this.apiKey = apiKey
|
||||
|
|
|
|||
|
|
@ -1,2 +1,2 @@
|
|||
// TODO
|
||||
export type TODO = 'TODO'
|
||||
export type { KyInstance } from 'ky'
|
||||
export type { ThrottledFunction } from 'p-throttle'
|
||||
|
|
|
|||
26
src/utils.ts
26
src/utils.ts
|
|
@ -1,3 +1,6 @@
|
|||
import type * as types from './types.js'
|
||||
|
||||
export { default as delay } from 'delay'
|
||||
export { default as assert } from 'tiny-invariant'
|
||||
|
||||
/**
|
||||
|
|
@ -60,3 +63,26 @@ export function getEnv(name: string): string | undefined {
|
|||
return undefined
|
||||
}
|
||||
}
|
||||
|
||||
/**
|
||||
* Function that does nothing.
|
||||
*/
|
||||
export const noop = () => undefined
|
||||
|
||||
/**
|
||||
* Throttles HTTP requests made by a ky instance.
|
||||
*
|
||||
* Very useful for enforcing rate limits.
|
||||
*/
|
||||
export function throttleKy(
|
||||
ky: types.KyInstance,
|
||||
throttleFn: <Arguments extends readonly unknown[], ReturnValue>(
|
||||
function_: (...args_: Arguments) => ReturnValue
|
||||
) => types.ThrottledFunction<(...args_: Arguments) => ReturnValue>
|
||||
) {
|
||||
return ky.extend({
|
||||
hooks: {
|
||||
beforeRequest: [throttleFn(noop)]
|
||||
}
|
||||
})
|
||||
}
|
||||
|
|
|
|||
Ładowanie…
Reference in New Issue