From 60645817167151609b9be568f27606168ef1f1cb Mon Sep 17 00:00:00 2001
From: VennV <111500380+VennDev@users.noreply.github.com>
Date: Sat, 10 Aug 2024 02:13:55 +0700
Subject: [PATCH] Delete Promise.php

---
 Promise.php | 655 ----------------------------------------------------
 1 file changed, 655 deletions(-)
 delete mode 100644 Promise.php

diff --git a/Promise.php b/Promise.php
deleted file mode 100644
index f271ca5b3..000000000
--- a/Promise.php
+++ /dev/null
@@ -1,655 +0,0 @@
-<?php
-
-/**
- * Vapm - A library support for PHP about Async, Promise, Coroutine, Thread, GreenThread
- *          and other non-blocking methods. The library also includes some Javascript packages
- *          such as Express. The method is based on Fibers & Generator & Processes, requires
- *          you to have php version from >= 8.1
- *
- * Copyright (C) 2023  VennDev
- *
- * This program is free software; you can redistribute it and/or modify
- * it under the terms of the GNU General Public License as published by
- * the Free Software Foundation; either version 2 of the License, or
- * (at your option) any later version.
- *
- * This program is distributed in the hope that it will be useful,
- * but WITHOUT ANY WARRANTY; without even the implied warranty of
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
- * GNU General Public License for more details.
- */
-
-declare(strict_types=1);
-
-namespace vennv\vapm\simultaneous;
-
-use vennv\vapm\System;
-use Fiber;
-use Throwable;
-use ArrayObject;
-use function call_user_func;
-use function count;
-use function is_callable;
-use function microtime;
-
-interface PromiseInterface
-{
-
-    /**
-     * @param mixed $result
-     * @return Promise
-     *
-     * This method is used to set the result of the promise.
-     */
-    public function setResult(mixed $result): Promise;
-
-    /**
-     * @throws Throwable
-     *
-     * This method is used to create a new promise.
-     */
-    public static function c(callable $callback, bool $justGetResult = false): Promise;
-
-    /**
-     * This method is used to get the id of the promise.
-     */
-    public function getId(): int;
-
-    /**
-     * This method is used to get the fiber of the promise.
-     */
-    public function getFiber(): Fiber;
-
-    /**
-     * This method is used to check if the promise is just to get the result.
-     */
-    public function isJustGetResult(): bool;
-
-    /**
-     * This method is used to get the time out of the promise.
-     */
-    public function getTimeOut(): float;
-
-    /**
-     * This method is used to get the time start of the promise.
-     */
-    public function getTimeStart(): float;
-
-    /**
-     * This method is used to get the time end of the promise.
-     */
-    public function getTimeEnd(): float;
-
-    /**
-     * This method is used to set the time out of the promise.
-     */
-    public function setTimeEnd(float $timeEnd): void;
-
-    /**
-     * This method is used to check if the promise is timed out and can be dropped.
-     */
-    public function canDrop(): bool;
-
-    /**
-     * This method is used to get the status of the promise.
-     */
-    public function getStatus(): string;
-
-    /**
-     * This method is used to check if the promise is pending.
-     */
-    public function isPending(): bool;
-
-    /**
-     * This method is used to check if the promise is resolved.
-     */
-    public function isResolved(): bool;
-
-    /**
-     * This method is used to check if the promise is rejected.
-     */
-    public function isRejected(): bool;
-
-    /**
-     * This method is used to get the result of the promise.
-     */
-    public function getResult(): mixed;
-
-    /**
-     * This method is used to get the return when catch or then of the promise is resolved or rejected.
-     */
-    public function getReturn(): mixed;
-
-    /**
-     * @throws Throwable
-     *
-     * This method is used to get the callback of the promise.
-     */
-    public function getCallback(): callable;
-
-    /**
-     * This method is used to resolve the promise.
-     */
-    public function resolve(mixed $value = ''): void;
-
-    /**
-     * This method is used to reject the promise.
-     */
-    public function reject(mixed $value = ''): void;
-
-    /**
-     * This method is used to set the callback when the promise is resolved.
-     */
-    public function then(callable $callback): Promise;
-
-    /**
-     * This method is used to set the callback when the promise is rejected.
-     */
-    public function catch(callable $callback): Promise;
-
-    /**
-     * This method is used to set the callback when the promise is resolved or rejected.
-     */
-    public function finally(callable $callback): Promise;
-
-    /**
-     * @throws Throwable
-     *
-     * This method is used to use the callbacks of the promise.
-     */
-    public function useCallbacks(): void;
-
-    /**
-     * @param array<int, Async|Promise|callable> $promises
-     * @phpstan-param array<int, Async|Promise|callable> $promises
-     * @throws Throwable
-     */
-    public static function all(array $promises): Promise;
-
-    /**
-     * @param array<int, Async|Promise|callable> $promises
-     * @phpstan-param array<int, Async|Promise|callable> $promises
-     * @throws Throwable
-     */
-    public static function allSettled(array $promises): Promise;
-
-    /**
-     * @param array<int, Async|Promise|callable> $promises
-     * @phpstan-param array<int, Async|Promise|callable> $promises
-     * @throws Throwable
-     */
-    public static function any(array $promises): Promise;
-
-    /**
-     * @param array<int, Async|Promise|callable> $promises
-     * @phpstan-param array<int, Async|Promise|callable> $promises
-     * @throws Throwable
-     */
-    public static function race(array $promises): Promise;
-
-}
-
-final class Promise implements PromiseInterface
-{
-
-    private int $id;
-
-    private float $timeOut = 0.0;
-
-    private float $timeEnd = 0.0;
-
-    private mixed $result = null;
-
-    private mixed $return = null;
-
-    private string $status = StatusPromise::PENDING;
-
-    /** @var ArrayObject $callbacksResolve */
-    private ArrayObject $callbacksResolve;
-
-    /** @var callable $callbacksReject */
-    private mixed $callbackReject;
-
-    /** @var callable $callbackFinally */
-    private mixed $callbackFinally;
-
-    private float $timeStart;
-
-    private Fiber $fiber;
-
-    /** @var callable $callback */
-    private mixed $callback;
-
-    private bool $justGetResult;
-
-    /**
-     * @param callable $callback
-     * @param bool $justGetResult
-     * @throws Throwable
-     */
-    public function __construct(callable $callback, bool $justGetResult = false)
-    {
-        System::init();
-
-        $this->callbacksResolve = new ArrayObject();
-        $this->id = EventLoop::generateId();
-        $this->callback = $callback;
-        $this->fiber = new Fiber($callback);
-
-        if ($justGetResult) {
-            $this->result = $this->fiber->start();
-        } else {
-            $resolve = function ($result = ''): void {
-                $this->resolve($result);
-            };
-
-            $reject = function ($result = ''): void {
-                $this->reject($result);
-            };
-
-            $this->fiber->start($resolve, $reject);
-        }
-
-        if (!$this->fiber->isTerminated()) FiberManager::wait();
-
-        $this->justGetResult = $justGetResult;
-
-        $this->timeStart = microtime(true);
-
-        $this->callbacksResolve->offsetSet("master", function ($result): mixed {
-            return $result;
-        });
-
-        $this->callbackReject = function ($result): mixed {
-            return $result;
-        };
-
-        $this->callbackFinally = function (): void {};
-
-        EventLoop::addQueue($this);
-    }
-
-    public function setResult(mixed $result): Promise
-    {
-        $this->result = $result;
-        return $this;
-    }
-
-    /**
-     * @throws Throwable
-     */
-    public static function c(callable $callback, bool $justGetResult = false): Promise
-    {
-        return new self($callback, $justGetResult);
-    }
-
-    public function getId(): int
-    {
-        return $this->id;
-    }
-
-    public function getFiber(): Fiber
-    {
-        return $this->fiber;
-    }
-
-    public function isJustGetResult(): bool
-    {
-        return $this->justGetResult;
-    }
-
-    public function getTimeOut(): float
-    {
-        return $this->timeOut;
-    }
-
-    public function getTimeStart(): float
-    {
-        return $this->timeStart;
-    }
-
-    public function getTimeEnd(): float
-    {
-        return $this->timeEnd;
-    }
-
-    public function setTimeEnd(float $timeEnd): void
-    {
-        $this->timeEnd = $timeEnd;
-    }
-
-    public function canDrop(): bool
-    {
-        return microtime(true) - $this->timeEnd > Settings::TIME_DROP;
-    }
-
-    public function getStatus(): string
-    {
-        return $this->status;
-    }
-
-    public function isPending(): bool
-    {
-        return $this->status === StatusPromise::PENDING;
-    }
-
-    public function isResolved(): bool
-    {
-        return $this->status === StatusPromise::FULFILLED;
-    }
-
-    public function isRejected(): bool
-    {
-        return $this->status === StatusPromise::REJECTED;
-    }
-
-    public function getResult(): mixed
-    {
-        return $this->result;
-    }
-
-    public function getReturn(): mixed
-    {
-        return $this->return;
-    }
-
-    public function getCallback(): callable
-    {
-        return $this->callback;
-    }
-
-    public function resolve(mixed $value = ''): void
-    {
-        if ($this->isPending()) {
-            $this->status = StatusPromise::FULFILLED;
-            $this->result = $value;
-        }
-    }
-
-    public function reject(mixed $value = ''): void
-    {
-        if ($this->isPending()) {
-            $this->status = StatusPromise::REJECTED;
-            $this->result = $value;
-        }
-    }
-
-    public function then(callable $callback): Promise
-    {
-        $this->callbacksResolve[] = $callback;
-        return $this;
-    }
-
-    public function catch(callable $callback): Promise
-    {
-        $this->callbackReject = $callback;
-        return $this;
-    }
-
-    public function finally(callable $callback): Promise
-    {
-        $this->callbackFinally = $callback;
-        return $this;
-    }
-
-    /**
-     * @throws Throwable
-     */
-    public function useCallbacks(): void
-    {
-        $result = $this->result;
-
-        if ($this->isResolved()) {
-            $callbacks = $this->callbacksResolve;
-
-            /** @var callable $master */
-            $master = $callbacks["master"] ?? null;
-
-            if (is_callable($master)) {
-                $this->result = call_user_func($master, $result);
-                unset($callbacks["master"]);
-            }
-
-            if (count($callbacks) > 0) {
-                /** @var callable $callback */
-                $callback = $callbacks[0];
-                $resultFirstCallback = call_user_func($callback, $this->result);
-                $this->result = $resultFirstCallback;
-                $this->return = $resultFirstCallback;
-                $this->checkStatus($callbacks, $this->return);
-            }
-        } else if ($this->isRejected()) {
-            if (is_callable($this->callbackReject)) $this->result = call_user_func($this->callbackReject, $result);
-        }
-        if (is_callable($this->callbackFinally)) call_user_func($this->callbackFinally);
-    }
-
-    /**
-     * @param ArrayObject $callbacks
-     * @param mixed $return
-     */
-    private function checkStatus(ArrayObject $callbacks, mixed $return): void
-    {
-        $lastPromise = null;
-
-        while (count($callbacks) > 0) {
-            $cancel = false;
-
-            /**
-             * @var int|string $case
-             * @var callable $callback
-             */
-            foreach ($callbacks->getArrayCopy() as $case => $callback) {
-                if ($return === null) {
-                    $cancel = true;
-                    break;
-                }
-
-                if ($case !== 0 && $return instanceof Promise) {
-                    EventLoop::addQueue($return);
-
-                    $queue1 = EventLoop::getQueue($return->getId());
-                    $queue2 = MicroTask::getTask($return->getId());
-                    if (!is_null($queue1)) {
-                        $queue1->then($callback);
-                        if (is_callable($this->callbackReject)) $queue1->catch($this->callbackReject);
-                        $lastPromise = $queue1;
-                    } else if (!is_null($queue2)) {
-                        $queue2->then($callback);
-                        if (is_callable($this->callbackReject)) $queue2->catch($this->callbackReject);
-                        $lastPromise = $queue2;
-                    }
-
-                    $callbacks->offsetUnset($case);
-                    continue;
-                }
-
-                if (count($callbacks) === 1) $cancel = true;
-            }
-
-            if ($cancel) break;
-        }
-
-        if ($lastPromise !== null) {
-            $lastPromise->finally($this->callbackFinally);
-        } else {
-            if (is_callable($this->callbackFinally)) call_user_func($this->callbackFinally);
-        }
-    }
-
-    /**
-     * @param array<int, Async|Promise|callable> $promises
-     * @phpstan-param array<int, Async|Promise|callable> $promises
-     * @throws Throwable
-     */
-    public static function all(array $promises): Promise
-    {
-        $promise = new Promise(function ($resolve, $reject) use ($promises): void {
-            $count = count($promises);
-            $results = [];
-            $isSolved = false;
-
-            while (!$isSolved) {
-                foreach ($promises as $index => $promise) {
-                    if (is_callable($promise)) $promise = new Async($promise);
-
-                    if ($promise instanceof Async || $promise instanceof Promise) {
-                        $return = EventLoop::getReturn($promise->getId());
-
-                        if ($return?->isRejected() === true) {
-                            $reject($return->getResult());
-                            $isSolved = true;
-                            break;
-                        }
-
-                        if ($return?->isResolved() === true) {
-                            $results[] = $return->getResult();
-                            unset($promises[$index]);
-                        }
-                    }
-
-                    if (count($results) === $count) {
-                        $resolve($results);
-                        $isSolved = true;
-                    }
-                    FiberManager::wait();
-                }
-
-                if (!$isSolved) FiberManager::wait();
-            }
-        });
-
-        EventLoop::addQueue($promise);
-
-        return $promise;
-    }
-
-    /**
-     * @param array<int, Async|Promise|callable> $promises
-     * @phpstan-param array<int, Async|Promise|callable> $promises
-     * @throws Throwable
-     */
-    public static function allSettled(array $promises): Promise
-    {
-        $promise = new Promise(function ($resolve) use ($promises): void {
-            $count = count($promises);
-            $results = [];
-            $isSolved = false;
-
-            while (!$isSolved) {
-                foreach ($promises as $index => $promise) {
-                    if (is_callable($promise)) $promise = new Async($promise);
-
-                    if ($promise instanceof Async || $promise instanceof Promise) {
-                        $return = EventLoop::getReturn($promise->getId());
-
-                        if ($return !== null) {
-                            $results[] = new PromiseResult($return->getStatus(), $return->getResult());
-                            unset($promises[$index]);
-                        }
-                    }
-
-                    if (count($results) === $count) {
-                        $resolve($results);
-                        $isSolved = true;
-                    }
-                    FiberManager::wait();
-                }
-
-                if (!$isSolved === false) FiberManager::wait();
-            }
-        });
-
-        EventLoop::addQueue($promise);
-
-        return $promise;
-    }
-
-    /**
-     * @param array<int, Async|Promise|callable> $promises
-     * @phpstan-param array<int, Async|Promise|callable> $promises
-     * @throws Throwable
-     */
-    public static function any(array $promises): Promise
-    {
-        $promise = new Promise(function ($resolve, $reject) use ($promises): void {
-            $count = count($promises);
-            $results = [];
-            $isSolved = false;
-
-            while ($isSolved === false) {
-                foreach ($promises as $index => $promise) {
-                    if (is_callable($promise)) $promise = new Async($promise);
-
-                    if ($promise instanceof Async || $promise instanceof Promise) {
-                        $return = EventLoop::getReturn($promise->getId());
-
-                        if ($return?->isRejected() === true) {
-                            $results[] = $return->getResult();
-                            unset($promises[$index]);
-                        }
-
-                        if ($return?->isResolved() === true) {
-                            $resolve($return->getResult());
-                            $isSolved = true;
-                            break;
-                        }
-                    }
-
-                    if (count($results) === $count) {
-                        $reject($results);
-                        $isSolved = true;
-                    }
-                    FiberManager::wait();
-                }
-
-                if ($isSolved === false) FiberManager::wait();
-            }
-        });
-
-        EventLoop::addQueue($promise);
-
-        return $promise;
-    }
-
-    /**
-     * @param array<int, Async|Promise|callable> $promises
-     * @phpstan-param array<int, Async|Promise|callable> $promises
-     * @throws Throwable
-     */
-    public static function race(array $promises): Promise
-    {
-        $promise = new Promise(function ($resolve, $reject) use ($promises): void {
-            $isSolved = false;
-
-            while ($isSolved === false) {
-                foreach ($promises as $promise) {
-                    if (is_callable($promise)) $promise = new Async($promise);
-                    if ($promise instanceof Async || $promise instanceof Promise) {
-                        $return = EventLoop::getReturn($promise->getId());
-
-                        if ($return?->isRejected() === true) {
-                            $reject($return->getResult());
-                            $isSolved = true;
-                            break;
-                        }
-
-                        if ($return?->isResolved() === true) {
-                            $resolve($return->getResult());
-                            $isSolved = true;
-                            break;
-                        }
-                    }
-                    FiberManager::wait();
-                }
-
-                if ($isSolved === false) FiberManager::wait();
-            }
-        });
-
-        EventLoop::addQueue($promise);
-
-        return $promise;
-    }
-
-}
\ No newline at end of file