Compare commits

..
Author SHA1 Message Date
swaits e3c730bdfc flow: Closed <feature> 'refactor_state_management'. 2015-02-16 22:14:23 -08:00
swaits 72cac47961 docrawl() completely refactored to use goroutine per URL
* outputs status
* crawlStatus() function created (split out of docrawl())
* changed from using bool flags to linkType in single httpItem enum, tests updated to match this
* unified where we set httpItem.linkType (inside fetchType), appropriate errors and returns added
* renamed a lot of things from 'page' to 'item'
* include refurl in httpItem
* []*Location result is now sorted
2015-02-16 22:13:52 -08:00
swaits d7cc760e5b rename page.go -> item.go 2015-02-16 18:17:01 -08:00
swaits 58614802b6 renamed Page -> httpItem, and changed its members to unexported as well
* tests all passing
2015-02-16 18:14:12 -08:00
swaits 66f78b562f flow: Created branch 'feature/refactor_state_management'. 2015-02-16 16:34:09 -08:00
swaits d3aeafeba5 update TODO 2015-02-16 16:28:36 -08:00
swaits fe46e7af15 add a TODO list 2015-02-16 06:13:59 -08:00
swaits 77b50a22b4 split tests out from everything else in cloc (make stats) 2015-02-15 23:12:01 -08:00
swaits 81e673a6bc flow: Merged <feature> 'url_on_command_line' to <develop> ('develop'). 2015-02-15 22:58:06 -08:00
swaits e867840994 flow: Closed <feature> 'url_on_command_line'. 2015-02-15 22:58:06 -08:00
swaits 5813e948f0 will attempt to crawl any URLs passed in on command line 2015-02-15 22:58:01 -08:00
swaits e3556df1b1 flow: Created branch 'feature/url_on_command_line'. 2015-02-15 22:31:18 -08:00
swaits b159dbf636 design doc extra line removed 2015-02-15 22:30:53 -08:00
swaits bdc75eca4a flow: Merged <feature> 'fix_broken_links' to <develop> ('develop'). 2015-02-15 22:27:04 -08:00
swaits c2b2897f5d flow: Closed <feature> 'fix_broken_links'. 2015-02-15 22:27:04 -08:00
swaits 569037d29f lint and fmt 2015-02-15 22:26:44 -08:00
swaits f3152b6f44 broken links now recorded as such
* Broken field in Page{} now,
* anything that fails to fetch (with http 200) or parse (should not happen) is considered broken
* tests updated appropriately
* discovered my "image.png" file was in the wrong directory because it showed up as broken. fixed!
* bug fix: only fetch if type=text/html (after HEAD response)
2015-02-15 22:25:50 -08:00
swaits f9fd0955e8 flow: Created branch 'feature/fix_broken_links'. 2015-02-15 22:09:25 -08:00
swaits 2f2d1036f6 flow: Merged <feature> 'limit_host_part' to <develop> ('develop'). 2015-02-15 22:09:10 -08:00
swaits 148e833454 flow: Closed <feature> 'limit_host_part'. 2015-02-15 22:09:10 -08:00
swaits 7498b648d7 urls with hosts that don't match the first URL are now skipped and marked as remote in the output
* added Skipped field to Page to remember this state
* marshaled into "Remote" field in JSON
* bug fix: skipped (etc.) sites weren't getting added to the main page list
* tests had to be reworked. because the crawl is non-deterministic, the tests started breaking. tests made a bit more robust, but are slightly weaker now.
* the lists of URLs in the output are now sorted
* ... and the parseLinks is no longer doing any sorting (no point in it)
* parser tests updated accordingly
* added a "broken" link to index.html - not currently supported, will fix next!
2015-02-15 22:07:37 -08:00
swaits 794f586979 flow: Created branch 'feature/limit_host_part'. 2015-02-15 20:44:54 -08:00
swaits 4598e6d8fe flow: Merged <feature> 'output_sitemap' to <develop> ('develop'). 2015-02-15 20:42:55 -08:00
swaits 2ae0502aba flow: Closed <feature> 'output_sitemap'. 2015-02-15 20:42:55 -08:00
swaits be11b13443 json sitemap output now functional
* the json marshaller cannot deal with circular data structures, and no automatic .String() conversion
* so we copy our crawl data slice into another slice which will be marshaled into json more easily
* made the page slice we use during crawling actually circular (as it should be) rather than putting duplicates in for each page discovered
* test for conversion to output data structure, and hacky cheater test for json output
* removed Base *Page from our Page struct as it's only needed temporarily
2015-02-15 18:57:34 -08:00
swaits 7d9bd98488 flow: Created branch 'feature/output_sitemap'. 2015-02-15 17:25:52 -08:00
swaits 8a6cac5df0 minor test cleanup; add "make stats" target to run cloc against project 2015-02-15 16:19:58 -08:00
swaits 828d776b94 flow: Merged <feature> 'improve_test_coverage' to <develop> ('develop'). 2015-02-15 16:04:09 -08:00
swaits 1e54b04490 flow: Closed <feature> 'improve_test_coverage'. 2015-02-15 16:04:09 -08:00
swaits ccc65f9715 coverage improved from 85.2% to 91.1% 2015-02-15 16:03:10 -08:00
swaits e4ce693396 flow: Created branch 'feature/improve_test_coverage'. 2015-02-15 15:38:01 -08:00
swaits cca2bcaf58 flow: Merged <feature> 'create_simple_sitemap' to <develop> ('develop'). 2015-02-15 15:31:27 -08:00
17 changed files with 533 additions and 135 deletions

