2021-04-08 12:54:49 +02:00
|
|
|
<?php
|
|
|
|
|
|
|
|
|
|
|
|
namespace JeroenED\Webcron\Repository;
|
|
|
|
|
|
|
|
|
2021-04-13 14:07:11 +02:00
|
|
|
use DateTime;
|
2021-04-08 12:54:49 +02:00
|
|
|
use Doctrine\DBAL\Connection;
|
|
|
|
|
|
|
|
class Job
|
|
|
|
{
|
|
|
|
private Connection $dbcon;
|
|
|
|
|
|
|
|
public function __construct(Connection $dbcon)
|
|
|
|
{
|
|
|
|
$this->dbcon = $dbcon;
|
|
|
|
}
|
|
|
|
|
|
|
|
public function getAllJobs()
|
|
|
|
{
|
|
|
|
$jobsSql = "SELECT * FROM job";
|
|
|
|
$jobsStmt = $this->dbcon->prepare($jobsSql);
|
|
|
|
$jobsRslt = $jobsStmt->execute();
|
|
|
|
$jobs = $jobsRslt->fetchAllAssociative();
|
|
|
|
foreach ($jobs as $key=>&$job) {
|
|
|
|
$job['data'] = json_decode($job['data'], true);
|
|
|
|
}
|
|
|
|
return $jobs;
|
|
|
|
}
|
2021-04-13 14:07:11 +02:00
|
|
|
|
|
|
|
public function addJob(array $values)
|
|
|
|
{
|
|
|
|
if(empty($values['type']) ||
|
|
|
|
empty($values['name']) ||
|
|
|
|
empty($values['delay']) ||
|
|
|
|
empty($values['nextrun'])
|
|
|
|
) {
|
|
|
|
return ['success' => false, 'message' => 'Some fields are empty'];
|
|
|
|
}
|
|
|
|
|
|
|
|
if(empty($values['lastrun'])) {
|
|
|
|
$values['lastrun'] = NULL;
|
|
|
|
} else {
|
|
|
|
$values['lastrun'] = DateTime::createFromFormat('m/d/Y g:i:s A',$values['lastrun'])->getTimestamp();
|
|
|
|
}
|
|
|
|
|
|
|
|
$values['nextrun'] = DateTime::createFromFormat('m/d/Y g:i:s A', $values['nextrun'])->getTimestamp();
|
|
|
|
$data['type'] = $values['type'];
|
|
|
|
|
|
|
|
switch($data['type'])
|
|
|
|
{
|
2021-04-15 13:52:06 +02:00
|
|
|
case 'local':
|
|
|
|
$data['command'] = $values['command'];
|
|
|
|
$data['host'] = 'localhost';
|
|
|
|
break;
|
2021-04-15 13:52:27 +02:00
|
|
|
case 'ssh':
|
|
|
|
$data['host'] = $values['host'];
|
|
|
|
$data['user'] = $values['user'];
|
|
|
|
if(!empty($_FILES['privkey']['tmp_name'])) {
|
|
|
|
$newsecretkey = count($values['secretval']);
|
|
|
|
$values['secretid'][$newsecretkey] = 'ssh-privkey';
|
|
|
|
$values['secretval'][$newsecretkey] = base64_encode(file_get_contents($_FILES['privkey']['tmp_name']));
|
|
|
|
}
|
|
|
|
$data['command'] = $values['command'];
|
|
|
|
break;
|
2021-04-13 14:07:11 +02:00
|
|
|
case 'http':
|
|
|
|
$parsedUrl = parse_url($values['url']);
|
|
|
|
$data['url'] = $values['url'];
|
2021-04-13 14:44:58 +02:00
|
|
|
$data['basicauth-username'] = $values['basicauth-username'];
|
2021-04-13 14:07:11 +02:00
|
|
|
if(empty($parsedUrl['host'])) {
|
|
|
|
return ['success' => false, 'message' => 'Some data was invalid'];
|
|
|
|
}
|
|
|
|
$data['host'] = $parsedUrl['host'];
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
|
2021-04-13 14:44:58 +02:00
|
|
|
if(!empty($values['secretval'])) {
|
|
|
|
foreach($values['secretval'] as $key => $name) {
|
|
|
|
if(!empty($name)) $data['secrets'][$values['secretid'][$key]] = base64_encode(Secret::encrypt($values['secretval'][$key]));
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2021-04-13 14:07:11 +02:00
|
|
|
$data = json_encode($data);
|
|
|
|
$addJobSql = "INSERT INTO job(name, data, delay, nextrun, lastrun) VALUES (:name, :data, :delay, :nextrun, :lastrun)";
|
|
|
|
|
|
|
|
$addJobStmt = $this->dbcon->prepare($addJobSql);
|
|
|
|
$addJobStmt->execute([':name' => $values['name'], ':data' => $data, ':delay' => $values['delay'], ':nextrun' => $values['nextrun'], ':lastrun' => $values['lastrun'], ]);
|
|
|
|
|
|
|
|
return ['success' => true, 'message' => 'Cronjob succesfully added'];
|
|
|
|
}
|
2021-04-13 14:44:58 +02:00
|
|
|
|
|
|
|
public function getJob(int $id, bool $withSecrets = false) {
|
|
|
|
$jobSql = "SELECT * FROM job WHERE id = :id";
|
|
|
|
$jobStmt = $this->dbcon->prepare($jobSql);
|
|
|
|
$jobRslt = $jobStmt->execute([':id' => $id])->fetchAssociative();
|
|
|
|
|
|
|
|
$jobRslt['data'] = json_decode($jobRslt['data'], true);
|
|
|
|
if(!empty($jobRslt['data']['secrets'])) {
|
|
|
|
foreach ($jobRslt['data']['secrets'] as $key => &$value) {
|
|
|
|
$value = ($withSecrets) ? Secret::decrypt(base64_decode($value)) : '';
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
return $jobRslt;
|
|
|
|
}
|
2021-04-08 12:54:49 +02:00
|
|
|
}
|