Thilawyn/effect-fc
1
0
Fork 0
Code Issues 1 Pull Requests 1 Actions Packages Projects Releases Wiki Activity

0.2.2 #31

Merged
Thilawyn merged 184 commits from next into master 2026-01-16 17:05:31 +01:00
Conversation 0 Commits 184 Files Changed 14 +20 -24
1 changed files with 20 additions and 24 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit a510dbc77b - Show all commits

44
packages/effect-fc/src/Form.ts
View File

@@ -24,7 +24,7 @@ extends Pipeable.Pipeable {
readonly valueRef: SubscriptionRef.SubscriptionRef<Option.Option<A>> readonly valueRef: SubscriptionRef.SubscriptionRef<Option.Option<A>>
readonly encodedValueRef: SubscriptionRef.SubscriptionRef<I> readonly encodedValueRef: SubscriptionRef.SubscriptionRef<I>
readonly errorRef: SubscriptionRef.SubscriptionRef<Option.Option<ParseResult.ParseError>> readonly errorRef: SubscriptionRef.SubscriptionRef<Option.Option<ParseResult.ParseError>>
readonly validationFiberRef: SubscriptionRef.SubscriptionRef<Option.Option<Fiber.Fiber<void, never>>> readonly validationFiberRef: SubscriptionRef.SubscriptionRef<Option.Option<Fiber.Fiber<A, ParseResult.ParseError>>>
readonly submitResultRef: SubscriptionRef.SubscriptionRef<Result.Result<SA, SE>> readonly submitResultRef: SubscriptionRef.SubscriptionRef<Result.Result<SA, SE>>
readonly canSubmitSubscribable: Subscribable.Subscribable<boolean> readonly canSubmitSubscribable: Subscribable.Subscribable<boolean>
@@ -43,7 +43,7 @@ extends Pipeable.Class() implements Form<A, I, R, SA, SE, SR> {
readonly valueRef: SubscriptionRef.SubscriptionRef<Option.Option<A>>, readonly valueRef: SubscriptionRef.SubscriptionRef<Option.Option<A>>,
readonly encodedValueRef: SubscriptionRef.SubscriptionRef<I>, readonly encodedValueRef: SubscriptionRef.SubscriptionRef<I>,
readonly errorRef: SubscriptionRef.SubscriptionRef<Option.Option<ParseResult.ParseError>>, readonly errorRef: SubscriptionRef.SubscriptionRef<Option.Option<ParseResult.ParseError>>,
readonly validationFiberRef: SubscriptionRef.SubscriptionRef<Option.Option<Fiber.Fiber<void, never>>>, readonly validationFiberRef: SubscriptionRef.SubscriptionRef<Option.Option<Fiber.Fiber<A, ParseResult.ParseError>>>,
readonly submitResultRef: SubscriptionRef.SubscriptionRef<Result.Result<SA, SE>>, readonly submitResultRef: SubscriptionRef.SubscriptionRef<Result.Result<SA, SE>>,
readonly canSubmitSubscribable: Subscribable.Subscribable<boolean>, readonly canSubmitSubscribable: Subscribable.Subscribable<boolean>,
@@ -76,7 +76,7 @@ export const make: {
) { ) {
const valueRef = yield* SubscriptionRef.make(Option.none<A>()) const valueRef = yield* SubscriptionRef.make(Option.none<A>())
const errorRef = yield* SubscriptionRef.make(Option.none<ParseResult.ParseError>()) const errorRef = yield* SubscriptionRef.make(Option.none<ParseResult.ParseError>())
const validationFiberRef = yield* SubscriptionRef.make(Option.none<Fiber.Fiber<void, never>>()) const validationFiberRef = yield* SubscriptionRef.make(Option.none<Fiber.Fiber<A, ParseResult.ParseError>>())
const submitResultRef = yield* SubscriptionRef.make<Result.Result<SA, SE>>(Result.initial()) const submitResultRef = yield* SubscriptionRef.make<Result.Result<SA, SE>>(Result.initial())
return new FormImpl( return new FormImpl(
@@ -116,35 +116,31 @@ export const run = <A, I, R, SA, SE, SR>(
onNone: () => Effect.void, onNone: () => Effect.void,
})), })),
Effect.andThen( Effect.andThen(
Effect.addFinalizer(() => Ref.set(self.validationFiberRef, Option.none())).pipe( Effect.forkScoped(Effect.onExit(
Effect.andThen(Schema.decode(self.schema, { errors: "all" })(encodedValue)), Schema.decode(self.schema, { errors: "all" })(encodedValue),
Effect.exit, exit => Effect.andThen(
Effect.andThen(flow( Exit.matchEffect(exit, {
Exit.matchEffect({ onSuccess: v => Effect.andThen(
onSuccess: v => Ref.set(self.valueRef, Option.some(v)).pipe( Ref.set(self.valueRef, Option.some(v)),
Effect.andThen(Ref.set(self.errorRef, Option.none())), Ref.set(self.errorRef, Option.none()),
Effect.as(Option.some(v)),
),
onFailure: c => Chunk.findFirst(Cause.failures(c), e => e._tag === "ParseError").pipe(
Option.match({
onSome: e => Ref.set(self.errorRef, Option.some(e)),
onNone: () => Effect.void,
}),
Effect.as(Option.none<A>()),
), ),
onFailure: c => Option.match(Chunk.findFirst(Cause.failures(c), e => e._tag === "ParseError"), {
onSome: e => Ref.set(self.errorRef, Option.some(e)),
onNone: () => Effect.void,
}),
}), }),
Effect.uninterruptible, Ref.set(self.validationFiberRef, Option.none()),
)), ),
Effect.scoped, )).pipe(
Effect.tap(fiber => Ref.set(self.validationFiberRef, Option.some(fiber))),
Effect.andThen(value => Option.isSome(value) && self.autosubmit Effect.andThen(Fiber.join),
Effect.andThen(() => self.autosubmit
? Effect.asVoid(Effect.forkScoped(submit(self))) ? Effect.asVoid(Effect.forkScoped(submit(self)))
: Effect.void : Effect.void
), ),
Effect.forkScoped, Effect.forkScoped,
) )
), ),
Effect.andThen(fiber => Ref.set(self.validationFiberRef, Option.some(fiber)))
), ),
) )