From bc81c443ab92b0ab527846401840a56c30edb879 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Julien=20Valverd=C3=A9?= <julien.valverde@mailo.com>
Date: Tue, 11 Mar 2025 21:19:57 +0100
Subject: [PATCH] Query work

---
 packages/extension-query/src/FailureHandler.ts | 11 +++++++++++
 packages/extension-query/src/QueryExtension.ts |  4 ++--
 2 files changed, 13 insertions(+), 2 deletions(-)
 create mode 100644 packages/extension-query/src/FailureHandler.ts

diff --git a/packages/extension-query/src/FailureHandler.ts b/packages/extension-query/src/FailureHandler.ts
new file mode 100644
index 0000000..96d784b
--- /dev/null
+++ b/packages/extension-query/src/FailureHandler.ts
@@ -0,0 +1,11 @@
+import { Effect, type Queue, type Stream } from "effect"
+
+
+export interface FailureHandler<E> {
+    readonly failures: Stream.Stream<E>
+    readonly queue: Queue.Queue<E>
+}
+
+export const Tag = <const Id extends string>(id: Id) => <
+    Self, E = never,
+>() => Effect.Tag(id)<Self, FailureHandler<E>>()
diff --git a/packages/extension-query/src/QueryExtension.ts b/packages/extension-query/src/QueryExtension.ts
index 1a55d78..888fda6 100644
--- a/packages/extension-query/src/QueryExtension.ts
+++ b/packages/extension-query/src/QueryExtension.ts
@@ -6,11 +6,11 @@ import * as QueryRunner from "./QueryRunner.js"
 import type * as QueryService from "./QueryService.js"
 
 
-export interface QueryExtension<GlobalE> {
+export interface QueryExtension<HandlerE> {
     useQuery<K extends readonly unknown[], A, E, R>(
         this: ReffuseHelpers.ReffuseHelpers<R>,
         props: UseQueryProps<K, A, E, R>,
-    ): UseQueryResult<K, A, Exclude<E, GlobalE>>
+    ): UseQueryResult<K, A, Exclude<E, HandlerE>>
 }
 
 export interface UseQueryProps<K extends readonly unknown[], A, E, R> {