Commitd13f5a4

committed

[1.1.0-SNAPSHOT]

Rest before timeout check for api not exceed rate

1 parent315ef5f commitd13f5a4Copy full SHA for d13f5a4

File tree

+15

-8

lines changed

+15

-8

lines changed

Lines changed: 11 additions & 6 deletions

Original file line number	Diff line number	Diff line change
`@@ -11,21 +11,26 @@ public class ApiRunner extends Assert {`
`11`	`11`	`privatestaticfinalEtherScanApiapiRopsten;`
`12`	`12`	`privatestaticfinalEtherScanApiapiRinkeby;`
`13`	`13`	`privatestaticfinalEtherScanApiapiKovan;`
	`14`	`+privatestaticfinalStringkey;`
`14`	`15`
`15`	`16`	`static {`
`16`	`17`	`finalStringapiKey =System.getenv("API_KEY");`
`17`		`-finalStringkeyOrDefault = (apiKey ==null \|\|apiKey.isEmpty())`
	`18`	`+key = (apiKey ==null \|\|apiKey.isEmpty())`
`18`	`19`	`?EtherScanApi.DEFAULT_KEY`
`19`	`20`	`:apiKey;`
`20`	`21`
`21`		`-finalQueueManagerqueue =keyOrDefault.equals(EtherScanApi.DEFAULT_KEY)`
	`22`	`+finalQueueManagerqueue =key.equals(EtherScanApi.DEFAULT_KEY)`
`22`	`23`	`?QueueManager.DEFAULT_KEY_QUEUE`
`23`	`24`	`:newQueueManager(1,2);`
`24`	`25`
`25`		`-api =newEtherScanApi(keyOrDefault,EthNetwork.MAINNET,queue);`
`26`		`-apiRopsten =newEtherScanApi(keyOrDefault,EthNetwork.ROPSTEN,queue);`
`27`		`-apiRinkeby =newEtherScanApi(keyOrDefault,EthNetwork.RINKEBY,queue);`
`28`		`-apiKovan =newEtherScanApi(keyOrDefault,EthNetwork.KOVAN,queue);`
	`26`	`+api =newEtherScanApi(key,EthNetwork.MAINNET,queue);`
	`27`	`+apiRopsten =newEtherScanApi(key,EthNetwork.ROPSTEN,queue);`
	`28`	`+apiRinkeby =newEtherScanApi(key,EthNetwork.RINKEBY,queue);`
	`29`	`+apiKovan =newEtherScanApi(key,EthNetwork.KOVAN,queue);`
	`30`	`+ }`
	`31`	`+`
	`32`	`+publicstaticStringgetKey() {`
	`33`	`+returnkey;`
`29`	`34`	`}`
`30`	`35`
`31`	`36`	`publicstaticEtherScanApigetApi() {`

Lines changed: 4 additions & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -13,6 +13,7 @@`
`13`	`13`	`importorg.junit.Test;`
`14`	`14`
`15`	`15`	`importjava.util.List;`
	`16`	`+importjava.util.concurrent.TimeUnit;`
`16`	`17`	`importjava.util.function.Supplier;`
`17`	`18`
`18`	`19`	`/**`
`@@ -75,9 +76,10 @@ public void noTimeoutUnlimitedAwait() {`
`75`	`76`	`}`
`76`	`77`
`77`	`78`	`@Test(expected =ApiTimeoutException.class)`
`78`		`-publicvoidtimeout() {`
	`79`	`+publicvoidtimeout()throwsInterruptedException {`
	`80`	`+TimeUnit.SECONDS.sleep(5);`
`79`	`81`	`Supplier<IHttpExecutor>supplier = () ->newHttpExecutor(300,300);`
`80`		`-EtherScanApiapi =newEtherScanApi(EthNetwork.KOVAN,supplier);`
	`82`	`+EtherScanApiapi =newEtherScanApi(getKey(),EthNetwork.KOVAN,supplier);`
`81`	`83`	`List<Block>blocks =api.account().minedBlocks("0x0010f94b296A852aAac52EA6c5Ac72e03afD032D");`
`82`	`84`	`assertNotNull(blocks);`
`83`	`85`	`}`

Comments

(0)