add feeds

Author: root

Note.md

@@ -3,16 +3,11 @@
 ## 资源
 
 - 增加 strorage
-- 资源增加拷贝功能，即基于一个资源拷贝为新资源
 
 ### 服务器
 
 - 服务器特殊环境配置：Docker 仓库地址、Docker 加速地址、代理地址
-- 环境预装机制：在线一键脚本或由 AppOS 推送到服务器后执行
 
-## 隧道
-
-- 隧道链接到服务器的 detail page
 
 ## Workflow
 
@@ -146,16 +141,11 @@ Prerequisites
 ports tab 不稳定，经常打开显示  somethins wrong
 
 
-
 addons 的 netdata restart 报错
-Server Terminal  退出连接后再重连，就会失败
-
-crontab list 保存不住
 
 去掉所有与 docker.sock 的强依赖与硬编码
 
-平台metrics 的读取查询与对服务器 metrics 的查询，是不是后端代码应该分离
+rss 文章总数量，每个 source 文章上限问题，清理机制
 
-所以 appos 容器內其實完全可以通過 uname -r、/proc/meminfo 等獲取宿主機的內核版本、內存大小、CPU 信息，不需要任何特殊權限。只有 OS 發行版（os-release）是個例外
 
 

backend/cmd/appos/bootstrap/cron.go

@@ -6,6 +6,7 @@ import (
 	"time"
 
 	"github.com/hibiken/asynq"
+	"github.com/websoft9/appos/backend/domain/feeds"
 	"github.com/websoft9/appos/backend/domain/monitor"
 	swcatalog "github.com/websoft9/appos/backend/domain/software/catalog"
 	swinventory "github.com/websoft9/appos/backend/domain/software/inventory"
@@ -23,6 +24,7 @@ const monitorFactsPullCronJobID = "monitor_facts_pull"
 const monitorRuntimeSnapshotPullCronJobID = "monitor_runtime_snapshot_pull"
 const monitorCredentialCronJobID = "monitor_credential_checks"
 const monitorAppHealthCronJobID = "monitor_app_health_checks"
+const feedsPollCronJobID = "feeds_poll"
 
 func registerCronHooks(app *pocketbase.PocketBase, asynqClient *asynq.Client) {
 	app.Cron().MustAdd(
@@ -35,6 +37,16 @@ func registerCronHooks(app *pocketbase.PocketBase, asynqClient *asynq.Client) {
 		}),
 	)
 
+	app.Cron().MustAdd(
+		feedsPollCronJobID,
+		"*/5 * * * *",
+		cronutil.Wrap(app, feedsPollCronJobID, func() {
+			if _, err := feeds.PollDueSources(nil, app, nil, time.Now().UTC()); err != nil {
+				panic(err)
+			}
+		}),
+	)
+
 	if asynqClient == nil {
 		return
 	}

backend/cmd/appos/bootstrap/cron_test.go

@@ -7,6 +7,7 @@ import (
 	"testing"
 	"time"
 
+	"github.com/pocketbase/pocketbase"
 	swcatalog "github.com/websoft9/appos/backend/domain/software/catalog"
 )
 
@@ -96,3 +97,16 @@ func TestShouldRunMonitorInterval(t *testing.T) {
 		t.Fatal("expected 7-minute interval not to run at minute 15")
 	}
 }
+
+func TestRegisterCronHooksRegistersFeedsPollJob(t *testing.T) {
+	app := pocketbase.New()
+	registerCronHooks(app, nil)
+
+	for _, job := range app.Cron().Jobs() {
+		if job.Id() == feedsPollCronJobID {
+			return
+		}
+	}
+
+	t.Fatalf("expected cron job %q to be registered", feedsPollCronJobID)
+}