refactor guthub api
[pharext/pharext.org] / app / Controller / Github / Callback.php
1 <?php
2
3 namespace app\Controller\Github;
4
5 use app\Controller\Github;
6 use app\Github\API;
7 use app\Github\Exception;
8 use app\Model\Accounts;
9 use app\Session;
10 use app\Web;
11
12 class Callback extends Github
13 {
14
15 /**
16 * @var Accounts
17 */
18 private $accounts;
19
20 function __construct(Web $app, API $github, Session $session, Accounts $accounts) {
21 parent::__construct($app, $github, $session);
22 $this->accounts = $accounts;
23 }
24
25 function __invoke(array $args = null) {
26 if ($this->app->getRequest()->getQuery("error")) {
27 $this->app->getView()->addData([
28 "error" => $this->app->getRequest()->getQuery("error_description")
29 ]);
30 } else {
31 $this->github->fetchToken(
32 $this->app->getRequest()->getQuery("code"),
33 $this->app->getRequest()->getQuery("state"),
34 function($token) {
35 $this->github->setToken($token->access_token);
36 $this->github->fetchUser($this->createUserCallback($token));
37 })->send();
38 if (isset($this->session->returnto)) {
39 $returnto = $this->session->returnto;
40 unset($this->session->returnto);
41 $this->app->redirect($returnto);
42 } else {
43 $this->app->redirect(
44 $this->app->getBaseUrl()->mod("./github"));
45 }
46 }
47 $this->app->display("github/callback");
48 }
49
50 function createUserCallback($token) {
51 return function($user) use($token) {
52 $tx = $this->accounts->getConnection()->startTransaction();
53
54 if (!($account = $this->accounts->byOAuth("github", $token->access_token, $user->login))) {
55 $account = $this->accounts->createOAuthAccount("github", $token->access_token, $user->login);
56 }
57 $account->updateToken("github", $token->access_token, $token);
58 $owner = $account->updateOwner("github", $user->login, $user);
59
60 $tx->commit();
61
62 $this->session->account = $account->account->get();
63 $this->session->github = (object) $owner->export();
64 };
65 }
66 }