import { WyreAPIInterface } from './WyreAPIInterface'
import { CreateSubscriptionRequest } from './CreateSubscriptionRequest'
import { APIResponse } from './APIResponse'
import { Subscription } from './Subscription'
import { SubscriptionsList } from './SubscriptionsList'
import { GetSubscriptionsRequest } from './GetSubscriptionsRequest'
import { Transfer } from './Transfer'
import { TransferRequest } from './TransferRequest'
import { WyreAccount } from './WyreAccount'
import { CreateAccountRequest } from './CreateAccountRequest'
import { WyreAPIOptions } from './WyreAPIOptions'
import { BaseWyreAPI } from './BaseWyreAPI'
import { UploadDocumentParams } from './UploadDocumentParams'
import { CreateWyreWalletParams } from './CreateWyreWalletParams'
import { WyreWallet } from './WyreWallet'
import { CreateMultipleWalletsParams } from './CreateMultipleWalletsParams'
import { EditWalletParams } from './EditWalletParams'
import { PaymentMethodParams } from './PaymentMethodParams'
import { PaymentMethod } from './PaymentMethod'
import { UploadPaymentMethodDocumentParams } from './UploadPaymentMethodDocumentParams'
import { UpdateAccountRequest } from './UpdateAccountRequest'
import { WyreUser } from './WyreUser'
import { CreateUserRequest } from './CreateUserRequest'
import { WyreUserKYCData } from './WyreUserKYCData'
import { MigrateAccountResponse } from './MigrateAccountResponse'

// tslint:disable: no-console

export class BearerTokenWyreAPI extends BaseWyreAPI implements WyreAPIInterface {
  constructor(
    options: WyreAPIOptions,
  ) {
    super(options)
  }

  async createUser(params: CreateUserRequest): Promise<APIResponse<WyreUser>> {
    throw new Error(`Unsupported`)
  }

  async getUser(
    userID: string,
    scopes: string = 'TRANSFER',
  ): Promise<APIResponse<WyreUser>> {
    throw new Error(`Unsupported`)
  }

  uploadUserKYCData(
    userID: string,
    kycData: WyreUserKYCData,
  ): Promise<APIResponse<WyreUser>> {
    throw new Error(`Unsupported`)
  }

  async createAccount(params: CreateAccountRequest): Promise<APIResponse<WyreAccount>> {
    const { error } = await this.createSession()
    if (error) {
      return { error }
    }

    const req = this.getAxiosInstance().post(
      '/v3/accounts',
      params,
    )

    return await this.executeRequest<WyreAccount>(req)
  }

  async updateAccount(
    accountID: string,
    updates: UpdateAccountRequest,
  ): Promise<APIResponse<WyreAccount>> {

    const req = this.getAxiosInstance().post(
      `/v3/accounts/${accountID}`,
      updates,
    )

    return await this.executeRequest<WyreAccount>(req)
  }

  async migrateAccount(
    accountID,
  ): Promise<APIResponse<MigrateAccountResponse>> {

    const req = this.getAxiosInstance().post(
      `/v3/users/migrateAccount/${accountID}`,
    )

    return await this.executeRequest<MigrateAccountResponse>(req)
  }

  async uploadDocument(
    params: UploadDocumentParams,
    buff: Buffer,
  ): Promise<APIResponse<WyreAccount>> {
    const { accountId, fieldId, contentType } = params

    const headers = {
      'Content-Type': contentType,
      'Content-Length': buff.length,
    }

    const req = this.getAxiosInstance().post(
      `/v3/accounts/${accountId}/${fieldId}`,
      buff,
      { headers },
    )

    return await this.executeRequest<WyreAccount>(req)
  }

  async uploadPaymentMethodDocument(
    params: UploadPaymentMethodDocumentParams,
    buff: Buffer,
  ): Promise<APIResponse<PaymentMethod>> {
    const { paymentMethodId, contentType } = params

    const headers = {
      'Content-Type': contentType,
      'Content-Length': buff.length,
    }

    const req = this.getAxiosInstance().post(
      `/v2/paymentMethod/${paymentMethodId}/followup`,
      buff,
      { headers },
    )

    return await this.executeRequest<PaymentMethod>(req)
  }

  async addPaymentMethod(
    params: PaymentMethodParams,
  ): Promise<APIResponse<PaymentMethod>> {
    const req = this.getAxiosInstance().post(
      '/v2/paymentMethods',
      params,
    )

    return await this.executeRequest<PaymentMethod>(req)
  }

  async getPaymentMethod(
    paymentMethodID: string,
  ): Promise<APIResponse<PaymentMethod>> {
    const req = this.getAxiosInstance().get(
      `/v2/paymentMethod/${paymentMethodID}`,
    )

    return await this.executeRequest<PaymentMethod>(req)
  }

  async listPaymentMethods(): Promise<APIResponse<PaymentMethod[]>> {
    const req = this.getAxiosInstance().get(
      `/v2/paymentMethod`,
    )

    return await this.executeRequest<PaymentMethod[]>(req)
  }

