[project @ Add getExpired to stores]

1 files changed, 17 insertions, 1 deletions

diff --git a/Auth/OpenID/SQLStore.php b/Auth/OpenID/SQLStore.php
index 2f775a1..5829f18 100644
--- a/Auth/OpenID/SQLStore.php
+++ b/Auth/OpenID/SQLStore.php
@@ -220,6 +220,7 @@ class Auth_OpenID_SQLStore extends Auth_OpenID_OpenIDStore {
                                    'get_assoc',
                                    'get_assocs',
                                    'remove_assoc',
+                                   'get_expired',
                                    );
 
         foreach ($required_sql_keys as $key) {
@@ -250,7 +251,8 @@ class Auth_OpenID_SQLStore extends Auth_OpenID_OpenIDStore {
                                                     'set_assoc',
                                                     'get_assoc',
                                                     'get_assocs',
-                                                    'remove_assoc')
+                                                    'remove_assoc',
+                                                    'get_expired')
                                     )
                               );
 
@@ -392,6 +394,20 @@ class Auth_OpenID_SQLStore extends Auth_OpenID_OpenIDStore {
         return true;
     }
 
+    function getExpired()
+    {
+        $sql = $this->sql['get_expired'];
+        $result = $this->connection->getAll($sql, array(time()));
+
+        $expired = array();
+
+        foreach ($result as $row) {
+            $expired[] = $row['server_url'];
+        }
+
+        return $expired;
+    }
+
     function getAssociation($server_url, $handle = null)
     {
         if ($handle !== null) {