wrp/wrp.go

//
// WRP - Web Rendering Proxy
//
// Copyright (c) 2013-2018 Antoni Sawicki
// Copyright (c) 2019 Google LLC
//

package main

import (
	"bytes"
	"context"
	"flag"
	"fmt"
	_ "image"
	"image/gif"
	"image/png"
	"log"
	"math/rand"
	"net/http"
	"net/url"
	"os"
	"strconv"
	"time"

	"github.com/chromedp/cdproto/emulation"

	"github.com/chromedp/cdproto/cdp"
	"github.com/chromedp/cdproto/dom"
	"github.com/chromedp/chromedp"
)

var (
	ctx    context.Context
	cancel context.CancelFunc
	gifmap = make(map[string]bytes.Buffer)
)

func pageServer(out http.ResponseWriter, req *http.Request) {
	req.ParseForm()
	furl := req.Form["url"]
	var gourl string
	if len(furl) >= 1 && len(furl[0]) > 4 {
		gourl = furl[0]
	} else {
		gourl = "https://www.bbc.com/news"
	}
	log.Printf("%s Page Reqest for %s [%s]\n", req.RemoteAddr, gourl, req.URL.Path)
	out.Header().Set("Content-Type", "text/html")
	fmt.Fprintf(out, "<HTML>\n<HEAD><TITLE>WRP %s</TITLE>\n<BODY BGCOLOR=\"#F0F0F0\">", gourl)
	fmt.Fprintf(out, "<FORM ACTION=\"/\">URL: <INPUT TYPE=\"TEXT\" NAME=\"url\" VALUE=\"%s\">", gourl)
	fmt.Fprintf(out, "<INPUT TYPE=\"SUBMIT\" VALUE=\"Go\"></FORM><P>\n")
	if len(gourl) > 4 {
		capture(gourl, out)
	}
	fmt.Fprintf(out, "</BODY>\n</HTML>\n")
}

func imgServer(out http.ResponseWriter, req *http.Request) {
	log.Printf("%s Img Request for %s\n", req.RemoteAddr, req.URL.Path)
	gifbuf := gifmap[req.URL.Path]
	defer delete(gifmap, req.URL.Path)
	out.Header().Set("Content-Type", "image/gif")
	out.Header().Set("Content-Length", strconv.Itoa(len(gifbuf.Bytes())))
	out.Write(gifbuf.Bytes())
	out.(http.Flusher).Flush()
}

func haltServer(out http.ResponseWriter, req *http.Request) {
	log.Printf("%s Shutdown request received [%s]\n", req.RemoteAddr, req.URL.Path)
	out.Header().Set("Content-Type", "text/plain")
	fmt.Fprintf(out, "WRP Shutdown")
	out.(http.Flusher).Flush()
	cancel()
	os.Exit(0)
}

func capture(gourl string, out http.ResponseWriter) {
	var nodes []*cdp.Node
	ctxx := chromedp.FromContext(ctx)
	var pngbuf []byte
	var gifbuf bytes.Buffer
	var loc string

	log.Printf("Processing Caputure Request for %s\n", gourl)

	// Run ChromeDP Magic
	chromedp.Run(ctx,
		emulation.SetDeviceMetricsOverride(1024, 768, 1.0, false),
		chromedp.Navigate(gourl),
		chromedp.Sleep(time.Second*2),
		chromedp.CaptureScreenshot(&pngbuf),
		chromedp.Location(&loc),
		chromedp.Nodes("a", &nodes, chromedp.ByQueryAll))

	log.Printf("Landed on: %s, Got %d nodes\n", loc, len(nodes))

	// Process Screenshot Image
	bytes.NewReader(pngbuf).Seek(0, 0)
	img, err := png.Decode(bytes.NewReader(pngbuf))
	if err != nil {
		log.Printf("Failed to decode screenshot: %s\n", err)
		fmt.Fprintf(out, "<BR>Unable to decode page screenshot:<BR>%s<BR>\n", err)
		return
	}
	gifbuf.Reset()
	err = gif.Encode(&gifbuf, img, nil)
	if err != nil {
		log.Printf("Failed to encode GIF: %s\n", err)
		fmt.Fprintf(out, "<BR>Unable to encode GIF:<BR>%s<BR>\n", err)
		return
	}
	imgpath := fmt.Sprintf("/img/%04d.gif", rand.Intn(9999))
	gifmap[imgpath] = gifbuf

	// Process Nodes
	base, _ := url.Parse(loc)
	fmt.Fprintf(out, "<IMG SRC=\"%s\" ALT=\"wrp\" USEMAP=\"#map\">\n<MAP NAME=\"map\">\n", imgpath)
	log.Printf("Image path will be: %s", imgpath)

	for _, n := range nodes {
		b, err := dom.GetBoxModel().WithNodeID(n.NodeID).Do(cdp.WithExecutor(ctx, ctxx.Target))
		if err != nil {
			continue
		}
		tgt, err := base.Parse(n.AttributeValue("href"))
		if err != nil {
			continue
		}
		target := fmt.Sprintf("/?url=%s", tgt)

		if len(b.Content) > 6 && len(target) > 7 {
			fmt.Fprintf(out, "<AREA SHAPE=\"RECT\" COORDS=\"%.f,%.f,%.f,%.f\" ALT=\"%s\" TITLE=\"%s\" HREF=\"%s\">\n",
				b.Content[0], b.Content[1], b.Content[4], b.Content[5], n.AttributeValue("href"), n.AttributeValue("href"), target)
		}
	}

	fmt.Fprintf(out, "</MAP>\n")
	out.(http.Flusher).Flush()
	log.Printf("Done with caputure for %s\n", gourl)
}

