<?php

namespace App\Http\Controllers\API;

use App\Http\Controllers\Controller;

use Illuminate\Http\Request;
use App\Models\{
    Project,
    UserToProyek,
    Activity,
    UserToActivity,
    User,
    AssignMaterial,
    DokumenProject,
    FolderDocumentProyek,
    ProjectCharter,
    ProjectApproval,
    ProjectPhase,
    ProjectType,
    ProjectMileStone,
    ProjectParticipants,
    ShowHideColumn,
    VersionGantt,
    Image,
    CommentActivity,
    Link,
    ActivityDokumen,
    Holiday,
    ReportActivity,
    OfficeHours,
    ReportActivityMaterial
};
use Illuminate\Support\Facades\{DB, Artisan, Validator};
use App\Helpers\MasterFunctionsHelper;

const API_GEOLOCATION = "https://nominatim.oslogdev.com/search/ADDR?format=json&addressdetails=1&limit=1";

class ProjectController extends Controller
{

    public function add(Request $request)
    {
        $validator = Validator::make($request->all(), [
            'kode_sortname' => 'string|nullable',
            'jumlah_stakeholder' => 'integer|nullable',
            'nama' => 'required|string',
            'mulai_proyek' => 'required|date',
            'akhir_proyek' => 'nullable|date',
            'area_kerja' => 'nullable|string|max:200',
            'lokasi_kantor' => 'nullable',
            'rencana_biaya' => 'nullable|string',
            'biaya_actual' => 'nullable|string',
            'company' => 'nullable|string',
            'pm_id' => 'nullable|integer',
            'type_proyek_id' => 'nullable|integer',
            'persentase_progress' => 'nullable|numeric',
            'keterangan' => 'nullable',
            'durasi_proyek' => 'nullable|integer',
            'created_by' => 'nullable|string|max:80',
            'updated_by' => 'nullable|string|max:80',
            'progress_by_worklog' => 'nullable|boolean',
            'status' => 'nullable|string|max:50',
            'project_objectives' => 'nullable',
            'considered_success_when' => 'nullable',
            'potential_risk' => 'nullable',
            'testing_environment' => 'nullable',
            'currency_symbol' => 'nullable|string|max:100',
            'currency_code' => 'nullable|string|max:100',
            'currency_name' => 'nullable|string|max:100',
            'phase_id' => 'nullable|integer',
            'budget_health' => 'nullable|string|max:10',
            'divisi_id' => 'nullable|integer',
            'calculaiton_status' => 'nullable|boolean',
            'scurve' => 'nullable|json',
        ]);

        if ($validator->fails()) {
            return response()->json(['status' => 'failed', 'message' => 'Failed to add data!', 'code' => 500], 500);
        }

        $validated = $validator->validated();

        $validated['created_by'] = $this->currentName;
        if (empty($validated['phase_id'])) {
            $validated['phase_id'] = 1;
        }

        $result = Project::create($validated);

        if (!$result) {
            return response()->json(['status' => 'failed', 'message' => 'Failed to add data!', 'code' => 500], 500);
        }

        $this->createOfficeHours($result->id);
        $dataResultInsert = Project::query()
            ->where([
                ['nama', $validated['nama']],
                ['mulai_proyek', $validated['mulai_proyek']]
            ])->first();

        return response()->json(['status' => 'success', 'message' => 'Data added!', 'data_result' => $dataResultInsert, 'code' => 200], 200);
    }

    public function edit($id)
    {
        if (empty($id))
            return response()->json(['status' => 'failed', 'message' => 'id is required!', 'code' => 400], 400);

        $result = Project::find($id);

        if (!$result) {
            return response()->json(['status' => 'failed', 'message' => 'Data not found!', 'code' => 404], 404);
        }

        return response()->json(['status' => 'success', 'code' => 200, 'data' => $result], 200);
    }

