mirror of
https://github.com/mountain-loop/yaak.git
synced 2026-04-01 06:53:11 +02:00
Implement request deletion
This commit is contained in:
@@ -186,6 +186,16 @@
|
|||||||
},
|
},
|
||||||
"query": "\n INSERT INTO http_requests (id, workspace_id, name, url, method, body, headers, updated_at)\n VALUES (?, ?, ?, ?, ?, ?, ?, CURRENT_TIMESTAMP)\n ON CONFLICT (id) DO UPDATE SET\n updated_at = CURRENT_TIMESTAMP,\n name = excluded.name,\n method = excluded.method,\n body = excluded.body,\n url = excluded.url\n "
|
"query": "\n INSERT INTO http_requests (id, workspace_id, name, url, method, body, headers, updated_at)\n VALUES (?, ?, ?, ?, ?, ?, ?, CURRENT_TIMESTAMP)\n ON CONFLICT (id) DO UPDATE SET\n updated_at = CURRENT_TIMESTAMP,\n name = excluded.name,\n method = excluded.method,\n body = excluded.body,\n url = excluded.url\n "
|
||||||
},
|
},
|
||||||
|
"448a1d1f1866ab42c0f81fcf8eb2930bf21dfdd43ca4831bc1a198cf45ac3732": {
|
||||||
|
"describe": {
|
||||||
|
"columns": [],
|
||||||
|
"nullable": [],
|
||||||
|
"parameters": {
|
||||||
|
"Right": 1
|
||||||
|
}
|
||||||
|
},
|
||||||
|
"query": "\n DELETE FROM http_requests\n WHERE id = ?\n "
|
||||||
|
},
|
||||||
"55eae4b20a2c313134579b0ea43bad4dc2dd313db6cd1654f783bac12602db8a": {
|
"55eae4b20a2c313134579b0ea43bad4dc2dd313db6cd1654f783bac12602db8a": {
|
||||||
"describe": {
|
"describe": {
|
||||||
"columns": [
|
"columns": [
|
||||||
|
|||||||
@@ -193,6 +193,21 @@ async fn update_request(
|
|||||||
Ok(())
|
Ok(())
|
||||||
}
|
}
|
||||||
|
|
||||||
|
#[tauri::command]
|
||||||
|
async fn delete_request(
|
||||||
|
app_handle: AppHandle<Wry>,
|
||||||
|
db_instance: State<'_, Mutex<Pool<Sqlite>>>,
|
||||||
|
request_id: &str,
|
||||||
|
) -> Result<models::HttpRequest, String> {
|
||||||
|
let pool = &*db_instance.lock().await;
|
||||||
|
let req = models::delete_request(request_id, pool)
|
||||||
|
.await
|
||||||
|
.expect("Failed to delete request");
|
||||||
|
app_handle.emit_all("deleted_request", request_id).unwrap();
|
||||||
|
|
||||||
|
Ok(req)
|
||||||
|
}
|
||||||
|
|
||||||
#[tauri::command]
|
#[tauri::command]
|
||||||
async fn requests(
|
async fn requests(
|
||||||
workspace_id: &str,
|
workspace_id: &str,
|
||||||
@@ -324,6 +339,7 @@ fn main() {
|
|||||||
send_request,
|
send_request,
|
||||||
create_request,
|
create_request,
|
||||||
update_request,
|
update_request,
|
||||||
|
delete_request,
|
||||||
responses,
|
responses,
|
||||||
delete_response,
|
delete_response,
|
||||||
delete_all_responses,
|
delete_all_responses,
|
||||||
|
|||||||
@@ -187,6 +187,23 @@ pub async fn get_request(id: &str, pool: &Pool<Sqlite>) -> Result<HttpRequest, s
|
|||||||
.await
|
.await
|
||||||
}
|
}
|
||||||
|
|
||||||
|
pub async fn delete_request(id: &str, pool: &Pool<Sqlite>) -> Result<HttpRequest, sqlx::Error> {
|
||||||
|
let req = get_request(id, pool)
|
||||||
|
.await
|
||||||
|
.expect("Failed to get request to delete");
|
||||||
|
let _ = sqlx::query!(
|
||||||
|
r#"
|
||||||
|
DELETE FROM http_requests
|
||||||
|
WHERE id = ?
|
||||||
|
"#,
|
||||||
|
id,
|
||||||
|
)
|
||||||
|
.execute(pool)
|
||||||
|
.await;
|
||||||
|
|
||||||
|
Ok(req)
|
||||||
|
}
|
||||||
|
|
||||||
pub async fn create_response(
|
pub async fn create_response(
|
||||||
request_id: &str,
|
request_id: &str,
|
||||||
elapsed: i64,
|
elapsed: i64,
|
||||||
|
|||||||
@@ -6,8 +6,14 @@ import { Sidebar } from './components/Sidebar';
|
|||||||
import { UrlBar } from './components/UrlBar';
|
import { UrlBar } from './components/UrlBar';
|
||||||
import { Grid } from './components/Grid';
|
import { Grid } from './components/Grid';
|
||||||
import { useParams } from 'react-router-dom';
|
import { useParams } from 'react-router-dom';
|
||||||
import { useRequests, useRequestUpdate, useSendRequest } from './hooks/useRequest';
|
import {
|
||||||
|
useDeleteRequest,
|
||||||
|
useRequests,
|
||||||
|
useRequestUpdate,
|
||||||
|
useSendRequest,
|
||||||
|
} from './hooks/useRequest';
|
||||||
import { ResponsePane } from './components/ResponsePane';
|
import { ResponsePane } from './components/ResponsePane';
|
||||||
|
import { IconButton } from './components/IconButton';
|
||||||
|
|
||||||
type Params = {
|
type Params = {
|
||||||
workspaceId: string;
|
workspaceId: string;
|
||||||
@@ -22,6 +28,7 @@ function App() {
|
|||||||
|
|
||||||
const updateRequest = useRequestUpdate(request ?? null);
|
const updateRequest = useRequestUpdate(request ?? null);
|
||||||
const sendRequest = useSendRequest(request ?? null);
|
const sendRequest = useSendRequest(request ?? null);
|
||||||
|
const deleteRequest = useDeleteRequest(request ?? null);
|
||||||
|
|
||||||
useEffect(() => {
|
useEffect(() => {
|
||||||
const listener = async (e: KeyboardEvent) => {
|
const listener = async (e: KeyboardEvent) => {
|
||||||
@@ -41,6 +48,7 @@ function App() {
|
|||||||
<VStack className="w-full">
|
<VStack className="w-full">
|
||||||
<HStack as={WindowDragRegion} items="center" className="pl-3 pr-1.5">
|
<HStack as={WindowDragRegion} items="center" className="pl-3 pr-1.5">
|
||||||
Test Request
|
Test Request
|
||||||
|
<IconButton size="sm" icon="trash" onClick={() => deleteRequest.mutate()} />
|
||||||
</HStack>
|
</HStack>
|
||||||
<VStack className="pl-3 px-1.5 py-3" space={3}>
|
<VStack className="pl-3 px-1.5 py-3" space={3}>
|
||||||
<UrlBar
|
<UrlBar
|
||||||
|
|||||||
@@ -12,6 +12,7 @@ import {
|
|||||||
PlusIcon,
|
PlusIcon,
|
||||||
QuestionMarkIcon,
|
QuestionMarkIcon,
|
||||||
SunIcon,
|
SunIcon,
|
||||||
|
TrashIcon,
|
||||||
TriangleDownIcon,
|
TriangleDownIcon,
|
||||||
UpdateIcon,
|
UpdateIcon,
|
||||||
} from '@radix-ui/react-icons';
|
} from '@radix-ui/react-icons';
|
||||||
@@ -33,6 +34,7 @@ type IconName =
|
|||||||
| 'plus-circled'
|
| 'plus-circled'
|
||||||
| 'sun'
|
| 'sun'
|
||||||
| 'code'
|
| 'code'
|
||||||
|
| 'trash'
|
||||||
| 'moon';
|
| 'moon';
|
||||||
|
|
||||||
const icons: Record<IconName, NamedExoticComponent<{ className: string }>> = {
|
const icons: Record<IconName, NamedExoticComponent<{ className: string }>> = {
|
||||||
@@ -51,6 +53,7 @@ const icons: Record<IconName, NamedExoticComponent<{ className: string }>> = {
|
|||||||
question: QuestionMarkIcon,
|
question: QuestionMarkIcon,
|
||||||
eye: EyeOpenIcon,
|
eye: EyeOpenIcon,
|
||||||
code: CodeIcon,
|
code: CodeIcon,
|
||||||
|
trash: TrashIcon,
|
||||||
};
|
};
|
||||||
|
|
||||||
export interface IconProps {
|
export interface IconProps {
|
||||||
|
|||||||
@@ -2,10 +2,14 @@ import { useMutation, useQuery, useQueryClient } from '@tanstack/react-query';
|
|||||||
import { invoke } from '@tauri-apps/api';
|
import { invoke } from '@tauri-apps/api';
|
||||||
import { convertDates, HttpRequest } from '../lib/models';
|
import { convertDates, HttpRequest } from '../lib/models';
|
||||||
import { responsesQueryKey } from './useResponses';
|
import { responsesQueryKey } from './useResponses';
|
||||||
import { useNavigate, useNavigation } from 'react-router-dom';
|
import { useNavigate } from 'react-router-dom';
|
||||||
|
|
||||||
|
export function requestsQueryKey(workspaceId: string) {
|
||||||
|
return ['requests', { workspaceId }];
|
||||||
|
}
|
||||||
|
|
||||||
export function useRequests(workspaceId: string) {
|
export function useRequests(workspaceId: string) {
|
||||||
return useQuery(['requests'], async () => {
|
return useQuery(requestsQueryKey(workspaceId), async () => {
|
||||||
const requests = (await invoke('requests', { workspaceId })) as HttpRequest[];
|
const requests = (await invoke('requests', { workspaceId })) as HttpRequest[];
|
||||||
return requests.map(convertDates);
|
return requests.map(convertDates);
|
||||||
});
|
});
|
||||||
@@ -40,6 +44,7 @@ export function useRequestCreate({
|
|||||||
return useMutation<string, unknown, Pick<HttpRequest, 'name'>>({
|
return useMutation<string, unknown, Pick<HttpRequest, 'name'>>({
|
||||||
mutationFn: async (patch) => invoke('create_request', { ...patch, workspaceId }),
|
mutationFn: async (patch) => invoke('create_request', { ...patch, workspaceId }),
|
||||||
onSuccess: async (requestId) => {
|
onSuccess: async (requestId) => {
|
||||||
|
console.log('DONE', { requestId, navigateAfter });
|
||||||
if (navigateAfter) {
|
if (navigateAfter) {
|
||||||
navigate(`/workspaces/${workspaceId}/requests/${requestId}`);
|
navigate(`/workspaces/${workspaceId}/requests/${requestId}`);
|
||||||
}
|
}
|
||||||
@@ -60,3 +65,17 @@ export function useSendRequest(request: HttpRequest | null) {
|
|||||||
},
|
},
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
|
export function useDeleteRequest(request: HttpRequest | null) {
|
||||||
|
const queryClient = useQueryClient();
|
||||||
|
return useMutation<void, string>({
|
||||||
|
mutationFn: async () => {
|
||||||
|
if (request == null) return;
|
||||||
|
await invoke('delete_request', { requestId: request.id });
|
||||||
|
},
|
||||||
|
onSuccess: async () => {
|
||||||
|
if (request == null) return;
|
||||||
|
await queryClient.invalidateQueries(requestsQueryKey(request.workspaceId));
|
||||||
|
},
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|||||||
@@ -12,6 +12,7 @@ import { Layout } from './components/Layout';
|
|||||||
import { Workspaces } from './pages/Workspaces';
|
import { Workspaces } from './pages/Workspaces';
|
||||||
import './main.css';
|
import './main.css';
|
||||||
import { convertDates, HttpRequest } from './lib/models';
|
import { convertDates, HttpRequest } from './lib/models';
|
||||||
|
import { requestsQueryKey } from './hooks/useRequest';
|
||||||
|
|
||||||
setTheme();
|
setTheme();
|
||||||
|
|
||||||
@@ -20,16 +21,24 @@ await init();
|
|||||||
greet();
|
greet();
|
||||||
|
|
||||||
const queryClient = new QueryClient();
|
const queryClient = new QueryClient();
|
||||||
|
|
||||||
await listen('updated_request', ({ payload: request }: { payload: HttpRequest }) => {
|
await listen('updated_request', ({ payload: request }: { payload: HttpRequest }) => {
|
||||||
queryClient.setQueryData(['requests'], (requests: HttpRequest[] = []) =>
|
queryClient.setQueryData(requestsQueryKey(request.workspaceId), (requests: HttpRequest[] = []) =>
|
||||||
requests.map((r) => (r.id === request.id ? convertDates(request) : r)),
|
requests.map((r) => (r.id === request.id ? convertDates(request) : r)),
|
||||||
);
|
);
|
||||||
});
|
});
|
||||||
|
|
||||||
await listen('created_request', ({ payload: request }: { payload: HttpRequest }) => {
|
await listen('created_request', ({ payload: request }: { payload: HttpRequest }) => {
|
||||||
queryClient.setQueryData(['requests'], (requests: HttpRequest[] = []) => [
|
queryClient.setQueryData(
|
||||||
...requests,
|
requestsQueryKey(request.workspaceId),
|
||||||
convertDates(request),
|
(requests: HttpRequest[] = []) => [...requests, convertDates(request)],
|
||||||
]);
|
);
|
||||||
|
});
|
||||||
|
|
||||||
|
await listen('deleted_request', ({ payload: request }: { payload: HttpRequest }) => {
|
||||||
|
queryClient.setQueryData(requestsQueryKey(request.workspaceId), (requests: HttpRequest[] = []) =>
|
||||||
|
requests.filter((r) => r.id !== request.id),
|
||||||
|
);
|
||||||
});
|
});
|
||||||
|
|
||||||
const router = createBrowserRouter([
|
const router = createBrowserRouter([
|
||||||
|
|||||||
Reference in New Issue
Block a user