func main() {
	ctx, cancel = chromedp.NewContext(context.Background())
	defer cancel()
	var addr string
	flag.StringVar(&addr, "l", ":8080", "Listen address:port, default :8080")
	flag.Parse()
	rand.Seed(time.Now().UnixNano())
	http.HandleFunc("/", pageServer)
	http.HandleFunc("/img/", imgServer)
	http.HandleFunc("/favicon.ico", http.NotFound)
	http.HandleFunc("/halt", haltServer)
	log.Printf("Starting http server on %s\n", addr)
	http.ListenAndServe(addr, nil)
}
add copyright 2019-05-30 01:53:05 +00:00			`//`
			`// WRP - Web Rendering Proxy`
			`//`
			`// Copyright (c) 2013-2018 Antoni Sawicki`
			`// Copyright (c) 2019 Google LLC`
			`//`

gocdp initial checkin 2019-05-29 08:29:01 +00:00			`package main`

			`import (`
log decode error instead of bailing out 2019-05-30 06:49:39 +00:00			`"bytes"`
add flags 2019-05-29 08:52:28 +00:00			`"context"`
			`"flag"`
			`"fmt"`
log decode error instead of bailing out 2019-05-30 06:49:39 +00:00			`_ "image"`
			`"image/gif"`
			`"image/png"`
add flags 2019-05-29 08:52:28 +00:00			`"log"`
randomized image url 2019-05-30 09:03:17 +00:00			`"math/rand"`
add flags 2019-05-29 08:52:28 +00:00			`"net/http"`
log decode error instead of bailing out 2019-05-30 06:49:39 +00:00			`"net/url"`
shutdown function via /halt url 2019-05-30 07:07:08 +00:00			`"os"`
add flags 2019-05-29 08:52:28 +00:00			`"strconv"`
			`"time"`
gocdp initial checkin 2019-05-29 08:29:01 +00:00
add browser size setting 2019-05-29 09:39:06 +00:00			`"github.com/chromedp/cdproto/emulation"`

add flags 2019-05-29 08:52:28 +00:00			`"github.com/chromedp/cdproto/cdp"`
			`"github.com/chromedp/cdproto/dom"`
			`"github.com/chromedp/chromedp"`
gocdp initial checkin 2019-05-29 08:29:01 +00:00			`)`

			`var (`
add flags 2019-05-29 08:52:28 +00:00			`ctx context.Context`
			`cancel context.CancelFunc`
randomized image url 2019-05-30 09:03:17 +00:00			`gifmap = make(map[string]bytes.Buffer)`
gocdp initial checkin 2019-05-29 08:29:01 +00:00			`)`

			`func pageServer(out http.ResponseWriter, req *http.Request) {`
add flags 2019-05-29 08:52:28 +00:00			`req.ParseForm()`
			`furl := req.Form["url"]`
resolve relative a href urls 2019-05-30 01:48:07 +00:00			`var gourl string`
add flags 2019-05-29 08:52:28 +00:00			`if len(furl) >= 1 && len(furl[0]) > 4 {`
resolve relative a href urls 2019-05-30 01:48:07 +00:00			`gourl = furl[0]`
add flags 2019-05-29 08:52:28 +00:00			`} else {`
randomized image url 2019-05-30 09:03:17 +00:00			`gourl = "https://www.bbc.com/news"`
add flags 2019-05-29 08:52:28 +00:00			`}`
randomized image url 2019-05-30 09:03:17 +00:00			`log.Printf("%s Page Reqest for %s [%s]\n", req.RemoteAddr, gourl, req.URL.Path)`
add flags 2019-05-29 08:52:28 +00:00			`out.Header().Set("Content-Type", "text/html")`
resolve relative a href urls 2019-05-30 01:48:07 +00:00			`fmt.Fprintf(out, "<HTML>\n<HEAD><TITLE>WRP %s</TITLE>\n<BODY BGCOLOR=\"#F0F0F0\">", gourl)`
			`fmt.Fprintf(out, "<FORM ACTION=\"/\">URL: <INPUT TYPE=\"TEXT\" NAME=\"url\" VALUE=\"%s\">", gourl)`
