Lots of new code for the Spectre routine.

app/Support/Import/JobConfiguration/Spectre/AuthenticateConfig.php

@@ -0,0 +1,109 @@
+<?php
+/**
+ * AuthenticateConfig.php
+ * Copyright (c) 2018 thegrumpydictator@gmail.com
+ *
+ * This file is part of Firefly III.
+ *
+ * Firefly III is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * Firefly III is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with Firefly III. If not, see <http://www.gnu.org/licenses/>.
+ */
+
+declare(strict_types=1);
+
+namespace FireflyIII\Support\Import\JobConfiguration\Spectre;
+
+use FireflyIII\Exceptions\FireflyException;
+use FireflyIII\Models\ImportJob;
+use FireflyIII\Repositories\ImportJob\ImportJobRepositoryInterface;
+use FireflyIII\Services\Spectre\Object\Token;
+use Illuminate\Support\MessageBag;
+
+/**
+ * Class AuthenticateConfig
+ *
+ * @package FireflyIII\Support\Import\JobConfiguration\Spectre
+ */
+class AuthenticateConfig implements SpectreJobConfig
+{
+    /** @var ImportJob */
+    private $importJob;
+    /** @var ImportJobRepositoryInterface */
+    private $repository;
+
+    /**
+     * Return true when this stage is complete.
+     *
+     * always returns false.
+     *
+     * @return bool
+     */
+    public function configurationComplete(): bool
+    {
+        return false;
+    }
+
+    /**
+     * Store the job configuration.
+     *
+     * @param array $data
+     *
+     * @return MessageBag
+     */
+    public function configureJob(array $data): MessageBag
+    {
+        // does nothing
+        return new MessageBag;
+    }
+
+    /**
+     * Get data for config view.
+     *
+     * @return array
+     * @throws FireflyException
+     */
+    public function getNextData(): array
+    {
+        // next data only makes sure the job is ready for the next stage.
+        $this->repository->setStatus($this->importJob, 'ready_to_run');
+        $this->repository->setStage($this->importJob, 'authenticated');
+        $config = $this->importJob->configuration;
+        $token  = isset($config['token']) ? new Token($config['token']) : null;
+        if (null !== $token) {
+            return ['token-url' => $token->getConnectUrl()];
+        }
+        throw new FireflyException('The import routine cannot continue without a Spectre token. Apologies.');
+    }
+
+    /**
+     * Get the view for this stage.
+     *
+     * @return string
+     */
+    public function getNextView(): string
+    {
+        return 'import.spectre.redirect';
+    }
+
+    /**
+     * Set the import job.
+     *
+     * @param ImportJob $importJob
+     */
+    public function setImportJob(ImportJob $importJob): void
+    {
+        $this->importJob  = $importJob;
+        $this->repository = app(ImportJobRepositoryInterface::class);
+        $this->repository->setUser($importJob->user);
+    }
+}

app/Support/Import/JobConfiguration/Spectre/AuthenticatedConfigHandler.php

@@ -0,0 +1,91 @@
+<?php
+/**
+ * AuthenticatedConfigHandler.php
+ * Copyright (c) 2018 thegrumpydictator@gmail.com
+ *
+ * This file is part of Firefly III.
+ *
+ * Firefly III is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * Firefly III is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with Firefly III. If not, see <http://www.gnu.org/licenses/>.
+ */
+
+declare(strict_types=1);
+
+namespace FireflyIII\Support\Import\JobConfiguration\Spectre;
+
+
+use FireflyIII\Models\ImportJob;
+use FireflyIII\Repositories\ImportJob\ImportJobRepositoryInterface;
+use Illuminate\Support\MessageBag;
+
+class AuthenticatedConfigHandler implements SpectreJobConfig
+{
+    /** @var ImportJob */
+    private $importJob;
+    /** @var ImportJobRepositoryInterface */
+    private $repository;
+
+    /**
+     * Return true when this stage is complete.
+     *
+     * @return bool
+     */
+    public function configurationComplete(): bool
+    {
+        return true;
+    }
+
+    /**
+     * Store the job configuration.
+     *
+     * @param array $data
+     *
+     * @return MessageBag
+     */
+    public function configureJob(array $data): MessageBag
+    {
+        return new MessageBag();
+    }
+
+    /**
+     * Get data for config view.
+     *
+     * @return array
+     */
+    public function getNextData(): array
+    {
+        return [];
+    }
+
+    /**
+     * Get the view for this stage.
+     *
+     * @return string
+     */
+    public function getNextView(): string
+    {
+        return '';
+    }
+
+    /**
+     * Set the import job.
+     *
+     * @param ImportJob $importJob
+     */
+    public function setImportJob(ImportJob $importJob): void
+    {
+        $this->importJob  = $importJob;
+        $this->repository = app(ImportJobRepositoryInterface::class);
+        $this->repository->setUser($importJob->user);
+    }
+}

