Test your AI Agents with the all-new Agent to Agent Testing Platform.Learn More

How to use WithQuery method of wait Package

Best Testcontainers-go code snippet using wait.WithQuery

api_service_test.go

Source:api_service_test.go

...38	err = seed.WaitUntilTailHeight(b.Height(), 10*time.Second)39	require.NoError(t, err)40	e := httpexpect.New(t, testutil.IP2Local(seed.Config.Config.Rpc.HttpListen[0]))41	e.GET("/v1/account").42		WithQuery("type", "tail").43		WithQuery("address", payer.Addr).44		Expect().45		Status(http.StatusOK).46		JSON().Object().47		ValueEqual("address", payer.Address()).48		ValueEqual("balance", "0").49		ValueEqual("nonce", "1").50		ValueEqual("staking", "200000000000000000000").51		ValueEqual("voted", []string{}).52		ValueNotEqual("points", "0").53		ValueEqual("unstaking", "0")54	e.GET("/v1/account").55		WithQuery("address", payer.Addr).56		WithQuery("height", 2).57		Expect().58		Status(http.StatusOK).59		JSON().Object().60		ValueEqual("address", payer.Address()).61		ValueEqual("balance", "0").62		ValueEqual("nonce", "1").63		ValueEqual("staking", "200000000000000000000").64		ValueEqual("voted", []string{}).65		ValueNotEqual("points", "0").66		ValueEqual("unstaking", "0")67	e.GET("/v1/account").68		WithQuery("address", payer.Addr).69		WithQuery("height", 3).70		Expect().71		Status(http.StatusBadRequest).72		JSON().Object().73		ValueEqual("error", rpc.ErrMsgInvalidBlockHeight)74	e.GET("/v1/account").75		WithQuery("address", payer.Addr).76		WithQuery("type", "genesis").77		Expect().78		Status(http.StatusOK).79		JSON().Object().80		ValueEqual("staking", "0")81	e.GET("/v1/account").82		WithQuery("address", payer.Addr).83		WithQuery("type", "confirmed").84		Expect().85		Status(http.StatusOK).86		JSON().Object().87		ValueEqual("staking", "0")88	e.GET("/v1/account").89		WithQuery("address", payer.Addr).90		Expect().91		Status(http.StatusBadRequest).92		JSON().Object().93		ValueEqual("error", rpc.ErrMsgInvalidRequest)94	e.GET("/v1/account").95		WithQuery("address", payer.Addr).96		WithQuery("alias", "Hello World").97		Expect().98		Status(http.StatusBadRequest).99		JSON().Object().100		ValueEqual("error", rpc.ErrMsgInvalidRequest)101	e.GET("/v1/account").102		WithQuery("type", "confirmed").103		Expect().104		Status(http.StatusBadRequest).105		JSON().Object().106		ValueEqual("error", rpc.ErrMsgInvalidRequest)107	// TODO @jiseob alias test108}109func TestAPIService_GetBlock(t *testing.T) {110	network := testutil.NewNetwork(t)111	defer network.Cleanup()112	seed := network.NewSeedNode()113	seed.Start()114	network.WaitForEstablished()115	bb := blockutil.New(t, 3).AddKeyPairs(seed.Config.TokenDist)116	b := bb.Block(seed.GenesisBlock()).117		ChildWithTimestamp(dpos.NextMintSlotInSec(time.Now().Unix())).118		Stake().Tx().RandomTx().Execute().SignProposer().Build()119	err := seed.Med.BlockManager().PushBlockData(b.BlockData)120	assert.NoError(t, err)121	err = seed.WaitUntilTailHeight(b.Height(), 10*time.Second)122	require.NoError(t, err)123	e := httpexpect.New(t, testutil.IP2Local(seed.Config.Config.Rpc.HttpListen[0]))124	// The block response should be the same one for designated hash, type, height parameter125	e.GET("/v1/block").126		WithQuery("hash", "0123456789012345678901234567890123456789012345678901234567890123").127		Expect().128		Status(http.StatusNotFound).129		JSON().Object().130		ValueEqual("error", rpc.ErrMsgBlockNotFound)131	e.GET("/v1/block").132		WithQuery("hash", byteutils.Bytes2Hex(b.Hash())).133		Expect().134		Status(http.StatusOK).135		JSON().Object().136		ValueEqual("height", "2")137	e.GET("/v1/block").138		WithQuery("type", "tail").139		Expect().140		Status(http.StatusOK).141		JSON().Object().142		ValueEqual("height", "2")143	e.GET("/v1/block").144		WithQuery("height", "2").145		Expect().146		Status(http.StatusOK).147		JSON().Object().148		ValueEqual("height", "2")149	// The block response should be the genesis one150	e.GET("/v1/block").151		WithQuery("type", "genesis").152		Expect().153		Status(http.StatusOK).154		JSON().Object().155		ValueEqual("height", "1")156	// Check block response parameters157	e.GET("/v1/block").158		WithQuery("type", "tail").159		Expect().160		Status(http.StatusOK).161		JSON().Object().162		ContainsKey("height").163		ContainsKey("hash").164		ContainsKey("parent_hash").165		ContainsKey("coinbase").166		ContainsKey("reward").167		ContainsKey("supply").168		ContainsKey("timestamp").169		ContainsKey("chain_id").170		ContainsKey("sign").171		ContainsKey("accs_root").172		ContainsKey("txs_root").173		ContainsKey("dpos_root").174		ContainsKey("transactions")175	e.GET("/v1/block").176		WithQuery("type", "confirmed").177		Expect().178		Status(http.StatusOK).179		JSON().Object().180		ValueEqual("height", "1")181	e.GET("/v1/block").182		WithQuery("height", "5").183		Expect().184		Status(http.StatusBadRequest).185		JSON().Object().186		ValueEqual("error", rpc.ErrMsgInvalidBlockHeight)187	e.GET("/v1/block").188		WithQuery("type", "genesis").189		WithQuery("height", "1").190		Expect().191		Status(http.StatusBadRequest).192		JSON().Object().193		ValueEqual("error", rpc.ErrMsgInvalidRequest)194}195func TestAPIService_GetBlocks(t *testing.T) {196	network := testutil.NewNetwork(t)197	defer network.Cleanup()198	seed := network.NewSeedNode()199	seed.Start()200	network.WaitForEstablished()201	bb := blockutil.New(t, 3).AddKeyPairs(seed.Config.TokenDist)202	b := bb.Block(seed.GenesisBlock()).203		ChildWithTimestamp(dpos.NextMintSlotInSec(time.Now().Unix())).SignProposer().Build()204	err := seed.Med.BlockManager().PushBlockData(b.BlockData)205	assert.NoError(t, err)206	err = seed.WaitUntilTailHeight(b.Height(), 10*time.Second)207	require.NoError(t, err)208	e := httpexpect.New(t, testutil.IP2Local(seed.Config.Config.Rpc.HttpListen[0]))209	schema := `210	{211		"type":"object",212		"properties":{213			"blocks":{214				"type":"array",215				"items":{216					"type":"object",217					"properties":{218						"height": {219							"type":"string"220						}221					}222				},223				"minItems":2224			}225		}226	}`227	e.GET("/v1/blocks").228		WithQuery("from", "1").229		WithQuery("to", "5").230		Expect().JSON().Schema(schema)231	e.GET("/v1/blocks").232		WithQuery("from", "2").233		WithQuery("to", "1").234		Expect().235		Status(http.StatusBadRequest).236		JSON().Object().237		ValueEqual("error", rpc.ErrMsgInvalidRequest)238	e.GET("/v1/blocks").239		WithQuery("from", "1").240		WithQuery("to", rpc.MaxBlocksCount+2).241		Expect().242		Status(http.StatusBadRequest).243		JSON().Object().244		ValueEqual("error", rpc.ErrMsgTooManyBlocksRequest)245}246func TestAPIService_GetCandidates(t *testing.T) {247	network := testutil.NewNetwork(t)248	defer network.Cleanup()249	seed := network.NewSeedNode()250	seed.Start()251	network.WaitForEstablished()252	e := httpexpect.New(t, testutil.IP2Local(seed.Config.Config.Rpc.HttpListen[0]))253	e.GET("/v1/candidates").254		Expect().JSON().255		Path("$.candidates").256		Array().Length().Equal(3)257}258func TestAPIService_GetCandidate(t *testing.T) {259	network := testutil.NewNetwork(t)260	defer network.Cleanup()261	seed := network.NewSeedNode()262	seed.Start()263	network.WaitForEstablished()264	e := httpexpect.New(t, testutil.IP2Local(seed.Config.Config.Rpc.HttpListen[0]))265	TX := &core.Transaction{}266	for _, tx := range seed.GenesisBlock().Transactions() {267		if tx.TxType() == transaction.TxOpBecomeCandidate {268			TX = tx269			break270		}271	}272	e.GET("/v1/candidate").273		WithQuery("candidate_id", byteutils.Bytes2Hex(TX.Hash())).274		Expect().JSON().Object().275		ValueEqual("candidate_id", byteutils.Bytes2Hex(TX.Hash())).276		ValueEqual("address", TX.From().String())277}278func TestAPIService_GetDynasty(t *testing.T) {279	network := testutil.NewNetwork(t)280	defer network.Cleanup()281	seed := network.NewSeedNode()282	seed.Start()283	network.WaitForEstablished()284	b := blockutil.New(t, blockutil.DynastySize).AddKeyPairs(seed.Config.Dynasties).285		Block(seed.Tail()).Child().SignProposer().Build()286	err := seed.Med.BlockManager().PushBlockData(b.BlockData)287	require.NoError(t, err)288	err = seed.WaitUntilTailHeight(b.Height(), 10*time.Second)289	require.NoError(t, err)290	e := httpexpect.New(t, testutil.IP2Local(seed.Config.Config.Rpc.HttpListen[0]))291	addrs := e.GET("/v1/dynasty").292		Expect().JSON().293		Path("$.addresses").294		Array()295	addrs.Length().Equal(3)296	for _, addr := range addrs.Iter() {297		assert.True(t, common.IsHexAddress(addr.String().Raw()))298	}299}300func TestAPIService_GetMedState(t *testing.T) {301	network := testutil.NewNetwork(t)302	defer network.Cleanup()303	seed := network.NewSeedNode()304	seed.Start()305	network.WaitForEstablished()306	genesis := seed.Tail()307	bb := blockutil.New(t, 3).AddKeyPairs(seed.Config.TokenDist).Block(seed.GenesisBlock()).ChildWithTimestamp(dpos.308		NextMintSlotInSec(time.Now().Unix()))309	b := bb.SignProposer().Build()310	err := seed.Med.BlockManager().PushBlockData(b.BlockData)311	assert.NoError(t, err)312	err = seed.WaitUntilTailHeight(b.Height(), 10*time.Second)313	require.NoError(t, err)314	e := httpexpect.New(t, testutil.IP2Local(seed.Config.Config.Rpc.HttpListen[0]))315	e.GET("/v1/node/medstate").316		Expect().JSON().Object().317		ValueEqual("height", "2").318		ValueEqual("lib", byteutils.Bytes2Hex(genesis.Hash())).319		ValueEqual("tail", byteutils.Bytes2Hex(b.Hash()))320}321// TODO fix322//func TestAPIService_GetPendingTransactions(t *testing.T) {323//	network := testutil.NewNetwork(t)324//	defer network.Cleanup()325//326//	seed := network.NewSeedNode()327//	seed.Start()328//	network.WaitForEstablished()329//330//	bb := blockutil.New(t, 3).AddKeyPairs(seed.Config.TokenDist).Block(seed.GenesisBlock()).ChildWithTimestamp(dpos.331//		NextMintSlotInSec(time.Now().Unix()))332//333//	e := httpexpect.New(t, testutil.IP2Local(seed.Config.Config.Rpc.HttpListen[0]))334//335//	e.GET("/v1/transactions/pending").336//		Expect().JSON().337//		Path("$.transactions").338//		Array().Length().Equal(0)339//340//	tb := bb.Tx()341//	for i := 0; i < 10; i++ {342//		tx := tb.Nonce(5 + uint64(i)).RandomTx().Build()343//		err := seed.Med.TransactionManager().Push(tx)344//		require.NoError(t, err)345//		assert.Equal(t, tx, seed.Med.TransactionManager().Get(tx.Hash()))346//	}347//348//	e.GET("/v1/transactions/pending").349//		Expect().JSON().350//		Path("$.transactions").351//		Array().Length().Equal(10)352//}353func TestAPIService_GetTransaction(t *testing.T) {354	network := testutil.NewNetwork(t)355	defer network.Cleanup()356	seed := network.NewSeedNode()357	seed.Start()358	network.WaitForEstablished()359	bb := blockutil.New(t, blockutil.DynastySize).AddKeyPairs(seed.Config.TokenDist).Block(seed.GenesisBlock()).Child().Stake()360	tx := bb.Tx().RandomTx().Build()361	b := bb.ExecuteTx(tx).SignProposer().Build()362	err := seed.Med.BlockManager().PushBlockData(b.BlockData)363	assert.NoError(t, err)364	err = seed.WaitUntilTailHeight(b.Height(), 10*time.Second)365	require.NoError(t, err)366	e := httpexpect.New(t, testutil.IP2Local(seed.Config.Config.Rpc.HttpListen[0]))367	e.GET("/v1/transaction").368		WithQuery("hash", byteutils.Bytes2Hex(tx.Hash())).369		Expect().370		JSON().Object().371		ValueEqual("hash", byteutils.Bytes2Hex(tx.Hash())).372		ValueEqual("on_chain", true)373	e.GET("/v1/transaction").374		WithQuery("hash", "0123456789").375		Expect().376		Status(http.StatusBadRequest).377		JSON().Object().378		ValueEqual("error", rpc.ErrMsgInvalidTxHash)379	tx = bb.Tx().RandomTx().Build()380	err = seed.Med.TransactionManager().Push(tx)381	require.NoError(t, err)382	e.GET("/v1/transaction").383		WithQuery("hash", byteutils.Bytes2Hex(tx.Hash())).384		Expect().385		JSON().Object().386		ValueEqual("hash", byteutils.Bytes2Hex(tx.Hash())).387		ValueEqual("on_chain", false)388	e.GET("/v1/transaction").389		WithQuery("hash", "0123456789012345678901234567890123456789012345678901234567890123").390		Expect().391		JSON().Object().392		ValueEqual("error", rpc.ErrMsgTransactionNotFound)393}394func TestAPIService_GetTransactionReceipt(t *testing.T) {395	network := testutil.NewNetwork(t)396	defer network.Cleanup()397	seed := network.NewSeedNode()398	seed.Start()399	network.WaitForEstablished()400	bb := blockutil.New(t, 3).AddKeyPairs(seed.Config.TokenDist).Block(seed.GenesisBlock()).ChildWithTimestamp(dpos.401		NextMintSlotInSec(time.Now().Unix())).Stake()402	payer := seed.Config.TokenDist[blockutil.DynastySize]403	recordHash, err := byteutils.Hex2Bytes("255607ec7ef55d7cfd8dcb531c4aa33c4605f8aac0f5784a590041690695e6f7")404	require.NoError(t, err)405	payload := &transaction.AddRecordPayload{406		RecordHash: recordHash,407	}408	tx1 := bb.Tx().Nonce(2).Type(transaction.TxOpAddRecord).Payload(payload).SignPair(payer).Build()409	tx2 := bb.Tx().Nonce(3).Type(transaction.TxOpAddRecord).Payload(payload).SignPair(payer).Build()410	b := bb.ExecuteTx(tx1).ExecuteTxErr(tx2, transaction.ErrRecordAlreadyAdded).SignProposer().Build()411	err = seed.Med.BlockManager().PushBlockData(b.BlockData)412	assert.NoError(t, err)413	err = seed.WaitUntilTailHeight(b.Height(), 10*time.Second)414	require.NoError(t, err)415	e := httpexpect.New(t, testutil.IP2Local(seed.Config.Config.Rpc.HttpListen[0]))416	e.GET("/v1/transaction/receipt").417		WithQuery("hash", byteutils.Bytes2Hex(tx1.Hash())).418		Expect().419		JSON().Object().420		ValueEqual("error", "").421		ValueEqual("executed", true).422		ValueEqual("cpu_usage", strconv.FormatUint(tx1.Receipt().CPUUsage(), 10)).423		ValueEqual("net_usage", strconv.FormatUint(tx1.Receipt().NetUsage(), 10))424	e.GET("/v1/transaction/receipt").425		WithQuery("hash", byteutils.Bytes2Hex(tx2.Hash())).426		Expect().427		JSON().Object().428		ValueEqual("executed", false).429		ValueEqual("error", transaction.ErrRecordAlreadyAdded.Error()).430		ValueEqual("cpu_usage", strconv.FormatUint(tx2.Receipt().CPUUsage(), 10)).431		ValueEqual("net_usage", strconv.FormatUint(tx2.Receipt().NetUsage(), 10))432	e.GET("/v1/transaction/receipt").433		WithQuery("hash", "0123456789").434		Expect().435		Status(http.StatusBadRequest).436		JSON().Object().437		ValueEqual("error", rpc.ErrMsgInvalidTxHash)438	e.GET("/v1/transaction/receipt").439		WithQuery("hash", "0123456789012345678901234567890123456789012345678901234567890123").440		Expect().441		JSON().Object().442		ValueEqual("error", rpc.ErrMsgTransactionNotFound)443}444func TestAPIService_HealthCheck(t *testing.T) {445	network := testutil.NewNetwork(t)446	defer network.Cleanup()447	seed := network.NewSeedNode()448	seed.Start()449	network.WaitForEstablished()450	e := httpexpect.New(t, testutil.IP2Local(seed.Config.Config.Rpc.HttpListen[0]))451	e.GET("/v1/healthcheck").452		Expect().453		JSON().Object()....

