startwind / inventorio-command-line

namespace Startwind\Inventorio\Reporter;

use Exception;

use GuzzleHttp\Client;

use GuzzleHttp\Exception\ConnectException;

use GuzzleHttp\Exception\ServerException;

use GuzzleHttp\RequestOptions;

use RuntimeException;

use Symfony\Component\Console\Helper\Table;

use Symfony\Component\Console\Helper\TableSeparator;

use Symfony\Component\Console\Output\OutputInterface;

/**

 * Send the collected data to the Inventorio Cloud.

 */

class InventorioGradeReporter implements Reporter

{

    private const ENDPOINT_COLLECT = '/grade/';

    private OutputInterface $output;

    private string $userId;

    private string $serverId;

    private string $inventorioServer;

    const SEVERITIES = [

        0 => '<fg=white;bg=blue> low </>',

        500 => '<fg=white;bg=yellow> medium </>',

        1000 => '<fg=white;bg=red> high </>',

    ];

    private int $startTime;

    public function __construct(OutputInterface $output, string $inventorioServer, string $serverId, string $userId)

    {

        $this->output = $output;

        $this->userId = $userId;

        $this->serverId = $serverId;

        $this->inventorioServer = $inventorioServer;

        $this->startTime = time();

    }

    /**

     * @inheritDoc

     */

    public function report(array $collectionData): void

    {

        $endpoint = $this->getPreparedEndpoint();

        $client = new Client();

        $payload = [

            'userId' => $this->userId,

            'data' => $collectionData

        ];

        try {

            $response = $client->post($endpoint, [

                RequestOptions::JSON => $payload,

                RequestOptions::TIMEOUT => 5,

                RequestOptions::CONNECT_TIMEOUT => 2

            ]);

            var_dump('ahh');

            throw $e;

        }

        $result = json_decode((string)$response->getBody(), true);

        if (!is_array($result) || !array_key_exists('status', $result)) {

            throw new RuntimeException('Unknown error.');

        }

        if ($result['status'] !== 'SUCCESS') {

            throw new RuntimeException($result['message']);

        }

        $table = new Table($this->output);

        $table->setHeaders(['Severity', 'Name', 'Description', 'Assets']);

        $hints = $result['data']['hints'];

        $lastIndex = count($hints) - 1;

        foreach ($hints as $i => $hint) {

            $row = [

                'severity' => self::SEVERITIES[$hint['definition']['severity']],

                'name' => $hint['definition']['name'],

                'description' => wordwrap($hint['definition']['description'], 40)

            ];

            $assets = [];

            if (array_key_exists('files', $hint['issue']['parameters'])) {

                $assets = array_keys($hint['issue']['parameters']['files']);

                foreach ($assets as $key => $asset) {

                    $assets[$key] = '- ' . $asset;

                }

            }

            if (array_key_exists('websites', $hint['issue']['parameters'])) {

                $assets = $hint['issue']['parameters']['websites'];

                foreach ($assets as $key => $asset) {

                    $assets[$key] = '- https://' . $asset;

                }

            }

            $row['assets'] = implode("\n", $assets);

            $table->addRow($row);

            if ($i < $lastIndex) {

                $table->addRow(new TableSeparator());

            }

        }

            $seconds = $duration - $minutes * 60;

            $this->output->writeln('Grading took ' . $minutes . ' minutes and ' . $seconds . ' seconds');

        } else {

            $this->output->writeln('Grading took ' . (time() - $this->startTime) . ' seconds');

        }*/

    }

    /**

     * Return the final endpoint where the collected data should be sent to.

     */

    private function getPreparedEndpoint(): string

    {

        return str_replace('{serverId}', $this->serverId, $this->inventorioServer . self::ENDPOINT_COLLECT);

    }

}