Completed
Push — master ( e3ab56...2f3a52 )
by Jacob
03:32
created
src/Domain/Waterfall/Period/PeriodRepositoryInterface.php 1 patch
Indentation   +1 added lines, -1 removed lines patch added patch discarded remove patch
@@ -4,5 +4,5 @@
 block discarded – undo
4 4
 
5 5
 interface PeriodRepositoryInterface
6 6
 {
7
-    public function getPeriodList();
7
+	public function getPeriodList();
8 8
 }
Please login to merge, or discard this patch.
src/Domain/Waterfall/Watercourse/MysqlWatercourseRepository.php 2 patches
Indentation   +26 added lines, -26 removed lines patch added patch discarded remove patch
@@ -7,21 +7,21 @@  discard block
 block discarded – undo
7 7
 class MysqlWatercourseRepository implements WatercourseRepositoryInterface
8 8
 {
9 9
 
10
-    /** @var  Aura\Sql\ConnectionLocator */
11
-    protected $connections;
12
-
13
-    /**
14
-     * @param Aura\Sql\ConnectionLocator $connections
15
-     */
16
-    public function __construct(ConnectionLocator $connections)
17
-    {
18
-        $this->connections = $connections;
19
-    }
20
-
21
-    // todo wot are you even serious
22
-    public function getWatercourseList()
23
-    {
24
-        $query = "
10
+	/** @var  Aura\Sql\ConnectionLocator */
11
+	protected $connections;
12
+
13
+	/**
14
+	 * @param Aura\Sql\ConnectionLocator $connections
15
+	 */
16
+	public function __construct(ConnectionLocator $connections)
17
+	{
18
+		$this->connections = $connections;
19
+	}
20
+
21
+	// todo wot are you even serious
22
+	public function getWatercourseList()
23
+	{
24
+		$query = "
25 25
             SELECT `sum_table`.`name`, `sum_table`.`alias`, SUM(`count`) AS `count`
26 26
             FROM ((
27 27
                 SELECT `watercourse`.`name`, `watercourse`.`alias`, `parent_count`.`count`
@@ -46,15 +46,15 @@  discard block
 block discarded – undo
46 46
             GROUP BY `alias`
47 47
             ORDER BY `name`";
48 48
 
49
-        $bindings = [
50
-            'public' => 1,
51
-            'no_parent' => 0,
52
-            'has_page' => 1,
53
-        ];
54
-
55
-        return $this
56
-            ->connections
57
-            ->getRead()
58
-            ->fetchAll($query, $bindings);
59
-    }
49
+		$bindings = [
50
+			'public' => 1,
51
+			'no_parent' => 0,
52
+			'has_page' => 1,
53
+		];
54
+
55
+		return $this
56
+			->connections
57
+			->getRead()
58
+			->fetchAll($query, $bindings);
59
+	}
60 60
 }
Please login to merge, or discard this patch.
Doc Comments   +1 added lines, -1 removed lines patch added patch discarded remove patch
@@ -11,7 +11,7 @@
 block discarded – undo
11 11
     protected $connections;
12 12
 
13 13
     /**
14
-     * @param Aura\Sql\ConnectionLocator $connections
14
+     * @param ConnectionLocator $connections
15 15
      */
16 16
     public function __construct(ConnectionLocator $connections)
17 17
     {
Please login to merge, or discard this patch.
src/Domain/Waterfall/Watercourse/WatercourseRepositoryInterface.php 1 patch
Indentation   +1 added lines, -1 removed lines patch added patch discarded remove patch
@@ -4,5 +4,5 @@
 block discarded – undo
4 4
 
5 5
 interface WatercourseRepositoryInterface
6 6
 {
7
-    public function getWatercourseList();
7
+	public function getWatercourseList();
8 8
 }
Please login to merge, or discard this patch.
src/Domain/Waterfall/Waterfall/WaterfallRepositoryInterface.php 2 patches
Indentation   +1 added lines, -1 removed lines patch added patch discarded remove patch
@@ -4,5 +4,5 @@
 block discarded – undo
4 4
 
5 5
 interface WaterfallRepositoryInterface
6 6
 {
7
-    public function getWaterfalls($limit = null, $offset= 0);
7
+	public function getWaterfalls($limit = null, $offset= 0);
8 8
 }
Please login to merge, or discard this patch.
Spacing   +1 added lines, -1 removed lines patch added patch discarded remove patch
@@ -4,5 +4,5 @@
 block discarded – undo
4 4
 
5 5
 interface WaterfallRepositoryInterface
6 6
 {
7
-    public function getWaterfalls($limit = null, $offset= 0);
7
+    public function getWaterfalls($limit = null, $offset = 0);
8 8
 }
Please login to merge, or discard this patch.
script/cron/fetch-github-activity.php 2 patches
Unused Use Statements   -1 removed lines patch added patch discarded remove patch
@@ -3,7 +3,6 @@
 block discarded – undo
3 3
 require_once __DIR__ . '/../index.php';
4 4
 
5 5
 use Github\Client;
6
-
7 6
 use Jacobemerick\Web\Domain\Stream\Changelog\MysqlChangelogRepository as ChangelogRepository;
8 7
 
9 8
 $client = new Client();
Please login to merge, or discard this patch.
Indentation   +37 added lines, -37 removed lines patch added patch discarded remove patch
@@ -9,9 +9,9 @@  discard block
 block discarded – undo
9 9
 
10 10
 $client = new Client();
11 11
 $client->authenticate(
12
-    $config->github->client_id,
13
-    $config->github->client_secret,
14
-    Client::AUTH_URL_CLIENT_ID
12
+	$config->github->client_id,
13
+	$config->github->client_secret,
14
+	Client::AUTH_URL_CLIENT_ID
15 15
 );
16 16
 
17 17
 /*********************************************
@@ -24,33 +24,33 @@  discard block
 block discarded – undo
24 24
 $mostRecentChangeDateTime = new DateTime($mostRecentChangeDateTime);
25 25
 
26 26
 $parameters = [
27
-    'sha' => 'master',
28
-    'since' => $mostRecentChangeDateTime->format('c'),
27
+	'sha' => 'master',
28
+	'since' => $mostRecentChangeDateTime->format('c'),
29 29
 ];
30 30
 $commits = $client->api('repo')->commits()->all('jacobemerick', 'web', $parameters);
31 31
 
32 32
 foreach ($commits as $commit) {
33
-    $uniqueChangeCheck = $changelogRepository->getChangeByHash($commit['sha']);
34
-    if ($uniqueChangeCheck !== false) {
35
-        continue;
36
-    }
37
-    $changelogRepository->insertChange(
38
-        $commit['sha'],
39
-        $commit['commit']['message'],
40
-        new DateTime($commit['commit']['author']['date']),
41
-        $commit['commit']['author']['name'],
42
-        $commit['html_url']
43
-    );
33
+	$uniqueChangeCheck = $changelogRepository->getChangeByHash($commit['sha']);
34
+	if ($uniqueChangeCheck !== false) {
35
+		continue;
36
+	}
37
+	$changelogRepository->insertChange(
38
+		$commit['sha'],
39
+		$commit['commit']['message'],
40
+		new DateTime($commit['commit']['author']['date']),
41
+		$commit['commit']['author']['name'],
42
+		$commit['html_url']
43
+	);
44 44
 }
45 45
 
46 46
 /*********************************************
47 47
  * get activity for jacobemerick
48 48
  *********************************************/
49 49
 $supportedEventTypes = [
50
-    'CreateEvent',
51
-    'ForkEvent',
52
-    'PullRequestEvent',
53
-    'PushEvent',
50
+	'CreateEvent',
51
+	'ForkEvent',
52
+	'PullRequestEvent',
53
+	'PushEvent',
54 54
 ];
55 55
 
56 56
 $githubRepository = new GithubRepository($container['db_connection_locator']);
@@ -61,23 +61,23 @@  discard block
 block discarded – undo
61 61
 
62 62
 $events = $client->api('user')->publicEvents('jacobemerick');
63 63
 foreach ($events as $event) {
64
-    $eventDateTime = new DateTime($event['created_at']);
65
-    if ($eventDateTime >= $mostRecentEventDateTime) {
66
-        break;
67
-    }
64
+	$eventDateTime = new DateTime($event['created_at']);
65
+	if ($eventDateTime >= $mostRecentEventDateTime) {
66
+		break;
67
+	}
68 68
 
69
-    if (!in_array($event['type'], $supportedEventTypes)) {
70
-        continue;
71
-    }
72
-    $uniqueEventCheck = $githubRepository->getEventByEventId($event['id']);
73
-    if ($uniqueEventCheck !== false) {
74
-        continue;
75
-    }
69
+	if (!in_array($event['type'], $supportedEventTypes)) {
70
+		continue;
71
+	}
72
+	$uniqueEventCheck = $githubRepository->getEventByEventId($event['id']);
73
+	if ($uniqueEventCheck !== false) {
74
+		continue;
75
+	}
76 76
 
77
-    $githubRepository->insertEvent(
78
-        $event['id'],
79
-        $event['type'],
80
-        $eventDateTime,
81
-        $event
82
-    );
77
+	$githubRepository->insertEvent(
78
+		$event['id'],
79
+		$event['type'],
80
+		$eventDateTime,
81
+		$event
82
+	);
83 83
 }
Please login to merge, or discard this patch.
src/Domain/Stream/Changelog/MysqlChangelogRepository.php 1 patch
Indentation   +74 added lines, -74 removed lines patch added patch discarded remove patch
@@ -8,100 +8,100 @@
 block discarded – undo
8 8
 class MysqlChangelogRepository implements ChangelogRepositoryInterface
9 9
 {
10 10
 
11
-    /** @var  ConnectionLocator */
12
-    protected $connections;
11
+	/** @var  ConnectionLocator */
12
+	protected $connections;
13 13
 
14
-    /**
15
-     * @param ConnectonLocator $connections
16
-     */
17
-    public function __construct(ConnectionLocator $connections)
18
-    {
19
-        $this->connections = $connections;
20
-    }
14
+	/**
15
+	 * @param ConnectonLocator $connections
16
+	 */
17
+	public function __construct(ConnectionLocator $connections)
18
+	{
19
+		$this->connections = $connections;
20
+	}
21 21
 
22
-    /**
23
-     * @param integer $limit
24
-     * @param integer $offset
25
-     *
26
-     * @return array|false
27
-     */
28
-    public function getChanges($limit = null, $offset = 0)
29
-    {
30
-        $query = "
22
+	/**
23
+	 * @param integer $limit
24
+	 * @param integer $offset
25
+	 *
26
+	 * @return array|false
27
+	 */
28
+	public function getChanges($limit = null, $offset = 0)
29
+	{
30
+		$query = "
31 31
             SELECT `message`, `message_short`, `datetime`, `commit_link`
32 32
             FROM `jpemeric_stream`.`changelog`
33 33
             ORDER BY `datetime` DESC";
34
-        if (!is_null($limit)) {
35
-          $query .= "
34
+		if (!is_null($limit)) {
35
+		  $query .= "
36 36
           LIMIT {$offset}, {$limit}";
37
-        }
37
+		}
38 38
 
39
-        return $this
40
-            ->connections
41
-            ->getRead()
42
-            ->fetchAll($query);
43
-    }
39
+		return $this
40
+			->connections
41
+			->getRead()
42
+			->fetchAll($query);
43
+	}
44 44
 
45
-    /**
46
-     * @param string $hash
47
-     *
48
-     * @return array|false
49
-     */
50
-    public function getChangeByHash($hash)
51
-    {
52
-        $query = "
45
+	/**
46
+	 * @param string $hash
47
+	 *
48
+	 * @return array|false
49
+	 */
50
+	public function getChangeByHash($hash)
51
+	{
52
+		$query = "
53 53
             SELECT *
54 54
             FROM `jpemeric_stream`.`changelog`
55 55
             WHERE `hash` = :hash
56 56
             LIMIT 1";
57 57
 
58
-        $bindings = [
59
-            'hash' => $hash,
60
-        ];
58
+		$bindings = [
59
+			'hash' => $hash,
60
+		];
61 61
 
62
-        return $this
63
-            ->connections
64
-            ->getRead()
65
-            ->fetchOne($query, $bindings);
66
-    }
62
+		return $this
63
+			->connections
64
+			->getRead()
65
+			->fetchOne($query, $bindings);
66
+	}
67 67
 
68
-    /**
69
-     * @param string   $hash
70
-     * @param string   $message
71
-     * @param DateTime $datetime
72
-     * @param string   $author
73
-     * @param string   $commit_link
74
-     *
75
-     * @return
76
-     */
77
-    public function insertChange($hash, $message, DateTime $datetime, $author, $commit_link)
78
-    {
79
-        $message_short = $message;
80
-        $message_short = strtok($message_short, "\n");
81
-        if (strlen($message_short) > 72) {
82
-            $message_short = wordwrap($message_short, 65);
83
-            $message_short = strtok($message_short, "\n");
84
-            $message_short .= '...';
85
-        }
68
+	/**
69
+	 * @param string   $hash
70
+	 * @param string   $message
71
+	 * @param DateTime $datetime
72
+	 * @param string   $author
73
+	 * @param string   $commit_link
74
+	 *
75
+	 * @return
76
+	 */
77
+	public function insertChange($hash, $message, DateTime $datetime, $author, $commit_link)
78
+	{
79
+		$message_short = $message;
80
+		$message_short = strtok($message_short, "\n");
81
+		if (strlen($message_short) > 72) {
82
+			$message_short = wordwrap($message_short, 65);
83
+			$message_short = strtok($message_short, "\n");
84
+			$message_short .= '...';
85
+		}
86 86
 
87
-        $query = "
87
+		$query = "
88 88
             INSERT INTO `jpemeric_stream`.`changelog`
89 89
                 (`hash`, `message`, `message_short`, `datetime`, `author`, `commit_link`)
90 90
             VALUES
91 91
                 (:hash, :message, :message_short, :datetime, :author, :commit_link)";
92 92
 
93
-        $bindings = [
94
-            'hash' => $hash,
95
-            'message' => $message,
96
-            'message_short' => $message_short,
97
-            'datetime' => $datetime->format('Y-m-d H:i:s'),
98
-            'author' => $author,
99
-            'commit_link' => $commit_link
100
-        ];
93
+		$bindings = [
94
+			'hash' => $hash,
95
+			'message' => $message,
96
+			'message_short' => $message_short,
97
+			'datetime' => $datetime->format('Y-m-d H:i:s'),
98
+			'author' => $author,
99
+			'commit_link' => $commit_link
100
+		];
101 101
 
102
-        return $this
103
-            ->connections
104
-            ->getWrite()
105
-            ->perform($query, $bindings);
106
-    }
102
+		return $this
103
+			->connections
104
+			->getWrite()
105
+			->perform($query, $bindings);
106
+	}
107 107
 }
Please login to merge, or discard this patch.
src/Domain/Stream/Changelog/ChangelogRepositoryInterface.php 1 patch
Indentation   +1 added lines, -1 removed lines patch added patch discarded remove patch
@@ -4,5 +4,5 @@
 block discarded – undo
4 4
 
5 5
 interface ChangelogRepositoryInterface
6 6
 {
7
-    public function getChanges($limit = null, $offset = 0);
7
+	public function getChanges($limit = null, $offset = 0);
8 8
 }
Please login to merge, or discard this patch.
src/Domain/Stream/Github/MysqlGithubRepository.php 1 patch
Indentation   +64 added lines, -64 removed lines patch added patch discarded remove patch
@@ -8,89 +8,89 @@
 block discarded – undo
8 8
 class MysqlGithubRepository implements GithubRepositoryInterface
9 9
 {
10 10
 
11
-    /** @var  ConnectionLocator */
12
-    protected $connections;
11
+	/** @var  ConnectionLocator */
12
+	protected $connections;
13 13
 
14
-    /**
15
-     * @param ConnectonLocator $connections
16
-     */
17
-    public function __construct(ConnectionLocator $connections)
18
-    {
19
-        $this->connections = $connections;
20
-    }
14
+	/**
15
+	 * @param ConnectonLocator $connections
16
+	 */
17
+	public function __construct(ConnectionLocator $connections)
18
+	{
19
+		$this->connections = $connections;
20
+	}
21 21
 
22
-    /**
23
-     * @param integer $limit
24
-     * @param integer $offset
25
-     *
26
-     * @return array|false
27
-     */
28
-    public function getEvents($limit = null, $offset = 0)
29
-    {
30
-        $query = "
22
+	/**
23
+	 * @param integer $limit
24
+	 * @param integer $offset
25
+	 *
26
+	 * @return array|false
27
+	 */
28
+	public function getEvents($limit = null, $offset = 0)
29
+	{
30
+		$query = "
31 31
             SELECT `id`, `event_id`, `datetime`
32 32
             FROM `jpemeric_stream`.`github`
33 33
             ORDER BY `datetime` DESC";
34
-        if (!is_null($limit)) {
35
-          $query .= "
34
+		if (!is_null($limit)) {
35
+		  $query .= "
36 36
           LIMIT {$offset}, {$limit}";
37
-        }
37
+		}
38 38
 
39
-        return $this
40
-            ->connections
41
-            ->getRead()
42
-            ->fetchAll($query);
43
-    }
39
+		return $this
40
+			->connections
41
+			->getRead()
42
+			->fetchAll($query);
43
+	}
44 44
 
45
-    /**
46
-     * @param integer $eventId
47
-     *
48
-     * @return array|false
49
-     */
50
-    public function getEventByEventId($eventId)
51
-    {
52
-        $query = "
45
+	/**
46
+	 * @param integer $eventId
47
+	 *
48
+	 * @return array|false
49
+	 */
50
+	public function getEventByEventId($eventId)
51
+	{
52
+		$query = "
53 53
             SELECT *
54 54
             FROM `jpemeric_stream`.`github`
55 55
             WHERE `event_id` = :event_id
56 56
             LIMIT 1";
57 57
 
58
-        $bindings = [
59
-            'event_id' => $eventId,
60
-        ];
58
+		$bindings = [
59
+			'event_id' => $eventId,
60
+		];
61 61
 
62
-        return $this
63
-            ->connections
64
-            ->getRead()
65
-            ->fetchOne($query, $bindings);
66
-    }
62
+		return $this
63
+			->connections
64
+			->getRead()
65
+			->fetchOne($query, $bindings);
66
+	}
67 67
 
68
-    /**
69
-     * @param integer  $eventId
70
-     * @param string   $eventType
71
-     * @param DateTime $datetime
72
-     * @param array    $metadata
73
-     *
74
-     * @return
75
-     */
76
-    public function insertEvent($eventId, $eventType, DateTime $datetime, array $metadata)
77
-    {
78
-        $query = "
68
+	/**
69
+	 * @param integer  $eventId
70
+	 * @param string   $eventType
71
+	 * @param DateTime $datetime
72
+	 * @param array    $metadata
73
+	 *
74
+	 * @return
75
+	 */
76
+	public function insertEvent($eventId, $eventType, DateTime $datetime, array $metadata)
77
+	{
78
+		$query = "
79 79
             INSERT INTO `jpemeric_stream`.`github`
80 80
                 (`event_id`, `type`, `datetime`, `metadata`)
81 81
             VALUES
82 82
                 (:event_id, :event_type, :datetime, :metadata)";
83 83
 
84
-        $bindings = [
85
-            'event_id' => $eventId,
86
-            'event_type' => $eventType,
87
-            'datetime' => $datetime->format('Y-m-d H:i:s'),
88
-            'metadata' => json_encode($metadata),
89
-        ];
84
+		$bindings = [
85
+			'event_id' => $eventId,
86
+			'event_type' => $eventType,
87
+			'datetime' => $datetime->format('Y-m-d H:i:s'),
88
+			'metadata' => json_encode($metadata),
89
+		];
90 90
 
91
-        return $this
92
-            ->connections
93
-            ->getWrite()
94
-            ->perform($query, $bindings);
95
-    }
91
+		return $this
92
+			->connections
93
+			->getWrite()
94
+			->perform($query, $bindings);
95
+	}
96 96
 }
Please login to merge, or discard this patch.
src/Domain/Stream/Github/GithubRepositoryInterface.php 1 patch
Indentation   +2 added lines, -2 removed lines patch added patch discarded remove patch
@@ -4,6 +4,6 @@
 block discarded – undo
4 4
 
5 5
 interface GithubRepositoryInterface
6 6
 {
7
-    public function getEvents($limit = null, $offset = 0);
8
-    public function getEventByEventId($eventId);
7
+	public function getEvents($limit = null, $offset = 0);
8
+	public function getEventByEventId($eventId);
9 9
 }
Please login to merge, or discard this patch.