PokeApi with Effect.Service

Author: SandroMaglione

src/PokeApi.ts

@@ -1,42 +1,36 @@
 import { Schema } from "@effect/schema";
-import { Context, Effect, Layer } from "effect";
+import { Effect } from "effect";
 import { BuildPokeApiUrl } from "./BuildPokeApiUrl";
 import { FetchError, JsonError } from "./errors";
 import { PokemonCollection } from "./PokemonCollection";
 import { Pokemon } from "./schemas";
 
-const make = Effect.gen(function* () {
-  const pokemonCollection = yield* PokemonCollection;
-  const buildPokeApiUrl = yield* BuildPokeApiUrl;
+export class PokeApi extends Effect.Service<PokeApi>()("PokeApi", {
+  effect: Effect.gen(function* () {
+    const pokemonCollection = yield* PokemonCollection;
+    const buildPokeApiUrl = yield* BuildPokeApiUrl;
 
-  return {
-    getPokemon: Effect.gen(function* () {
-      const requestUrl = buildPokeApiUrl({ name: pokemonCollection[0] });
+    return {
+      getPokemon: Effect.gen(function* () {
+        const requestUrl = buildPokeApiUrl({ name: pokemonCollection[0] });
 
-      const response = yield* Effect.tryPromise({
-        try: () => fetch(requestUrl),
-        catch: () => new FetchError(),
-      });
+        const response = yield* Effect.tryPromise({
+          try: () => fetch(requestUrl),
+          catch: () => new FetchError(),
+        });
 
-      if (!response.ok) {
-        return yield* new FetchError();
-      }
+        if (!response.ok) {
+          return yield* new FetchError();
+        }
 
-      const json = yield* Effect.tryPromise({
-        try: () => response.json(),
-        catch: () => new JsonError(),
-      });
+        const json = yield* Effect.tryPromise({
+          try: () => response.json(),
+          catch: () => new JsonError(),
+        });
 
-      return yield* Schema.decodeUnknown(Pokemon)(json);
-    }),
-  };
-});
-
-export class PokeApi extends Context.Tag("PokeApi")<
-  PokeApi,
-  Effect.Effect.Success<typeof make>
->() {
-  static readonly Live = Layer.effect(this, make).pipe(
-    Layer.provide(Layer.mergeAll(PokemonCollection.Live, BuildPokeApiUrl.Live))
-  );
-}
+        return yield* Schema.decodeUnknown(Pokemon)(json);
+      }),
+    };
+  }),
+  dependencies: [PokemonCollection.Live, BuildPokeApiUrl.Live],
+}) {}

src/index.test.ts

@@ -12,7 +12,7 @@ const TestConfigProvider = ConfigProvider.fromMap(
 );
 
 const ConfigProviderLayer = Layer.setConfigProvider(TestConfigProvider);
-const MainLayer = PokeApi.Live.pipe(Layer.provide(ConfigProviderLayer));
+const MainLayer = PokeApi.Default.pipe(Layer.provide(ConfigProviderLayer));
 
 const TestingRuntime = ManagedRuntime.make(MainLayer);
 

src/index.ts

@@ -1,7 +1,7 @@
 import { Effect, Layer, ManagedRuntime } from "effect";
 import { PokeApi } from "./PokeApi";
 
-const MainLayer = Layer.mergeAll(PokeApi.Live);
+const MainLayer = Layer.mergeAll(PokeApi.Default);
 
 const PokemonRuntime = ManagedRuntime.make(MainLayer);