|
@@ -96,22 +96,22 @@ discard block |
|
|
block discarded – undo |
|
96
|
96
|
if ($item instanceof Item) { |
|
97
|
97
|
try { |
|
98
|
98
|
$set = [ |
|
99
|
|
- self::DRIVER_DATA_WRAPPER_INDEX => new Binary($this->encode($item->get()), Binary::TYPE_GENERIC), |
|
100
|
|
- self::DRIVER_TAGS_WRAPPER_INDEX => new Binary($this->encode($item->getTags()), Binary::TYPE_GENERIC), |
|
101
|
|
- self::DRIVER_EDATE_WRAPPER_INDEX => ($item->getTtl() > 0 ? new UTCDateTime((time() + $item->getTtl()) * 1000) : new UTCDateTime(time() * 1000)), |
|
|
99
|
+ self::DRIVER_DATA_WRAPPER_INDEX => new Binary($this->encode($item->get()), Binary::TYPE_GENERIC), |
|
|
100
|
+ self::DRIVER_TAGS_WRAPPER_INDEX => new Binary($this->encode($item->getTags()), Binary::TYPE_GENERIC), |
|
|
101
|
+ self::DRIVER_EDATE_WRAPPER_INDEX => ($item->getTtl() > 0 ? new UTCDateTime((time() + $item->getTtl()) * 1000) : new UTCDateTime(time() * 1000)), |
|
102
|
102
|
]; |
|
103
|
103
|
|
|
104
|
104
|
if(!empty($this->config[ 'itemDetailedDate' ])){ |
|
105
|
105
|
$set += [ |
|
106
|
|
- self::DRIVER_MDATE_WRAPPER_INDEX => ($item->getModificationDate() ? new UTCDateTime(($item->getModificationDate()->getTimestamp()) * 1000) : new UTCDateTime(time() * 1000)), |
|
107
|
|
- self::DRIVER_CDATE_WRAPPER_INDEX => ($item->getCreationDate() ? new UTCDateTime(($item->getCreationDate()->getTimestamp()) * 1000) : new UTCDateTime(time() * 1000)), |
|
|
106
|
+ self::DRIVER_MDATE_WRAPPER_INDEX => ($item->getModificationDate() ? new UTCDateTime(($item->getModificationDate()->getTimestamp()) * 1000) : new UTCDateTime(time() * 1000)), |
|
|
107
|
+ self::DRIVER_CDATE_WRAPPER_INDEX => ($item->getCreationDate() ? new UTCDateTime(($item->getCreationDate()->getTimestamp()) * 1000) : new UTCDateTime(time() * 1000)), |
|
108
|
108
|
]; |
|
109
|
109
|
} |
|
110
|
110
|
|
|
111
|
111
|
$result = (array)$this->getCollection()->updateOne( |
|
112
|
|
- ['_id' => $item->getEncodedKey()], |
|
113
|
|
- ['$set' => $set], |
|
114
|
|
- ['upsert' => true, 'multiple' => false] |
|
|
112
|
+ ['_id' => $item->getEncodedKey()], |
|
|
113
|
+ ['$set' => $set], |
|
|
114
|
+ ['upsert' => true, 'multiple' => false] |
|
115
|
115
|
); |
|
116
|
116
|
} catch (MongoDBException $e) { |
|
117
|
117
|
throw new phpFastCacheDriverException('Got an exception while trying to write data to MongoDB server', null, $e); |
|
@@ -133,15 +133,15 @@ discard block |
|
|
block discarded – undo |
|
133
|
133
|
|
|
134
|
134
|
if ($document) { |
|
135
|
135
|
$return = [ |
|
136
|
|
- self::DRIVER_DATA_WRAPPER_INDEX => $this->decode($document[ self::DRIVER_DATA_WRAPPER_INDEX ]->getData()), |
|
137
|
|
- self::DRIVER_TAGS_WRAPPER_INDEX => $this->decode($document[ self::DRIVER_TAGS_WRAPPER_INDEX ]->getData()), |
|
138
|
|
- self::DRIVER_EDATE_WRAPPER_INDEX => (new \DateTime())->setTimestamp($document[ self::DRIVER_EDATE_WRAPPER_INDEX ]->toDateTime()->getTimestamp()), |
|
|
136
|
+ self::DRIVER_DATA_WRAPPER_INDEX => $this->decode($document[ self::DRIVER_DATA_WRAPPER_INDEX ]->getData()), |
|
|
137
|
+ self::DRIVER_TAGS_WRAPPER_INDEX => $this->decode($document[ self::DRIVER_TAGS_WRAPPER_INDEX ]->getData()), |
|
|
138
|
+ self::DRIVER_EDATE_WRAPPER_INDEX => (new \DateTime())->setTimestamp($document[ self::DRIVER_EDATE_WRAPPER_INDEX ]->toDateTime()->getTimestamp()), |
|
139
|
139
|
]; |
|
140
|
140
|
|
|
141
|
141
|
if(!empty($this->config[ 'itemDetailedDate' ])){ |
|
142
|
142
|
$return += [ |
|
143
|
|
- self::DRIVER_MDATE_WRAPPER_INDEX => (new \DateTime())->setTimestamp($document[ self::DRIVER_MDATE_WRAPPER_INDEX ]->toDateTime()->getTimestamp()), |
|
144
|
|
- self::DRIVER_CDATE_WRAPPER_INDEX => (new \DateTime())->setTimestamp($document[ self::DRIVER_CDATE_WRAPPER_INDEX ]->toDateTime()->getTimestamp()), |
|
|
143
|
+ self::DRIVER_MDATE_WRAPPER_INDEX => (new \DateTime())->setTimestamp($document[ self::DRIVER_MDATE_WRAPPER_INDEX ]->toDateTime()->getTimestamp()), |
|
|
144
|
+ self::DRIVER_CDATE_WRAPPER_INDEX => (new \DateTime())->setTimestamp($document[ self::DRIVER_CDATE_WRAPPER_INDEX ]->toDateTime()->getTimestamp()), |
|
145
|
145
|
]; |
|
146
|
146
|
} |
|
147
|
147
|
|
|
@@ -281,15 +281,15 @@ discard block |
|
|
block discarded – undo |
|
281
|
281
|
public function getStats() |
|
282
|
282
|
{ |
|
283
|
283
|
$serverStats = $this->instance->getManager()->executeCommand('phpFastCache', new Command([ |
|
284
|
|
- 'serverStatus' => 1, |
|
285
|
|
- 'recordStats' => 0, |
|
286
|
|
- 'repl' => 0, |
|
287
|
|
- 'metrics' => 0, |
|
|
284
|
+ 'serverStatus' => 1, |
|
|
285
|
+ 'recordStats' => 0, |
|
|
286
|
+ 'repl' => 0, |
|
|
287
|
+ 'metrics' => 0, |
|
288
|
288
|
]))->toArray()[ 0 ]; |
|
289
|
289
|
|
|
290
|
290
|
$collectionStats = $this->instance->getManager()->executeCommand('phpFastCache', new Command([ |
|
291
|
|
- 'collStats' => (isset($this->config[ 'collectionName' ]) ? $this->config[ 'collectionName' ] : 'Cache'), |
|
292
|
|
- 'verbose' => true, |
|
|
291
|
+ 'collStats' => (isset($this->config[ 'collectionName' ]) ? $this->config[ 'collectionName' ] : 'Cache'), |
|
|
292
|
+ 'verbose' => true, |
|
293
|
293
|
]))->toArray()[ 0 ]; |
|
294
|
294
|
|
|
295
|
295
|
$array_filter_recursive = function ($array, callable $callback = null) use (&$array_filter_recursive) { |
|
@@ -318,14 +318,14 @@ discard block |
|
|
block discarded – undo |
|
318
|
318
|
$collectionStats = $array_filter_recursive($collectionStats, $callback); |
|
319
|
319
|
|
|
320
|
320
|
$stats = (new DriverStatistic()) |
|
321
|
|
- ->setInfo('MongoDB version ' . $serverStats->version . ', Uptime (in days): ' . round($serverStats->uptime / 86400, |
|
322
|
|
- 1) . "\n For more information see RawData.") |
|
323
|
|
- ->setSize($collectionStats->size) |
|
324
|
|
- ->setData(implode(', ', array_keys($this->itemInstances))) |
|
325
|
|
- ->setRawData([ |
|
|
321
|
+ ->setInfo('MongoDB version ' . $serverStats->version . ', Uptime (in days): ' . round($serverStats->uptime / 86400, |
|
|
322
|
+ 1) . "\n For more information see RawData.") |
|
|
323
|
+ ->setSize($collectionStats->size) |
|
|
324
|
+ ->setData(implode(', ', array_keys($this->itemInstances))) |
|
|
325
|
+ ->setRawData([ |
|
326
|
326
|
'serverStatus' => $serverStats, |
|
327
|
327
|
'collStats' => $collectionStats, |
|
328
|
|
- ]); |
|
|
328
|
+ ]); |
|
329
|
329
|
|
|
330
|
330
|
return $stats; |
|
331
|
331
|
} |