app/Support/Import/JobConfiguration/Spectre/ChooseAccount.php

@@ -0,0 +1,241 @@
+<?php
+/**
+ * ChooseAccount.php
+ * Copyright (c) 2018 thegrumpydictator@gmail.com
+ *
+ * This file is part of Firefly III.
+ *
+ * Firefly III is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * Firefly III is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with Firefly III. If not, see <http://www.gnu.org/licenses/>.
+ */
+
+declare(strict_types=1);
+
+namespace FireflyIII\Support\Import\JobConfiguration\Spectre;
+
+
+use FireflyIII\Exceptions\FireflyException;
+use FireflyIII\Models\Account as AccountModel;
+use FireflyIII\Models\AccountType;
+use FireflyIII\Models\ImportJob;
+use FireflyIII\Models\TransactionCurrency;
+use FireflyIII\Repositories\Account\AccountRepositoryInterface;
+use FireflyIII\Repositories\Currency\CurrencyRepositoryInterface;
+use FireflyIII\Repositories\ImportJob\ImportJobRepositoryInterface;
+use FireflyIII\Services\Spectre\Object\Account as SpectreAccount;
+use FireflyIII\Services\Spectre\Object\Login;
+use Illuminate\Support\MessageBag;
+
+/**
+ * Class ChooseAccount
+ *
+ * @package FireflyIII\Support\Import\JobConfiguration\Spectre
+ */
+class ChooseAccount implements SpectreJobConfig
+{
+
+    /** @var AccountRepositoryInterface */
+    private $accountRepository;
+    /** @var CurrencyRepositoryInterface */
+    private $currencyRepository;
+    /** @var ImportJob */
+    private $importJob;
+    /** @var ImportJobRepositoryInterface */
+    private $repository;
+
+    /**
+     * Return true when this stage is complete.
+     *
+     * @return bool
+     */
+    public function configurationComplete(): bool
+    {
+        $config         = $this->importJob->configuration;
+        $importAccounts = $config['account_mapping'] ?? [];
+        $complete       = \count($importAccounts) > 0 && $importAccounts !== [0 => 0];
+        if ($complete) {
+            $this->repository->setStage($this->importJob, 'go-for-import');
+        }
+
+        return $complete;
+    }
+
+    /**
+     * Store the job configuration.
+     *
+     * @param array $data
+     *
+     * @return MessageBag
+     */
+    public function configureJob(array $data): MessageBag
+    {
+        $config  = $this->importJob->configuration;
+        $mapping = $data['account_mapping'] ?? [];
+        $final   = [];
+        foreach ($mapping as $spectreId => $fireflyIIIId) {
+            // validate each
+            $spectreId         = $this->validSpectreAccount((int)$spectreId);
+            $accountId         = $this->validFireflyIIIAccount((int)$fireflyIIIId);
+            $final[$spectreId] = $accountId;
+
+        }
+        $messages                  = new MessageBag;
+        $config['account_mapping'] = $final;
+
+        $this->repository->setConfiguration($this->importJob, $config);
+        if (\count($final) === 0 || $final === [0 => 0]) {
+            $messages->add('count', trans('import.spectre_no_mapping'));
+        }
+
+        return $messages;
+    }
+
+    /**
+     * Get data for config view.
+     *
+     * @return array
+     * @throws FireflyException
+     */
+    public function getNextData(): array
+    {
+        $config   = $this->importJob->configuration;
+        $accounts = $config['accounts'] ?? [];
+        if (\count($accounts) === 0) {
+            throw new FireflyException('It seems you have no accounts with this bank. The import cannot continue.');
+        }
+        $converted = [];
+        foreach ($accounts as $accountArray) {
+            $converted[] = new SpectreAccount($accountArray);
+        }
+
+        // get the provider that was used.
+        $login    = null;
+        $logins   = $config['all-logins'] ?? [];
+        $selected = $config['selected-login'] ?? 0;
+        if (\count($logins) === 0) {
+            throw new FireflyException('It seems you have no configured logins in this import job. The import cannot continue.');
+        }
+        if ($selected === 0) {
+            $login = new Login($logins[0]);
+        }
+        if ($selected !== 0) {
+            foreach ($logins as $loginArray) {
+                $loginId = $loginArray['id'] ?? -1;
+                if ($loginId === $selected) {
+                    $login = new Login($loginArray);
+                }
+            }
+        }
+        if (null === $login) {
+            throw new FireflyException('Was not able to determine which login to use. The import cannot continue.');
+        }
+
+        // list the users accounts:
+        $accounts = $this->accountRepository->getAccountsByType([AccountType::ASSET]);
+
+        $array = [];
+        /** @var AccountModel $account */
+        foreach ($accounts as $account) {
+            $accountId         = $account->id;
+            $currencyId        = (int)$this->accountRepository->getMetaValue($account, 'currency_id');
+            $currency          = $this->getCurrency($currencyId);
+            $array[$accountId] = [
+                'name' => $account->name,
+                'iban' => $account->iban,
+                'code' => $currency->code,
+            ];
+        }
+
+        return [
+            'accounts'    => $converted,
+            'ff_accounts' => $array,
+            'login'       => $login,
+
+        ];
+    }
+
+    /**
+     * Get the view for this stage.
+     *
+     * @return string
+     */
+    public function getNextView(): string
+    {
+        return 'import.spectre.accounts';
+    }
+
+    /**
+     * Set the import job.
+     *
+     * @param ImportJob $importJob
+     */
+    public function setImportJob(ImportJob $importJob): void
+    {
+        $this->importJob          = $importJob;
+        $this->repository         = app(ImportJobRepositoryInterface::class);
+        $this->accountRepository  = app(AccountRepositoryInterface::class);
+        $this->currencyRepository = app(CurrencyRepositoryInterface::class);
+        $this->repository->setUser($importJob->user);
+        $this->currencyRepository->setUser($importJob->user);
+        $this->accountRepository->setUser($importJob->user);
+    }
+
+    /**
+     * @param int $currencyId
+     *
+     * @return TransactionCurrency
+     */
+    private function getCurrency(int $currencyId): TransactionCurrency
+    {
+        $currency = $this->currencyRepository->findNull($currencyId);
+        if (null === $currency) {
+            return app('amount')->getDefaultCurrencyByUser($this->importJob->user);
+        }
+
+        return $currency;
+
+    }
+
+    /**
+     * @param int $accountId
+     *
+     * @return int
+     */
+    private function validFireflyIIIAccount(int $accountId): int
+    {
+        $account = $this->accountRepository->findNull($accountId);
+        if (null === $account) {
+            return 0;
+        }
+
+        return $accountId;
+    }
+
+    /**
+     * @param int $accountId
+     *
+     * @return int
+     */
+    private function validSpectreAccount(int $accountId): int
+    {
+        $config   = $this->importJob->configuration;
+        $accounts = $config['accounts'] ?? [];
+        foreach ($accounts as $account) {
+            if ((int)$account['id'] === $accountId) {
+                return $accountId;
+            }
+        }
+
+        return 0;
+    }
+}

