starred/yaak
1
0
Fork 0
mirror of https://github.com/mountain-loop/yaak.git synced 2026-03-20 08:34:18 +01:00
Code Issues 8 Packages Projects Releases 10 Wiki Activity

Better reflect failure UI

Browse Source
This commit is contained in:
Gregory Schier
2024-02-05 14:50:47 -08:00
parent 5ad13a61e6
commit 0dc6b2d9e7
13 changed files with 584 additions and 395 deletions
Download Patch File Download Diff File Expand all files Collapse all files

41
src-web/hooks/useGrpc.ts
View File

@@ -1,9 +1,10 @@
import { useMutation, useQuery } from '@tanstack/react-query';
import { invoke } from '@tauri-apps/api';
import { emit } from '@tauri-apps/api/event';
import { useCallback } from 'react';
import type { GrpcConnection, GrpcMessage, GrpcRequest } from '../lib/models';
interface ReflectResponseService {
export interface ReflectResponseService {
name: string;
methods: { name: string; schema: string; serverStreaming: boolean; clientStreaming: boolean }[];
}
@@ -13,58 +14,46 @@ export function useGrpc(req: GrpcRequest | null, conn: GrpcConnection | null) {
const unary = useMutation<GrpcMessage, string>({
mutationKey: ['grpc_unary', conn?.id ?? 'n/a'],
mutationFn: async () => {
const message = (await invoke('cmd_grpc_call_unary', {
mutationFn: async () =>
(await invoke('cmd_grpc_call_unary', {
requestId,
})) as GrpcMessage;
return message;
},
})) as GrpcMessage,
});
const clientStreaming = useMutation<void, string>({
mutationKey: ['grpc_client_streaming', conn?.id ?? 'n/a'],
mutationFn: async () => {
await invoke('cmd_grpc_client_streaming', { requestId });
},
mutationFn: async () => await invoke('cmd_grpc_client_streaming', { requestId }),
});
const serverStreaming = useMutation<void, string>({
mutationKey: ['grpc_server_streaming', conn?.id ?? 'n/a'],
mutationFn: async () => {
await invoke('cmd_grpc_server_streaming', { requestId });
},
mutationFn: async () => await invoke('cmd_grpc_server_streaming', { requestId }),
});
const streaming = useMutation<void, string>({
mutationKey: ['grpc_streaming', conn?.id ?? 'n/a'],
mutationFn: async () => {
await invoke('cmd_grpc_streaming', { requestId });
},
mutationFn: async () => await invoke('cmd_grpc_streaming', { requestId }),
});
const send = useMutation({
mutationFn: async ({ message }: { message: string }) => {
await emit(`grpc_client_msg_${conn?.id ?? 'none'}`, { Message: message });
},
mutationFn: async ({ message }: { message: string }) =>
await emit(`grpc_client_msg_${conn?.id ?? 'none'}`, { Message: message }),
});
const cancel = useMutation({
mutationKey: ['grpc_cancel', conn?.id ?? 'n/a'],
mutationFn: async () => {
await emit(`grpc_client_msg_${conn?.id ?? 'none'}`, 'Cancel');
},
mutationFn: async () => await emit(`grpc_client_msg_${conn?.id ?? 'none'}`, 'Cancel'),
});
const commit = useMutation({
mutationKey: ['grpc_commit', conn?.id ?? 'n/a'],
mutationFn: async () => {
await emit(`grpc_client_msg_${conn?.id ?? 'none'}`, 'Commit');
},
mutationFn: async () => await emit(`grpc_client_msg_${conn?.id ?? 'none'}`, 'Commit'),
});
const reflect = useQuery<ReflectResponseService[]>({
queryKey: ['grpc_reflect', conn?.id ?? 'n/a'],
queryKey: ['grpc_reflect', req?.url ?? 'n/a'],
queryFn: async () => {
await new Promise((resolve) => setTimeout(resolve, 1000));
return (await invoke('cmd_grpc_reflect', { requestId })) as ReflectResponseService[];
},
});
@@ -74,7 +63,7 @@ export function useGrpc(req: GrpcRequest | null, conn: GrpcConnection | null) {
clientStreaming,
serverStreaming,
streaming,
services: reflect.data,
reflect,
cancel,
commit,
isStreaming: conn?.elapsed === 0,