'use strict'
import request from 'request'
import * as SubscriptionsActions from '../../actions/subscriptions'
import { setup_env, api_url, return_url } from '../../config'
import url from 'url'

const paypal = setup_env()

export async function createSubscription(req, res) {
  try {
    let request = req.body
    request.user_id = req.user.id;
    let subscription = await SubscriptionsActions.createSubscription(request);
    return res.json(subscription);
  } catch (e) {
    console.log(e)
  }
}

export async function getSubscriptionDetails(req, res) {
  try {
    paypal.billingAgreement.get(req.billingAgreementId, (error, billingAgreement) => {
      if (error) {
        console.log(error);
        return res.status(500).json({message: "There was an error:" + error.response.message});
      } else {
        console.log("Get Billing Agreement");
        console.log(JSON.stringify(billingAgreement));
        return res.status(200).json(billingAgreement);
      }
    });
  } catch (e) {
    console.log(e)
  }
}

export async function searchSubscription(req, res) {
  try {
    let request = req.body
    request.user_id = req.user.id;
    let subscription = await SubscriptionsActions.searchSubscription(request);
    return res.json(subscription);
  } catch (e) {
    console.log(e)
  }
}

export async function updatePlan(req, res) {

  let { plan_id, op, state } = req.body
  let plan_atts = []
  if (op === 'remove') {
    plan_atts = [{
      "op": op,
      "path": "/",
      "value": {}
    }];
  } else {
    plan_atts = [{
      "op": op || "replace",
      "path": "/",
      "value": {
        "state":  state || "ACTIVE"
      }
    }];
  }

  paypal.billingPlan.get(plan_id, (error, billingPlan) => {
    if (error) {
      return res.status(500).json({message: "Get plan. There was an error:" + JSON.stringify(error.response)});
    } else {
      paypal.billingPlan.update(plan_id, plan_atts, async (error, response) => {
        if (error) {
          console.log(error.response)
          return res.status(500).json({message: "Update plan. There was an error:" + JSON.stringify(error.response)});
        } else {
          let data = {
            "paypal_plan_id": plan_id,
            "state": state,
            "deleted": (state === 'DELETED'),
          }
          let respUpdate = await SubscriptionsActions.updatePlan(data);
          return res.status(200).json(billingPlan);
        }
      });
    }
  });
}

export async function listPlans(req, res) {
  let { status, page_size, page, total_required } = req.query

  let list_billing_plan = {
    'status': status || 'ACTIVE',
    'page_size': parseInt(page_size, 0) || 5,
    'page': parseInt(page, 0) || 0,
    'total_required': total_required || 'yes'
  }

  paypal.billingPlan.list(list_billing_plan, (error, billingPlan) => {
    if (error) {
      console.log('error.response', error.response)
      return res.status(500).json({message: "there was an error:" + JSON.stringify(error.response.message)});
    } else {
      console.log('plans', billingPlan)
      return res.status(200).json(billingPlan);
    }
  });
}

export async function getPlan(req, res) {
  let { plan_id } = req.query

  paypal.billingPlan.get(plan_id, function (error, billingPlan) {
    if (error) {
      console.log(error);
      return res.status(500).json({message: "there was an error:" + JSON.stringify(error.response.message)});
    } else {
      return res.status(200).json(billingPlan)
    }
  });
}