app/Support/Import/JobConfiguration/Spectre/ChooseLoginHandler.php

@@ -0,0 +1,205 @@
+<?php
+/**
+ * ChooseLoginHandler.php
+ * Copyright (c) 2018 thegrumpydictator@gmail.com
+ *
+ * This file is part of Firefly III.
+ *
+ * Firefly III is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * Firefly III is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with Firefly III. If not, see <http://www.gnu.org/licenses/>.
+ */
+
+declare(strict_types=1);
+
+namespace FireflyIII\Support\Import\JobConfiguration\Spectre;
+
+use FireflyIII\Exceptions\FireflyException;
+use FireflyIII\Models\ImportJob;
+use FireflyIII\Repositories\ImportJob\ImportJobRepositoryInterface;
+use FireflyIII\Services\Spectre\Object\Customer;
+use FireflyIII\Services\Spectre\Object\Login;
+use FireflyIII\Services\Spectre\Object\Token;
+use FireflyIII\Services\Spectre\Request\CreateTokenRequest;
+use FireflyIII\Services\Spectre\Request\ListCustomersRequest;
+use FireflyIII\Services\Spectre\Request\NewCustomerRequest;
+use Illuminate\Support\MessageBag;
+use Log;
+
+
+/**
+ * Class ChooseLoginHandler
+ *
+ * @package FireflyIII\Support\Import\JobConfiguration\Spectre
+ */
+class ChooseLoginHandler implements SpectreJobConfig
+{
+    /** @var ImportJob */
+    private $importJob;
+    /** @var ImportJobRepositoryInterface */
+    private $repository;
+
+    /**
+     * Return true when this stage is complete.
+     *
+     * @return bool
+     */
+    public function configurationComplete(): bool
+    {
+        $config = $this->importJob->configuration;
+        if(isset($config['selected-login'])) {
+            return true;
+        }
+
+        return false;
+    }
+
+    /**
+     * Store the job configuration.
+     *
+     * @param array $data
+     *
+     * @return MessageBag
+     * @throws FireflyException
+     */
+    public function configureJob(array $data): MessageBag
+    {
+        $selectedLogin            = (int)$data['spectre_login_id'];
+        $config                   = $this->importJob->configuration;
+        $config['selected-login'] = $selectedLogin;
+        $this->repository->setConfiguration($this->importJob, $config);
+
+        // if selected login is zero, create a new one.
+        if ($selectedLogin === 0) {
+            $customer = $this->getCustomer();
+            // get a token for the user and redirect to next stage
+            $token           = $this->getToken($customer);
+            $config['token'] = $token->toArray();
+            $this->repository->setConfiguration($this->importJob, $config);
+            // move job to correct stage to redirect to Spectre:
+            $this->repository->setStage($this->importJob, 'authenticate');
+            return new MessageBag;
+
+        }
+        $this->repository->setStage($this->importJob, 'authenticated');
+        return new MessageBag;
+    }
+
+    /**
+     * Get data for config view.
+     *
+     * @return array
+     */
+    public function getNextData(): array
+    {
+        $config = $this->importJob->configuration;
+        $data   = ['logins' => []];
+        $logins = $config['all-logins'] ?? [];
+        foreach ($logins as $login) {
+            $data['logins'][] = new Login($login);
+        }
+
+        return $data;
+    }
+
+    /**
+     * Get the view for this stage.
+     *
+     * @return string
+     */
+    public function getNextView(): string
+    {
+        return 'import.spectre.choose-login';
+    }
+
+    /**
+     * Set the import job.
+     *
+     * @param ImportJob $importJob
+     */
+    public function setImportJob(ImportJob $importJob): void
+    {
+        $this->importJob  = $importJob;
+        $this->repository = app(ImportJobRepositoryInterface::class);
+        $this->repository->setUser($importJob->user);
+    }
+
+    /**
+     * @return Customer
+     * @throws FireflyException
+     */
+    private function getCustomer(): Customer
+    {
+        Log::debug('Now in stageNewHandler::getCustomer()');
+        $customer = $this->getExistingCustomer();
+        if (null === $customer) {
+            Log::debug('The customer is NULL, will fire a newCustomerRequest.');
+            $newCustomerRequest = new NewCustomerRequest($this->importJob->user);
+            $customer           = $newCustomerRequest->getCustomer();
+
+        }
+        Log::debug('The customer is not null.');
+
+        return $customer;
+    }
+
+    /**
+     * @return Customer|null
+     * @throws FireflyException
+     */
+    private function getExistingCustomer(): ?Customer
+    {
+        Log::debug('Now in getExistingCustomer()');
+        $preference = app('preferences')->getForUser($this->importJob->user, 'spectre_customer');
+        if (null !== $preference) {
+            Log::debug('Customer is in user configuration');
+            $customer = new Customer($preference->data);
+
+            return $customer;
+        }
+        Log::debug('Customer is not in user config');
+        $customer           = null;
+        $getCustomerRequest = new ListCustomersRequest($this->importJob->user);
+        $getCustomerRequest->call();
+        $customers = $getCustomerRequest->getCustomers();
+
+        Log::debug(sprintf('Found %d customer(s)', \count($customers)));
+        /** @var Customer $current */
+        foreach ($customers as $current) {
+            if ('default_ff3_customer' === $current->getIdentifier()) {
+                $customer = $current;
+                Log::debug('Found the correct customer.');
+                break;
+            }
+        }
+
+        return $customer;
+    }
+
+    /**
+     * @param Customer $customer
+     *
+     * @throws FireflyException
+     * @return Token
+     */
+    private function getToken(Customer $customer): Token
+    {
+        Log::debug('Now in ChooseLoginsHandler::getToken()');
+        $request = new CreateTokenRequest($this->importJob->user);
+        $request->setUri(route('import.job.status.index', [$this->importJob->key]));
+        $request->setCustomer($customer);
+        $request->call();
+        Log::debug('Call to get token is finished');
+
+        return $request->getToken();
+    }
+}

