mirror of
https://github.com/NohamR/papeer.git
synced 2026-05-25 12:27:20 +00:00
Compare commits
4 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
008e4ebd7a | ||
|
|
5e735f9c52 | ||
|
|
29008185a8 | ||
|
|
ff3d09c727 |
10
Makefile
10
Makefile
@@ -1,10 +1,14 @@
|
|||||||
install:
|
|
||||||
go install
|
|
||||||
|
|
||||||
format:
|
format:
|
||||||
gofmt -s -w .
|
gofmt -s -w .
|
||||||
|
|
||||||
|
test:
|
||||||
|
go test github.com/lapwat/papeer/book
|
||||||
|
|
||||||
|
install:
|
||||||
|
go install
|
||||||
|
|
||||||
clean:
|
clean:
|
||||||
find . -maxdepth 1 -not -name 'README.md' -name '*.md' -delete
|
find . -maxdepth 1 -not -name 'README.md' -name '*.md' -delete
|
||||||
find . -maxdepth 1 -name '*.epub' -delete
|
find . -maxdepth 1 -name '*.epub' -delete
|
||||||
find . -maxdepth 1 -name '*.mobi' -delete
|
find . -maxdepth 1 -name '*.mobi' -delete
|
||||||
|
find . -maxdepth 1 -name 'papeer-v*' -delete
|
||||||
|
|||||||
50
README.md
50
README.md
@@ -29,6 +29,7 @@ Flags:
|
|||||||
-n, --name string book name (default: page title)
|
-n, --name string book name (default: page title)
|
||||||
-o, --offset int skip first chapters, in recursive mode
|
-o, --offset int skip first chapters, in recursive mode
|
||||||
--output string file name (default: book name)
|
--output string file name (default: book name)
|
||||||
|
-q, --quiet hide progress bar
|
||||||
-r, --recursive create one chapter per natigation item
|
-r, --recursive create one chapter per natigation item
|
||||||
-s, --selector string table of content CSS selector, in resursive mode
|
-s, --selector string table of content CSS selector, in resursive mode
|
||||||
-t, --threads int download concurrency, in recursive mode (default -1)
|
-t, --threads int download concurrency, in recursive mode (default -1)
|
||||||
@@ -59,13 +60,20 @@ The `recursive` option lets you extract the table of content of a website, then
|
|||||||
Before trying the `recursive` option, it is a good idea to use the `ls` option, which lets you vizualize the content that will be retrieved. You can use several options to customize the table of content extraction, such as `selector`, `limit`, `offset` and `include`. Type `papeer help` for more information about those options.
|
Before trying the `recursive` option, it is a good idea to use the `ls` option, which lets you vizualize the content that will be retrieved. You can use several options to customize the table of content extraction, such as `selector`, `limit`, `offset` and `include`. Type `papeer help` for more information about those options.
|
||||||
|
|
||||||
```sh
|
```sh
|
||||||
papeer ls https://news.ycombinator.com/ --limit=5
|
papeer ls https://12factor.net/ -s 'section.concrete > article > h2 > a'
|
||||||
# # NAME URL
|
# # NAME URL
|
||||||
# 1 Tailwind CSS v3.0 https://tailwindcss.com/blog/tailwindcss-v3
|
# 1 I. Codebase https://12factor.net/codebase
|
||||||
# 2 A molten salt storage solution using sodium hydroxide https://sifted.eu/articles/salt-energy-storage-seaborg-hyme/
|
# 2 II. Dependencies https://12factor.net/dependencies
|
||||||
# 3 HashiCorp IPO today https://www.hashicorp.com/blog/a-new-chapter-for-hashicorp
|
# 3 III. Config https://12factor.net/config
|
||||||
# 4 Stack Graphs https://github.blog/2021-12-09-introducing-stack-graphs/
|
# 4 IV. Backing services https://12factor.net/backing-services
|
||||||
# 5 ‘Tipping point’ makes partisan polarization irreversible https://news.cornell.edu/stories/2021/12/tipping-point-makes-partisan-polarization-irreversible
|
# 5 V. Build, release, run https://12factor.net/build-release-run
|
||||||
|
# 6 VI. Processes https://12factor.net/processes
|
||||||
|
# 7 VII. Port binding https://12factor.net/port-binding
|
||||||
|
# 8 VIII. Concurrency https://12factor.net/concurrency
|
||||||
|
# 9 IX. Disposability https://12factor.net/disposability
|
||||||
|
# 10 X. Dev/prod parity https://12factor.net/dev-prod-parity
|
||||||
|
# 11 XI. Logs https://12factor.net/logs
|
||||||
|
# 12 XII. Admin processes https://12factor.net/admin-processes
|
||||||
```
|
```
|
||||||
|
|
||||||
### Scrape time
|
### Scrape time
|
||||||
@@ -73,14 +81,21 @@ papeer ls https://news.ycombinator.com/ --limit=5
|
|||||||
Once you are satisfied with the table of content listed by the `ls` command, you can actually scrape the content of those pages. You can use the same options that you specified for the `ls` command. In recursive mode, you also have the possibility to use `delay` and `threads` options.
|
Once you are satisfied with the table of content listed by the `ls` command, you can actually scrape the content of those pages. You can use the same options that you specified for the `ls` command. In recursive mode, you also have the possibility to use `delay` and `threads` options.
|
||||||
|
|
||||||
```sh
|
```sh
|
||||||
papeer get https://news.ycombinator.com/ --recursive --delay=500 --limit=5 --format=md
|
papeer get https://12factor.net/ --recursive -s 'section.concrete > article > h2 > a' --format=md
|
||||||
# [========================================>---------------------------] Chapters 3 / 5
|
# [======================================>-----------------------------] Chapters 7 / 12
|
||||||
# [====================================================================] 1. Tailwind CSS v3.0
|
# [====================================================================] 1. I. Codebase
|
||||||
# [====================================================================] 2. A molten salt storage solution using sodium hydroxide
|
# [====================================================================] 2. II. Dependencies
|
||||||
# [====================================================================] 3. HashiCorp IPO today
|
# [====================================================================] 3. III. Config
|
||||||
# [--------------------------------------------------------------------] 4. Stack Graphs
|
# [====================================================================] 4. IV. Backing services
|
||||||
# [--------------------------------------------------------------------] 5. ‘Tipping point’ makes partisan polarization irreversible
|
# [====================================================================] 5. V. Build, release, run
|
||||||
# Markdown saved to "Hacker News.md"
|
# [====================================================================] 6. VI. Processes
|
||||||
|
# [====================================================================] 7. VII. Port binding
|
||||||
|
# [--------------------------------------------------------------------] 8. VIII. Concurrency
|
||||||
|
# [--------------------------------------------------------------------] 9. IX. Disposability
|
||||||
|
# [--------------------------------------------------------------------] 10. X. Dev/prod parity
|
||||||
|
# [--------------------------------------------------------------------] 11. XI. Logs
|
||||||
|
# [--------------------------------------------------------------------] 12. XII. Admin processes
|
||||||
|
# Markdown saved to "The_Twelve-Factor_App.md"
|
||||||
```
|
```
|
||||||
|
|
||||||
# Installation
|
# Installation
|
||||||
@@ -97,14 +112,15 @@ go get -u github.com/lapwat/papeer
|
|||||||
|
|
||||||
```sh
|
```sh
|
||||||
platform=linux # use platform=darwin for MacOS
|
platform=linux # use platform=darwin for MacOS
|
||||||
curl -L https://github.com/lapwat/papeer/releases/download/v0.3.1/papeer-v0.3.1-$platform-amd64 > papeer
|
release=0.3.3
|
||||||
|
curl -L https://github.com/lapwat/papeer/releases/download/v$release/papeer-v$release-$platform-amd64 > papeer
|
||||||
chmod +x papeer
|
chmod +x papeer
|
||||||
sudo mv papeer /usr/local/bin
|
sudo mv papeer /usr/local/bin
|
||||||
```
|
```
|
||||||
|
|
||||||
### On Windows
|
### On Windows
|
||||||
|
|
||||||
Download [latest release](https://github.com/lapwat/papeer/releases/download/v0.3.1/papeer-v0.3.1-windows-amd64.exe).
|
Download [latest release](https://github.com/lapwat/papeer/releases/download/3/papeer-v0.3.3-windows-amd64.exe).
|
||||||
|
|
||||||
## Install kindlegen to export websites to MOBI (optional)
|
## Install kindlegen to export websites to MOBI (optional)
|
||||||
|
|
||||||
|
|||||||
@@ -1,13 +1,20 @@
|
|||||||
package book
|
package book
|
||||||
|
|
||||||
type chapter struct {
|
type chapter struct {
|
||||||
name string
|
body string
|
||||||
author string
|
name string
|
||||||
content string
|
author string
|
||||||
|
content string
|
||||||
|
subChapters []chapter
|
||||||
|
config *ScrapeConfig
|
||||||
}
|
}
|
||||||
|
|
||||||
func NewChapter(name, author, content string) chapter {
|
func NewChapter(body, name, author, content string, subChapters []chapter, config *ScrapeConfig) chapter {
|
||||||
return chapter{name, author, content}
|
return chapter{body, name, author, content, subChapters, config}
|
||||||
|
}
|
||||||
|
|
||||||
|
func (c chapter) Body() string {
|
||||||
|
return c.body
|
||||||
}
|
}
|
||||||
|
|
||||||
func (c chapter) Name() string {
|
func (c chapter) Name() string {
|
||||||
@@ -21,3 +28,7 @@ func (c chapter) Author() string {
|
|||||||
func (c chapter) Content() string {
|
func (c chapter) Content() string {
|
||||||
return c.content
|
return c.content
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (c chapter) SubChapters() []chapter {
|
||||||
|
return c.subChapters
|
||||||
|
}
|
||||||
|
|||||||
143
book/format.go
Normal file
143
book/format.go
Normal file
@@ -0,0 +1,143 @@
|
|||||||
|
package book
|
||||||
|
|
||||||
|
import (
|
||||||
|
"fmt"
|
||||||
|
"log"
|
||||||
|
"os"
|
||||||
|
"os/exec"
|
||||||
|
"strings"
|
||||||
|
|
||||||
|
md "github.com/JohannesKaufmann/html-to-markdown"
|
||||||
|
"github.com/PuerkitoBio/goquery"
|
||||||
|
epub "github.com/bmaupin/go-epub"
|
||||||
|
)
|
||||||
|
|
||||||
|
func Filename(name string) string {
|
||||||
|
filename := name
|
||||||
|
|
||||||
|
filename = strings.ReplaceAll(filename, " ", "_")
|
||||||
|
filename = strings.ReplaceAll(filename, "/", "")
|
||||||
|
|
||||||
|
return filename
|
||||||
|
}
|
||||||
|
|
||||||
|
func ToMarkdown(c chapter) string {
|
||||||
|
markdown := ""
|
||||||
|
|
||||||
|
if c.config.include {
|
||||||
|
// title
|
||||||
|
markdown += fmt.Sprintf("%s\n", c.Name())
|
||||||
|
markdown += fmt.Sprintf("%s\n\n", strings.Repeat("=", len(c.Name())))
|
||||||
|
|
||||||
|
// convert content to markdown
|
||||||
|
content, err := md.NewConverter("", true, nil).ConvertString(c.Content())
|
||||||
|
if err != nil {
|
||||||
|
log.Fatal(err)
|
||||||
|
}
|
||||||
|
markdown += fmt.Sprintf("%s\n\n\n", content)
|
||||||
|
}
|
||||||
|
|
||||||
|
for _, sc := range c.SubChapters() {
|
||||||
|
// subchapters content
|
||||||
|
markdown += fmt.Sprintf("%s\n\n\n", ToMarkdown(sc))
|
||||||
|
}
|
||||||
|
|
||||||
|
return markdown
|
||||||
|
}
|
||||||
|
|
||||||
|
func ToEpub(c chapter, filename string) string {
|
||||||
|
if len(filename) == 0 {
|
||||||
|
filename = fmt.Sprintf("%s.epub", Filename(c.Name()))
|
||||||
|
}
|
||||||
|
|
||||||
|
// init ebook
|
||||||
|
e := epub.NewEpub(c.Name())
|
||||||
|
e.SetAuthor(c.Author())
|
||||||
|
|
||||||
|
AppendToEpub(e, c)
|
||||||
|
|
||||||
|
err := e.Write(filename)
|
||||||
|
if err != nil {
|
||||||
|
log.Fatal(err)
|
||||||
|
}
|
||||||
|
|
||||||
|
return filename
|
||||||
|
}
|
||||||
|
|
||||||
|
func AppendToEpub(e *epub.Epub, c chapter) {
|
||||||
|
content := ""
|
||||||
|
|
||||||
|
if c.config.include {
|
||||||
|
|
||||||
|
if c.config.imagesOnly == false {
|
||||||
|
content = c.Content()
|
||||||
|
}
|
||||||
|
|
||||||
|
// parse content
|
||||||
|
doc, err := goquery.NewDocumentFromReader(strings.NewReader(c.Content()))
|
||||||
|
if err != nil {
|
||||||
|
log.Fatal(err)
|
||||||
|
}
|
||||||
|
|
||||||
|
// download images and replace src in img tags of content
|
||||||
|
doc.Find("img").Each(func(i int, s *goquery.Selection) {
|
||||||
|
src, _ := s.Attr("src")
|
||||||
|
src = strings.Split(src, "?")[0] // remove query part
|
||||||
|
imagePath, _ := e.AddImage(src, "")
|
||||||
|
|
||||||
|
if c.config.imagesOnly {
|
||||||
|
imageTag, _ := goquery.OuterHtml(s)
|
||||||
|
content += strings.Replace(imageTag, src, imagePath, 1)
|
||||||
|
} else {
|
||||||
|
content = strings.Replace(content, src, imagePath, 1)
|
||||||
|
}
|
||||||
|
})
|
||||||
|
|
||||||
|
html := ""
|
||||||
|
// add title only if imagesOnly = false
|
||||||
|
if c.config.imagesOnly == false {
|
||||||
|
html += fmt.Sprintf("<h1>%s</h1>", c.Name())
|
||||||
|
}
|
||||||
|
html += content
|
||||||
|
|
||||||
|
// write to epub file
|
||||||
|
_, err = e.AddSection(html, c.Name(), "", "")
|
||||||
|
if err != nil {
|
||||||
|
log.Fatal(err)
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
for _, sc := range c.SubChapters() {
|
||||||
|
AppendToEpub(e, sc)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
func ToMobi(c chapter, filename string) string {
|
||||||
|
if len(filename) == 0 {
|
||||||
|
filename = fmt.Sprintf("%s.mobi", Filename(c.Name()))
|
||||||
|
} else {
|
||||||
|
|
||||||
|
// add .mobi extension if not specified
|
||||||
|
if strings.HasSuffix(filename, ".mobi") == false {
|
||||||
|
filename = fmt.Sprintf("%s.mobi", filename)
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
filenameEPUB := strings.ReplaceAll(filename, ".mobi", ".epub")
|
||||||
|
ToEpub(c, filenameEPUB)
|
||||||
|
|
||||||
|
exec.Command("kindlegen", filenameEPUB).Run()
|
||||||
|
// exec command always return status 1 even if it succeed
|
||||||
|
// if err != nil {
|
||||||
|
// log.Fatal(err)
|
||||||
|
// }
|
||||||
|
|
||||||
|
err := os.Remove(filenameEPUB)
|
||||||
|
if err != nil {
|
||||||
|
log.Fatal(err)
|
||||||
|
}
|
||||||
|
|
||||||
|
return filename
|
||||||
|
}
|
||||||
79
book/format_test.go
Normal file
79
book/format_test.go
Normal file
@@ -0,0 +1,79 @@
|
|||||||
|
package book
|
||||||
|
|
||||||
|
import (
|
||||||
|
"errors"
|
||||||
|
"os"
|
||||||
|
"testing"
|
||||||
|
)
|
||||||
|
|
||||||
|
func TestFilename(t *testing.T) {
|
||||||
|
|
||||||
|
got := Filename("This is a chapter / book")
|
||||||
|
want := "This_is_a_chapter__book"
|
||||||
|
|
||||||
|
if got != want {
|
||||||
|
t.Errorf("got %q, wanted %q", got, want)
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestToMarkdown(t *testing.T) {
|
||||||
|
|
||||||
|
c := NewChapterFromURL("https://books.lapw.at/", []*ScrapeConfig{NewScrapeConfig()}, 0, func(index int, name string) {})
|
||||||
|
|
||||||
|
got := ToMarkdown(c)
|
||||||
|
want := "Books\n=====\n\n- [Discours de la Méthode](https://books.lapw.at/posts/ren%C3%A9-descartes-discours-de-la-m%C3%A9thode/)clock 98 min read -\n1637\n\n- [The Twelve-Factor App](https://books.lapw.at/posts/adam-wiggins-the-twelve-factor-app/)clock 22 min read -\n2011\n\n\n"
|
||||||
|
|
||||||
|
if got != want {
|
||||||
|
t.Errorf("got %q, wanted %q", got, want)
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestToEpub(t *testing.T) {
|
||||||
|
|
||||||
|
filename := "Books.epub"
|
||||||
|
c := NewChapterFromURL("https://books.lapw.at/", []*ScrapeConfig{NewScrapeConfig()}, 0, func(index int, name string) {})
|
||||||
|
ToEpub(c, "")
|
||||||
|
|
||||||
|
if _, err := os.Stat(filename); errors.Is(err, os.ErrNotExist) {
|
||||||
|
t.Errorf("%s does not exist: %v", filename, err)
|
||||||
|
} else {
|
||||||
|
if err := os.Remove(filename); err != nil {
|
||||||
|
t.Errorf("cannot remove %v: %v", filename, err)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestToEpubFilename(t *testing.T) {
|
||||||
|
|
||||||
|
filename := "ebook.epub"
|
||||||
|
c := NewChapterFromURL("https://books.lapw.at/", []*ScrapeConfig{NewScrapeConfig()}, 0, func(index int, name string) {})
|
||||||
|
ToEpub(c, filename)
|
||||||
|
|
||||||
|
if _, err := os.Stat(filename); errors.Is(err, os.ErrNotExist) {
|
||||||
|
t.Errorf("%s does not exist: %v", filename, err)
|
||||||
|
} else {
|
||||||
|
if err := os.Remove(filename); err != nil {
|
||||||
|
t.Errorf("cannot remove %v: %v", filename, err)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestToMobi(t *testing.T) {
|
||||||
|
|
||||||
|
filename := "ebook.mobi"
|
||||||
|
c := NewChapterFromURL("https://books.lapw.at/", []*ScrapeConfig{NewScrapeConfig()}, 0, func(index int, name string) {})
|
||||||
|
ToMobi(c, filename)
|
||||||
|
|
||||||
|
if _, err := os.Stat(filename); errors.Is(err, os.ErrNotExist) {
|
||||||
|
t.Errorf("%s does not exist: %v", filename, err)
|
||||||
|
} else {
|
||||||
|
if err := os.Remove(filename); err != nil {
|
||||||
|
t.Errorf("cannot remove %v: %v", filename, err)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
@@ -2,6 +2,7 @@ package book
|
|||||||
|
|
||||||
import (
|
import (
|
||||||
"fmt"
|
"fmt"
|
||||||
|
"strings"
|
||||||
|
|
||||||
"github.com/gosuri/uiprogress"
|
"github.com/gosuri/uiprogress"
|
||||||
)
|
)
|
||||||
@@ -11,20 +12,22 @@ type progress struct {
|
|||||||
individuals []*uiprogress.Bar
|
individuals []*uiprogress.Bar
|
||||||
}
|
}
|
||||||
|
|
||||||
func NewProgress(links []link) progress {
|
func NewProgress(links []link, parent string, depth int) progress {
|
||||||
uiprogress.Start()
|
uiprogress.Start()
|
||||||
|
|
||||||
global := uiprogress.AddBar(len(links))
|
global := uiprogress.AddBar(len(links))
|
||||||
|
indentGlobal := strings.Repeat("> ", depth)
|
||||||
global.AppendFunc(func(b *uiprogress.Bar) string {
|
global.AppendFunc(func(b *uiprogress.Bar) string {
|
||||||
return fmt.Sprintf("Chapters %d / %d", b.Current(), len(links))
|
return fmt.Sprintf("%v%v (%v / %v)", indentGlobal, parent, b.Current(), len(links))
|
||||||
})
|
})
|
||||||
|
|
||||||
// hide individual bars if more than 50 chapters
|
// hide individual bars if more than 50 chapters
|
||||||
individuals := []*uiprogress.Bar{}
|
individuals := []*uiprogress.Bar{}
|
||||||
|
indent := strings.Repeat("- ", depth)
|
||||||
if len(links) <= 50 {
|
if len(links) <= 50 {
|
||||||
for index, link := range links {
|
for index, link := range links {
|
||||||
bar := uiprogress.AddBar(1)
|
bar := uiprogress.AddBar(1)
|
||||||
barText := fmt.Sprintf("%d. %s", index+1, link.text)
|
barText := fmt.Sprintf("%v#%v %v", indent, index+1, link.Text())
|
||||||
bar.AppendFunc(func(b *uiprogress.Bar) string {
|
bar.AppendFunc(func(b *uiprogress.Bar) string {
|
||||||
return barText
|
return barText
|
||||||
})
|
})
|
||||||
@@ -35,13 +38,22 @@ func NewProgress(links []link) progress {
|
|||||||
return progress{global, individuals}
|
return progress{global, individuals}
|
||||||
}
|
}
|
||||||
|
|
||||||
func (p *progress) IncrGlobal() {
|
func (p *progress) IncrementGlobal() {
|
||||||
p.global.Incr()
|
p.global.Incr()
|
||||||
}
|
}
|
||||||
|
|
||||||
func (p *progress) Incr(index int) {
|
func (p *progress) Increment(index int) {
|
||||||
p.global.Incr()
|
p.IncrementGlobal()
|
||||||
if len(p.individuals) > index {
|
if len(p.individuals) > index {
|
||||||
p.individuals[index].Incr()
|
p.individuals[index].Incr()
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func (p *progress) UpdateName(index int, name string) {
|
||||||
|
if len(p.individuals) > index {
|
||||||
|
barText := fmt.Sprintf("%s", name)
|
||||||
|
p.individuals[index].AppendFunc(func(b *uiprogress.Bar) string {
|
||||||
|
return barText
|
||||||
|
})
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|||||||
257
book/scraper.go
257
book/scraper.go
@@ -1,9 +1,12 @@
|
|||||||
package book
|
package book
|
||||||
|
|
||||||
import (
|
import (
|
||||||
|
"bytes"
|
||||||
"fmt"
|
"fmt"
|
||||||
|
"io"
|
||||||
"log"
|
"log"
|
||||||
"math"
|
"math"
|
||||||
|
"net/http"
|
||||||
urllib "net/url"
|
urllib "net/url"
|
||||||
"strings"
|
"strings"
|
||||||
"sync"
|
"sync"
|
||||||
@@ -14,14 +17,84 @@ import (
|
|||||||
colly "github.com/gocolly/colly/v2"
|
colly "github.com/gocolly/colly/v2"
|
||||||
)
|
)
|
||||||
|
|
||||||
func NewBookFromURL(url, selector, name, author string, recursive, include bool, limit, offset, delay, threads int) book {
|
type ScrapeConfig struct {
|
||||||
|
depth int
|
||||||
|
selector string
|
||||||
|
limit int
|
||||||
|
offset int
|
||||||
|
delay int
|
||||||
|
threads int
|
||||||
|
include bool
|
||||||
|
imagesOnly bool
|
||||||
|
}
|
||||||
|
|
||||||
|
func NewScrapeConfig() *ScrapeConfig {
|
||||||
|
return &ScrapeConfig{0, "", -1, 0, -1, -1, true, false}
|
||||||
|
}
|
||||||
|
|
||||||
|
func NewScrapeConfigsAjin() []*ScrapeConfig {
|
||||||
|
config0 := NewScrapeConfig()
|
||||||
|
config0.depth = 0
|
||||||
|
config0.selector = ".dt>a"
|
||||||
|
config0.limit = 3
|
||||||
|
config0.offset = 0
|
||||||
|
config0.delay = 5000
|
||||||
|
config0.include = false
|
||||||
|
|
||||||
|
config1 := NewScrapeConfig()
|
||||||
|
config1.depth = 1
|
||||||
|
config1.selector = ".nav_apb>a"
|
||||||
|
config1.limit = 3
|
||||||
|
config1.offset = 1
|
||||||
|
config1.delay = 5000
|
||||||
|
config1.include = false
|
||||||
|
|
||||||
|
config2 := NewScrapeConfig()
|
||||||
|
config2.depth = 2
|
||||||
|
config2.imagesOnly = true
|
||||||
|
|
||||||
|
return []*ScrapeConfig{config0, config1, config2}
|
||||||
|
}
|
||||||
|
|
||||||
|
func NewScrapeConfigsWikipedia() []*ScrapeConfig {
|
||||||
|
config0 := NewScrapeConfig()
|
||||||
|
config0.depth = 0
|
||||||
|
config0.threads = -1
|
||||||
|
config0.include = true
|
||||||
|
|
||||||
|
config1 := NewScrapeConfig()
|
||||||
|
config1.depth = 1
|
||||||
|
config1.include = true
|
||||||
|
|
||||||
|
return []*ScrapeConfig{config0, config1}
|
||||||
|
}
|
||||||
|
|
||||||
|
func NewScrapeConfigFake() *ScrapeConfig {
|
||||||
|
config := NewScrapeConfig()
|
||||||
|
config.include = false
|
||||||
|
|
||||||
|
return config
|
||||||
|
}
|
||||||
|
|
||||||
|
func NewBookFromURL(url, selector, name, author string, recursive, include, imagesOnly, quiet bool, limit, offset, delay, threads int) book {
|
||||||
|
config1 := NewScrapeConfig()
|
||||||
|
config1.imagesOnly = imagesOnly
|
||||||
|
|
||||||
var chapters []chapter
|
var chapters []chapter
|
||||||
var home chapter
|
var home chapter
|
||||||
|
|
||||||
if recursive {
|
if recursive {
|
||||||
chapters, home = tableOfContent(url, selector, limit, offset, delay, threads, include)
|
config2 := NewScrapeConfig()
|
||||||
|
config2.selector = selector
|
||||||
|
config2.limit = limit
|
||||||
|
config2.offset = offset
|
||||||
|
config2.delay = delay
|
||||||
|
config2.threads = threads
|
||||||
|
config2.include = include
|
||||||
|
config2.imagesOnly = imagesOnly
|
||||||
|
chapters, home = tableOfContent(url, config2, config1, quiet)
|
||||||
} else {
|
} else {
|
||||||
chapters = []chapter{NewChapterFromURL(url)}
|
chapters = []chapter{NewChapterFromURL(url, []*ScrapeConfig{config1}, 0, func(index int, name string) {})}
|
||||||
home = chapters[0]
|
home = chapters[0]
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -41,45 +114,150 @@ func NewBookFromURL(url, selector, name, author string, recursive, include bool,
|
|||||||
return b
|
return b
|
||||||
}
|
}
|
||||||
|
|
||||||
func NewChapterFromURL(url string) chapter {
|
func NewChapterFromURL(url string, configs []*ScrapeConfig, index int, updateProgressBarName func(index int, name string)) chapter {
|
||||||
article, err := readability.FromURL(url, 30*time.Second)
|
config := configs[0]
|
||||||
if err != nil {
|
|
||||||
log.Fatalf("failed to parse %s, %v\n", url, err)
|
|
||||||
}
|
|
||||||
|
|
||||||
content := strings.ReplaceAll(article.Content, "\n", "")
|
|
||||||
|
|
||||||
// if images {
|
|
||||||
// // parse html content
|
|
||||||
// doc, err := goquery.NewDocumentFromReader(strings.NewReader(content))
|
|
||||||
// if err != nil {
|
|
||||||
// log.Fatal(err)
|
|
||||||
// }
|
|
||||||
|
|
||||||
// // extract images only
|
|
||||||
// content = ""
|
|
||||||
// doc.Find("img").Each(func(i int, s *goquery.Selection) {
|
|
||||||
// newContent, _ := goquery.OuterHtml(s)
|
|
||||||
// content += newContent
|
|
||||||
// })
|
|
||||||
// }
|
|
||||||
|
|
||||||
return chapter{article.Title, article.Byline, content}
|
|
||||||
}
|
|
||||||
|
|
||||||
func tableOfContent(url, selector string, limit, offset, delay, threads int, include bool) ([]chapter, chapter) {
|
|
||||||
base, err := urllib.Parse(url)
|
base, err := urllib.Parse(url)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Fatal(err)
|
log.Fatal(err)
|
||||||
}
|
}
|
||||||
|
|
||||||
links, home, err := GetLinks(base, selector, limit, offset, include)
|
// get page body
|
||||||
|
response, err := http.Get(url)
|
||||||
|
if err != nil {
|
||||||
|
log.Fatal(err)
|
||||||
|
}
|
||||||
|
defer response.Body.Close()
|
||||||
|
|
||||||
|
// duplicate response stream
|
||||||
|
readabilityReader := &bytes.Buffer{}
|
||||||
|
bodyReader := io.TeeReader(response.Body, readabilityReader)
|
||||||
|
|
||||||
|
// extract HTML body
|
||||||
|
body, err := io.ReadAll(bodyReader)
|
||||||
|
|
||||||
|
// extract article content and metadata
|
||||||
|
article, err := readability.FromReader(readabilityReader, base)
|
||||||
|
if err != nil {
|
||||||
|
log.Fatalf("failed to parse %s, %v\n", url, err)
|
||||||
|
}
|
||||||
|
name := article.Title
|
||||||
|
|
||||||
|
// notify progress bar with new name
|
||||||
|
updateProgressBarName(index, name)
|
||||||
|
|
||||||
|
subchapters := []chapter{}
|
||||||
|
if len(configs) > 1 {
|
||||||
|
// add subchapters
|
||||||
|
|
||||||
|
links, _, err := GetLinks(base, config.selector, config.limit, config.offset, false)
|
||||||
|
if err != nil {
|
||||||
|
log.Fatal(err)
|
||||||
|
}
|
||||||
|
|
||||||
|
subchapters = make([]chapter, len(links))
|
||||||
|
progress := NewProgress(links, name, config.depth)
|
||||||
|
|
||||||
|
if config.delay >= 0 {
|
||||||
|
|
||||||
|
// synchronous mode
|
||||||
|
for index, link := range links {
|
||||||
|
// and then use it to parse relative URLs
|
||||||
|
u, err := base.Parse(link.href)
|
||||||
|
if err != nil {
|
||||||
|
log.Fatal(err)
|
||||||
|
}
|
||||||
|
|
||||||
|
sc := NewChapterFromURL(u.String(), configs[1:], index, progress.UpdateName)
|
||||||
|
subchapters[index] = sc
|
||||||
|
progress.Increment(index)
|
||||||
|
|
||||||
|
time.Sleep(time.Duration(config.delay) * time.Millisecond)
|
||||||
|
}
|
||||||
|
|
||||||
|
} else {
|
||||||
|
// asynchronous mode
|
||||||
|
var wg sync.WaitGroup
|
||||||
|
|
||||||
|
threads := config.threads
|
||||||
|
if threads == -1 {
|
||||||
|
threads = len(links)
|
||||||
|
}
|
||||||
|
semaphore := make(chan bool, threads)
|
||||||
|
|
||||||
|
for index, l := range links {
|
||||||
|
|
||||||
|
wg.Add(1)
|
||||||
|
semaphore <- true
|
||||||
|
|
||||||
|
go func(index int, l link) {
|
||||||
|
defer wg.Done()
|
||||||
|
|
||||||
|
// and then use it to parse relative URLs
|
||||||
|
u, err := base.Parse(l.href)
|
||||||
|
if err != nil {
|
||||||
|
log.Fatal(err)
|
||||||
|
}
|
||||||
|
|
||||||
|
sc := NewChapterFromURL(u.String(), configs[1:], index, progress.UpdateName)
|
||||||
|
subchapters[index] = sc
|
||||||
|
progress.Increment(index)
|
||||||
|
|
||||||
|
<-semaphore
|
||||||
|
}(index, l)
|
||||||
|
}
|
||||||
|
wg.Wait()
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
content := ""
|
||||||
|
if config.include {
|
||||||
|
|
||||||
|
// we care about the content only if we include this level
|
||||||
|
content = article.Content
|
||||||
|
|
||||||
|
// extract images
|
||||||
|
if config.imagesOnly {
|
||||||
|
|
||||||
|
// parse HTML
|
||||||
|
doc, err := goquery.NewDocumentFromReader(strings.NewReader(content))
|
||||||
|
if err != nil {
|
||||||
|
log.Fatal(err)
|
||||||
|
}
|
||||||
|
|
||||||
|
// append every image to content
|
||||||
|
content = ""
|
||||||
|
doc.Find("img").Each(func(i int, s *goquery.Selection) {
|
||||||
|
imageTag, _ := goquery.OuterHtml(s)
|
||||||
|
imageTag = strings.ReplaceAll(imageTag, "\n", "")
|
||||||
|
|
||||||
|
content += imageTag
|
||||||
|
})
|
||||||
|
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
return chapter{string(body), name, article.Byline, content, subchapters, config}
|
||||||
|
}
|
||||||
|
|
||||||
|
func tableOfContent(url string, config *ScrapeConfig, subConfig *ScrapeConfig, quiet bool) ([]chapter, chapter) {
|
||||||
|
base, err := urllib.Parse(url)
|
||||||
|
if err != nil {
|
||||||
|
log.Fatal(err)
|
||||||
|
}
|
||||||
|
|
||||||
|
links, home, err := GetLinks(base, config.selector, config.limit, config.offset, config.include)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Fatal(err)
|
log.Fatal(err)
|
||||||
}
|
}
|
||||||
|
|
||||||
chapters := make([]chapter, len(links))
|
chapters := make([]chapter, len(links))
|
||||||
progress := NewProgress(links)
|
delay := config.delay
|
||||||
|
|
||||||
|
var p progress
|
||||||
|
if quiet == false {
|
||||||
|
p = NewProgress(links, "", 0)
|
||||||
|
}
|
||||||
|
|
||||||
if delay >= 0 {
|
if delay >= 0 {
|
||||||
// synchronous mode
|
// synchronous mode
|
||||||
@@ -91,8 +269,11 @@ func tableOfContent(url, selector string, limit, offset, delay, threads int, inc
|
|||||||
log.Fatal(err)
|
log.Fatal(err)
|
||||||
}
|
}
|
||||||
|
|
||||||
chapters[index] = NewChapterFromURL(u.String())
|
chapters[index] = NewChapterFromURL(u.String(), []*ScrapeConfig{subConfig}, 0, func(index int, name string) {})
|
||||||
progress.Incr(index)
|
|
||||||
|
if quiet == false {
|
||||||
|
p.Increment(index)
|
||||||
|
}
|
||||||
|
|
||||||
// short sleep for last chapter to let the progress bar update
|
// short sleep for last chapter to let the progress bar update
|
||||||
if index == len(links)-1 {
|
if index == len(links)-1 {
|
||||||
@@ -106,6 +287,7 @@ func tableOfContent(url, selector string, limit, offset, delay, threads int, inc
|
|||||||
// asynchronous mode
|
// asynchronous mode
|
||||||
var wg sync.WaitGroup
|
var wg sync.WaitGroup
|
||||||
|
|
||||||
|
threads := config.threads
|
||||||
if threads == -1 {
|
if threads == -1 {
|
||||||
threads = len(links)
|
threads = len(links)
|
||||||
}
|
}
|
||||||
@@ -125,8 +307,11 @@ func tableOfContent(url, selector string, limit, offset, delay, threads int, inc
|
|||||||
log.Fatal(err)
|
log.Fatal(err)
|
||||||
}
|
}
|
||||||
|
|
||||||
chapters[index] = NewChapterFromURL(u.String())
|
chapters[index] = NewChapterFromURL(u.String(), []*ScrapeConfig{subConfig}, 0, func(index int, name string) {})
|
||||||
progress.Incr(index)
|
|
||||||
|
if quiet == false {
|
||||||
|
p.Increment(index)
|
||||||
|
}
|
||||||
|
|
||||||
<-semaphore
|
<-semaphore
|
||||||
}(index, l)
|
}(index, l)
|
||||||
@@ -202,7 +387,7 @@ func GetLinks(url *urllib.URL, selector string, limit, offset int, include bool)
|
|||||||
|
|
||||||
links = links[offset:end]
|
links = links[offset:end]
|
||||||
|
|
||||||
home := NewChapterFromURL(url.String())
|
home := NewChapterFromURL(url.String(), []*ScrapeConfig{NewScrapeConfig()}, 0, func(index int, name string) {})
|
||||||
|
|
||||||
if include {
|
if include {
|
||||||
l := NewLink(url.String(), home.Name())
|
l := NewLink(url.String(), home.Name())
|
||||||
|
|||||||
184
book/scraper_test.go
Normal file
184
book/scraper_test.go
Normal file
@@ -0,0 +1,184 @@
|
|||||||
|
package book
|
||||||
|
|
||||||
|
import (
|
||||||
|
"testing"
|
||||||
|
"time"
|
||||||
|
)
|
||||||
|
|
||||||
|
func TestBody(t *testing.T) {
|
||||||
|
|
||||||
|
config := NewScrapeConfig()
|
||||||
|
c := NewChapterFromURL("https://books.lapw.at/", []*ScrapeConfig{config}, 0, func(index int, name string) {})
|
||||||
|
|
||||||
|
got := c.Body()
|
||||||
|
want := "<!doctype html>\n<html lang=\"en-us\">\n <head>\n <title>Books</title>\n <link rel=\"shortcut icon\" href=\"/favicon.ico\" />\n <meta charset=\"utf-8\" />\n <meta name=\"generator\" content=\"Hugo 0.59.1\" />\n <meta name=\"viewport\" content=\"width=device-width, initial-scale=1\" />\n <meta name=\"author\" content=\"John Doe\" />\n <meta name=\"description\" content=\" \" />\n <link rel=\"stylesheet\" href=\"https://books.lapw.at/css/main.min.88e7083eff65effb7485b6e6f38d10afbec25093a6fac42d734ce9024d3defbd.css\" />\n\n \n <meta name=\"twitter:card\" content=\"summary\"/>\n<meta name=\"twitter:title\" content=\"Books\"/>\n<meta name=\"twitter:description\" content=\" \"/>\n\n <meta property=\"og:title\" content=\"Books\" />\n<meta property=\"og:description\" content=\" \" />\n<meta property=\"og:type\" content=\"website\" />\n<meta property=\"og:url\" content=\"https://books.lapw.at/\" />\n\n\n\n </head>\n <body>\n <header class=\"app-header\">\n <a href=\"https://books.lapw.at/\"><img class=\"app-header-avatar\" src=\"/book.svg\" alt=\"John Doe\" /></a>\n <h1>Books</h1>\n <p> </p>\n <div class=\"app-header-social\">\n \n </div>\n </header>\n <main class=\"app-container\">\n \n <article>\n <h1>Books</h1>\n <ul class=\"posts-list\">\n \n <li class=\"posts-list-item\">\n <a class=\"posts-list-item-title\" href=\"https://books.lapw.at/posts/ren%C3%A9-descartes-discours-de-la-m%C3%A9thode/\">Discours de la Méthode</a>\n <span class=\"posts-list-item-description\">\n <svg xmlns=\"http://www.w3.org/2000/svg\" width=\"24\" height=\"24\" viewBox=\"0 0 24 24\" fill=\"none\" stroke=\"currentColor\" stroke-width=\"2\" stroke-linecap=\"round\" stroke-linejoin=\"round\" class=\"icon icon-clock\">\n <title>clock</title>\n <circle cx=\"12\" cy=\"12\" r=\"10\"></circle><polyline points=\"12 6 12 12 16 14\"></polyline>\n</svg> 98 min read -\n 1637\n </span>\n </li>\n \n <li class=\"posts-list-item\">\n <a class=\"posts-list-item-title\" href=\"https://books.lapw.at/posts/adam-wiggins-the-twelve-factor-app/\">The Twelve-Factor App</a>\n <span class=\"posts-list-item-description\">\n <svg xmlns=\"http://www.w3.org/2000/svg\" width=\"24\" height=\"24\" viewBox=\"0 0 24 24\" fill=\"none\" stroke=\"currentColor\" stroke-width=\"2\" stroke-linecap=\"round\" stroke-linejoin=\"round\" class=\"icon icon-clock\">\n <title>clock</title>\n <circle cx=\"12\" cy=\"12\" r=\"10\"></circle><polyline points=\"12 6 12 12 16 14\"></polyline>\n</svg> 22 min read -\n 2011\n </span>\n </li>\n \n </ul>\n \n\n\n\n </article>\n\n </main>\n </body>\n</html>\n"
|
||||||
|
|
||||||
|
if got != want {
|
||||||
|
t.Errorf("got %v, wanted %v", got, want)
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestName(t *testing.T) {
|
||||||
|
|
||||||
|
config := NewScrapeConfig()
|
||||||
|
c := NewChapterFromURL("https://books.lapw.at/", []*ScrapeConfig{config}, 0, func(index int, name string) {})
|
||||||
|
|
||||||
|
got := c.Name()
|
||||||
|
want := "Books"
|
||||||
|
|
||||||
|
if got != want {
|
||||||
|
t.Errorf("got %v, wanted %v", got, want)
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestAuthor(t *testing.T) {
|
||||||
|
|
||||||
|
config := NewScrapeConfig()
|
||||||
|
c := NewChapterFromURL("https://books.lapw.at/", []*ScrapeConfig{config}, 0, func(index int, name string) {})
|
||||||
|
|
||||||
|
got := c.Author()
|
||||||
|
want := "John Doe"
|
||||||
|
|
||||||
|
if got != want {
|
||||||
|
t.Errorf("got %v, wanted %v", got, want)
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestContent(t *testing.T) {
|
||||||
|
|
||||||
|
config := NewScrapeConfig()
|
||||||
|
c := NewChapterFromURL("https://books.lapw.at/", []*ScrapeConfig{config}, 0, func(index int, name string) {})
|
||||||
|
|
||||||
|
got := c.Content()
|
||||||
|
want := "<div id=\"readability-page-1\" class=\"page\">\n \n <main>\n \n <article>\n \n <ul>\n \n <li>\n <a href=\"https://books.lapw.at/posts/ren%C3%A9-descartes-discours-de-la-m%C3%A9thode/\">Discours de la Méthode</a>\n <span>\n <svg xmlns=\"http://www.w3.org/2000/svg\" width=\"24\" height=\"24\" viewBox=\"0 0 24 24\" fill=\"none\" stroke=\"currentColor\" stroke-width=\"2\" stroke-linecap=\"round\" stroke-linejoin=\"round\">\n <title>clock</title>\n <circle cx=\"12\" cy=\"12\" r=\"10\"></circle><polyline points=\"12 6 12 12 16 14\"></polyline>\n</svg> 98 min read -\n 1637\n </span>\n </li>\n \n <li>\n <a href=\"https://books.lapw.at/posts/adam-wiggins-the-twelve-factor-app/\">The Twelve-Factor App</a>\n <span>\n <svg xmlns=\"http://www.w3.org/2000/svg\" width=\"24\" height=\"24\" viewBox=\"0 0 24 24\" fill=\"none\" stroke=\"currentColor\" stroke-width=\"2\" stroke-linecap=\"round\" stroke-linejoin=\"round\">\n <title>clock</title>\n <circle cx=\"12\" cy=\"12\" r=\"10\"></circle><polyline points=\"12 6 12 12 16 14\"></polyline>\n</svg> 22 min read -\n 2011\n </span>\n </li>\n \n </ul>\n \n\n\n\n </article>\n\n </main>\n \n\n</div>"
|
||||||
|
|
||||||
|
if got != want {
|
||||||
|
t.Errorf("got %v, wanted %v", got, want)
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestDelay(t *testing.T) {
|
||||||
|
|
||||||
|
config0 := NewScrapeConfig()
|
||||||
|
config0.delay = 500
|
||||||
|
|
||||||
|
config1 := NewScrapeConfig()
|
||||||
|
|
||||||
|
start := time.Now()
|
||||||
|
NewChapterFromURL("https://books.lapw.at/", []*ScrapeConfig{config0, config1}, 0, func(index int, name string) {})
|
||||||
|
elapsed := time.Since(start)
|
||||||
|
|
||||||
|
got := elapsed
|
||||||
|
want := time.Duration(500) * time.Millisecond
|
||||||
|
|
||||||
|
if got < want {
|
||||||
|
t.Errorf("got %v, wanted min %v", got, want)
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestContentImagesOnly(t *testing.T) {
|
||||||
|
|
||||||
|
config := NewScrapeConfig()
|
||||||
|
config.imagesOnly = true
|
||||||
|
|
||||||
|
c := NewChapterFromURL("https://books.lapw.at/posts/adam-wiggins-the-twelve-factor-app/", []*ScrapeConfig{config}, 0, func(index int, name string) {})
|
||||||
|
|
||||||
|
got := c.Content()
|
||||||
|
want := "<img src=\"https://books.lapw.at/images/codebase-deploys.png\" alt=\"One codebase maps to many deploys\"/><img src=\"https://books.lapw.at/images/attached-resources.png\" alt=\"A production deploy attached to four backing services.\"/><img src=\"https://books.lapw.at/images/release.png\" alt=\"Code becomes a build, which is combined with config to create a release.\"/><img src=\"https://books.lapw.at/images/process-types.png\" alt=\"Scale is expressed as running processes, workload diversity is expressed as process types.\"/>"
|
||||||
|
|
||||||
|
if got != want {
|
||||||
|
t.Errorf("got %v, wanted %v", got, want)
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestSubChapters(t *testing.T) {
|
||||||
|
|
||||||
|
config0 := NewScrapeConfig()
|
||||||
|
config1 := NewScrapeConfig()
|
||||||
|
|
||||||
|
c := NewChapterFromURL("https://books.lapw.at/", []*ScrapeConfig{config0, config1}, 0, func(index int, name string) {})
|
||||||
|
|
||||||
|
got := len(c.SubChapters())
|
||||||
|
want := 2
|
||||||
|
|
||||||
|
if got != want {
|
||||||
|
t.Errorf("got %v, wanted %v", got, want)
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestSubChaptersSelector(t *testing.T) {
|
||||||
|
|
||||||
|
config0 := NewScrapeConfig()
|
||||||
|
config0.selector = "section.concrete > article > h2 > a"
|
||||||
|
|
||||||
|
config1 := NewScrapeConfig()
|
||||||
|
|
||||||
|
c := NewChapterFromURL("https://12factor.net/", []*ScrapeConfig{config0, config1}, 0, func(index int, name string) {})
|
||||||
|
|
||||||
|
got := len(c.SubChapters())
|
||||||
|
want := 12
|
||||||
|
|
||||||
|
if got != want {
|
||||||
|
t.Errorf("got %v, wanted %v", got, want)
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestSubChaptersLimit(t *testing.T) {
|
||||||
|
|
||||||
|
config0 := NewScrapeConfig()
|
||||||
|
config0.limit = 1
|
||||||
|
|
||||||
|
config1 := NewScrapeConfig()
|
||||||
|
|
||||||
|
c := NewChapterFromURL("https://books.lapw.at/", []*ScrapeConfig{config0, config1}, 0, func(index int, name string) {})
|
||||||
|
|
||||||
|
got := len(c.SubChapters())
|
||||||
|
want := 1
|
||||||
|
|
||||||
|
if got != want {
|
||||||
|
t.Errorf("got %v, wanted %v", got, want)
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestSubChaptersLimitOver(t *testing.T) {
|
||||||
|
|
||||||
|
config0 := NewScrapeConfig()
|
||||||
|
config0.limit = 3
|
||||||
|
|
||||||
|
config1 := NewScrapeConfig()
|
||||||
|
|
||||||
|
c := NewChapterFromURL("https://books.lapw.at/", []*ScrapeConfig{config0, config1}, 0, func(index int, name string) {})
|
||||||
|
|
||||||
|
got := len(c.SubChapters())
|
||||||
|
want := 2
|
||||||
|
|
||||||
|
if got != want {
|
||||||
|
t.Errorf("got %v, wanted %v", got, want)
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
func TestNotInclude(t *testing.T) {
|
||||||
|
|
||||||
|
config := NewScrapeConfig()
|
||||||
|
config.include = false
|
||||||
|
|
||||||
|
c := NewChapterFromURL("https://books.lapw.at/", []*ScrapeConfig{config}, 0, func(index int, name string) {})
|
||||||
|
|
||||||
|
got := c.Content()
|
||||||
|
want := ""
|
||||||
|
|
||||||
|
if got != want {
|
||||||
|
t.Errorf("got %v, wanted %v", got, want)
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
159
cmd/get.go
159
cmd/get.go
@@ -5,18 +5,14 @@ import (
|
|||||||
"fmt"
|
"fmt"
|
||||||
"log"
|
"log"
|
||||||
"os"
|
"os"
|
||||||
"os/exec"
|
|
||||||
"strings"
|
"strings"
|
||||||
|
|
||||||
md "github.com/JohannesKaufmann/html-to-markdown"
|
|
||||||
"github.com/PuerkitoBio/goquery"
|
|
||||||
epub "github.com/bmaupin/go-epub"
|
|
||||||
"github.com/spf13/cobra"
|
"github.com/spf13/cobra"
|
||||||
|
|
||||||
"github.com/lapwat/papeer/book"
|
"github.com/lapwat/papeer/book"
|
||||||
)
|
)
|
||||||
|
|
||||||
var recursive, include, images bool
|
var recursive, include, images, quiet bool
|
||||||
var format, output, selector, name, author string
|
var format, output, selector, name, author string
|
||||||
var limit, offset, delay, threads int
|
var limit, offset, delay, threads int
|
||||||
|
|
||||||
@@ -77,161 +73,48 @@ var getCmd = &cobra.Command{
|
|||||||
},
|
},
|
||||||
Run: func(cmd *cobra.Command, args []string) {
|
Run: func(cmd *cobra.Command, args []string) {
|
||||||
url := args[0]
|
url := args[0]
|
||||||
b := book.NewBookFromURL(url, selector, name, author, recursive, include, limit, offset, delay, threads)
|
b := book.NewBookFromURL(url, selector, name, author, recursive, include, images, quiet, limit, offset, delay, threads)
|
||||||
|
|
||||||
if len(output) == 0 {
|
fakeConfig := book.NewScrapeConfigFake()
|
||||||
// set default output
|
fakeChapter := book.NewChapter("", b.Name(), b.Author(), "", b.Chapters(), fakeConfig)
|
||||||
output = strings.ReplaceAll(b.Name(), " ", "_")
|
|
||||||
output = strings.ReplaceAll(output, "/", "")
|
|
||||||
output = fmt.Sprintf("%s.%s", output, format)
|
|
||||||
}
|
|
||||||
|
|
||||||
if format == "stdout" {
|
if format == "stdout" {
|
||||||
|
// TODO: ToMarkdownString
|
||||||
for _, c := range b.Chapters() {
|
markdown := book.ToMarkdown(fakeChapter)
|
||||||
// convert to markdown
|
fmt.Println(markdown)
|
||||||
content, err := md.NewConverter("", true, nil).ConvertString(c.Content())
|
|
||||||
if err != nil {
|
|
||||||
log.Fatal(err)
|
|
||||||
}
|
|
||||||
|
|
||||||
text := fmt.Sprintf("%s\n%s\n\n%s\n\n\n", c.Name(), strings.Repeat("=", len(c.Name())), content)
|
|
||||||
|
|
||||||
// write to stdout
|
|
||||||
fmt.Println(text)
|
|
||||||
}
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
if format == "md" {
|
if format == "md" {
|
||||||
|
// TODO: ToMarkdownFile
|
||||||
|
markdown := book.ToMarkdown(fakeChapter)
|
||||||
|
|
||||||
// create markdown file
|
if len(output) == 0 {
|
||||||
|
filename := book.Filename(fakeChapter.Name())
|
||||||
|
output = fmt.Sprintf("%s.md", filename)
|
||||||
|
}
|
||||||
|
|
||||||
|
// write to file
|
||||||
f, err := os.Create(output)
|
f, err := os.Create(output)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Fatal(err)
|
log.Fatal(err)
|
||||||
}
|
}
|
||||||
defer f.Close()
|
_, err2 := f.WriteString(markdown)
|
||||||
|
if err2 != nil {
|
||||||
for _, c := range b.Chapters() {
|
log.Fatal(err2)
|
||||||
// convert to markdown
|
|
||||||
content, err := md.NewConverter("", true, nil).ConvertString(c.Content())
|
|
||||||
if err != nil {
|
|
||||||
log.Fatal(err)
|
|
||||||
}
|
|
||||||
|
|
||||||
text := fmt.Sprintf("%s\n%s\n\n%s\n\n\n", c.Name(), strings.Repeat("=", len(c.Name())), content)
|
|
||||||
|
|
||||||
// write to markdown file
|
|
||||||
_, err = f.WriteString(text)
|
|
||||||
if err != nil {
|
|
||||||
log.Fatal(err)
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
f.Close()
|
||||||
|
|
||||||
fmt.Printf("Markdown saved to \"%s\"\n", output)
|
fmt.Printf("Markdown saved to \"%s\"\n", output)
|
||||||
}
|
}
|
||||||
|
|
||||||
if format == "epub" {
|
if format == "epub" {
|
||||||
e := epub.NewEpub(b.Name())
|
output = book.ToEpub(fakeChapter, output)
|
||||||
e.SetAuthor(b.Author())
|
|
||||||
|
|
||||||
for _, c := range b.Chapters() {
|
|
||||||
var content string
|
|
||||||
|
|
||||||
if images == false {
|
|
||||||
content = c.Content()
|
|
||||||
}
|
|
||||||
|
|
||||||
// parse content
|
|
||||||
doc, err := goquery.NewDocumentFromReader(strings.NewReader(c.Content()))
|
|
||||||
if err != nil {
|
|
||||||
log.Fatal(err)
|
|
||||||
}
|
|
||||||
|
|
||||||
// retrieve images and download it
|
|
||||||
doc.Find("img").Each(func(i int, s *goquery.Selection) {
|
|
||||||
src, _ := s.Attr("src")
|
|
||||||
imagePath, _ := e.AddImage(src, "")
|
|
||||||
|
|
||||||
if images {
|
|
||||||
imageTag, _ := goquery.OuterHtml(s)
|
|
||||||
content += imageTag
|
|
||||||
}
|
|
||||||
|
|
||||||
content = strings.ReplaceAll(content, src, imagePath)
|
|
||||||
})
|
|
||||||
|
|
||||||
html := fmt.Sprintf("<h1>%s</h1>%s", c.Name(), content)
|
|
||||||
_, err = e.AddSection(html, c.Name(), "", "")
|
|
||||||
if err != nil {
|
|
||||||
log.Fatal(err)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
err := e.Write(output)
|
|
||||||
if err != nil {
|
|
||||||
log.Fatal(err)
|
|
||||||
}
|
|
||||||
|
|
||||||
fmt.Printf("Ebook saved to \"%s\"\n", output)
|
fmt.Printf("Ebook saved to \"%s\"\n", output)
|
||||||
}
|
}
|
||||||
|
|
||||||
if format == "mobi" {
|
if format == "mobi" {
|
||||||
e := epub.NewEpub(b.Name())
|
output = book.ToMobi(fakeChapter, output)
|
||||||
e.SetAuthor(b.Author())
|
|
||||||
|
|
||||||
for _, c := range b.Chapters() {
|
|
||||||
var content string
|
|
||||||
|
|
||||||
if images == false {
|
|
||||||
content = c.Content()
|
|
||||||
}
|
|
||||||
|
|
||||||
// parse content
|
|
||||||
doc, err := goquery.NewDocumentFromReader(strings.NewReader(c.Content()))
|
|
||||||
if err != nil {
|
|
||||||
log.Fatal(err)
|
|
||||||
}
|
|
||||||
|
|
||||||
// retrieve images and download it
|
|
||||||
doc.Find("img").Each(func(i int, s *goquery.Selection) {
|
|
||||||
src, _ := s.Attr("src")
|
|
||||||
imagePath, _ := e.AddImage(src, "")
|
|
||||||
|
|
||||||
if images {
|
|
||||||
imageTag, _ := goquery.OuterHtml(s)
|
|
||||||
content += imageTag
|
|
||||||
}
|
|
||||||
|
|
||||||
content = strings.ReplaceAll(content, src, imagePath)
|
|
||||||
})
|
|
||||||
|
|
||||||
html := fmt.Sprintf("<h1>%s</h1>%s", c.Name(), content)
|
|
||||||
_, err = e.AddSection(html, c.Name(), "", "")
|
|
||||||
if err != nil {
|
|
||||||
log.Fatal(err)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
outputEPUB := strings.ReplaceAll(output, ".mobi", ".epub")
|
|
||||||
|
|
||||||
err := e.Write(outputEPUB)
|
|
||||||
if err != nil {
|
|
||||||
log.Fatal(err)
|
|
||||||
}
|
|
||||||
|
|
||||||
exec.Command("kindlegen", outputEPUB).Run()
|
|
||||||
// exec command always return status 1 even if it succeed
|
|
||||||
// if err != nil {
|
|
||||||
// log.Fatal(err)
|
|
||||||
// }
|
|
||||||
|
|
||||||
fmt.Printf("Ebook saved to \"%s\"\n", output)
|
fmt.Printf("Ebook saved to \"%s\"\n", output)
|
||||||
|
|
||||||
err = os.Remove(outputEPUB)
|
|
||||||
if err != nil {
|
|
||||||
log.Fatal(err)
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -31,6 +31,7 @@ func init() {
|
|||||||
rootCmd.PersistentFlags().BoolVarP(&recursive, "recursive", "r", false, "create one chapter per natigation item")
|
rootCmd.PersistentFlags().BoolVarP(&recursive, "recursive", "r", false, "create one chapter per natigation item")
|
||||||
rootCmd.PersistentFlags().BoolVarP(&include, "include", "i", false, "include URL as first chapter, in resursive mode")
|
rootCmd.PersistentFlags().BoolVarP(&include, "include", "i", false, "include URL as first chapter, in resursive mode")
|
||||||
rootCmd.PersistentFlags().BoolVarP(&images, "images", "", false, "retrieve images only")
|
rootCmd.PersistentFlags().BoolVarP(&images, "images", "", false, "retrieve images only")
|
||||||
|
rootCmd.PersistentFlags().BoolVarP(&quiet, "quiet", "q", false, "hide progress bar")
|
||||||
rootCmd.PersistentFlags().IntVarP(&limit, "limit", "l", -1, "limit number of chapters, in recursive mode")
|
rootCmd.PersistentFlags().IntVarP(&limit, "limit", "l", -1, "limit number of chapters, in recursive mode")
|
||||||
rootCmd.PersistentFlags().IntVarP(&offset, "offset", "o", 0, "skip first chapters, in recursive mode")
|
rootCmd.PersistentFlags().IntVarP(&offset, "offset", "o", 0, "skip first chapters, in recursive mode")
|
||||||
rootCmd.PersistentFlags().IntVarP(&delay, "delay", "d", -1, "time to wait before downloading next chapter, in milliseconds")
|
rootCmd.PersistentFlags().IntVarP(&delay, "delay", "d", -1, "time to wait before downloading next chapter, in milliseconds")
|
||||||
|
|||||||
@@ -14,6 +14,6 @@ var versionCmd = &cobra.Command{
|
|||||||
Use: "version",
|
Use: "version",
|
||||||
Short: "Print the version number of papeer",
|
Short: "Print the version number of papeer",
|
||||||
Run: func(cmd *cobra.Command, args []string) {
|
Run: func(cmd *cobra.Command, args []string) {
|
||||||
fmt.Println("papeer v0.3.1")
|
fmt.Println("papeer v0.3.3")
|
||||||
},
|
},
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -3,12 +3,18 @@
|
|||||||
version=$1
|
version=$1
|
||||||
platforms=("linux/amd64" "darwin/amd64" "windows/amd64")
|
platforms=("linux/amd64" "darwin/amd64" "windows/amd64")
|
||||||
|
|
||||||
|
if [ "$#" -ne 1 ]; then
|
||||||
|
echo "Illegal number of parameters"
|
||||||
|
echo "Usage: ./release.sh X.X.X"
|
||||||
|
exit 1
|
||||||
|
fi
|
||||||
|
|
||||||
for platform in "${platforms[@]}"
|
for platform in "${platforms[@]}"
|
||||||
do
|
do
|
||||||
platform_split=(${platform//\// })
|
platform_split=(${platform//\// })
|
||||||
GOOS=${platform_split[0]}
|
GOOS=${platform_split[0]}
|
||||||
GOARCH=${platform_split[1]}
|
GOARCH=${platform_split[1]}
|
||||||
output_name='papeer-'$version'-'$GOOS'-'$GOARCH
|
output_name='papeer-v'$version'-'$GOOS'-'$GOARCH
|
||||||
if [ $GOOS = "windows" ]; then
|
if [ $GOOS = "windows" ]; then
|
||||||
output_name+='.exe'
|
output_name+='.exe'
|
||||||
fi
|
fi
|
||||||
|
|||||||
Reference in New Issue
Block a user