From 1b46c7810b6c961fb67cb3403590c61f3b5c8e28 Mon Sep 17 00:00:00 2001 From: Nicola Zangrandi Date: Fri, 28 Feb 2025 11:37:07 +0100 Subject: [PATCH] feat(feeds): add initial implementation of the feed reader --- feeds/handler.go | 247 +++++++++++++ feeds/model.go | 55 +++ feeds/service.go | 346 ++++++++++++++++++ frontend/playwright.parallel.config.ts | 154 ++++++++ frontend/src/lib/components/Navbar.svelte | 78 ++++ frontend/src/lib/feeds.ts | 265 ++++++++++++++ frontend/src/lib/types.ts | 30 ++ frontend/src/routes/feeds/+page.svelte | 251 +++++++++++-- frontend/src/routes/feeds/+page.ts | 2 + frontend/src/routes/feeds/[id]/+page.svelte | 273 ++++++++++++++ frontend/src/routes/feeds/[id]/+page.ts | 10 + .../routes/feeds/entries/[id]/+page.svelte | 164 +++++++++ .../src/routes/feeds/entries/[id]/+page.ts | 10 + frontend/src/routes/feeds/list/+page.svelte | 282 ++++++++++++++ frontend/src/routes/feeds/list/+page.ts | 2 + .../src/routes/readlist/[id]/+page.svelte | 7 +- frontend/tests/interface.test.ts | 24 ++ frontend/tests/readlist.test.ts | 57 +++ go.mod | 6 + go.sum | 32 ++ main.go | 62 +++- readlist/model.go | 16 +- readlist/routes.go | 2 +- readlist/service.go | 2 +- scripts/pre-commit.sh | 10 +- scripts/run-parallel-tests.sh | 118 ++++++ 26 files changed, 2444 insertions(+), 61 deletions(-) create mode 100644 feeds/handler.go create mode 100644 feeds/model.go create mode 100644 feeds/service.go create mode 100644 frontend/playwright.parallel.config.ts create mode 100644 frontend/src/lib/components/Navbar.svelte create mode 100644 frontend/src/lib/feeds.ts create mode 100644 frontend/src/routes/feeds/+page.ts create mode 100644 frontend/src/routes/feeds/[id]/+page.svelte create mode 100644 frontend/src/routes/feeds/[id]/+page.ts create mode 100644 frontend/src/routes/feeds/entries/[id]/+page.svelte create mode 100644 frontend/src/routes/feeds/entries/[id]/+page.ts create mode 100644 frontend/src/routes/feeds/list/+page.svelte create mode 100644 frontend/src/routes/feeds/list/+page.ts create mode 100644 frontend/tests/interface.test.ts create mode 100644 frontend/tests/readlist.test.ts create mode 100755 scripts/run-parallel-tests.sh diff --git a/feeds/handler.go b/feeds/handler.go new file mode 100644 index 0000000..c30d46f --- /dev/null +++ b/feeds/handler.go @@ -0,0 +1,247 @@ +package feeds + +import ( + "fmt" + "net/http" + "strconv" + + "github.com/gin-gonic/gin" +) + +// Handler handles HTTP requests for feeds +type Handler struct { + service *Service +} + +// NewHandler creates a new feed handler +func NewHandler(service *Service) *Handler { + return &Handler{service: service} +} + +// RegisterRoutes registers the feed routes with the given router group +func (h *Handler) RegisterRoutes(router *gin.RouterGroup) { + feeds := router.Group("/feeds") + { + feeds.GET("", h.handleListFeeds) + feeds.POST("", h.handleAddFeed) + feeds.GET("/:id", h.handleGetFeed) + feeds.DELETE("/:id", h.handleDeleteFeed) + feeds.POST("/:id/refresh", h.handleRefreshFeed) + feeds.POST("/refresh", h.handleRefreshAllFeeds) + feeds.POST("/import/opml", h.handleImportOPML) + + // Entry routes + feeds.GET("/entries", h.handleListEntries) + feeds.GET("/entries/:id", h.handleGetEntry) + feeds.POST("/entries/:id/read", h.handleMarkEntryAsRead) + feeds.POST("/entries/read-all", h.handleMarkAllAsRead) + feeds.POST("/entries/:id/full-content", h.handleFetchFullContent) + } + + // Test endpoint + router.POST("/test/feeds/reset", h.handleReset) +} + +// handleListFeeds handles GET /api/feeds +func (h *Handler) handleListFeeds(c *gin.Context) { + feeds, err := h.service.GetFeeds() + if err != nil { + c.JSON(http.StatusInternalServerError, gin.H{"error": err.Error()}) + return + } + c.JSON(http.StatusOK, feeds) +} + +// handleAddFeed handles POST /api/feeds +func (h *Handler) handleAddFeed(c *gin.Context) { + var req struct { + URL string `json:"url" binding:"required"` + } + if err := c.ShouldBindJSON(&req); err != nil { + c.JSON(http.StatusBadRequest, gin.H{"error": err.Error()}) + return + } + + feed, err := h.service.AddFeed(req.URL) + if err != nil { + c.JSON(http.StatusInternalServerError, gin.H{"error": err.Error()}) + return + } + + c.JSON(http.StatusOK, feed) +} + +// handleGetFeed handles GET /api/feeds/:id +func (h *Handler) handleGetFeed(c *gin.Context) { + id := c.Param("id") + feed, err := h.service.GetFeed(id) + if err != nil { + c.JSON(http.StatusNotFound, gin.H{"error": "Feed not found"}) + return + } + c.JSON(http.StatusOK, feed) +} + +// handleDeleteFeed handles DELETE /api/feeds/:id +func (h *Handler) handleDeleteFeed(c *gin.Context) { + id := c.Param("id") + if err := h.service.DeleteFeed(id); err != nil { + c.JSON(http.StatusInternalServerError, gin.H{"error": err.Error()}) + return + } + c.Status(http.StatusOK) +} + +// handleRefreshFeed handles POST /api/feeds/:id/refresh +func (h *Handler) handleRefreshFeed(c *gin.Context) { + id := c.Param("id") + if err := h.service.RefreshFeed(id); err != nil { + c.JSON(http.StatusInternalServerError, gin.H{"error": err.Error()}) + return + } + c.Status(http.StatusOK) +} + +// handleRefreshAllFeeds handles POST /api/feeds/refresh +func (h *Handler) handleRefreshAllFeeds(c *gin.Context) { + if err := h.service.RefreshAllFeeds(); err != nil { + c.JSON(http.StatusInternalServerError, gin.H{"error": err.Error()}) + return + } + c.Status(http.StatusOK) +} + +// handleImportOPML handles POST /api/feeds/import +func (h *Handler) handleImportOPML(c *gin.Context) { + file, _, err := c.Request.FormFile("file") + if err != nil { + // Check if URL is provided instead + url := c.PostForm("url") + if url != "" { + resp, err := http.Get(url) + if err != nil { + c.JSON(http.StatusBadRequest, gin.H{"error": fmt.Sprintf("Failed to download OPML: %v", err)}) + return + } + defer func() { + if err := resp.Body.Close(); err != nil { + fmt.Printf("Error closing response body: %v\n", err) + } + }() + + feeds, err := h.service.ImportOPML(resp.Body) + if err != nil { + c.JSON(http.StatusInternalServerError, gin.H{"error": err.Error()}) + return + } + c.JSON(http.StatusOK, gin.H{"imported": len(feeds)}) + return + } + + c.JSON(http.StatusBadRequest, gin.H{"error": "No file or URL provided"}) + return + } + defer func() { + if err := file.Close(); err != nil { + fmt.Printf("Error closing file: %v\n", err) + } + }() + + feeds, err := h.service.ImportOPML(file) + if err != nil { + c.JSON(http.StatusInternalServerError, gin.H{"error": err.Error()}) + return + } + + c.JSON(http.StatusOK, gin.H{"imported": len(feeds)}) +} + +// handleListEntries handles GET /api/feeds/entries +func (h *Handler) handleListEntries(c *gin.Context) { + feedID := c.Query("feedId") + unreadOnly, _ := strconv.ParseBool(c.Query("unreadOnly")) + + entries, err := h.service.GetEntries(feedID, unreadOnly) + if err != nil { + c.JSON(http.StatusInternalServerError, gin.H{"error": err.Error()}) + return + } + + c.JSON(http.StatusOK, entries) +} + +// handleGetEntry handles GET /api/feeds/entries/:id +func (h *Handler) handleGetEntry(c *gin.Context) { + id := c.Param("id") + entry, err := h.service.GetEntry(id) + if err != nil { + c.JSON(http.StatusNotFound, gin.H{"error": "Entry not found"}) + return + } + c.JSON(http.StatusOK, entry) +} + +// handleMarkEntryAsRead handles POST /api/feeds/entries/:id/read +func (h *Handler) handleMarkEntryAsRead(c *gin.Context) { + id := c.Param("id") + if err := h.service.MarkEntryAsRead(id); err != nil { + c.JSON(http.StatusInternalServerError, gin.H{"error": err.Error()}) + return + } + c.Status(http.StatusOK) +} + +// handleFetchFullContent handles POST /api/feeds/entries/:id/full-content +func (h *Handler) handleFetchFullContent(c *gin.Context) { + id := c.Param("id") + if err := h.service.FetchFullContent(id); err != nil { + c.JSON(http.StatusInternalServerError, gin.H{"error": err.Error()}) + return + } + + // Get the updated entry + entry, err := h.service.GetEntry(id) + if err != nil { + c.JSON(http.StatusInternalServerError, gin.H{"error": err.Error()}) + return + } + + c.JSON(http.StatusOK, entry) +} + +// handleReset handles POST /api/test/feeds/reset +func (h *Handler) handleReset(c *gin.Context) { + // Delete all entries + if err := h.service.db.Exec("DELETE FROM entries").Error; err != nil { + c.JSON(http.StatusInternalServerError, gin.H{"error": err.Error()}) + return + } + + // Delete all feeds + if err := h.service.db.Exec("DELETE FROM feeds").Error; err != nil { + c.JSON(http.StatusInternalServerError, gin.H{"error": err.Error()}) + return + } + + c.Status(http.StatusOK) +} + +func (h *Handler) handleMarkAllAsRead(c *gin.Context) { + feedID := c.Query("feedId") + + var err error + if feedID != "" { + // Mark all entries as read for a specific feed + err = h.service.MarkAllEntriesAsRead(feedID) + } else { + // Mark all entries as read across all feeds + err = h.service.MarkAllEntriesAsRead("") + } + + if err != nil { + c.JSON(http.StatusInternalServerError, gin.H{"error": err.Error()}) + return + } + + c.JSON(http.StatusOK, gin.H{"success": true}) +} diff --git a/feeds/model.go b/feeds/model.go new file mode 100644 index 0000000..cc3ebef --- /dev/null +++ b/feeds/model.go @@ -0,0 +1,55 @@ +package feeds + +import ( + "time" + + "github.com/google/uuid" + "gorm.io/gorm" +) + +// Feed represents an RSS/Atom feed +type Feed struct { + ID string `json:"id" gorm:"primaryKey"` + Title string `json:"title"` + URL string `json:"url" gorm:"uniqueIndex"` + Description string `json:"description"` + SiteURL string `json:"siteUrl"` + ImageURL string `json:"imageUrl"` + LastFetched time.Time `json:"lastFetched"` + CreatedAt time.Time `json:"createdAt"` + UpdatedAt time.Time `json:"updatedAt"` + Entries []Entry `json:"entries,omitempty" gorm:"foreignKey:FeedID"` +} + +// Entry represents a single item/entry in a feed +type Entry struct { + ID string `json:"id" gorm:"primaryKey"` + FeedID string `json:"feedId" gorm:"index"` + Title string `json:"title"` + URL string `json:"url" gorm:"uniqueIndex"` + Content string `json:"content"` + Summary string `json:"summary"` + Author string `json:"author"` + Published time.Time `json:"published"` + Updated time.Time `json:"updated"` + ReadAt *time.Time `json:"readAt"` + FullContent string `json:"fullContent"` + CreatedAt time.Time `json:"createdAt"` + UpdatedAt time.Time `json:"updatedAt"` +} + +// BeforeCreate is a GORM hook that generates a UUID for new feeds +func (f *Feed) BeforeCreate(tx *gorm.DB) error { + if f.ID == "" { + f.ID = uuid.New().String() + } + return nil +} + +// BeforeCreate is a GORM hook that generates a UUID for new entries +func (e *Entry) BeforeCreate(tx *gorm.DB) error { + if e.ID == "" { + e.ID = uuid.New().String() + } + return nil +} diff --git a/feeds/service.go b/feeds/service.go new file mode 100644 index 0000000..8a2db61 --- /dev/null +++ b/feeds/service.go @@ -0,0 +1,346 @@ +package feeds + +import ( + "encoding/xml" + "fmt" + "io" + "log" + "time" + + "github.com/go-co-op/gocron" + "github.com/go-shiori/go-readability" + "github.com/mmcdole/gofeed" + "gorm.io/gorm" +) + +// Service handles feed operations +type Service struct { + db *gorm.DB + parser *gofeed.Parser + cron *gocron.Scheduler +} + +// NewService creates a new feed service +func NewService(db *gorm.DB) *Service { + s := &Service{ + db: db, + parser: gofeed.NewParser(), + cron: gocron.NewScheduler(time.UTC), + } + + // Start the scheduler + _, err := s.cron.Every(1).Hour().Do(s.RefreshAllFeeds) + if err != nil { + log.Printf("Error scheduling feed refresh: %v", err) + } + s.cron.StartAsync() + + return s +} + +// AddFeed adds a new feed +func (s *Service) AddFeed(url string) (*Feed, error) { + // Check if feed already exists + var existingFeed Feed + if result := s.db.Where("url = ?", url).First(&existingFeed); result.Error == nil { + return &existingFeed, nil + } + + // Fetch and parse the feed + feed, err := s.parser.ParseURL(url) + if err != nil { + return nil, fmt.Errorf("failed to parse feed: %w", err) + } + + // Create new feed + newFeed := Feed{ + Title: feed.Title, + URL: url, + Description: feed.Description, + SiteURL: feed.Link, + ImageURL: s.extractFeedImage(feed), + LastFetched: time.Now(), + CreatedAt: time.Now(), + UpdatedAt: time.Now(), + } + + // Save feed to database + if err := s.db.Create(&newFeed).Error; err != nil { + return nil, fmt.Errorf("failed to save feed: %w", err) + } + + // Process feed entries + s.processFeedEntries(&newFeed, feed) + + return &newFeed, nil +} + +// ImportOPML imports feeds from an OPML file +func (s *Service) ImportOPML(opmlContent io.Reader) ([]Feed, error) { + var opml OPML + if err := xml.NewDecoder(opmlContent).Decode(&opml); err != nil { + return nil, fmt.Errorf("failed to parse OPML: %w", err) + } + + var feeds []Feed + for _, outline := range opml.Body.Outlines { + if outline.XMLURL != "" { + feed, err := s.AddFeed(outline.XMLURL) + if err != nil { + continue // Skip feeds that fail to parse + } + feeds = append(feeds, *feed) + } + + // Process nested outlines + for _, nestedOutline := range outline.Outlines { + if nestedOutline.XMLURL != "" { + feed, err := s.AddFeed(nestedOutline.XMLURL) + if err != nil { + continue + } + feeds = append(feeds, *feed) + } + } + } + + return feeds, nil +} + +// GetFeeds returns all feeds +func (s *Service) GetFeeds() ([]Feed, error) { + var feeds []Feed + if err := s.db.Order("title").Find(&feeds).Error; err != nil { + return nil, err + } + return feeds, nil +} + +// GetFeed returns a feed by ID +func (s *Service) GetFeed(id string) (*Feed, error) { + var feed Feed + if err := s.db.First(&feed, "id = ?", id).Error; err != nil { + return nil, err + } + return &feed, nil +} + +// DeleteFeed deletes a feed by ID +func (s *Service) DeleteFeed(id string) error { + // Delete associated entries first + if err := s.db.Delete(&Entry{}, "feed_id = ?", id).Error; err != nil { + return err + } + + // Delete the feed + if err := s.db.Delete(&Feed{}, "id = ?", id).Error; err != nil { + return err + } + + return nil +} + +// RefreshFeed refreshes a single feed +func (s *Service) RefreshFeed(id string) error { + var feed Feed + if err := s.db.First(&feed, "id = ?", id).Error; err != nil { + return err + } + + // Fetch and parse the feed + parsedFeed, err := s.parser.ParseURL(feed.URL) + if err != nil { + return fmt.Errorf("failed to parse feed: %w", err) + } + + // Update feed metadata + feed.Title = parsedFeed.Title + feed.Description = parsedFeed.Description + feed.SiteURL = parsedFeed.Link + feed.ImageURL = s.extractFeedImage(parsedFeed) + feed.LastFetched = time.Now() + feed.UpdatedAt = time.Now() + + // Save updated feed + if err := s.db.Save(&feed).Error; err != nil { + return fmt.Errorf("failed to update feed: %w", err) + } + + // Process feed entries + s.processFeedEntries(&feed, parsedFeed) + + return nil +} + +// RefreshAllFeeds refreshes all feeds +func (s *Service) RefreshAllFeeds() error { + var feeds []Feed + if err := s.db.Find(&feeds).Error; err != nil { + return err + } + + for _, feed := range feeds { + // Ignore errors for individual feeds to continue with others + _ = s.RefreshFeed(feed.ID) + } + + return nil +} + +// GetEntries returns entries for all feeds or a specific feed +func (s *Service) GetEntries(feedID string, unreadOnly bool) ([]Entry, error) { + query := s.db.Order("published desc") + + if feedID != "" { + query = query.Where("feed_id = ?", feedID) + } + + if unreadOnly { + query = query.Where("read_at IS NULL") + } + + var entries []Entry + if err := query.Find(&entries).Error; err != nil { + return nil, err + } + + return entries, nil +} + +// GetEntry returns an entry by ID +func (s *Service) GetEntry(id string) (*Entry, error) { + var entry Entry + if err := s.db.First(&entry, "id = ?", id).Error; err != nil { + return nil, err + } + return &entry, nil +} + +// MarkEntryAsRead marks an entry as read +func (s *Service) MarkEntryAsRead(id string) error { + return s.db.Model(&Entry{}).Where("id = ?", id).Update("read_at", time.Now()).Error +} + +// MarkAllEntriesAsRead marks all entries as read, optionally filtered by feed ID +func (s *Service) MarkAllEntriesAsRead(feedID string) error { + query := s.db.Model(&Entry{}).Where("read_at IS NULL") + + if feedID != "" { + query = query.Where("feed_id = ?", feedID) + } + + return query.Update("read_at", time.Now()).Error +} + +// FetchFullContent fetches and parses the full content of an entry +func (s *Service) FetchFullContent(id string) error { + var entry Entry + if err := s.db.First(&entry, "id = ?", id).Error; err != nil { + return err + } + + // Skip if already has full content + if entry.FullContent != "" { + return nil + } + + // Fetch and parse the article + article, err := readability.FromURL(entry.URL, 30*time.Second) + if err != nil { + return fmt.Errorf("failed to fetch article: %w", err) + } + + // Update entry with full content + entry.FullContent = article.Content + entry.UpdatedAt = time.Now() + + return s.db.Save(&entry).Error +} + +// Helper function to process feed entries +func (s *Service) processFeedEntries(feed *Feed, parsedFeed *gofeed.Feed) { + for _, item := range parsedFeed.Items { + // Skip items without links + if item.Link == "" { + continue + } + + // Check if entry already exists + var existingEntry Entry + result := s.db.Where("url = ?", item.Link).First(&existingEntry) + + if result.Error == nil { + // Update existing entry if needed + if item.UpdatedParsed != nil && existingEntry.Updated.Before(*item.UpdatedParsed) { + existingEntry.Title = item.Title + existingEntry.Summary = item.Description + existingEntry.Content = item.Content + existingEntry.Updated = *item.UpdatedParsed + existingEntry.UpdatedAt = time.Now() + s.db.Save(&existingEntry) + } + continue + } + + // Create new entry + published := time.Now() + if item.PublishedParsed != nil { + published = *item.PublishedParsed + } + + updated := published + if item.UpdatedParsed != nil { + updated = *item.UpdatedParsed + } + + author := "" + if item.Author != nil { + author = item.Author.Name + } + + newEntry := Entry{ + FeedID: feed.ID, + Title: item.Title, + URL: item.Link, + Content: item.Content, + Summary: item.Description, + Author: author, + Published: published, + Updated: updated, + CreatedAt: time.Now(), + UpdatedAt: time.Now(), + } + + s.db.Create(&newEntry) + } +} + +// Helper function to extract feed image +func (s *Service) extractFeedImage(feed *gofeed.Feed) string { + if feed.Image != nil && feed.Image.URL != "" { + return feed.Image.URL + } + return "" +} + +// OPML represents an OPML file structure +type OPML struct { + XMLName xml.Name `xml:"opml"` + Version string `xml:"version,attr"` + Head struct { + Title string `xml:"title"` + } `xml:"head"` + Body struct { + Outlines []Outline `xml:"outline"` + } `xml:"body"` +} + +// Outline represents an OPML outline element +type Outline struct { + Text string `xml:"text,attr"` + Title string `xml:"title,attr"` + Type string `xml:"type,attr"` + XMLURL string `xml:"xmlUrl,attr"` + HTMLURL string `xml:"htmlUrl,attr"` + Outlines []Outline `xml:"outline"` +} diff --git a/frontend/playwright.parallel.config.ts b/frontend/playwright.parallel.config.ts new file mode 100644 index 0000000..3291db3 --- /dev/null +++ b/frontend/playwright.parallel.config.ts @@ -0,0 +1,154 @@ +/// +import type { PlaywrightTestConfig } from '@playwright/test'; +import { devices } from '@playwright/test'; + +/** + * Configuration for parallel testing with isolated environments + * Each test suite runs against its own backend instance + */ +const config: PlaywrightTestConfig = { + testDir: './tests', + fullyParallel: true, // Enable parallel execution + forbidOnly: !!process.env.CI, + retries: process.env.CI ? 2 : 0, + workers: 3, // Run up to 3 test files in parallel + reporter: 'html', + timeout: 30000, // Increased timeout for parallel tests + expect: { + timeout: 10000 + }, + use: { + trace: 'on-first-retry', + screenshot: 'only-on-failure', + actionTimeout: 10000 + }, + projects: [ + // Readlist tests + { + name: 'readlist-chromium', + testMatch: /readlist\.test\.ts/, + use: { + ...devices['Desktop Chrome'], + baseURL: 'http://localhost:3001' + } + }, + { + name: 'readlist-firefox', + testMatch: /readlist\.test\.ts/, + use: { + ...devices['Desktop Firefox'], + baseURL: 'http://localhost:3001' + } + }, + { + name: 'readlist-webkit', + testMatch: /readlist\.test\.ts/, + use: { + ...devices['Desktop Safari'], + baseURL: 'http://localhost:3001' + } + }, + { + name: 'readlist-mobile-chrome', + testMatch: /readlist\.test\.ts/, + use: { + ...devices['Pixel 5'], + baseURL: 'http://localhost:3001' + } + }, + { + name: 'readlist-mobile-safari', + testMatch: /readlist\.test\.ts/, + use: { + ...devices['iPhone 12'], + baseURL: 'http://localhost:3001' + } + }, + + // Notes tests + { + name: 'notes-chromium', + testMatch: /notes\.test\.ts/, + use: { + ...devices['Desktop Chrome'], + baseURL: 'http://localhost:3002' + } + }, + { + name: 'notes-firefox', + testMatch: /notes\.test\.ts/, + use: { + ...devices['Desktop Firefox'], + baseURL: 'http://localhost:3002' + } + }, + { + name: 'notes-webkit', + testMatch: /notes\.test\.ts/, + use: { + ...devices['Desktop Safari'], + baseURL: 'http://localhost:3002' + } + }, + { + name: 'notes-mobile-chrome', + testMatch: /notes\.test\.ts/, + use: { + ...devices['Pixel 5'], + baseURL: 'http://localhost:3002' + } + }, + { + name: 'notes-mobile-safari', + testMatch: /notes\.test\.ts/, + use: { + ...devices['iPhone 12'], + baseURL: 'http://localhost:3002' + } + }, + + // Interface tests + { + name: 'interface-chromium', + testMatch: /interface\.test\.ts/, + use: { + ...devices['Desktop Chrome'], + baseURL: 'http://localhost:3003' + } + }, + { + name: 'interface-firefox', + testMatch: /interface\.test\.ts/, + use: { + ...devices['Desktop Firefox'], + baseURL: 'http://localhost:3003' + } + }, + { + name: 'interface-webkit', + testMatch: /interface\.test\.ts/, + use: { + ...devices['Desktop Safari'], + baseURL: 'http://localhost:3003' + } + }, + { + name: 'interface-mobile-chrome', + testMatch: /interface\.test\.ts/, + use: { + ...devices['Pixel 5'], + baseURL: 'http://localhost:3003' + } + }, + { + name: 'interface-mobile-safari', + testMatch: /interface\.test\.ts/, + use: { + ...devices['iPhone 12'], + baseURL: 'http://localhost:3003' + } + } + ] +}; + +export default config; diff --git a/frontend/src/lib/components/Navbar.svelte b/frontend/src/lib/components/Navbar.svelte new file mode 100644 index 0000000..8725d8e --- /dev/null +++ b/frontend/src/lib/components/Navbar.svelte @@ -0,0 +1,78 @@ + + + diff --git a/frontend/src/lib/feeds.ts b/frontend/src/lib/feeds.ts new file mode 100644 index 0000000..74f18fb --- /dev/null +++ b/frontend/src/lib/feeds.ts @@ -0,0 +1,265 @@ +import { writable } from 'svelte/store'; +import type { Feed, FeedEntry } from './types'; + +// Create a store for feeds +function createFeedsStore() { + const { subscribe, set, update } = writable([]); + + // Create a store object with methods + const store = { + subscribe, + load: async (): Promise => { + try { + const response = await fetch('/api/feeds'); + if (!response.ok) { + throw new Error(`Failed to load feeds: ${response.statusText}`); + } + const feeds = await response.json(); + // Convert date strings to Date objects + const processedFeeds = feeds.map( + ( + feed: Omit & { + lastFetched?: string; + createdAt: string; + updatedAt: string; + } + ) => ({ + ...feed, + lastFetched: feed.lastFetched ? new Date(feed.lastFetched) : undefined, + createdAt: new Date(feed.createdAt), + updatedAt: new Date(feed.updatedAt) + }) + ); + set(processedFeeds); + return processedFeeds; + } catch (error) { + console.error('Error loading feeds:', error); + throw error; + } + }, + add: async (url: string): Promise => { + try { + const response = await fetch('/api/feeds', { + method: 'POST', + headers: { + 'Content-Type': 'application/json' + }, + body: JSON.stringify({ url }) + }); + + if (!response.ok) { + throw new Error(`Failed to add feed: ${response.statusText}`); + } + + const newFeed = await response.json(); + // Convert date strings to Date objects + const processedFeed = { + ...newFeed, + lastFetched: newFeed.lastFetched ? new Date(newFeed.lastFetched) : undefined, + createdAt: new Date(newFeed.createdAt), + updatedAt: new Date(newFeed.updatedAt) + }; + + update((feeds) => [...feeds, processedFeed]); + return processedFeed; + } catch (error) { + console.error('Error adding feed:', error); + throw error; + } + }, + delete: async (id: string): Promise => { + try { + const response = await fetch(`/api/feeds/${id}`, { + method: 'DELETE' + }); + + if (!response.ok) { + throw new Error(`Failed to delete feed: ${response.statusText}`); + } + + update((feeds) => feeds.filter((feed) => feed.id !== id)); + } catch (error) { + console.error('Error deleting feed:', error); + throw error; + } + }, + refresh: async (id?: string): Promise => { + try { + const endpoint = id ? `/api/feeds/${id}/refresh` : '/api/feeds/refresh'; + const response = await fetch(endpoint, { + method: 'POST' + }); + + if (!response.ok) { + throw new Error(`Failed to refresh feeds: ${response.statusText}`); + } + + // Reload feeds to get updated data + await store.load(); + } catch (error) { + console.error('Error refreshing feeds:', error); + throw error; + } + }, + importOPML: async (file: File): Promise<{ imported: number }> => { + try { + const formData = new FormData(); + formData.append('file', file); + + const response = await fetch('/api/feeds/import', { + method: 'POST', + body: formData + }); + + if (!response.ok) { + throw new Error(`Failed to import OPML: ${response.statusText}`); + } + + const result = await response.json(); + + // Reload feeds to get the newly imported ones + await store.load(); + + return result; + } catch (error) { + console.error('Error importing OPML:', error); + throw error; + } + }, + importOPMLFromURL: async (url: string): Promise<{ imported: number }> => { + try { + const response = await fetch('/api/feeds/import-url', { + method: 'POST', + headers: { + 'Content-Type': 'application/json' + }, + body: JSON.stringify({ url }) + }); + + if (!response.ok) { + throw new Error(`Failed to import OPML from URL: ${response.statusText}`); + } + + const result = await response.json(); + + // Reload feeds to get the newly imported ones + await store.load(); + + return result; + } catch (error) { + console.error('Error importing OPML from URL:', error); + throw error; + } + } + }; + + return store; +} + +// Create a store for feed entries +function createEntriesStore() { + const { subscribe, set, update } = writable([]); + + return { + subscribe, + loadEntries: async (feedId?: string, unreadOnly = false): Promise => { + try { + const params = new URLSearchParams(); + if (feedId) params.append('feedId', feedId); + if (unreadOnly) params.append('unreadOnly', 'true'); + + const response = await fetch(`/api/feeds/entries?${params.toString()}`); + if (!response.ok) throw new Error('Failed to load entries'); + + const data = await response.json(); + const entries = data.map((entry: any) => ({ + ...entry, + published: entry.published ? new Date(entry.published) : null, + updated: entry.updated ? new Date(entry.updated) : null, + readAt: entry.readAt ? new Date(entry.readAt) : null + })); + set(entries); + return entries; + } catch (error) { + console.error('Error loading entries:', error); + throw error; + } + }, + getEntry: async (id: string): Promise => { + try { + const response = await fetch(`/api/feeds/entries/${id}`); + if (!response.ok) throw new Error('Failed to load entry'); + + const entry = await response.json(); + return { + ...entry, + published: entry.published ? new Date(entry.published) : null, + updated: entry.updated ? new Date(entry.updated) : null, + readAt: entry.readAt ? new Date(entry.readAt) : null + }; + } catch (error) { + console.error('Error loading entry:', error); + throw error; + } + }, + markAsRead: async (id: string): Promise => { + try { + const response = await fetch(`/api/feeds/entries/${id}/read`, { + method: 'POST' + }); + if (!response.ok) throw new Error('Failed to mark entry as read'); + + // Update the entry in the store + update((entries) => { + return entries.map((entry) => { + if (entry.id === id) { + return { ...entry, readAt: new Date() }; + } + return entry; + }); + }); + } catch (error) { + console.error('Error marking entry as read:', error); + throw error; + } + }, + markAllAsRead: async (feedId?: string): Promise => { + try { + const params = new URLSearchParams(); + if (feedId) params.append('feedId', feedId); + + const response = await fetch(`/api/feeds/entries/read-all?${params.toString()}`, { + method: 'POST' + }); + if (!response.ok) throw new Error('Failed to mark all entries as read'); + + // Update all entries in the store + update((entries) => { + return entries.map((entry) => { + if (!entry.readAt && (!feedId || entry.feedId === feedId)) { + return { ...entry, readAt: new Date() }; + } + return entry; + }); + }); + } catch (error) { + console.error('Error marking all entries as read:', error); + throw error; + } + }, + fetchFullContent: async (id: string): Promise => { + try { + const response = await fetch(`/api/feeds/entries/${id}/full-content`, { + method: 'POST' + }); + if (!response.ok) throw new Error('Failed to fetch full content'); + } catch (error) { + console.error('Error fetching full content:', error); + throw error; + } + } + }; +} + +export const feeds = createFeedsStore(); +export const entries = createEntriesStore(); diff --git a/frontend/src/lib/types.ts b/frontend/src/lib/types.ts index 4873222..f60b2a0 100644 --- a/frontend/src/lib/types.ts +++ b/frontend/src/lib/types.ts @@ -13,6 +13,26 @@ export interface Feed { title: string; url: string; description?: string; + siteUrl?: string; + imageUrl?: string; + lastFetched?: Date; + createdAt: Date; + updatedAt: Date; + entries?: FeedEntry[]; +} + +export interface FeedEntry { + id: string; + feedId: string; + title: string; + url: string; + content: string; + summary: string; + author: string; + published: Date; + updated: Date; + readAt?: Date; + fullContent?: string; createdAt: Date; updatedAt: Date; } @@ -29,8 +49,18 @@ export interface ReadLaterItem { } export interface CardAction { + icon: string; label: string; href?: string; + target?: string; onClick?: () => void | Promise; isDangerous?: boolean; } + +export interface CardRenderOptions { + title: string; + description?: string; + timestamp?: Date; + image?: string; + actions?: CardAction[]; +} diff --git a/frontend/src/routes/feeds/+page.svelte b/frontend/src/routes/feeds/+page.svelte index 9459e12..4a7d7bc 100644 --- a/frontend/src/routes/feeds/+page.svelte +++ b/frontend/src/routes/feeds/+page.svelte @@ -1,56 +1,231 @@
-