app/Support/Import/JobConfiguration/Spectre/NewConfig.php

@@ -0,0 +1,89 @@
+<?php
+/**
+ * NewConfig.php
+ * Copyright (c) 2018 thegrumpydictator@gmail.com
+ *
+ * This file is part of Firefly III.
+ *
+ * Firefly III is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * Firefly III is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with Firefly III. If not, see <http://www.gnu.org/licenses/>.
+ */
+
+declare(strict_types=1);
+
+namespace FireflyIII\Support\Import\JobConfiguration\Spectre;
+
+
+use FireflyIII\Models\ImportJob;
+use Illuminate\Support\MessageBag;
+
+/**
+ * Class NewConfig
+ *
+ * @package FireflyIII\Support\Import\JobConfiguration\Spectre
+ */
+class NewConfig implements SpectreJobConfig
+{
+
+    /**
+     * Return true when this stage is complete.
+     *
+     * @return bool
+     */
+    public function configurationComplete(): bool
+    {
+        return true;
+    }
+
+    /**
+     * Store the job configuration.
+     *
+     * @param array $data
+     *
+     * @return MessageBag
+     */
+    public function configureJob(array $data): MessageBag
+    {
+        return new MessageBag;
+    }
+
+    /**
+     * Get data for config view.
+     *
+     * @return array
+     */
+    public function getNextData(): array
+    {
+        return [];
+    }
+
+    /**
+     * Get the view for this stage.
+     *
+     * @return string
+     */
+    public function getNextView(): string
+    {
+        return '';
+    }
+
+    /**
+     * Set the import job.
+     *
+     * @param ImportJob $importJob
+     */
+    public function setImportJob(ImportJob $importJob): void
+    {
+        return;
+    }
+}

