mirror of https://github.com/MISP/MISP
75 lines
2.3 KiB
PHP
75 lines
2.3 KiB
PHP
<?php
|
|
App::uses('AppModel', 'Model');
|
|
|
|
class Job extends AppModel
|
|
{
|
|
public $belongsTo = array(
|
|
'Org' => array(
|
|
'className' => 'Organisation',
|
|
'foreignKey' => 'org_id',
|
|
'order' => array(),
|
|
'fields' => array('id', 'name', 'uuid')
|
|
),
|
|
);
|
|
|
|
public function beforeValidate($options = array())
|
|
{
|
|
parent::beforeValidate();
|
|
$date = date('Y-m-d H:i:s');
|
|
if (empty($this->data['Job']['id'])) {
|
|
$this->data['Job']['date_created'] = $date;
|
|
$this->data['Job']['date_modified'] = $date;
|
|
} else {
|
|
$this->data['Job']['date_modified'] = $date;
|
|
}
|
|
}
|
|
|
|
public function cache($type, $user)
|
|
{
|
|
$extra = null;
|
|
$extra2 = null;
|
|
$shell = 'Event';
|
|
$this->create();
|
|
$data = array(
|
|
'worker' => 'cache',
|
|
'job_type' => 'cache_' . $type,
|
|
'job_input' => $user['Role']['perm_site_admin'] ? 'All events.' : 'Events visible to: ' . $user['Organisation']['name'],
|
|
'status' => 0,
|
|
'retries' => 0,
|
|
'org_id' => $user['Role']['perm_site_admin'] ? 0 : $user['org_id'],
|
|
'message' => 'Fetching events.',
|
|
);
|
|
if ($type === 'md5' || $type === 'sha1' || $type === 'sha256') {
|
|
$extra = $type;
|
|
$type = 'hids';
|
|
}
|
|
if ($type === 'csv_all' || $type === 'csv_sig') {
|
|
$extra = $type;
|
|
$type = 'csv';
|
|
}
|
|
if ($type === 'suricata' || $type === 'snort') {
|
|
$extra = $type;
|
|
$type = 'nids';
|
|
$extra2 = isset($user['nids_sid']) ? $user['nids_sid'] : 0;
|
|
}
|
|
if ($type === 'bro') {
|
|
$extra = $type;
|
|
$type = 'bro';
|
|
$extra2 = isset($user['nids_sid']) ? $user['nids_sid'] : 0;
|
|
}
|
|
if ($type === 'rpz') {
|
|
$extra = $type;
|
|
}
|
|
$this->save($data);
|
|
$id = $this->id;
|
|
$process_id = CakeResque::enqueue(
|
|
'cache',
|
|
$shell . 'Shell',
|
|
array('cache' . $type, $user['id'], $id, $extra, $extra2),
|
|
true
|
|
);
|
|
$this->saveField('process_id', $process_id);
|
|
return $id;
|
|
}
|
|
}
|