Skip to content

Commit ccb48e4

Browse files
james-toussaintjames-toussaint
authored
Merge pull request #175 from iExecBlockchainComputing/can-send-tx-when-unsync-node
Can send tx when unsync node
2 parents 1377907 + 4498be7 commit ccb48e4

File tree

6 files changed

+100
-22
lines changed

6 files changed

+100
-22
lines changed

‎gradle.properties‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
11
iexecCommonVersion=3.0.0
22
nexusUser=fake
33
nexusPassword=fake
4-
version=3.0.0-SNAPSHOT
4+
version=3.0.1-SNAPSHOT

‎src/main/java/com/iexec/worker/chain/ContributionService.java‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -79,7 +79,7 @@ private boolean hasEnoughtStakeToContribute(ChainTask chainTask) {
7979
}
8080

8181
private boolean isTaskActiveToContribute(ChainTask chainTask) {
82-
return chainTask.getStatus().equals(ChainTaskStatus.ACTIVE);
82+
return iexecHubService.isChainTaskActiveWhenNodeNotSync(chainTask.getChainTaskId());
8383
}
8484

8585
private boolean isBeforeContributionDeadlineToContribute(ChainTask chainTask) {

‎src/main/java/com/iexec/worker/chain/IexecHubService.java‎

Lines changed: 79 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -10,17 +10,16 @@
1010
import org.springframework.beans.factory.annotation.Autowired;
1111
import org.springframework.stereotype.Service;
1212
import org.web3j.protocol.Web3j;
13-
import org.web3j.protocol.core.DefaultBlockParameterName;
1413
import org.web3j.protocol.core.RemoteCall;
1514
import org.web3j.protocol.core.methods.response.TransactionReceipt;
1615

17-
import java.io.IOException;
1816
import java.util.List;
1917
import java.util.Optional;
2018
import java.util.concurrent.CompletableFuture;
2119
import java.util.concurrent.ExecutionException;
2220
import java.util.concurrent.Executors;
2321
import java.util.concurrent.ThreadPoolExecutor;
22+
import java.util.function.Function;
2423

2524
import static com.iexec.common.chain.ChainContributionStatus.CONTRIBUTED;
2625
import static com.iexec.common.chain.ChainContributionStatus.REVEALED;
@@ -173,6 +172,10 @@ public long getLatestBlockNumber() {
173172
return web3jService.getLatestBlockNumber();
174173
}
175174

175+
public long getMaxWaitingTimeWhenNotSync() {
176+
return web3jService.getMaxWaitingTimeWhenPendingReceipt();
177+
}
178+
176179
private Boolean isContributionStatusValidOnChain(String chainTaskId, ChainStatus chainContributionStatus) {
177180
if (chainContributionStatus instanceof ChainContributionStatus) {
178181
Optional<ChainContribution> chainContribution = getChainContribution(chainTaskId);
@@ -181,4 +184,78 @@ private Boolean isContributionStatusValidOnChain(String chainTaskId, ChainStatus
181184
return false;
182185
}
183186

187+
private boolean isBlockchainReadTrueWhenNodeNotSync(String chainTaskId, Function<String, Boolean> booleanBlockchainReadFunction) {
188+
long maxWaitingTime = web3jService.getMaxWaitingTimeWhenPendingReceipt();
189+
long startTime = System.currentTimeMillis();
190+
191+
for(long duration = 0L; duration < maxWaitingTime; duration = System.currentTimeMillis() - startTime) {
192+
try {
193+
if (booleanBlockchainReadFunction.apply(chainTaskId)) {
194+
return true;
195+
}
196+
197+
Thread.sleep(500L);
198+
} catch (InterruptedException e) {
199+
log.error("Error in checking the latest block number [chainTaskId:{}, maxWaitingTime:{}]",
200+
chainTaskId, maxWaitingTime);
201+
}
202+
}
203+
204+
return false;
205+
}
206+
207+
boolean isChainTaskActiveWhenNodeNotSync(String chainTaskId) {
208+
boolean isChainTaskStatusActive = isBlockchainReadTrueWhenNodeNotSync(chainTaskId, this::isChainTaskActive);
209+
if (!isChainTaskStatusActive){
210+
log.error("ChainTask status is still not in 'active' stage after maxWaitingTime [chainTaskId:{}]", chainTaskId);
211+
}
212+
return isChainTaskStatusActive;
213+
}
214+
215+
boolean isChainTaskRevealingWhenNodeNotSync(String chainTaskId) {
216+
boolean isChainTaskStatusRevealing = isBlockchainReadTrueWhenNodeNotSync(chainTaskId, this::isChainTaskRevealing);
217+
if (!isChainTaskStatusRevealing){
218+
log.error("ChainTask status is still not in 'revealing' stage after maxWaitingTime [chainTaskId:{}]", chainTaskId);
219+
}
220+
return isChainTaskStatusRevealing;
221+
}
222+
223+
private Boolean isChainTaskActive(String chainTaskId){
224+
Optional<ChainTask> chainTask = getChainTask(chainTaskId);
225+
if (chainTask.isPresent()){
226+
switch (chainTask.get().getStatus()){
227+
case UNSET:
228+
break;//Could happen if node not synchronized. Should wait.
229+
case ACTIVE:
230+
return true;
231+
case REVEALING:
232+
return false;
233+
case COMPLETED:
234+
return false;
235+
case FAILLED:
236+
return false;
237+
}
238+
}
239+
return false;
240+
}
241+
242+
private Boolean isChainTaskRevealing(String chainTaskId){
243+
Optional<ChainTask> chainTask = getChainTask(chainTaskId);
244+
if (chainTask.isPresent()){
245+
switch (chainTask.get().getStatus()){
246+
case UNSET:
247+
break;//Should not happen
248+
case ACTIVE:
249+
break;//Could happen if node not synchronized. Should wait.
250+
case REVEALING:
251+
return true;
252+
case COMPLETED:
253+
return false;
254+
case FAILLED:
255+
return false;
256+
}
257+
}
258+
return false;
259+
}
260+
184261
}

‎src/main/java/com/iexec/worker/chain/RevealService.java‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,7 @@ public boolean canReveal(String chainTaskId) {
3434
}
3535
ChainTask chainTask = optionalChainTask.get();
3636

37-
boolean isChainTaskStatusRevealing = chainTask.getStatus().equals(ChainTaskStatus.REVEALING);
37+
boolean isChainTaskRevealing = iexecHubService.isChainTaskRevealingWhenNodeNotSync(chainTaskId);
3838
boolean isRevealDeadlineReached = chainTask.getRevealDeadline() < new Date().getTime();
3939

4040
Optional<ChainContribution> optionalContribution = iexecHubService.getChainContribution(chainTaskId);
@@ -57,18 +57,18 @@ public boolean canReveal(String chainTaskId) {
5757
);
5858
}
5959

60-
boolean ret = isChainTaskStatusRevealing && !isRevealDeadlineReached &&
60+
boolean ret = isChainTaskRevealing && !isRevealDeadlineReached &&
6161
isChainContributionStatusContributed && isContributionResultHashConsensusValue &&
6262
isContributionResultHashCorrect && isContributionResultSealCorrect;
6363

6464
if (ret) {
6565
log.info("All the conditions are valid for the reveal to happen [chainTaskId:{}]", chainTaskId);
6666
} else {
6767
log.warn("One or more conditions are not met for the reveal to happen [chainTaskId:{}, " +
68-
"isChainTaskStatusRevealing:{}, isRevealDeadlineReached:{}, " +
68+
"isChainTaskRevealingWhenNodeNotSync:{}, isRevealDeadlineReached:{}, " +
6969
"isChainContributionStatusContributed:{}, isContributionResultHashConsensusValue:{}, " +
7070
"isContributionResultHashCorrect:{}, isContributionResultSealCorrect:{}]", chainTaskId,
71-
isChainTaskStatusRevealing, isRevealDeadlineReached,
71+
isChainTaskRevealing, isRevealDeadlineReached,
7272
isChainContributionStatusContributed, isContributionResultHashConsensusValue,
7373
isContributionResultHashCorrect, isContributionResultSealCorrect);
7474
}

‎src/test/java/com/iexec/worker/chain/ContributionServiceTests.java‎

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -96,7 +96,6 @@ public void GetCanContributeStatusShouldReturnCanContribute() {
9696
ChainTask chainTask = ChainTask.builder()
9797
.dealid(chainDealId)
9898
.idx(0)
99-
.status(ACTIVE)
10099
.contributionDeadline(new Date().getTime() + 1000)
101100
.build();
102101

@@ -106,6 +105,7 @@ public void GetCanContributeStatusShouldReturnCanContribute() {
106105
when(iexecHubService.getChainAccount()).thenReturn(Optional.of(ChainAccount.builder().deposit(1000).build()));
107106
when(iexecHubService.getChainDeal(chainDealId)).thenReturn(Optional.of(ChainDeal.builder().workerStake(BigInteger.valueOf(5)).build()));
108107
when(iexecHubService.getChainContribution(chainTaskId)).thenReturn(Optional.of(ChainContribution.builder().status(ChainContributionStatus.UNSET).build()));
108+
when(iexecHubService.isChainTaskActiveWhenNodeNotSync(chainTaskId)).thenReturn(true);
109109

110110
assertThat(contributionService.getCanContributeStatus(chainTaskId).isPresent()).isTrue();
111111
assertThat(contributionService.getCanContributeStatus(chainTaskId).get().equals(ReplicateStatus.CAN_CONTRIBUTE)).isTrue();
@@ -118,7 +118,6 @@ public void GetCanContributeStatusShouldReturnStakeTooLoww() {
118118
ChainTask chainTask = ChainTask.builder()
119119
.dealid(chainDealId)
120120
.idx(0)
121-
.status(ACTIVE)
122121
.contributionDeadline(new Date().getTime() + 1000)
123122
.build();
124123

@@ -128,6 +127,7 @@ public void GetCanContributeStatusShouldReturnStakeTooLoww() {
128127
when(iexecHubService.getChainAccount()).thenReturn(Optional.of(ChainAccount.builder().deposit(0).build()));
129128
when(iexecHubService.getChainDeal(chainDealId)).thenReturn(Optional.of(ChainDeal.builder().workerStake(BigInteger.valueOf(5)).build()));
130129
when(iexecHubService.getChainContribution(chainTaskId)).thenReturn(Optional.of(ChainContribution.builder().status(ChainContributionStatus.UNSET).build()));
130+
when(iexecHubService.isChainTaskActiveWhenNodeNotSync(chainTaskId)).thenReturn(true);
131131

132132
assertThat(contributionService.getCanContributeStatus(chainTaskId).isPresent()).isTrue();
133133
assertThat(contributionService.getCanContributeStatus(chainTaskId).get().equals(ReplicateStatus.CANT_CONTRIBUTE_SINCE_STAKE_TOO_LOW)).isTrue();
@@ -140,7 +140,6 @@ public void GetCanContributeStatusShouldReturnTaskNotActive() {
140140
ChainTask chainTask = ChainTask.builder()
141141
.dealid(chainDealId)
142142
.idx(0)
143-
.status(REVEALING)
144143
.contributionDeadline(new Date().getTime() + 1000)
145144
.build();
146145

@@ -150,6 +149,7 @@ public void GetCanContributeStatusShouldReturnTaskNotActive() {
150149
when(iexecHubService.getChainAccount()).thenReturn(Optional.of(ChainAccount.builder().deposit(1000).build()));
151150
when(iexecHubService.getChainDeal(chainDealId)).thenReturn(Optional.of(ChainDeal.builder().workerStake(BigInteger.valueOf(5)).build()));
152151
when(iexecHubService.getChainContribution(chainTaskId)).thenReturn(Optional.of(ChainContribution.builder().status(ChainContributionStatus.UNSET).build()));
152+
when(iexecHubService.isChainTaskActiveWhenNodeNotSync(chainTaskId)).thenReturn(false);
153153

154154
assertThat(contributionService.getCanContributeStatus(chainTaskId).isPresent()).isTrue();
155155
assertThat(contributionService.getCanContributeStatus(chainTaskId).get().equals(ReplicateStatus.CANT_CONTRIBUTE_SINCE_TASK_NOT_ACTIVE)).isTrue();
@@ -162,7 +162,6 @@ public void GetCanContributeStatusShouldReturnAfterDeadline() {
162162
ChainTask chainTask = ChainTask.builder()
163163
.dealid(chainDealId)
164164
.idx(0)
165-
.status(ACTIVE)
166165
.contributionDeadline(new Date().getTime() - 1000)
167166
.build();
168167

@@ -172,6 +171,7 @@ public void GetCanContributeStatusShouldReturnAfterDeadline() {
172171
when(iexecHubService.getChainAccount()).thenReturn(Optional.of(ChainAccount.builder().deposit(1000).build()));
173172
when(iexecHubService.getChainDeal(chainDealId)).thenReturn(Optional.of(ChainDeal.builder().workerStake(BigInteger.valueOf(5)).build()));
174173
when(iexecHubService.getChainContribution(chainTaskId)).thenReturn(Optional.of(ChainContribution.builder().status(ChainContributionStatus.UNSET).build()));
174+
when(iexecHubService.isChainTaskActiveWhenNodeNotSync(chainTaskId)).thenReturn(true);
175175

176176
assertThat(contributionService.getCanContributeStatus(chainTaskId).isPresent()).isTrue();
177177
assertThat(contributionService.getCanContributeStatus(chainTaskId).get().equals(ReplicateStatus.CANT_CONTRIBUTE_SINCE_AFTER_DEADLINE)).isTrue();
@@ -184,7 +184,6 @@ public void GetCanContributeStatusShouldReturnContributed() {
184184
ChainTask chainTask = ChainTask.builder()
185185
.dealid(chainDealId)
186186
.idx(0)
187-
.status(ACTIVE)
188187
.contributionDeadline(new Date().getTime() + 1000)
189188
.build();
190189

@@ -194,6 +193,7 @@ public void GetCanContributeStatusShouldReturnContributed() {
194193
when(iexecHubService.getChainAccount()).thenReturn(Optional.of(ChainAccount.builder().deposit(1000).build()));
195194
when(iexecHubService.getChainDeal(chainDealId)).thenReturn(Optional.of(ChainDeal.builder().workerStake(BigInteger.valueOf(5)).build()));
196195
when(iexecHubService.getChainContribution(chainTaskId)).thenReturn(Optional.of(ChainContribution.builder().status(ChainContributionStatus.CONTRIBUTED).build()));
196+
when(iexecHubService.isChainTaskActiveWhenNodeNotSync(chainTaskId)).thenReturn(true);
197197

198198
assertThat(contributionService.getCanContributeStatus(chainTaskId).isPresent()).isTrue();
199199
assertThat(contributionService.getCanContributeStatus(chainTaskId).get().equals(ReplicateStatus.CANT_CONTRIBUTE_SINCE_CONTRIBUTION_ALREADY_SET)).isTrue();

0 commit comments

Comments
 (0)