From 031d5f545dee0d1e4f3172a5aa48b4d7b2d4bce3 Mon Sep 17 00:00:00 2001 From: bel Date: Thu, 24 Apr 2025 22:31:28 -0600 Subject: [PATCH] what tables... --- src/cmd/config.go | 2 +- src/cmd/cron/main.go | 31 +++++++++++++++++++++++++++++++ 2 files changed, 32 insertions(+), 1 deletion(-) diff --git a/src/cmd/config.go b/src/cmd/config.go index 8e78a05..1e99165 100644 --- a/src/cmd/config.go +++ b/src/cmd/config.go @@ -6,7 +6,7 @@ import ( ) func Config(ctx context.Context) (context.Context, error) { - ctx, err := db.Inject(ctx) + ctx, err := db.Inject(ctx, "/tmp/f.db") if err != nil { return ctx, err } diff --git a/src/cmd/cron/main.go b/src/cmd/cron/main.go index 15906e4..f6d81ca 100644 --- a/src/cmd/cron/main.go +++ b/src/cmd/cron/main.go @@ -3,8 +3,39 @@ package cron import ( "context" "io" + "show-rss/src/db" + "time" ) func Main(ctx context.Context) error { + c := time.NewTicker(time.Minute) + defer c.Stop() + for { + if err := one(ctx); err != nil { + return err + } + + select { + case <-ctx.Done(): + case <-c.C: + } + } + return ctx.Err() +} + +func one(ctx context.Context) error { + if err := initDB(ctx); err != nil { + return err + } return io.EOF } + +func initDB(ctx context.Context) error { + return db.Exec(ctx, ` + CREATE TABLE IF NOT EXISTS feeds ( + id SERIAL + ); + ALTER TABLE feeds ADD COLUMN IF NOT EXISTS b TEXT; + ALTER TABLE feeds ADD COLUMN IF NOT EXISTS b TEXT; + `) +}