feat: errors in client-lambda and client-eventbridge

.changeset/fast-kings-relax.md

@@ -0,0 +1,6 @@
+---
+"@effect-aws/client-eventbridge": minor
+"@effect-aws/client-lambda": minor
+---
+
+return proper errors in failure channel in eventbridge and lambda services

packages/client-eventbridge/src/Errors.ts

@@ -0,0 +1,38 @@
+import type {
+  ConcurrentModificationException,
+  IllegalStatusException,
+  InternalException,
+  InvalidEventPatternException,
+  InvalidStateException,
+  LimitExceededException,
+  ManagedRuleException,
+  OperationDisabledException,
+  PolicyLengthExceededException,
+  ResourceAlreadyExistsException,
+  ResourceNotFoundException,
+} from "@aws-sdk/client-eventbridge";
+import * as Data from "effect/Data";
+
+export type TaggedException<T extends { name: string }> = T & {
+  readonly _tag: T["name"];
+};
+
+export type ConcurrentModificationError =
+  TaggedException<ConcurrentModificationException>;
+export type IllegalStatusError = TaggedException<IllegalStatusException>;
+export type InternalError = TaggedException<InternalException>;
+export type InvalidEventPatternError =
+  TaggedException<InvalidEventPatternException>;
+export type InvalidStateError = TaggedException<InvalidStateException>;
+export type LimitExceededError = TaggedException<LimitExceededException>;
+export type ManagedRuleError = TaggedException<ManagedRuleException>;
+export type OperationDisabledError =
+  TaggedException<OperationDisabledException>;
+export type PolicyLengthExceededError =
+  TaggedException<PolicyLengthExceededException>;
+export type ResourceAlreadyExistsError =
+  TaggedException<ResourceAlreadyExistsException>;
+export type ResourceNotFoundError = TaggedException<ResourceNotFoundException>;
+
+export type SdkError = TaggedException<Error & { name: "SdkError" }>;
+export const SdkError = Data.tagged<SdkError>("SdkError");

packages/client-eventbridge/src/EventBridgeClientInstanceConfig.ts

@@ -26,13 +26,23 @@ export const makeDefaultEventBridgeClientInstanceConfig: Effect.Effect<EventBrid
 
     return {
       logger: {
-        info: (m) => Effect.logInfo(m).pipe(runSync),
-        warn: (m) => Effect.logWarning(m).pipe(runSync),
-        error: (m) => Effect.logError(m).pipe(runSync),
-        debug: (m) => Effect.logDebug(m).pipe(runSync),
-        trace: (m) => Effect.logTrace(m).pipe(runSync),
+        info(m) {
+          Effect.logInfo(m).pipe(runSync);
+        },
+        warn(m) {
+          Effect.logWarning(m).pipe(runSync);
+        },
+        error(m) {
+          Effect.logError(m).pipe(runSync);
+        },
+        debug(m) {
+          Effect.logDebug(m).pipe(runSync);
+        },
+        trace(m) {
+          Effect.logTrace(m).pipe(runSync);
+        },
       },
-    } as EventBridgeClientConfig;
+    };
   });
 
 /**