invoiceninja/app/Libraries/OFX.php

<?php
/**
 * Invoice Ninja (https://invoiceninja.com).
 *
 * @link https://github.com/invoiceninja/invoiceninja source repository
 *
 * @copyright Copyright (c) 2021. Invoice Ninja LLC (https://invoiceninja.com)
 *
 * @license https://opensource.org/licenses/AAL
 */

namespace App\Libraries;

// https://github.com/denvertimothy/OFX

use SimpleXMLElement;

class OFX
{
    public $bank;
    public $request;
    public $response;
    public $responseHeader;
    public $responseBody;

    public function __construct($bank, $request)
    {
        $this->bank = $bank;
        $this->request = $request;
    }

    public function go()
    {
        $c = curl_init();
        curl_setopt($c, CURLOPT_URL, $this->bank->url);
        curl_setopt($c, CURLOPT_POST, 1);
        // User-Agent: http://www.ofxhome.com/ofxforum/viewtopic.php?pid=108091#p108091
        curl_setopt($c, CURLOPT_HTTPHEADER, ['Content-Type: application/x-ofx', 'User-Agent: httpclient']);
        curl_setopt($c, CURLOPT_POSTFIELDS, $this->request);
        curl_setopt($c, CURLOPT_RETURNTRANSFER, 1);

        $this->response = curl_exec($c);

        curl_close($c);

        $tmp = explode('<OFX>', $this->response);
        $this->responseHeader = $tmp[0];
        $this->responseBody = '<OFX>'.$tmp[1];
    }

    public function xml()
    {
        $xml = $this->responseBody;
        $xml = self::closeTags($xml);
        $x = new SimpleXMLElement($xml);

        return $x;
    }

    public static function closeTags($x)
    {
        $x = preg_replace('/\s+/', '', $x);

        return preg_replace('/(<([^<\/]+)>)(?!.*?<\/\2>)([^<]+)/', '\1\3</\2>', $x);
    }
}

class Finance
{
    public $banks;
}

class Bank
{
    public $logins; // array of class User
    public $finance; // the Finance object that hold this Bank object
    public $fid;
    public $org;
    public $url;

    public function __construct($finance, $fid, $url, $org)
    {
        $this->finance = $finance;
        $this->fid = $fid;
        $this->url = $url;
        $this->org = $org;
    }
}

class Login
{
    public $accounts;
    public $bank;
    public $id;
    public $pass;
    public $ofxVersion;
    public $appVersion;

    public function __construct($bank, $id, $pass)
    {
        $this->bank = $bank;
        $this->id = $id;
        $this->pass = $pass;
    }

    public function setup()
    {
        $ofxRequest =
            "OFXHEADER:100\n".
            "DATA:OFXSGML\n".
            'VERSION:'.$this->ofxVersion."\n".
            "SECURITY:NONE\n".
            "ENCODING:USASCII\n".
            "CHARSET:1252\n".
            "COMPRESSION:NONE\n".
            "OLDFILEUID:NONE\n".
            "NEWFILEUID:NONE\n".
            "\n".
            "<OFX>\n".
            "<SIGNONMSGSRQV1>\n".
            "<SONRQ>\n".
            "<DTCLIENT>20110412162900.000[-7:MST]\n".
            '<USERID>'.$this->id."\n".
            '<USERPASS>'.$this->pass."\n".
            "<GENUSERKEY>N\n".
            "<LANGUAGE>ENG\n".
            "<FI>\n".
            '<ORG>'.$this->bank->org."\n".
            '<FID>'.$this->bank->fid."\n".
            "</FI>\n".
            "<APPID>QWIN\n".
            '<APPVER>'.$this->appVersion."\n".
            "</SONRQ>\n".
            "</SIGNONMSGSRQV1>\n".
            "<SIGNUPMSGSRQV1>\n".
            "<ACCTINFOTRNRQ>\n".
            '<TRNUID>'.md5(time().$this->bank->url.$this->id)."\n".
            "<ACCTINFORQ>\n".
            "<DTACCTUP>19900101\n".
            "</ACCTINFORQ>\n".
            "</ACCTINFOTRNRQ> \n".
            "</SIGNUPMSGSRQV1>\n".
            "</OFX>\n";
        $o = new OFX($this->bank, $ofxRequest);
        $o->go();
        $x = $o->xml();
        foreach ($x->xpath('/OFX/SIGNUPMSGSRSV1/ACCTINFOTRNRS/ACCTINFORS/ACCTINFO/BANKACCTINFO/BANKACCTFROM') as $a) {
            $this->accounts[] = new Account($this, (string) $a->ACCTID, 'BANK', (string) $a->ACCTTYPE, (string) $a->BANKID);
        }
        foreach ($x->xpath('/OFX/SIGNUPMSGSRSV1/ACCTINFOTRNRS/ACCTINFORS/ACCTINFO/CCACCTINFO/CCACCTFROM') as $a) {
            $this->accounts[] = new Account($this, (string) $a->ACCTID, 'CC');
        }
    }
}

