firefly-iii/app/Helpers/Csv/Wizard.php

<?php
namespace FireflyIII\Helpers\Csv;

use Auth;
use Config;
use Crypt;
use FireflyIII\Exceptions\FireflyException;
use FireflyIII\Helpers\Csv\Mapper\MapperInterface;
use League\Csv\Reader;
use ReflectionException;
use Session;
use Log;
/**
 * Class Wizard
 *
 * @package FireflyIII\Helpers\Csv
 */
class Wizard implements WizardInterface
{

    /**
     * @param Reader $reader
     * @param array  $map
     * @param bool   $hasHeaders
     *
     * @return array
     */
    public function getMappableValues($reader, array $map, $hasHeaders)
    {
        $values = [];
        /*
         * Loop over the CSV and collect mappable data:
         */
        $keys = array_keys($map);
        foreach ($reader as $index => $row) {
            if ($this->useRow($hasHeaders, $index)) {
                // collect all map values

                foreach ($keys as $column) {
                    $values[$column][] = $row[$column];
                }
            }
        }
        /*
         * Make each one unique.
         */
        $values = $this->uniqueRecursive($values);

        return $values;
    }

    /**
     * @param array $roles
     * @param mixed $map
     *
     * @return array
     */
    public function processSelectedMapping(array $roles, $map)
    {
        $configRoles = Config::get('csv.roles');
        $maps        = [];


        if (is_array($map)) {
            foreach ($map as $index => $field) {
                if (isset($roles[$index])) {
                    $name = $roles[$index];
                    if ($configRoles[$name]['mappable']) {
                        $maps[$index] = $name;
                    }
                }
            }
        }

        return $maps;

    }

    /**
     * @param mixed $input
     *
     * @return array
     */
    public function processSelectedRoles($input)
    {
        $roles = [];


        /*
         * Store all rows for each column:
         */
        if (is_array($input)) {
            foreach ($input as $index => $role) {
                if ($role != '_ignore') {
                    $roles[$index] = $role;
                }
            }
        }

        return $roles;
    }

    /**
     * @param array $fields
     *
     * @return bool
     */
    public function sessionHasValues(array $fields)
    {
        foreach ($fields as $field) {
            if (!Session::has($field)) {
                Log::error('Session is missing field: ' . $field);
                return false;
            }
        }

        return true;
    }

    /**
     * @param array $map
     *
     * @return array
     * @throws FireflyException
     */
    public function showOptions(array $map)
    {
        $options = [];
        foreach ($map as $index => $columnRole) {

            $mapper = Config::get('csv.roles.' . $columnRole . '.mapper');
            if (is_null($mapper)) {
                throw new FireflyException('Cannot map field of type "' . $columnRole . '".');
            }
            $class = 'FireflyIII\Helpers\Csv\Mapper\\' . $mapper;
            try {
                /** @var MapperInterface $mapObject */
                $mapObject = app($class);
            } catch (ReflectionException $e) {
                throw new FireflyException('Column "' . $columnRole . '" cannot be mapped because class ' . $mapper . ' does not exist.');
            }
            $set             = $mapObject->getMap();
            $options[$index] = $set;
        }

        return $options;
    }

    /**
     * @param $path
     *
     * @return string
     */
    public function storeCsvFile($path)
    {
        $time             = str_replace(' ', '-', microtime());
        $fileName         = 'csv-upload-' . Auth::user()->id . '-' . $time . '.csv.encrypted';
        $fullPath         = storage_path('upload') . DIRECTORY_SEPARATOR . $fileName;
        $content          = file_get_contents($path);
        $contentEncrypted = Crypt::encrypt($content);
        file_put_contents($fullPath, $contentEncrypted);

        return $fullPath;


    }

    /**
     * @param bool $hasHeaders
     * @param int  $index
     *
     * @return bool
     */
    protected function useRow($hasHeaders, $index)
    {
        return ($hasHeaders && $index > 1) || !$hasHeaders;
    }

    /**
     * @param array $array
     *
     * @return array
     */
    protected function uniqueRecursive(array $array)
    {
        foreach ($array as $column => $found) {
            $array[$column] = array_unique($found);
        }

        return $array;
    }
}