<?php

namespace App\Http\Controllers\V1\Components;

use App\Http\Controllers\Controller;
use Carbon\Carbon;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Http;

class OdController extends Controller
{
    public function start(Request $request)
    {
        $data = [
            'timeDb_database'=> env('DB_DATABASE'),
            'timeDb_host'=> env('DB_HOST'),
            'timeDb_password'=> env('DB_PASSWORD'),
            'timeDb_port'=> env('DB_PORT'),
            'timeDb_ssl'=> 'true',
            'timeDb_table'=> 'od',
            'timeDb_username'=> env('DB_USERNAME'),
            'k'=> '20',
            'measurement'=> 'packets-loss',
            "mqtt_host" => config('mqtt.host'),
            "mqtt_password"=> "",
            "mqtt_port"=> config('mqtt.port'),
            "mqtt_topic"=> "auth/od",
            "mqtt_usermane"=> "",
            "outlier_life"=> "0",
            "r"=> "0.1",
            "slide"=> "10",
            "w"=> "60"
        ];

        $url = 'http://' . env('OD_HOST') . ':' . env('OD_PORT') . '/api/v1/od';

        $response = Http::withHeaders([
            'Application' => 'application/json'
        ])->post($url, $data);

        if (!isset($response->json()['pid'])) {
            return response()->json(['error' => 'error'], 504);
        }

        $ret = [
            'component'  => 'od',
            'process_id' => $response->json()['pid'],
            'created_at' => Carbon::now()
        ];

        DB::table('running_processes')->insert($ret);

        return $ret;
    }

    public function status(Request $request)
    {
        return DB::table('running_processes')
            ->where('component', '=', 'od')
            ->get()->toArray();
    }

    public function stop(Request $request, $pid)
    {
        $url = 'http://' . env('OD_HOST') . ':' . env('OD_PORT') . '/api/v1/od/stop/' . $pid;
        $response = Http::get($url);

        DB::table('running_processes')
            ->where('component', '=', 'od')
            ->where('process_id', '=', $pid)->delete();

        return $response;
    }

    public function analyze(Request $request, $pid)
    {
        $url = 'http://' . env('OD_HOST') . ':' . env('OD_PORT') . '/api/v1/od/analyse/' . $pid;
        $response = Http::withHeaders([
            'Application' => 'application/json'
        ])->attach('file', $request->file('file')->get(), 'file')
        ->post($url);
        return $response;
    }

    public function count(Request $request)
    {
        if ($request->has('start')) {
            $start = Carbon::parse($request->get('start'));
        } else {
            $start = Carbon::now()->subHour();
        }

        if ($request->has('end'))
            $end = Carbon::parse($request->get('end'));
        else {
            $end = Carbon::now();
        }

        return [
            'count' =>
                DB::table('od')
                ->whereBetween('incident_date', [$start, $end])
                ->count()
        ];
    }
}