Function makeTestClient

packages/server/test/adapter/tanstack-start.test.ts:24–78

(
    apiPath: string,
    options: TanStackStartOptions<SchemaDef>,
    qArg?: unknown,
    otherArgs?: any,
)

}

function makeTestClient(
    apiPath: string,
    options: TanStackStartOptions<SchemaDef>,
    qArg?: unknown,
    otherArgs?: any,
): TestClient {
    const pathParts = apiPath.split('/').filter((p) => p);
    const path = pathParts.join('/');

    const handler = TanStackStartHandler(options);

    const params = {
        _splat: path,
        ...otherArgs,
    };

    const buildUrl = (method: string) => {
        const baseUrl = `http://localhost${apiPath}`;
        if (method === 'GET' || method === 'DELETE') {
            const url = new URL(baseUrl);
            if (qArg) {
                url.searchParams.set('q', JSON.stringify(qArg));
            }
            if (otherArgs) {
                Object.entries(otherArgs).forEach(([key, value]) => {
                    url.searchParams.set(key, String(value));
                });
            }
            return url.toString();
        }
        return baseUrl;
    };

    const executeRequest = async (method: string, body?: any) => {
        const url = buildUrl(method);
        const request = makeRequest(method, url, body);
        const response = await handler({ request, params });
        const responseBody = await unmarshal(response);
        return {
            status: response.status,
            body: responseBody,
        };
    };

    return {
        get: async () => executeRequest('GET'),
        post: () => ({
            send: async (data: any) => executeRequest('POST', data),
        }),
        put: () => ({
            send: async (data: any) => executeRequest('PUT', data),
        }),
        del: async () => executeRequest('DELETE'),
    };
}

describe('TanStack Start adapter tests - rpc handler', () => {
    it('simple crud', async () => {