. */ declare(strict_types=1); namespace FireflyIII\Import\Routine; use FireflyIII\Models\ImportJob; use FireflyIII\Models\SpectreProvider; use FireflyIII\Services\Spectre\Object\Customer; use FireflyIII\Services\Spectre\Request\CreateLoginRequest; use FireflyIII\Services\Spectre\Request\ListLoginsRequest; use FireflyIII\Services\Spectre\Request\NewCustomerRequest; use Illuminate\Support\Collection; use Log; use Preferences; /** * Class FileRoutine */ class SpectreRoutine implements RoutineInterface { /** @var Collection */ public $errors; /** @var Collection */ public $journals; /** @var int */ public $lines = 0; /** @var ImportJob */ private $job; /** * ImportRoutine constructor. */ public function __construct() { $this->journals = new Collection; $this->errors = new Collection; } /** * @return Collection */ public function getErrors(): Collection { return $this->errors; } /** * @return Collection */ public function getJournals(): Collection { return $this->journals; } /** * @return int */ public function getLines(): int { return $this->lines; } /** * * @throws \FireflyIII\Exceptions\FireflyException */ public function run(): bool { if ('configured' !== $this->job->status) { Log::error(sprintf('Job %s is in state "%s" so it cannot be started.', $this->job->key, $this->job->status)); return false; } set_time_limit(0); Log::info(sprintf('Start with import job %s using Spectre.', $this->job->key)); // create customer if user does not have one: $customer = $this->getCustomer(); // list all logins present at Spectre $logins = $this->listLogins($customer); // use latest (depending on status, and if login exists for selected country + provider) $country = $this->job->configuration['country']; $providerId = $this->job->configuration['provider']; $login = $this->filterLogins($logins, $country, $providerId); // create new login if list is empty or no login exists. if (is_null($login)) { $login = $this->createLogin($customer); var_dump($login); exit; } echo '

';
        print_r($logins);
        exit;

        return true;
    }

    /**
     * @param ImportJob $job
     */
    public function setJob(ImportJob $job)
    {
        $this->job = $job;
    }

    /**
     * @return Customer
     * @throws \FireflyIII\Exceptions\FireflyException
     */
    protected function createCustomer(): Customer
    {
        $newCustomerRequest = new NewCustomerRequest($this->job->user);
        $newCustomerRequest->call();
        $customer = $newCustomerRequest->getCustomer();

        // store customer. Not sure where. User preference? TODO
        return $customer;

    }

    /**
     * @param Customer $customer
     */
    protected function createLogin(Customer $customer)
    {

        $providerId = intval($this->job->configuration['provider']);
        $provider   = $this->findProvider($providerId);


        $createLoginRequest = new CreateLoginRequest($this->job->user);
        $createLoginRequest->setCustomer($customer);
        $createLoginRequest->setProvider($provider);
        $createLoginRequest->setMandatoryFields($this->decrypt($this->job->configuration['mandatory-fields']));
        $createLoginRequest->call();
        echo '123';
        // country code, provider code (find by spectre ID)
        // credentials
        // daily_refresh=true
        // fetch_type=recent
        // include_fake_providers=true
        // store_credentials=true


        var_dump($this->job->configuration);
        exit;
    }

    /**
     * @param int $providerId
     *
     * @return SpectreProvider|null
     */
    protected function findProvider(int $providerId): ?SpectreProvider
    {
        return SpectreProvider::where('spectre_id', $providerId)->first();
    }

    /**
     * @return Customer
     * @throws \FireflyIII\Exceptions\FireflyException
     */
    protected function getCustomer(): Customer
    {
        $preference = Preferences::getForUser($this->job->user, 'spectre_customer', null);
        if (is_null($preference)) {
            return $this->createCustomer();
        }
        var_dump($preference->data);
        exit;
    }

    /**
     * @param Customer $customer
     *
     * @return array
     * @throws \FireflyIII\Exceptions\FireflyException
     */
    protected function listLogins(Customer $customer): array
    {
        $listLoginRequest = new ListLoginsRequest($this->job->user);
        $listLoginRequest->setCustomer($customer);
        $listLoginRequest->call();

        $logins = $listLoginRequest->getLogins();

        return $logins;
    }

    /**
     * @param array $configuration
     *
     * @return array
     */
    private function decrypt(array $configuration): array
    {
        $new = [];
        foreach ($configuration as $key => $value) {
            $new[$key] = app('steam')->tryDecrypt($value);
        }

        return $new;
    }

    /**
     * Return login belonging to country and provider
     * TODO must return Login object, not array
     *
     * @param array  $logins
     * @param string $country
     * @param int    $providerId
     *
     * @return array|null
     */
    private function filterLogins(array $logins, string $country, int $providerId): ?array
    {
        if (count($logins) === 0) {
            return null;
        }
        foreach ($logins as $login) {
            die('do some filter');
        }

        return null;
    }
}