Unlock 30% off on Manual Testing Annual Plans this Holiday Season.

Copied to Clipboard!

How to use Call method of rod Package

Best Rod code snippet using rod.Call

browser_test.go

Source:browser_test.go

...58}59func TestPageFromTarget(t *testing.T) {60	g := setup(t)61	g.Panic(func() {62		res, err := proto.TargetCreateTarget{URL: "about:blank"}.Call(g.browser)63		g.E(err)64		defer func() {65			g.browser.MustPageFromTargetID(res.TargetID).MustClose()66		}()67		g.mc.stubErr(1, proto.EmulationSetDeviceMetricsOverride{})68		g.browser.MustPageFromTargetID(res.TargetID)69	})70}71func TestBrowserPages(t *testing.T) {72	g := setup(t)73	b := g.browser74	pages := b.MustPages()75	g.Gte(len(pages), 1)76	{77		g.mc.stub(1, proto.TargetGetTargets{}, func(send StubSend) (gson.JSON, error) {78			d, _ := send()79			return *d.Set("targetInfos.0.type", "iframe"), nil80		})81		b.MustPages()82	}83	g.Panic(func() {84		g.mc.stubErr(1, proto.TargetCreateTarget{})85		b.MustPage()86	})87	g.Panic(func() {88		g.mc.stubErr(1, proto.TargetGetTargets{})89		b.MustPages()90	})91	g.Panic(func() {92		_, err := proto.TargetCreateTarget{URL: "about:blank"}.Call(b)93		g.E(err)94		g.mc.stubErr(1, proto.TargetAttachToTarget{})95		b.MustPages()96	})97}98func TestBrowserClearStates(t *testing.T) {99	g := setup(t)100	g.E(proto.EmulationClearGeolocationOverride{}.Call(g.page))101}102func TestBrowserEvent(t *testing.T) {103	g := setup(t)104	messages := g.browser.Context(g.Context()).Event()105	p := g.newPage()106	wait := make(chan struct{})107	for msg := range messages {108		e := proto.TargetAttachedToTarget{}109		if msg.Load(&e) {110			g.Eq(e.TargetInfo.TargetID, p.TargetID)111			close(wait)112			break113		}114	}115	<-wait116}117func TestBrowserWaitEvent(t *testing.T) {118	g := setup(t)119	g.NotNil(g.browser.Context(g.Context()).Event())120	wait := g.page.WaitEvent(proto.PageFrameNavigated{})121	g.page.MustNavigate(g.blank())122	wait()123	wait = g.browser.EachEvent(func(e *proto.PageFrameNavigated, id proto.TargetSessionID) bool {124		return true125	})126	g.page.MustNavigate(g.blank())127	wait()128}129func TestBrowserCrash(t *testing.T) {130	g := setup(t)131	browser := rod.New().Context(g.Context()).MustConnect()132	page := browser.MustPage()133	js := `() => new Promise(r => setTimeout(r, 10000))`134	go g.Panic(func() {135		page.MustEval(js)136	})137	utils.Sleep(0.2)138	_ = proto.BrowserCrash{}.Call(browser)139	utils.Sleep(0.3)140	_, err := page.Eval(js)141	g.Has(err.Error(), "use of closed network connection")142}143func TestBrowserCall(t *testing.T) {144	g := setup(t)145	v, err := proto.BrowserGetVersion{}.Call(g.browser)146	g.E(err)147	g.Regex("1.3", v.ProtocolVersion)148}149func TestBlockingNavigation(t *testing.T) {150	g := setup(t)151	/*152		Navigate can take forever if a page doesn't response.153		If one page is blocked, other pages should still work.154	*/155	s := g.Serve()156	pause := g.Context()157	s.Mux.HandleFunc("/a", func(w http.ResponseWriter, r *http.Request) {158		<-pause.Done()159	})160	s.Route("/b", ".html", `<html>ok</html>`)161	blocked := g.newPage()162	go func() {163		g.Panic(func() {164			blocked.MustNavigate(s.URL("/a"))165		})166	}()167	utils.Sleep(0.3)168	g.newPage(s.URL("/b"))169}170func TestResolveBlocking(t *testing.T) {171	g := setup(t)172	s := g.Serve()173	pause := g.Context()174	s.Mux.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {175		<-pause.Done()176	})177	p := g.newPage()178	go func() {179		utils.Sleep(0.1)180		p.MustStopLoading()181	}()182	g.Panic(func() {183		p.MustNavigate(s.URL())184	})185}186func TestTestTry(t *testing.T) {187	g := setup(t)188	g.Nil(rod.Try(func() {}))189	err := rod.Try(func() { panic(1) })190	var errVal *rod.ErrTry191	g.True(errors.As(err, &errVal))192	g.Is(err, &rod.ErrTry{})193	g.Eq(errVal.Unwrap().Error(), "1")194	g.Eq(1, errVal.Value)195	g.Has(errVal.Error(), "error value: 1\ngoroutine")196	errVal = rod.Try(func() { panic(errors.New("t")) }).(*rod.ErrTry)197	g.Eq(errVal.Unwrap().Error(), "t")198}199func TestBrowserOthers(t *testing.T) {200	g := setup(t)201	g.browser.Timeout(time.Second).CancelTimeout().MustGetCookies()202}203func TestBinarySize(t *testing.T) {204	g := setup(t)205	if runtime.GOOS == "windows" || utils.InContainer {206		g.SkipNow()207	}208	cmd := exec.Command("go", "build",209		"-trimpath",210		"-ldflags", "-w -s",211		"-o", "tmp/translator",212		"./lib/examples/translator")213	cmd.Env = append(os.Environ(), "GOOS=linux")214	g.Nil(cmd.Run())215	stat, err := os.Stat("tmp/translator")216	g.E(err)217	g.Lte(float64(stat.Size())/1024/1024, 10.4) // mb218}219func TestBrowserCookies(t *testing.T) {220	g := setup(t)221	b := g.browser.MustIncognito()222	defer b.MustClose()223	b.MustSetCookies(&proto.NetworkCookie{224		Name:   "a",225		Value:  "val",226		Domain: "test.com",227	})228	cookies := b.MustGetCookies()229	g.Len(cookies, 1)230	g.Eq(cookies[0].Name, "a")231	g.Eq(cookies[0].Value, "val")232	{233		b.MustSetCookies()234		cookies := b.MustGetCookies()235		g.Len(cookies, 0)236	}237	g.mc.stubErr(1, proto.StorageGetCookies{})238	g.Err(b.GetCookies())239}240func TestWaitDownload(t *testing.T) {241	g := setup(t)242	s := g.Serve()243	content := "test content"244	s.Route("/d", ".bin", []byte(content))245	s.Route("/page", ".html", fmt.Sprintf(`<html><a href="%s/d" download>click</a></html>`, s.URL()))246	page := g.page.MustNavigate(s.URL("/page"))247	wait := g.browser.MustWaitDownload()248	page.MustElement("a").MustClick()249	data := wait()250	g.Eq(content, string(data))251}252func TestWaitDownloadDataURI(t *testing.T) {253	g := setup(t)254	s := g.Serve()255	s.Route("/", ".html",256		`<html>257			<a id="a" href="data:text/plain;,test%20data" download>click</a>258			<a id="b" download>click</a>259			<script>260				const b = document.getElementById('b')261				b.href = URL.createObjectURL(new Blob(['test blob'], {262					type: "text/plain; charset=utf-8"263				}))264			</script>265		</html>`,266	)267	page := g.page.MustNavigate(s.URL())268	wait1 := g.browser.MustWaitDownload()269	page.MustElement("#a").MustClick()270	data := wait1()271	g.Eq("test data", string(data))272	wait2 := g.browser.MustWaitDownload()273	page.MustElement("#b").MustClick()274	data = wait2()275	g.Eq("test blob", string(data))276}277func TestWaitDownloadCancel(t *testing.T) {278	g := setup(t)279	wait := g.browser.Context(g.Timeout(0)).WaitDownload(os.TempDir())280	g.Eq(wait(), (*proto.PageDownloadWillBegin)(nil))281}282func TestWaitDownloadFromNewPage(t *testing.T) {283	g := setup(t)284	s := g.Serve()285	content := "test content"286	s.Route("/d", ".bin", content)287	s.Route("/page", ".html", fmt.Sprintf(288		`<html><a href="%s/d" download target="_blank">click</a></html>`,289		s.URL()),290	)291	page := g.page.MustNavigate(s.URL("/page"))292	wait := g.browser.MustWaitDownload()293	page.MustElement("a").MustClick()294	data := wait()295	g.Eq(content, string(data))296}297func TestBrowserConnectErr(t *testing.T) {298	g := setup(t)299	g.Panic(func() {300		rod.New().ControlURL(g.RandStr(16)).MustConnect()301	})302}303func TestStreamReader(t *testing.T) {304	g := setup(t)305	r := rod.NewStreamReader(g.page, "")306	g.mc.stub(1, proto.IORead{}, func(send StubSend) (gson.JSON, error) {307		return gson.New(proto.IOReadResult{308			Data: "test",309		}), nil310	})311	b := make([]byte, 4)312	_, _ = r.Read(b)313	g.Eq("test", string(b))314	g.mc.stubErr(1, proto.IORead{})315	_, err := r.Read(nil)316	g.Err(err)317	g.mc.stub(1, proto.IORead{}, func(send StubSend) (gson.JSON, error) {318		return gson.New(proto.IOReadResult{319			Base64Encoded: true,320			Data:          "@",321		}), nil322	})323	_, err = r.Read(nil)324	g.Err(err)325}326func TestBrowserConnectFailure(t *testing.T) {327	g := setup(t)328	c := g.Context()329	c.Cancel()330	err := rod.New().Context(c).Connect()331	if err == nil {332		g.Fatal("expected an error on connect failure")333	}334}335func TestBrowserPool(t *testing.T) {336	pool := rod.NewBrowserPool(3)337	create := func() *rod.Browser { return rod.New().MustConnect() }338	b := pool.Get(create)339	pool.Put(b)340	pool.Cleanup(func(p *rod.Browser) {341		p.MustClose()342	})343}344func TestOldBrowser(t *testing.T) {345	t.Skip()346	g := setup(t)347	u := launcher.New().Revision(686378).MustLaunch()348	b := rod.New().ControlURL(u).MustConnect()349	g.Cleanup(b.MustClose)350	res, err := proto.BrowserGetVersion{}.Call(b)351	g.E(err)352	g.Eq(res.Revision, "@19d4547535ab5aba70b4730443f84e8153052174")353}354func TestBrowserLostConnection(t *testing.T) {355	g := setup(t)356	l := launcher.New()357	p := rod.New().ControlURL(l.MustLaunch()).MustConnect().MustPage(g.blank())358	go func() {359		utils.Sleep(1)360		l.Kill()361	}()362	_, err := p.Eval(`() => new Promise(r => {})`)363	g.Err(err)364}...

setup_test.go

Source:setup_test.go

...167		if g.Failed() {168			return169		}170		// close all other pages other than g.page171		res, err := proto.TargetGetTargets{}.Call(g.browser)172		g.E(err)173		for _, info := range res.TargetInfos {174			if info.TargetID != g.page.TargetID {175				g.E(proto.TargetCloseTarget{TargetID: info.TargetID}.Call(g.browser))176			}177		}178		if g.browser.LoadState(g.page.SessionID, &proto.FetchEnable{}) {179			g.Logf("leaking FetchEnable")180			g.FailNow()181		}182		g.mc.setCall(nil)183	})184}185type Call func(ctx context.Context, sessionID, method string, params interface{}) ([]byte, error)186var _ rod.CDPClient = &MockClient{}187type MockClient struct {188	sync.RWMutex189	id        string190	t         got.Testable191	log       *log.Logger192	principal *cdp.Client193	call      Call194	event     <-chan *cdp.Event195}196var mockClientCount int32197func newMockClient(u string) *MockClient {198	id := fmt.Sprintf("%02d", atomic.AddInt32(&mockClientCount, 1))199	// create init log file200	utils.E(os.MkdirAll(filepath.Join(LogDir, id), 0755))201	f, err := os.Create(filepath.Join(LogDir, id, "_.log"))202	log := log.New(f, "", log.Ltime)203	utils.E(err)204	client := cdp.New().Logger(utils.MultiLogger(defaults.CDP, log)).Start(cdp.MustConnectWS(u))205	return &MockClient{id: id, principal: client, log: log}206}207func (mc *MockClient) Event() <-chan *cdp.Event {208	if mc.event != nil {209		return mc.event210	}211	return mc.principal.Event()212}213func (mc *MockClient) Call(ctx context.Context, sessionID, method string, params interface{}) ([]byte, error) {214	return mc.getCall()(ctx, sessionID, method, params)215}216func (mc *MockClient) getCall() Call {217	mc.RLock()218	defer mc.RUnlock()219	if mc.call == nil {220		return mc.principal.Call221	}222	return mc.call223}224func (mc *MockClient) setCall(fn Call) {225	mc.Lock()226	defer mc.Unlock()227	if mc.call != nil {228		mc.t.Logf("leaking MockClient.stub")229		mc.t.Fail()230	}231	mc.call = fn232}233func (mc *MockClient) resetCall() {234	mc.Lock()235	defer mc.Unlock()236	mc.call = nil237}238// Use it to find out which cdp call to intercept. Put a print like log.Println("*****") after the cdp call you want to intercept.239// The output of the test should has something like:240//241//	[stubCounter] begin242//	[stubCounter] 1, proto.DOMResolveNode{}243//	[stubCounter] 1, proto.RuntimeCallFunctionOn{}244//	[stubCounter] 2, proto.RuntimeCallFunctionOn{}245//	01:49:43 *****246//247// So the 3rd call is the one we want to intercept, then you can use the output with s.at or s.errorAt.248func (mc *MockClient) stubCounter() {249	l := sync.Mutex{}250	mCount := map[string]int{}251	fmt.Fprintln(os.Stdout, "[stubCounter] begin")252	mc.setCall(func(ctx context.Context, sessionID, method string, params interface{}) ([]byte, error) {253		l.Lock()254		mCount[method]++255		m := fmt.Sprintf("%d, proto.%s{}", mCount[method], proto.GetType(method).Name())256		_, _ = fmt.Fprintln(os.Stdout, "[stubCounter]", m)257		l.Unlock()258		return mc.principal.Call(ctx, sessionID, method, params)259	})260}261type StubSend func() (gson.JSON, error)262// When call the cdp.Client.Call the nth time use fn instead.263// Use p to filter method.264func (mc *MockClient) stub(nth int, p proto.Request, fn func(send StubSend) (gson.JSON, error)) {265	if p == nil {266		mc.t.Logf("p must be specified")267		mc.t.FailNow()268	}269	count := int64(0)270	mc.setCall(func(ctx context.Context, sessionID, method string, params interface{}) ([]byte, error) {271		if method == p.ProtoReq() {272			if int(atomic.AddInt64(&count, 1)) == nth {273				mc.resetCall()274				j, err := fn(func() (gson.JSON, error) {275					b, err := mc.principal.Call(ctx, sessionID, method, params)276					return gson.New(b), err277				})278				if err != nil {279					return nil, err280				}281				return j.MarshalJSON()282			}283		}284		return mc.principal.Call(ctx, sessionID, method, params)285	})286}287// When call the cdp.Client.Call the nth time return error.288// Use p to filter method.289func (mc *MockClient) stubErr(nth int, p proto.Request) {290	mc.stub(nth, p, func(send StubSend) (gson.JSON, error) {291		return gson.New(nil), errors.New("mock error")292	})293}294type MockRoundTripper struct {295	res *http.Response296	err error297}298func (mrt *MockRoundTripper) RoundTrip(*http.Request) (*http.Response, error) {299	return mrt.res, mrt.err300}301type MockReader struct {...

example_test.go

Source:example_test.go

...21	}()22	// Such as call this endpoint on the api doc:23	// https://chromedevtools.github.io/devtools-protocol/tot/Page#method-navigate24	// This will create a new tab and navigate to the test.com25	res, err := client.Call(ctx, "", "Target.createTarget", map[string]string{26		"url": "http://test.com",27	})28	utils.E(err)29	fmt.Println(len(gson.New(res).Get("targetId").Str()))30	// close browser by using the proto lib to encode json31	_ = proto.BrowserClose{}.Call(client)32	// Output: 3233}34func Example_customize_cdp_log() {35	ws := cdp.MustConnectWS(launcher.New().MustLaunch())36	cdp.New().37		Logger(utils.Log(func(args ...interface{}) {38			switch v := args[0].(type) {39			case *cdp.Request:40				fmt.Printf("id: %d", v.ID)41			}42		})).43		Start(ws)44}...