    public function update(Request $request, $id)
    {
        if (empty($id)) {
            return response()->json(['status' => 'failed', 'message' => 'id is required!', 'code' => 400], 400);
        }
        $validator = Validator::make($request->all(), [
            'kode_sortname' => 'string|nullable',
            'jumlah_stakeholder' => 'integer|nullable',
            'nama' => 'required|string',
            'mulai_proyek' => 'required|date',
            'akhir_proyek' => 'nullable|date',
            'area_kerja' => 'nullable|string|max:200',
            'lokasi_kantor' => 'nullable',
            'rencana_biaya' => 'nullable|string',
            'biaya_actual' => 'nullable|string',
            'company' => 'nullable|string',
            'pm_id' => 'nullable|integer',
            'type_proyek_id' => 'nullable|integer',
            'persentase_progress' => 'nullable|numeric',
            'keterangan' => 'nullable',
            'durasi_proyek' => 'nullable|integer',
            'created_by' => 'nullable|string|max:80',
            'updated_by' => 'nullable|string|max:80',
            'progress_by_worklog' => 'nullable|boolean',
            'status' => 'nullable|string|max:50',
            'project_objectives' => 'nullable',
            'considered_success_when' => 'nullable',
            'potential_risk' => 'nullable',
            'testing_environment' => 'nullable',
            'currency_symbol' => 'nullable|string|max:100',
            'currency_code' => 'nullable|string|max:100',
            'currency_name' => 'nullable|string|max:100',
            'phase_id' => 'nullable|integer',
            'budget_health' => 'nullable|string|max:10',
            'divisi_id' => 'nullable|integer',
            'calculaiton_status' => 'nullable|boolean',
            'scurve' => 'nullable|json',
        ]);

        if ($validator->fails()) {
            return response()->json(['status' => 'failed', 'message' => 'Failed to update!', 'code' => 500], 500);
        }

        $validated = $validator->validated();

        $data = Project::find($id);

        if (!$data) {
            return response()->json(['status' => 'failed', 'message' => 'Data not found!', 'code' => 404], 404);
        }

        $result = $data->update($validated);

        if (!$result) {
            return response()->json(['status' => 'failed', 'message' => 'Failed to update!', 'code' => 500], 500);
        }

        return response()->json(['status' => 'success', 'message' => 'Data updated!', 'code' => 200], 200);
    }

    private function createOfficeHours($proyek_id)
    {
        $dataCreate = array(
            "proyek_id" => $proyek_id,
            "monday_start" => "08:00:00",
            "monday_end" => "16:00:00",
            "tuesday_start" => "08:00:00",
            "tuesday_end" => "16:00:00",
            "wednesday_start" => "08:00:00",
            "wednesday_end" => "16:00:00",
            "thursday_start" => "08:00:00",
            "thursday_end" => "16:00:00",
            "friday_start" => "08:00:00",
            "friday_end" => "16:00:00",
            "saturday_start" => "08:00:00",
            "saturday_end" => "16:00:00",
            "sunday_start" => "08:00:00",
            "sunday_end" => "16:00:00",
            "created_by" => $this->currentName
        );

        OfficeHours::create($dataCreate);

        return true;
    }

    public function delete($id)
    {
        $data = Project::find($id);

        if (!$data) {
            return response()->json(['status' => 'failed', 'message' => 'Data not found!', 'code' => 404], 404);
        }

        $this->deleteRelative($id);

        if (!$data->delete()) {
            return response()->json(['status' => 'failed', 'message' => 'Delete failed!', 'code' => 500], 500);
        }

        return response()->json(['status' => 'success', 'message' => 'Data deleted!', 'code' => 200], 200);
    }

    private function deleteRelative($project_id)
    {
        $id_proyek = $project_id;

        UserToProyek::where('proyek_id', $id_proyek)->delete();
        UserToActivity::where('proyek_id', $id_proyek)->delete();
        AssignMaterial::where('proyek_id', $id_proyek)->delete();
        ProjectCharter::where('proyek_id', $id_proyek)->delete();
        ProjectApproval::where('proyek_id', $id_proyek)->delete();
        ProjectMileStone::where('proyek_id', $id_proyek)->delete();
        ProjectParticipants::where('proyek_id', $id_proyek)->delete();
        $this->deleteVersionGantt($id_proyek);
        $this->deleteDokumenProject($id_proyek);
    }

