WSIVMissionsNextRequest.php

<?php
class WSIVMissionsNextRequest {
    private $request;
    private $requestFilename;
    private $location;
    private $uri;
    private $action;
    private $version;
    private $client;

    private $station;
    private $direction;
    private $date;
    private $line;
    private $return;
    private $perturbations;
    private $missions;
    private $expire;

    public function __construct($idLine, $stationName, $directionSens, $proxyHost = null, $proxyPort = null) {
        $this->expire   = time() - 30;
        $this->maxByDay = 1000*1000*100;
        $this->location = "http://opendata-tr.ratp.fr/wsiv/services/Wsiv?wsdl=";
        $this->uri      = "http://opendata-tr.ratp.fr/wsiv/services";
        $this->action   = "urn:getMissionsNext";
        $this->version  = 0;
        $this->proxyHost = $proxyHost;
        $this->proxyPort = $proxyPort;

        if ($this->proxyHost) {
            $this->client   = new SoapClient(null, array(
                'location'       => $this->location,
                'uri'            => "",
                'proxy_host'     => $this->proxyHost,
                'proxy_port'     => $this->proxyPort
            ));
        } else {
            $this->client   = new SoapClient(null, array(
                'location'       => $this->location,
                'uri'            => ""
            ));
        }

        $this->requestFilename = 'cache/' . $idLine . '-' . $stationName . '-' . $directionSens;
        $this->request = '<soapenv:Envelope xmlns:soapenv="http://schemas.xmlsoap.org/soap/envelope/" xmlns:xsd="http://wsiv.ratp.fr/xsd" xmlns:wsiv="http://wsiv.ratp.fr">
            <soapenv:Header/>
         <soapenv:Body>
             <wsiv:getMissionsNext>
                <wsiv:station>
                    <xsd:line>
                        <xsd:id>' . $idLine .'</xsd:id>
                    </xsd:line>
                    <xsd:name>' . $stationName . '</xsd:name>
                </wsiv:station>
                <wsiv:direction>
                    <xsd:sens>' . $directionSens . '</xsd:sens>
                </wsiv:direction>
             </wsiv:getMissionsNext>
         </soapenv:Body>
        </soapenv:Envelope>';

        $xml = $this->getXML();
        $this->setAttributesFromXML($xml);
    }

    public function getReturn() {
        return $this->return;
    }

    public function getStation() {
        return $this->station;
    }

    public function getDirection() {
        return $this->direction;
    }

    public function getTime() {
        return strtotime($this->date);
    }

    public function getLine() {
        return $this->line;
    }

    public function getPerturbations() {
        return $this->perturbations;
    }

    public function getMissions() {
        return $this->missions;
    }

    private function getXML() {
        if(file_exists($this->requestFilename) && filemtime($this->requestFilename) > $this->expire) {
            $clean_xml = file_get_contents($this->requestFilename);
            $xml       = simplexml_load_string($clean_xml);
            return $xml;
        }
        if (!$this->incrementAndCheckIsAllowed()) {
            echo "I've had too much today, sorry."; die;
        }
        $xmlstring = $this->client->__doRequest($this->request, $this->location, $this->action, $this->version);
        $clean_xml = str_ireplace(['SOAPENV:', 'NS1:', 'NS2:'], '', $xmlstring);
        file_put_contents($this->requestFilename, $clean_xml);
        $xml       = simplexml_load_string($clean_xml);
        return $xml;
    }

    private function setAttributesFromXML($xml) {
        $this->return        = $xml->Body->getMissionsNextResponse->return;
        $this->station       = $this->return->argumentStation->name;
        $this->direction     = $this->return->argumentDirection->name;
        $this->date          = $this->return->argumentDate;
        $this->line          = $this->return->argumentLine->reseau->name . ' ' . $this->return->argumentLine->code;
        $this->perturbations = $this->return->perturbations;
        $this->missions      = $this->return->missions;
    }

    private function incrementAndCheckIsAllowed() {
        $filename = "logs/" . date("Ymd");
        if (!file_exists($filename)) {
            file_put_contents($filename, 1);
            return true;
        }
        $count = file_get_contents($filename);
        file_put_contents($filename, 1 + (int)$count);
        return ($count <= $this->maxByDay);
    }
}