<?php

/**
 * ZohoRecruit Record Api
 *
 */

namespace BitCode\BitFormPro\Integration\ZohoMail;

use BitCode\BitForm\Core\Util\HttpHelper;
use BitCode\BitForm\Core\Util\FieldValueHandler;
use BitCode\BitForm\Core\Util\ApiResponse as UtilApiResponse;

/**
 * Provide functionality for Record insert,upsert
 */
class RecordApiHelper
{
    private $_defaultHeader;
    private $_tokenDetails;

    private $_integrationID;

    private $_logID;

    private $_logResponse;

    public function __construct($tokenDetails, $integId, $logID)
    {
        $this->_tokenDetails = $tokenDetails;
        $this->_integrationID = $integId;
        $this->_logID = $logID;
        $this->_logResponse = new UtilApiResponse();
        $this->_defaultHeader['Authorization'] = "Zoho-oauthtoken {$tokenDetails->access_token}";
        $this->_defaultHeader['accountId'] = $tokenDetails->accountId;
        $this->_defaultHeader['Content-Type'] = 'application/json';
    }

    public function insertRecord($dataCenter, $data)
    {
        $insertRecordEndpoint = "https://mail.zoho.{$dataCenter}/api/accounts/{$this->_defaultHeader['accountId']}/messages";
        return HttpHelper::post($insertRecordEndpoint, $data, $this->_defaultHeader);
    }

    public function executeRecordApi($integrationDetails, $fieldValues, $formID, $entryID)
    {

        $mailInfo = [
            'fromAddress' => $integrationDetails->tokenDetails->accountEmail,
            'toAddress' => implode(',', FieldValueHandler::validateMailArry($integrationDetails->to, $fieldValues)),
            'ccAddress' => implode(',', FieldValueHandler::validateMailArry($integrationDetails->cc, $fieldValues)),
            'bccAddress' => implode(',', FieldValueHandler::validateMailArry($integrationDetails->bcc, $fieldValues)),
            'subject' => FieldValueHandler::replaceFieldWithValue($integrationDetails->subject, $fieldValues),
            'content' => FieldValueHandler::replaceFieldWithValue($integrationDetails->body, $fieldValues)
        ];

        if ($integrationDetails->mailType === 'draft') {
            $mailInfo['mode'] = 'draft';
        }

        if (!empty($integrationDetails->actions->attachments)) {
            $mailAttachments = [];
            $fileFound = 0;
            $responseType = 'success';
            $attachmentApiResponses = [];
            $filesApiHelper = new FilesApiHelper($this->_tokenDetails, $formID, $entryID);
            $attachments = explode(",", $integrationDetails->actions->attachments);
            foreach ($attachments as $fileField) {
                if (isset($fieldValues[$fileField]) && !empty($fieldValues[$fileField])) {
                    $fileFound = 1;
                    if (is_array($fieldValues[$fileField])) {
                        foreach ($fieldValues[$fileField] as $singleFile) {
                            $attachmentApiResponse = $filesApiHelper->uploadFiles($singleFile, $integrationDetails->tokenDetails->accountId, $integrationDetails->dataCenter);
                            if (isset($attachmentApiResponse->data)) {
                                array_push($mailAttachments, $attachmentApiResponse->data);
                            }
                            if (!isset($attachmentApiResponse->status) && !isset($attachmentApiResponse->status->code) && $attachmentApiResponse->status->code !== 200) {
                                $responseType = 'error';
                            }
                            $attachmentApiResponses[] = $attachmentApiResponse;
                        }
                    } else {
                        $attachmentApiResponse = $filesApiHelper->uploadFiles($fieldValues[$fileField], $integrationDetails->tokenDetails->accountId, $integrationDetails->dataCenter);
                        if (isset($attachmentApiResponse->data)) {
                            array_push($mailAttachments, $attachmentApiResponse->data);
                        }
                        if (!isset($attachmentApiResponse->status) && !isset($attachmentApiResponse->status->code) && $attachmentApiResponse->status->code !== 200) {
                            $responseType = 'error';
                        }

                        $attachmentApiResponses[] = $attachmentApiResponse;
                    }
                }
            }

            $mailInfo['attachments'] = $mailAttachments;
            if ($fileFound) {
                $this->_logResponse->apiResponse($this->_logID, $this->_integrationID, ['type' => 'file', 'type_name' => 'mail'], $responseType, $attachmentApiResponses);
            }
        }

        $recordApiResponse = $this->insertRecord($integrationDetails->dataCenter, wp_json_encode($mailInfo));
        if ($recordApiResponse->status->code === 200) {
            $this->_logResponse->apiResponse($this->_logID, $this->_integrationID, ['type' =>  $integrationDetails->mailType, 'type_name' => 'mail'], 'success', $recordApiResponse);
        } else {
            $this->_logResponse->apiResponse($this->_logID, $this->_integrationID, ['type' => $integrationDetails->mailType, 'type_name' => 'mail'], 'error', $recordApiResponse);
        }

        return $recordApiResponse;
    }
}