    private function deleteVersionGantt($project_id)
    {
        $dataVg = VersionGantt::where("proyek_id", $project_id)->pluck("id");
        $vhIds = $dataVg->all();
        $activity = Activity::whereIn("version_gantt_id", $vhIds)->pluck('id');
        $activityIds = $activity->all();
        $dataRa = ReportActivity::whereIn("activity_id", $activityIds)->get();
        foreach ($dataRa as $ra) {
            $images = Image::where("ref_id", $ra['id'])->where("category", "report_activity")->get();
            foreach ($images as $image) {
                if (file_exists($this->pathImage . $image->image)) {
                    unlink($this->pathImage . $image->image);
                }
            }
            Image::query()
                ->where([
                    ["ref_id", $ra['id']],
                    ["category", "report_activity"]
                ])
                ->delete();
        }
        $dataAd = ActivityDokumen::whereIn("activity_id", $activityIds)->get();
        foreach ($dataAd as $ad) {
            if (file_exists($this->pathActivityDocument . $ad->file)) {
                unlink($this->pathActivityDocument . $ad->file);
            }
        }
        ActivityDokumen::whereIn("activity_id", $activityIds)->delete();
        CommentActivity::whereIn("activity_id", $activityIds)->delete();
        Holiday::where("proyek_id", $project_id)->delete();
        VersionGantt::where("proyek_id", $project_id)->delete();
        Link::whereIn("version_gantt_id", $vhIds)->delete();
        ShowHideColumn::whereIn("version_gantt_id", $vhIds)->delete();
        Activity::whereIn("version_gantt_id", $vhIds)->delete();
        ReportActivity::whereIn("activity_id", $activityIds)->delete();
    }

    private function deleteDokumenProject($project_id)
    {
        $dataDokumen = DokumenProject::where([
            ["type_dokumen", "project-document-out-folder"],
            ['ref_id', $project_id]
        ])->get();

        foreach ($dataDokumen as $dokumen) {
            if (file_exists($this->pathDocument . $dokumen->file)) {
                unlink($this->pathDocument . $dokumen->file);
            }
        }
        DokumenProject::query()
            ->where([
                ["type_dokumen", "project-document-out-folder"],
                ['ref_id', $project_id]
            ])->delete();

        $dataFolder = FolderDocumentProyek::where('proyek_id', $project_id)->pluck("id");
        $ref_ids = $dataFolder->all();
        $dataDokumen = DokumenProject::where("type_dokumen", "project-document-in-folder")->whereIn('ref_id', $ref_ids)->get();
        foreach ($dataDokumen as $dokumen) {
            if (file_exists($this->pathDocument . $dokumen->file)) {
                unlink($this->pathDocument . $dokumen->file);
            }
        }

        DokumenProject::where("type_dokumen", "project-document-in-folder")->whereIn('ref_id', $ref_ids)->delete();
    }

    public function search(Request $request)
    {
        $payload = $request->all();

        $dataBuilder = $this->setUpPayload($payload, 'm_proyek');
        $builder = $dataBuilder['builder'];
        $countBuilder = $dataBuilder['count'];
        $dataGet = $builder->get();
        $totalRecord = $countBuilder->count();

        return response()->json(['status' => 'success', 'code' => 200, 'data' => $dataGet, 'totalRecord' => $totalRecord], 200);
    }

