PSR-16 SimpleCache Implementation using MongoDB

v3.0.0 2022-09-19 18:03 UTC

This package is auto-updated.

Last update: 2024-04-19 21:45:00 UTC


Build Status Scrutinizer Code Quality Coverage Status

Latest Stable Version Latest Unstable Version License

Total Downloads Daily Downloads Monthly Downloads


PSR-16 SimpleCache Implementation using MongoDB


Requires PHP 7.0 (or later).


To add the library as a local, per-project dependency use Composer! Simply add a dependency on subjective-php/psr-cache-mongodb to your project's composer.json file such as:

composer require subjective-php/psr-cache-mongodb


Developers may be contacted at:

Project Build

With a checkout of the code get Composer in your PATH and run:

composer install

Example Caching PSR-7 Response Messages with Guzzle Client

Below is a very simplified example of caching responses to GET requests in mongo.


use Chadicus\Psr\SimplCache\SerializerInterface;
use Chadicus\Psr\SimplCache\MongoCache;
use GuzzleHttp\Psr7;
use MongoDB\Client;
use Psr\SimpleCache\InvalidArgumentException;

 * Provides serialization from mongo documents to PSR-7 response objects.
final class Psr7Serializer implements SerializerInterface
     * Unserializes cached data into the original state.
     * @param array $data The data to unserialize.
     * @return Diactoros\Response
    public function unserialize(array $data)
        return new Psr7\Response(

     * Serializes the given data for storage in caching.
     * @param mixed $value The data to serialize for caching.
     * @return array The result of serializing the given $data.
     * @throws InvalidArgumentException Thrown if the given value is not a PSR-7 Response instance.
    public function serialize($value) : array
        if (!is_a($value, '\\Psr\\Http\\Message\\ResponseInterface')) {
            throw new class('$value was not a PSR-7 Response') extends \Exception implements InvalidArgumentException { };

        return [
            'statusCode' => $value->getStatusCode(),
            'headers' => $value->getHeaders(),
            'body' => (string)$value->getBody(),
            'protocolVersion' => $value->getProtocolVersion(),
            'reasonPhrase' => $value->getReasonPhrase(),

//create the mongo collection
$collection = (new Client('mongodb://locathost:27017'))->selectDatabase('psr')->selectCollection('cache');
//Set a TTL index on the expires field
$collection->createIndex(['expires' => 1], ['expireAfterSeconds' => 0]);

$cache = new MongoCache($collection, new Psr7Serializer());

// Use the cache when sending guzzle requests

//Only caching GET responses
if ($request->getMethod() === 'GET') {
    $key = (string)$request->getUri();
    $response = $cache->get($key);
    if ($response === null) {
        $response = $guzzleClient->send($request);
        //Add to cache if valid Expires header
        if ($response->hasHeader('Expires')) {
            $expires = strtotime($response->getHeader('Expires')[0]);
            $cache->set($key, $response, $expires - time());
} else {
    $response = $guzzleClient->send($request);