1 files changed, 30 insertions, 1 deletions
diff --git a/src/lib/Effect/json.ts b/src/lib/Effect/json.ts
index b905cc41..24414fb0 100644
--- a/src/lib/Effect/json.ts
+++ b/src/lib/Effect/json.ts
@@ -1,4 +1,8 @@
-import { Effect, Result } from "effect";
+import { Effect, Result, Schema } from "effect";
+
+type SyncDecodingSchema = Schema.Top & {
+	readonly DecodingServices: never;
+};
 
 export const parseJsonStringEffect = (value: string) =>
 	Effect.try({
@@ -26,3 +30,28 @@ export const parseJsonStringOrDefault = <T>(value: string, fallback: T): T => {
 		onFailure: () => fallback,
 	});
 };
+
+export const parseJsonStringWithSchemaOrDefault = <
+	S extends SyncDecodingSchema,
+>(
+	value: string,
+	schema: S,
+	fallback: S["Type"],
+): S["Type"] => {
+	const parsed = parseJsonStringEither(value);
+
+	return Result.match(parsed, {
+		onSuccess: (decoded) => {
+			const decodedWithSchema = Result.try({
+				try: () => Schema.decodeUnknownSync(schema)(decoded),
+				catch: () => fallback,
+			});
+
+			return Result.match(decodedWithSchema, {
+				onSuccess: (value) => value,
+				onFailure: () => fallback,
+			});
+		},
+		onFailure: () => fallback,
+	});
+};