Thilawyn/reffuse
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

@reffuse/extension-query 0.1.4 #15

Merged
Thilawyn merged 340 commits from next into master 2025-05-26 04:15:01 +02:00
Conversation 0 Commits 340 Files Changed 18 +110 -120
1 changed files with 110 additions and 120 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit 825de84cef - Show all commits

230
packages/extension-query/src/MutationRunner.ts
View File

@@ -1,144 +1,134 @@
import { BrowserStream } from "@effect/platform-browser" // import { BrowserStream } from "@effect/platform-browser"
import * as AsyncData from "@typed/async-data" // import * as AsyncData from "@typed/async-data"
import { type Cause, Effect, Fiber, identity, Option, Ref, type Scope, Stream, SubscriptionRef } from "effect" // import { type Cause, Effect, Fiber, identity, Option, Ref, type Scope, Stream, SubscriptionRef } from "effect"
export interface MutationRunner<K extends readonly unknown[], A, E, R> { // export interface MutationRunner<K extends readonly unknown[], A, E, R> {
readonly key: Stream.Stream<K> // readonly mutation: (...args: K) => Effect.Effect<A, E, R>
readonly mutation: (key: K) => Effect.Effect<A, E, R>
readonly latestKeyRef: SubscriptionRef.SubscriptionRef<Option.Option<K>> // readonly stateRef: SubscriptionRef.SubscriptionRef<AsyncData.AsyncData<A, E>>
readonly stateRef: SubscriptionRef.SubscriptionRef<AsyncData.AsyncData<A, E>>
readonly fiberRef: SubscriptionRef.SubscriptionRef<Option.Option<Fiber.RuntimeFiber<void, Cause.NoSuchElementException>>>
readonly forkInterrupt: Effect.Effect<Fiber.RuntimeFiber<void, Cause.NoSuchElementException>> // readonly forkMutate: Effect.Effect<Fiber.RuntimeFiber<void>>
readonly forkFetch: Effect.Effect<Fiber.RuntimeFiber<void, Cause.NoSuchElementException>> // }
readonly forkRefresh: Effect.Effect<Fiber.RuntimeFiber<void, Cause.NoSuchElementException>>
readonly fetchOnKeyChange: Effect.Effect<void, Cause.NoSuchElementException, Scope.Scope>
}
export interface MakeProps<K extends readonly unknown[], A, E, R> { // export interface MakeProps<K extends readonly unknown[], A, E, R> {
readonly key: Stream.Stream<K> // readonly mutation: (...args: K) => Effect.Effect<A, E, R>
readonly mutation: (key: K) => Effect.Effect<A, E, R> // }
}
export const make = <K extends readonly unknown[], A, E, R>( // export const make = <K extends readonly unknown[], A, E, R>(
{ key, query }: MakeProps<K, A, E, R> // { key, query }: MakeProps<K, A, E, R>
): Effect.Effect<MutationRunner<K, A, E, R>, never, R> => Effect.gen(function*() { // ): Effect.Effect<MutationRunner<K, A, E, R>, never, R> => Effect.gen(function*() {
const context = yield* Effect.context<R>() // const context = yield* Effect.context<R>()
const latestKeyRef = yield* SubscriptionRef.make(Option.none<K>()) // const stateRef = yield* SubscriptionRef.make(AsyncData.noData<A, E>())
const stateRef = yield* SubscriptionRef.make(AsyncData.noData<A, E>())
const fiberRef = yield* SubscriptionRef.make(Option.none<Fiber.RuntimeFiber<void, Cause.NoSuchElementException>>())
const interrupt = fiberRef.pipe( // const interrupt = fiberRef.pipe(
Effect.flatMap(Option.match({ // Effect.flatMap(Option.match({
onSome: fiber => Ref.set(fiberRef, Option.none()).pipe( // onSome: fiber => Ref.set(fiberRef, Option.none()).pipe(
Effect.andThen(Fiber.interrupt(fiber)) // Effect.andThen(Fiber.interrupt(fiber))
), // ),
onNone: () => Effect.void, // onNone: () => Effect.void,
})) // }))
) // )
const forkInterrupt = fiberRef.pipe( // const forkInterrupt = fiberRef.pipe(
Effect.flatMap(Option.match({ // Effect.flatMap(Option.match({
onSome: fiber => Ref.set(fiberRef, Option.none()).pipe( // onSome: fiber => Ref.set(fiberRef, Option.none()).pipe(
Effect.andThen(Fiber.interrupt(fiber).pipe( // Effect.andThen(Fiber.interrupt(fiber).pipe(
Effect.asVoid, // Effect.asVoid,
Effect.forkDaemon, // Effect.forkDaemon,
)) // ))
), // ),
onNone: () => Effect.forkDaemon(Effect.void), // onNone: () => Effect.forkDaemon(Effect.void),
})) // }))
) // )
const forkFetch = interrupt.pipe( // const forkFetch = interrupt.pipe(
Effect.andThen( // Effect.andThen(
Ref.set(stateRef, AsyncData.loading()).pipe( // Ref.set(stateRef, AsyncData.loading()).pipe(
Effect.andThen(latestKeyRef), // Effect.andThen(latestKeyRef),
Effect.flatMap(identity), // Effect.flatMap(identity),
Effect.flatMap(key => query(key).pipe( // Effect.flatMap(key => query(key).pipe(
Effect.matchCauseEffect({ // Effect.matchCauseEffect({
onSuccess: v => Ref.set(stateRef, AsyncData.success(v)), // onSuccess: v => Ref.set(stateRef, AsyncData.success(v)),
onFailure: c => Ref.set(stateRef, AsyncData.failure(c)), // onFailure: c => Ref.set(stateRef, AsyncData.failure(c)),
}) // })
)), // )),
Effect.provide(context), // Effect.provide(context),
Effect.fork, // Effect.fork,
) // )
), // ),
Effect.flatMap(fiber => // Effect.flatMap(fiber =>
Ref.set(fiberRef, Option.some(fiber)).pipe( // Ref.set(fiberRef, Option.some(fiber)).pipe(
Effect.andThen(Fiber.join(fiber)), // Effect.andThen(Fiber.join(fiber)),
Effect.andThen(Ref.set(fiberRef, Option.none())), // Effect.andThen(Ref.set(fiberRef, Option.none())),
) // )
), // ),
Effect.forkDaemon, // Effect.forkDaemon,
) // )
const forkRefresh = interrupt.pipe( // const forkRefresh = interrupt.pipe(
Effect.andThen( // Effect.andThen(
Ref.update(stateRef, previous => { // Ref.update(stateRef, previous => {
if (AsyncData.isSuccess(previous) || AsyncData.isFailure(previous)) // if (AsyncData.isSuccess(previous) || AsyncData.isFailure(previous))
return AsyncData.refreshing(previous) // return AsyncData.refreshing(previous)
if (AsyncData.isRefreshing(previous)) // if (AsyncData.isRefreshing(previous))
return AsyncData.refreshing(previous.previous) // return AsyncData.refreshing(previous.previous)
return AsyncData.loading() // return AsyncData.loading()
}).pipe( // }).pipe(
Effect.andThen(latestKeyRef), // Effect.andThen(latestKeyRef),
Effect.flatMap(identity), // Effect.flatMap(identity),
Effect.flatMap(key => query(key).pipe( // Effect.flatMap(key => query(key).pipe(
Effect.matchCauseEffect({ // Effect.matchCauseEffect({
onSuccess: v => Ref.set(stateRef, AsyncData.success(v)), // onSuccess: v => Ref.set(stateRef, AsyncData.success(v)),
onFailure: c => Ref.set(stateRef, AsyncData.failure(c)), // onFailure: c => Ref.set(stateRef, AsyncData.failure(c)),
}) // })
)), // )),
Effect.provide(context), // Effect.provide(context),
Effect.fork, // Effect.fork,
) // )
), // ),
Effect.flatMap(fiber => // Effect.flatMap(fiber =>
Ref.set(fiberRef, Option.some(fiber)).pipe( // Ref.set(fiberRef, Option.some(fiber)).pipe(
Effect.andThen(Fiber.join(fiber)), // Effect.andThen(Fiber.join(fiber)),
Effect.andThen(Ref.set(fiberRef, Option.none())), // Effect.andThen(Ref.set(fiberRef, Option.none())),
) // )
), // ),
Effect.forkDaemon, // Effect.forkDaemon,
) // )
const fetchOnKeyChange = Effect.addFinalizer(() => interrupt).pipe( // const fetchOnKeyChange = Effect.addFinalizer(() => interrupt).pipe(
Effect.andThen(Stream.runForEach(key, latestKey => // Effect.andThen(Stream.runForEach(key, latestKey =>
Ref.set(latestKeyRef, Option.some(latestKey)).pipe( // Ref.set(latestKeyRef, Option.some(latestKey)).pipe(
Effect.andThen(forkFetch) // Effect.andThen(forkFetch)
) // )
)) // ))
) // )
const refreshOnWindowFocus = Stream.runForEach( // const refreshOnWindowFocus = Stream.runForEach(
BrowserStream.fromEventListenerWindow("focus"), // BrowserStream.fromEventListenerWindow("focus"),
() => forkRefresh, // () => forkRefresh,
) // )
return { // return {
query, // query,
latestKeyRef, // latestKeyRef,
stateRef, // stateRef,
fiberRef, // fiberRef,
forkInterrupt, // forkInterrupt,
forkFetch, // forkFetch,
forkRefresh, // forkRefresh,
fetchOnKeyChange, // fetchOnKeyChange,
refreshOnWindowFocus, // refreshOnWindowFocus,
} // }
}) // })