mirror of
https://github.com/kc4x4sar/d4h-typescript.git
synced 2026-07-12 17:21:05 -07:00
Added test project.
This commit is contained in:
@@ -0,0 +1,63 @@
|
||||
interface D4HResponse<DataType> {
|
||||
statusCode: number;
|
||||
data: DataType;
|
||||
error: string;
|
||||
}
|
||||
|
||||
interface D4HError {
|
||||
statusCode: number;
|
||||
error: string;
|
||||
}
|
||||
|
||||
export default class HttpUtils {
|
||||
private readonly _fetchLimit: number;
|
||||
private readonly _token: string;
|
||||
|
||||
constructor(token: string, fetchLimit: number) {
|
||||
if (!token) {
|
||||
throw new Error("Token cannot be empty");
|
||||
}
|
||||
|
||||
this._fetchLimit = fetchLimit;
|
||||
this._token = token;
|
||||
}
|
||||
|
||||
async get<DataType>(url: URL): Promise<DataType> {
|
||||
let method = "GET";
|
||||
let headers = {
|
||||
"Authorization": `Bearer ${this._token}`,
|
||||
};
|
||||
|
||||
console.log(url);
|
||||
|
||||
let rawResponse = await fetch(url.toString(), { method, headers });
|
||||
let response = await rawResponse.json() as D4HResponse<DataType>;
|
||||
|
||||
if (response.statusCode !== 200) {
|
||||
throw response as D4HError;
|
||||
}
|
||||
|
||||
return response.data as DataType;
|
||||
}
|
||||
|
||||
async getMany<DataType>(url: URL): Promise<DataType[]> {
|
||||
let results: DataType[] = [];
|
||||
|
||||
let offset = 0;
|
||||
while (true) {
|
||||
let urlWithOffset = new URL(url);
|
||||
urlWithOffset.searchParams.append('offset', offset.toString());
|
||||
urlWithOffset.searchParams.append('limit', this._fetchLimit.toString());
|
||||
|
||||
let newResults = await this.get<DataType[]>(urlWithOffset);
|
||||
results = results.concat(newResults);
|
||||
offset += this._fetchLimit;
|
||||
|
||||
if (newResults.length < this._fetchLimit) {
|
||||
break;
|
||||
}
|
||||
}
|
||||
|
||||
return results;
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user