    public function list()
    {
        $data = Project::orderByDesc('id')->get();
        $countData = $data->count();

        if (!$data) {
            return response()->json(['status' => 'failed', 'message' => 'Data not found!', 'code' => 404], 404);
        }

        $scheduleWarningThreshold = 10;
        $scheduleDangerThreshold = 5;
        foreach ($data as $d) {
            $progress = $costVariance = $actualCost = 0;
            $lastActivity = null;
            $scheduleHealth = "on-track";
            $rootActivity = Activity::whereNull('parent_id')->where('proyek_id', $d['id'])->orderByDesc('version_gantt_id')->first();
            if ($rootActivity) {
                $costVariance = (int)$d['rencana_biaya'] - (int)$rootActivity->biaya_actual;
                $actualCost = $rootActivity->biaya_actual ?? 0;
                $progress = $rootActivity->persentase_progress ?? 0;

                $timeleft = strtotime($d['mulai_proyek']) - strtotime($rootActivity->end_date);
                $date1 = new \DateTime(date("Y-m-d", strtotime($d['mulai_proyek'])));
                $date2 = new \DateTime(date("Y-m-d", strtotime($rootActivity->end_date)));
                $daysRemaining = $date2->diff($date1);
                $daysRemaining = $daysRemaining->d;

                if ($daysRemaining <= $scheduleDangerThreshold) {
                    $scheduleHealth = "danger";
                } elseif ($daysRemaining <= $scheduleWarningThreshold) {
                    $scheduleHealth = "warning";
                }
                $lastActivity = date("d/m/Y", strtotime($rootActivity->end_date));
            }
            $d['plannedInterval'] = date("d/m/Y", strtotime($d['mulai_proyek'])) . " - " . date("d/m/Y", strtotime($d['akhir_proyek']));
            $d['plannedCost'] = $d['rencana_biaya'];
            $d['actualCost'] = $actualCost;
            $d['lastActivity'] = $lastActivity ?? "-";
            $d['costVariance'] = $costVariance;
            $d['costHealth'] = $d['budget_health'];
            $d['scheduleHealth'] = $scheduleHealth;
            $d['progress'] = $progress;
            $d['lastGanttId'] = VersionGantt::where("proyek_id", $d['id'])->orderByDesc('id')->first()->id ?? null;
            $d['manpower'] = UserToProyek::where("proyek_id", $d['id'])->count() ?? 0;
            $d['projectManager'] = Project::query()
                ->join('m_users', 'm_users.id', '=', 'm_proyek.pm_id')
                ->where('m_proyek.id', $d['id'])
                ->pluck('m_users.name')
                ->first();
            if ($d['area_kerja'] != '') {
                $d['geolocation'] = $this->httpReq($d['area_kerja']);
                $d['geolocation'] = [];
            } else {
                $d['geolocation'] = [];
            }
        }

        $totalPlannedCost = array_sum(array_map('intval', array_column($data->toArray(), 'plannedCost')));
        $totalActualCost = $data->sum('actualCost');
        $manpowers = User::count();
        $projectsOnDanger = Project::where('budget_health', 'overrun')->count();
        $projectPhases = ProjectPhase::orderBy('order', 'asc')->pluck('name');
        $projectTypes = ProjectType::orderBy('id', 'asc')->pluck('name');
        try {
            $projectsByPhase = Project::query()
                ->selectRaw('m_proyek_phase.name, m_proyek_phase.color, COUNT(*) as total')
                ->join('m_proyek_phase', 'm_proyek_phase.id', '=', 'm_proyek.phase_id')
                ->groupBy('m_proyek_phase.name', 'm_proyek_phase.color')
                ->get();
        } catch (\Exception $e) {
            return response()->json(['message' => $e->getMessage()]);
        }
        try {
            $projectsByType = Project::query()
                ->selectRaw('m_type_proyek.name, COUNT(*) as total')
                ->join('m_type_proyek', 'm_type_proyek.id', '=', 'm_proyek.type_proyek_id')
                ->groupBy('m_type_proyek.name')
                ->get();
        } catch (\Exception $e) {
            return response()->json(['message' => $e->getMessage()]);
        }

        return response()->json(
            [
                'status' => 'success',
                'code' => 200,
                'data' => $data,
                'totalRecord' => $countData,
                'totalPlannedCost' => $totalPlannedCost,
                'totalActualCost' => $totalActualCost,
                'totalRevenue' => $totalPlannedCost - $totalActualCost,
                'manpowers' => $manpowers,
                'projectsOnDanger' => $projectsOnDanger,
                'projectPhases' => $projectPhases,
                'projectsByPhase' => $projectsByPhase,
                'projectTypes' => $projectTypes,
                'projectsByType' => $projectsByType,
            ],
            200
        );
    }

    public function getListProjectTask($id)
    {
        $data = UserToActivity::select("assign_hr_to_activity.user_id as user_id", "m_proyek.*")
            ->where("assign_hr_to_activity.user_id", $id)
            ->join('m_proyek', 'assign_hr_to_activity.proyek_id', '=', 'm_proyek.id')
            ->groupBy("m_proyek.proyek_id")
            ->get();

        if ($data->isNotEmpty()) :
            return response()->json(['status' => 'success', 'code' => 200, 'data' => $data], 200);
        else :
            return response()->json(['status' => 'failed', 'message' => 'Data not found!', 'code' => 404], 404);
        endif;
    }

    public function getSCurve(Request $request)
    {
        $data = MasterFunctionsHelper::getSCurve($request);
        return response()->json(['status' => 'success', 'code' => 200, 'data' => $data], 200);
    }

    public function calculateSCurve(Request $request)
    {
        $sCurve = Project::select('scurve')->where('id', $request->project_id)->first();
        return response()->json(['status' => 'success', 'code' => 200, 'data' => json_decode($sCurve->scurve)], 200);
    }

