Method getClient

backend/src/temporal/temporal.service.ts:235–266

()

  }

  private async getClient(): Promise<WorkflowClient> {
    if (this.clientPromise) {
      return this.clientPromise;
    }

    this.clientPromise = (async () => {
      try {
        this.logger.log(`Connecting to Temporal at ${this.address} (namespace=${this.namespace})`);
        const connection = await Connection.connect({ address: this.address });
        await this.ensureNamespace(connection);
        this.connection = connection;
        const client = new WorkflowClient({
          connection,
          namespace: this.namespace,
        });
        this.logger.log(
          `Temporal client ready (namespace=${this.namespace}, defaultTaskQueue=${this.defaultTaskQueue})`,
        );
        return client;
      } catch (error) {
        this.clientPromise = undefined;
        this.logger.error(
          `Failed to connect to Temporal: ${
            error instanceof Error ? error.message : String(error)
          }`,
        );
        throw error;
      }
    })();

    return this.clientPromise;
  }

  private async ensureNamespace(connection: Connection): Promise<void> {
    try {