?HAMA

Edit File Size: 3.96 KB

/home/nshryvcy/himaltourism.com/wp-content/plugins/mailpoet/lib/Automation/Engine/Data/AutomationRunLog.php

Text Base64

<?php declare(strict_types = 1);

namespace MailPoet\Automation\Engine\Data;

if (!defined('ABSPATH')) exit;

use DateTimeImmutable;
use InvalidArgumentException;
use MailPoet\Automation\Engine\Utils\Json;
use Throwable;

class AutomationRunLog {

const STATUS_RUNNING = 'running';
  const STATUS_COMPLETED = 'completed';
  const STATUS_FAILED = 'failed';

/** @var int */
  private $id;

/** @var int */
  private $automationRunId;

/** @var DateTimeImmutable */
  private $startedAt;

/** @var DateTimeImmutable|null */
  private $completedAt;

/** @var string */
  private $status;

/** @var array */
  private $error;

/** @var array */
  private $data;

/** @var string */
  private $stepId;

public function __construct(
    int $automationRunId,
    string $stepId,
    int $id = null
  ) {
    $this->automationRunId = $automationRunId;
    $this->stepId = $stepId;
    $this->status = self::STATUS_RUNNING;

if ($id) {
      $this->id = $id;
    }

$this->startedAt = new DateTimeImmutable();

$this->error = [];
    $this->data = [];
  }

public function getId(): int {
    return $this->id;
  }

public function getAutomationRunId(): int {
    return $this->automationRunId;
  }

public function getStepId(): string {
    return $this->stepId;
  }

public function getStatus(): string {
    return $this->status;
  }

public function getError(): array {
    return $this->error;
  }

public function getData(): array {
    return $this->data;
  }

public function getCompletedAt(): ?DateTimeImmutable {
    return $this->completedAt;
  }

/**
   * @param string $key
   * @param mixed $value
   * @return void
   */
  public function setData(string $key, $value): void {
    if (!$this->isDataStorable($value)) {
      throw new InvalidArgumentException("Invalid data provided for key '$key'. Only scalar values and arrays of scalar values are allowed.");
    }
    $this->data[$key] = $value;
  }

public function getStartedAt(): DateTimeImmutable {
    return $this->startedAt;
  }

public function toArray(): array {
    return [
      'automation_run_id' => $this->automationRunId,
      'step_id' => $this->stepId,
      'status' => $this->status,
      'started_at' => $this->startedAt->format(DateTimeImmutable::W3C),
      'completed_at' => $this->completedAt ? $this->completedAt->format(DateTimeImmutable::W3C) : null,
      'error' => Json::encode($this->error),
      'data' => Json::encode($this->data),
    ];
  }

public function markCompletedSuccessfully(): void {
    $this->status = self::STATUS_COMPLETED;
    $this->completedAt = new DateTimeImmutable();
  }

public function markFailed(): void {
    $this->status = self::STATUS_FAILED;
    $this->completedAt = new DateTimeImmutable();
  }

public function setError(Throwable $error): void {
    $error = [
      'message' => $error->getMessage(),
      'errorClass' => get_class($error),
      'code' => $error->getCode(),
      'trace' => $error->getTrace(),
    ];

$this->error = $error;
  }

public static function fromArray(array $data): self {
    $automationRunLog = new AutomationRunLog((int)$data['automation_run_id'], $data['step_id']);
    $automationRunLog->id = (int)$data['id'];
    $automationRunLog->status = $data['status'];
    $automationRunLog->error = Json::decode($data['error']);
    $automationRunLog->data = Json::decode($data['data']);
    $automationRunLog->startedAt = new DateTimeImmutable($data['started_at']);

if ($data['completed_at']) {
      $automationRunLog->completedAt = new DateTimeImmutable($data['completed_at']);
    }

return $automationRunLog;
  }

/**
   * @param mixed $data
   * @return bool
   */
  private function isDataStorable($data): bool {
    if (is_object($data)) {
      return false;
    }

if (is_scalar($data)) {
      return true;
    }

if (!is_array($data)) {
      return false;
    }

foreach ($data as $value) {
      if (!$this->isDataStorable($value)) {
        return false;
      }
    }

return true;
  }
}

Exit & Reset Text mode: syntax highlighting auto-detects file type.

Name	Size	Perms	Modified	Actions
Automation.php	5.84 KB	lrw-r--r--	2023-04-04 05:35:40	Edit Download recursive recursive
AutomationRun.php	3.06 KB	lrw-r--r--	2023-04-04 05:35:40	Edit Download recursive recursive
AutomationRunLog.php	3.96 KB	lrw-r--r--	2023-04-04 05:35:40	Edit Download recursive recursive
AutomationStatistics.php	1.16 KB	lrw-r--r--	2023-04-04 05:35:40	Edit Download recursive recursive
AutomationTemplate.php	2.07 KB	lrw-r--r--	2023-04-04 05:35:40	Edit Download recursive recursive
Field.php	1.16 KB	lrw-r--r--	2023-04-04 05:35:40	Edit Download recursive recursive
index.php	0 B	lrw-r--r--	2023-04-04 05:35:40	Edit Download recursive recursive
NextStep.php	491 B	lrw-r--r--	2023-04-04 05:35:40	Edit Download recursive recursive
Step.php	1.84 KB	lrw-r--r--	2023-04-04 05:35:40	Edit Download recursive recursive
StepRunArgs.php	3.31 KB	lrw-r--r--	2023-04-04 05:35:40	Edit Download recursive recursive
StepValidationArgs.php	1.83 KB	lrw-r--r--	2023-04-04 05:35:40	Edit Download recursive recursive
Subject.php	909 B	lrw-r--r--	2023-04-04 05:35:40	Edit Download recursive recursive
SubjectEntry.php	1.18 KB	lrw-r--r--	2023-04-04 05:35:40	Edit Download recursive recursive

Directory Contents