/**
 * Connect gateway with data.
 */
import { IAPIGatewayEvent, IDynamoDbEvent, ISnsEvent } from "@kushki/core";
import { Context } from "aws-lambda";
import { PublishResponse } from "aws-sdk/clients/sns";
import { Observable } from "rxjs";
import { AgentRequestParameters } from "types/agent_request_parameters";
import { ChargeSnsMessage } from "types/charge_sns_message";
import { DynamoTransactionSns } from "types/dynamo_transaction_sns";
import { InitRequest } from "types/init_request";
import { StatusRequestParameters } from "types/status_request_parameters";
import { TokenRequest } from "types/token_request";
import { TransactionFetch } from "types/transaction_fetch";

/**
 * Connect gateway with data.
 */
export interface ITransferService {
  /**
   * Get a token
   */
  getToken(
    event: IAPIGatewayEvent<TokenRequest, null, null, { merchantId: string }>,
    context: Context
  ): Observable<object>;
  /**
   * Send a queueWebhooks request
   */
  queueWebhooks(
    event: IDynamoDbEvent<TransactionFetch>,
    context: Context
  ): Observable<boolean | PublishResponse>;
  /**
   * * Init a transaction
   */
  init(
    event: IAPIGatewayEvent<InitRequest, null, null, { merchantId: string }>,
    context: Context
  ): Observable<object>;
  /**
   * Get bank list from transfer service
   */
  bankList(
    event: IAPIGatewayEvent<null, null, null, { merchantId: string }>,
    context: Context
  ): Observable<object>;
  /**
   * * Get information and finalize a transaction
   */
  charge(
    event: ISnsEvent<ChargeSnsMessage>,
    context: Context
  ): Observable<boolean>;
  /**
   * * Send webhook request to merchant
   */
  webhook(
    event: ISnsEvent<DynamoTransactionSns>,
    context: Context
  ): Observable<object | boolean>;
  /**
   * Check status of transfer transaction
   */
  status(
    event: IAPIGatewayEvent<
      null,
      StatusRequestParameters,
      null,
      { merchantId: string }
    >,
    context: Context
  ): Observable<object>;

  /**
   * Manage ticketNumber and token status
   */
  agent(
    event: IAPIGatewayEvent<null, null, AgentRequestParameters>,
    context: Context
  ): Observable<object>;

  /**
   * Call a Gateway endpoint
   */
  call(event: { method: string; args: object }): Observable<object>;
}