| | |
|---|
| | | use JVBase\managers\Cache; |
|---|
| | | use JVBase\managers\CustomTable; |
|---|
| | | use LogicException; |
|---|
| | | use Throwable; |
|---|
| | | |
|---|
| | | class Storage |
|---|
| | | { |
|---|
| | |
|---|
| | | public function __construct() |
|---|
| | | { |
|---|
| | | $this->defineTables(); |
|---|
| | | $this->cache = Cache::for('queue', DAY_IN_SECONDS)->user(); |
|---|
| | | $this->cache = Cache::for('queue', null, DAY_IN_SECONDS)->user(); |
|---|
| | | } |
|---|
| | | |
|---|
| | | public function hasProcessingOperations(): bool |
|---|
| | |
|---|
| | | $result = $callback(); |
|---|
| | | $this->table->commit(); |
|---|
| | | return $result; |
|---|
| | | } catch (\Throwable $e) { |
|---|
| | | } catch (Throwable $e) { |
|---|
| | | $this->table->rollback(); |
|---|
| | | error_log('[Storage] Transaction rolled back: ' . $e->getMessage()); |
|---|
| | | throw $e; |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * @throws \Throwable |
|---|
| | | * @throws Throwable |
|---|
| | | */ |
|---|
| | | public function replaceDependency(string $fromId, string $toId): int |
|---|
| | | { |
|---|
