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, r *http.Request) {
	r.ParseForm()
	u := r.FormValue("url")
	w, _ := strconv.ParseInt(r.FormValue("w"), 10, 64)
	if w < 10 {
		w = 1024
	}
	h, _ := strconv.ParseInt(r.FormValue("h"), 10, 64)
	if h < 10 {
		h = 768
	}
	s, _ := strconv.ParseFloat(r.FormValue("s"), 64)
	if s < 0.1 {
		s = 1.0
	}
	log.Printf("%s Page Reqest for url=\"%s\" [%s]\n", r.RemoteAddr, u, r.URL.Path)
	out.Header().Set("Content-Type", "text/html")
	fmt.Fprintf(out, "<HTML>\n<HEAD><TITLE>WRP %s</TITLE>\n<BODY BGCOLOR=\"#F0F0F0\">", u)
	fmt.Fprintf(out, "<FORM ACTION=\"/\">URL: <INPUT TYPE=\"TEXT\" NAME=\"url\" VALUE=\"%s\" SIZE=\"40\">", u)
	fmt.Fprintf(out, "<INPUT TYPE=\"SUBMIT\" VALUE=\"Go\"><P>\n")
	fmt.Fprintf(out, "Width:<INPUT TYPE=\"TEXT\" NAME=\"w\" VALUE=\"%d\" SIZE=\"5\"> \n", w)
	fmt.Fprintf(out, "Height:<INPUT TYPE=\"TEXT\" NAME=\"h\" VALUE=\"%d\" SIZE=\"5\"> \n", h)
	fmt.Fprintf(out, "Scale:<INPUT TYPE=\"TEXT\" NAME=\"s\" VALUE=\"%1.2f\" SIZE=\"4\"> \n", s)
	fmt.Fprintf(out, "</FORM><P>")
	if len(u) > 4 {
		capture(u, w, h, s, out)
	} else {
		fmt.Fprintf(out, "No URL specified")
	}
	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, w int64, h int64, s float64, 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(w, h, s, 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&w=%d&h=%d&s=%1.2f", tgt, w, h, s)

		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]*s, b.Content[1]*s, b.Content[4]*s, b.Content[5]*s, 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 WRP 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			`)`

add width height and scale input boxes 2019-05-31 01:08:48 +00:00			`func pageServer(out http.ResponseWriter, r *http.Request) {`
			`r.ParseForm()`
			`u := r.FormValue("url")`
			`w, _ := strconv.ParseInt(r.FormValue("w"), 10, 64)`
			`if w < 10 {`
			`w = 1024`
			`}`
			`h, _ := strconv.ParseInt(r.FormValue("h"), 10, 64)`
			`if h < 10 {`
			`h = 768`
add flags 2019-05-29 08:52:28 +00:00			`}`
add width height and scale input boxes 2019-05-31 01:08:48 +00:00			`s, _ := strconv.ParseFloat(r.FormValue("s"), 64)`
			`if s < 0.1 {`
			`s = 1.0`
			`}`
			`log.Printf("%s Page Reqest for url=\"%s\" [%s]\n", r.RemoteAddr, u, r.URL.Path)`
add flags 2019-05-29 08:52:28 +00:00			`out.Header().Set("Content-Type", "text/html")`
add width height and scale input boxes 2019-05-31 01:08:48 +00:00			`fmt.Fprintf(out, "<HTML>\n<HEAD><TITLE>WRP %s</TITLE>\n<BODY BGCOLOR=\"#F0F0F0\">", u)`
			`fmt.Fprintf(out, "<FORM ACTION=\"/\">URL: <INPUT TYPE=\"TEXT\" NAME=\"url\" VALUE=\"%s\" SIZE=\"40\">", u)`
			`fmt.Fprintf(out, "<INPUT TYPE=\"SUBMIT\" VALUE=\"Go\"><P>\n")`
			`fmt.Fprintf(out, "Width:<INPUT TYPE=\"TEXT\" NAME=\"w\" VALUE=\"%d\" SIZE=\"5\"> \n", w)`
			`fmt.Fprintf(out, "Height:<INPUT TYPE=\"TEXT\" NAME=\"h\" VALUE=\"%d\" SIZE=\"5\"> \n", h)`
width height and scale go to area target 2019-05-31 01:10:52 +00:00			`fmt.Fprintf(out, "Scale:<INPUT TYPE=\"TEXT\" NAME=\"s\" VALUE=\"%1.2f\" SIZE=\"4\"> \n", s)`
add width height and scale input boxes 2019-05-31 01:08:48 +00:00			`fmt.Fprintf(out, "</FORM><P>")`
			`if len(u) > 4 {`
			`capture(u, w, h, s, out)`
			`} else {`
			`fmt.Fprintf(out, "No URL specified")`
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)`
			`}`

add width height and scale input boxes 2019-05-31 01:08:48 +00:00			`func capture(gourl string, w int64, h int64, s float64, 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 width height and scale input boxes 2019-05-31 01:08:48 +00:00			`emulation.SetDeviceMetricsOverride(w, h, s, 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			`}`
width height and scale go to area target 2019-05-31 01:10:52 +00:00			`target := fmt.Sprintf("/?url=%s&w=%d&h=%d&s=%1.2f", tgt, w, h, s)`
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",`
scale area map too 2019-05-31 06:40:43 +00:00			`b.Content[0]s, b.Content[1]s, b.Content[4]s, b.Content[5]s, n.AttributeValue("href"), n.AttributeValue("href"), target)`
add flags 2019-05-29 08:52:28 +00:00			`}`
			`}`
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)`
scale area map too 2019-05-31 06:40:43 +00:00			`log.Printf("Starting WRP http server on %s\n", addr)`
add flags 2019-05-29 08:52:28 +00:00			`http.ListenAndServe(addr, nil)`
gocdp initial checkin 2019-05-29 08:29:01 +00:00			`}`