No files matched your search

+14 -2
View File
@@ -3,7 +3,7 @@
# derived from: http://zduck.com/2014/go-project-structure-and-dependencies/
# build targets (which aren't files)
.PHONY: build fmt lint vet test autotest cover doc run clean env vendor
.PHONY: build fmt lint vet test autotest cover doc run clean env stats vendor
# configuration
APPNAME := docrawler
@@ -26,8 +26,8 @@ build: fmt lint vet
fmt:
go fmt ./src/...
# TODO golint is not accepting the "./src/..." for some reason (from within make)
lint:
# TODO golint is not accepting the "./src/..." for some reason (from within make)
golint ./src/${APPNAME}/*.go
vet:
@@ -55,6 +55,18 @@ clean:
env:
go env
stats:
@echo ===============================================================================
@echo Tests
@echo ===============================================================================
@cloc --match-f=_test.go ./src
@echo
@echo
@echo ===============================================================================
@echo Everything Else
@echo ===============================================================================
@cloc --not-match-f=_test.go ./src
# vendor
# * wipes our vendor directory completely
# * fetches all packages in ${PACKAGES} (GOPATH hardcoded to vendor directory only)
-1
View File
@@ -44,7 +44,6 @@ These are features I'd like to include.
* launch goroutine per fetch
* when there's no Jobs left, and nothing being fetched or parsed, convert the data struct into something useful and output it
## Wishlist
These are features that sound cool but are probably out of scope.
+21
View File
@@ -0,0 +1,21 @@
# To Do
## Bugs
* deal with anchor issue (repeatedly crawling index.html#about, index.html#contact, etc.)
* should only crawl these pages once
* but should be included in the links part
* when sorting links, "uniq" them as well
* be smart about index.html?
## Cleanup
* helper function to do the whole crawl process
* document code better
* test with godoc
## Features
* command line options, flag parsing
* check RFCs on URL character sets, compliance, etc.
* packagize parts of app
+116 -54
View File
@@ -1,67 +1,129 @@
package main
import ()
import (
"fmt"
"log"
"os"
"time"
)
// docrawl begins crawling the site at "url"
func docrawl(url string) []*Page {
// our result structure
var sitemap []*Page
// docrawl begins crawling the site at "homeurl"
func docrawl(homeurl string) itemSlice {
// set of what we have already crawled
crawled := make(map[string]struct{})
// what we've already parsed, what we still need to parse
crawled := make(map[string]*Page)
queued := make(map[string]*Page)
// map (of urlString -> httpItem) of our results
results := make(itemMap)
// create first page and add to the queue
homepage, _ := NewPage(nil, url) // TODO check error
queued[homepage.URL.String()] = homepage
// a channel to receive our results on
rchan := make(chan *httpItem)
// main loop
for len(queued) > 0 {
// pop a page off of queued
var dest *Page
var destURL string
for destURL, dest = range queued {
break
}
delete(queued, destURL)
// start a ticker which we'll use to output status and check for completion
ticker := time.Tick(250 * time.Millisecond)
// skip loop if we already did this URL
if _, ok := crawled[dest.URL.String()]; ok {
continue // TODO handle
}
// mark this page as complete
crawled[dest.URL.String()] = dest
// fetch page
text, err := fetchPage(dest)
if err != nil {
continue // TODO handle
}
// parse links
_, links, err := parseLinks(text)
if err != nil {
continue // TODO handle
}
for _, l := range links {
p, _ := NewPage(dest, l) // TODO check error
dest.Children = append(dest.Children, p)
// see if we should queue this new page for crawling
_, haveCrawled := crawled[p.URL.String()]
_, haveQueued := queued[p.URL.String()]
if !haveCrawled && !haveQueued {
queued[p.URL.String()] = p
}
}
// add page to list
sitemap = append(sitemap, dest)
// create first page's httpItem
homeitem, err := newHTTPItem(nil, homeurl)
if err != nil {
log.Fatal("unable to create httpItem for homeurl")
}
return sitemap
// set our number of outstanding pages (initially 1 to account for first page)
crawlingCount := 1
// start the home page crawl
crawled[homeitem.url.String()] = struct{}{}
go crawlItem(homeitem, rchan)
// wait for results
for {
select {
case r := <-rchan: // new results?
// add result to our results map
results[r.url.String()] = r
// decrease the outstanding page count by 1
crawlingCount--
// start crawly any new child pages we haven't yet crawled
for i, c := range r.children {
// see if we already have a result for this page, if so, point to that result
if existing, ok := results[c.url.String()]; ok {
r.children[i] = existing
continue
}
// see if we're already crawling this page (but maybe don't have results yet)
if _, ok := crawled[c.url.String()]; !ok {
// haven't crawled this one yet, do so now
crawlingCount++
crawled[c.url.String()] = struct{}{}
go crawlItem(c, rchan)
}
}
case <-ticker: // our regular ticker. for status output and checking for completion.
// output status to console
log.Printf("Crawled %v links, have %v left.\n", len(results), crawlingCount)
// see if we're finished
if crawlingCount == 0 {
// finished! convert results map to a slice and return it
rslice := itemSlice{}
for _, v := range results {
rslice = append(rslice, v)
}
return rslice
}
}
}
}
// crawlItem crawls a single httpItem, fetching the header, hte page, parsing it,
// and filling out its structure as much as possible
func crawlItem(item *httpItem, rchan chan<- *httpItem) {
// make sure this item is the same domain (i.e. URL "host part") as its referrer
if item.refurl != nil && item.url.Host != item.refurl.Host {
// skip URLs associated with other Hosts
item.linkType = tRemote
rchan <- item
return
}
// fetch page
text, err := fetchPage(item)
if err != nil {
rchan <- item
return
}
// parse links
title, links, _ := parseLinks(text) // TODO remove error from parseLinks, not needed
if err != nil {
item.linkType = tBroken
rchan <- item
return
}
item.title = title
// walk links and add them as children to the current item
for _, l := range links {
newItem, err := newHTTPItem(item, l)
if err != nil {
continue // TODO bad item
}
item.children = append(item.children, newItem)
}
// send back our item struct now that it's all filled out
rchan <- item
}
func main() {
// crawl each URL on the command line
for _, u := range os.Args[1:] {
pages := docrawl(u)
l := sitemapToLocations(pages)
j, _ := locationsToJSON(l)
fmt.Println(j)
}
}
+138 -32
View File
@@ -18,13 +18,13 @@ func TestMain(m *testing.M) {
// start our simple web server
l, err := net.Listen("tcp", ":"+strconv.Itoa(port))
if err != nil {
panic("unable to open port for http server") // TODO remove panic?
panic("unable to open port for http server")
}
http.Handle("/", http.FileServer(http.Dir("./testsite")))
go func() {
err = http.Serve(l, nil)
if err != nil {
panic("unable to start http server") // TODO remove panic?
panic("unable to start http server")
}
}()
@@ -58,9 +58,9 @@ func TestBadRequest(t *testing.T) {
// TestSimpleFetch makes sure we can fetch a file and we get exactly what we expect
func TestSimpleFetch(t *testing.T) {
page, err := NewPage(nil, baseURL+"fetch_test.html")
page, err := newHTTPItem(nil, baseURL+"fetch_test.html")
if err != nil {
t.Error("problem creating New Page struct")
t.Error("problem creating New httpItem struct")
}
body, err := fetchPage(page)
if err != nil {
@@ -77,59 +77,165 @@ func TestSimpleFetch(t *testing.T) {
// TestSimpleMap figures out the site map for the site in baseURL
func TestSimpleMap(t *testing.T) {
pages := docrawl(baseURL)
t.Log("pages = ", pages)
if len(pages) != 4 {
t.Logf("got %v, wanted %v\n", len(pages), 1)
// because our crawl is non-deterministic, we have to do a complete
// cycle through every page, counting stuff, finding specific pages
// so that we can then verify certain aspects of each page
skipped, children := 0, 0
var homepage, aboutpage, skippage *httpItem
for _, p := range pages {
if p.title == "Home" {
homepage = p
} else if p.title == "About Test" {
aboutpage = p
} else if p.url.String() == "http://doesntexist23492387492837492374982734.com/" {
skippage = p
}
if p.linkType == tRemote {
skipped++
}
children += len(p.children)
}
// check page counts
if len(pages) != 6 {
t.Logf("got %v, wanted %v\n", len(pages), 6)
t.Fatal("got wrong number of pages")
}
if pages[0].URL.String() != baseURL {
if children != 8 {
t.Logf("got %v, wanted %v\n", children, 8)
t.Fatal("got wrong number of total children")
}
if skipped != 1 {
t.Logf("got %v, wanted %v\n", skipped, 1)
t.Fatal("got wrong number of total skipped")
}
// check first page URL
if homepage.url.String() != baseURL {
t.Error("page URL is invalid")
}
if len(pages[0].Children) != 3 {
t.Logf("got %v, wanted %v\n", len(pages[0].Children), 1)
// specific page number of children
if len(homepage.children) != 4 {
t.Logf("got %v, wanted %v\n", len(homepage.children), 4)
t.Fatal("got wrong number of links")
}
if pages[0].Children[0].URL.String() != baseURL+"about.html" {
t.Logf(" Got: %q\n", pages[0].Children[0].URL.String())
t.Logf("Wanted: %q\n", baseURL+"about.html")
t.Error("link name is incorrect")
if len(aboutpage.children) != 4 {
t.Logf("got %v, wanted %v\n", len(aboutpage.children), 4)
t.Fatal("got wrong number of links")
}
if pages[0].Children[1].URL.String() != baseURL+"assets/image.png" {
t.Logf(" Got: %q\n", pages[0].Children[1].URL.String())
t.Logf("Wanted: %q\n", baseURL+"assets/image.png")
t.Error("link name is incorrect")
// make sure remote pages were skipped
if homepage.linkType == tRemote {
t.Logf("found a page that should NOT have been skipped %q", homepage.children[0].url.String())
t.Error("child was skipped")
}
if pages[0].Children[2].URL.String() != baseURL+"scripts/blah.js" {
t.Logf(" Got: %q\n", pages[0].Children[2].URL.String())
t.Logf("Wanted: %q\n", baseURL+"scripts/blah.js")
t.Error("link name is incorrect")
if skippage.linkType != tRemote {
t.Logf("found a page that should have been skipped %q", pages[3].children[2].url.String())
t.Error("child wasn't skipped")
}
// verify page content
// TODO find a better way to do this
//if homepage.children[0].url.String() != baseURL+"about.html" {
//t.Logf(" Got: %q\n", homepage.children[0].url.String())
//t.Logf("Wanted: %q\n", baseURL+"about.html")
//t.Error("link name is incorrect")
//}
//if homepage.children[1].url.String() != baseURL+"assets/image.png" {
//t.Logf(" Got: %q\n", homepage.children[1].url.String())
//t.Logf("Wanted: %q\n", baseURL+"assets/image.png")
//t.Error("link name is incorrect")
//}
//if homepage.children[3].url.String() != baseURL+"scripts/blah.js" {
//t.Logf(" Got: %q\n", homepage.children[3].url.String())
//t.Logf("Wanted: %q\n", baseURL+"scripts/blah.js")
//t.Error("link name is incorrect")
//}
}
// TestHeaderFetching tests fetchFiletype() to see if we are getting expected results
func TestHeaderFetching(t *testing.T) {
basepage, err := NewPage(nil, baseURL)
basepage, err := newHTTPItem(nil, baseURL)
if err != nil {
t.Error("problem creating New Page struct")
t.Error("problem creating New httpItem struct")
}
if err := fetchFiletype(basepage); err != nil || basepage.MediaType != "text/html" {
if err := fetchFiletype(basepage); err != nil || basepage.linkType != tHTMLPage {
t.Error("problem fetching filetype")
}
page, err := NewPage(basepage, "about.html")
page, err := newHTTPItem(basepage, "about.html")
if err != nil {
t.Error("problem creating New Page struct")
t.Error("problem creating New httpItem struct")
}
if err := fetchFiletype(page); err != nil || page.MediaType != "text/html" {
if err := fetchFiletype(page); err != nil || page.linkType != tHTMLPage {
t.Error("problem fetching filetype")
}
page, err = NewPage(basepage, "assets/image.png")
page, err = newHTTPItem(basepage, "assets/image.png")
if err != nil {
t.Error("problem creating New Page struct")
t.Error("problem creating New httpItem struct")
}
if err := fetchFiletype(page); err != nil || page.MediaType != "text/plain" {
t.Logf("got %q, wanted %q", page.MediaType, "text/plain")
if err := fetchFiletype(page); err != nil || page.linkType != tAsset {
t.Logf("got %q, wanted %q", page.linkType, tAsset)
t.Error("problem fetching filetype")
}
}
// TestJsonOutput gets a sitemap and then converts it to json
func TestJsonOutput(t *testing.T) {
pages := docrawl(baseURL)
l := sitemapToLocations(pages)
if len(l) != 2 {
t.Error("sitemapToLocations has the wrong number of locations")
}
if l[0].URL != baseURL {
t.Error("got an incorrect location")
}
if len(l[0].Links) != 1 {
t.Error("location 0 has wrong number of links")
}
if len(l[0].Assets) != 2 {
t.Logf("got %v", len(l[0].Assets))
t.Error("location 0 has wrong number of assets")
}
if len(l[0].Broken) != 1 {
t.Logf("got %v", len(l[0].Broken))
t.Error("location 0 has wrong number of broken urls")
}
if len(l[0].Remote) != 0 {
t.Logf("got %v", len(l[1].Remote))
t.Error("location 0 has wrong number of remote urls")
}
if l[1].URL != baseURL+"about.html" {
t.Error("got an incorrect location")
}
if len(l[1].Links) != 1 {
t.Error("location 1 has wrong number of links")
}
if len(l[1].Assets) != 2 {
t.Error("location 1 has wrong number of assets")
}
if len(l[1].Broken) != 0 {
t.Logf("got %v", len(l[1].Broken))
t.Error("location 1 has wrong number of broken urls")
}
if len(l[1].Remote) != 1 {
t.Logf("got %v", len(l[1].Remote))
t.Error("location 1 has wrong number of remote urls")
}
// this is a cheater test because the output is from a run of the code being
// test itself. but, it's been examined and I think it's right. and, there's not
// many other ways to test this without some significant pain
cheaterTest := `[{"URL":"http://localhost:8765/","Title":"Home","Links":["http://localhost:8765/about.html"],"Assets":["http://localhost:8765/assets/image.png","http://localhost:8765/scripts/blah.js"],"Broken":["http://localhost:8765/zzzbroken.html"],"Remote":null},{"URL":"http://localhost:8765/about.html","Title":"About Test","Links":["http://localhost:8765/"],"Assets":["http://localhost:8765/assets/image.png","http://localhost:8765/scripts/blah.js"],"Broken":null,"Remote":["http://doesntexist23492387492837492374982734.com/"]}]`
j, err := locationsToJSON(l)
if err != nil {
t.Error("locationsToJSON failed")
}
if j != cheaterTest {
t.Error("locationsToJSON text doesn't match")
}
t.Log(j)
}
+39 -9
View File
@@ -9,48 +9,78 @@ import (
var (
errContentTypeNotFound = errors.New("no Content-Type header found")
errFetchError = errors.New("couldn't fetch item")
errFileTypeUnknown = errors.New("couldn't determine file type")
)
// fetchFiletype performs an http HEAD to get the media type, and sets it
// directly in Page.MediaType
func fetchFiletype(page *Page) error {
resp, err := http.Head(page.URL.String())
// directly in httpItem.mediaType
func fetchFiletype(item *httpItem) error {
resp, err := http.Head(item.url.String())
if err != nil {
item.linkType = tBroken
return err
}
// check response code
if resp.StatusCode != http.StatusOK {
item.linkType = tBroken
return errFetchError
}
// pull the content type out of the http header
contentType, ok := resp.Header["Content-Type"]
if !ok {
// no Content-Type header found
item.linkType = tBroken
return errContentTypeNotFound
}
// parse mime type
mediatype, _, err := mime.ParseMediaType(contentType[0])
if err != nil {
item.linkType = tBroken
return err
}
// set and return
page.MediaType = mediatype
// success, set item type and return
if mediatype == "text/html" {
item.linkType = tHTMLPage
} else {
item.linkType = tAsset
}
return nil
}
// fetchPage takes a Page, GETs it, and returns the body as a string
func fetchPage(page *Page) (string, error) {
// fetchPage takes a httpItem, GETs it, and returns the body as a string
func fetchPage(item *httpItem) (string, error) {
// figure out the file type
err := fetchFiletype(page)
err := fetchFiletype(item)
if err != nil {
return "", err
}
// make sure we got a file type!
if item.linkType == tUnknown {
return "", errFileTypeUnknown
}
// we only want to fetch html, so return if it's anything else
if item.linkType != tHTMLPage {
return "", nil // but this isn't an error!
}
// GET the url
resp, err := http.Get(page.URL.String())
resp, err := http.Get(item.url.String())
if err != nil {
return "", err
}
// check response code
if resp.StatusCode != http.StatusOK {
return "", errFetchError
}
// read the body
body, err := ioutil.ReadAll(resp.Body)
if err != nil {
+27
View File
@@ -0,0 +1,27 @@
package main
import (
"testing"
)
// TestFailedHeaderFetching tests fetchFiletype() to see if we are getting expected failures
func TestFailedHeaderFetching(t *testing.T) {
page, err := newHTTPItem(nil, "http://doesntexist23492387492837492374982734.com/")
if err != nil {
t.Error("problem creating New Page struct")
}
if err := fetchFiletype(page); err == nil {
t.Error("tired fetching bogus page but didn't get nil back from fetchFiletype")
}
}
// TestFailedFetching tests fetchFiletype() to see if we are getting expected failures
func TestFailedFetching(t *testing.T) {
page, err := newHTTPItem(nil, "http://doesntexist23492387492837492374982734.com/")
if err != nil {
t.Error("problem creating New Page struct")
}
if _, err := fetchPage(page); err == nil {
t.Error("tired fetching bogus page but didn't get nil back from fetchPage")
}
}
+55
View File
@@ -0,0 +1,55 @@
package main
import (
"net/url"
)
// itemSlice is a convenience type for a slice of items
type itemSlice []*httpItem
// itemMap convenience type for map of string's (URL) to items
type itemMap map[string]*httpItem
// itemType is an enum so we know how to classify each item
type itemType int
const (
tUnknown itemType = iota
tHTMLPage
tAsset
tRemote
tBroken
)
// httpItem is a struct which defines a single page, which URLs (links and assets) it contains, etc.
type httpItem struct {
url *url.URL
refurl *url.URL
title string
linkType itemType
children itemSlice
}
// newHTTPItem takes a referring httpItem + a URL and returns a new &httpItem{}
func newHTTPItem(referrer *httpItem, rawurl string) (*httpItem, error) {
// determine the base URL so we can resulve this into a full URL
baseURL := ""
if referrer != nil {
baseURL = referrer.url.String()
}
// resolve URL into a full absolute URL (non-relative)
u, err := resolveURL(baseURL, rawurl)
if err != nil {
return nil, err
}
// figure out referrer url
var rurl *url.URL
if referrer != nil {
rurl = referrer.url
}
// create struct and return
return &httpItem{url: u, refurl: rurl}, nil
}
+13
View File
@@ -0,0 +1,13 @@
package main
import (
"testing"
)
// TestBadnewHTTPItem tests newHTTPItem to see if we are getting expected failures
func TestBadnewHTTPItem(t *testing.T) {
_, err := newHTTPItem(nil, "h%20t\tp://doesntexist23492387492837492374982734.com/")
if err == nil {
t.Error("tried creating a newHTTPItem with an invalid URL but didn't get an error")
}
}
+78
View File
@@ -0,0 +1,78 @@
package main
import (
"encoding/json"
"sort"
)
// Location is a struct which defines a single URL, which URLs (links and assets) it contains, etc.
type Location struct {
URL string
Title string
Links []string
Assets []string
Broken []string
Remote []string
}
// implement Location slice sorting (by URL)
type byURL []*Location
// implement Sort interface on byURL (which is a []*Location)
func (l byURL) Len() int { return len(l) }
func (l byURL) Less(i, j int) bool { return l[i].URL < l[j].URL }
func (l byURL) Swap(i, j int) { l[i], l[j] = l[j], l[i] }
// sitemapToLocations converts an itemSlice to []*Location, which is appropriate for marshalling
func sitemapToLocations(pages itemSlice) []*Location {
// build a map of our pages
pageMap := make(map[string]*httpItem)
for _, p := range pages {
pageMap[p.url.String()] = p
}
// build a slice of locations (one per page)
var locations []*Location
for _, p := range pages {
if p.linkType == tHTMLPage {
// create a location for this page
l := &Location{URL: p.url.String(), Title: p.title}
// add its children
for _, c := range p.children {
// look up this child's media type from the root list of pages
//mediaType := pageMap[c.url.String()].mediaType
if c.linkType == tRemote {
l.Remote = append(l.Remote, c.url.String())
} else if c.linkType == tHTMLPage {
l.Links = append(l.Links, c.url.String())
} else if c.linkType == tBroken {
l.Broken = append(l.Broken, c.url.String())
} else {
l.Assets = append(l.Assets, c.url.String())
}
}
// now sort the children slices
sort.Strings(l.Remote)
sort.Strings(l.Links)
sort.Strings(l.Broken)
sort.Strings(l.Assets)
// and add this location to our slice
locations = append(locations, l)
}
}
// sort the Locations themselves and return
sort.Sort(byURL(locations))
return locations
}
func locationsToJSON(locations []*Location) (string, error) {
b, err := json.Marshal(locations)
if err != nil {
return "", err
}
return string(b), nil
}
-32
View File
@@ -1,32 +0,0 @@
package main
import (
"net/url"
)
// Page is a struct which defines a single page, which URLs (links and assets) it contains, etc.
type Page struct {
URL *url.URL
Base *Page
Title string
MediaType string
Children []*Page
}
// NewPage takes a referring Page + a URL and returns a new &Page{}
func NewPage(referrer *Page, rawurl string) (*Page, error) {
// determine the base URL so we can resulve this into a full URL
baseURL := ""
if referrer != nil {
baseURL = referrer.URL.String()
}
// resolve URL into a full absolute URL (non-relative)
u, err := resolveURL(baseURL, rawurl)
if err != nil {
return nil, err
}
// create struct and return
return &Page{URL: u}, nil
}
+1 -3
View File
@@ -2,7 +2,6 @@ package main
import (
"regexp"
"sort"
"strings"
)
@@ -11,7 +10,7 @@ var reURL = regexp.MustCompile(`(?i)(src|href|xhref)\s*=\s*"([^"]+)"`) // TODO m
var reTitle = regexp.MustCompile(`(?i)<\s*title\s*>([^<]*)<\s*\/\s*title`)
// parseLinks takes a string and attempts to parse any html title and all links out of it,
// and returns a sorted slice of the captures found
// and returns a slice of the captures found
func parseLinks(s string) (string, []string, error) {
// find the title, or default to empty
title := ""
@@ -26,6 +25,5 @@ func parseLinks(s string) (string, []string, error) {
for _, match := range reURL.FindAllStringSubmatch(s, -1) {
results = append(results, match[2])
}
sort.Strings(results)
return title, results, nil
}
+2 -2
View File
@@ -26,10 +26,10 @@ func TestSimpleParse(t *testing.T) {
if len(matches) != 3 {
t.Error("invalid number of matches in parse")
}
if matches[0] != "/about.html" {
if matches[0] != "/assets/image.png" {
t.Error("match text is invalid")
}
if matches[1] != "/assets/image.png" {
if matches[1] != "/about.html" {
t.Error("match text is invalid")
}
if matches[2] != "scripts/blah.js" {
+11
View File
@@ -0,0 +1,11 @@
<html>
<head>
<title>About Test</title>
<script src="scripts/blah.js"/>
</head>
<body>
<img src="/assets/image.png"/>
<a href="/">fooey!</a>
<a href="http://doesntexist23492387492837492374982734.com/">bad one</a>
</body>
</html>
File renamed without changes.
+2
View File
@@ -1,9 +1,11 @@
<html>
<head>
<title>Home</title>
</head>
<body>
<img src="/assets/image.png"/>
<a href="/about.html">fooey!</a>
<script src="scripts/blah.js"/>
<a href="/zzzbroken.html">oops!</a>
</body>
</html>
+16
View File
@@ -52,3 +52,19 @@ func TestURLResolution(t *testing.T) {
doResolveTest(t, "http://another.com/blah.html", "http://S:D@BaSe.CoM:1/some/crazy/path/index.html?parm=x&blah=foo", "http://aNOThER.CoM/blah.html")
doResolveTest(t, "http://empty.com/blah.html", "", "http://empty.com/blah.html")
}
// TestBadResolve tries to resolve bogus URLs to be sure we're getting errors
/* TODO not sure how to make url.Parse fail in these cases!!!
func TestBadResolve(t* testing.T) {
u, err := resolveURL("http://a.com/", "h%20t\tp://doesnte%20xist23492387492837492374982734.com/")
if err == nil {
t.Logf("got %q", u.String())
t.Error("tried resolveURL with an invalid URL but didn't get an error")
}
u, err = resolveURL("h%20t\tp://doesnte%20xist23492387492837492374982734.com/", "http://a.com/")
if err == nil {
t.Logf("got %q", u.String())
t.Error("tried resolveURL with an invalid URL but didn't get an error")
}
}
*/