feat: improved logging

typescript-sdk/src/clients/dispatcher/dispatcher-client.ts

@@ -7,6 +7,7 @@ import {
 } from '@hatchet/protoc/dispatcher';
 import { ClientConfig } from '@clients/hatchet-client/client-config';
 import HatchetError from '@util/errors/hatchet-error';
+import { Logger } from '@hatchet/util/logger';
 import { ActionListener } from './action-listener';
 
 interface GetActionListenerOptions {
@@ -19,9 +20,12 @@ export class DispatcherClient {
   config: ClientConfig;
   client: PbDispatcherClient;
 
+  logger: Logger;
+
   constructor(config: ClientConfig, channel: Channel, factory: ClientFactory) {
     this.config = config;
     this.client = factory.create(DispatcherDefinition, channel);
+    this.logger = new Logger(`Dispatcher`, config.log_level);
   }
 
   async getActionListener(options: GetActionListenerOptions) {

typescript-sdk/src/clients/event/event-client.ts

@@ -6,14 +6,18 @@ import {
 } from '@hatchet/protoc/events/events';
 import HatchetError from '@util/errors/hatchet-error';
 import { ClientConfig } from '@clients/hatchet-client/client-config';
+import { Logger } from '@hatchet/util/logger';
 
 export class EventClient {
   config: ClientConfig;
   client: EventsServiceClient;
 
+  logger: Logger;
+
   constructor(config: ClientConfig, channel: Channel, factory: ClientFactory) {
     this.config = config;
     this.client = factory.create(EventsServiceDefinition, channel);
+    this.logger = new Logger(`Dispatcher`, config.log_level);
   }
 
   push<T>(type: string, input: T) {
@@ -24,7 +28,9 @@ export class EventClient {
     };
 
     try {
-      return this.client.push(req);
+      const e = this.client.push(req);
+      this.logger.info(`Event pushed: ${type}`);
+      return e;
     } catch (e: any) {
       throw new HatchetError(e.message);
     }