app/Support/Import/JobConfiguration/Spectre/SpectreJobConfig.php

@@ -0,0 +1,70 @@
+<?php
+/**
+ * SpectreJobConfig.php
+ * Copyright (c) 2018 thegrumpydictator@gmail.com
+ *
+ * This file is part of Firefly III.
+ *
+ * Firefly III is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * Firefly III is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with Firefly III. If not, see <http://www.gnu.org/licenses/>.
+ */
+
+declare(strict_types=1);
+
+namespace FireflyIII\Support\Import\JobConfiguration\Spectre;
+
+
+use FireflyIII\Models\ImportJob;
+use Illuminate\Support\MessageBag;
+
+interface SpectreJobConfig
+{
+    /**
+     * Return true when this stage is complete.
+     *
+     * @return bool
+     */
+    public function configurationComplete(): bool;
+
+
+    /**
+     * Store the job configuration.
+     *
+     * @param array $data
+     *
+     * @return MessageBag
+     */
+    public function configureJob(array $data): MessageBag;
+
+    /**
+     * Get data for config view.
+     *
+     * @return array
+     */
+    public function getNextData(): array;
+
+    /**
+     * Get the view for this stage.
+     *
+     * @return string
+     */
+    public function getNextView(): string;
+
+    /**
+     * Set the import job.
+     *
+     * @param ImportJob $importJob
+     */
+    public function setImportJob(ImportJob $importJob): void;
+
+}

app/Support/Import/Routine/Spectre/ImportDataHandler.php

@@ -0,0 +1,62 @@
+<?php
+/**
+ * ImportDataHandler.php
+ * Copyright (c) 2018 thegrumpydictator@gmail.com
+ *
+ * This file is part of Firefly III.
+ *
+ * Firefly III is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * Firefly III is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with Firefly III. If not, see <http://www.gnu.org/licenses/>.
+ */
+
+declare(strict_types=1);
+
+namespace FireflyIII\Support\Import\Routine\Spectre;
+
+
+use FireflyIII\Models\ImportJob;
+use FireflyIII\Repositories\ImportJob\ImportJobRepositoryInterface;
+
+/**
+ * Class ImportDataHandler
+ *
+ * @package FireflyIII\Support\Import\Routine\Spectre
+ */
+class ImportDataHandler
+{
+    /** @var ImportJob */
+    private $importJob;
+    /** @var ImportJobRepositoryInterface */
+    private $repository;
+
+    /**
+     *
+     */
+    public function run()
+    {
+        die('here we are');
+
+    }
+
+    /**
+     * @param ImportJob $importJob
+     *
+     * @return void
+     */
+    public function setImportJob(ImportJob $importJob): void
+    {
+        $this->importJob  = $importJob;
+        $this->repository = app(ImportJobRepositoryInterface::class);
+        $this->repository->setUser($importJob->user);
+    }
+}

