Create New Item
Item Type
File
Folder
Item Name
Search file in folder and subfolders...
Are you sure want to rename?
primogenial
/
languages
/
wp-content
/
plugins
/
mailpoet
/
lib
/
Automation
/
Engine
/
Storage
:
WorkflowRunLogStorage.php
Advanced Search
Upload
New Item
Settings
Back
Back Up
Advanced Editor
Save
<?php declare(strict_types = 1); namespace MailPoet\Automation\Engine\Storage; if (!defined('ABSPATH')) exit; use MailPoet\Automation\Engine\Data\WorkflowRunLog; use MailPoet\Automation\Engine\Exceptions; use MailPoet\InvalidStateException; use wpdb; class WorkflowRunLogStorage { /** @var string */ private $table; /** @var wpdb */ private $wpdb; public function __construct() { global $wpdb; $this->table = $wpdb->prefix . 'mailpoet_workflow_run_logs'; $this->wpdb = $wpdb; } public function createWorkflowRunLog(WorkflowRunLog $workflowRunLog): int { $result = $this->wpdb->insert($this->table, $workflowRunLog->toArray()); if ($result === false) { throw Exceptions::databaseError($this->wpdb->last_error); } return $this->wpdb->insert_id; } public function getWorkflowRunLog(int $id): ?WorkflowRunLog { $table = esc_sql($this->table); $query = $this->wpdb->prepare("SELECT * FROM $table WHERE id = %d", $id); if (!is_string($query)) { throw InvalidStateException::create(); } $result = $this->wpdb->get_row($query, ARRAY_A); if ($result) { $data = (array)$result; return WorkflowRunLog::fromArray($data); } return null; } /** * @param int $workflowRunId * @return WorkflowRunLog[] * @throws InvalidStateException */ public function getLogsForWorkflowRun(int $workflowRunId): array { $table = esc_sql($this->table); $query = $this->wpdb->prepare(" SELECT * FROM $table WHERE workflow_run_id = %d ORDER BY id ASC ", $workflowRunId); if (!is_string($query)) { throw InvalidStateException::create(); } $results = $this->wpdb->get_results($query, ARRAY_A); if (!is_array($results)) { throw InvalidStateException::create(); } if ($results) { return array_map(function($data) { return WorkflowRunLog::fromArray($data); }, $results); } return []; } public function truncate(): void { $table = esc_sql($this->table); $sql = "truncate $table"; $this->wpdb->query($sql); } }