Call

Using AI Code Generation

1import "fmt"2import "math"3type Circle struct {4}5func circleArea(c *Circle) float64 {6}7func main() {8    c := Circle{0, 0, 5}9    fmt.Println(circleArea(&c))10}

Call

Using AI Code Generation

1import (2func main() {3	browser := rod.New().Connect()4	page.Element("input[name=q]").Input("Rod")5	page.Keyboard.Press("Enter")6	fmt.Println(page.Element("h3").Text())7}8import (9func main() {10	browser := rod.New().Connect()11	page.Element("input[name=q]").Input("Rod")12	page.Keyboard.Press("Enter")13	fmt.Println(page.Eval("document.querySelector('h3').innerText"))14}15import (16func main() {17	browser := rod.New().Connect()18	page.Element("input[name=q]").Input("Rod")19	page.Keyboard.Press("Enter")20	fmt.Println(page.Eval("document.querySelector('h3').innerText"))21}22import (23func main() {24	browser := rod.New().Connect()25	page.Element("input[name=q]").Input("Rod")26	page.Keyboard.Press("Enter")27	fmt.Println(page.Eval("document.querySelector('h3').innerText"))28}29import (30func main() {31	browser := rod.New().Connect()32	page.Element("input[name=q]").Input("Rod")33	page.Keyboard.Press("Enter")34	fmt.Println(page.Eval("document.querySelector('h3').innerText"))35}36import (37func main() {38	browser := rod.New().Connect()39	page.Element("input[name=q

Call

Using AI Code Generation

1import "fmt"2func main() {3    rod := Rod{Length: 10}4    fmt.Println("rod length is", rod.Length)5    rod.Call(5)6    fmt.Println("rod length is", rod.Length)7}8type Rod struct {9}10func (r *Rod) Call(x int) {11}12import "fmt"13func main() {14    rod := Rod{Length: 10}15    fmt.Println("rod length is", rod.Length)16    rod.Call(5)17    fmt.Println("rod length is", rod.Length)18}19type Rod struct {20}21func (r *Rod) Call(x int) {22}23import "fmt"24func main() {25    rod := Rod{Length: 10}26    fmt.Println("rod length is", rod.Length)27    rod.Call(5)28    fmt.Println("rod length is", rod.Length)29}30type Rod struct {31}32func (r Rod) Call(x int) {33}34import "fmt"35func main() {36    rod := Rod{Length: 10}37    fmt.Println("rod length is", rod.Length)38    rod.Call(5)39    fmt.Println("rod length is", rod.Length)40}41type Rod struct {42}43func (r Rod) Call(x int) {44}

Call

Using AI Code Generation

1import (2type rod struct {3}4func (r *rod) Call() {5	fmt.Println("Call method of rod class")6}7func main() {8	r := rod{name: "Rod"}

Call

Using AI Code Generation

1import (2func main() {3	r := rod.NewRod(1, 2)4	fmt.Println(r.Call())5}6import (7func main() {8	r := rod.NewRod(1, 2)9	fmt.Println(r.Call())10}11import (12func main() {13	r := rod.NewRod(1, 2)14	fmt.Println(r.Call())15}16import (17func main() {18	r := rod.NewRod(1, 2)19	fmt.Println(r.Call())20}21import (22func main() {23	r := rod.NewRod(1, 2)24	fmt.Println(r.Call())25}26import (27func main() {

Call

Using AI Code Generation

1import (2func main() {3	rod1 := new(rod.Rod)4	fmt.Println("Rod created: ", rod1)5	rod1.Call()6}7import (8func main() {9	rod1 := new(rod.Rod)10	fmt.Println("Rod created: ", rod1)11	rod1.Call()12}13import (14func main() {15	rod1 := new(rod.Rod)16	fmt.Println("Rod created: ", rod1)17	rod1.Call()18}19import (20func main() {21	rod1 := new(rod.Rod)22	fmt.Println("Rod created: ", rod1)23	rod1.Call()24}25import (26func main() {27	rod1 := new(rod.Rod)28	fmt.Println("Rod created: ", rod1)29	rod1.Call()30}31import (32func main() {33	rod1 := new(rod.Rod)34	fmt.Println("Rod created: ", rod1)35	rod1.Call()36}37import (

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.