    public function sCurveCommand(Request $request)
    {
        Artisan::call('calculate:scurve', [
            'project_id' => $request->project_id
        ]);
    }

    public function getLinearSCurve(Request $request)
    {
        $data = MasterFunctionsHelper::getLinearSCurve($request);
        return response()->json(['status' => 'success', 'code' => 200, 'data' => $data], 200);
    }

    public function synchronizeReport($gantt_id)
    {
        $activities = Activity::where("version_gantt_id", $gantt_id)->get();
        $reports = [];

        foreach ($activities as $activity) {
            $activity_id = $activity['id'];
            $countReports = ReportActivityMaterial::where('activity_id', $activity_id)->count();
            if ($countReports === 1) {
                $dataReports = ReportActivityMaterial::where('activity_id', $activity_id)->orderBy('report_date')->get();
                foreach ($dataReports as $dr) {
                    $reports[] = array(
                        'activity_id' => $activity_id,
                        'min_date' => $dr->report_date,
                        'max_date' => date_modify(date_create($dr->report_date), "1 days")
                    );
                }
            }
            if ($countReports > 1) {
                $firstReport = ReportActivityMaterial::where('activity_id', $activity_id)->orderBy('report_date')->first();
                $lastReport = ReportActivityMaterial::where('activity_id', $activity_id)->orderByDesc('report_date')->first();
                $reports[] = array(
                    'activity_id' => $activity_id,
                    'min_date' => $firstReport->report_date,
                    'max_date' => date_modify(date_create($lastReport->report_date), "1 days")
                );
            }
            $activity->reports = $reports;
        }

        for ($i = 0; $i < count($reports); $i++) {
            $activity = Activity::find($reports[$i]['activity_id']);
            $activity['start_date'] = $reports[$i]['min_date'];
            $activity['end_date'] = $reports[$i]['max_date'];
            $activity->save();
        }

        return response()->json(['status' => 'success', 'message' => 'Synchronize to report success!', 'code' => 200], 200);
    }

    public function setBaseline($gantt_id)
    {
        $activities = Activity::where("version_gantt_id", $gantt_id)->get();

        foreach ($activities as $activity) {
            $activity->update([
                "planned_start" => $activity['start_date'],
                "planned_end" => $activity['end_date'],
            ]);
        }

        return response()->json(['status' => 'success', 'message' => 'Set baseline success!', 'code' => 200], 200);
    }

    public function getInvoiceIntegration(Request $request)
    {
        $response = null;

        return response()->json(['status' => 'success', 'data' => '', 'code' => 200], 200);
    }

    public function detail($id)
    {
        if (empty($id)) {
            return response()->json(['status' => 'failed', 'message' => 'id is required!', 'code' => 400], 400);
        }

        $result = Project::find($id);

        if (empty($result)) {
            return response()->json(['status' => 'failed', 'message' => 'Data not found!', 'code' => 404], 404);
        }

        $gantt = MasterFunctionsHelper::getLatestGantt($id);
        $result->projectManager = User::where('id', $result->pm_id)->value('name');
        $result->header = Activity::whereNull('parent_id')->where("proyek_id", $id)->where("version_gantt_id", $gantt['last_gantt_id'])->first();
        return response()->json(['status' => 'success', 'code' => 200, 'data' => $result, 'gantt' => $gantt], 200);
    }

    public function getOverdueActivities(Request $request)
    {
        $payload = $request->all();
        if (empty($payload['id'])) {
            return response()->json(['status' => 'failed', 'message' => 'id is required!', 'code' => 400], 400);
        }

        $result = Project::find($payload['id']);

        if (!$result) {
            return response()->json(['status' => 'failed', 'message' => 'Project not found!', 'code' => 404], 404);
        }
        //TODO possible overdue bug
        if (isset($payload['till_date'])) :
            $overdueActivities = Activity::where('proyek_id', $payload['id'])->whereNotNull('parent_id')->where('persentase_progress', '!=', 100)->whereDate('end_date', '<=', $payload['till_date'])->orderBy('end_date', 'asc')->get();
        else :
            $overdueActivities = Activity::where('proyek_id', $payload['id'])->whereNotNull('parent_id')->where('persentase_progress', '!=', 100)->orderBy('end_date', 'asc')->get();
        endif;

        $result->overdueActivities = $overdueActivities;

        return response()->json(['status' => 'success', 'code' => 200, 'data' => $result], 200);
    }

