Thanasis Naskos / CUREX - Knowledge Extraction Analytics - KEA

Blame view

api/app/Http/Controllers/V1/Partners/XlsiemController.php 2.92 KB
edit raw normal view history
0d8c0f816   Thanasis Naskos   initial commit 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
 
  <?php
  
  namespace App\Http\Controllers\V1\Partners;
  
  use App\Http\Controllers\Controller;
  use App\Http\Requests\XlsiemRequest;
  use Carbon\Carbon;
  use Illuminate\Support\Facades\DB;
  use Salman\Mqtt\Facades\Mqtt;
  
  class XlsiemController extends Controller
  {
      public function store(XlsiemRequest $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')),
                  'source_ip' => $ev['source_ip'],
                  'source_port' => isset($ev['source_port']) ? $ev['source_port'] : null,
                  'destination_ip' => $ev['destination_ip'],
                  'destination_port' => isset($ev['destination_port']) ? $ev['destination_port'] : null,
                  'priority' => isset($ev['priority']) ? $ev['priority'] : null,
                  'confidence' => isset($ev['confidence']) ? $ev['confidence'] : null,
              ];
e0d6f0a8e   Thanasis Naskos   Changed the forma... 
31
 
              $eventAlarms[] = [
0d8c0f816   Thanasis Naskos   initial commit 
32
33
34
 
                  'event_alarm_id' => $ev['event_alarm_id'],
                  'event_alarm_char' => $ev['event_alarm_char'],
                  'name' => isset($ev['name']) ? $ev['name'] : null,
0d8c0f816   Thanasis Naskos   initial commit 
35
36
37
38
39
40
41
 
                  'source_ip' => $ev['source_ip'],
                  'source_port' => isset($ev['source_port']) ? $ev['source_port'] : null,
                  'destination_ip' => $ev['destination_ip'],
                  'destination_port' => isset($ev['destination_port']) ? $ev['destination_port'] : null,
                  'priority' => isset($ev['priority']) ? $ev['priority'] : null,
                  'confidence' => isset($ev['confidence']) ? $ev['confidence'] : null
              ];
e0d6f0a8e   Thanasis Naskos   Changed the forma... 
42
 
              Mqtt::ConnectAndPublish('xlsiem/event', json_encode($mqttEvents), 1);
0d8c0f816   Thanasis Naskos   initial commit 
43
 
          }
e0d6f0a8e   Thanasis Naskos   Changed the forma... 
44
45
46
47
48
49
 
          $mqttEvents = {
          	'asset_id' => $request->get('asset_id'),
          	'timestamp' => Carbon::createFromTimestamp($request->get('timestamp')),
          	'event_alarm' => $eventAlarms
          };
0d8c0f816   Thanasis Naskos   initial commit 
50
51
 
  
          // publish to MQTT Broker
7c65431cf   Chris Bellas   Temporary removed... 
52
53
 
          //Mqtt::ConnectAndPublish('xlsiem/event', json_encode($mqttEvents), $request->user()->id);
          Mqtt::ConnectAndPublish('xlsiem/event', json_encode($mqttEvents), 1);
0d8c0f816   Thanasis Naskos   initial commit 
54
55
56
57
 
          DB::table('xlsiem')->insert($dbEvents);
  
          return response()->json(['success' => 'success'], 200);
      }
2f4aeec4c   Chris Bellas   Added GET endpoin... 
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
 
  
      public function get()
      {
          return DB::table('xlsiem')->select([
              'asset_id',
              'event_alarm_id',
              'event_alarm_char',
              'name',
              'time',
              'source_ip',
              'source_port',
              'destination_ip',
              'destination_port',
              'priority',
              'confidence',
          ])->paginate(20);
      }
0d8c0f816   Thanasis Naskos   initial commit 
75
 
  }