<?php

namespace Parasut;

use Exception;

class Client
{
    public $BASE_URL = 'https://api.parasut.com';
    public $version = 'v4';
    public $config;
    public $access_token;
    public $company_id;
    public $file = 'token.ini';

    public function __construct($config)
    {
        $this->config = $config;
        $this->company_id = $this->config['company_id'];
        if (function_exists('storage_path')) {
            $this->file = storage_path('token.ini');
        }
        $this->checkTokens();
    }

    public function checkTokens()
    {
        try {
            $tokens = parse_ini_file($this->file);
        } catch (\Exception $e) {
            @unlink($this->file);
        }

        if (! isset($tokens['access_token']) || ! isset($tokens['created_at'])) {
            return $this->authorize();
        }
        if (time() - (int) $tokens['created_at'] > 7200) {
            return $this->authorize();
        }
        $this->access_token = $tokens['access_token'];

        return $tokens;
    }

    public function authorize()
    {
        if ($this->config['grant_type'] == 'password') {
            $resp = $this->authWithPassword();
        }

        if (isset($resp['access_token'])) {
            $token = '';
            foreach ($resp as $key => $value) {
                $token .= $key.'='.$value."\n";
            }
            file_put_contents($this->file, $token);

            $this->access_token = $resp['access_token'];
        }

        return false;
    }

    public function call($class)
    {
        return new $class($this);
    }

    public function request($path, $params = null, $method = 'POST', $fullPath = false)
    {
        $headers = [];
        $headers[] = 'Accept: application/json';
        $headers[] = 'Content-Type: application/json';
        $headers[] = 'Authorization: Bearer '.$this->access_token;

        $ch = curl_init();
        if (is_array($params) && $method == 'GET' && count($params) > 0) {
            $path = rtrim($path,'/');
            $path .= '?'.http_build_query($params);
        }

        if ($fullPath) {
            curl_setopt($ch, CURLOPT_URL, $path);
        } else {
            curl_setopt($ch, CURLOPT_URL, $this->BASE_URL.'/'.$this->version.'/'.$this->company_id.'/'.$path);
        }

        curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);
        curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 20);
        curl_setopt($ch, CURLOPT_TIMEOUT, 90);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
        curl_setopt($ch, CURLOPT_HEADER, false);
        switch ($method) {
            case 'PUT':
                curl_setopt($ch, CURLOPT_CUSTOMREQUEST, 'PUT');
                curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($params));
                break;
            case 'POST':
                curl_setopt($ch, CURLOPT_POST, 1);
                curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($params));
                break;
            case 'PATCH':
                curl_setopt($ch, CURLOPT_CUSTOMREQUEST, 'PATCH');
                curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($params));
                break;
            case 'DELETE':
                curl_setopt($ch, CURLOPT_CUSTOMREQUEST, 'DELETE');
                break;
        }
        $jsonData = curl_exec($ch);
        $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
        $response = json_decode($jsonData, true);
        curl_close($ch);
        
        switch ($httpCode) {
            case '400':
                $msg = strlen($jsonData) < 3 ? $msg = 'Bad Request' : $jsonData;
                throw new Exception($msg, 400);
                break;
            case '401':
                $msg = strlen($jsonData) < 3 ? $msg = 'Authentication Error' : $jsonData;
                throw new Exception($msg, 401);
                break;
            case '404':
                $msg = strlen($jsonData) < 3 ? $msg = 'Not Found Error' : $jsonData;
                throw new Exception($msg, 404);
                break;
            case '422':
                $msg = strlen($jsonData) < 3 ? $msg = 'Unprocessable Entity Error' : $jsonData;
                throw new Exception($msg, 422);
                break;
            case '500':
                $msg = strlen($jsonData) < 3 ? $msg = 'Internal Server Error' : $jsonData;
                throw new Exception($msg, 500);
                break;
            default:
                return $response;
                break;
        }
    }

    private function authWithPassword()
    {
        $path = $this->BASE_URL.'/oauth/token';

        return $this->request(
            $path,
            $this->config,
            'POST',
            true
        );
    }
}

