1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95
|
package main
import (
"fmt"
"io/ioutil"
"net/http"
"os"
"strings"
"github.com/mmcdole/gofeed"
"github.com/mmcdole/gofeed/atom"
"github.com/mmcdole/gofeed/rss"
"github.com/urfave/cli"
)
func main() {
app := cli.NewApp()
app.Name = "ftest"
app.Usage = "provide a feed file path or url to parse and print"
app.Flags = []cli.Flag{
cli.StringFlag{
Name: "type,t",
Value: "universal",
Usage: "type of parser (atom, rss, universal)",
},
}
app.Action = func(c *cli.Context) {
if c.NArg() == 0 {
fmt.Println("Missing feed path or url")
os.Exit(1)
}
feedType := c.String("type")
feedLoc := c.Args()[0]
fc, err := fetchFeed(feedLoc)
if err != nil {
fmt.Println(err.Error())
os.Exit(1)
}
var feed interface{}
if strings.EqualFold(feedType, "rss") ||
strings.EqualFold(feedType, "r") {
p := rss.Parser{}
feed, err = p.Parse(strings.NewReader(fc))
} else if strings.EqualFold(feedType, "atom") ||
strings.EqualFold(feedType, "a") {
p := atom.Parser{}
feed, err = p.Parse(strings.NewReader(fc))
} else {
p := gofeed.NewParser()
feed, err = p.ParseString(fc)
}
if err != nil {
fmt.Println(err.Error())
os.Exit(1)
}
fmt.Println(feed)
}
app.Run(os.Args)
}
func fetchFeed(feedLoc string) (string, error) {
if strings.HasPrefix(feedLoc, "http") {
return fetchURL(feedLoc)
}
file, err := fetchFile(feedLoc)
if err != nil {
return "", err
}
return string(file), nil
}
func fetchFile(path string) (string, error) {
f, err := ioutil.ReadFile(path)
return string(f), err
}
func fetchURL(url string) (string, error) {
response, err := http.Get(url)
if err != nil {
return "", err
}
defer response.Body.Close()
contents, err := ioutil.ReadAll(response.Body)
if err != nil {
return "", err
}
return string(contents), nil
}
|