From 96d937fe2dd9e608756808c0f06d57813a0bbcb7 Mon Sep 17 00:00:00 2001
From: CREDO23 <thierrybakera12@gmail.com>
Date: Thu, 18 Dec 2025 23:26:15 +0200
Subject: [PATCH] feat: add query atoms

---
 .../atoms/connectors/connector-query.atoms.ts | 21 +++++++++++++++++++
 surfsense_web/atoms/connectors/ui.atoms.ts    |  7 +++++++
 .../contracts/types/connector.types.ts        |  2 +-
 3 files changed, 29 insertions(+), 1 deletion(-)
 create mode 100644 surfsense_web/atoms/connectors/connector-query.atoms.ts
 create mode 100644 surfsense_web/atoms/connectors/ui.atoms.ts

diff --git a/surfsense_web/atoms/connectors/connector-query.atoms.ts b/surfsense_web/atoms/connectors/connector-query.atoms.ts
new file mode 100644
index 000000000..24777c8c6
--- /dev/null
+++ b/surfsense_web/atoms/connectors/connector-query.atoms.ts
@@ -0,0 +1,21 @@
+import { atomWithQuery } from "jotai-tanstack-query";
+import { connectorsApiService } from "@/lib/apis/connectors-api.service";
+import { cacheKeys } from "@/lib/query-client/cache-keys";
+import { activeSearchSpaceIdAtom } from "../search-spaces/search-space-query.atoms";
+
+export const connectorsAtom = atomWithQuery((get) => {
+	const searchSpaceId = get(activeSearchSpaceIdAtom);
+
+	return {
+		queryKey: cacheKeys.connectors.all(searchSpaceId!),
+		enabled: !!searchSpaceId,
+		staleTime: 5 * 60 * 1000, // 5 minutes
+		queryFn: async () => {
+			return connectorsApiService.getConnectors({
+				queryParams: {
+					search_space_id: searchSpaceId!,
+				},
+			});
+		},
+	};
+});
diff --git a/surfsense_web/atoms/connectors/ui.atoms.ts b/surfsense_web/atoms/connectors/ui.atoms.ts
new file mode 100644
index 000000000..e085ad34e
--- /dev/null
+++ b/surfsense_web/atoms/connectors/ui.atoms.ts
@@ -0,0 +1,7 @@
+import { atom } from "jotai";
+import type { GetConnectorsRequest } from "@/contracts/types/connector.types";
+
+export const globalConnectorsQueryParamsAtom = atom<GetConnectorsRequest["queryParams"]>({
+	skip: 0,
+	limit: 10,
+});
diff --git a/surfsense_web/contracts/types/connector.types.ts b/surfsense_web/contracts/types/connector.types.ts
index be286a286..4e09ba067 100644
--- a/surfsense_web/contracts/types/connector.types.ts
+++ b/surfsense_web/contracts/types/connector.types.ts
@@ -46,7 +46,7 @@ export const getConnectorsRequest = z.object({
 	queryParams: paginationQueryParams
 		.pick({ skip: true, limit: true })
 		.extend({
-			search_space_id: z.number().or(z.string()),
+			search_space_id: z.number().or(z.string()).nullish(),
 		})
 		.nullish(),
 });