mirror of https://github.com/MISP/MISP
chg: [internal] Use FileAccessTool for publishing sightings
parent
d74343b7b6
commit
d983d10c14
|
@ -1,6 +1,7 @@
|
|||
<?php
|
||||
App::uses('Folder', 'Utility');
|
||||
App::uses('File', 'Utility');
|
||||
App::uses('FileAccessTool', 'Tools');
|
||||
require_once 'AppShell.php';
|
||||
|
||||
/**
|
||||
|
@ -404,7 +405,6 @@ class EventShell extends AppShell
|
|||
|
||||
public function publish_sightings()
|
||||
{
|
||||
$this->ConfigLoad->execute();
|
||||
if (empty($this->args[0]) || empty($this->args[2]) || empty($this->args[3])) {
|
||||
die('Usage: ' . $this->Server->command_line_functions['event_management_tasks']['data']['Publish sightings'] . PHP_EOL);
|
||||
}
|
||||
|
@ -414,14 +414,8 @@ class EventShell extends AppShell
|
|||
|
||||
$sightingsUuidsToPush = [];
|
||||
if (isset($this->args[4])) { // push just specific sightings
|
||||
$path = APP . 'tmp/cache/ingest' . DS . $this->args[4];
|
||||
$tempFile = new File($path);
|
||||
$inputData = $tempFile->read();
|
||||
if ($inputData === false) {
|
||||
$this->error("File `$path` not found.");
|
||||
}
|
||||
$sightingsUuidsToPush = $this->Event->jsonDecode($inputData);
|
||||
$tempFile->delete();
|
||||
$path = $this->args[4][0] === '/' ? $this->args[4] : (APP . 'tmp/cache/ingest' . DS . $this->args[4]);
|
||||
$sightingsUuidsToPush = $this->Event->jsonDecode(FileAccessTool::readAndDelete($path));
|
||||
}
|
||||
|
||||
$this->Event->Behaviors->unload('SysLogLogable.SysLogLogable');
|
||||
|
@ -528,9 +522,8 @@ class EventShell extends AppShell
|
|||
|
||||
$inputFile = $this->args[0];
|
||||
$inputFile = $inputFile[0] === '/' ? $inputFile : APP . 'tmp/cache/ingest' . DS . $inputFile;
|
||||
$inputData = FileAccessTool::readFromFile($inputFile);
|
||||
$inputData = FileAccessTool::readAndDelete($inputFile);
|
||||
$inputData = $this->Event->jsonDecode($inputData);
|
||||
FileAccessTool::deleteFile($inputFile);
|
||||
Configure::write('CurrentUserId', $inputData['user']['id']);
|
||||
$this->Event->processFreeTextData(
|
||||
$inputData['user'],
|
||||
|
@ -552,9 +545,8 @@ class EventShell extends AppShell
|
|||
|
||||
$inputFile = $this->args[0];
|
||||
$inputFile = $inputFile[0] === '/' ? $inputFile : APP . 'tmp/cache/ingest' . DS . $inputFile;
|
||||
$inputData = FileAccessTool::readFromFile($inputFile);
|
||||
$inputData = FileAccessTool::readAndDelete($inputFile);
|
||||
$inputData = $this->Event->jsonDecode($inputData);
|
||||
FileAccessTool::deleteFile($inputFile);
|
||||
Configure::write('CurrentUserId', $inputData['user']['id']);
|
||||
$this->Event->processModuleResultsData(
|
||||
$inputData['user'],
|
||||
|
|
|
@ -47,6 +47,18 @@ class FileAccessTool
|
|||
return $content;
|
||||
}
|
||||
|
||||
/**
|
||||
* @param string $file
|
||||
* @return string
|
||||
* @throws Exception
|
||||
*/
|
||||
public static function readAndDelete($file)
|
||||
{
|
||||
$content = self::readFromFile($file);
|
||||
self::deleteFile($file);
|
||||
return $content;
|
||||
}
|
||||
|
||||
/**
|
||||
* @param string $file
|
||||
* @param mixed $content
|
||||
|
|
|
@ -1,7 +1,7 @@
|
|||
<?php
|
||||
App::uses('AppModel', 'Model');
|
||||
App::uses('CakeEmail', 'Network/Email');
|
||||
App::uses('RandomTool', 'Tools');
|
||||
App::uses('FileAccessTool', 'Tools');
|
||||
App::uses('AttachmentTool', 'Tools');
|
||||
App::uses('TmpFileTool', 'Tools');
|
||||
App::uses('SendEmailTemplate', 'Tools');
|
||||
|
@ -4544,14 +4544,8 @@ class Event extends AppModel
|
|||
|
||||
$command = ['publish_sightings', $id, $passAlong, $jobId, $user['id']];
|
||||
if (!empty($sightingUuids)) {
|
||||
$randomFileName = $this->generateRandomFileName() . '.json';
|
||||
App::uses('File', 'Utility');
|
||||
$tempFile = new File(APP . 'tmp/cache/ingest' . DS . $randomFileName, true, 0644);
|
||||
$writeResult = $tempFile->write(json_encode($sightingUuids));
|
||||
if (!$writeResult) {
|
||||
throw new Exception("Could not write file content");
|
||||
}
|
||||
$command[] = $randomFileName;
|
||||
$filePath = FileAccessTool::writeToTempFile(json_encode($sightingUuids));
|
||||
$command[] = $filePath;
|
||||
}
|
||||
|
||||
$processId = CakeResque::enqueue(Job::WORKER_PRIO, 'EventShell', $command, true);
|
||||
|
|
Loading…
Reference in New Issue