ChromeDP, get whole response body

main.go

// Get the entire response body of the Navigate() (?) as a string.
package main

import (
	"context"
	"fmt"
	"log"
	"time"

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

func main() {
	opts := append(chromedp.DefaultExecAllocatorOptions[:],
		chromedp.DisableGPU,
		chromedp.NoDefaultBrowserCheck,
		chromedp.Flag("headless", false),
		chromedp.Flag("ignore-certificate-errors", true),
		chromedp.Flag("window-size", "50,400"),
	)

	allocCtx, cancel := chromedp.NewExecAllocator(context.Background(), opts...)
	defer cancel()

	// also set up a custom logger
	taskCtx, cancel := chromedp.NewContext(allocCtx, chromedp.WithLogf(log.Printf))
	defer cancel()

	// create a timeout
	taskCtx, cancel = context.WithTimeout(taskCtx, 3*time.Second)
	defer cancel()

	cRB := make(chan string)

	chromedp.ListenTarget(
		taskCtx,
		func(ev interface{}) {
			evtResp, ok := ev.(*network.EventResponseReceived)
			if !ok {
				return
			}
			if evtResp.Type != network.ResourceTypeDocument {
				return
			}

			go func() {
				c := chromedp.FromContext(taskCtx)
				rbp := network.GetResponseBody(evtResp.RequestID)
				respBody, err := rbp.Do(cdp.WithExecutor(taskCtx, c.Target))
				if err != nil {
					log.Printf("error: %q\n", err)
				}
				cRB <- string(respBody)
			}()

		},
	)

	err := chromedp.Run(taskCtx,
		network.Enable(),
		chromedp.Navigate("http://example.com"),
	)
	if err != nil {
		log.Fatal(err)
	}

	fmt.Println(<-cRB)
}