improve plugin store

app/Models/PluginStore.php

@@ -5,20 +5,35 @@ namespace App\Models;
 use Illuminate\Contracts\Support\Htmlable;
 use Illuminate\Database\Eloquent\Model;
 use Illuminate\Support\Facades\Http;
+use Illuminate\Support\Facades\Route;
 use Illuminate\Support\HtmlString;
+use Nexus\Database\NexusDB;
 use Sushi\Sushi;
+use Nexus\Plugin\Plugin;
 
 class PluginStore extends Model
 {
     use Sushi;
 
+    protected $casts = [
+        'title' => 'array',
+        'description' => 'array',
+    ];
+
     const PLUGIN_LIST_API = "https://nppl.nexusphp.workers.dev";
     const BLOG_POST_INFO_API = "https://nexusphp.org/wp-json/wp/v2/posts/%d";
     const BLOG_POST_URL = "https://nexusphp.org/?p=%d";
 
+    private static array|null $rows =null;
+
     public function getRows()
     {
-        return Http::get(self::PLUGIN_LIST_API)->json();
+        $list = self::listAll(true);
+        $enabled = Plugin::listEnabled();
+        foreach ($list as &$row) {
+            $row['installed_version'] = $enabled[$row['plugin_id']] ?? '';
+        }
+        return $list;
     }
 
     public function getBlogPostUrl(): string
@@ -30,7 +45,7 @@ class PluginStore extends Model
     {
         $url = $this->getBlogPostInfoUrl($this->post_id);
         $logPrefix = sprintf("post_id: %s, url: %s", $this->post_id, $url);
-        $defaultContent = "无法获取详细信息 ...";
+        $defaultContent = "Fail to get content ...";
         try {
             $result = Http::get($url)->json();
             do_log("$logPrefix, result: " . json_encode($result));
@@ -50,8 +65,69 @@ class PluginStore extends Model
         return sprintf(self::BLOG_POST_INFO_API, $postId);
     }
 
+    public function hasNewVersion(): bool
+    {
+        return $this->installed_version
+            && version_compare($this->version, $this->installed_version, '>');
+    }
+
     public static function getInfo(string $id)
     {
         return Http::get(self::PLUGIN_LIST_API . "/plugin/$id")->json();
     }
+
+    public static function listAll($withoutCache = false)
+    {
+        $log = "listAll, withoutCache: $withoutCache";
+        $cacheKey = "nexus_plugin_store_all";
+        $cacheTime = 86400*100;
+        if (is_null(self::$rows)) {
+            $log .= ", is_null";
+            if ($withoutCache) {
+                $log .= ", WITHOUT_CACHE";
+                self::$rows = self::listAllFromRemote();
+                NexusDB::cache_put($cacheKey, self::$rows, $cacheTime);
+            } else {
+                $log .= ", WITH_CACHE";
+                self::$rows = NexusDB::remember($cacheKey, $cacheTime, function () {
+                    return self::listAllFromRemote();
+                });
+            }
+        } else {
+            $log .= ", not_null";
+        }
+        do_log($log, 'debug');
+        return self::$rows;
+    }
+
+    private static function listAllFromRemote()
+    {
+        $list = Http::get(self::PLUGIN_LIST_API)->json();
+        foreach ($list as &$row) {
+            foreach ($row as $key => $value) {
+                if (is_array($value)) {
+                    $row[$key] = json_encode($value);
+                }
+            }
+        }
+        return $list;
+    }
+
+    public static function getHasNewVersionCount(): int
+    {
+        $currentRouteName = Route::currentRouteName();
+        $withoutCacheRouteName = ['filament.admin.resources.system.plugin-stores.index', 'filament.admin.pages.dashboard'];
+        $list = self::listAll(in_array($currentRouteName, $withoutCacheRouteName));
+        $enabled = Plugin::listEnabled();
+        $count = 0;
+        foreach ($list as $row) {
+            $installedVersion = $enabled[$row['plugin_id']] ?? '';
+            if ($installedVersion && version_compare($installedVersion, $row['version'], '<=')) {
+                $count++;
+            }
+        }
+        return $count;
+    }
+
+
 }