Almost working. csv last record is not written properly

app/app.go

@@ -71,6 +71,8 @@ func ProcessFeed(feed FeedCfg, scheduler *Scheduler, dbDir string, tgram telegra
 		return
 	}
 
+	scheduler.Good(feed.Name)
+
 	filteredEntries, err := db.Filter(entries)
 	if err != nil {
 		log.Error("failed to filter entries", "feed", feed.Name, "error", err)

app/db.go

@@ -2,10 +2,14 @@ package app
 
 import (
 	"encoding/csv"
+	"errors"
 	"fmt"
 	"os"
 	"path"
+	"strings"
 	"time"
+
+	"go.balki.me/tss/log"
 )
 
 type Status string
@@ -37,8 +41,14 @@ type db struct {
 
 func NewDB(storageDir, feedName string) (DB, error) {
 	dbPath := path.Join(storageDir, fmt.Sprintf("%s.csv", feedName))
+	db := db{dbPath: dbPath}
+	db.seenLinks = map[string]struct{}{}
 	f, err := os.Open(dbPath)
 	if err != nil {
+		if errors.Is(err, os.ErrNotExist) {
+			log.Info("db file does not exist, will be created", "feed", feedName, "path", dbPath)
+			return &db, nil
+		}
 		return nil, err
 	}
 	defer f.Close()
@@ -47,8 +57,6 @@ func NewDB(storageDir, feedName string) (DB, error) {
 	if err != nil {
 		return nil, fmt.Errorf("failed to parse csv, path:%v, error:%w", dbPath, err)
 	}
-	db := db{dbPath: dbPath}
-	db.seenLinks = map[string]struct{}{}
 	for _, rec := range records {
 		var recStatus Status = Status(rec[2])
 		if recStatus == Sent || recStatus == Filtered {
@@ -73,7 +81,10 @@ func (d *db) Save(records []Record) error {
 	if err != nil {
 		return err
 	}
-	defer f.Close()
+	defer func() {
+		f.Sync()
+		f.Close()
+	}()
 	csvw := csv.NewWriter(f)
 	if len(d.seenLinks) == 0 { //New file, write header
 		csvw.Write([]string{
@@ -90,7 +101,7 @@ func (d *db) Save(records []Record) error {
 			r.FeedEntry.Link,
 			string(r.Status),
 			"-",
-			r.FeedEntry.Content,
+			strings.ReplaceAll(r.FeedEntry.Content, "\n", " "),
 		})
 	}
 	return nil

app/schedule.go

@@ -3,11 +3,11 @@ package app
 import (
 	"errors"
 	"fmt"
-	"log"
 	"os"
 	"time"
 
 	"github.com/robfig/cron/v3"
+	"go.balki.me/tss/log"
 	"gopkg.in/yaml.v3"
 )
 
@@ -28,7 +28,7 @@ func NewScheduler(filePath string) (*Scheduler, error) {
 			return nil, fmt.Errorf("path:%v does not exist and unable to create: err: %w", filePath, err)
 		}
 		f.Close()
-		log.Printf("file: %v does not exist. Will be created\n", filePath)
+		log.Info("scheduler file does not exist, will be created", "path", filePath)
 	} else {
 		err = yaml.Unmarshal(data, &s.lastSuccessTime)
 		if err != nil {

telegram/telegram.go

@@ -26,13 +26,14 @@ type telegramSender struct {
 }
 
 func (ts *telegramSender) SendLink(link string, channel string, rhash string) error {
-
 	msg := struct {
-		ChatID string `json:"chat_id"`
-		Text   string `json:"text"`
+		ChatID    string `json:"chat_id"`
+		Text      string `json:"text"`
+		ParseMode string `json:"parse_mode"`
 	}{
-		ChatID: channel,
-		Text:   fmt.Sprintf(`<a href="%s">➢</a> <a href="%s">Link</a>`, genIVLink(link, rhash), link),
+		ChatID:    channel,
+		Text:      fmt.Sprintf(`<a href="%s">➢</a> <a href="%s">Link</a>`, genIVLink(link, rhash), link),
+		ParseMode: "HTML",
 	}
 	data, err := json.Marshal(msg)
 

tss.yml

@@ -0,0 +1 @@
+w.tmp/tss.yaml