From 2e00db57785870bce1fc364cf91c5421ede8b13c Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Julien=20Valverd=C3=A9?= <julien.valverde@mailo.com>
Date: Sun, 2 Mar 2025 01:11:18 +0100
Subject: [PATCH] Query work

---
 packages/extension-query/src/Query.ts | 39 +++++++++++++++++++++++++++
 1 file changed, 39 insertions(+)
 create mode 100644 packages/extension-query/src/Query.ts

diff --git a/packages/extension-query/src/Query.ts b/packages/extension-query/src/Query.ts
new file mode 100644
index 0000000..8098466
--- /dev/null
+++ b/packages/extension-query/src/Query.ts
@@ -0,0 +1,39 @@
+import { Effect, Fiber, Option, type Ref, type SubscriptionRef } from "effect"
+import * as AsyncData from "@typed/async-data"
+
+
+export interface QueryRunner<A, E, R> {
+    readonly stateRef: SubscriptionRef.SubscriptionRef<AsyncData.AsyncData<A, E>>
+    readonly fiberRef: SubscriptionRef.SubscriptionRef<Option.Option<Fiber.Fiber<void>>>
+
+    readonly interrupt: Effect.Effect<void>
+    readonly fetch: Effect.Effect<void>
+    readonly refetch: Effect.Effect<void>
+}
+
+
+export class Query<A, E, R> {
+    constructor(
+        private readonly stateRef: SubscriptionRef.SubscriptionRef<AsyncData.AsyncData<A, E>>,
+        private readonly fiberRef: SubscriptionRef.SubscriptionRef<Option.Option<Fiber.Fiber<void>>>,
+    ) {}
+
+    private run(effect: Effect.Effect<A, E, R>) {
+
+    }
+
+    // interrupt(): Effect.Effect<void> {
+    //     return this.fiberRef.pipe(
+    //         Effect.flatMap(Option.match({
+    //             onSome: Fiber.interrupt,
+    //             onNone: () => Effect.void,
+    //         }))
+    //     )
+    // }
+
+
+
+    fetch = Effect.gen(this, function*() {
+        yield* this.interrupt()
+    })
+}