    public function getReportDistribution(Request $request)
    {
        $payload = $request->all();

        if (empty($payload['project_id'])) {
            return response()->json(['status' => 'failed', 'message' => 'id is required!', 'code' => 400], 400);
        }

        $reports = DB::table('assign_material_to_activity AS ama')
            ->select(
                'u.name',
                'a.name as activity_name',
                'ama.qty_planning',
                'ram.qty as qty_real',
                'rm.description as material_name',
                'rm.uom as material_unit',
                'ram.lat',
                'ram.lon',
                'ram.description as report_notes',
                'ram.report_date'
            )
            ->join('report_activity_material AS ram', 'ram.assign_material_id', '=', 'ama.id')
            ->join('m_req_material AS rm', 'rm.id', '=', 'ama.material_id')
            ->join('m_activity AS a', 'a.id', '=', 'ama.activity_id')
            ->join('m_users AS u', 'u.id', '=', 'ram.user_id')
            ->where('ama.proyek_id', '=', $payload['project_id'])
            ->whereNotNull('ram.lat')
            ->whereBetween('ram.report_date', [$payload['start_date'], $payload['end_date']]);

        return response()->json(['status' => 'success', 'code' => 200, 'data' => $reports], 200);
    }

    public function getManpower($proyek_id)
    {
        $manCount = UserToProyek::where('proyek_id', $proyek_id)->count();
        return response()->json(['totalRecord' => $manCount]);
    }

    public function getAssignedHR($gantt_id)
    {
        $results = UserToActivity::select('assign_hr_to_activity.proyek_id', 'assign_hr_to_activity.user_id', 'm_activity.id', 'm_activity.name', 'm_activity.start_date', 'm_activity.end_date')
            ->join('m_activity', 'm_activity.id', '=', 'assign_hr_to_activity.activity_id')
            ->where('assign_hr_to_activity.version_gantt_id', $gantt_id)
            ->get();
        return response()->json(['data' => $results]);
    }

    public function dashboard($id)
    {
        $data = DB::table('m_proyek as mp')
            ->select(
                'mp.kode_sortname',
                'mp.nama as name_project',
                'mp.mulai_proyek as start',
                'mp.akhir_proyek as finish',
                'mp.rencana_biaya',
                'mp.company',
                'mp.currency_symbol',
                'mu.name as pm',
                'mp.budget_health'
            )
            ->join('m_users AS mu', 'mu.id', '=', 'mp.pm_id')
            ->where('mp.id', $id)
            ->first();

        if (!$data) {
            return response()->json(['status' => 'failed', 'message' => 'Data tidak ditemukan!', 'code' => 404], 404);
        }

        $manpowers = UserToProyek::where('proyek_id', $id)->count();
        $rootActivity = Activity::whereNull('parent_id')->where('proyek_id', $id)->orderByDesc('version_gantt_id')->first();

        $actualCost = $rootActivity['biaya_actual'] ?? 0;
        $progress = $rootActivity['persentase_progress'] ?? 0;

        $commentActivity = DB::table('m_comment_activity as mca')
            ->select(
                'mca.activity_id',
                'mca.comment AS comment',
                'mca.created_by AS comment_by',
                'mca.created_at AS comment_created',
                'ma.name AS activity'
            )
            ->join('m_activity AS ma', 'ma.id', '=', 'mca.activity_id')
            ->where('ma.proyek_id', $id)
            ->orderBy('comment_by')
            ->take(2)
            ->get();

        $data->actual_cost = $actualCost;
        $data->progress = $progress;
        $data->comment = $commentActivity;
        $data->man_power = $manpowers;

        return response()->json(['status' => 'success', 'code' => 200, 'data' => $data], 200);
    }

    private function httpReq($search)
    {
        $ch = curl_init();
        curl_setopt($ch, CURLOPT_URL, str_replace("ADDR", $search, API_GEOLOCATION));

        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, FALSE);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
        curl_setopt($ch, CURLOPT_VERBOSE, true);
        curl_setopt($ch, CURLOPT_STDERR, fopen('php://stderr', 'w'));

        $info = curl_getinfo($ch);

        $output = curl_exec($ch);
        curl_close($ch);

        return json_decode($output);
    }
}