mirror of
https://github.com/usebruno/bruno.git
synced 2026-06-11 09:51:30 +00:00
0a9988f80d
* feat: add gRPC proxy support * fix: respect channelOptions grpc.primary_user_agent over User-Agent header * fix: remove non-standard grpc_proxy/no_grpc_proxy env var support These are not recognized by any standard gRPC implementation. gRPC proxy now uses the standard http_proxy/https_proxy/no_proxy variables like grpc-core, grpc-go, and grpc-java. * chore: add resolveGrpcProxyConfig tests and clean up grpc-client Export resolveGrpcProxyConfig for testability and add unit tests covering all proxy modes (off, on, system), auth encoding, protocol rejection, bypass lists, and edge cases. Remove redundant cancelAndCloseConnection call in startConnection (already guarded by addConnection). Document why internal @grpc/grpc-js channel options are used for programmatic proxy.
299 lines
14 KiB
TypeScript
299 lines
14 KiB
TypeScript
import { test, expect } from '../../../playwright';
|
|
import { buildGrpcCommonLocators } from '../../utils/page/locators';
|
|
|
|
const saveShortcut = process.platform === 'darwin' ? 'Meta+s' : 'Control+s';
|
|
|
|
test.describe('make grpc requests', () => {
|
|
const setupGrpcTest = async (page) => {
|
|
const locators = buildGrpcCommonLocators(page);
|
|
|
|
await test.step('navigate to gRPC collection', async () => {
|
|
await locators.sidebar.collection('Grpcbin').click();
|
|
await locators.sidebar.folder('HelloService').click();
|
|
});
|
|
|
|
await test.step('select environment', async () => {
|
|
await locators.environment.selector().click();
|
|
await locators.environment.collectionTab().click();
|
|
await locators.environment.envOption('Env').click();
|
|
});
|
|
};
|
|
|
|
test('make unary request', async ({ pageWithUserData: page }) => {
|
|
await setupGrpcTest(page);
|
|
const locators = buildGrpcCommonLocators(page);
|
|
|
|
await test.step('select unary method', async () => {
|
|
await locators.sidebar.request('SayHello').click();
|
|
await expect(locators.method.dropdownTrigger()).toContainText('HelloService/SayHello', { timeout: 30000 });
|
|
});
|
|
|
|
await test.step('verify gRPC unary request is opened successfully', async () => {
|
|
await expect(locators.method.indicator()).toContainText('gRPC');
|
|
await expect(locators.request.queryUrlContainer().locator('.CodeMirror')).toBeVisible();
|
|
await expect(locators.request.sendButton()).toBeVisible();
|
|
await expect(locators.request.messagesContainer()).toBeVisible();
|
|
});
|
|
|
|
await test.step('send request', async () => {
|
|
await locators.request.sendButton().click();
|
|
await expect(locators.response.statusCode()).toBeVisible({ timeout: 2000 });
|
|
await expect(locators.response.statusText()).toBeVisible({ timeout: 2000 });
|
|
await expect(locators.response.statusCode()).toHaveText(/0/);
|
|
await expect(locators.response.statusText()).toHaveText(/OK/);
|
|
});
|
|
|
|
await test.step('verify response message count', async () => {
|
|
await expect(locators.response.tabCount()).toHaveText('1');
|
|
});
|
|
|
|
await test.step('verify response items are rendered', async () => {
|
|
await expect(locators.response.content()).toBeVisible();
|
|
await expect(locators.response.container()).toBeVisible();
|
|
await expect(locators.response.singleResponse()).toBeVisible();
|
|
});
|
|
|
|
/* TODO: Reflection fetching incorrectly marks requests as modified, causing save indicators to appear. This save step prevents test timeouts by clearing the modified state. This is a temporary workaround until the reflection fetching issue is resolved. */
|
|
await test.step('save request via shortcut', async () => {
|
|
await page.keyboard.press(saveShortcut);
|
|
});
|
|
});
|
|
|
|
test('make server streaming request', async ({ pageWithUserData: page }) => {
|
|
await setupGrpcTest(page);
|
|
const locators = buildGrpcCommonLocators(page);
|
|
|
|
await test.step('select server streaming method', async () => {
|
|
await locators.sidebar.request('LotOfReplies').click();
|
|
await expect(locators.method.dropdownTrigger()).toContainText('HelloService/LotsOfReplies');
|
|
});
|
|
|
|
await test.step('verify gRPC server streaming request is opened successfully', async () => {
|
|
await expect(locators.method.indicator()).toContainText('gRPC');
|
|
await expect(locators.request.queryUrlContainer().locator('.CodeMirror')).toBeVisible();
|
|
await expect(locators.request.messagesContainer()).toBeVisible();
|
|
await expect(locators.request.sendButton()).toBeVisible();
|
|
});
|
|
|
|
await test.step('send request', async () => {
|
|
await locators.request.sendButton().click();
|
|
await expect(locators.response.statusCode()).toBeVisible({ timeout: 2000 });
|
|
await expect(locators.response.statusText()).toBeVisible({ timeout: 2000 });
|
|
await expect(locators.response.statusCode()).toHaveText(/0/);
|
|
await expect(locators.response.statusText()).toHaveText(/OK/);
|
|
});
|
|
|
|
await test.step('verify response message count', async () => {
|
|
await expect(locators.response.tabCount()).toHaveText('10');
|
|
});
|
|
|
|
await test.step('verify response items are rendered', async () => {
|
|
await expect(locators.response.content()).toBeVisible();
|
|
await expect(locators.response.container()).toBeVisible();
|
|
await expect(locators.response.list()).toBeVisible();
|
|
await expect(locators.response.responseItems()).toHaveCount(10);
|
|
});
|
|
|
|
/* TODO: Reflection fetching incorrectly marks requests as modified, causing save indicators to appear. This save step prevents test timeouts by clearing the modified state. This is a temporary workaround until the reflection fetching issue is resolved. */
|
|
await test.step('save request via shortcut', async () => {
|
|
await page.keyboard.press(saveShortcut);
|
|
});
|
|
});
|
|
|
|
test('make client streaming request', async ({ pageWithUserData: page }) => {
|
|
await setupGrpcTest(page);
|
|
const locators = buildGrpcCommonLocators(page);
|
|
|
|
await test.step('select client streaming method', async () => {
|
|
await locators.sidebar.request('LotOfGreetings').click();
|
|
await expect(locators.method.dropdownTrigger()).toContainText('HelloService/LotsOfGreetings');
|
|
});
|
|
|
|
await test.step('verify gRPC client streaming request is opened successfully', async () => {
|
|
await expect(locators.request.queryUrlContainer().locator('.CodeMirror')).toBeVisible();
|
|
await expect(locators.request.messagesContainer()).toBeVisible();
|
|
await expect(locators.request.addMessageButton()).toBeVisible();
|
|
await expect(locators.request.sendMessage(0)).toBeVisible();
|
|
await expect(locators.request.sendButton()).toBeVisible();
|
|
});
|
|
|
|
await test.step('start client streaming connection', async () => {
|
|
await locators.request.sendButton().click();
|
|
await expect(locators.request.endConnectionButton()).toBeVisible();
|
|
await expect(locators.request.cancelConnectionButton()).toBeVisible();
|
|
});
|
|
|
|
await test.step('send individual message', async () => {
|
|
await locators.request.sendMessage(0).click();
|
|
});
|
|
|
|
await test.step('end client streaming connection', async () => {
|
|
await locators.request.endConnectionButton().click();
|
|
await expect(locators.response.statusCode()).toBeVisible({ timeout: 2000 });
|
|
await expect(locators.response.statusText()).toBeVisible({ timeout: 2000 });
|
|
await expect(locators.response.statusCode()).toHaveText(/0/);
|
|
await expect(locators.response.statusText()).toHaveText(/OK/);
|
|
});
|
|
|
|
await test.step('verify connection is closed after end', async () => {
|
|
await expect(locators.request.endConnectionButton()).not.toBeVisible();
|
|
await expect(locators.request.cancelConnectionButton()).not.toBeVisible();
|
|
await expect(locators.request.sendButton()).toBeVisible();
|
|
});
|
|
|
|
await test.step('verify response message count', async () => {
|
|
await expect(locators.response.tabCount()).toHaveText('1');
|
|
});
|
|
|
|
await test.step('verify response items are rendered', async () => {
|
|
await expect(locators.response.content()).toBeVisible();
|
|
await expect(locators.response.container()).toBeVisible();
|
|
await expect(locators.response.singleResponse()).toBeVisible();
|
|
});
|
|
|
|
/* TODO: Reflection fetching incorrectly marks requests as modified, causing save indicators to appear. This save step prevents test timeouts by clearing the modified state. This is a temporary workaround until the reflection fetching issue is resolved. */
|
|
await test.step('save request via shortcut', async () => {
|
|
await page.keyboard.press(saveShortcut);
|
|
});
|
|
});
|
|
|
|
test('make bidi streaming request', async ({ pageWithUserData: page }) => {
|
|
await setupGrpcTest(page);
|
|
const locators = buildGrpcCommonLocators(page);
|
|
|
|
await test.step('select bidirectional streaming method', async () => {
|
|
await locators.sidebar.request('BidiHello').click();
|
|
await expect(locators.method.dropdownTrigger()).toContainText('HelloService/BidiHello');
|
|
});
|
|
|
|
await test.step('verify gRPC bidi streaming request is opened successfully', async () => {
|
|
await expect(locators.request.queryUrlContainer().locator('.CodeMirror')).toBeVisible();
|
|
await expect(locators.request.messagesContainer()).toBeVisible();
|
|
await expect(locators.request.addMessageButton()).toBeVisible();
|
|
await expect(locators.request.sendMessage(0)).toBeVisible();
|
|
await expect(locators.request.sendButton()).toBeVisible();
|
|
});
|
|
|
|
await test.step('start bidirectional streaming connection', async () => {
|
|
await locators.request.sendButton().click();
|
|
await expect(locators.request.endConnectionButton()).toBeVisible();
|
|
await expect(locators.request.cancelConnectionButton()).toBeVisible();
|
|
});
|
|
|
|
await test.step('send individual message', async () => {
|
|
await locators.request.sendMessage(0).click();
|
|
await locators.request.sendMessage(1).click();
|
|
});
|
|
|
|
await test.step('end bidirectional streaming connection', async () => {
|
|
await locators.request.endConnectionButton().click();
|
|
await expect(locators.response.statusCode()).toBeVisible({ timeout: 2000 });
|
|
await expect(locators.response.statusText()).toBeVisible({ timeout: 2000 });
|
|
await expect(locators.response.statusCode()).toHaveText(/0/);
|
|
await expect(locators.response.statusText()).toHaveText(/OK/);
|
|
});
|
|
|
|
await test.step('verify connection is closed after end', async () => {
|
|
await expect(locators.request.endConnectionButton()).not.toBeVisible();
|
|
await expect(locators.request.cancelConnectionButton()).not.toBeVisible();
|
|
await expect(locators.request.sendButton()).toBeVisible();
|
|
});
|
|
|
|
await test.step('verify response message count', async () => {
|
|
await expect(locators.response.tabCount()).toHaveText('2');
|
|
});
|
|
|
|
await test.step('verify response items are rendered', async () => {
|
|
await expect(locators.response.content()).toBeVisible();
|
|
await expect(locators.response.container()).toBeVisible();
|
|
await expect(locators.response.list()).toBeVisible();
|
|
await expect(locators.response.responseItems()).toHaveCount(2);
|
|
});
|
|
|
|
/* TODO: Reflection fetching incorrectly marks requests as modified, causing save indicators to appear. This save step prevents test timeouts by clearing the modified state. This is a temporary workaround until the reflection fetching issue is resolved. */
|
|
await test.step('save request via shortcut', async () => {
|
|
await page.keyboard.press(saveShortcut);
|
|
});
|
|
});
|
|
|
|
test('cancel client streaming request', async ({ pageWithUserData: page }) => {
|
|
await setupGrpcTest(page);
|
|
const locators = buildGrpcCommonLocators(page);
|
|
|
|
await test.step('select client streaming method', async () => {
|
|
await locators.sidebar.request('LotOfGreetings').click();
|
|
await expect(locators.method.dropdownTrigger()).toContainText('HelloService/LotsOfGreetings');
|
|
});
|
|
|
|
await test.step('start client streaming connection', async () => {
|
|
await locators.request.sendButton().click();
|
|
await expect(locators.request.endConnectionButton()).toBeVisible();
|
|
await expect(locators.request.cancelConnectionButton()).toBeVisible();
|
|
});
|
|
|
|
await test.step('cancel the connection', async () => {
|
|
await locators.request.cancelConnectionButton().click();
|
|
});
|
|
|
|
await test.step('verify connection is cancelled', async () => {
|
|
await expect(locators.response.statusCode()).toBeVisible({ timeout: 5000 });
|
|
await expect(locators.response.statusText()).toBeVisible();
|
|
await expect(locators.response.statusCode()).toHaveText(/1/);
|
|
await expect(locators.response.statusText()).toHaveText(/CANCELLED/);
|
|
});
|
|
|
|
await test.step('verify connection controls are reset', async () => {
|
|
await expect(locators.request.endConnectionButton()).not.toBeVisible();
|
|
await expect(locators.request.cancelConnectionButton()).not.toBeVisible();
|
|
await expect(locators.request.sendButton()).toBeVisible();
|
|
});
|
|
|
|
/* TODO: Reflection fetching incorrectly marks requests as modified, causing save indicators to appear. This save step prevents test timeouts by clearing the modified state. This is a temporary workaround until the reflection fetching issue is resolved. */
|
|
await test.step('save request via shortcut', async () => {
|
|
await page.keyboard.press(saveShortcut);
|
|
});
|
|
});
|
|
|
|
test('cancel bidi streaming request', async ({ pageWithUserData: page }) => {
|
|
await setupGrpcTest(page);
|
|
const locators = buildGrpcCommonLocators(page);
|
|
|
|
await test.step('select bidirectional streaming method', async () => {
|
|
await locators.sidebar.request('BidiHello').click();
|
|
await expect(locators.method.dropdownTrigger()).toContainText('HelloService/BidiHello');
|
|
});
|
|
|
|
await test.step('start bidirectional streaming connection', async () => {
|
|
await locators.request.sendButton().click();
|
|
await expect(locators.request.endConnectionButton()).toBeVisible();
|
|
await expect(locators.request.cancelConnectionButton()).toBeVisible();
|
|
});
|
|
|
|
await test.step('send a message before cancelling', async () => {
|
|
await locators.request.sendMessage(0).click();
|
|
});
|
|
|
|
await test.step('cancel the connection', async () => {
|
|
await locators.request.cancelConnectionButton().click();
|
|
});
|
|
|
|
await test.step('verify connection is cancelled', async () => {
|
|
await expect(locators.response.statusCode()).toBeVisible({ timeout: 5000 });
|
|
await expect(locators.response.statusText()).toBeVisible();
|
|
await expect(locators.response.statusCode()).toHaveText(/1/);
|
|
await expect(locators.response.statusText()).toHaveText(/CANCELLED/);
|
|
});
|
|
|
|
await test.step('verify connection controls are reset', async () => {
|
|
await expect(locators.request.endConnectionButton()).not.toBeVisible();
|
|
await expect(locators.request.cancelConnectionButton()).not.toBeVisible();
|
|
await expect(locators.request.sendButton()).toBeVisible();
|
|
});
|
|
|
|
/* TODO: Reflection fetching incorrectly marks requests as modified, causing save indicators to appear. This save step prevents test timeouts by clearing the modified state. This is a temporary workaround until the reflection fetching issue is resolved. */
|
|
await test.step('save request via shortcut', async () => {
|
|
await page.keyboard.press(saveShortcut);
|
|
});
|
|
});
|
|
});
|