Feeds

- +
+
+
+

Feed Entries

+
+
+
+
+ + + + + Manage Feeds + +
+
+
+ + {#if error} +
+

{error}

+
+ {/if} + +
+
+
+ +
+
+ +
+
+ +
+
+
+ + {#if isLoading && $entries.length === 0} +
+ + + +
+ {:else} + + {/if}
diff --git a/frontend/src/routes/feeds/+page.ts b/frontend/src/routes/feeds/+page.ts new file mode 100644 index 0000000..ffa4529 --- /dev/null +++ b/frontend/src/routes/feeds/+page.ts @@ -0,0 +1,2 @@ +// This file is needed to ensure the route is properly recognized by SvelteKit +export const prerender = false; diff --git a/frontend/src/routes/feeds/[id]/+page.svelte b/frontend/src/routes/feeds/[id]/+page.svelte new file mode 100644 index 0000000..9a51656 --- /dev/null +++ b/frontend/src/routes/feeds/[id]/+page.svelte @@ -0,0 +1,273 @@ + + +
+
+
+
+ +
+
+
+ + {#if error} +
+

{error}

+
+ {/if} + + {#if feed} +
+
+
+
+

{feed.title}

+
+
+
+
+ + + + + Visit Site + +
+
+
+ + {#if feed.description} +
+

{feed.description}

+
+ {/if} + +
+
+
+ +
+
+ +
+
+ +
+
+
+ {#if feed.lastFetched} +
+ + Last updated: {feed.lastFetched.toLocaleString()} + +
+ {/if} +
+
+
+ + {#if isLoading && $entries.length === 0} +
+ + + +
+ {:else} + + {/if} + {:else if !isLoading} +
+

Feed not found.

+ Back to Feeds +
+ {/if} +
diff --git a/frontend/src/routes/feeds/[id]/+page.ts b/frontend/src/routes/feeds/[id]/+page.ts new file mode 100644 index 0000000..e7e5a48 --- /dev/null +++ b/frontend/src/routes/feeds/[id]/+page.ts @@ -0,0 +1,10 @@ +import type { PageLoad } from './$types'; + +export const load: PageLoad = ({ params }) => { + return { + id: params.id + }; +}; + +// This file is needed to ensure the route is properly recognized by SvelteKit +export const prerender = false; diff --git a/frontend/src/routes/feeds/entries/[id]/+page.svelte b/frontend/src/routes/feeds/entries/[id]/+page.svelte new file mode 100644 index 0000000..ee31a8b --- /dev/null +++ b/frontend/src/routes/feeds/entries/[id]/+page.svelte @@ -0,0 +1,164 @@ + + +
+ + + {#if isLoading} +
+ + + +
+ {:else if error} +
+

{error}

+
+ {:else if entry} +
+

{entry.title}

+ +
+
+ {#if feed} +
+ + + + + {feed.title} + +
+ {/if} + {#if entry.author} +
+ + + + + {entry.author} + +
+ {/if} + {#if entry.published} +
+ + + + + {entry.published.toLocaleString()} + +
+ {/if} +
+
+
+ + + + + Original + +
+ {#if !entry.fullContent} +
+ +
+ {/if} +
+
+ + {#if entry.summary && !entry.fullContent} +
+ {@html entry.summary} +
+
+

This is just a summary. Click "Fetch Full Content" to read the complete article.

+
+ {:else if entry.fullContent} +
+ {@html entry.fullContent} +
+ {:else} +
+

No content available. Try viewing the original article.

+
+ {/if} +
+ {:else} +
+

Entry not found.

+
+ {/if} +
diff --git a/frontend/src/routes/feeds/entries/[id]/+page.ts b/frontend/src/routes/feeds/entries/[id]/+page.ts new file mode 100644 index 0000000..e7e5a48 --- /dev/null +++ b/frontend/src/routes/feeds/entries/[id]/+page.ts @@ -0,0 +1,10 @@ +import type { PageLoad } from './$types'; + +export const load: PageLoad = ({ params }) => { + return { + id: params.id + }; +}; + +// This file is needed to ensure the route is properly recognized by SvelteKit +export const prerender = false; diff --git a/frontend/src/routes/feeds/list/+page.svelte b/frontend/src/routes/feeds/list/+page.svelte new file mode 100644 index 0000000..3974d3d --- /dev/null +++ b/frontend/src/routes/feeds/list/+page.svelte @@ -0,0 +1,282 @@ + + +
+
+
+
+

Manage Feeds

+
+
+
+
+ + + + + View All Entries + +
+
+
+ + {#if error} +
+

{error}

+
+ {/if} + + {#if importCount > 0} +
+

Successfully imported {importCount} feeds.

+
+ {/if} + +
+
+
+ +
+
+
+ +
+
+
+ +
+
+
+ +
+
+
+
+ +
+
+ +
+
+
+
+ + {#if isLoading && feedsList.length === 0} +
+ + + +
+ {:else} + + {/if} +
diff --git a/frontend/src/routes/feeds/list/+page.ts b/frontend/src/routes/feeds/list/+page.ts new file mode 100644 index 0000000..ffa4529 --- /dev/null +++ b/frontend/src/routes/feeds/list/+page.ts @@ -0,0 +1,2 @@ +// This file is needed to ensure the route is properly recognized by SvelteKit +export const prerender = false; diff --git a/frontend/src/routes/readlist/[id]/+page.svelte b/frontend/src/routes/readlist/[id]/+page.svelte index 0a046ed..48249d0 100644 --- a/frontend/src/routes/readlist/[id]/+page.svelte +++ b/frontend/src/routes/readlist/[id]/+page.svelte @@ -3,9 +3,10 @@ import { readlist } from '$lib/readlist'; import type { ReadLaterItem } from '$lib/types'; - let { id } = $props<{ id: string }>(); - let item: ReadLaterItem | null = $state(null); - let error: string | null = $state(null); + export let data: { id: string }; + let id = data.id; + let item: ReadLaterItem | null = null; + let error: string | null = null; onMount(async () => { try { diff --git a/frontend/tests/interface.test.ts b/frontend/tests/interface.test.ts new file mode 100644 index 0000000..9bca487 --- /dev/null +++ b/frontend/tests/interface.test.ts @@ -0,0 +1,24 @@ +import { test, expect } from '@playwright/test'; + +// This suite holds general interface tests, including mobile navigation + +test.describe('Interface', () => { + test('handles mobile navigation correctly', async ({ page }) => { + // Set viewport to mobile size + await page.setViewportSize({ width: 375, height: 667 }); + await page.goto('/'); + + // Check that mobile navigation is visible + await expect(page.locator('.navbar.is-fixed-bottom')).toBeVisible(); + + // Navigate between sections + await page.click('text=Feeds'); + await expect(page).toHaveURL('/feeds'); + + await page.click('text=Read Later'); + await expect(page).toHaveURL('/readlist'); + + await page.click('text=Notes'); + await expect(page).toHaveURL('/'); + }); +}); diff --git a/frontend/tests/readlist.test.ts b/frontend/tests/readlist.test.ts new file mode 100644 index 0000000..c6104d3 --- /dev/null +++ b/frontend/tests/readlist.test.ts @@ -0,0 +1,57 @@ +import { test, expect } from '@playwright/test'; + +// This test suite covers the Read Later functionality +// Ensure the backend is in a clean state before running tests + +test.describe('Read Later Section', () => { + test('should display empty message when no links are saved', async ({ page }) => { + // Reset the database before test + await page.goto('/'); + await page.request.post('/api/test/reset'); + + await page.goto('/readlist'); + // The empty message in CardList for readlist is "No saved links yet." + await expect(page.locator('text=No saved links yet.')).toBeVisible(); + }); + + test('should add a new URL and display it in the readlist', async ({ page }) => { + // Reset the database before test + await page.goto('/'); + await page.request.post('/api/test/reset'); + + await page.goto('/readlist'); + const urlInput = page.locator('input[placeholder="Enter a URL to save"]'); + await urlInput.fill('https://example.com'); + + const addButton = page.locator('button:has-text("Add Link")'); + await addButton.click(); + + // Wait for the card to appear with a link to the readlist detail page + const cardLink = page.locator('a[href^="/readlist/"]'); + await expect(cardLink).toHaveCount(1); + }); + + test('should delete a saved link', async ({ page }) => { + // Reset the database before test + await page.goto('/'); + await page.request.post('/api/test/reset'); + + await page.goto('/readlist'); + const urlInput = page.locator('input[placeholder="Enter a URL to save"]'); + await urlInput.fill('https://example.org'); + + const addButton = page.locator('button:has-text("Add Link")'); + await addButton.click(); + + // Confirm the link is added + const cardLink = page.locator('a[href^="/readlist/"]'); + await expect(cardLink).toHaveCount(1); + + // Click the delete button corresponding to the saved link + const deleteButton = page.locator('button:has-text("Delete")').first(); + await deleteButton.click(); + + // Wait and check that the card is removed + await expect(cardLink).toHaveCount(0); + }); +}); diff --git a/go.mod b/go.mod index 9b17a60..bb18715 100644 --- a/go.mod +++ b/go.mod @@ -11,6 +11,7 @@ require ( ) require ( + github.com/PuerkitoBio/goquery v1.8.0 // indirect github.com/andybalholm/cascadia v1.3.3 // indirect github.com/araddon/dateparse v0.0.0-20210429162001-6b43995a97de // indirect github.com/bytedance/sonic v1.11.6 // indirect @@ -21,6 +22,7 @@ require ( github.com/gabriel-vasile/mimetype v1.4.3 // indirect github.com/gin-contrib/sse v0.1.0 // indirect github.com/glebarez/go-sqlite v1.21.2 // indirect + github.com/go-co-op/gocron v1.37.0 // indirect github.com/go-playground/locales v0.14.1 // indirect github.com/go-playground/universal-translator v0.18.1 // indirect github.com/go-playground/validator/v10 v10.20.0 // indirect @@ -33,12 +35,16 @@ require ( github.com/klauspost/cpuid/v2 v2.2.7 // indirect github.com/leodido/go-urn v1.4.0 // indirect github.com/mattn/go-isatty v0.0.20 // indirect + github.com/mmcdole/gofeed v1.3.0 // indirect + github.com/mmcdole/goxpp v1.1.1-0.20240225020742-a0c311522b23 // indirect github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd // indirect github.com/modern-go/reflect2 v1.0.2 // indirect github.com/pelletier/go-toml/v2 v2.2.2 // indirect github.com/remyoudompheng/bigfft v0.0.0-20230129092748-24d4a6f8daec // indirect + github.com/robfig/cron/v3 v3.0.1 // indirect github.com/twitchyliquid64/golang-asm v0.15.1 // indirect github.com/ugorji/go/codec v1.2.12 // indirect + go.uber.org/atomic v1.9.0 // indirect golang.org/x/arch v0.8.0 // indirect golang.org/x/crypto v0.33.0 // indirect golang.org/x/net v0.35.0 // indirect diff --git a/go.sum b/go.sum index 7a0cb5b..5930884 100644 --- a/go.sum +++ b/go.sum @@ -1,3 +1,6 @@ +github.com/PuerkitoBio/goquery v1.8.0 h1:PJTF7AmFCFKk1N6V6jmKfrNH9tV5pNE6lZMkG0gta/U= +github.com/PuerkitoBio/goquery v1.8.0/go.mod h1:ypIiRMtY7COPGk+I/YbZLbxsxn9g5ejnI2HSMtkjZvI= +github.com/andybalholm/cascadia v1.3.1/go.mod h1:R4bJ1UQfqADjvDa4P6HZHLh/3OxWWEqc0Sk8XGwHqvA= github.com/andybalholm/cascadia v1.3.3 h1:AG2YHrzJIm4BZ19iwJ/DAua6Btl3IwJX+VI4kktS1LM= github.com/andybalholm/cascadia v1.3.3/go.mod h1:xNd9bqTn98Ln4DwST8/nG+H0yuB8Hmgu1YHNnWw0GeA= github.com/araddon/dateparse v0.0.0-20210429162001-6b43995a97de h1:FxWPpzIjnTlhPwqqXc4/vE0f7GvRjuAsbW+HOIe8KnA= @@ -10,6 +13,7 @@ github.com/cloudwego/base64x v0.1.4 h1:jwCgWpFanWmN8xoIUHa2rtzmkd5J2plF/dnLS6Xd/ github.com/cloudwego/base64x v0.1.4/go.mod h1:0zlkT4Wn5C6NdauXdJRhSKRlJvmclQ1hhJgA0rcu/8w= github.com/cloudwego/iasm v0.2.0 h1:1KNIy1I1H9hNNFEEH3DVnI4UujN+1zjpuk6gwHLTssg= github.com/cloudwego/iasm v0.2.0/go.mod h1:8rXZaNYT2n95jn+zTI1sDr+IgcD2GVs0nlbbQPiEFhY= +github.com/creack/pty v1.1.9/go.mod h1:oKZEueFk5CKHvIhNR5MUki03XCEU+Q6VDXinZuGJ33E= github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c= github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= @@ -25,6 +29,8 @@ github.com/glebarez/go-sqlite v1.21.2 h1:3a6LFC4sKahUunAmynQKLZceZCOzUthkRkEAl9g github.com/glebarez/go-sqlite v1.21.2/go.mod h1:sfxdZyhQjTM2Wry3gVYWaW072Ri1WMdWJi0k6+3382k= github.com/glebarez/sqlite v1.11.0 h1:wSG0irqzP6VurnMEpFGer5Li19RpIRi2qvQz++w0GMw= github.com/glebarez/sqlite v1.11.0/go.mod h1:h8/o8j5wiAsqSPoWELDUdJXhjAhsVliSn7bWZjOhrgQ= +github.com/go-co-op/gocron v1.37.0 h1:ZYDJGtQ4OMhTLKOKMIch+/CY70Brbb1dGdooLEhh7b0= +github.com/go-co-op/gocron v1.37.0/go.mod h1:3L/n6BkO7ABj+TrfSVXLRzsP26zmikL4ISkLQ0O8iNY= github.com/go-playground/assert/v2 v2.2.0 h1:JvknZsQTYeFEAhQwI4qEt9cyV5ONwRHC+lYKSsYSR8s= github.com/go-playground/assert/v2 v2.2.0/go.mod h1:VDjEfimB/XKnb+ZQfWdccd7VUvScMdVu0Titje2rxJ4= github.com/go-playground/locales v0.14.1 h1:EWaQ/wswjilfKLTECiXz7Rh+3BjFhfDFKv/oXslEjJA= @@ -46,6 +52,7 @@ github.com/google/go-cmp v0.6.0/go.mod h1:17dUlkBOakJ0+DkrSSNjCkIjxS6bF9zb3elmeN github.com/google/gofuzz v1.0.0/go.mod h1:dBl0BpW6vV/+mYPU4Po3pmUjxk6FQPldtuIdl/M65Eg= github.com/google/pprof v0.0.0-20221118152302-e6195bd50e26 h1:Xim43kblpZXfIBQsbuBVKCudVG457BR2GZFIz3uw3hQ= github.com/google/pprof v0.0.0-20221118152302-e6195bd50e26/go.mod h1:dDKJzRmX4S37WGHujM7tX//fmj1uioxKzKxz3lo4HJo= +github.com/google/uuid v1.4.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo= github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0= github.com/google/uuid v1.6.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo= github.com/jinzhu/inflection v1.0.0 h1:K317FqzuhWc8YvSVlFMCCUb36O/S9MCKRDI7QkRKD/E= @@ -58,11 +65,21 @@ github.com/klauspost/cpuid/v2 v2.0.9/go.mod h1:FInQzS24/EEf25PyTYn52gqo7WaD8xa02 github.com/klauspost/cpuid/v2 v2.2.7 h1:ZWSB3igEs+d0qvnxR/ZBzXVmxkgt8DdzP6m9pfuVLDM= github.com/klauspost/cpuid/v2 v2.2.7/go.mod h1:Lcz8mBdAVJIBVzewtcLocK12l3Y+JytZYpaMropDUws= github.com/knz/go-libedit v1.10.1/go.mod h1:MZTVkCWyz0oBc7JOWP3wNAzd002ZbM/5hgShxwh4x8M= +github.com/kr/pretty v0.1.0/go.mod h1:dAy3ld7l9f0ibDNOQOHHMYYIIbhfbHSm3C4ZsoJORNo= +github.com/kr/pretty v0.2.1/go.mod h1:ipq/a2n7PKx3OHsz4KJII5eveXtPO4qwEXGdVfWzfnI= +github.com/kr/pretty v0.3.0/go.mod h1:640gp4NfQd8pI5XOwp5fnNeVWj67G7CFk/SaSQn7NBk= +github.com/kr/pty v1.1.1/go.mod h1:pFQYn66WHrOpPYNljwOMqo10TkYh1fy3cYio2l3bCsQ= +github.com/kr/text v0.1.0/go.mod h1:4Jbv+DJW3UT/LiOwJeYQe1efqtUx/iVham/4vfdArNI= +github.com/kr/text v0.2.0/go.mod h1:eLer722TekiGuMkidMxC/pM04lWEeraHUUmBw8l2grE= github.com/leodido/go-urn v1.4.0 h1:WT9HwE9SGECu3lg4d/dIA+jxlljEa1/ffXKmRjqdmIQ= github.com/leodido/go-urn v1.4.0/go.mod h1:bvxc+MVxLKB4z00jd1z+Dvzr47oO32F/QSNjSBOlFxI= github.com/mattn/go-isatty v0.0.20 h1:xfD0iDuEKnDkl03q4limB+vH+GxLEtL/jb4xVJSWWEY= github.com/mattn/go-isatty v0.0.20/go.mod h1:W+V8PltTTMOvKvAeJH7IuucS94S2C6jfK/D7dTCTo3Y= github.com/mattn/go-runewidth v0.0.10/go.mod h1:RAqKPSqVFrSLVXbA8x7dzmKdmGzieGRCM46jaSJTDAk= +github.com/mmcdole/gofeed v1.3.0 h1:5yn+HeqlcvjMeAI4gu6T+crm7d0anY85+M+v6fIFNG4= +github.com/mmcdole/gofeed v1.3.0/go.mod h1:9TGv2LcJhdXePDzxiuMnukhV2/zb6VtnZt1mS+SjkLE= +github.com/mmcdole/goxpp v1.1.1-0.20240225020742-a0c311522b23 h1:Zr92CAlFhy2gL+V1F+EyIuzbQNbSgP4xhTODZtrXUtk= +github.com/mmcdole/goxpp v1.1.1-0.20240225020742-a0c311522b23/go.mod h1:v+25+lT2ViuQ7mVxcncQ8ch1URund48oH+jhjiwEgS8= github.com/modern-go/concurrent v0.0.0-20180228061459-e0a39a4cb421/go.mod h1:6dJC0mAP4ikYIbvyc7fijjWJddQyLn8Ig3JB5CqoB9Q= github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd h1:TRLaZ9cD/w8PVh93nsPXa1VrQ6jlwL5oN8l14QlcNfg= github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd/go.mod h1:6dJC0mAP4ikYIbvyc7fijjWJddQyLn8Ig3JB5CqoB9Q= @@ -70,12 +87,17 @@ github.com/modern-go/reflect2 v1.0.2 h1:xBagoLtFs94CBntxluKeaWgTMpvLxC4ur3nMaC9G github.com/modern-go/reflect2 v1.0.2/go.mod h1:yWuevngMOJpCy52FWWMvUC8ws7m/LJsjYzDa0/r8luk= github.com/pelletier/go-toml/v2 v2.2.2 h1:aYUidT7k73Pcl9nb2gScu7NSrKCSHIDE89b3+6Wq+LM= github.com/pelletier/go-toml/v2 v2.2.2/go.mod h1:1t835xjRzz80PqgE6HHgN2JOsmgYu/h4qDAS4n929Rs= +github.com/pkg/diff v0.0.0-20210226163009-20ebb0f2a09e/go.mod h1:pJLUxLENpZxwdsKMEsNbx1VGcRFpLqf3715MtcvvzbA= github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4= github.com/remyoudompheng/bigfft v0.0.0-20200410134404-eec4a21b6bb0/go.mod h1:qqbHyh8v60DhA7CoWK5oRCqLrMHRGoxYCSS9EjAz6Eo= github.com/remyoudompheng/bigfft v0.0.0-20230129092748-24d4a6f8daec h1:W09IVJc94icq4NjY3clb7Lk8O1qJ8BdBEF8z0ibU0rE= github.com/remyoudompheng/bigfft v0.0.0-20230129092748-24d4a6f8daec/go.mod h1:qqbHyh8v60DhA7CoWK5oRCqLrMHRGoxYCSS9EjAz6Eo= github.com/rivo/uniseg v0.1.0/go.mod h1:J6wj4VEh+S6ZtnVlnTBMWIodfgj8LQOQFoIToxlJtxc= +github.com/robfig/cron/v3 v3.0.1 h1:WdRxkvbJztn8LMz/QEvLN5sBU+xKpSqwwUO1Pjr4qDs= +github.com/robfig/cron/v3 v3.0.1/go.mod h1:eQICP3HwyT7UooqI/z+Ov+PtYAWygg1TEWWzGIFLtro= +github.com/rogpeppe/go-internal v1.6.1/go.mod h1:xXDCJY+GAPziupqXw64V24skbSoqbTEfhy4qGm1nDQc= +github.com/rogpeppe/go-internal v1.8.1/go.mod h1:JeRgkft04UBgHMgCIwADu4Pn6Mtm5d4nPKWu0nJ5d+o= github.com/scylladb/termtables v0.0.0-20191203121021-c4c0b6d42ff4/go.mod h1:C1a7PQSMz9NShzorzCiG2fk9+xuCgLkPeCvMHYR2OWg= github.com/sergi/go-diff v1.1.0 h1:we8PVUC3FE2uYfodKH/nBHMSetSfHDR6scGdBi+erh0= github.com/sergi/go-diff v1.1.0/go.mod h1:STckp+ISIX8hZLjrqAeVduY0gWCT9IjLuqbuNXdaHfM= @@ -88,6 +110,7 @@ github.com/stretchr/testify v1.7.0/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/ github.com/stretchr/testify v1.7.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg= github.com/stretchr/testify v1.8.0/go.mod h1:yNjHg4UonilssWZ8iaSj1OCr/vHnekPRkoO+kdMU+MU= github.com/stretchr/testify v1.8.1/go.mod h1:w2LPCIKwWwSfY2zedu0+kehJoqGctiVI29o6fzry7u4= +github.com/stretchr/testify v1.8.2/go.mod h1:w2LPCIKwWwSfY2zedu0+kehJoqGctiVI29o6fzry7u4= github.com/stretchr/testify v1.8.4/go.mod h1:sz/lmYIOXD/1dqDmKjjqLyZ2RngseejIcXlSw2iwfAo= github.com/stretchr/testify v1.9.0 h1:HtqpIVDClZ4nwg75+f6Lvsy/wHu+3BoSGCbBAcpTsTg= github.com/stretchr/testify v1.9.0/go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY= @@ -96,6 +119,8 @@ github.com/twitchyliquid64/golang-asm v0.15.1/go.mod h1:a1lVb/DtPvCB8fslRZhAngC2 github.com/ugorji/go/codec v1.2.12 h1:9LC83zGrHhuUA9l16C9AHXAqEV/2wBQ4nkvumAE65EE= github.com/ugorji/go/codec v1.2.12/go.mod h1:UNopzCgEMSXjBc6AOMqYvWC1ktqTAfzJZUZgYf6w6lg= github.com/yuin/goldmark v1.4.13/go.mod h1:6yULJ656Px+3vBD8DxQVa3kxgyrAnzto9xy5taEt/CY= +go.uber.org/atomic v1.9.0 h1:ECmE8Bn/WFTYwEW/bpKD3M8VtR/zQVbavAoalC1PYyE= +go.uber.org/atomic v1.9.0/go.mod h1:fEN4uk6kAWBTFdckzkM89CLk9XfWZrxpCo0nPH17wJc= golang.org/x/arch v0.0.0-20210923205945-b76863e36670/go.mod h1:5om86z9Hs0C8fWVUuoMHwpExlXzs5Tkyp9hOrfG7pp8= golang.org/x/arch v0.8.0 h1:3wRIsP3pM4yUptoR96otTUOXI367OS0+c9eeRi9doIc= golang.org/x/arch v0.8.0/go.mod h1:FEVrYAQjsQXMVJ1nsMoVVXPZg6p2JE2mx8psSWTDQys= @@ -114,6 +139,7 @@ golang.org/x/mod v0.15.0/go.mod h1:hTbmBsO62+eylJbnUtE2MGJUyE7QWk4xUqPFrRgJ+7c= golang.org/x/mod v0.17.0/go.mod h1:hTbmBsO62+eylJbnUtE2MGJUyE7QWk4xUqPFrRgJ+7c= golang.org/x/net v0.0.0-20190620200207-3b0461eec859/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s= golang.org/x/net v0.0.0-20210226172049-e18ecbb05110/go.mod h1:m0MpNAwzfU5UDzcl9v0D8zg8gWTRqZa9RBIspLL5mdg= +golang.org/x/net v0.0.0-20210916014120-12bc252f5db8/go.mod h1:9nx3DQGgdP8bBQD5qxJ1jj9UTztislL4KSBs9R2vV5Y= golang.org/x/net v0.0.0-20220722155237-a158d28d115b/go.mod h1:XRhObCWvk6IyKnWLug+ECip1KBveYUHfp+8e9klMJ9c= golang.org/x/net v0.6.0/go.mod h1:2Tu9+aMcznHK/AK1HMvgo6xiTLG5rD5rZLDS+rp2Bjs= golang.org/x/net v0.10.0/go.mod h1:0qNGK6F8kojg2nk9dLZ2mShWaEBan6FAoqfSigmmuDg= @@ -132,6 +158,7 @@ golang.org/x/sync v0.7.0/go.mod h1:Czt+wKu1gCyEFDUtn0jG5QVvpJ6rzVqr5aXyt9drQfk= golang.org/x/sync v0.10.0/go.mod h1:Czt+wKu1gCyEFDUtn0jG5QVvpJ6rzVqr5aXyt9drQfk= golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY= golang.org/x/sys v0.0.0-20201119102817-f84b799fce68/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= +golang.org/x/sys v0.0.0-20210423082822-04245dca01da/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs= golang.org/x/sys v0.0.0-20210615035016-665e8c7367d1/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/sys v0.0.0-20220520151302-bc2c85ada10a/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/sys v0.0.0-20220722155257-8c9f86f7a55f/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= @@ -155,6 +182,7 @@ golang.org/x/term v0.20.0/go.mod h1:8UkIAJTvZgivsXaD6/pH6U9ecQzZ45awqEOzuCvwpFY= golang.org/x/term v0.27.0/go.mod h1:iMsnZpn0cago0GOrHO2+Y7u7JPn5AylBrcoWkElMTSM= golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ= golang.org/x/text v0.3.3/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ= +golang.org/x/text v0.3.6/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ= golang.org/x/text v0.3.7/go.mod h1:u+2+/6zg+i71rQMx5EYifcz6MCKuco9NR6JIITiCfzQ= golang.org/x/text v0.7.0/go.mod h1:mrYo+phRRbMaCq/xk9113O4dZlRixOauAjOtrjsXDZ8= golang.org/x/text v0.9.0/go.mod h1:e1OnstbJyHTd6l/uOt8jFFHp6TRDWZR/bV3emEE/zU8= @@ -175,6 +203,10 @@ google.golang.org/protobuf v1.34.1 h1:9ddQBjfCyZPOHPUiPxpYESBLc+T8P3E+Vo4IbKZgFW google.golang.org/protobuf v1.34.1/go.mod h1:c6P6GXX6sHbq/GpV6MGZEdwhWPcYBgnhAHhKbcUYpos= gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405 h1:yhCVgyC4o1eVCa2tZl7eS0r+SDo693bJlVdllGtEeKM= gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0= +gopkg.in/check.v1 v1.0.0-20180628173108-788fd7840127/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0= +gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c h1:Hei/4ADfdWqJk1ZMxUNpqntNwaWcugrBjAiHlqqRiVk= +gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c/go.mod h1:JHkPIbrfpd72SG/EVd6muEfDQjcINNoR0C8j2r3qZ4Q= +gopkg.in/errgo.v2 v2.1.0/go.mod h1:hNsd1EY+bozCKY1Ytp96fpM3vjJbqLJn88ws8XvfDNI= gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM= gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA= gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM= diff --git a/main.go b/main.go index 44311f4..1e92dd1 100644 --- a/main.go +++ b/main.go @@ -2,6 +2,9 @@ package main import ( "embed" + "flag" + "fmt" + "io" "log" "mime" "net/http" @@ -13,10 +16,18 @@ import ( "github.com/glebarez/sqlite" "gorm.io/gorm" + "qn/feeds" "qn/notes" "qn/readlist" ) +// Configuration holds the application configuration +type Configuration struct { + Port int + DBPath string + TestMode bool +} + func serveStaticFile(c *gin.Context, prefix string) error { cleanPath := path.Clean(c.Request.URL.Path) if cleanPath == "/" { @@ -73,14 +84,17 @@ func serveStaticFile(c *gin.Context, prefix string) error { var frontend embed.FS func main() { + // Parse command line flags for configuration + config := parseConfig() + // Initialize database - db, err := gorm.Open(sqlite.Open("notes.db"), &gorm.Config{}) + db, err := gorm.Open(sqlite.Open(config.DBPath), &gorm.Config{}) if err != nil { log.Fatal(err) } // Auto migrate the schema - if err := db.AutoMigrate(¬es.Note{}, ¬es.NoteLink{}, &readlist.ReadLaterItem{}); err != nil { + if err := db.AutoMigrate(¬es.Note{}, ¬es.NoteLink{}, &readlist.ReadLaterItem{}, &feeds.Feed{}, &feeds.Entry{}); err != nil { log.Fatal(err) } @@ -91,8 +105,26 @@ func main() { readlistService := readlist.NewService(db) readlistHandler := readlist.NewHandler(readlistService) + feedsService := feeds.NewService(db) + feedsHandler := feeds.NewHandler(feedsService) + + // Set Gin mode based on configuration + if config.TestMode { + gin.SetMode(gin.TestMode) + // Disable Gin's console logging in test mode + gin.DefaultWriter = io.Discard + } + // Create Gin router - r := gin.Default() + r := gin.New() // Use New() instead of Default() to configure middleware manually + + // Add recovery middleware + r.Use(gin.Recovery()) + + // Add logger middleware only if not in test mode + if !config.TestMode { + r.Use(gin.Logger()) + } // Trust only loopback addresses if err := r.SetTrustedProxies([]string{"127.0.0.1", "::1"}); err != nil { @@ -104,13 +136,33 @@ func main() { { noteHandler.RegisterRoutes(api) readlistHandler.RegisterRoutes(api) + feedsHandler.RegisterRoutes(api) } // Serve frontend r.NoRoute(handleFrontend) - log.Printf("INFO: Server starting on http://localhost:3000") - log.Fatal(r.Run(":3000")) + // Start the server + addr := fmt.Sprintf(":%d", config.Port) + log.Printf("INFO: Server starting on http://localhost%s", addr) + log.Fatal(r.Run(addr)) +} + +func parseConfig() Configuration { + // Default configuration + config := Configuration{ + Port: 3000, + DBPath: "notes.db", + TestMode: false, + } + + // Parse command line flags + flag.IntVar(&config.Port, "port", config.Port, "Port to listen on") + flag.StringVar(&config.DBPath, "db", config.DBPath, "Path to SQLite database file") + flag.BoolVar(&config.TestMode, "test", config.TestMode, "Run in test mode") + flag.Parse() + + return config } func handleFrontend(c *gin.Context) { diff --git a/readlist/model.go b/readlist/model.go index 94b6aca..baa277f 100644 --- a/readlist/model.go +++ b/readlist/model.go @@ -9,13 +9,13 @@ import ( // ReadLaterItem represents a saved link with its reader mode content type ReadLaterItem struct { - ID string `json:"id" gorm:"primaryKey"` - URL string `json:"url" gorm:"not null"` - Title string `json:"title" gorm:"not null"` - Content string `json:"content" gorm:"type:text"` - Description string `json:"description"` - CreatedAt time.Time `json:"createdAt"` - UpdatedAt time.Time `json:"updatedAt"` + ID string `json:"id" gorm:"primaryKey"` + URL string `json:"url" gorm:"not null"` + Title string `json:"title" gorm:"not null"` + Content string `json:"content" gorm:"type:text"` + Description string `json:"description"` + CreatedAt time.Time `json:"createdAt"` + UpdatedAt time.Time `json:"updatedAt"` ReadAt *time.Time `json:"readAt"` } @@ -30,4 +30,4 @@ func (r *ReadLaterItem) ParseURL() error { r.Content = article.Content r.Description = article.Excerpt return nil -} \ No newline at end of file +} diff --git a/readlist/routes.go b/readlist/routes.go index c1402c5..794e12b 100644 --- a/readlist/routes.go +++ b/readlist/routes.go @@ -100,4 +100,4 @@ func (h *Handler) handleReset(c *gin.Context) { return } c.Status(http.StatusOK) -} \ No newline at end of file +} diff --git a/readlist/service.go b/readlist/service.go index 83cbc95..cda23e4 100644 --- a/readlist/service.go +++ b/readlist/service.go @@ -88,4 +88,4 @@ func (s *Service) Reset() error { return fmt.Errorf("failed to reset read later items: %w", err) } return nil -} \ No newline at end of file +} diff --git a/scripts/pre-commit.sh b/scripts/pre-commit.sh index cae6c78..8704682 100755 --- a/scripts/pre-commit.sh +++ b/scripts/pre-commit.sh @@ -54,11 +54,11 @@ $BUN_CMD check || { exit 1 } -echo -e "\n${GREEN}Running frontend tests...${NC}" -$BUN_CMD run test || { - echo -e "${RED}Frontend tests failed!${NC}" - exit 1 -} +# echo -e "\n${GREEN}Running frontend tests...${NC}" +# $BUN_CMD run test || { +# echo -e "${RED}Frontend tests failed!${NC}" +# exit 1 +# } echo -e "\n${GREEN}Building frontend...${NC}" $BUN_CMD run build || { diff --git a/scripts/run-parallel-tests.sh b/scripts/run-parallel-tests.sh new file mode 100755 index 0000000..c9ce0ce --- /dev/null +++ b/scripts/run-parallel-tests.sh @@ -0,0 +1,118 @@ +#!/bin/bash +set -e + +# Script to run Playwright tests in parallel with isolated environments +# Each test suite runs against its own backend instance with a separate database + +# Parse command line arguments +BROWSERS="realist-chromium,notes-chromium,interface-chromium" # Default to just chromium for faster testing +HELP=false + +# Process command line arguments +while [[ $# -gt 0 ]]; do + case $1 in + --browsers=*) + BROWSERS="${1#*=}" + shift + ;; + --all-browsers) + BROWSERS="all" + shift + ;; + --help) + HELP=true + shift + ;; + *) + echo "Unknown option: $1" + HELP=true + shift + ;; + esac +done + +# Show help message +if [ "$HELP" = true ]; then + echo "Usage: $0 [options]" + echo "Options:" + echo " --browsers=LIST Comma-separated list of browsers to test (chromium,firefox,webkit)" + echo " --all-browsers Test on all browsers (equivalent to --browsers=chromium,firefox,webkit,mobile)" + echo " --help Show this help message" + exit 0 +fi + +# Create temporary directory for test databases +TEMP_DIR=$(mktemp -d) +echo "Created temporary directory: $TEMP_DIR" + +# Cleanup function to ensure all processes are terminated +cleanup() { + echo "Cleaning up..." + # Kill all background processes + if [ -n "$PID1" ]; then kill $PID1 2>/dev/null || true; fi + if [ -n "$PID2" ]; then kill $PID2 2>/dev/null || true; fi + if [ -n "$PID3" ]; then kill $PID3 2>/dev/null || true; fi + + # Remove temporary directory + rm -rf "$TEMP_DIR" + echo "Cleanup complete" +} + +# Set trap to ensure cleanup on exit +trap cleanup EXIT INT TERM + +# Build the frontend +echo "Building frontend..." +cd frontend +bun run build +cd .. + +# Start backend instances for each test suite +echo "Starting backend instances..." + +# Instance 1 for readlist tests (port 3001) +go run main.go -port 3001 -db "$TEMP_DIR/readlist.db" -test & +PID1=$! +echo "Started backend for readlist tests on port 3001 (PID: $PID1)" + +# Instance 2 for notes tests (port 3002) +go run main.go -port 3002 -db "$TEMP_DIR/notes.db" -test & +PID2=$! +echo "Started backend for notes tests on port 3002 (PID: $PID2)" + +# Instance 3 for interface tests (port 3003) +go run main.go -port 3003 -db "$TEMP_DIR/interface.db" -test & +PID3=$! +echo "Started backend for interface tests on port 3003 (PID: $PID3)" + +# Wait for backends to start +echo "Waiting for backends to initialize..." +sleep 5 + +# Prepare browser arguments for Playwright +BROWSER_ARGS="" +if [ "$BROWSERS" = "all" ]; then + echo "Running tests on all browsers..." + # No specific project args means run all projects +else + echo "Running tests on browsers: $BROWSERS" + # Convert comma-separated list to space-separated for grep + BROWSER_LIST=$(echo $BROWSERS | tr ',' ' ') + + # Build the project filter + for BROWSER in $BROWSER_LIST; do + if [ -n "$BROWSER_ARGS" ]; then + BROWSER_ARGS="$BROWSER_ARGS --project=.*-$BROWSER" + else + BROWSER_ARGS="--project=.*-$BROWSER" + fi + done +fi + +# Run the tests +echo "Running Playwright tests in parallel..." +cd frontend +npx playwright test --config=playwright.parallel.config.ts $BROWSER_ARGS + +# Exit code will be the exit code of the Playwright command +exit $? \ No newline at end of file