Wicked\Timely\Command\Push::execute()

Complexity

Conditions	10
Paths	23

Size

Total Lines

102

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    protected function execute(InputInterface $input, OutputInterface $output)
    {
        // get the ticket
        $ticket = $input->getArgument('ticket');

        // we might need framing dates
        $toDate = null;
        $fromDate = null;

        // there might be a limit
        $limit = null;

        // prepare all the input options
        $this->prepareInputParams($input, $ticket, $fromDate, $toDate, $limit);

        // filter by ticket if given
        /** @var \Wicked\Timely\Storage\StorageInterface $storage */
        $storage = StorageFactory::getStorage();
        $bookings = $storage->retrieve($ticket, $toDate, $fromDate, $limit);

        // return if we did not find any bookings
        if (empty($bookings)) {
            $output->write('No bookings found, nothing to push ...', true);
            return;
        }

        // get tasks from bookings
        $tasks = TaskFactory::getTasksFromBookings($bookings);

        // retrieve configuration
        $configuration = new DotEnvConfiguration();

        $bookingsPushed = array();
        // get our issue service and push the tasks
        $issueService = new IssueService($configuration);
        foreach ($tasks as $task) {
            // Allready pushed to jira? take next one
            if ($task->isPushed()) {
                continue;
            }
            // create a worklog from the task
            $workLog = new Worklog();
            $workLog->setComment($task->getComment())
                ->setStarted($task->getStartTime())
                ->setTimeSpent(Date::secondsToUnits(Date::roundByInterval($task->getDuration(), 900)));

            // check the sanity of our worklog and discard it if there is something missing
            if (!$task->getTicketId() || empty($workLog->timeSpent) || empty($workLog->comment))
            {
                $output->writeln('Not pushing one worklog as it misses vital information');
                continue;
            }

            // log the worklog about to being pushed if output is verbose
            if ($output->getVerbosity() >= OutputInterface::VERBOSITY_VERBOSE) {
                $output->writeln(
                    sprintf(
                        '%s : %s > %s',
                        $task->getTicketId(),
                        $workLog->timeSpent,
                        $workLog->comment
                    )
                );
            }

            try {
                // push to remote
                $issueService->addWorklog($task->getTicketId(), $workLog);

                $output->writeln(
                    sprintf(
                        'PUSHED %s : %s > %s',
                        $task->getTicketId(),
                        $workLog->timeSpent,
                        $workLog->comment
                    )
                );

                $bookingsPushed[] = $task->getStartBooking();

            } catch (JiraException $e) {
                $output->write(
                    sprintf(
                        'Error while pushing. Status %s, with message: "%s"',
                        $e->getCode(),
                        $e->getMessage()
                    )
                );
            }
        }

        foreach ($bookingsPushed as $booking) {
            $storage->storePush($booking);
            $formatter = FormatterFactory::getFormatter();
            $bookString = $formatter->toString($booking);
            $output->write($bookString, true);
        }

        // write output
        $output->write(sprintf('Successfully pushed %s tasks.', count($bookingsPushed)), true);

    }
}