FileJournal.php

Go to the documentation of this file.

<?php
abstract class FileJournal {
    protected $backend;

    protected $ttlDays;

    protected function __construct( array $config ) {
        $this->ttlDays = isset( $config['ttlDays'] ) ? $config['ttlDays'] : false;
    }

    final public static function factory( array $config, $backend ) {
        $class = $config['class'];
        $jrn = new $class( $config );
        if ( !$jrn instanceof self ) {
            throw new Exception( "Class given is not an instance of FileJournal." );
        }
        $jrn->backend = $backend;

        return $jrn;
    }

    final public function getTimestampedUUID() {
        $s = '';
        for ( $i = 0; $i < 5; $i++ ) {
            $s .= mt_rand( 0, 2147483647 );
        }
        $s = Wikimedia\base_convert( sha1( $s ), 16, 36, 31 );

        return substr( Wikimedia\base_convert( wfTimestamp( TS_MW ), 10, 36, 9 ) . $s, 0, 31 );
    }

    final public function logChangeBatch( array $entries, $batchId ) {
        if ( !count( $entries ) ) {
            return Status::newGood();
        }

        return $this->doLogChangeBatch( $entries, $batchId );
    }

    abstract protected function doLogChangeBatch( array $entries, $batchId );

    final public function getCurrentPosition() {
        return $this->doGetCurrentPosition();
    }

    abstract protected function doGetCurrentPosition();

    final public function getPositionAtTime( $time ) {
        return $this->doGetPositionAtTime( $time );
    }

    abstract protected function doGetPositionAtTime( $time );

    final public function getChangeEntries( $start = null, $limit = 0, &$next = null ) {
        $entries = $this->doGetChangeEntries( $start, $limit ? $limit + 1 : 0 );
        if ( $limit && count( $entries ) > $limit ) {
            $last = array_pop( $entries ); // remove the extra entry
            $next = $last['id']; // update for next call
        } else {
            $next = null; // end of list
        }

        return $entries;
    }

    abstract protected function doGetChangeEntries( $start, $limit );

    final public function purgeOldLogs() {
        return $this->doPurgeOldLogs();
    }

    abstract protected function doPurgeOldLogs();
}

class NullFileJournal extends FileJournal {
    protected function doLogChangeBatch( array $entries, $batchId ) {
        return Status::newGood();
    }

    protected function doGetCurrentPosition() {
        return false;
    }

    protected function doGetPositionAtTime( $time ) {
        return false;
    }

    protected function doGetChangeEntries( $start, $limit ) {
        return [];
    }

    protected function doPurgeOldLogs() {
        return Status::newGood();
    }
}