Popstas\Transmission\Console\Command\StatsGet::execute()

Complexity

Conditions	8
Paths	55

Size

Total Lines	83
Code Lines	55

Duplication

Lines	0
Ratio	0 %

Importance

Changes	4
Bugs	1	Features	1

<?php
    protected function execute(InputInterface $input, OutputInterface $output)
    {
        $config = $this->getApplication()->getConfig();
        $logger = $this->getApplication()->getLogger();
        $client = $this->getApplication()->getClient();

        try {
            $influxDbClient = $this->getApplication()->getInfluxDbClient(
                $config->get('influxdb-host'),
                $config->get('influxdb-port'),
                $config->get('influxdb-user'),
                $config->get('influxdb-password'),
                $config->get('influxdb-database')
            );

            $lastDays = (int)$input->getOption('days') ? (int)$input->getOption('days') : 0;
            $limit = (int)$input->getOption('limit') ? (int)$input->getOption('limit') : 0;

            $torrentList = $client->getTorrentData();

            $torrentList = TorrentListUtils::filterTorrents($torrentList, [
                'name' => $input->getOption('name'),
            ]);

            $transmissionHost = $config->overrideConfig($input, 'transmission-host');

            $rows = [];

            foreach ($torrentList as $torrent) {
                $uploaded = $influxDbClient->getTorrentSum($torrent, 'uploaded_last', $transmissionHost, $lastDays);

                $profit = round($uploaded / $torrent[Torrent\Get::TOTAL_SIZE], 2);

                $rows[] = [
                    $torrent[Torrent\Get::NAME],
                    $torrent[Torrent\Get::ID],
                    TorrentUtils::getSizeInGb($uploaded) . ' GB',
                    $profit
                ];
            }
        } catch (\Exception $e) {
            $logger->critical($e->getMessage());
            return 1;
        }

        $rows = TableUtils::filterRows($rows, [
            '3' => ['type' => 'numeric', 'value' => $input->getOption('profit')]
        ]);

        TableUtils::printTable([
            'headers' => ['Name', 'Id', 'Uploaded', 'Profit'],
            'rows' => $rows,
            'totals' => [
                '',
                '',
                TorrentListUtils::sumArrayField($rows, 2),
                TorrentListUtils::sumArrayField($rows, 3)
            ]
        ], $output, $input->getOption('sort'), $limit);

        if ($input->getOption('rm')) {
            $rows = TableUtils::sortRowsByColumnNumber($rows, $input->getOption('sort'));

            if ($limit && $limit < count($rows)) {
                $rows = array_slice($rows, 0, $limit);
            }

            $torrentIds = TorrentListUtils::getArrayField($rows, 1);
            $command = $this->getApplication()->find('torrent-remove');
            $arguments = array(
                'command'     => 'torrent-remove',
                'torrent-ids' => $torrentIds,
                '--dry-run'   => $input->getOption('dry-run'),
                '--yes'       => $input->getOption('yes'),
                '--soft'      => $input->getOption('soft'),
            );

            $removeInput = new ArrayInput($arguments);
            return $command->run($removeInput, $output);
        }

        return 0;
    }
}