class Base
{
    public $client;

    public function __construct(Client $client)
    {
        $this->client = $client;
    }
}

class Account extends Base
{
    public function create($data)
    {
        return $this->client->request(
            'contacts',
            $data,
            'POST'
        );
    }

    public function show($id , $data = [])
    {
        return $this->client->request(
            'contacts/' . $id,
            $data,
            'GET'
        );
    }

    public function update($id , $data = [])
    {
        return $this->client->request(
            'contacts/' . $id,
            $data,
            'PUT'
        );
    }
}


class PurchaseBill extends Base
{

    public function create($data)
    {
        return $this->client->request(
            'purchase_bills#detailed',
            $data
        );
    }

    public function show($id , $data = [])
    {
        return $this->client->request(
            'purchase_bills/' . $id,
            $data,
            'GET'
        );
    }

    public function edit($id , $data = [])
    {
        return $this->client->request(
            'products/' . $id,
            $data,
            'PUT'
        );
    }

    public function pay($id , $data = [])
    {
        return $this->client->request(
            'products/' . $id . '/payments',
            $data
        );
    }
}

class Product extends Base
{

    public function create($data)
    {
        return $this->client->request(
            'products',
            $data
        );
    } 

    public function show($id , $data = [])
    {
        return $this->client->request(
            'products/' . $id,
            $data,
            'GET'
        );
    }


    public function update($id , $data = [])
    {
        return $this->client->request(
            'products/' . $id,
            $data,
            'PUT'
        );
    }
}

Class Invoice extends Base
{
    public function listInvoices($params = [])
    {
        return $this->client->request(
          'sales_invoices/',
          $params,
          'GET'
        );
    }


    public function show($id, $params = [])
    {
        return $this->client->request(
          'sales_invoices/'.$id,
          $params,
          'GET'
        );
    }
    
    public function checkPdf($id)
    {
        $response = $this->client->request(
            'sales_invoices/'.$id.'?include=active_e_document',
            [],
            'GET'
        );
        if (isset($response['included']) && isset($response['included'][0])) {
            return ['type' => $response['included'][0]['type'], 'id' => $response['included'][0]['id']];
        }
        return false;
    }

    public function edit($id, $data)
    {
        return $this->client->request(
            'sales_invoices/'.$id,
            $data
        );
    }
    public function create($data)
    {
        return $this->client->request(
            'sales_invoices',
            $data
        );
    }
    
    public function delete($id)
    {
        return $this->client->request('sales_invoices/'.$id,[],'DELETE');
    }
    
    public function pay($id, $data)
    {
        $resp = $this->client->request(
            'sales_invoices/'.$id.'/payments',
            $data
        );
        return $resp;
    }

    public function checkType($vkn)
    {
        return $this->client->request(
            'e_invoice_inboxes?filter[vkn]='.$vkn,
            [],
            'GET'
        );
    }

    public function create_e_archive($data)
    {
        return $this->client->request(
            'e_archives',
            $data
        );
    }

    public function show_e_archive($id)
    {
        return $this->client->request(
            'e_archives/'.$id,
            [],
            'GET'
        );
        
    }

    public function pdf_e_archive($id)
    {
        return $this->client->request(
            "e_archives/$id/pdf",
            [],
            'GET'
        );
    }

    public function create_e_invoice($data)
    {
        return $this->client->request(
            'e_invoices',
            $data
        );
    }

    public function show_e_invoice($id)
    {
        return $this->client->request(
          'e_invoices/'.$id,
            [],
            'GET'
        );
    }

    public function pdf_e_invoice($id)
    {
        return $this->client->request(
            "e_invoices/$id/pdf",
            [],
            'GET'
        );
    }

    public function checkJobStatus($id)
    {
        return $this->client->request(
            'trackable_jobs/'.$id,
            [],
            'GET'
        );
    }
}