laravel-nami-api/src/Api.php

<?php

namespace Zoomyboy\LaravelNami;

use App\Conf;
use App\Nami\Exceptions\TooManyLoginAttemptsException;
use App\Nami\Interfaces\UserResolver;
use Illuminate\Support\Facades\Http;

class Api {

    public $cookie;
    public $loggedIn = null;
    public static $url = 'https://nami.dpsg.de';

    public function __construct() {
        $this->cookie = new \GuzzleHttp\Cookie\CookieJar();
    }

    private function http() {
        return Http::withOptions(['cookies' => $this->cookie]);
    }

    public function setUser(NamiUser $user) {
        $this->user = $user;

        return $this;
    }

    protected function loggedInAlready(): bool {
        return $this->loggedIn !== null;
    }

    public function login($mglnr = null, $password = null, $groupid = null): self {
        if ($this->loggedIn) { return $this; }

        $mglnr = $mglnr ?: config('nami.auth.mglnr');
        $password = $password ?: config('nami.auth.password');
        $groupid = $groupid ?: config('nami.auth.groupid');

        Http::withOptions(['cookies' => $this->cookie])->get(self::$url.'/ica/pages/login.jsp');
        $response = Http::asForm()->withOptions(['cookies' => $this->cookie])->post(self::$url.'/ica/rest/nami/auth/manual/sessionStartup', [
            'Login' => 'API',
            'redirectTo' => './app.jsp',
            'username' => $mglnr,
            'password' => $password
        ])->json();

        if ($response['statusCode'] !== 0) {
            $e = new LoginException();
            $e->setResponse($response);
            throw $e;
        }

        $this->loggedIn = $mglnr;

        return $this;
    }


    public function groups() {
        $r = $this->http()->get(self::$url.'/ica/rest/nami/gruppierungen/filtered-for-navigation/gruppierung/node/root')->body();
    }

    public function fees() {
        $response = $this->client->get("/ica/rest/namiBeitrag/beitragsartmgl/gruppierung/{$this->user->getNamiGroupId()}", [
            'cookies' => $this->cookie
        ]);

        return json_decode((string)$response->getBody());
    }

    public function nationalities() {
        $response = $this->client->get("/ica/rest/baseadmin/staatsangehoerigkeit", [
            'cookies' => $this->cookie
        ]);

        return json_decode((string)$response->getBody());
    }

    public function confessions() {
        $response = $this->client->get("/ica/rest/baseadmin/konfession", [
            'cookies' => $this->cookie
        ]);

        return json_decode((string)$response->getBody());
    }

    public function genders() {
        $response = $this->client->get("/ica/rest/baseadmin/geschlecht", [
            'cookies' => $this->cookie
        ]);

        return json_decode((string)$response->getBody());
    }

    public function regions() {
        $response = $this->client->get("/ica/rest/baseadmin/region", [
            'cookies' => $this->cookie
        ]);

        return json_decode((string)$response->getBody());
    }

    public function countries() {
        $response = $this->client->get("/ica/rest/baseadmin/land", [
            'cookies' => $this->cookie
        ]);

        return json_decode((string)$response->getBody());
    }

    public function activities() {
        $response = $this->client->get("/ica/rest/nami/taetigkeitaufgruppierung/filtered/gruppierung/gruppierung/{$this->user->getNamiGroupId()}", [
            'cookies' => $this->cookie
        ]);

        return json_decode((string)$response->getBody());
    }

    public function groupForActivity($activityId) {

        $response = $this->client->get("/ica/rest//nami/untergliederungauftaetigkeit/filtered/untergliederung/taetigkeit/{$activityId}", [
            'cookies' => $this->cookie
        ]);

        return json_decode((string)$response->getBody());
    }

    public function allMembers() {
        $response = $this->client->get("/ica/rest/nami/mitglied/filtered-for-navigation/gruppierung/gruppierung/{$this->user->getNamiGroupId()}/flist", [
            'cookies' => $this->cookie
        ]);

        return json_decode((string)$response->getBody());
    }

    public function getMember($memberId) {
        $response = $this->client->get('/ica/rest/nami/mitglied/filtered-for-navigation/gruppierung/gruppierung/'.$this->user->getNamiGroupId().'/'.$memberId, [
                'cookies' => $this->cookie,
                'http_errors' => false
            ]
        );

        return json_decode((string)$response->getBody());
    }

    /** @todo testen mit guzzle fake */
    public function isSuccess($response) {
        return isset ($response->success) && $response->success === true
            && isset ($response->responseType) && $response->responseType == 'OK';
    }

    public function checkCredentials() {
        try {
            $this->login();
        } catch (LoginException $e) {
            return false;
        }

        return true;
    }

    public function get($url) {
        $this->login();

        $response = $this->client->request('GET', $this->baseUrl.$url, [
            'http_errors' => false,
            'cookies' => $this->cookie
        ]);

        $json = json_decode((string) $response->getBody());

        return collect($json);
    }

    public function post($url, $fields) {
        $this->login();

        $response = $this->client->request('POST', $this->baseUrl.$url, [
            'http_errors' => false,
            'cookies' => $this->cookie,
            'headers' => [
                'Accept' => '*/*',
                'Content-Type' => 'application/x-www-form-urlencoded; charset=UTF-8'
            ],
            'form_params' => $fields
        ]);

        $json = json_decode((string) $response->getBody());

        return collect($json);
    }

    public function put($url, $fields) {
        $this->login();

        $response = $this->client->request('PUT', $this->baseUrl.$url, [
            'http_errors' => false,
            'cookies' => $this->cookie,
            'headers' => [
                'Accept' => 'application/json',
                'Content-Type' => 'application/json'
            ],
            'json' => $fields
        ]);

        $json = json_decode((string) $response->getBody());

        if (is_null($json)) {
            \Log::critical('Api gibt kein JSON zurück', [
                'response' => (string) $response->getBody(),
                'fields' => $fields,
                'url' => $url
            ]);

            return null;
        }

        if (!$json->success || $json->success == false) {
            \Log::critical('Fehler beim Update', [
                'response' => (string) $response->getBody(),
                'fields' => $fields,
                'url' => $url
            ]);

            return null;
        }

        return collect($json);
    }
}