mirror of
https://github.com/tnypxl/rollup.git
synced 2025-12-13 06:23:18 +00:00
Compare commits
8 Commits
feat/click
...
61dde38773
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
61dde38773 | ||
|
|
9495ddd788 | ||
|
|
eb3b611864 | ||
|
|
877a7876c0 | ||
|
|
7569aff6ec | ||
|
|
9341a51d09 | ||
|
|
9e9ac903e4 | ||
|
|
645626f763 |
53
CLAUDE.md
Normal file
53
CLAUDE.md
Normal file
@@ -0,0 +1,53 @@
|
||||
# CLAUDE.md
|
||||
|
||||
This file provides guidance to Claude Code (claude.ai/code) when working with code in this repository.
|
||||
|
||||
## Build and Run Commands
|
||||
|
||||
```bash
|
||||
# Build the binary
|
||||
go build -o rollup .
|
||||
|
||||
# Run directly
|
||||
go run main.go [command]
|
||||
|
||||
# Run tests
|
||||
go test ./...
|
||||
|
||||
# Run a single test
|
||||
go test -run TestName ./path/to/package
|
||||
```
|
||||
|
||||
## Project Overview
|
||||
|
||||
Rollup is a Go CLI tool that aggregates text-based files and webpages into markdown files. It has three main commands:
|
||||
- `files` - Rolls up local files into a single markdown file
|
||||
- `web` - Scrapes webpages and converts to markdown using Playwright
|
||||
- `generate` - Creates a default rollup.yml config file
|
||||
|
||||
## Architecture
|
||||
|
||||
**Entry Point**: `main.go` initializes Playwright browser and loads config before executing commands via Cobra.
|
||||
|
||||
**Command Layer** (`cmd/`):
|
||||
- `root.go` - Cobra root command with global flags (--config, --verbose)
|
||||
- `files.go` - File aggregation with glob pattern matching for ignore/codegen detection
|
||||
- `web.go` - Web scraping orchestration, converts config site definitions to scraper configs
|
||||
- `generate.go` - Scans directory for text file types and generates rollup.yml
|
||||
|
||||
**Internal Packages**:
|
||||
- `internal/config` - YAML config loading and validation. Defines `Config`, `SiteConfig`, `PathOverride` structs
|
||||
- `internal/scraper` - Playwright-based web scraping with rate limiting, HTML-to-markdown conversion via goquery and html-to-markdown library
|
||||
|
||||
**Key Dependencies**:
|
||||
- `spf13/cobra` - CLI framework
|
||||
- `playwright-go` - Browser automation for web scraping
|
||||
- `PuerkitoBio/goquery` - HTML parsing and CSS selector extraction
|
||||
- `JohannesKaufmann/html-to-markdown` - HTML to markdown conversion
|
||||
|
||||
## Configuration
|
||||
|
||||
The tool reads from `rollup.yml` by default. Key config fields:
|
||||
- `file_extensions` - File types to include in rollup
|
||||
- `ignore_paths` / `code_generated_paths` - Glob patterns for exclusion
|
||||
- `sites` - Web scraping targets with CSS selectors, path filtering, rate limiting
|
||||
212
README.md
212
README.md
@@ -1,145 +1,225 @@
|
||||
# Rollup
|
||||
|
||||
Rollup aggregates the contents of text-based files and webpages into a markdown file.
|
||||
Rollup aggregates the contents of text-based files and webpages into markdown files.
|
||||
|
||||
## Features
|
||||
|
||||
- File type filtering for targeted content aggregation
|
||||
- Ignore patterns for excluding specific files or directories
|
||||
- Support for code-generated file detection and exclusion
|
||||
- Advanced web scraping functionality with depth control
|
||||
- Verbose logging option for detailed operation insights
|
||||
- Exclusionary CSS selectors for precise web content extraction
|
||||
- Support for multiple URLs in web scraping operations
|
||||
- Configurable output format for web scraping (single file or separate files)
|
||||
- Flexible configuration file support (YAML)
|
||||
- Automatic generation of default configuration file
|
||||
- Custom output file naming
|
||||
- Rate limiting for web scraping to respect server resources
|
||||
- **File aggregation**: Combine multiple source files into a single markdown document
|
||||
- **File type filtering**: Include only specific file extensions
|
||||
- **Ignore patterns**: Exclude files/directories using glob patterns
|
||||
- **Code-generated file detection**: Mark auto-generated files as read-only in output
|
||||
- **Web scraping**: Scrape webpage content using Playwright browser automation
|
||||
- **HTML to Markdown conversion**: Automatically converts scraped HTML to clean markdown
|
||||
- **CSS selectors**: Extract specific content sections or exclude unwanted elements
|
||||
- **Path-based overrides**: Configure different selectors for specific URL paths
|
||||
- **Rate limiting**: Configurable requests per second and burst limits for web scraping
|
||||
- **Output modes**: Single combined file or separate files per source
|
||||
- **Verbose logging**: Detailed operation insights for debugging
|
||||
- **YAML configuration**: Flexible configuration file support
|
||||
|
||||
## Installation
|
||||
|
||||
To install Rollup, make sure you have Go installed on your system, then run:
|
||||
Ensure you have Go 1.21+ installed, then run:
|
||||
|
||||
```bash
|
||||
go get github.com/tnypxl/rollup
|
||||
go install github.com/tnypxl/rollup@latest
|
||||
```
|
||||
|
||||
Or build from source:
|
||||
|
||||
```bash
|
||||
git clone https://github.com/tnypxl/rollup.git
|
||||
cd rollup
|
||||
go build -o rollup .
|
||||
```
|
||||
|
||||
## Usage
|
||||
|
||||
Basic usage:
|
||||
|
||||
```bash
|
||||
rollup [command] [flags]
|
||||
```
|
||||
|
||||
### Commands
|
||||
|
||||
- `rollup files`: Rollup files into a single Markdown file
|
||||
- `rollup web`: Scrape main content from webpages and convert to Markdown
|
||||
- `rollup generate`: Generate a rollup.yml config file
|
||||
| Command | Description |
|
||||
|---------|-------------|
|
||||
| `files` | Aggregate local files into a single markdown file |
|
||||
| `web` | Scrape webpages and convert to markdown |
|
||||
| `generate` | Generate a default rollup.yml config file |
|
||||
|
||||
### Flags for `files` command
|
||||
|
||||
- `--path, -p`: Path to the project directory (default: current directory)
|
||||
- `--types, -t`: Comma-separated list of file extensions to include (default: .go,.md,.txt)
|
||||
- `--codegen, -g`: Comma-separated list of glob patterns for code-generated files
|
||||
- `--ignore, -i`: Comma-separated list of glob patterns for files to ignore
|
||||
| Flag | Short | Default | Description |
|
||||
|------|-------|---------|-------------|
|
||||
| `--path` | `-p` | `.` | Path to the project directory |
|
||||
| `--types` | `-t` | `go,md,txt` | Comma-separated list of file extensions (without dots) |
|
||||
| `--codegen` | `-g` | | Glob patterns for code-generated files |
|
||||
| `--ignore` | `-i` | | Glob patterns for files to ignore |
|
||||
|
||||
### Flags for `web` command
|
||||
|
||||
- `--urls, -u`: URLs of the webpages to scrape (comma-separated)
|
||||
- `--output, -o`: Output type: 'single' for one file, 'separate' for multiple files (default: single)
|
||||
- `--depth, -d`: Depth of link traversal (default: 0, only scrape the given URLs)
|
||||
- `--css`: CSS selector to extract specific content
|
||||
- `--exclude`: CSS selectors to exclude from the extracted content (comma-separated)
|
||||
| Flag | Short | Description |
|
||||
|------|-------|-------------|
|
||||
| `--urls` | `-u` | URLs of webpages to scrape (comma-separated) |
|
||||
| `--output` | `-o` | Output type: `single` or `separate` |
|
||||
| `--css` | | CSS selector to extract specific content |
|
||||
| `--exclude` | | CSS selectors to exclude (comma-separated) |
|
||||
|
||||
### Global flags
|
||||
|
||||
- `--config, -f`: Path to the configuration file (default: rollup.yml in the current directory)
|
||||
- `--verbose, -v`: Enable verbose logging
|
||||
| Flag | Short | Description |
|
||||
|------|-------|-------------|
|
||||
| `--config` | `-f` | Path to config file (default: `rollup.yml`) |
|
||||
| `--verbose` | `-v` | Enable verbose logging |
|
||||
|
||||
## Configuration
|
||||
|
||||
Rollup can be configured using a YAML file. By default, it looks for `rollup.yml` in the current directory. You can specify a different configuration file using the `--config` flag.
|
||||
Rollup reads from `rollup.yml` by default. Use `--config` to specify a different file.
|
||||
|
||||
Example `rollup.yml`:
|
||||
### Configuration Options
|
||||
|
||||
```yaml
|
||||
# File extensions to include (without leading dots)
|
||||
file_extensions:
|
||||
- go
|
||||
- md
|
||||
- js
|
||||
|
||||
# Glob patterns for paths to ignore
|
||||
ignore_paths:
|
||||
- node_modules/**
|
||||
- vendor/**
|
||||
- .git/**
|
||||
|
||||
# Glob patterns for code-generated files (marked as read-only in output)
|
||||
code_generated_paths:
|
||||
- **/generated/**
|
||||
- "**/*.pb.go"
|
||||
- "**/generated/**"
|
||||
|
||||
# Web scraping site configurations
|
||||
sites:
|
||||
- base_url: https://example.com
|
||||
css_locator: .content
|
||||
css_locator: .main-content
|
||||
exclude_selectors:
|
||||
- .ads
|
||||
- .navigation
|
||||
max_depth: 2
|
||||
- footer
|
||||
allowed_paths:
|
||||
- /blog
|
||||
- /docs
|
||||
- /blog
|
||||
exclude_paths:
|
||||
- /admin
|
||||
output_alias: example
|
||||
file_name_prefix: example-docs
|
||||
path_overrides:
|
||||
- path: /special-page
|
||||
css_locator: .special-content
|
||||
exclude_selectors:
|
||||
- .special-ads
|
||||
|
||||
# Output type for web scraping: 'single' or 'separate'
|
||||
output_type: single
|
||||
|
||||
# Rate limiting for web requests
|
||||
requests_per_second: 1.0
|
||||
burst_limit: 3
|
||||
```
|
||||
|
||||
### Configuration Reference
|
||||
|
||||
| Field | Type | Description |
|
||||
|-------|------|-------------|
|
||||
| `file_extensions` | list | File extensions to include in file rollup |
|
||||
| `ignore_paths` | list | Glob patterns for files/directories to skip |
|
||||
| `code_generated_paths` | list | Glob patterns for auto-generated files |
|
||||
| `sites` | list | Web scraping target configurations |
|
||||
| `output_type` | string | `single` (one file) or `separate` (multiple files) |
|
||||
| `requests_per_second` | float | Rate limit for web requests (default: 1.0) |
|
||||
| `burst_limit` | int | Maximum burst size for rate limiting (default: 3) |
|
||||
|
||||
#### Site Configuration
|
||||
|
||||
| Field | Type | Description |
|
||||
|-------|------|-------------|
|
||||
| `base_url` | string | Starting URL for scraping (required) |
|
||||
| `css_locator` | string | CSS selector for content extraction |
|
||||
| `exclude_selectors` | list | CSS selectors for content to exclude |
|
||||
| `allowed_paths` | list | URL paths allowed for scraping |
|
||||
| `exclude_paths` | list | URL paths to skip |
|
||||
| `file_name_prefix` | string | Prefix for output file names |
|
||||
| `path_overrides` | list | Path-specific selector overrides |
|
||||
|
||||
## Examples
|
||||
|
||||
1. Rollup files with default configuration:
|
||||
### File Aggregation
|
||||
|
||||
```bash
|
||||
rollup files
|
||||
```
|
||||
```bash
|
||||
# Rollup files using config file
|
||||
rollup files
|
||||
|
||||
2. Web scraping with multiple URLs:
|
||||
# Specify file types and ignore patterns
|
||||
rollup files --types=go,js,ts --ignore="vendor/**,*_test.go"
|
||||
|
||||
```bash
|
||||
rollup web --urls=https://example.com,https://another-example.com
|
||||
```
|
||||
# Rollup a specific directory
|
||||
rollup files --path=/path/to/project
|
||||
```
|
||||
|
||||
3. Generate a default configuration file:
|
||||
### Web Scraping
|
||||
|
||||
```bash
|
||||
rollup generate
|
||||
```
|
||||
```bash
|
||||
# Scrape URLs from command line
|
||||
rollup web --urls=https://example.com/docs
|
||||
|
||||
4. Use a custom configuration file:
|
||||
# Scrape multiple URLs
|
||||
rollup web --urls=https://example.com,https://another.com
|
||||
|
||||
```bash
|
||||
rollup files --config=my-config.yml
|
||||
```
|
||||
# Extract specific content with CSS selector
|
||||
rollup web --urls=https://example.com --css=".article-content"
|
||||
|
||||
5. Web scraping with separate output files:
|
||||
# Exclude elements from scraped content
|
||||
rollup web --urls=https://example.com --css=".content" --exclude=".ads,.sidebar"
|
||||
|
||||
```bash
|
||||
rollup web --urls=https://example.com,https://another-example.com --output=separate
|
||||
```
|
||||
# Output to separate files
|
||||
rollup web --urls=https://example.com --output=separate
|
||||
```
|
||||
|
||||
6. Rollup files with specific types and ignore patterns:
|
||||
### Configuration Generation
|
||||
|
||||
```bash
|
||||
rollup files --types=go,md --ignore=vendor/**,*_test.go
|
||||
```
|
||||
```bash
|
||||
# Generate rollup.yml based on files in current directory
|
||||
rollup generate
|
||||
```
|
||||
|
||||
7. Web scraping with depth and CSS selector:
|
||||
```bash
|
||||
rollup web --urls=https://example.com --depth=2 --css=.main-content
|
||||
```
|
||||
### Using Custom Config
|
||||
|
||||
```bash
|
||||
rollup files --config=my-config.yml
|
||||
rollup web --config=my-config.yml
|
||||
```
|
||||
|
||||
## Output
|
||||
|
||||
### File Rollup Output
|
||||
|
||||
The `files` command generates a markdown file named `<project-name>-<timestamp>.rollup.md` containing all matched files:
|
||||
|
||||
```markdown
|
||||
# File: src/main.go
|
||||
|
||||
```go
|
||||
package main
|
||||
// ... file contents
|
||||
```
|
||||
|
||||
# File: docs/README.md (Code-generated, Read-only)
|
||||
|
||||
```md
|
||||
// ... file contents
|
||||
```
|
||||
```
|
||||
|
||||
### Web Rollup Output
|
||||
|
||||
The `web` command generates markdown files from scraped content, with filenames based on the page title or URL.
|
||||
|
||||
## Contributing
|
||||
|
||||
|
||||
@@ -33,7 +33,7 @@ whose name is <project-directory-name>-rollup-<timestamp>.md.`,
|
||||
|
||||
func init() {
|
||||
filesCmd.Flags().StringVarP(&path, "path", "p", ".", "Path to the project directory")
|
||||
filesCmd.Flags().StringVarP(&fileTypes, "types", "t", ".go,.md,.txt", "Comma-separated list of file extensions to include")
|
||||
filesCmd.Flags().StringVarP(&fileTypes, "types", "t", "go,md,txt", "Comma-separated list of file extensions to include (without leading dot)")
|
||||
filesCmd.Flags().StringVarP(&codeGenPatterns, "codegen", "g", "", "Comma-separated list of glob patterns for code-generated files")
|
||||
filesCmd.Flags().StringVarP(&ignorePatterns, "ignore", "i", "", "Comma-separated list of glob patterns for files to ignore")
|
||||
}
|
||||
|
||||
32
cmd/root.go
32
cmd/root.go
@@ -1,8 +1,10 @@
|
||||
package cmd
|
||||
|
||||
import (
|
||||
"log"
|
||||
|
||||
"github.com/spf13/cobra"
|
||||
config "github.com/tnypxl/rollup/internal/config"
|
||||
"github.com/tnypxl/rollup/internal/config"
|
||||
)
|
||||
|
||||
var (
|
||||
@@ -15,13 +17,31 @@ var rootCmd = &cobra.Command{
|
||||
Short: "Rollup is a tool for combining and processing files",
|
||||
Long: `Rollup is a versatile tool that can combine and process files in various ways.
|
||||
Use subcommands to perform specific operations.`,
|
||||
PersistentPreRunE: func(cmd *cobra.Command, args []string) error {
|
||||
// Skip config loading for generate and help commands
|
||||
if cmd.Name() == "generate" || cmd.Name() == "help" {
|
||||
return nil
|
||||
}
|
||||
|
||||
// Determine config path
|
||||
configPath := configFile
|
||||
if configPath == "" {
|
||||
configPath = "rollup.yml"
|
||||
}
|
||||
|
||||
// Load configuration
|
||||
var err error
|
||||
cfg, err = config.Load(configPath)
|
||||
if err != nil {
|
||||
log.Printf("Warning: Failed to load configuration from %s: %v", configPath, err)
|
||||
cfg = &config.Config{} // Use empty config if loading fails
|
||||
}
|
||||
|
||||
return nil
|
||||
},
|
||||
}
|
||||
|
||||
func Execute(conf *config.Config) error {
|
||||
if conf == nil {
|
||||
conf = &config.Config{} // Use an empty config if none is provided
|
||||
}
|
||||
cfg = conf // Set the cfg variable in cmd/files.go
|
||||
func Execute() error {
|
||||
return rootCmd.Execute()
|
||||
}
|
||||
|
||||
|
||||
119
cmd/web.go
119
cmd/web.go
@@ -28,12 +28,26 @@ var webCmd = &cobra.Command{
|
||||
Use: "web",
|
||||
Short: "Scrape main content from webpages and convert to Markdown",
|
||||
Long: `Scrape the main content from one or more webpages, ignoring navigational elements, ads, and other UI aspects. Convert the content to a well-structured Markdown file.`,
|
||||
RunE: runWeb,
|
||||
PreRunE: func(cmd *cobra.Command, args []string) error {
|
||||
// Setup logger before initializing Playwright
|
||||
scraper.SetupLogger(verbose)
|
||||
// Initialize Playwright for web scraping
|
||||
if err := scraper.InitPlaywright(); err != nil {
|
||||
return fmt.Errorf("failed to initialize Playwright: %w", err)
|
||||
}
|
||||
return nil
|
||||
},
|
||||
RunE: runWeb,
|
||||
PostRunE: func(cmd *cobra.Command, args []string) error {
|
||||
// Clean up Playwright resources
|
||||
scraper.ClosePlaywright()
|
||||
return nil
|
||||
},
|
||||
}
|
||||
|
||||
func init() {
|
||||
webCmd.Flags().StringSliceVarP(&urls, "urls", "u", []string{}, "URLs of the webpages to scrape (comma-separated)")
|
||||
webCmd.Flags().StringVarP(&outputType, "output", "o", "single", "Output type: 'single' for one file, 'separate' for multiple files")
|
||||
webCmd.Flags().StringVarP(&outputType, "output", "o", "", "Output type: 'single' for one file, 'separate' for multiple files")
|
||||
webCmd.Flags().StringVar(&includeSelector, "css", "", "CSS selector to extract specific content")
|
||||
webCmd.Flags().StringSliceVar(&excludeSelectors, "exclude", []string{}, "CSS selectors to exclude from the extracted content (comma-separated)")
|
||||
}
|
||||
@@ -58,7 +72,6 @@ func runWeb(cmd *cobra.Command, args []string) error {
|
||||
ExcludeSelectors: site.ExcludeSelectors,
|
||||
AllowedPaths: site.AllowedPaths,
|
||||
ExcludePaths: site.ExcludePaths,
|
||||
OutputAlias: site.OutputAlias,
|
||||
PathOverrides: convertPathOverrides(site.PathOverrides),
|
||||
}
|
||||
logger.Printf("Site %d configuration: BaseURL=%s, CSSLocator=%s, AllowedPaths=%v",
|
||||
@@ -72,6 +85,7 @@ func runWeb(cmd *cobra.Command, args []string) error {
|
||||
BaseURL: u,
|
||||
CSSLocator: includeSelector,
|
||||
ExcludeSelectors: excludeSelectors,
|
||||
AllowedPaths: []string{""},
|
||||
}
|
||||
logger.Printf("URL %d configuration: BaseURL=%s, CSSLocator=%s",
|
||||
i+1, u, includeSelector)
|
||||
@@ -132,7 +146,7 @@ func runWeb(cmd *cobra.Command, args []string) error {
|
||||
}
|
||||
}()
|
||||
|
||||
scrapedContent, err := scraper.ScrapeSites(scraperConfig)
|
||||
err := scraper.ScrapeSites(scraperConfig)
|
||||
done <- true
|
||||
fmt.Println() // New line after progress indicator
|
||||
|
||||
@@ -140,106 +154,11 @@ func runWeb(cmd *cobra.Command, args []string) error {
|
||||
logger.Printf("Error occurred during scraping: %v", err)
|
||||
return fmt.Errorf("error scraping content: %v", err)
|
||||
}
|
||||
logger.Printf("Scraping completed. Total content scraped: %d", len(scrapedContent))
|
||||
|
||||
if outputType == "single" {
|
||||
logger.Println("Writing content to a single file")
|
||||
return writeSingleFile(scrapedContent)
|
||||
} else {
|
||||
logger.Println("Writing content to multiple files")
|
||||
return writeMultipleFiles(scrapedContent)
|
||||
}
|
||||
}
|
||||
|
||||
func writeSingleFile(content map[string]string) error {
|
||||
outputFile := generateDefaultFilename()
|
||||
file, err := os.Create(outputFile)
|
||||
if err != nil {
|
||||
return fmt.Errorf("error creating output file: %v", err)
|
||||
}
|
||||
defer file.Close()
|
||||
|
||||
for url, c := range content {
|
||||
_, err = fmt.Fprintf(file, "# ::: Content from %s\n\n%s\n\n---\n\n", url, c)
|
||||
if err != nil {
|
||||
return fmt.Errorf("error writing content to file: %v", err)
|
||||
}
|
||||
}
|
||||
|
||||
fmt.Printf("Content has been extracted from %d URL(s) and saved to %s\n", len(content), outputFile)
|
||||
return nil
|
||||
}
|
||||
|
||||
func writeMultipleFiles(content map[string]string) error {
|
||||
for url, c := range content {
|
||||
filename, err := getFilenameFromContent(c, url)
|
||||
if err != nil {
|
||||
return fmt.Errorf("error generating filename for %s: %v", url, err)
|
||||
}
|
||||
|
||||
file, err := os.Create(filename)
|
||||
if err != nil {
|
||||
return fmt.Errorf("error creating output file %s: %v", filename, err)
|
||||
}
|
||||
|
||||
_, err = file.WriteString(fmt.Sprintf("# ::: Content from %s\n\n%s\n", url, c))
|
||||
if err != nil {
|
||||
file.Close()
|
||||
return fmt.Errorf("error writing content to file %s: %v", filename, err)
|
||||
}
|
||||
|
||||
file.Close()
|
||||
fmt.Printf("Content from %s has been saved to %s\n", url, filename)
|
||||
}
|
||||
logger.Println("Scraping completed")
|
||||
|
||||
return nil
|
||||
}
|
||||
|
||||
func generateDefaultFilename() string {
|
||||
timestamp := time.Now().Format("20060102-150405")
|
||||
return fmt.Sprintf("web-%s.rollup.md", timestamp)
|
||||
}
|
||||
|
||||
func scrapeURL(urlStr string) (string, error) {
|
||||
content, err := testExtractAndConvertContent(urlStr)
|
||||
if err != nil {
|
||||
return "", err
|
||||
}
|
||||
|
||||
return content, nil
|
||||
}
|
||||
|
||||
var (
|
||||
testExtractAndConvertContent = extractAndConvertContent
|
||||
)
|
||||
|
||||
func extractAndConvertContent(urlStr string) (string, error) {
|
||||
content, err := scraper.FetchWebpageContent(urlStr)
|
||||
if err != nil {
|
||||
return "", fmt.Errorf("error fetching webpage content: %v", err)
|
||||
}
|
||||
|
||||
if includeSelector != "" {
|
||||
content, err = scraper.ExtractContentWithCSS(content, includeSelector, excludeSelectors)
|
||||
if err != nil {
|
||||
return "", fmt.Errorf("error extracting content with CSS: %v", err)
|
||||
}
|
||||
}
|
||||
|
||||
markdown, err := scraper.ProcessHTMLContent(content, scraper.Config{})
|
||||
if err != nil {
|
||||
return "", fmt.Errorf("error processing HTML content: %v", err)
|
||||
}
|
||||
|
||||
parsedURL, err := url.Parse(urlStr)
|
||||
if err != nil {
|
||||
return "", fmt.Errorf("error parsing URL: %v", err)
|
||||
}
|
||||
header := fmt.Sprintf("# ::: Content from %s\n\n", parsedURL.String())
|
||||
|
||||
return header + markdown + "\n\n", nil
|
||||
}
|
||||
|
||||
func getFilenameFromContent(content, urlStr string) (string, error) {
|
||||
// Try to extract title from content
|
||||
titleStart := strings.Index(content, "<title>")
|
||||
|
||||
@@ -2,7 +2,7 @@ package cmd
|
||||
|
||||
import (
|
||||
"testing"
|
||||
"strings"
|
||||
|
||||
"github.com/tnypxl/rollup/internal/config"
|
||||
)
|
||||
|
||||
@@ -67,9 +67,9 @@ func TestSanitizeFilename(t *testing.T) {
|
||||
|
||||
func TestGetFilenameFromContent(t *testing.T) {
|
||||
tests := []struct {
|
||||
content string
|
||||
url string
|
||||
expected string
|
||||
content string
|
||||
url string
|
||||
expected string
|
||||
expectErr bool
|
||||
}{
|
||||
{"<title>Test Page</title>", "http://example.com", "Test_Page.rollup.md", false},
|
||||
@@ -97,58 +97,3 @@ func TestGetFilenameFromContent(t *testing.T) {
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
// Mock functions for testing
|
||||
func mockExtractAndConvertContent(urlStr string) (string, error) {
|
||||
return "Mocked content for " + urlStr, nil
|
||||
}
|
||||
|
||||
func mockExtractLinks() ([]string, error) {
|
||||
return []string{"http://example.com/link1", "http://example.com/link2"}, nil
|
||||
}
|
||||
|
||||
func TestScrapeURL(t *testing.T) {
|
||||
// Store the original functions
|
||||
originalExtractAndConvertContent := testExtractAndConvertContent
|
||||
originalExtractLinks := testExtractLinks
|
||||
|
||||
// Define mock functions
|
||||
testExtractAndConvertContent = func(urlStr string) (string, error) {
|
||||
return "Mocked content for " + urlStr, nil
|
||||
}
|
||||
testExtractLinks = func(urlStr string) ([]string, error) {
|
||||
return []string{"http://example.com/link1", "http://example.com/link2"}, nil
|
||||
}
|
||||
|
||||
// Defer the restoration of original functions
|
||||
defer func() {
|
||||
testExtractAndConvertContent = originalExtractAndConvertContent
|
||||
testExtractLinks = originalExtractLinks
|
||||
}()
|
||||
|
||||
tests := []struct {
|
||||
url string
|
||||
depth int
|
||||
expectedCalls int
|
||||
}{
|
||||
{"http://example.com", 0, 1},
|
||||
{"http://example.com", 1, 3},
|
||||
{"http://example.com", 2, 3}, // Same as depth 1 because our mock only returns 2 links
|
||||
}
|
||||
|
||||
for _, test := range tests {
|
||||
visited := make(map[string]bool)
|
||||
content, err := scrapeURL(test.url, test.depth, visited)
|
||||
if err != nil {
|
||||
t.Errorf("scrapeURL(%q, %d) returned error: %v", test.url, test.depth, err)
|
||||
continue
|
||||
}
|
||||
if len(visited) != test.expectedCalls {
|
||||
t.Errorf("scrapeURL(%q, %d) made %d calls, expected %d", test.url, test.depth, len(visited), test.expectedCalls)
|
||||
}
|
||||
expectedContent := "Mocked content for " + test.url
|
||||
if !strings.Contains(content, expectedContent) {
|
||||
t.Errorf("scrapeURL(%q, %d) content doesn't contain %q", test.url, test.depth, expectedContent)
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@@ -48,8 +48,8 @@ type SiteConfig struct {
|
||||
// ExcludePaths lists paths that should not be scraped
|
||||
ExcludePaths []string `yaml:"exclude_paths"`
|
||||
|
||||
// OutputAlias provides an alternative name for output files
|
||||
OutputAlias string `yaml:"output_alias"`
|
||||
// FileNamePrefix provides the base name for output files
|
||||
FileNamePrefix string `yaml:"file_name_prefix"`
|
||||
|
||||
// PathOverrides allows for path-specific configurations
|
||||
PathOverrides []PathOverride `yaml:"path_overrides"`
|
||||
@@ -88,6 +88,14 @@ func Load(configPath string) (*Config, error) {
|
||||
|
||||
// Validate checks the configuration for any invalid values
|
||||
func (c *Config) Validate() error {
|
||||
if len(c.FileExtensions) == 0 && len(c.Sites) == 0 {
|
||||
return fmt.Errorf("file_extensions or sites must be specified")
|
||||
}
|
||||
|
||||
if c.OutputType != "" && c.OutputType != "single" && c.OutputType != "separate" {
|
||||
return fmt.Errorf("output_type must be 'single' or 'separate'")
|
||||
}
|
||||
|
||||
if c.RequestsPerSecond != nil && *c.RequestsPerSecond <= 0 {
|
||||
return fmt.Errorf("requests_per_second must be positive")
|
||||
}
|
||||
|
||||
@@ -10,8 +10,8 @@ func TestLoad(t *testing.T) {
|
||||
// Create a temporary config file
|
||||
content := []byte(`
|
||||
file_extensions:
|
||||
- .go
|
||||
- .md
|
||||
- go
|
||||
- md
|
||||
ignore_paths:
|
||||
- "*.tmp"
|
||||
- "**/*.log"
|
||||
@@ -27,7 +27,7 @@ sites:
|
||||
- "/blog"
|
||||
exclude_paths:
|
||||
- "/admin"
|
||||
output_alias: "example"
|
||||
file_name_prefix: "example"
|
||||
path_overrides:
|
||||
- path: "/special"
|
||||
css_locator: ".special-content"
|
||||
@@ -61,7 +61,7 @@ burst_limit: 5
|
||||
rps := 1.0
|
||||
bl := 5
|
||||
expectedConfig := &Config{
|
||||
FileExtensions: []string{".go", ".md"},
|
||||
FileExtensions: []string{"go", "md"},
|
||||
IgnorePaths: []string{"*.tmp", "**/*.log"},
|
||||
CodeGeneratedPaths: []string{"generated_*.go"},
|
||||
Sites: []SiteConfig{
|
||||
@@ -69,10 +69,9 @@ burst_limit: 5
|
||||
BaseURL: "https://example.com",
|
||||
CSSLocator: "main",
|
||||
ExcludeSelectors: []string{".ads"},
|
||||
MaxDepth: 2,
|
||||
AllowedPaths: []string{"/blog"},
|
||||
ExcludePaths: []string{"/admin"},
|
||||
OutputAlias: "example",
|
||||
FileNamePrefix: "example",
|
||||
PathOverrides: []PathOverride{
|
||||
{
|
||||
Path: "/special",
|
||||
@@ -101,9 +100,9 @@ func TestValidate(t *testing.T) {
|
||||
{
|
||||
name: "Valid config",
|
||||
config: Config{
|
||||
FileExtensions: []string{".go"},
|
||||
FileExtensions: []string{"go"},
|
||||
Sites: []SiteConfig{
|
||||
{BaseURL: "https://example.com", MaxDepth: 2},
|
||||
{BaseURL: "https://example.com"},
|
||||
},
|
||||
},
|
||||
wantErr: false,
|
||||
@@ -116,7 +115,7 @@ func TestValidate(t *testing.T) {
|
||||
{
|
||||
name: "Invalid requests per second",
|
||||
config: Config{
|
||||
FileExtensions: []string{".go"},
|
||||
FileExtensions: []string{"go"},
|
||||
RequestsPerSecond: func() *float64 { f := -1.0; return &f }(),
|
||||
},
|
||||
wantErr: true,
|
||||
@@ -124,7 +123,7 @@ func TestValidate(t *testing.T) {
|
||||
{
|
||||
name: "Invalid burst limit",
|
||||
config: Config{
|
||||
FileExtensions: []string{".go"},
|
||||
FileExtensions: []string{"go"},
|
||||
BurstLimit: func() *int { i := -1; return &i }(),
|
||||
},
|
||||
wantErr: true,
|
||||
@@ -132,16 +131,32 @@ func TestValidate(t *testing.T) {
|
||||
{
|
||||
name: "Site without base URL",
|
||||
config: Config{
|
||||
FileExtensions: []string{".go"},
|
||||
FileExtensions: []string{"go"},
|
||||
Sites: []SiteConfig{{}},
|
||||
},
|
||||
wantErr: true,
|
||||
},
|
||||
{
|
||||
name: "Negative max depth",
|
||||
name: "Valid output type single",
|
||||
config: Config{
|
||||
FileExtensions: []string{".go"},
|
||||
Sites: []SiteConfig{{BaseURL: "https://example.com", MaxDepth: -1}},
|
||||
FileExtensions: []string{"go"},
|
||||
OutputType: "single",
|
||||
},
|
||||
wantErr: false,
|
||||
},
|
||||
{
|
||||
name: "Valid output type separate",
|
||||
config: Config{
|
||||
FileExtensions: []string{"go"},
|
||||
OutputType: "separate",
|
||||
},
|
||||
wantErr: false,
|
||||
},
|
||||
{
|
||||
name: "Invalid output type",
|
||||
config: Config{
|
||||
FileExtensions: []string{"go"},
|
||||
OutputType: "invalid",
|
||||
},
|
||||
wantErr: true,
|
||||
},
|
||||
|
||||
@@ -8,6 +8,7 @@ import (
|
||||
"math/rand"
|
||||
"net/url"
|
||||
"os"
|
||||
"path/filepath"
|
||||
"regexp"
|
||||
"strings"
|
||||
"sync"
|
||||
@@ -47,7 +48,7 @@ type SiteConfig struct {
|
||||
ExcludeSelectors []string
|
||||
AllowedPaths []string
|
||||
ExcludePaths []string
|
||||
OutputAlias string
|
||||
FileNamePrefix string
|
||||
PathOverrides []PathOverride
|
||||
}
|
||||
|
||||
@@ -58,19 +59,24 @@ type PathOverride struct {
|
||||
ExcludeSelectors []string
|
||||
}
|
||||
|
||||
func ScrapeSites(config Config) (map[string]string, error) {
|
||||
func ScrapeSites(config Config) error {
|
||||
logger.Println("Starting ScrapeSites function - Verbose mode is active")
|
||||
results := make(chan struct {
|
||||
url string
|
||||
content string
|
||||
site SiteConfig // Add site config to track which site the content came from
|
||||
err error
|
||||
})
|
||||
|
||||
limiter := rate.NewLimiter(rate.Limit(config.Scrape.RequestsPerSecond), config.Scrape.BurstLimit)
|
||||
logger.Printf("Rate limiter configured with %f requests per second and burst limit of %d\n", config.Scrape.RequestsPerSecond, config.Scrape.BurstLimit)
|
||||
logger.Printf("Rate limiter configured with %f requests per second and burst limit of %d\n",
|
||||
config.Scrape.RequestsPerSecond, config.Scrape.BurstLimit)
|
||||
|
||||
var wg sync.WaitGroup
|
||||
totalURLs := 0
|
||||
for _, site := range config.Sites {
|
||||
totalURLs += len(site.AllowedPaths)
|
||||
}
|
||||
for _, site := range config.Sites {
|
||||
logger.Printf("Processing site: %s\n", site.BaseURL)
|
||||
wg.Add(1)
|
||||
@@ -78,7 +84,6 @@ func ScrapeSites(config Config) (map[string]string, error) {
|
||||
defer wg.Done()
|
||||
for _, path := range site.AllowedPaths {
|
||||
fullURL := site.BaseURL + path
|
||||
totalURLs++
|
||||
logger.Printf("Queueing URL for scraping: %s\n", fullURL)
|
||||
scrapeSingleURL(fullURL, site, results, limiter)
|
||||
}
|
||||
@@ -91,71 +96,73 @@ func ScrapeSites(config Config) (map[string]string, error) {
|
||||
logger.Println("All goroutines completed, results channel closed")
|
||||
}()
|
||||
|
||||
scrapedContent := make(map[string]string)
|
||||
// Use a map that includes site configuration
|
||||
scrapedContent := make(map[string]struct {
|
||||
content string
|
||||
site SiteConfig
|
||||
})
|
||||
|
||||
for result := range results {
|
||||
if result.err != nil {
|
||||
logger.Printf("Error scraping %s: %v\n", result.url, result.err)
|
||||
continue
|
||||
}
|
||||
logger.Printf("Successfully scraped content from %s (length: %d)\n", result.url, len(result.content))
|
||||
scrapedContent[result.url] = result.content
|
||||
logger.Printf("Successfully scraped content from %s (length: %d)\n",
|
||||
result.url, len(result.content))
|
||||
scrapedContent[result.url] = struct {
|
||||
content string
|
||||
site SiteConfig
|
||||
}{
|
||||
content: result.content,
|
||||
site: result.site,
|
||||
}
|
||||
}
|
||||
|
||||
logger.Printf("Total URLs processed: %d\n", totalURLs)
|
||||
logger.Printf("Successfully scraped content from %d URLs\n", len(scrapedContent))
|
||||
|
||||
return scrapedContent, nil
|
||||
return SaveToFiles(scrapedContent, config)
|
||||
}
|
||||
|
||||
func scrapeSingleURL(url string, site SiteConfig, results chan<- struct {
|
||||
url string
|
||||
content string
|
||||
site SiteConfig
|
||||
err error
|
||||
}, limiter *rate.Limiter,
|
||||
) {
|
||||
}, limiter *rate.Limiter) {
|
||||
logger.Printf("Starting to scrape URL: %s\n", url)
|
||||
|
||||
// Wait for rate limiter before making the request
|
||||
err := limiter.Wait(context.Background())
|
||||
if err != nil {
|
||||
logger.Printf("Rate limiter error for %s: %v\n", url, err)
|
||||
results <- struct {
|
||||
url string
|
||||
content string
|
||||
site SiteConfig
|
||||
err error
|
||||
}{url, "", fmt.Errorf("rate limiter error: %v", err)}
|
||||
}{url, "", site, fmt.Errorf("rate limiter error: %v", err)}
|
||||
return
|
||||
}
|
||||
|
||||
cssLocator, excludeSelectors := getOverrides(url, site)
|
||||
logger.Printf("Using CSS locator for %s: %s\n", url, cssLocator)
|
||||
logger.Printf("Exclude selectors for %s: %v\n", url, excludeSelectors)
|
||||
|
||||
content, err := scrapeURL(url, cssLocator, excludeSelectors)
|
||||
if err != nil {
|
||||
logger.Printf("Error scraping %s: %v\n", url, err)
|
||||
results <- struct {
|
||||
url string
|
||||
content string
|
||||
site SiteConfig
|
||||
err error
|
||||
}{url, "", err}
|
||||
}{url, "", site, err}
|
||||
return
|
||||
}
|
||||
|
||||
if content == "" {
|
||||
logger.Printf("Warning: Empty content scraped from %s\n", url)
|
||||
} else {
|
||||
logger.Printf("Successfully scraped content from %s (length: %d)\n", url, len(content))
|
||||
}
|
||||
|
||||
results <- struct {
|
||||
url string
|
||||
content string
|
||||
site SiteConfig
|
||||
err error
|
||||
}{url, content, nil}
|
||||
}{url, content, site, nil}
|
||||
}
|
||||
|
||||
|
||||
func isAllowedURL(urlStr string, site SiteConfig) bool {
|
||||
parsedURL, err := url.Parse(urlStr)
|
||||
if err != nil {
|
||||
@@ -228,9 +235,14 @@ func getFilenameFromContent(content, url string) string {
|
||||
}
|
||||
|
||||
func sanitizeFilename(name string) string {
|
||||
// Remove any character that isn't alphanumeric, dash, or underscore
|
||||
reg, _ := regexp.Compile("[^a-zA-Z0-9-_]+")
|
||||
return reg.ReplaceAllString(name, "_")
|
||||
// Replace all non-alphanumeric characters with dashes
|
||||
reg := regexp.MustCompile("[^a-zA-Z0-9]+")
|
||||
name = reg.ReplaceAllString(name, "-")
|
||||
// Remove any leading or trailing dashes
|
||||
name = strings.Trim(name, "-")
|
||||
// Collapse multiple consecutive dashes into one
|
||||
reg = regexp.MustCompile("-+")
|
||||
return reg.ReplaceAllString(name, "-")
|
||||
}
|
||||
|
||||
// URLConfig holds configuration for a single URL
|
||||
@@ -238,7 +250,7 @@ type URLConfig struct {
|
||||
URL string
|
||||
CSSLocator string
|
||||
ExcludeSelectors []string
|
||||
OutputAlias string
|
||||
FileNamePrefix string
|
||||
}
|
||||
|
||||
// SetupLogger initializes the logger based on the verbose flag
|
||||
@@ -266,7 +278,7 @@ func InitPlaywright() error {
|
||||
return fmt.Errorf("could not start Playwright: %v", err)
|
||||
}
|
||||
|
||||
userAgent := "Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/91.0.4472.124 Safari/537.36"
|
||||
userAgent := "Mozilla/5.0 (Linux; Android 15; Pixel 9 Build/AP3A.241105.008) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/130.0.6723.106 Mobile Safari/537.36 OPX/2.5"
|
||||
|
||||
browser, err = pw.Chromium.Launch(playwright.BrowserTypeLaunchOptions{
|
||||
Args: []string{fmt.Sprintf("--user-agent=%s", userAgent)},
|
||||
@@ -299,6 +311,119 @@ func CloseBrowser() {
|
||||
ClosePlaywright()
|
||||
}
|
||||
|
||||
// SaveToFiles writes the scraped content to files based on output type
|
||||
func SaveToFiles(content map[string]struct {
|
||||
content string
|
||||
site SiteConfig
|
||||
}, config Config) error {
|
||||
if config.OutputType == "" {
|
||||
config.OutputType = "separate" // default to separate files if not specified
|
||||
}
|
||||
|
||||
switch config.OutputType {
|
||||
case "single":
|
||||
if err := os.MkdirAll("output", 0755); err != nil {
|
||||
return fmt.Errorf("failed to create output directory: %v", err)
|
||||
}
|
||||
var combined strings.Builder
|
||||
for url, data := range content {
|
||||
combined.WriteString(fmt.Sprintf("## %s\n\n", url))
|
||||
combined.WriteString(data.content)
|
||||
combined.WriteString("\n\n")
|
||||
}
|
||||
return os.WriteFile(filepath.Join("output", "combined.md"), []byte(combined.String()), 0644)
|
||||
|
||||
case "separate":
|
||||
if err := os.MkdirAll("output", 0755); err != nil {
|
||||
return fmt.Errorf("failed to create output directory: %v", err)
|
||||
}
|
||||
|
||||
// Group content by site and path
|
||||
contentBySitePath := make(map[string]map[string]string)
|
||||
for urlStr, data := range content {
|
||||
parsedURL, err := url.Parse(urlStr)
|
||||
if err != nil {
|
||||
logger.Printf("Warning: Could not parse URL %s: %v", urlStr, err)
|
||||
continue
|
||||
}
|
||||
|
||||
// Find matching allowed path for this URL
|
||||
var matchingPath string
|
||||
for _, path := range data.site.AllowedPaths {
|
||||
if strings.HasPrefix(parsedURL.Path, path) {
|
||||
matchingPath = path
|
||||
break
|
||||
}
|
||||
}
|
||||
if matchingPath == "" {
|
||||
logger.Printf("Warning: No matching allowed path for URL %s", urlStr)
|
||||
continue
|
||||
}
|
||||
|
||||
siteKey := fmt.Sprintf("%s-%s", data.site.BaseURL, data.site.FileNamePrefix)
|
||||
if contentBySitePath[siteKey] == nil {
|
||||
contentBySitePath[siteKey] = make(map[string]string)
|
||||
}
|
||||
|
||||
// Combine all content for the same path
|
||||
if existing, exists := contentBySitePath[siteKey][matchingPath]; exists {
|
||||
contentBySitePath[siteKey][matchingPath] = existing + "\n\n" + data.content
|
||||
} else {
|
||||
contentBySitePath[siteKey][matchingPath] = data.content
|
||||
}
|
||||
}
|
||||
|
||||
// Write files for each site and path
|
||||
for siteKey, pathContent := range contentBySitePath {
|
||||
for path, content := range pathContent {
|
||||
parts := strings.SplitN(siteKey, "-", 2) // Split only on first hyphen
|
||||
prefix := parts[1] // Get the FileNamePrefix part
|
||||
if prefix == "" {
|
||||
prefix = "doc" // default prefix if none specified
|
||||
}
|
||||
|
||||
normalizedPath := NormalizePathForFilename(path)
|
||||
if normalizedPath == "" {
|
||||
normalizedPath = "index"
|
||||
}
|
||||
|
||||
filename := filepath.Join("output", fmt.Sprintf("%s-%s.md",
|
||||
prefix, normalizedPath))
|
||||
|
||||
// Ensure we don't have empty files
|
||||
if strings.TrimSpace(content) == "" {
|
||||
logger.Printf("Skipping empty content for path %s", path)
|
||||
continue
|
||||
}
|
||||
|
||||
if err := os.WriteFile(filename, []byte(content), 0644); err != nil {
|
||||
return fmt.Errorf("failed to write file %s: %v", filename, err)
|
||||
}
|
||||
logger.Printf("Wrote content to %s", filename)
|
||||
}
|
||||
}
|
||||
return nil
|
||||
|
||||
default:
|
||||
return fmt.Errorf("unsupported output type: %s", config.OutputType)
|
||||
}
|
||||
}
|
||||
|
||||
// NormalizePathForFilename converts a URL path into a valid filename component
|
||||
func NormalizePathForFilename(urlPath string) string {
|
||||
// Remove leading/trailing slashes
|
||||
path := strings.Trim(urlPath, "/")
|
||||
// Replace all non-alphanumeric characters with dashes
|
||||
reg := regexp.MustCompile("[^a-zA-Z0-9]+")
|
||||
path = reg.ReplaceAllString(path, "-")
|
||||
// Remove any leading or trailing dashes
|
||||
path = strings.Trim(path, "-")
|
||||
// Collapse multiple consecutive dashes into one
|
||||
reg = regexp.MustCompile("-+")
|
||||
path = reg.ReplaceAllString(path, "-")
|
||||
return path
|
||||
}
|
||||
|
||||
// FetchWebpageContent retrieves the content of a webpage using Playwright
|
||||
func FetchWebpageContent(urlStr string) (string, error) {
|
||||
logger.Printf("Fetching webpage content for URL: %s\n", urlStr)
|
||||
@@ -409,8 +534,6 @@ func scrollPage(page playwright.Page) error {
|
||||
() => {
|
||||
window.scrollTo(0, document.body.scrollHeight);
|
||||
return document.body.scrollHeight;
|
||||
// wait for 500 ms
|
||||
new Promise(resolve => setTimeout(resolve, 500));
|
||||
}
|
||||
`
|
||||
|
||||
@@ -442,9 +565,8 @@ func scrollPage(page playwright.Page) error {
|
||||
|
||||
previousHeight = currentHeight
|
||||
|
||||
// Wait for a while before scrolling again
|
||||
|
||||
|
||||
// Wait for content to load before scrolling again
|
||||
time.Sleep(100 * time.Millisecond)
|
||||
}
|
||||
|
||||
logger.Println("Scrolling back to top")
|
||||
@@ -458,7 +580,6 @@ func scrollPage(page playwright.Page) error {
|
||||
return nil
|
||||
}
|
||||
|
||||
|
||||
// ExtractContentWithCSS extracts content from HTML using a CSS selector
|
||||
func ExtractContentWithCSS(content, includeSelector string, excludeSelectors []string) (string, error) {
|
||||
logger.Printf("Extracting content with CSS selector: %s\n", includeSelector)
|
||||
|
||||
@@ -3,8 +3,8 @@ package scraper
|
||||
import (
|
||||
"io"
|
||||
"log"
|
||||
"net/http"
|
||||
"net/http/httptest"
|
||||
// "net/http"
|
||||
// "net/http/httptest"
|
||||
"reflect"
|
||||
"strings"
|
||||
"testing"
|
||||
@@ -143,39 +143,39 @@ This is a **test** paragraph.
|
||||
}
|
||||
}
|
||||
|
||||
func TestExtractLinks(t *testing.T) {
|
||||
// Initialize Playwright before running the test
|
||||
if err := InitPlaywright(); err != nil {
|
||||
t.Fatalf("Failed to initialize Playwright: %v", err)
|
||||
}
|
||||
defer ClosePlaywright()
|
||||
// func TestExtractLinks(t *testing.T) {
|
||||
// // Initialize Playwright before running the test
|
||||
// if err := InitPlaywright(); err != nil {
|
||||
// t.Fatalf("Failed to initialize Playwright: %v", err)
|
||||
// }
|
||||
// defer ClosePlaywright()
|
||||
|
||||
server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
||||
w.Header().Set("Content-Type", "text/html")
|
||||
w.Write([]byte(`
|
||||
<html>
|
||||
<body>
|
||||
<a href="https://example.com/page1">Page 1</a>
|
||||
<a href="https://example.com/page2">Page 2</a>
|
||||
<a href="https://othersite.com">Other Site</a>
|
||||
</body>
|
||||
</html>
|
||||
`))
|
||||
}))
|
||||
defer server.Close()
|
||||
// server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
||||
// w.Header().Set("Content-Type", "text/html")
|
||||
// w.Write([]byte(`
|
||||
// <html>
|
||||
// <body>
|
||||
// <a href="https://example.com/page1">Page 1</a>
|
||||
// <a href="https://example.com/page2">Page 2</a>
|
||||
// <a href="https://othersite.com">Other Site</a>
|
||||
// </body>
|
||||
// </html>
|
||||
// `))
|
||||
// }))
|
||||
// defer server.Close()
|
||||
|
||||
links, err := ExtractLinks(server.URL)
|
||||
if err != nil {
|
||||
t.Fatalf("ExtractLinks() returned error: %v", err)
|
||||
}
|
||||
// links, err := ExtractLinks(server.URL)
|
||||
// if err != nil {
|
||||
// t.Fatalf("ExtractLinks() returned error: %v", err)
|
||||
// }
|
||||
|
||||
expectedLinks := []string{
|
||||
"https://example.com/page1",
|
||||
"https://example.com/page2",
|
||||
"https://othersite.com",
|
||||
}
|
||||
// expectedLinks := []string{
|
||||
// "https://example.com/page1",
|
||||
// "https://example.com/page2",
|
||||
// "https://othersite.com",
|
||||
// }
|
||||
|
||||
if !reflect.DeepEqual(links, expectedLinks) {
|
||||
t.Errorf("ExtractLinks() = %v, want %v", links, expectedLinks)
|
||||
}
|
||||
}
|
||||
// if !reflect.DeepEqual(links, expectedLinks) {
|
||||
// t.Errorf("ExtractLinks() = %v, want %v", links, expectedLinks)
|
||||
// }
|
||||
// }
|
||||
|
||||
31
main.go
31
main.go
@@ -2,42 +2,13 @@ package main
|
||||
|
||||
import (
|
||||
"fmt"
|
||||
"log"
|
||||
"os"
|
||||
|
||||
"github.com/tnypxl/rollup/cmd"
|
||||
"github.com/tnypxl/rollup/internal/config"
|
||||
"github.com/tnypxl/rollup/internal/scraper"
|
||||
)
|
||||
|
||||
var cfg *config.Config
|
||||
|
||||
func main() {
|
||||
// Check if the command is "help"
|
||||
isHelpCommand := len(os.Args) > 1 && (os.Args[1] == "help" || os.Args[1] == "--help" || os.Args[1] == "-h")
|
||||
|
||||
var cfg *config.Config
|
||||
var err error
|
||||
|
||||
if !isHelpCommand {
|
||||
configPath := "rollup.yml"
|
||||
cfg, err = config.Load(configPath)
|
||||
if err != nil {
|
||||
log.Printf("Warning: Failed to load configuration: %v", err)
|
||||
// Continue execution without a config file
|
||||
}
|
||||
|
||||
// Initialize the scraper logger with default verbosity (false)
|
||||
scraper.SetupLogger(false)
|
||||
|
||||
err = scraper.InitPlaywright()
|
||||
if err != nil {
|
||||
log.Fatalf("Failed to initialize Playwright: %v", err)
|
||||
}
|
||||
defer scraper.ClosePlaywright()
|
||||
}
|
||||
|
||||
if err := cmd.Execute(cfg); err != nil {
|
||||
if err := cmd.Execute(); err != nil {
|
||||
fmt.Println(err)
|
||||
os.Exit(1)
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user