X-Git-Url: https://git.m6w6.name/?a=blobdiff_plain;f=app%2FController%2FGithub%2FCallback.php;h=baa6c4d47389f0d4aba92eede281c180f2e742f0;hb=2198c781a021d85ee845f2f4b2f5c322f73e6bd5;hp=fefc12c77a2e9c76d628f80bba723f4ea74f42c2;hpb=c05a8f703d5a097355b5813154c264c87e3f71fe;p=pharext%2Fpharext.org

diff --git a/app/Controller/Github/Callback.php b/app/Controller/Github/Callback.php
index fefc12c..baa6c4d 100644
--- a/app/Controller/Github/Callback.php
+++ b/app/Controller/Github/Callback.php
@@ -27,34 +27,7 @@ class Callback extends Github
 				"error" => $this->app->getRequest()->getQuery("error_description")
 			]);
 		} else {
-			$this->github->fetchToken(
-				$this->app->getRequest()->getQuery("code"),
-				$this->app->getRequest()->getQuery("state")
-			)->then(function($result) {
-				list($oauth) = $result;
-				$this->github->setToken($oauth->access_token);
-				return $this->github->readAuthUser()->then(function($result) use($oauth) {
-					list($user) = $result;
-					return [$oauth, $user];
-				});
-			})->then(function($result) {
-				list($oauth, $user) = $result;
-				$tx = $this->accounts->getConnection()->startTransaction();
-
-				if (($cookie = $this->app->getRequest()->getCookie("account"))) {
-					$account = $this->accounts->find(["account=" => $cookie])->current();
-				} elseif (!($account = $this->accounts->byOAuth("github", $oauth->access_token, $user->login))) {
-					$account = $this->accounts->createOAuthAccount("github", $oauth->access_token, $user->login);
-				}
-				$token = $account->updateToken("github", $oauth->access_token, $oauth);
-				$owner = $account->updateOwner("github", $user->login, $user);
-
-				$tx->commit();
-
-				$this->login($account, $token, $owner);
-			})->done();
-			
-			$this->github->getClient()->send();
+			$this->validateUser();
 			
 			if (isset($this->session->returnto)) {
 				$returnto = $this->session->returnto;
@@ -68,4 +41,37 @@ class Callback extends Github
 		$this->app->display("github/callback");
 	}
 	
+	private function validateUser() {
+		$this->github->fetchToken(
+			$this->app->getRequest()->getQuery("code"),
+			$this->app->getRequest()->getQuery("state")
+		)->then(function($result) {
+			list($oauth) = $result;
+			$this->github->setToken($oauth->access_token);
+			return $this->github->readAuthUser()->then(function($result) use($oauth) {
+				list($user) = $result;
+				return $this->persistUser($oauth, $user);
+			});
+		})->done(function($result) {
+			$this->login(...$result);
+		});
+
+		$this->github->getClient()->send();
+	}
+	
+	private function persistUser($oauth, $user) {
+		$tx = $this->accounts->getConnection()->startTransaction();
+
+		if (($cookie = $this->app->getRequest()->getCookie("account"))) {
+			$account = $this->accounts->find(["account=" => $cookie])->current();
+		} elseif (!($account = $this->accounts->byOAuth("github", $oauth->access_token, $user->login))) {
+			$account = $this->accounts->createOAuthAccount("github", $oauth->access_token, $user->login);
+		}
+		$token = $account->updateToken("github", $oauth->access_token, $oauth);
+		$owner = $account->updateOwner("github", $user->login, $user);
+
+		$tx->commit();
+
+		return [$account, $token, $owner];
+	}
 }