digiaonline / lumen-contentful-sync / 60

Committed 21 Nov 2018 - 9:44 coverage: 35.802% (-0.8%) from 36.646%

Build # 60

Build Type

Pull #15

travis-ci

Committed by

web-flow

Commit Message

Bump the Phpstan analysis level to 7, fix a minor complaint

Pull Request Pull Request #15: [WIP] Upgrade to lumen-contentful 4.x, Contentful SDK 4.x

Run Details

0 of 10 new or added lines in 2 files covered. (0.0%)

58 of 162 relevant lines covered (35.8%)

0.52 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/src/Console/Commands/SyncContentsCommand.php

<?php

namespace Digia\Lumen\ContentfulSync\Console\Commands;

use Contentful\Delivery\Query;
use Digia\JsonHelpers\JsonEncoder;

/**
 * Class SyncContentsCommand
 * @package Digia\Lumen\ContentfulSync\Console\Commands
 */
class SyncContentsCommand extends AbstractSyncCommand
{

    /**
     * @var string
     */
    protected $signature = 'contentful:contents:sync 
                            {contentTypes?* : The content types, e.g. "article" or "brand". You can specify multiple content types. Omit to synchronize all content types.}
                            {--batchSize=100 : The number of items to request from Contentful in one batch. Defaults to 100.} 
                            {--ignoreErrors : Whether to ignore errors when synchronizing, useful to get around circular references.}
                            {--ignoreExisting : Whether to ignore existing entries, i.e. only synchronize new entries.}';

    /**
     * @var string
     */
    protected $description = 'Synchronizes content from Contentful';

    /**
     * @var boolean
     */
    protected $ignoreErrors;

    /**
     * @inheritdoc
     */
    protected function getQuery(?string $contentType = null): Query
    {
        $query = new Query();
        $query->setSkip($this->skip);
        $query->setLimit($this->batchSize);
        $query->setContentType($contentType);

        return $query;
    }

    /**
     * @inheritdoc
     */
    public function handle()
    {
        parent::handle();

        // Parse options and arguments
        $this->ignoreErrors = (bool)$this->option('ignoreErrors');
        $contentTypes       = $this->argument('contentTypes');

        // Synchronize all content types in a particular order unless specific content types were specified
        if (!\is_array($contentTypes)) {
            $contentTypes = $this->contentTypes;
        }

        foreach ($contentTypes as $contentType) {
            // Reset counters before each content type
            $this->resetCounters();

            $this->synchronizeContentType($contentType);
        }
    }

    /**
     * @param string $contentType
     *
     * @throws \Throwable
     */
    protected function synchronizeContentType(string $contentType): void
    {
        $this->info('Synchronizing content of type "' . $contentType . '"...');

        $this->output->progressStart($this->getClient()->getEntries($this->getTotalQuery($contentType))->getTotal());

        do {
            $entries = $this->getClient()->getEntries($this->getQuery($contentType));

            // Process the current batch
            foreach ($entries as $entry) {
                // Optionally catch exceptions, depending on whether errors should be ignored
                try {
                    $this->contentfulSyncService->publishEntry(
                        $contentType,
                        JsonEncoder::encode($entry),
                        $this->ignoreExisting
                    );

                    $this->numSynchronized++;

                    $this->output->progressAdvance();
                } catch (\Throwable $e) {
                    $this->error("  Failed to synchronize {$entry->getId()}: {$e->getMessage()}");

                    if (!$this->ignoreErrors) {
                        throw $e;
                    }
                }
            }

            // Move on to the next batch
            $this->skip += $entries->getLimit();
        } while ($this->skip < $entries->getTotal());

        $this->output->progressFinish();

        $this->info("Done, synchronized {$this->numSynchronized} entries");
    }
}

1	<?php
2
3	namespace Digia\Lumen\ContentfulSync\Console\Commands;
4
5	use Contentful\Delivery\Query;
6	use Digia\JsonHelpers\JsonEncoder;
7
8	/**
9	* Class SyncContentsCommand
10	* @package Digia\Lumen\ContentfulSync\Console\Commands
11	*/
12	class SyncContentsCommand extends AbstractSyncCommand
13	{
14
15	/**
16	* @var string
17	*/
18	protected $signature = 'contentful:contents:sync
19	{contentTypes?* : The content types, e.g. "article" or "brand". You can specify multiple content types. Omit to synchronize all content types.}
20	{--batchSize=100 : The number of items to request from Contentful in one batch. Defaults to 100.}
21	{--ignoreErrors : Whether to ignore errors when synchronizing, useful to get around circular references.}
22	{--ignoreExisting : Whether to ignore existing entries, i.e. only synchronize new entries.}';
23
24	/**
25	* @var string
26	*/
27	protected $description = 'Synchronizes content from Contentful';
28
29	/**
30	* @var boolean
31	*/
32	protected $ignoreErrors;
33
34	/**
35	* @inheritdoc
36	*/
37	protected function getQuery(?string $contentType = null): Query
38	{
39	$query = new Query();	!
40	$query->setSkip($this->skip);	!
41	$query->setLimit($this->batchSize);	!
42	$query->setContentType($contentType);	!
43
44	return $query;	!
45	}
46
47	/**
48	* @inheritdoc
49	*/
50	public function handle()
51	{
52	parent::handle();	!
53
54	// Parse options and arguments
55	$this->ignoreErrors = (bool)$this->option('ignoreErrors');	!
56	$contentTypes = $this->argument('contentTypes');	!
57
58	// Synchronize all content types in a particular order unless specific content types were specified
NEW 59	if (!\is_array($contentTypes)) {	!
NEW 60	$contentTypes = $this->contentTypes;	!
61	}
62
63	foreach ($contentTypes as $contentType) {	!
64	// Reset counters before each content type
65	$this->resetCounters();	!
66
67	$this->synchronizeContentType($contentType);	!
68	}
69	}	!
70
71	/**
72	* @param string $contentType
73	*
74	* @throws \Throwable
75	*/
76	protected function synchronizeContentType(string $contentType): void
77	{
78	$this->info('Synchronizing content of type "' . $contentType . '"...');	!
79
80	$this->output->progressStart($this->getClient()->getEntries($this->getTotalQuery($contentType))->getTotal());	!
81
82	do {
83	$entries = $this->getClient()->getEntries($this->getQuery($contentType));	!
84
85	// Process the current batch
86	foreach ($entries as $entry) {	!
87	// Optionally catch exceptions, depending on whether errors should be ignored
88	try {
89	$this->contentfulSyncService->publishEntry(	!
90	$contentType,	!
91	JsonEncoder::encode($entry),	!
92	$this->ignoreExisting	!
93	);
94
95	$this->numSynchronized++;	!
96
97	$this->output->progressAdvance();	!
98	} catch (\Throwable $e) {	!
99	$this->error(" Failed to synchronize {$entry->getId()}: {$e->getMessage()}");	!
100
101	if (!$this->ignoreErrors) {	!
102	throw $e;	!
103	}
104	}
105	}
106
107	// Move on to the next batch
108	$this->skip += $entries->getLimit();	!
109	} while ($this->skip < $entries->getTotal());	!
110
111	$this->output->progressFinish();	!
112
113	$this->info("Done, synchronized {$this->numSynchronized} entries");	!
114	}	!
115	}

digiaonline / lumen-contentful-sync / 60

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous