include fetch types and console-stamp

jest.config.js

@@ -1,4 +1,5 @@
 module.exports = {
   preset: 'ts-jest',
   testEnvironment: 'node',
+  setupFiles: ["<rootDir>/src/test/setup-globals.js"],
 };

package.json

@@ -7,8 +7,10 @@
     "test": "jest"
   },
   "devDependencies": {
+    "console-stamp": "3.0.6",
     "@types/jsonwebtoken": "8.5.8",
     "jsonwebtoken": "8.5.1",
+    "@types/node-fetch": "2.6.2",
     "node-fetch": "2.6.7",
     "@types/jest": "28.1.1",
     "jest": "28.1.1",

src/RaidApi.ts

@@ -1,12 +1,48 @@
-import fetch from "node-fetch";
+import fetch, {Response, RequestInfo, RequestInit} from "node-fetch";
 
 const apiBase = "https://api.raid.org.au/v1";
 
 export async function getRoot(): Promise<any> {
-  const response = await fetch(`${apiBase}/`, {
+  return await apiFetchJson(`${apiBase}/`, {
     method: "GET",
   });
-  console.log("got", response);
+}
+
+const delay = 200;
+let lastSent = new Date().getTime();
+
+/*
+I have no idea what this is going to do for parallel requests :|
+
+ IMPROVE: way too dumb, but it'll do for now
+*/
+async function apiFetchJson(
+  url: RequestInfo,
+  init?: RequestInit
+): Promise<any>{
+  const nextAllowed = lastSent + delay;
+  const now = new Date().getTime();
 
-  return "";
-}
+  if( now < nextAllowed ){
+    const sleepTime = nextAllowed - now;
+    console.log(`request rate-limit, sleep ${sleepTime}ms for ${url}`);
+    await sleep(sleepTime);
+    console.log(`request rate-limit, awake for ${url}`);
+  }
+
+  const response: Response = await fetch(url, init);
+  if( response.status === 429 ){
+    console.log("API 429", response);
+    throw new Error("API gave too many requests error");
+  }
+  if( !response.ok ){
+    console.log("API not ok", response);
+    throw new Error("API returned error - " + response.statusText);
+  }
+
+  return await response.json();
+}
+
+async function sleep(sleepMs: number){
+  return new Promise(resolve => setTimeout(resolve, sleepMs));
+}

test/Api.test.ts → src/test/Api.test.ts

@@ -1,4 +1,4 @@
-import {getRoot} from "../src/RaidApi";
+import {getRoot} from "../RaidApi";
 
 const apiBase = "https://api.raid.org.au/v1";
 
@@ -7,10 +7,6 @@ describe("RaidApi", () => {
   test("root responds 200", async () => {
     console.log("starting test");
 
-    // const response = await fetch(`${apiBase}/`, {
-    //   method: "GET",
-    // });
-
     const response = await getRoot();
     console.log("got", response);
   });

test/Empty.test.ts → src/test/Empty.test.ts

@@ -1,4 +1,4 @@
-import {doNothing} from "../src/empty";
+import {doNothing} from "../empty";
 
 describe("Empty", () => {
 

src/test/setup-globals.js

@@ -0,0 +1,5 @@
+
+// require( 'console-stamp' )( global.console );
+
+global.console = require('console');
+