import { Dispatch } from '@reduxjs/toolkit'
import { Agent } from 'daf-core'
import { SelectiveDisclosureRequest } from 'daf-selective-disclosure'
import { ActionSendDIDComm } from '@rsksmart/rif-id-daf/lib/did-comm-action-handler'
import { addIssuedCredentialRequest, Claims, IssuedCredentialRequest, setIssuedCredentialRequestStatus, deleteIssuedCredentialRequest } from '../reducers/issuedCredentialRequests'
import { CredentialRequest, findCredentialRequests } from '../entities/CredentialRequest'
import { callbackify, Callback } from './util'

export const initCredentialRequestsFactory = (agent: Agent) => (cb?: Callback<IssuedCredentialRequest[]>) => (dispatch: Dispatch): IssuedCredentialRequest => callbackify(
  async () => {
    const identities = await agent.identityManager.getIdentities()
    const connection = await agent.dbConnection
    const credentialRequests = await findCredentialRequests(connection)
    credentialRequests.forEach(credentialRequest => {
      if (credentialRequest.message.from && identities.filter(identity => identity.did === credentialRequest.message.from.did).length > 0) {
        dispatch(addIssuedCredentialRequest({
          id: credentialRequest.id,
          from: credentialRequest.message.from.did,
          to: credentialRequest.message.to.did,
          claims: credentialRequest.message.data.claims,
          status: credentialRequest.status
        }))
      }
    })
  },
  cb
)

export const issueCredentialRequestFactory = (agent: Agent) => (from: string, to: string, claims: Claims, status: string, sendOptions?: { url?: string, headers?: HeadersInit }, cb?: Callback<IssuedCredentialRequest>) => (dispatch: Dispatch): IssuedCredentialRequest => callbackify(
  () => agent.handleAction({
    type: 'sign.sdr.jwt',
    data: {
      issuer: from,
      subject: to,
      claims
    } as SelectiveDisclosureRequest
  }).then(jwt => agent.handleAction({
    type: 'send.message.didcomm-alpha-1',
    data: {
      from,
      to,
      type: 'jwt',
      body: jwt
    },
    ...sendOptions,
    save: true
  } as ActionSendDIDComm)
  ).then(message => {
    if (!message) throw new Error('Failed to send credential request')
    return agent.dbConnection.then(connection => ({ connection, message }))
  }).then(({ connection, message }) => {
    const credentialRequest = new CredentialRequest()
    credentialRequest.message = message
    credentialRequest.status = status
    return connection.getRepository(CredentialRequest).save(credentialRequest)
  }).then(credentialRequest => {
    const addIssuedCredentialRequestPayload = {
      from,
      id: credentialRequest.id,
      to,
      claims,
      status
    }
    dispatch(addIssuedCredentialRequest(addIssuedCredentialRequestPayload))
    return addIssuedCredentialRequestPayload
  }),
  cb
)

export const setIssuedCredentialRequestStatusFactory = (agent: Agent) => (from: string, id: string, status: string, cb?: Callback<void>) => (dispatch: Dispatch) => callbackify(
  async () => {
    const connection = await agent.dbConnection
    const credentialRequest = await connection.getRepository(CredentialRequest).findOne(id)
    credentialRequest.status = status
    await connection.manager.save(credentialRequest)
    dispatch(setIssuedCredentialRequestStatus({ from, id, status }))
  },
  cb
)

export const deleteIssuedCredentialRequestFactory = (agent: Agent) => (from: string, id: string, cb?: Callback<void>) => (dispatch: Dispatch) => callbackify(
  () => agent.dbConnection.then(connection => connection.manager.createQueryBuilder()
    .delete()
    .from(CredentialRequest)
    .where('id = :id', { id })
    .execute()
  ).then(() => dispatch(deleteIssuedCredentialRequest({ from, id }))),
  cb
)