// Code generated by protoc-gen-ts_proto. DO NOT EDIT.
// versions:
//   protoc-gen-ts_proto  v2.11.4
//   protoc               v7.34.0
// source: webhook.proto

/* eslint-disable */
import { GrpcMethod, GrpcStreamMethod } from "@nestjs/microservices";
import { Observable } from "rxjs";

export const protobufPackage = "webhook.v1";

export interface ProcessWebhookRequest {
  /**
   * Полное тело события от BitGo в виде одной JSON-строки (как передал gateway после приёма webhook).
   * Клиент (gateway) обязан передавать валидный JSON; mpc парсит и маппит поля transfer / state / data и т.д.
   */
  jsonPayload: string;
}

export interface ProcessWebhookResponse {
  /** true, если обработка завершилась без фатальной ошибки. */
  ok: boolean;
  /** Стабильный id события (хеш, transfer id и т.п.) — для логов и ответа вызывающей стороне. */
  eventId: string;
}

export const WEBHOOK_V1_PACKAGE_NAME = "webhook.v1";

export interface WebhookServiceClient {
  /**
   * Обработка одного события webhook BitGo: разбор JSON, дедупликация по event_id, обновление custody-транзакций,
   * при необходимости — gRPC в Ledger (статус вывода, зачисление депозита).
   */

  processBitGoWebhook(request: ProcessWebhookRequest): Observable<ProcessWebhookResponse>;
}

export interface WebhookServiceController {
  /**
   * Обработка одного события webhook BitGo: разбор JSON, дедупликация по event_id, обновление custody-транзакций,
   * при необходимости — gRPC в Ledger (статус вывода, зачисление депозита).
   */

  processBitGoWebhook(
    request: ProcessWebhookRequest,
  ): Promise<ProcessWebhookResponse> | Observable<ProcessWebhookResponse> | ProcessWebhookResponse;
}

export function WebhookServiceControllerMethods() {
  return function (constructor: Function) {
    const grpcMethods: string[] = ["processBitGoWebhook"];
    for (const method of grpcMethods) {
      const descriptor: any = Reflect.getOwnPropertyDescriptor(constructor.prototype, method);
      GrpcMethod("WebhookService", method)(constructor.prototype[method], method, descriptor);
    }
    const grpcStreamMethods: string[] = [];
    for (const method of grpcStreamMethods) {
      const descriptor: any = Reflect.getOwnPropertyDescriptor(constructor.prototype, method);
      GrpcStreamMethod("WebhookService", method)(constructor.prototype[method], method, descriptor);
    }
  };
}

export const WEBHOOK_SERVICE_NAME = "WebhookService";