app/Support/Import/Routine/Spectre/ManageLoginsHandler.php

@@ -0,0 +1,133 @@
+<?php
+/**
+ * ManageLoginsHandler.php
+ * Copyright (c) 2018 thegrumpydictator@gmail.com
+ *
+ * This file is part of Firefly III.
+ *
+ * Firefly III is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * Firefly III is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with Firefly III. If not, see <http://www.gnu.org/licenses/>.
+ */
+
+declare(strict_types=1);
+
+namespace FireflyIII\Support\Import\Routine\Spectre;
+
+use FireflyIII\Exceptions\FireflyException;
+use FireflyIII\Models\ImportJob;
+use FireflyIII\Repositories\ImportJob\ImportJobRepositoryInterface;
+use FireflyIII\Services\Spectre\Object\Customer;
+use FireflyIII\Services\Spectre\Object\Login;
+use FireflyIII\Services\Spectre\Request\ListCustomersRequest;
+use FireflyIII\Services\Spectre\Request\ListLoginsRequest;
+use FireflyIII\Services\Spectre\Request\NewCustomerRequest;
+use Log;
+
+class ManageLoginsHandler
+{
+
+
+    public $countLogins = 0;
+    /** @var ImportJob */
+    private $importJob;
+    /** @var ImportJobRepositoryInterface */
+    private $repository;
+
+    /**
+     * Tasks for this stage:
+     *
+     * - List all of the users logins.
+     * - If zero, return to "get-token" stage and make user make a login. That stage redirects here.
+     * - If one or more, list and let user select.
+     *
+     * @throws FireflyException
+     */
+    public function run(): void
+    {
+        $customer = $this->getCustomer();
+
+        $request = new ListLoginsRequest($this->importJob->user);
+        $request->setCustomer($customer);
+        $request->call();
+
+        $list = $request->getLogins();
+
+        // count is zero?
+        $this->countLogins = \count($list);
+        if ($this->countLogins > 0) {
+            $store = [];
+            /** @var Login $login */
+            foreach ($list as $login) {
+                $store[] = $login->toArray();
+            }
+            $config               = $this->repository->getConfiguration($this->importJob);
+            $config['all-logins'] = $store;
+            $this->repository->setConfiguration($this->importJob, $config);
+        }
+    }
+
+    /**
+     * @param ImportJob $importJob
+     */
+    public function setImportJob(ImportJob $importJob): void
+    {
+        $this->importJob  = $importJob;
+        $this->repository = app(ImportJobRepositoryInterface::class);
+        $this->repository->setUser($importJob->user);
+    }
+
+    /**
+     * @return Customer
+     * @throws FireflyException
+     */
+    private function getCustomer(): Customer
+    {
+        Log::debug('Now in manageLoginsHandler::getCustomer()');
+        $customer = $this->getExistingCustomer();
+        if (null === $customer) {
+            Log::debug('The customer is NULL, will fire a newCustomerRequest.');
+            $newCustomerRequest = new NewCustomerRequest($this->importJob->user);
+            $customer           = $newCustomerRequest->getCustomer();
+
+        }
+        Log::debug('The customer is not null.');
+
+        return $customer;
+    }
+
+    /**
+     * @return Customer|null
+     * @throws FireflyException
+     */
+    private function getExistingCustomer(): ?Customer
+    {
+        Log::debug('Now in getExistingCustomer()');
+        $customer           = null;
+        $getCustomerRequest = new ListCustomersRequest($this->importJob->user);
+        $getCustomerRequest->call();
+        $customers = $getCustomerRequest->getCustomers();
+
+        Log::debug(sprintf('Found %d customer(s)', \count($customers)));
+        /** @var Customer $current */
+        foreach ($customers as $current) {
+            if ('default_ff3_customer' === $current->getIdentifier()) {
+                $customer = $current;
+                Log::debug('Found the correct customer.');
+                break;
+            }
+        }
+
+        return $customer;
+    }
+
+}

