Basic couchdb support

CouchDocument/AccessToken.php

@@ -0,0 +1,18 @@
+<?php
+
+/*
+ * This file is part of the FOSOAuthServerBundle package.
+ *
+ * (c) FriendsOfSymfony <http://friendsofsymfony.github.com/>
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+namespace FOS\OAuthServerBundle\CouchDocument;
+
+use FOS\OAuthServerBundle\Model\AccessToken as BaseAccessToken;
+
+class AccessToken extends BaseAccessToken
+{
+}

CouchDocument/AccessTokenManager.php

@@ -0,0 +1,18 @@
+<?php
+
+/*
+ * This file is part of the FOSOAuthServerBundle package.
+ *
+ * (c) FriendsOfSymfony <http://friendsofsymfony.github.com/>
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+namespace FOS\OAuthServerBundle\CouchDocument;
+
+use FOS\OAuthServerBundle\Model\AccessTokenManagerInterface;
+
+class AccessTokenManager extends TokenManager implements AccessTokenManagerInterface
+{
+}

CouchDocument/AuthCode.php

@@ -0,0 +1,21 @@
+<?php
+
+/*
+ * This file is part of the FOSOAuthServerBundle package.
+ *
+ * (c) FriendsOfSymfony <http://friendsofsymfony.github.com/>
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+namespace FOS\OAuthServerBundle\CouchDocument;
+
+use FOS\OAuthServerBundle\Model\AuthCode as BaseAuthCode;
+
+/**
+ * @author Richard Fullmer <richard.fullmer@opensoftdev.com>
+ */
+class AuthCode extends BaseAuthCode
+{
+}

CouchDocument/AuthCodeManager.php

