More updates to relational example

examples/relational/Storage/AuthCodeStorage.php

@@ -7,6 +7,8 @@ use League\OAuth2\Server\Storage\Adapter;
 use League\OAuth2\Server\Entity\AuthCodeEntity;
 use League\OAuth2\Server\Entity\ScopeEntity;
 
+use Illuminate\Database\Capsule\Manager as Capsule;
+
 class AuthCodeStorage extends Adapter implements AuthCodeInterface
 {
     /**
@@ -14,7 +16,29 @@ class AuthCodeStorage extends Adapter implements AuthCodeInterface
      */
     public function get($code)
     {
-        die(var_dump(__METHOD__, func_get_args()));
+        $result = Capsule::table('oauth_auth_codes')
+                            ->where('auth_code', $code)
+                            ->where('expire_time', '>=', time())
+                            ->get();
+
+        if (count($result) === 1) {
+            $token = new AuthCodeEntity($this->server);
+            $token->setToken($result[0]['auth_code']);
+            return $token;
+        }
+
+        return null;
+    }
+
+    public function create($token, $$expireTime, $sessionId)
+    {
+        Capsule::table('oauth_auth_codes')
+                    ->insert([
+                        'auth_code'     =>  $token,
+                        'client_redirect_uri'  =>  $redirectUri,
+                        'session_id'    =>  $sessionId,
+                        'expire_time'   =>  $expireTime
+                    ]);
     }
 
     /**
@@ -30,7 +54,11 @@ class AuthCodeStorage extends Adapter implements AuthCodeInterface
      */
     public function associateScope(AuthCodeEntity $token, ScopeEntity $scope)
     {
-        die(var_dump(__METHOD__, func_get_args()));
+        Capsule::table('oauth_auth_code_scopes')
+                            ->insert([
+                                'auth_code' =>  $token->getToken(),
+                                'scope'     =>  $scope->getId()
+                            ]);
     }
 
     /**

examples/relational/Storage/ClientStorage.php

@@ -16,7 +16,31 @@ class ClientStorage extends Adapter implements ClientInterface
      */
     public function get($clientId, $clientSecret = null, $redirectUri = null, $grantType = null)
     {
-        die(var_dump(__METHOD__, func_get_args()));
+        $query = Capsule::table('oauth_clients')
+                          ->select('oauth_clients.*')
+                          ->where('oauth_clients.id', $clientId);
+
+        if ($clientSecret !== null) {
+            $query->where('oauth_clients.secret', $clientSecret);
+        }
+
+        if ($redirectUri) {
+            $query->join('oauth_client_redirect_uris', 'oauth_clients.id', '=', 'oauth_client_redirect_uris.client_id')
+                  ->select(['oauth_clients.*', 'oauth_client_redirect_uris.*'])
+                  ->where('oauth_client_redirect_uris.redirect_uri', $redirectUri);
+        }
+
+        $result = $query->get();
+
+        if (count($result) === 1) {
+            $client = new ClientEntity($this->server);
+            $client->setId($result[0]['id']);
+            $client->setName($result[0]['name']);
+
+            return $client;
+        }
+
+        return null;
     }
 
     /**
@@ -37,5 +61,7 @@ class ClientStorage extends Adapter implements ClientInterface
 
             return $client;
         }
+
+        return null;
     }
 }

examples/relational/Storage/ScopeStorage.php

@@ -4,6 +4,9 @@ namespace RelationalExample\Storage;
 
 use League\OAuth2\Server\Storage\ScopeInterface;
 use League\OAuth2\Server\Storage\Adapter;
+use League\OAuth2\Server\Entity\ScopeEntity;
+
+use Illuminate\Database\Capsule\Manager as Capsule;
 
 class ScopeStorage extends Adapter implements ScopeInterface
 {
@@ -12,6 +15,16 @@ class ScopeStorage extends Adapter implements ScopeInterface
      */
     public function get($scope, $grantType = null)
     {
-        die(var_dump(__METHOD__, func_get_args()));
+        $result = Capsule::table('oauth_scopes')
+                                ->where('id', $scope)
+                                ->get();
+
+        if (count($result) === 0) {
+            return null;
+        }
+
+        return (new ScopeEntity($this->server))
+                            ->setId($result[0]['id'])
+                            ->setDescription($result[0]['description']);
     }
 }

examples/relational/Storage/SessionStorage.php

@@ -57,7 +57,22 @@ class SessionStorage extends Adapter implements SessionInterface
      */
     public function getScopes(SessionEntity $session)
     {
-        die(var_dump(__CLASS__.'::'.__METHOD__, func_get_args()));
+        $result = Capsule::table('oauth_sessions')
+                            ->select('oauth_scopes.*')
+                            ->join('oauth_session_scopes', 'oauth_sessions.id', '=', 'oauth_session_scopes.session_id')
+                            ->join('oauth_scopes', 'oauth_scopes.id', '=', 'oauth_session_scopes.scope')
+                            ->where('oauth_sessions.id', $session->getId())
+                            ->get();
+
+        $scopes = [];
+
+        foreach ($result as $scope) {
+            $scopes[] = (new ScopeEntity($this->server))
+                            ->setId($scope['id'])
+                            ->setDescription($scope['description']);
+        }
+
+        return $scopes;
     }
 
     /**
@@ -65,7 +80,14 @@ class SessionStorage extends Adapter implements SessionInterface
      */
     public function create($ownerType, $ownerId, $clientId, $clientRedirectUri = null)
     {
-        die(var_dump(__CLASS__.'::'.__METHOD__, func_get_args()));
+        $id = Capsule::table('oauth_sessions')
+                        ->insert([
+                            'owner_type'  =>    $ownerType,
+                            'owner_id'    =>    $ownerId,
+                            'client_id'   =>    $clientId
+                        ]);
+
+        return $id;
     }
 
     /**