app/Support/Import/Routine/Spectre/StageAuthenticatedHandler.php

@@ -0,0 +1,105 @@
+<?php
+/**
+ * StageAuthenticatedHandler.php
+ * Copyright (c) 2018 thegrumpydictator@gmail.com
+ *
+ * This file is part of Firefly III.
+ *
+ * Firefly III is free software: you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation, either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * Firefly III is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with Firefly III. If not, see <http://www.gnu.org/licenses/>.
+ */
+
+declare(strict_types=1);
+
+namespace FireflyIII\Support\Import\Routine\Spectre;
+
+use FireflyIII\Exceptions\FireflyException;
+use FireflyIII\Models\ImportJob;
+use FireflyIII\Repositories\ImportJob\ImportJobRepositoryInterface;
+use FireflyIII\Services\Spectre\Object\Account;
+use FireflyIII\Services\Spectre\Object\Login;
+use FireflyIII\Services\Spectre\Request\ListAccountsRequest;
+
+class StageAuthenticatedHandler
+{
+    /** @var ImportJob */
+    private $importJob;
+    /** @var ImportJobRepositoryInterface */
+    private $repository;
+
+    /**
+     * User has selected a login (a bank). Will grab all accounts from this bank.
+     * Then make user pick some to import from.
+     *
+     * @throws FireflyException
+     */
+    public function run()
+    {
+        // grab a list of logins.
+        $config = $this->importJob->configuration;
+        $logins = $config['all-logins'] ?? [];
+        if (\count($logins) === 0) {
+            throw new FireflyException('StageAuthenticatedHandler expects more than 0 logins. Apologies, the import has stopped.');
+        }
+
+        $selectedLogin = $config['selected-login'];
+        $login         = null;
+        foreach ($logins as $loginArray) {
+            $loginId = $loginArray['id'] ?? -1;
+            if ($loginId === $selectedLogin) {
+                $login = new Login($loginArray);
+            }
+        }
+        if (null === $login) {
+            $login = new Login($logins[0]);
+        }
+
+        // with existing login we can grab accounts from this login.
+        $accounts           = $this->getAccounts($login);
+        $config['accounts'] = [];
+        /** @var Account $account */
+        foreach ($accounts as $account) {
+            $config['accounts'][] = $account->toArray();
+        }
+        $this->repository->setConfiguration($this->importJob, $config);
+
+    }
+
+    /**
+     * @param ImportJob $importJob
+     */
+    public function setImportJob(ImportJob $importJob): void
+    {
+        $this->importJob  = $importJob;
+        $this->repository = app(ImportJobRepositoryInterface::class);
+        $this->repository->setUser($importJob->user);
+    }
+
+    /**
+     * @param Login $login
+     *
+     * @return array
+     * @throws FireflyException
+     */
+    private function getAccounts(Login $login): array
+    {
+        $request = new ListAccountsRequest($this->importJob->user);
+        $request->setLogin($login);
+        $request->call();
+        $accounts = $request->getAccounts();
+
+        return $accounts;
+    }
+
+
+}

app/Support/Import/Routine/Spectre/StageNewHandler.php

@@ -61,11 +61,14 @@ class StageNewHandler
     {
         Log::debug('Now in stageNewHandler::run()');
         $customer = $this->getCustomer();
-        // get token using customer.
-        $token = $this->getToken($customer);
 
+        // get token using customer.
         app('preferences')->setForUser($this->importJob->user, 'spectre_customer', $customer->toArray());
-        app('preferences')->setForUser($this->importJob->user, 'spectre_token', $token->toArray());
+
+        // store token in the job.
+        $config          = $this->repository->getConfiguration($this->importJob);
+
+        $this->repository->setConfiguration($this->importJob, $config);
     }
 
     /**
@@ -122,23 +125,6 @@ class StageNewHandler
         return $customer;
     }
 
-    /**
-     * @param Customer $customer
-     *
-     * @throws FireflyException
-     * @return Token
-     */
-    private function getToken(Customer $customer): Token
-    {
-        Log::debug('Now in getToken()');
-        $request = new CreateTokenRequest($this->importJob->user);
-        $request->setUri(route('import.job.status.index', [$this->importJob->key]));
-        $request->setCustomer($customer);
-        $request->call();
-        Log::debug('Call to get token is finished');
-
-        return $request->getToken();
-    }
 
 
 }