v1_test.go

Source:v1_test.go

...26	test.DoAPITest(t, "Request kebab shops within a box", apispecs.API_V1_SpecsFile,27		func(t *testing.T, env *test.APITestEnvironment) {28			env.LoadOSMTestData(t)29			resp := env.Expect.GET("/api/v1/kebabshops/box").30				WithQuery("ltm", 50).31				WithQuery("ltx", 60).32				WithQuery("lnm", 10).33				WithQuery("lnx", 20).34				Expect().Status(http.StatusOK).JSON()35			cords := resp.Path("$.cords").Array()36			cords.NotEmpty()37			for _, v := range cords.Iter() {38				v.Schema(`{39					"type": "object",40					"properties": {41					   "id": {42						   "type": "string"43					   },44					   "lat": {45						   "type": "number"46					   },47					   "lng": {48						   "type": "number"49					   }50				   },51				   "require": ["id", "lat", "lng"]52				 }`)53			}54		})55	test.DoAPITest(t, "Request only kebab shops within a box that are rated by users", apispecs.API_V1_SpecsFile,56		func(t *testing.T, env *test.APITestEnvironment) {57			env.LoadOSMTestData(t)58			u := env.CreateUser(t, "u1")59			shop, err := env.Client.KebabShop.Query().First(context.Background())60			require.NoError(t, err)61			nf, err := env.Services.KebabShopService.AddUserScore(shop.ID, u.ID, false, 5.0)62			require.NoError(t, err)63			require.False(t, nf)64			resp := env.Expect.GET("/api/v1/kebabshops/box").65				WithQuery("ltm", -180).66				WithQuery("ltx", 180).67				WithQuery("lnm", -180).68				WithQuery("lnx", 180).69				WithQuery("rvnx_only", true).70				Expect().Status(http.StatusOK).JSON()71			cords := resp.Path("$.cords").Array()72			cords.Length().Equal(1)73			for _, v := range cords.Iter() {74				v.Schema(`{75					"type": "object",76					"properties": {77					   "id": {78						   "type": "string"79					   },80					   "lat": {81						   "type": "number"82					   },83					   "lng": {84						   "type": "number"85					   }86				   },87				   "require": ["id", "lat", "lng"]88				 }`)89			}90		})91	test.DoAPITest(t, "Request only kebab shops within a box that are submitted by users", apispecs.API_V1_SpecsFile,92		func(t *testing.T, env *test.APITestEnvironment) {93			env.LoadOSMTestData(t)94			u := env.CreateUser(t, "u1")95			shop, err := env.Client.KebabShop.Create().SetName("Mega DÃ¶ner").SetLat(13).SetLng(37).AddSubmittedBy(u).Save(context.Background())96			require.NoError(t, err)97			resp := env.Expect.GET("/api/v1/kebabshops/box").98				WithQuery("ltm", -180).99				WithQuery("ltx", 180).100				WithQuery("lnm", -180).101				WithQuery("lnx", 180).102				WithQuery("rvnx_only", true).103				Expect().Status(http.StatusOK).JSON()104			cords := resp.Path("$.cords").Array()105			cords.Length().Equal(1)106			cords.First().Path("$.id").Equal(strconv.Itoa(int(shop.ID)))107			for _, v := range cords.Iter() {108				v.Schema(`{109					"type": "object",110					"properties": {111					   "id": {112						   "type": "string"113					   },114					   "lat": {115						   "type": "number"116					   },117					   "lng": {118						   "type": "number"119					   }120				   },121				   "require": ["id", "lat", "lng"]122				 }`)123			}124		})125	test.DoAPITest(t, "Invalid request", nil,126		func(t *testing.T, env *test.APITestEnvironment) {127			env.LoadOSMTestData(t)128			env.Expect.GET("/api/v1/kebabshops/box").129				Expect().Status(http.StatusBadRequest)130			env.Expect.GET("/api/v1/kebabshops/box").131				WithQuery("ltx", 60).132				WithQuery("lnm", 10).133				WithQuery("lnx", 20).134				Expect().Status(http.StatusBadRequest)135			env.Expect.GET("/api/v1/kebabshops/box").136				WithQuery("ltm", 50).137				WithQuery("lnm", 10).138				WithQuery("lnx", 20).139				Expect().Status(http.StatusBadRequest)140			env.Expect.GET("/api/v1/kebabshops/box").141				WithQuery("ltm", 50).142				WithQuery("ltx", 60).143				WithQuery("lnx", 20).144				Expect().Status(http.StatusBadRequest)145			env.Expect.GET("/api/v1/kebabshops/box").146				WithQuery("ltm", 50).147				WithQuery("ltx", 60).148				WithQuery("lnm", 10).149				Expect().Status(http.StatusBadRequest)150			env.Expect.GET("/api/v1/kebabshops/box").151				WithQuery("ltm", "not a number").152				WithQuery("ltx", "not a number").153				WithQuery("lnm", "not a number").154				WithQuery("lnx", "not a number").155				Expect().Status(http.StatusBadRequest)156		})157}158func TestV1KebabShops_Cluster(t *testing.T) {159	// TODO: add tests160	t.Skip("TODO: add tests")161}162func TestV1KebabShops_Auto(t *testing.T) {163	// TODO: add tests164	t.Skip("TODO: add tests")165}166func TestV1KebabShops_ShopByID(t *testing.T) {167	test.DoAPITest(t, "Request kebab shop by its id", apispecs.API_V1_SpecsFile,168		func(t *testing.T, env *test.APITestEnvironment) {...

main_test.go

Source:main_test.go

...31	serverConfig.BindFile(defaultConfigFilename)32	app := api.NewServer(serverConfig)33	e := httptest.New(t, app.Application)34	// get first balance35	resp := e.GET("/detail").WithQuery("account", mainAccount).Expect()36	resp.Status(httptest.StatusOK)37	balance := uint64(resp.JSON().Object().Raw()["payload"].(map[string]interface{})["user"].(map[string]interface{})["balance"].(float64))38	fmt.Println(balance)39	for i := 0; i < numberRequest; i++ {40		wg.Add(1)41		account := RandStringRunes(10)42		go func() { // send request in diffenrence goroutine no waitting43			e.GET("/register").WithQuery("account", account).Expect().Status(httptest.StatusOK) // test register44			e.GET("/detail").WithQuery("account", account).Expect().Status(httptest.StatusOK)   // test get detail45			// test transfer main account to this account46			e.GET("/transfer").47				WithQuery("from", mainAccount).48				WithQuery("to", account).49				WithQuery("amount", 100).50				Expect().51				Status(httptest.StatusOK)52			// test transfer this account back to main account53			e.GET("/transfer").54				WithQuery("from", account).55				WithQuery("to", mainAccount).56				WithQuery("amount", 50).57				Expect().58				Status(httptest.StatusOK)59			wg.Done()60		}()61	}62	wg.Wait()63	// get detail main account64	newResp := e.GET("/detail").WithQuery("account", mainAccount).Expect()65	newResp.Status(httptest.StatusOK)66	newBalance := uint64(newResp.JSON().Object().Raw()["payload"].(map[string]interface{})["user"].(map[string]interface{})["balance"].(float64))67	// recalculate main account and compare with in system db68	if (balance - (numberRequest*100 - numberRequest*50)) != newBalance {69		t.Error("Wrong expect Balance ", (balance - (numberRequest*100 - numberRequest*50)), newBalance)70	}71}...

WithQuery

Using AI Code Generation

1import (2func main() {3	c := make(chan string)4	go func() {5		time.Sleep(2 * time.Second)6	}()7	select {8		fmt.Println(res)9	case <-time.After(1 * time.Second):10		fmt.Println("timeout 1")11	}12}13import (14func main() {15	c := make(chan string, 1)16	go func() {17		time.Sleep(2 * time.Second)18	}()19	select {20		fmt.Println(res)21	case <-time.After(3 * time.Second):22		fmt.Println("timeout 2")23	}24}25import (26func main() {27	c1 := make(chan string, 1)28	go func() {29		time.Sleep(2 * time.Second)30	}()31	select {32		fmt.Println(res)33	case <-time.After(1 * time.Second):34		fmt.Println("timeout 1")35	}36	c2 := make(chan string, 1)37	go func() {38		time.Sleep(2 * time.Second)39	}()40	select {41		fmt.Println(res)42	case <-time.After(3 * time.Second):43		fmt.Println("timeout 2")44	}45}46import (47func main() {48	c1 := make(chan string, 1)49	go func() {50		time.Sleep(2 * time.Second)51	}()52	select {53		fmt.Println(res)54	case <-time.After(1 * time.Second):55		fmt.Println("

WithQuery

Using AI Code Generation

1import (2func main() {3	c := make(chan int)4	go func() {5		fmt.Println("Hello")6		time.Sleep(2 * time.Second)7	}()8	select {9		fmt.Println("World")10	case <-time.After(1 * time.Second):11		fmt.Println("Timed out")12	}13}14import (15func main() {16	ctx, cancel := context.WithTimeout(context.Background(), 1*time.Second)17	defer cancel()18	c := make(chan int)19	go func() {20		fmt.Println("Hello")21		time.Sleep(2 * time.Second)22	}()23	select {24		fmt.Println("World")25	case <-ctx.Done():26		fmt.Println("Timed out")27	}28}29import (30func main() {31	ctx, cancel := context.WithCancel(context.Background())32	go func() {33		fmt.Println("Hello")34		time.Sleep(2 * time.Second)35		cancel()36	}()37	select {38	case <-ctx.Done():39		fmt.Println("World")40	}41}42import (43func main() {44	ctx, cancel := context.WithDeadline(context.Background(), time.Now().Add(1*time.Second))45	defer cancel()46	c := make(chan int)47	go func() {48		fmt.Println("Hello")49		time.Sleep(2 * time.Second)50	}()51	select {52		fmt.Println("World")53	case <-ctx.Done():54		fmt.Println("Timed out")55	}56}57import (58func main() {59	ctx, cancel := context.WithTimeout(context.Background(), 1*time.Second)60	defer cancel()61	c := make(chan int)

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.