  async deletePaymentMethod(
    paymentMethodID: string,
  ): Promise<APIResponse<any>> {
    const req = this.getAxiosInstance().delete(
      `/v2/paymentMethod/${paymentMethodID}`,
    )

    return await this.executeRequest<any>(req)
  }

  async attachBlockchainToPaymentMethod(paymentMethodId, params) {
    const req = this.getAxiosInstance().post(
      `/v2/paymentMethod/${paymentMethodId}/attach`,
      params,
    )

    return await this.executeRequest(req)
  }

  async createTransfer(transferRequest: TransferRequest): Promise<APIResponse<Transfer>> {
    const req = this.getAxiosInstance().post(
      `/v3/transfers`,
      transferRequest,
    )

    return await this.executeRequest<Transfer>(req)
  }

  async confirmTransfer(transferID): Promise<APIResponse<Transfer>> {
    const req = this.getAxiosInstance().post(
      `/v3/transfers/${transferID}/confirm`,
    )

    return await this.executeRequest<Transfer>(req)
  }

  async getAccountInfoV2(): Promise<APIResponse<WyreAccount>> {
    const req = this.getAxiosInstance().get(
      `/v2/account`,
    )

    return await this.executeRequest(req)
  }

  async getAccountInfoV3(accountID): Promise<APIResponse<WyreAccount>> {
    const req = this.getAxiosInstance().get(
      `/v3/accounts/${accountID}`,
    )

    return await this.executeRequest<WyreAccount>(req)
  }

  async getTransfers(transferID): Promise<APIResponse<Transfer>> {
    let url = `/v3/transfers`
    if (transferID) {
      url += `/${transferID}`
    }

    const req = this.getAxiosInstance().get(url)
    return await this.executeRequest<Transfer>(req)
  }

  async createSubscription(
    subscribeRequest: CreateSubscriptionRequest
  ): Promise<APIResponse<Subscription>> {
    const req = this.getAxiosInstance().post(
      `/v3/subscriptions`,
      subscribeRequest
    )

    const {
      response: subscription,
      error,
    } = await this.executeRequest<Subscription>(req)

    if (error) {
      return { error }
    }

    if (Object.keys(subscription).length === 0) {
      return { error: 'subscribeWebhook failed' }
    }
    return { response: subscription }
  }

  async deleteSubscription(subscriptionID): Promise<APIResponse<any>> {
    const req = this.getAxiosInstance().delete(
      `/v3/subscriptions/${subscriptionID}`
    )

    return await this.executeRequest<any>(req)
  }

  async getSubscriptions(
    subscriptionsReq: GetSubscriptionsRequest
  ): Promise<APIResponse<SubscriptionsList>> {
    const { offset, length } = subscriptionsReq

    const req = this.getAxiosInstance().get(
      `/v3/subscriptions?offset=${offset}&length=${length}`,
    )

    const {
      response,
      error,
    } = await this.executeRequest<SubscriptionsList>(req)

    if (error) {
      return { error }
    }

    return { response }
  }

  async getRates(as, pair) {
    const req = this.getAxiosInstance().get(
      `/v3/rates?as=${as}`,
    )

    const { response: rates, error } = await this.executeRequest(req)
    if (error) {
      return { error }
    }

    if (pair) {
      return { rates: rates[pair] }
    }

    return { response: rates }
  }

  // Wallet Endpoints

  async createWallet(walletParams: CreateWyreWalletParams): Promise<APIResponse<WyreWallet>> {
    const req = this.getAxiosInstance().post(
      `/v2/wallets`,
      walletParams,
    )

    return await this.executeRequest<WyreWallet>(req)
  }

  async createMultipleWallets(params: CreateMultipleWalletsParams): Promise<APIResponse<WyreWallet[]>> {
    const req = this.getAxiosInstance().post(
      `/v2/wallets/batch`,
      params,
    )

    return await this.executeRequest<WyreWallet[]>(req)
  }

  async lookupWallet(walletID: string): Promise<APIResponse<WyreWallet>> {
    const req = this.getAxiosInstance().get(
      `/v2/wallet/${walletID}`,
    )

    return await this.executeRequest<WyreWallet>(req)
  }

  async editWallet(walletID: string, params: EditWalletParams): Promise<APIResponse<any>> {
    const req = this.getAxiosInstance().post(
      `/v2/wallet/${walletID}/update`,
      params,
    )

    return await this.executeRequest<any>(req)
  }

  async deleteWallet(walletID: string): Promise<APIResponse<any>> {
    const req = this.getAxiosInstance().delete(
      `/v2/wallet/${walletID}`,
    )

    return await this.executeRequest<any>(req)
  }

  async listWallets(limit: number, offset: number): Promise<APIResponse<WyreWallet[]>> {
    const req = this.getAxiosInstance().get(
      `/v2/wallets?limit=${limit}&offset=${offset}`,
    )

    return await this.executeRequest<WyreWallet[]>(req)
  }

  getMasqueraded(accountToken: string): WyreAPIInterface {
    return this
  }
}