add flags 2019-05-29 08:52:28 +00:00			`fmt.Fprintf(out, "<INPUT TYPE=\"SUBMIT\" VALUE=\"Go\"></FORM><P>\n")`
resolve relative a href urls 2019-05-30 01:48:07 +00:00			`if len(gourl) > 4 {`
			`capture(gourl, out)`
add flags 2019-05-29 08:52:28 +00:00			`}`
			`fmt.Fprintf(out, "</BODY>\n</HTML>\n")`
gocdp initial checkin 2019-05-29 08:29:01 +00:00			`}`

			`func imgServer(out http.ResponseWriter, req *http.Request) {`
randomized image url 2019-05-30 09:03:17 +00:00			`log.Printf("%s Img Request for %s\n", req.RemoteAddr, req.URL.Path)`
			`gifbuf := gifmap[req.URL.Path]`
			`defer delete(gifmap, req.URL.Path)`
encode image as gif 2019-05-30 01:02:29 +00:00			`out.Header().Set("Content-Type", "image/gif")`
			`out.Header().Set("Content-Length", strconv.Itoa(len(gifbuf.Bytes())))`
			`out.Write(gifbuf.Bytes())`
randomized image url 2019-05-30 09:03:17 +00:00			`out.(http.Flusher).Flush()`
gocdp initial checkin 2019-05-29 08:29:01 +00:00			`}`

shutdown function via /halt url 2019-05-30 07:07:08 +00:00			`func haltServer(out http.ResponseWriter, req *http.Request) {`
			`log.Printf("%s Shutdown request received [%s]\n", req.RemoteAddr, req.URL.Path)`
			`out.Header().Set("Content-Type", "text/plain")`
			`fmt.Fprintf(out, "WRP Shutdown")`
			`out.(http.Flusher).Flush()`
			`cancel()`
			`os.Exit(0)`
			`}`

resolve relative a href urls 2019-05-30 01:48:07 +00:00			`func capture(gourl string, out http.ResponseWriter) {`
add flags 2019-05-29 08:52:28 +00:00			`var nodes []*cdp.Node`
			`ctxx := chromedp.FromContext(ctx)`
randomized image url 2019-05-30 09:03:17 +00:00			`var pngbuf []byte`
			`var gifbuf bytes.Buffer`
resolve relative a href urls 2019-05-30 01:48:07 +00:00			`var loc string`
gocdp initial checkin 2019-05-29 08:29:01 +00:00
randomized image url 2019-05-30 09:03:17 +00:00			`log.Printf("Processing Caputure Request for %s\n", gourl)`
add browser size setting 2019-05-29 09:39:06 +00:00
randomized image url 2019-05-30 09:03:17 +00:00			`// Run ChromeDP Magic`
add flags 2019-05-29 08:52:28 +00:00			`chromedp.Run(ctx,`
add browser size setting 2019-05-29 09:39:06 +00:00			`emulation.SetDeviceMetricsOverride(1024, 768, 1.0, false),`
resolve relative a href urls 2019-05-30 01:48:07 +00:00			`chromedp.Navigate(gourl),`
add flags 2019-05-29 08:52:28 +00:00			`chromedp.Sleep(time.Second*2),`
randomized image url 2019-05-30 09:03:17 +00:00			`chromedp.CaptureScreenshot(&pngbuf),`
resolve relative a href urls 2019-05-30 01:48:07 +00:00			`chromedp.Location(&loc),`
add flags 2019-05-29 08:52:28 +00:00			`chromedp.Nodes("a", &nodes, chromedp.ByQueryAll))`
gocdp initial checkin 2019-05-29 08:29:01 +00:00
resolve relative a href urls 2019-05-30 01:48:07 +00:00			`log.Printf("Landed on: %s, Got %d nodes\n", loc, len(nodes))`

