cleanup

Author: Pckool

tests/api.test.ts

@@ -2,13 +2,16 @@ import { beforeEach, afterEach, describe, test, expect } from 'vitest'
 import { api, PlexusApi } from '@plexusjs/api'
 // only imported here to make sure it works in testing environment (node), not needed by user
 import 'isomorphic-fetch'
+import { PlexusError } from '@plexusjs/utils'
 
 // if(globalThis.fetch === undefined) globalThis.fetch = fetch as any as (input: RequestInfo, init?: RequestInit) => Promise<Response>;
 
 let myApi: PlexusApi
 
 beforeEach(() => {
-	myApi = api()
+	myApi = api('', {
+		abortOnTimeout: true,
+	})
 })
 describe('Testing Api Function', () => {
 	test('Send a get request to google', async () => {
@@ -87,7 +90,55 @@ describe('Testing Api Function', () => {
 			apiUsingOnResponse.post('https://google.com/this/url/doesnt/exist')
 		).rejects.toThrow()
 	})
-})
+
+	test('can set a timeout with abort', async () => {
+		// const value = state(1)
+		const apiUsingOnResponse = api('', {
+			timeout: 1000,
+			throws: true,
+			abortOnTimeout: true,
+		})
+
+		apiUsingOnResponse.options({
+			headers: {
+				custom: 'header',
+			},
+		})
+		// console.log(myApi.config)
+		expect(apiUsingOnResponse.config).toBeDefined()
+		expect(apiUsingOnResponse.config.headers).toBeDefined()
+		expect(apiUsingOnResponse.config.headers['custom']).toBe('header')
+
+		let errorOccurred = false
+
+		try {
+			await apiUsingOnResponse.post('http://httpstat.us/526?sleep=2800')
+		} catch (error) {
+			console.log(error)
+			errorOccurred = true
+		}
+		expect(errorOccurred).toBe(true)
+
+		// Wait for the sleep duration of the request endpoint
+		await new Promise((resolve) => setTimeout(resolve, 3000))
+
+		// Check if a second error is thrown
+		errorOccurred = false
+
+		try {
+			await apiUsingOnResponse.post('http://httpstat.us/526?sleep=2800')
+		} catch (error) {
+			console.log(error)
+			if (error instanceof PlexusError) {
+				// if it's a PlexusError, it means this is the timeout error
+				return
+			}
+			errorOccurred = true
+		}
+
+		expect(errorOccurred).toBe(false)
+	})
+}, 10000)
 describe("Test the API's baseURL capabilities", () => {
 	const myApi2 = api('https://google.com').setHeaders({
 		'Content-Type': 'application/json',

tests/edgecases.test.tsx

@@ -89,7 +89,7 @@ describe('Collection Relations', () => {
 	)
 
 	test('Batching race condition with selectors', () => {
-		batch(() => { })
+		batch(() => {})
 	})
 })
 

tests/efficiency.test.ts

@@ -31,7 +31,7 @@ const users1kRelated = Array.from(
 			id: randUuid(),
 			firstName: randFirstName(),
 			appointmentId: randUuid(),
-		} as UserType)
+		}) as UserType
 )
 
 const appointments1kRelated = users1kRelated.map(
@@ -41,7 +41,7 @@ const appointments1kRelated = users1kRelated.map(
 			userId: user.id,
 			date: randFutureDate().getTime(),
 			name: randBook().title,
-		} as AppointmentType)
+		}) as AppointmentType
 )
 
 // check the .cache directory for the generated data. If it doesn't exist, it will be generated. Need users1k.json, users10k.json, users10kRelated.json, appointments10kRelated.json

tests/react.test.tsx

@@ -186,7 +186,7 @@ describe('Test react integration (useDeposit)', () => {
 			const { value, save, edit } = useDeposit(
 				{ ...def },
 				{
-					onEdit(k, v) { },
+					onEdit(k, v) {},
 					onSave(payload) {
 						setVal(payload.name ?? '')
 					},

tests/timed.test.ts

@@ -37,11 +37,14 @@ describe('Ephemeral Collection data', () => {
 					expect(decayingUsers.value.length).toBe(1)
 				}, DEFAULT_DECAY_RATE + 10)
 				// and then it should decay past the decay rate
-				setTimeout(() => {
-					expect(decayingUsers.value.length).toBe(0)
-					console.log('done! Thing is decayed!')
-					resolve(true)
-				}, DEFAULT_DECAY_RATE * 2 + 10)
+				setTimeout(
+					() => {
+						expect(decayingUsers.value.length).toBe(0)
+						console.log('done! Thing is decayed!')
+						resolve(true)
+					},
+					DEFAULT_DECAY_RATE * 2 + 10
+				)
 			}),
 		{
 			timeout: DEFAULT_DECAY_RATE * 2 + 100,

tests/utils.tests.tsx

@@ -77,8 +77,8 @@ describe('Test helper functions from the utils module', () => {
 		expect(merged4).toEqual({ a: 2, b: { c: [{ d: 2, e: [4, 5, 6] }] } })
 	})
 	test('Test isAsyncFunction', () => {
-		expect(isAsyncFunction(async () => { })).toBe(true)
-		expect(isAsyncFunction(() => { })).toBe(false)
+		expect(isAsyncFunction(async () => {})).toBe(true)
+		expect(isAsyncFunction(() => {})).toBe(false)
 	})
 	test('Test convertStringToThing', () => {
 		expect(convertStringToThing('{"a":1}')).toEqual({ a: 1 })