mirror of
https://github.com/mountain-loop/yaak.git
synced 2025-12-23 22:48:55 -05:00
187 lines
6.7 KiB
TypeScript
187 lines
6.7 KiB
TypeScript
import { open } from '@tauri-apps/plugin-dialog';
|
|
import type { GrpcRequest } from '@yaakapp-internal/models';
|
|
import { useActiveRequest } from '../hooks/useActiveRequest';
|
|
import { useGrpc } from '../hooks/useGrpc';
|
|
import { useGrpcProtoFiles } from '../hooks/useGrpcProtoFiles';
|
|
import { pluralizeCount } from '../lib/pluralize';
|
|
import { Banner } from './core/Banner';
|
|
import { Button } from './core/Button';
|
|
import { Icon } from './core/Icon';
|
|
import { IconButton } from './core/IconButton';
|
|
import { InlineCode } from './core/InlineCode';
|
|
import { Link } from './core/Link';
|
|
import { HStack, VStack } from './core/Stacks';
|
|
|
|
interface Props {
|
|
onDone: () => void;
|
|
}
|
|
|
|
export function GrpcProtoSelectionDialog(props: Props) {
|
|
const request = useActiveRequest();
|
|
if (request?.model !== 'grpc_request') return null;
|
|
|
|
return <GrpcProtoSelectionDialogWithRequest request={request} {...props} />;
|
|
}
|
|
|
|
function GrpcProtoSelectionDialogWithRequest({ request }: Props & { request: GrpcRequest }) {
|
|
const protoFilesKv = useGrpcProtoFiles(request.id);
|
|
const protoFiles = protoFilesKv.value ?? [];
|
|
const grpc = useGrpc(request, null, protoFiles);
|
|
const services = grpc.reflect.data;
|
|
const serverReflection = protoFiles.length === 0 && services != null;
|
|
let reflectError = grpc.reflect.error ?? null;
|
|
const reflectionUnimplemented = `${reflectError}`.match(/unimplemented/i);
|
|
|
|
if (reflectionUnimplemented) {
|
|
reflectError = null;
|
|
}
|
|
|
|
if (request == null) {
|
|
return null;
|
|
}
|
|
|
|
return (
|
|
<VStack className="flex-col-reverse mb-3" space={3}>
|
|
{/* Buttons on top so they get focus first */}
|
|
<HStack space={2} justifyContent="start" className="flex-row-reverse mt-3">
|
|
<Button
|
|
color="primary"
|
|
variant="border"
|
|
onClick={async () => {
|
|
const selected = await open({
|
|
title: 'Select Proto Files',
|
|
multiple: true,
|
|
filters: [{ name: 'Proto Files', extensions: ['proto'] }],
|
|
});
|
|
if (selected == null) return;
|
|
|
|
const newFiles = selected.filter((p) => !protoFiles.includes(p));
|
|
await protoFilesKv.set([...protoFiles, ...newFiles]);
|
|
await grpc.reflect.refetch();
|
|
}}
|
|
>
|
|
Add Proto Files
|
|
</Button>
|
|
<Button
|
|
variant="border"
|
|
color="primary"
|
|
onClick={async () => {
|
|
const selected = await open({
|
|
title: 'Select Proto Directory',
|
|
directory: true,
|
|
});
|
|
if (selected == null) return;
|
|
|
|
await protoFilesKv.set([...protoFiles.filter((f) => f !== selected), selected]);
|
|
await grpc.reflect.refetch();
|
|
}}
|
|
>
|
|
Add Import Folders
|
|
</Button>
|
|
<Button
|
|
isLoading={grpc.reflect.isFetching}
|
|
disabled={grpc.reflect.isFetching}
|
|
variant="border"
|
|
color="secondary"
|
|
onClick={() => grpc.reflect.refetch()}
|
|
>
|
|
Refresh Schema
|
|
</Button>
|
|
</HStack>
|
|
<VStack space={5}>
|
|
{reflectError && (
|
|
<Banner color="warning">
|
|
<h1 className="font-bold">
|
|
Reflection failed on URL <InlineCode>{request.url || 'n/a'}</InlineCode>
|
|
</h1>
|
|
<p>{reflectError.trim()}</p>
|
|
</Banner>
|
|
)}
|
|
{!serverReflection && services != null && services.length > 0 && (
|
|
<Banner className="flex flex-col gap-2">
|
|
<p>
|
|
Found services{' '}
|
|
{services?.slice(0, 5).map((s, i) => {
|
|
return (
|
|
<span key={s.name + s.methods.join(',')}>
|
|
<InlineCode>{s.name}</InlineCode>
|
|
{i === services.length - 1 ? '' : i === services.length - 2 ? ' and ' : ', '}
|
|
</span>
|
|
);
|
|
})}
|
|
{services?.length > 5 && pluralizeCount('other', services?.length - 5)}
|
|
</p>
|
|
</Banner>
|
|
)}
|
|
{serverReflection && services != null && services.length > 0 && (
|
|
<Banner className="flex flex-col gap-2">
|
|
<p>
|
|
Server reflection found services
|
|
{services?.map((s, i) => {
|
|
return (
|
|
<span key={s.name + s.methods.join(',')}>
|
|
<InlineCode>{s.name}</InlineCode>
|
|
{i === services.length - 1 ? '' : i === services.length - 2 ? ' and ' : ', '}
|
|
</span>
|
|
);
|
|
})}
|
|
. You can override this schema by manually selecting <InlineCode>*.proto</InlineCode>{' '}
|
|
files.
|
|
</p>
|
|
</Banner>
|
|
)}
|
|
|
|
{protoFiles.length > 0 && (
|
|
<table className="w-full divide-y divide-surface-highlight">
|
|
<thead>
|
|
<tr>
|
|
<th className="text-text-subtlest" colSpan={3}>
|
|
Added File Paths
|
|
</th>
|
|
</tr>
|
|
</thead>
|
|
<tbody className="divide-y divide-surface-highlight">
|
|
{protoFiles.map((f, i) => {
|
|
const parts = f.split('/');
|
|
return (
|
|
// biome-ignore lint/suspicious/noArrayIndexKey: none
|
|
<tr key={f + i} className="group">
|
|
<td>
|
|
<Icon icon={f.endsWith('.proto') ? 'file_code' : 'folder_code'} />
|
|
</td>
|
|
<td className="pl-1 font-mono text-sm" title={f}>
|
|
{parts.length > 3 && '.../'}
|
|
{parts.slice(-3).join('/')}
|
|
</td>
|
|
<td className="w-0 py-0.5">
|
|
<IconButton
|
|
title="Remove file"
|
|
variant="border"
|
|
size="xs"
|
|
icon="trash"
|
|
className="my-0.5 ml-auto opacity-50 transition-opacity group-hover:opacity-100"
|
|
onClick={async () => {
|
|
await protoFilesKv.set(protoFiles.filter((p) => p !== f));
|
|
}}
|
|
/>
|
|
</td>
|
|
</tr>
|
|
);
|
|
})}
|
|
</tbody>
|
|
</table>
|
|
)}
|
|
{reflectionUnimplemented && protoFiles.length === 0 && (
|
|
<Banner>
|
|
<InlineCode>{request.url}</InlineCode> doesn't implement{' '}
|
|
<Link href="https://github.com/grpc/grpc/blob/9aa3c5835a4ed6afae9455b63ed45c761d695bca/doc/server-reflection.md">
|
|
Server Reflection
|
|
</Link>{' '}
|
|
. Please manually add the <InlineCode>.proto</InlineCode> file to get started.
|
|
</Banner>
|
|
)}
|
|
</VStack>
|
|
</VStack>
|
|
);
|
|
}
|