randomized image url 2019-05-30 09:03:17 +00:00			`// Process Screenshot Image`
unexpected eof on windows 2019-05-30 09:15:52 +00:00			`bytes.NewReader(pngbuf).Seek(0, 0)`
randomized image url 2019-05-30 09:03:17 +00:00			`img, err := png.Decode(bytes.NewReader(pngbuf))`
resolve relative a href urls 2019-05-30 01:48:07 +00:00			`if err != nil {`
log decode error instead of bailing out 2019-05-30 06:49:39 +00:00			`log.Printf("Failed to decode screenshot: %s\n", err)`
			`fmt.Fprintf(out, "<BR>Unable to decode page screenshot:<BR>%s<BR>\n", err)`
			`return`
resolve relative a href urls 2019-05-30 01:48:07 +00:00			`}`
			`gifbuf.Reset()`
log encode errors 2019-05-30 07:53:59 +00:00			`err = gif.Encode(&gifbuf, img, nil)`
			`if err != nil {`
			`log.Printf("Failed to encode GIF: %s\n", err)`
			`fmt.Fprintf(out, "<BR>Unable to encode GIF:<BR>%s<BR>\n", err)`
			`return`
			`}`
randomized image url 2019-05-30 09:03:17 +00:00			`imgpath := fmt.Sprintf("/img/%04d.gif", rand.Intn(9999))`
			`gifmap[imgpath] = gifbuf`
encode image as gif 2019-05-30 01:02:29 +00:00
randomized image url 2019-05-30 09:03:17 +00:00			`// Process Nodes`
resolve relative a href urls 2019-05-30 01:48:07 +00:00			`base, _ := url.Parse(loc)`
randomized image url 2019-05-30 09:03:17 +00:00			`fmt.Fprintf(out, "<IMG SRC=\"%s\" ALT=\"wrp\" USEMAP=\"#map\">\n<MAP NAME=\"map\">\n", imgpath)`
			`log.Printf("Image path will be: %s", imgpath)`
gocdp initial checkin 2019-05-29 08:29:01 +00:00
add flags 2019-05-29 08:52:28 +00:00			`for _, n := range nodes {`
			`b, err := dom.GetBoxModel().WithNodeID(n.NodeID).Do(cdp.WithExecutor(ctx, ctxx.Target))`
resolve relative a href urls 2019-05-30 01:48:07 +00:00			`if err != nil {`
			`continue`
			`}`
			`tgt, err := base.Parse(n.AttributeValue("href"))`
			`if err != nil {`
			`continue`
add flags 2019-05-29 08:52:28 +00:00			`}`
resolve relative a href urls 2019-05-30 01:48:07 +00:00			`target := fmt.Sprintf("/?url=%s", tgt)`
gocdp initial checkin 2019-05-29 08:29:01 +00:00
resolve relative a href urls 2019-05-30 01:48:07 +00:00			`if len(b.Content) > 6 && len(target) > 7 {`
add flags 2019-05-29 08:52:28 +00:00			`fmt.Fprintf(out, "<AREA SHAPE=\"RECT\" COORDS=\"%.f,%.f,%.f,%.f\" ALT=\"%s\" TITLE=\"%s\" HREF=\"%s\">\n",`
			`b.Content[0], b.Content[1], b.Content[4], b.Content[5], n.AttributeValue("href"), n.AttributeValue("href"), target)`
			`}`
			`}`
gocdp initial checkin 2019-05-29 08:29:01 +00:00
add flags 2019-05-29 08:52:28 +00:00			`fmt.Fprintf(out, "</MAP>\n")`
randomized image url 2019-05-30 09:03:17 +00:00			`out.(http.Flusher).Flush()`
resolve relative a href urls 2019-05-30 01:48:07 +00:00			`log.Printf("Done with caputure for %s\n", gourl)`
gocdp initial checkin 2019-05-29 08:29:01 +00:00			`}`

			`func main() {`
add flags 2019-05-29 08:52:28 +00:00			`ctx, cancel = chromedp.NewContext(context.Background())`
			`defer cancel()`
			`var addr string`
			`flag.StringVar(&addr, "l", ":8080", "Listen address:port, default :8080")`
			`flag.Parse()`
randomized image url 2019-05-30 09:03:17 +00:00			`rand.Seed(time.Now().UnixNano())`
add flags 2019-05-29 08:52:28 +00:00			`http.HandleFunc("/", pageServer)`
randomized image url 2019-05-30 09:03:17 +00:00			`http.HandleFunc("/img/", imgServer)`
added favico handler 2019-05-30 01:47:03 +00:00			`http.HandleFunc("/favicon.ico", http.NotFound)`
shutdown function via /halt url 2019-05-30 07:07:08 +00:00			`http.HandleFunc("/halt", haltServer)`
add flags 2019-05-29 08:52:28 +00:00			`log.Printf("Starting http server on %s\n", addr)`
			`http.ListenAndServe(addr, nil)`
gocdp initial checkin 2019-05-29 08:29:01 +00:00			`}`