class Account
{
    public $login;
    public $id;
    public $type;
    public $subType;
    public $bankId;
    public $ledgerBalance;
    public $availableBalance;
    public $response;

    public function __construct($login, $id, $type, $subType = null, $bankId = null)
    {
        $this->login = $login;
        $this->id = $id;
        $this->type = $type;
        $this->subType = $subType;
        $this->bankId = $bankId;
    }

    public function setup($includeTransactions = true)
    {
        $ofxRequest =
            "OFXHEADER:100\n".
            "DATA:OFXSGML\n".
            'VERSION:'.$this->login->ofxVersion."\n".
            "SECURITY:NONE\n".
            "ENCODING:USASCII\n".
            "CHARSET:1252\n".
            "COMPRESSION:NONE\n".
            "OLDFILEUID:NONE\n".
            "NEWFILEUID:NONE\n".
            "\n".
            "<OFX>\n".
            "<SIGNONMSGSRQV1>\n".
            "<SONRQ>\n".
            "<DTCLIENT>20110412162900.000[-7:MST]\n".
            '<USERID>'.$this->login->id."\n".
            '<USERPASS>'.$this->login->pass."\n".
            "<LANGUAGE>ENG\n".
            "<FI>\n".
            '<ORG>'.$this->login->bank->org."\n".
            '<FID>'.$this->login->bank->fid."\n".
            "</FI>\n".
            "<APPID>QWIN\n".
            '<APPVER>'.$this->login->appVersion."\n".
            "</SONRQ>\n".
            "</SIGNONMSGSRQV1>\n";
        if ($this->type == 'BANK') {
            $ofxRequest .=
                "	<BANKMSGSRQV1>\n".
                "		<STMTTRNRQ>\n".
                '			<TRNUID>'.md5(time().$this->login->bank->url.$this->id)."\n".
                "			<STMTRQ>\n".
                "				<BANKACCTFROM>\n".
                '					<BANKID>'.$this->bankId."\n".
                '					<ACCTID>'.$this->id."\n".
                '					<ACCTTYPE>'.$this->subType."\n".
                "				</BANKACCTFROM>\n".
                "				<INCTRAN>\n".
                "					<DTSTART>20110301\n".
                '					<INCLUDE>'.($includeTransactions ? 'Y' : 'N')."\n".
                "				</INCTRAN>\n".
                "			</STMTRQ>\n".
                "		</STMTTRNRQ>\n".
                "	</BANKMSGSRQV1>\n";
        } elseif ($this->type == 'CC') {
            $ofxRequest .=
                "	<CREDITCARDMSGSRQV1>\n".
                "		<CCSTMTTRNRQ>\n".
                '			<TRNUID>'.md5(time().$this->login->bank->url.$this->id)."\n".
                "			<CCSTMTRQ>\n".
                "				<CCACCTFROM>\n".
                '					<ACCTID>'.$this->id."\n".
                "				</CCACCTFROM>\n".
                "				<INCTRAN>\n".
                "					<DTSTART>20110320\n".
                '					<INCLUDE>'.($includeTransactions ? 'Y' : 'N')."\n".
                "				</INCTRAN>\n".
                "			</CCSTMTRQ>\n".
                "		</CCSTMTTRNRQ>\n".
                "	</CREDITCARDMSGSRQV1>\n";
        }
        $ofxRequest .=
            '</OFX>';
        $o = new OFX($this->login->bank, $ofxRequest);
        $o->go();
        $this->response = $o->response;
        $x = $o->xml();
        $a = $x->xpath('/OFX/*/*/*/LEDGERBAL/BALAMT');
        $this->ledgerBalance = (float) $a[0];
        $a = $x->xpath('/OFX/*/*/*/AVAILBAL/BALAMT');
        if (isset($a[0])) {
            $this->availableBalance = (float) $a[0];
        }
    }
}