mirror of https://github.com/hyperledger/besu
CJ Hare
6 years ago
committed by
GitHub
parent
458e3bfb00
commit
757650f308
@ -0,0 +1,44 @@ |
||||
/* |
||||
* Copyright 2019 ConsenSys AG. |
||||
* |
||||
* Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with |
||||
* the License. You may obtain a copy of the License at |
||||
* |
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
* |
||||
* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on |
||||
* an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the |
||||
* specific language governing permissions and limitations under the License. |
||||
*/ |
||||
package tech.pegasys.pantheon.tests.acceptance.dsl.condition.admin; |
||||
|
||||
import static org.assertj.core.api.Assertions.fail; |
||||
|
||||
import tech.pegasys.pantheon.tests.acceptance.dsl.condition.Condition; |
||||
import tech.pegasys.pantheon.tests.acceptance.dsl.node.Node; |
||||
import tech.pegasys.pantheon.tests.acceptance.dsl.node.RunnableNode; |
||||
import tech.pegasys.pantheon.tests.acceptance.dsl.transaction.admin.AdminTransactions; |
||||
|
||||
import java.net.URI; |
||||
|
||||
public class AdminConditions { |
||||
|
||||
private final AdminTransactions admin; |
||||
|
||||
public AdminConditions(final AdminTransactions admin) { |
||||
this.admin = admin; |
||||
} |
||||
|
||||
public Condition addPeer(final Node addingPeer) { |
||||
|
||||
return new ExpectPeerAdded(admin.addPeer(enodeUrl(addingPeer))); |
||||
} |
||||
|
||||
private URI enodeUrl(final Node node) { |
||||
if (!(node instanceof RunnableNode)) { |
||||
fail("A RunnableNode instance is required"); |
||||
} |
||||
|
||||
return ((RunnableNode) node).enodeUrl(); |
||||
} |
||||
} |
||||
@ -0,0 +1,34 @@ |
||||
/* |
||||
* Copyright 2019 ConsenSys AG. |
||||
* |
||||
* Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with |
||||
* the License. You may obtain a copy of the License at |
||||
* |
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
* |
||||
* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on |
||||
* an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the |
||||
* specific language governing permissions and limitations under the License. |
||||
*/ |
||||
package tech.pegasys.pantheon.tests.acceptance.dsl.condition.admin; |
||||
|
||||
import static org.assertj.core.api.Assertions.assertThat; |
||||
|
||||
import tech.pegasys.pantheon.tests.acceptance.dsl.condition.Condition; |
||||
import tech.pegasys.pantheon.tests.acceptance.dsl.node.Node; |
||||
import tech.pegasys.pantheon.tests.acceptance.dsl.transaction.admin.AddPeerTransaction; |
||||
|
||||
public class ExpectPeerAdded implements Condition { |
||||
|
||||
private final AddPeerTransaction transaction; |
||||
|
||||
public ExpectPeerAdded(final AddPeerTransaction transaction) { |
||||
this.transaction = transaction; |
||||
} |
||||
|
||||
@Override |
||||
public void verify(final Node node) { |
||||
final Boolean result = node.execute(transaction); |
||||
assertThat(result).isTrue(); |
||||
} |
||||
} |
||||
@ -1,52 +0,0 @@ |
||||
/* |
||||
* Copyright 2019 ConsenSys AG. |
||||
* |
||||
* Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with |
||||
* the License. You may obtain a copy of the License at |
||||
* |
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
* |
||||
* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on |
||||
* an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the |
||||
* specific language governing permissions and limitations under the License. |
||||
*/ |
||||
package tech.pegasys.pantheon.tests.acceptance.dsl.jsonrpc; |
||||
|
||||
import static org.assertj.core.api.Assertions.assertThat; |
||||
import static org.assertj.core.api.Assertions.fail; |
||||
|
||||
import tech.pegasys.pantheon.tests.acceptance.dsl.condition.Condition; |
||||
import tech.pegasys.pantheon.tests.acceptance.dsl.node.Node; |
||||
import tech.pegasys.pantheon.tests.acceptance.dsl.node.RunnableNode; |
||||
import tech.pegasys.pantheon.tests.acceptance.dsl.transaction.Transaction; |
||||
|
||||
import java.io.IOException; |
||||
import java.net.URI; |
||||
|
||||
import org.web3j.protocol.core.Response; |
||||
|
||||
public class Admin { |
||||
private Transaction<Boolean> addPeerTransaction(final URI enode) { |
||||
return (n) -> { |
||||
try { |
||||
final Response<Boolean> resp = n.admin().adminAddPeer(enode).send(); |
||||
assertThat(resp).isNotNull(); |
||||
assertThat(resp.hasError()).isFalse(); |
||||
return resp.getResult(); |
||||
} catch (final IOException e) { |
||||
throw new RuntimeException(e); |
||||
} |
||||
}; |
||||
} |
||||
|
||||
public Condition addPeer(final Node node) { |
||||
if (!(node instanceof RunnableNode)) { |
||||
fail("Admin.addPeer() needs a RunnableNode instance"); |
||||
} |
||||
|
||||
return (n) -> { |
||||
final Boolean result = n.execute(addPeerTransaction(((RunnableNode) node).enodeUrl())); |
||||
assertThat(result).isTrue(); |
||||
}; |
||||
} |
||||
} |
||||
@ -0,0 +1,44 @@ |
||||
/* |
||||
* Copyright 2019 ConsenSys AG. |
||||
* |
||||
* Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with |
||||
* the License. You may obtain a copy of the License at |
||||
* |
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
* |
||||
* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on |
||||
* an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the |
||||
* specific language governing permissions and limitations under the License. |
||||
*/ |
||||
package tech.pegasys.pantheon.tests.acceptance.dsl.transaction.admin; |
||||
|
||||
import static org.assertj.core.api.Assertions.assertThat; |
||||
|
||||
import tech.pegasys.pantheon.tests.acceptance.dsl.transaction.NodeRequests; |
||||
import tech.pegasys.pantheon.tests.acceptance.dsl.transaction.Transaction; |
||||
|
||||
import java.io.IOException; |
||||
import java.net.URI; |
||||
|
||||
import org.web3j.protocol.core.Response; |
||||
|
||||
public class AddPeerTransaction implements Transaction<Boolean> { |
||||
|
||||
private final URI peer; |
||||
|
||||
public AddPeerTransaction(final URI peer) { |
||||
this.peer = peer; |
||||
} |
||||
|
||||
@Override |
||||
public Boolean execute(final NodeRequests node) { |
||||
try { |
||||
final Response<Boolean> resp = node.admin().adminAddPeer(peer).send(); |
||||
assertThat(resp).isNotNull(); |
||||
assertThat(resp.hasError()).isFalse(); |
||||
return resp.getResult(); |
||||
} catch (final IOException e) { |
||||
throw new RuntimeException(e); |
||||
} |
||||
} |
||||
} |
||||
@ -0,0 +1,22 @@ |
||||
/* |
||||
* Copyright 2019 ConsenSys AG. |
||||
* |
||||
* Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with |
||||
* the License. You may obtain a copy of the License at |
||||
* |
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
* |
||||
* Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on |
||||
* an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the |
||||
* specific language governing permissions and limitations under the License. |
||||
*/ |
||||
package tech.pegasys.pantheon.tests.acceptance.dsl.transaction.admin; |
||||
|
||||
import java.net.URI; |
||||
|
||||
public class AdminTransactions { |
||||
|
||||
public AddPeerTransaction addPeer(final URI peer) { |
||||
return new AddPeerTransaction(peer); |
||||
} |
||||
} |
||||
Loading…
Reference in new issue