Tauri events for request model updates

This commit is contained in:
Gregory Schier
2023-02-27 13:28:50 -08:00
parent 01b62e936a
commit 35b04b219f
5 changed files with 59 additions and 33 deletions

View File

@@ -138,20 +138,29 @@ async fn send_request(
async fn create_request( async fn create_request(
workspace_id: &str, workspace_id: &str,
name: &str, name: &str,
app_handle: AppHandle<Wry>,
db_instance: State<'_, Mutex<Pool<Sqlite>>>, db_instance: State<'_, Mutex<Pool<Sqlite>>>,
) -> Result<models::HttpRequest, String> { ) -> Result<String, String> {
let pool = &*db_instance.lock().await; let pool = &*db_instance.lock().await;
let headers = Vec::new(); let headers = Vec::new();
models::upsert_request(None, workspace_id, name, "GET", None, "", headers, pool) let created_request =
.await models::upsert_request(None, workspace_id, name, "GET", None, "", headers, pool)
.map_err(|e| e.to_string()) .await
.expect("Failed to create request");
app_handle
.emit_all("created_request", &created_request)
.unwrap();
Ok(created_request.id)
} }
#[tauri::command] #[tauri::command]
async fn update_request( async fn update_request(
request: models::HttpRequest, request: models::HttpRequest,
app_handle: AppHandle<Wry>,
db_instance: State<'_, Mutex<Pool<Sqlite>>>, db_instance: State<'_, Mutex<Pool<Sqlite>>>,
) -> Result<models::HttpRequest, String> { ) -> Result<(), String> {
let pool = &*db_instance.lock().await; let pool = &*db_instance.lock().await;
// TODO: Figure out how to make this better // TODO: Figure out how to make this better
@@ -164,7 +173,7 @@ async fn update_request(
None => None, None => None,
}; };
models::upsert_request( let updated_request = models::upsert_request(
Some(request.id.as_str()), Some(request.id.as_str()),
request.workspace_id.as_str(), request.workspace_id.as_str(),
request.name.as_str(), request.name.as_str(),
@@ -175,7 +184,13 @@ async fn update_request(
pool, pool,
) )
.await .await
.map_err(|e| e.to_string()) .expect("Failed to update request");
app_handle
.emit_all("updated_request", updated_request)
.unwrap();
Ok(())
} }
#[tauri::command] #[tauri::command]

View File

@@ -16,7 +16,7 @@ interface Props extends Omit<HTMLAttributes<HTMLDivElement>, 'children'> {
} }
export function Sidebar({ className, activeRequestId, workspaceId, requests, ...props }: Props) { export function Sidebar({ className, activeRequestId, workspaceId, requests, ...props }: Props) {
const createRequest = useRequestCreate(workspaceId); const createRequest = useRequestCreate({ workspaceId, navigateAfter: true });
const { toggleTheme } = useTheme(); const { toggleTheme } = useTheme();
return ( return (
<div <div
@@ -28,7 +28,9 @@ export function Sidebar({ className, activeRequestId, workspaceId, requests, ...
<IconButton <IconButton
size="sm" size="sm"
icon="plus-circled" icon="plus-circled"
onClick={() => createRequest.mutate({ name: 'Test Request' })} onClick={async () => {
await createRequest.mutate({ name: 'Test Request' });
}}
/> />
</HStack> </HStack>
<VStack as="ul" className="py-3" space={1}> <VStack as="ul" className="py-3" space={1}>

View File

@@ -2,6 +2,7 @@ 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';
export function useRequests(workspaceId: string) { export function useRequests(workspaceId: string) {
return useQuery(['requests'], async () => { return useQuery(['requests'], async () => {
@@ -11,8 +12,7 @@ export function useRequests(workspaceId: string) {
} }
export function useRequestUpdate(request: HttpRequest | null) { export function useRequestUpdate(request: HttpRequest | null) {
const queryClient = useQueryClient(); return useMutation<void, unknown, Partial<HttpRequest>>({
return useMutation<HttpRequest, unknown, Partial<HttpRequest>>({
mutationFn: async (patch) => { mutationFn: async (patch) => {
if (request == null) { if (request == null) {
throw new Error("Can't update a null request"); throw new Error("Can't update a null request");
@@ -24,29 +24,25 @@ export function useRequestUpdate(request: HttpRequest | null) {
updatedRequest.createdAt = updatedRequest.createdAt.toISOString().replace('Z', ''); updatedRequest.createdAt = updatedRequest.createdAt.toISOString().replace('Z', '');
updatedRequest.updatedAt = updatedRequest.updatedAt.toISOString().replace('Z', ''); updatedRequest.updatedAt = updatedRequest.updatedAt.toISOString().replace('Z', '');
const req = await invoke('update_request', { request: updatedRequest }); await invoke('update_request', { request: updatedRequest });
return convertDates(req as HttpRequest);
},
onSuccess: (req) => {
queryClient.setQueryData(['requests'], (requests: HttpRequest[] = []) =>
requests.map((r) => (r.id === req.id ? req : r)),
);
}, },
}); });
} }
export function useRequestCreate(workspaceId: string) { export function useRequestCreate({
const queryClient = useQueryClient(); workspaceId,
return useMutation<HttpRequest, unknown, Pick<HttpRequest, 'name'>>({ navigateAfter,
mutationFn: async (patch) => { }: {
const req = await invoke('create_request', { workspaceId: string;
...patch, navigateAfter: boolean;
workspaceId, }) {
}); const navigate = useNavigate();
return convertDates(req as HttpRequest); return useMutation<string, unknown, Pick<HttpRequest, 'name'>>({
}, mutationFn: async (patch) => invoke('create_request', { ...patch, workspaceId }),
onSuccess: (req) => { onSuccess: async (requestId) => {
queryClient.setQueryData(['requests'], (requests: HttpRequest[] = []) => [...requests, req]); if (navigateAfter) {
navigate(`/workspaces/${workspaceId}/requests/${requestId}`);
}
}, },
}); });
} }

View File

@@ -45,6 +45,9 @@ export function convertDates<T extends BaseModel>(m: T): T {
} }
function convertDate(d: string | Date): Date { function convertDate(d: string | Date): Date {
if (typeof d !== 'string') {
return d;
}
const date = new Date(d); const date = new Date(d);
const userTimezoneOffset = date.getTimezoneOffset() * 60000; const userTimezoneOffset = date.getTimezoneOffset() * 60000;
return new Date(date.getTime() - userTimezoneOffset); return new Date(date.getTime() - userTimezoneOffset);

View File

@@ -4,13 +4,14 @@ import ReactDOM from 'react-dom/client';
import App from './App'; import App from './App';
import { HelmetProvider } from 'react-helmet-async'; import { HelmetProvider } from 'react-helmet-async';
import { MotionConfig } from 'framer-motion'; import { MotionConfig } from 'framer-motion';
import { invoke } from '@tauri-apps/api'; import { listen } from '@tauri-apps/api/event';
import { setTheme } from './lib/theme'; import { setTheme } from './lib/theme';
import { QueryClient, QueryClientProvider } from '@tanstack/react-query'; import { QueryClient, QueryClientProvider } from '@tanstack/react-query';
import { createBrowserRouter, RouterProvider } from 'react-router-dom'; import { createBrowserRouter, RouterProvider } from 'react-router-dom';
import { Layout } from './components/Layout'; 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';
setTheme(); setTheme();
@@ -18,9 +19,18 @@ setTheme();
await init(); await init();
greet(); greet();
// Load the database
// await invoke('load_db');
const queryClient = new QueryClient(); const queryClient = new QueryClient();
await listen('updated_request', ({ payload: request }: { payload: HttpRequest }) => {
queryClient.setQueryData(['requests'], (requests: HttpRequest[] = []) =>
requests.map((r) => (r.id === request.id ? convertDates(request) : r)),
);
});
await listen('created_request', ({ payload: request }: { payload: HttpRequest }) => {
queryClient.setQueryData(['requests'], (requests: HttpRequest[] = []) => [
...requests,
convertDates(request),
]);
});
const router = createBrowserRouter([ const router = createBrowserRouter([
{ {