添加redis驱动支持

config/purple.php

@@ -7,4 +7,13 @@
  * Email: [email protected]
  */
 
-return [];
+return [
+    // 路由前缀
+    'prefix'  => '_purple',
+
+    // 表名/redis key名
+    'table'   => 'purple',
+
+    // 存储方式
+    'storage' => 'mysql'
+];

src/Collections/AbstractCollection.php → src/Collectors/AbstractCollection.php

@@ -7,7 +7,7 @@
  * Email: [email protected]
  */
 
-namespace Purple\Collections;
+namespace Purple\Collectors;
 
 
 use Illuminate\Foundation\Application;

src/Collections/CollectionInterface.php → src/Collectors/CollectionInterface.php

@@ -8,7 +8,7 @@
  * Email: [email protected]
  */
 
-namespace Purple\Collections;
+namespace Purple\Collectors;
 
 use Illuminate\Foundation\Application;
 use Symfony\Component\HttpFoundation\Response;

src/Collections/Dashboard.php → src/Collectors/Dashboard.php

@@ -6,7 +6,7 @@
  * Time: 11:48 PM
  */
 
-namespace Purple\Collections;
+namespace Purple\Collectors;
 
 
 use Illuminate\Foundation\Application;

src/Collections/Database.php → src/Collectors/Database.php

@@ -6,7 +6,7 @@
  * Time: 8:35 PM
  */
 
-namespace Purple\Collections;
+namespace Purple\Collectors;
 
 
 use Illuminate\Foundation\Application;

src/Collections/Event.php → src/Collectors/Event.php

@@ -6,7 +6,7 @@
  * Time: 6:58 PM
  */
 
-namespace Purple\Collections;
+namespace Purple\Collectors;
 
 
 use Illuminate\Foundation\Application;

src/Collections/Info.php → src/Collectors/Info.php

@@ -6,7 +6,7 @@
  * Time: 11:44 PM
  */
 
-namespace Purple\Collections;
+namespace Purple\Collectors;
 
 use Illuminate\Foundation\Application;
 use Symfony\Component\HttpFoundation\Response;

src/Collections/Request.php → src/Collectors/Request.php

@@ -7,7 +7,7 @@
  * Email: [email protected]
  */
 
-namespace Purple\Collections;
+namespace Purple\Collectors;
 
 
 use Illuminate\Foundation\Application;

src/Collections/Route.php → src/Collectors/Route.php

@@ -6,7 +6,7 @@
  * Time: 9:57 PM
  */
 
-namespace Purple\Collections;
+namespace Purple\Collectors;
 
 
 use Illuminate\Foundation\Application;

src/Controller/PurpleController.php

@@ -11,7 +11,7 @@
 
 use App\Http\Controllers\Controller;
 use Illuminate\Foundation\Application;
