mirror of
https://github.com/Kong/insomnia
synced 2024-11-07 22:30:15 +00:00
e3caa557be
* client cert ui * first pass * use import to avoid url onChange timing issue * re order test * use 4001 port, refresh certs * move test to critical * expose cacert create over maain
119 lines
3.5 KiB
TypeScript
119 lines
3.5 KiB
TypeScript
import crypto from 'node:crypto';
|
|
|
|
import express from 'express';
|
|
import { readFileSync } from 'fs';
|
|
import { createHandler } from 'graphql-http/lib/use/http';
|
|
import { createServer } from 'https';
|
|
import { join } from 'path';
|
|
|
|
import { basicAuthRouter } from './basic-auth';
|
|
import githubApi from './github-api';
|
|
import gitlabApi from './gitlab-api';
|
|
import { schema } from './graphql';
|
|
import { startGRPCServer } from './grpc';
|
|
import insomniaApi from './insomnia-api';
|
|
import { oauthRoutes } from './oauth';
|
|
import { startWebSocketServer } from './websocket';
|
|
|
|
const app = express();
|
|
const port = 4010;
|
|
const httpsPort = 4011;
|
|
const grpcPort = 50051;
|
|
|
|
app.get('/pets/:id', (req, res) => {
|
|
res.status(200).send({ id: req.params.id });
|
|
});
|
|
|
|
app.get('/builds/check/*', (_req, res) => {
|
|
res.status(200).send({
|
|
url: 'https://github.com/Kong/insomnia/releases/download/core@2023.5.6/Insomnia.Core-2023.5.6.zip',
|
|
name: '2099.1.0',
|
|
});
|
|
});
|
|
|
|
app.get('/sleep', (_req, res) => {
|
|
res.status(200).send({ sleep: true });
|
|
});
|
|
|
|
app.get('/cookies', (_req, res) => {
|
|
res
|
|
.status(200)
|
|
.header('content-type', 'text/plain')
|
|
.cookie('insomnia-test-cookie', 'value123')
|
|
.send(`${_req.headers['cookie']}`);
|
|
});
|
|
|
|
app.use('/file', express.static('fixtures/files'));
|
|
app.use('/auth/basic', basicAuthRouter);
|
|
|
|
githubApi(app);
|
|
gitlabApi(app);
|
|
insomniaApi(app);
|
|
|
|
app.get('/delay/seconds/:duration', (req, res) => {
|
|
const delaySec = Number.parseInt(req.params.duration || '2');
|
|
setTimeout(() => {
|
|
res.send(`Delayed by ${delaySec} seconds`);
|
|
}, delaySec * 1000);
|
|
});
|
|
|
|
app.use('/oidc', oauthRoutes(port));
|
|
|
|
app.get('/', (_req, res) => {
|
|
res.status(200).send();
|
|
});
|
|
|
|
app.all('/graphql', createHandler({ schema }));
|
|
|
|
app.use(express.json()); // Used to parse JSON bodies
|
|
|
|
// SSE routes
|
|
let subscribers: { id: string; response: express.Response }[] = [];
|
|
app.get('/events', (request, response) => {
|
|
const headers = {
|
|
'Content-Type': 'text/event-stream',
|
|
'Connection': 'keep-alive',
|
|
'Cache-Control': 'no-cache',
|
|
};
|
|
response.writeHead(200, headers);
|
|
const subscriberId = crypto.randomUUID();
|
|
const data = `data: ${JSON.stringify({ id: subscriberId })}\n\n`;
|
|
response.write(data);
|
|
const subscriber = {
|
|
id: subscriberId,
|
|
response,
|
|
};
|
|
subscribers.push(subscriber);
|
|
setInterval(() => {
|
|
// const id = subscriberId;
|
|
const data = JSON.stringify({ message: 'Time: ' + new Date().toISOString().slice(11, 19) });
|
|
// response.write('id: ' + id + '\n');
|
|
response.write('data: ' + data + '\n\n');
|
|
}, 1000);
|
|
request.on('close', () => {
|
|
console.log(`${subscriberId} Connection closed`);
|
|
subscribers = subscribers.filter(sub => sub.id !== subscriberId);
|
|
});
|
|
});
|
|
app.post('/send-event', (request, response) => {
|
|
// Requires middleware to parse JSON body
|
|
console.log('Received event', request.body);
|
|
subscribers.forEach(subscriber => subscriber.response.write(`data: ${JSON.stringify(request.body)}\n\n`));
|
|
response.json({ success: true });
|
|
});
|
|
|
|
startWebSocketServer(app.listen(port, () => {
|
|
console.log(`Listening at http://localhost:${port}`);
|
|
console.log(`Listening at ws://localhost:${port}`);
|
|
}));
|
|
|
|
startWebSocketServer(createServer({
|
|
cert: readFileSync(join(__dirname, '../fixtures/certificates/localhost.pem')),
|
|
key: readFileSync(join(__dirname, '../fixtures/certificates/localhost-key.pem')),
|
|
}, app).listen(httpsPort, () => {
|
|
console.log(`Listening at https://localhost:${httpsPort}`);
|
|
console.log(`Listening at wss://localhost:${httpsPort}`);
|
|
}));
|
|
|
|
startGRPCServer(grpcPort);
|