export async function createPlan(req, res) {
  let { name,
    description,
    plan_type,
    frequency,
    frequency_interval,
    amount,
    currency,
    pay_def_plan_type,
    cycles,
    cancel_url,
    accept_url
  } = req.body

  let plan = {
    "description": description,
    "merchant_preferences": {
	    "setup_fee": {
		    "value": amount,
		    "currency": currency
	    },
      "auto_bill_amount": "YES",
      "cancel_url": cancel_url || return_url + 'cancelPayment',
      "return_url": accept_url || return_url + 'acceptPayment',
      "initial_fail_amount_action": "CONTINUE",
      "max_fail_attempts": "1"
    },
    "name": name,
    "payment_definitions": [
      {
        "name": name,
        "type": pay_def_plan_type,
        "frequency": frequency,
        "frequency_interval": frequency_interval,
        "amount": {
          "value": amount,
          "currency": currency
        },
        "cycles": cycles
      }
    ],
    "type": plan_type
  };

  paypal.billingPlan.create(plan, async (error, plan) => {
    if (error) {
      return res.status(500).send(JSON.stringify(error.response))
    } else {
      let planToSave = {}
      if (frequency === 'YEAR') {
        planToSave = {
          "paypal_plan_id": plan.id,
          "name": plan.name,
          "description": plan.description,
          "price_per_year": amount,
          "status": plan.state
        }
      } else if (frequency === 'MONTH') {
        planToSave = {
          "paypal_plan_id": plan.id,
          "name": plan.name,
          "description": plan.description,
          "price_per_month": amount,
          "status": plan.state
        }
      } else {
        return res.status(500).json({message: "Frequency is not either YEAR or MONTH. you did something wrong"});
      }
      await SubscriptionsActions.createPlan(planToSave);
      return res.status(200).json(plan);
    }
  });
}

export async function searchSubscriptions(req, res) {

}

export async function createAgreement(req, res) {
  let isoDate = new Date();
  let tomorrow = isoDate.setDate(isoDate.getDate() + 1);
  isoDate = new Date(tomorrow);
  isoDate.toISOString().slice(0, 19) + 'Z';

  let billingAgreementAttributes = {
    "name": req.body.name,
    "description": req.body.description,
    "start_date": isoDate,
    "plan": {
      "id": req.body.plan_id
    },
    "payer": {
      "payment_method": "paypal"
    }
  };

  paypal.billingAgreement.create(billingAgreementAttributes, (error, billingAgreement) => {
    if (error) {
      console.log('error.response', error.response)
      return res.status(500).json({message: "There was an error:" + error.response.message});
    } else {
      for (let index = 0; index < billingAgreement.links.length; index++) {
        if (billingAgreement.links[index].rel === 'approval_url') {
          let approval_url = billingAgreement.links[index].href;
          return res.status(200).json({
            approval_url: approval_url,
            payment_token: url.parse(approval_url, true).query.token
          });
        }
      }
    }
  });
}

export async function executeAgreement(req, res) {
  let paymentToken = req.body.paymentToken
  let plan_id = req.body.plan_id

  paypal.billingAgreement.execute(paymentToken, {}, async (error, billingAgreement) => {
      if (error) {
          console.log(error.response)
      } else {
          let subscriptionToSave = {
            "agreement_Id": billingAgreement.id,
            "state": billingAgreement.state,
            "created_at": billingAgreement.start_date,
            "payer_id": billingAgreement.payer.payer_info.payer_id,
            "user_id": req.user.id,
            "plan_unq_id": plan_id
          }
          await SubscriptionsActions.createSubscription(subscriptionToSave);
          return res.status(200).json({message: 'Billing Agreement success. ID: ' + billingAgreement.id})
      }
  });
}

export async function cancelAgreement(req, res) {
  let billingAgreementId = req.body.billingAgreementId
  let cancel_note = {
    "note": req.body.cancelAgreementNote
  }

  paypal.billingAgreement.cancel(billingAgreementId, cancel_note, (error, response) => {
    if (error) {
        console.log(error);
        return res.status(500).json({message: "There was an error with cancelation:" + error.response.message});
    } else {

      paypal.billingAgreement.get(billingAgreementId, (error, billingAgreement) => {
        if (error) {
          console.log(error.response);
          return res.status(500).json({message: "There was an error:" + error.response.message});
        } else {
          let data = {
            id: billingAgreementId,
            state: billingAgreement.state
          }
          SubscriptionsActions.cancelSubscription(data);
          return res.status(200).json({message: 'Your billing agreement state is: ' + billingAgreement.state});
        }
      });
    }
  });
}

export async function getAgreement(req, res) {
}

export async function updateAgreement(req, res) {
}