@@ -0,0 +1,92 @@
+<?php
+
+/*
+ * This file is part of the FOSOAuthServerBundle package.
+ *
+ * (c) FriendsOfSymfony <http://friendsofsymfony.github.com/>
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+namespace FOS\OAuthServerBundle\CouchDocument;
+
+use Doctrine\ODM\CouchDB\DocumentManager;
+use Doctrine\ODM\CouchDB\DocumentRepository;
+use FOS\OAuthServerBundle\Model\AuthCodeInterface;
+use FOS\OAuthServerBundle\Model\AuthCodeManager as BaseAuthCodeManager;
+
+class AuthCodeManager extends BaseAuthCodeManager
+{
+    /**
+     * @var DocumentManager
+     */
+    protected $dm;
+
+    /**
+     * @var DocumentRepository
+     */
+    protected $repository;
+
+    /**
+     * @var string
+     */
+    protected $class;
+
+    public function __construct(DocumentManager $dm, $class)
+    {
+        $this->dm = $dm;
+        $this->repository = $dm->getRepository($class);
+        $this->class = $class;
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function getClass()
+    {
+        return $this->class;
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function findAuthCodeBy(array $criteria)
+    {
+        return $this->repository->findOneBy($criteria);
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function updateAuthCode(AuthCodeInterface $authCode)
+    {
+        $this->dm->persist($authCode);
+        $this->dm->flush();
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function deleteAuthCode(AuthCodeInterface $authCode)
+    {
+        $this->dm->remove($authCode);
+        $this->dm->flush();
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function deleteExpired()
+    {
+        $result = $this
+            ->repository
+            ->createQueryBuilder()
+            ->remove()
+            ->field('expiresAt')->lt(time())
+            ->getQuery(array('safe' => true))
+            ->execute();
+
+        return $result['n'];
+    }
+}

CouchDocument/Client.php

@@ -0,0 +1,18 @@
+<?php
+
+/*
+ * This file is part of the FOSOAuthServerBundle package.
+ *
+ * (c) FriendsOfSymfony <http://friendsofsymfony.github.com/>
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+namespace FOS\OAuthServerBundle\CouchDocument;
+
+use FOS\OAuthServerBundle\Model\Client as BaseClient;
+
+class Client extends BaseClient
+{
+}

CouchDocument/ClientManager.php

@@ -0,0 +1,82 @@
+<?php
+
+/*
+ * This file is part of the FOSOAuthServerBundle package.
+ *
+ * (c) FriendsOfSymfony <http://friendsofsymfony.github.com/>
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+namespace FOS\OAuthServerBundle\CouchDocument;
+
+use Doctrine\ODM\CouchDB\DocumentManager;
+use Doctrine\ODM\CouchDB\DocumentRepository;
+use FOS\OAuthServerBundle\Model\ClientManager as BaseClientManager;
+use FOS\OAuthServerBundle\Model\ClientInterface;
+
+class ClientManager extends BaseClientManager
+{
+    /**
+     * @var DocumentManager
+     */
+    protected $dm;
+
+    /**
+     * @var DocumentRepository
+     */
+    protected $repository;
+
+    /**
+     * @var string
+     */
+    protected $class;
+
+    public function __construct(DocumentManager $dm, $class)
+    {
+        $this->dm = $dm;
+        $this->repository = $dm->getRepository($class);
+        $this->class = $class;
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function getClass()
+    {
+        return $this->class;
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function findClientBy(array $criteria)
+    {
+        $client =  $this->repository->findOneBy(array("randomId"=>$criteria["randomId"]));
+
+	if ($client != null)
+	    if ($client->getId() == $criteria["id"])
+		return $client;
+
+	return null;
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function updateClient(ClientInterface $client)
+    {
+        $this->dm->persist($client);
+        $this->dm->flush();
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function deleteClient(ClientInterface $client)
+    {
+        $this->dm->remove($client);
+        $this->dm->flush();
+    }
+}

CouchDocument/RefreshToken.php

@@ -0,0 +1,18 @@
+<?php
+
+/*
+ * This file is part of the FOSOAuthServerBundle package.
+ *
+ * (c) FriendsOfSymfony <http://friendsofsymfony.github.com/>
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+namespace FOS\OAuthServerBundle\CouchDocument;
+
+use FOS\OAuthServerBundle\Model\RefreshToken as BaseRefreshToken;
+
+class RefreshToken extends BaseRefreshToken
+{
+}

CouchDocument/RefreshTokenManager.php

@@ -0,0 +1,18 @@
+<?php
+
+/*
+ * This file is part of the FOSOAuthServerBundle package.
+ *
+ * (c) FriendsOfSymfony <http://friendsofsymfony.github.com/>
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+namespace FOS\OAuthServerBundle\CouchDocument;
+
+use FOS\OAuthServerBundle\Model\RefreshTokenManagerInterface;
+
+class RefreshTokenManager extends TokenManager implements RefreshTokenManagerInterface
+{
+}

CouchDocument/TokenManager.php

@@ -0,0 +1,90 @@
+<?php
+
+/*
+ * This file is part of the FOSOAuthServerBundle package.
+ *
+ * (c) FriendsOfSymfony <http://friendsofsymfony.github.com/>
+ *
+ * For the full copyright and license information, please view the LICENSE
+ * file that was distributed with this source code.
+ */
+
+namespace FOS\OAuthServerBundle\CouchDocument;
+
+use Doctrine\ODM\CouchDB\DocumentManager;
+use Doctrine\ODM\CouchDB\DocumentRepository;
+use FOS\OAuthServerBundle\Model\TokenInterface;
+use FOS\OAuthServerBundle\Model\TokenManager as BaseTokenManager;
+
+class TokenManager extends BaseTokenManager
+{
+    /**
+     * @var DocumentManager
+     */
+    protected $dm;
+
+    /**
+     * @var DocumentRepository
+     */
+    protected $repository;
+
+    /**
+     * @var string
+     */
+    protected $class;
+
+    public function __construct(DocumentManager $dm, $class)
+    {
+        $this->dm = $dm;
+        $this->repository = $dm->getRepository($class);
+        $this->class = $class;
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function getClass()
+    {
+        return $this->class;
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function findTokenBy(array $criteria)
+    {
+        return $this->repository->findOneBy($criteria);
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function updateToken(TokenInterface $token)
+    {
+        $this->dm->persist($token);
+        $this->dm->flush();
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function deleteToken(TokenInterface $token)
+    {
+        $this->dm->remove($token);
+        $this->dm->flush();
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function deleteExpired()
+    {
+        $result = $this->dm->createQuery("symfony", "accesstoken")
+            ->remove()
+            ->field('expiresAt')->lt(time())
+            ->getQuery(array('safe' => true))
+            ->execute();
+
+        return $result['n'];
+    }
+}

DependencyInjection/Configuration.php

@@ -30,7 +30,7 @@ public function getConfigTreeBuilder()
         $treeBuilder = new TreeBuilder();
         $rootNode = $treeBuilder->root('fos_oauth_server');
 
-        $supportedDrivers = array('orm', 'mongodb', 'propel');
+        $supportedDrivers = array('orm', 'mongodb', 'propel', 'couchdb');
 
         $rootNode
             ->children()