Add VersionedHash DB logic only (Consensys#9931)

* Safer interface for VersionedHashDBSource

Author: zilm13

ethereum/pow/api/build.gradle

@@ -7,3 +7,9 @@ dependencies {
 
   testImplementation testFixtures(project(':ethereum:spec'))
 }
+
+publishing {
+  publications {
+    mavenJava(MavenPublication) { artifactId 'ethereum-pow-api' }
+  }
+}

ethereum/spec/src/main/java/tech/pegasys/teku/spec/logic/versions/deneb/types/VersionedHash.java

@@ -22,6 +22,7 @@
 public class VersionedHash {
 
   public static final int SIZE = 32;
+  public static final VersionedHash EMPTY = new VersionedHash(Bytes32.ZERO);
 
   final Bytes version;
   final Bytes value;
@@ -53,6 +54,10 @@ public Bytes getValue() {
     return value;
   }
 
+  public Bytes32 get() {
+    return Bytes32.wrap(Bytes.concatenate(version, value));
+  }
+
   public String toHexString() {
     return Bytes.wrap(version, value).toHexString();
   }

ethereum/statetransition/api/build.gradle

@@ -0,0 +1,9 @@
+dependencies {
+  implementation project(':infrastructure:events')
+}
+
+publishing {
+  publications {
+    mavenJava(MavenPublication) { artifactId 'ethereum-statetransition-api' }
+  }
+}

…transition/CustodyGroupCountChannel.java …sition/api/CustodyGroupCountChannel.javaethereum/statetransition/src/main/java/tech/pegasys/teku/statetransition/CustodyGroupCountChannel.java renamed to ethereum/statetransition/api/src/main/java/tech/pegasys/teku/statetransition/api/CustodyGroupCountChannel.java ethereum/statetransition/src/main/java/tech/pegasys/teku/statetransition/CustodyGroupCountChannel.java renamed to ethereum/statetransition/api/src/main/java/tech/pegasys/teku/statetransition/api/CustodyGroupCountChannel.java

@@ -11,7 +11,7 @@
  * specific language governing permissions and limitations under the License.
  */
 
-package tech.pegasys.teku.statetransition;
+package tech.pegasys.teku.statetransition.api;
 
 import java.util.function.Consumer;
 import tech.pegasys.teku.infrastructure.events.VoidReturningChannelInterface;

ethereum/statetransition/build.gradle

@@ -6,6 +6,7 @@ idea {
 
 dependencies {
   api project(':ethereum:events')
+  api project(':ethereum:statetransition:api')
 
   implementation project(':ethereum:performance-trackers')
   implementation project(':ethereum:execution-types')

ethereum/statetransition/src/main/java/tech/pegasys/teku/statetransition/datacolumns/CustodyGroupCountManagerImpl.java

@@ -31,7 +31,7 @@
 import tech.pegasys.teku.spec.SpecMilestone;
 import tech.pegasys.teku.spec.config.SpecConfigFulu;
 import tech.pegasys.teku.spec.logic.versions.fulu.helpers.MiscHelpersFulu;
-import tech.pegasys.teku.statetransition.CustodyGroupCountChannel;
+import tech.pegasys.teku.statetransition.api.CustodyGroupCountChannel;
 import tech.pegasys.teku.statetransition.forkchoice.PreparedProposerInfo;
 import tech.pegasys.teku.statetransition.forkchoice.ProposersDataManager;
 import tech.pegasys.teku.storage.client.CombinedChainDataClient;

ethereum/statetransition/src/test/java/tech/pegasys/teku/statetransition/datacolumns/CustodyGroupCountManagerImplTest.java

@@ -39,7 +39,7 @@
 import tech.pegasys.teku.spec.config.SpecConfigFulu;
 import tech.pegasys.teku.spec.logic.versions.fulu.helpers.MiscHelpersFulu;
 import tech.pegasys.teku.spec.util.DataStructureUtil;
-import tech.pegasys.teku.statetransition.CustodyGroupCountChannel;
+import tech.pegasys.teku.statetransition.api.CustodyGroupCountChannel;
 import tech.pegasys.teku.statetransition.forkchoice.PreparedProposerInfo;
 import tech.pegasys.teku.statetransition.forkchoice.ProposersDataManager;
 import tech.pegasys.teku.storage.client.CombinedChainDataClient;

ethereum/statetransition/src/test/java/tech/pegasys/teku/statetransition/datacolumns/DasSamplerBasicTest.java

@@ -44,7 +44,7 @@
 import tech.pegasys.teku.spec.datastructures.state.beaconstate.BeaconState;
 import tech.pegasys.teku.spec.datastructures.util.DataColumnSlotAndIdentifier;
 import tech.pegasys.teku.spec.util.DataStructureUtil;
-import tech.pegasys.teku.statetransition.CustodyGroupCountChannel;
+import tech.pegasys.teku.statetransition.api.CustodyGroupCountChannel;
 import tech.pegasys.teku.statetransition.datacolumns.db.DataColumnSidecarDbAccessor;
 import tech.pegasys.teku.statetransition.datacolumns.retriever.DataColumnSidecarRetriever;
 import tech.pegasys.teku.statetransition.forkchoice.PreparedProposerInfo;

networking/eth2/src/main/java/tech/pegasys/teku/networking/eth2/gossip/subnets/DataColumnSidecarSubnetBackboneSubscriber.java

@@ -23,7 +23,7 @@
 import tech.pegasys.teku.infrastructure.unsigned.UInt64;
 import tech.pegasys.teku.networking.eth2.Eth2P2PNetwork;
 import tech.pegasys.teku.spec.Spec;
-import tech.pegasys.teku.statetransition.CustodyGroupCountChannel;
+import tech.pegasys.teku.statetransition.api.CustodyGroupCountChannel;
 
 public class DataColumnSidecarSubnetBackboneSubscriber
     implements SlotEventsChannel, CustodyGroupCountChannel {

networking/eth2/src/main/java/tech/pegasys/teku/networking/eth2/rpc/beaconchain/methods/MetadataMessagesFactory.java

@@ -22,7 +22,7 @@
 import tech.pegasys.teku.spec.datastructures.networking.libp2p.rpc.PingMessage;
 import tech.pegasys.teku.spec.datastructures.networking.libp2p.rpc.metadata.MetadataMessage;
 import tech.pegasys.teku.spec.datastructures.networking.libp2p.rpc.metadata.MetadataMessageSchema;
-import tech.pegasys.teku.statetransition.CustodyGroupCountChannel;
+import tech.pegasys.teku.statetransition.api.CustodyGroupCountChannel;
 
 public class MetadataMessagesFactory implements CustodyGroupCountChannel {
   private static final Logger LOG = LogManager.getLogger();