start refactoring to promises

[pharext/pharext.org] / app / Controller / Github / Callback.php

diff --git a/app/Controller/Github/Callback.php b/app/Controller/Github/Callback.php
index d6d11920c6bd14ab3ecd465356536b1b49e94175..fefc12c77a2e9c76d628f80bba723f4ea74f42c2 100644 (file)
--- a/app/Controller/Github/Callback.php
+++ b/app/Controller/Github/Callback.php
@@ -4,14 +4,13 @@ namespace app\Controller\Github;
 
 use app\Controller\Github;
 use app\Github\API;
-use app\Github\Exception;
 use app\Model\Accounts;
 use app\Session;
 use app\Web;
+use http\Cookie;
 
 class Callback extends Github
 {
-       
        /**
         * @var Accounts
         */
@@ -28,43 +27,45 @@ class Callback extends Github
                                "error" => $this->app->getRequest()->getQuery("error_description")
                        ]);
                } else {
-                       try {
-                               $this->github->fetchToken(
-                                       $this->app->getRequest()->getQuery("code"),
-                                       $this->app->getRequest()->getQuery("state"),
-                                       function($token) {
-                                               $this->github->setToken($token->access_token);
-                                               $this->github->fetchUser($this->createUserCallback($token));
-                               })->send();
-                               if (isset($this->session->returnto)) {
-                                       $returnto = $this->session->returnto;
-                                       unset($this->session->returnto);
-                                       $this->app->redirect($returnto);
-                               } else {
-                                       $this->app->redirect(
-                                               $this->app->getBaseUrl()->mod("./github"));
+                       $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);
                                }
-                       } catch (Exception $exception) {
-                               $this->app->getView()->addData(compact("exception"));
+                               $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();
+                       
+                       if (isset($this->session->returnto)) {
+                               $returnto = $this->session->returnto;
+                               unset($this->session->returnto);
+                               $this->app->redirect($returnto);
+                       } else {
+                               $this->app->redirect(
+                                       $this->app->getBaseUrl()->mod("./github"));
                        }
                }
                $this->app->display("github/callback");
        }
        
-       function createUserCallback($token) {
-               return function($user) use($token) {
-                       $tx = $this->accounts->getConnection()->startTransaction();
-                       
-                       if (!($account = $this->accounts->byOAuth("github", $token->access_token, $user->login))) {
-                               $account = $this->accounts->createOAuthAccount("github", $token->access_token, $user->login);
-                       }
-                       $account->updateToken("github", $token->access_token, $token);
-                       $owner = $account->updateOwner("github", $user->login, $user);
-                       
-                       $tx->commit();
-                       
-                       $this->session->account = $account->account->get();
-                       $this->session->github = (object) $owner->export();
-               };
-       }
 }