-use Purple\Collections\CollectionInterface;
+use Purple\Collectors\CollectionInterface;
 
 class PurpleController extends Controller
 {

src/PurpleHook.php

@@ -3,13 +3,13 @@
 namespace Purple;
 
 use Illuminate\Foundation\Application;
-use Purple\Collections\CollectionInterface;
-use Purple\Collections\Dashboard;
-use Purple\Collections\Database;
-use Purple\Collections\Event;
-use Purple\Collections\Info;
-use Purple\Collections\Request;
-use Purple\Collections\Route;
+use Purple\Collectors\CollectionInterface;
+use Purple\Collectors\Dashboard;
+use Purple\Collectors\Database;
+use Purple\Collectors\Event;
+use Purple\Collectors\Info;
+use Purple\Collectors\Request;
+use Purple\Collectors\Route;
 use Purple\Exceptions\InvalidCollectionException;
 use Symfony\Component\HttpFoundation\Response;
 
@@ -169,7 +169,7 @@ protected function isAjax()
     protected function endHook()
     {
         /**
-         * @var $collection \Purple\Collections\CollectionInterface
+         * @var $collection \Purple\Collectors\CollectionInterface
          */
         $request        = $this->app['purple.request'];
         $collectionData = [];

src/PurpleServiceProvider.php

@@ -3,9 +3,8 @@
 namespace Purple;
 
 use Illuminate\Support\ServiceProvider;
-use Purple\Adapter\MySQL;
 use Purple\Request\Request;
-use Purple\Storage\Storage;
+use Purple\Storage\RedisStorage;
 
 class PurpleServiceProvider extends ServiceProvider
 {
@@ -35,17 +34,16 @@ public function boot()
     public function register()
     {
         $app = $this->app;
-        $app->singleton('purple.adapter', MySQL::class);
 
-        $app->singleton('purple.storage', function ($app) {
-            return new Storage($app['purple.adapter']);
+        $app->singleton('purple.storage', function($app) {
+            $storage = new RedisStorage();
+            $storage->setApplication($app);
+            return $storage;
         });
         $app->singleton('purple.hook', PurpleHook::class);
 
         $app->singleton('purple.request', Request::class);
-        /**
-         * @var $purple \Purple\PurpleHook
-         */
+        /** @var $purple \Purple\PurpleHook */
         $purple = $app->make('purple.hook');
         $purple->setPrefix($app['config']->get('purple.prefix', '_purple'));
         $purple->registerHook();
@@ -64,17 +62,17 @@ protected function registerCommand()
      */
     protected function registerRouter()
     {
-        /**
-         * @var $config \Illuminate\Config\Repository
-         */
+        /** @var $config \Illuminate\Config\Repository */
         $config = $this->app['config'];
         $prefix = $config->get('purple.prefix', '_purple');
 
-        /**
-         * @var $router \Illuminate\Routing\Router
-         */
+        /** @var $router \Illuminate\Routing\Router */
         $router = $this->app['router'];
-        $router->get('/{id}/{key?}', ['prefix' => $prefix, 'as' => 'purple.index', 'uses' => 'Purple\Controller\PurpleController@index']);
+        $router->get('/{id}/{key?}', [
+            'prefix' => $prefix,
+            'as'     => 'purple.index',
+            'uses'   => 'Purple\Controller\PurpleController@index'
+        ]);
     }
 
     /**
@@ -94,10 +92,6 @@ protected function publishAssetsFiles()
             __DIR__ . '/../migrations' => database_path('migrations')
         ], 'purple.sql');
 
-//         $this->publishes([
-//             __DIR__ . '/Resources' => resource_path('views/purple')
-//         ], 'purple.view');
-
     }
 
 }

src/Request/Request.php

@@ -30,6 +30,11 @@ public function setUuid($uuid)
     {
         $this->uuid = $uuid;
     }
+
+    public function getUuid()
+    {
+        return $this->uuid;
+    }
 
     /**
      * @param mixed $time

src/Adapter/MySQL.php → src/Storage/MySQLStorage.php

@@ -3,38 +3,36 @@
  * Created by PhpStorm.
  * User: Krasen
  * Date: 16/5/17
- * Time: 17:23
+ * Time: 16:32
  * Email: [email protected]
  */
 
-namespace Purple\Adapter;
+namespace Purple\Storage;
 
 use DB;
-use Illuminate\Database\Eloquent\Model;
 use Purple\Request\Request;
+use Illuminate\Database\Eloquent\Model;
+
 
-class MySQL extends Model implements AdapterInterface
+class MySQLStorage extends Model implements StorageInterface
 {
+    use StorageTrait;
+
     protected $table = 'purple';
 
     protected $fillable = ['uuid', 'uri', 'content', 'time'];
 
-    public function store(Request $request)
+    public function retrieve($id)
     {
-        try {
-            self::create($request->toArray());
-        }catch (\Exception $e) {
-            throw new \Exception($e->getMessage());
-        }
-
+        return unserialize(DB::table('purple')->where('uuid', $id)->value('content'));
     }
 
-    public function retrieve($id)
+    public function store(Request $request)
     {
-        return DB::table('purple')->where('uuid', $id)->first();
+        self::create($request->toArray());
     }
 
-    public function clear()
+    public function purge()
     {
         DB::table('purple')->truncate();
     }

src/Storage/RedisStorage.php

@@ -0,0 +1,53 @@
+<?php
+/**
+ * Created by PhpStorm.
+ * User: krasen
+ * Date: 6/5/2016
+ * Time: 3:28 PM
+ */
+
+namespace Purple\Storage;
+
+use Cache;
+use Purple\Request\Request;
+
+class RedisStorage implements StorageInterface
+{
+    use StorageTrait;
+
+    public function retrieve($id)
+    {
+        /**
+         * @var $config \Illuminate\Config\Repository
+         */
+        $config = $this->app['config'];
+        $table = $config->get('purple.table', 'purple');
+
+        $client = Cache::store('redis')->connection();
+        $values = unserialize($client->hget($table, $id));
+        return unserialize($values['content']);
+    }
+
+    public function store(Request $request)
+    {
+        /**
+         * @var $config \Illuminate\Config\Repository
+         */
+        $config = $this->app['config'];
+        $table = $config->get('purple.table', 'purple');
+
+        $client = Cache::store('redis')->connection();
+        $client->hset($table, $request->getUuid(), serialize($request->toArray()));
+    }
+
+    public function purge()
+    {
+        /**
+         * @var $config \Illuminate\Config\Repository
+         */
+        $config = $this->app['config'];
+        $table = $config->get('purple.table', 'purple');
+
+        Cache::store('redis')->del($table);
+    }
+}