/
request-introspection-query.ts
73 lines (61 loc) · 2.07 KB
/
request-introspection-query.ts
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
import { parse } from 'node:url';
import Http from 'node:http';
import Https from 'node:https';
import { buildClientSchema, getIntrospectionQuery, type GraphQLSchema } from 'graphql';
const INTROSPECTION_QUERY_BODY = JSON.stringify({
query: getIntrospectionQuery(),
});
const INTROSPECTION_QUERY_LENGTH = Buffer.byteLength(INTROSPECTION_QUERY_BODY);
export interface RequestSetup {
url: string;
method?: string;
headers?: { [key: string]: string };
}
export function isRequestSetup(requestSetup: RequestSetup | any): requestSetup is RequestSetup {
const availablePropertyNames = ['url', 'method', 'headers'];
for (const property in requestSetup) {
if (!availablePropertyNames.includes(property)) {
return false;
}
}
return !!requestSetup.url;
}
export function requestIntrospectionQuery(options: RequestSetup) {
const headers: { [key: string]: string | number } = {
'Content-Type': 'application/json',
'Content-Length': INTROSPECTION_QUERY_LENGTH,
'User-Agent': 'ts-graphql-plugin',
...options.headers,
};
return new Promise<GraphQLSchema>((resolve, reject) => {
const uri = parse(options.url);
const { method = 'POST' } = options;
const { hostname, protocol, path } = uri;
const port = uri.port && Number.parseInt(uri.port, 10);
const reqParam = { hostname, protocol, path, port, headers, method };
const requester = protocol === 'https:' ? Https.request : Http.request;
let body = '';
const req = requester(reqParam, res => {
res.on('data', chunk => (body += chunk));
res.on('end', () => {
if (!res.statusCode || res.statusCode < 200 || res.statusCode > 300) {
reject({
statusCode: res.statusCode,
body,
});
} else {
let result: any;
try {
result = JSON.parse(body);
resolve(buildClientSchema(result.data));
} catch (e) {
reject(e);
}
}
});
});
req.on('error', reason => reject(reason));
req.write(INTROSPECTION_QUERY_BODY);
req.end();
});
}