<?php
  
  namespace App\Http\Controllers\V1\Partners;
  
  
  use App\Http\Controllers\Controller;
  use App\Http\Requests\AdtRequest;
  use Carbon\Carbon;

  use Illuminate\Http\Request;

  use Illuminate\Support\Facades\DB;

  use Salman\Mqtt\Facades\Mqtt;
  
  class AdtController extends Controller
  {
      public function store(AdtRequest $request)
      {
          $dbEvents = [];
          $mqttEvents = [];
          foreach ($request->get('event_alarm') as $ev) {
              $dbEvents[] = [
                  'asset_id' => $request->get('asset_id'),
                  'event_alarm_id' => $ev['event_alarm_id'],
                  'event_alarm_char' => $ev['event_alarm_char'],
                  'name' => isset($ev['name']) ? $ev['name'] : null,
                  'time' => Carbon::createFromTimestamp($request->get('timestamp')),
              ];
              $mqttEvents[] = [
                  'asset_id' => $request->get('asset_id'),
                  'event_alarm_id' => $ev['event_alarm_id'],
                  'event_alarm_char' => $ev['event_alarm_char'],
                  'name' => isset($ev['name']) ? $ev['name'] : null,
                  'time' => $request->get('timestamp'),
              ];
          }
  
          // publish to MQTT Broker

          // Mqtt::ConnectAndPublish('adt/event', json_encode($mqttEvents), $request->user()->id);
          Mqtt::ConnectAndPublish('adt/event', json_encode($mqttEvents), 1);

          DB::table('adt')->insert($dbEvents);
  
          return response()->json(['success' => 'success'], 200);
      }

  
      public function get(Request $request)
      {
          return DB::table('adt')->select([
              'uuid',
              'time',
              'asset_id',
              'event_alarm_id',
              'event_alarm_char',
              'name'
          ])->paginate(20);
      }

  }