Merge pull request #406 from blinklabs-io/feat/ledger-issuer-vkey-pool

feat: better support for issuer vkey

Author: agaffney

cmd/block-fetch/main.go

@@ -85,6 +85,8 @@ func main() {
 		fmt.Printf("era = %s, slot = %d, block_no = %d, id = %s\n", v.Era().Name, v.SlotNumber(), v.BlockNumber(), v.Hash())
 	}
 	if f.all {
+		issuerVkey := block.IssuerVkey()
+		fmt.Printf("\nMinted by: %s (%s)\n", issuerVkey.PoolId(), issuerVkey.Hash())
 		// Display transaction info
 		fmt.Printf("\nTransactions:\n")
 		for _, tx := range block.Transactions() {

ledger/allegra.go

@@ -55,7 +55,7 @@ func (b *AllegraBlock) SlotNumber() uint64 {
 	return b.Header.SlotNumber()
 }
 
-func (b *AllegraBlock) IssuerVkey() []byte {
+func (b *AllegraBlock) IssuerVkey() IssuerVkey {
 	return b.Header.IssuerVkey()
 }
 

ledger/alonzo.go

@@ -57,7 +57,7 @@ func (b *AlonzoBlock) SlotNumber() uint64 {
 	return b.Header.SlotNumber()
 }
 
-func (b *AlonzoBlock) IssuerVkey() []byte {
+func (b *AlonzoBlock) IssuerVkey() IssuerVkey {
 	return b.Header.IssuerVkey()
 }
 

ledger/babbage.go

@@ -57,7 +57,7 @@ func (b *BabbageBlock) SlotNumber() uint64 {
 	return b.Header.SlotNumber()
 }
 
-func (b *BabbageBlock) IssuerVkey() []byte {
+func (b *BabbageBlock) IssuerVkey() IssuerVkey {
 	return b.Header.IssuerVkey()
 }
 
@@ -99,7 +99,7 @@ type BabbageBlockHeader struct {
 		BlockNumber   uint64
 		Slot          uint64
 		PrevHash      Blake2b256
-		IssuerVkey    []byte
+		IssuerVkey    IssuerVkey
 		VrfKey        []byte
 		VrfResult     interface{}
 		BlockBodySize uint64
@@ -139,7 +139,7 @@ func (h *BabbageBlockHeader) SlotNumber() uint64 {
 	return h.Body.Slot
 }
 
-func (h *BabbageBlockHeader) IssuerVkey() []byte {
+func (h *BabbageBlockHeader) IssuerVkey() IssuerVkey {
 	return h.Body.IssuerVkey
 }
 

ledger/block.go

@@ -30,7 +30,7 @@ type BlockHeader interface {
 	Hash() string
 	BlockNumber() uint64
 	SlotNumber() uint64
-	IssuerVkey() []byte
+	IssuerVkey() IssuerVkey
 	BlockBodySize() uint64
 	Era() Era
 	Cbor() []byte

ledger/byron.go

@@ -96,9 +96,9 @@ func (h *ByronMainBlockHeader) SlotNumber() uint64 {
 	return uint64((h.ConsensusData.SlotId.Epoch * ByronSlotsPerEpoch) + uint64(h.ConsensusData.SlotId.Slot))
 }
 
-func (h *ByronMainBlockHeader) IssuerVkey() []byte {
+func (h *ByronMainBlockHeader) IssuerVkey() IssuerVkey {
 	// Byron blocks don't have an issuer
-	return nil
+	return IssuerVkey([]byte{})
 }
 
 func (h *ByronMainBlockHeader) BlockBodySize() uint64 {
@@ -203,9 +203,9 @@ func (h *ByronEpochBoundaryBlockHeader) SlotNumber() uint64 {
 	return uint64(h.ConsensusData.Epoch * ByronSlotsPerEpoch)
 }
 
-func (h *ByronEpochBoundaryBlockHeader) IssuerVkey() []byte {
+func (h *ByronEpochBoundaryBlockHeader) IssuerVkey() IssuerVkey {
 	// Byron blocks don't have an issuer
-	return nil
+	return IssuerVkey([]byte{})
 }
 
 func (h *ByronEpochBoundaryBlockHeader) BlockBodySize() uint64 {
@@ -241,7 +241,7 @@ func (b *ByronMainBlock) SlotNumber() uint64 {
 	return b.Header.SlotNumber()
 }
 
-func (b *ByronMainBlock) IssuerVkey() []byte {
+func (b *ByronMainBlock) IssuerVkey() IssuerVkey {
 	return b.Header.IssuerVkey()
 }
 
@@ -282,7 +282,7 @@ func (b *ByronEpochBoundaryBlock) SlotNumber() uint64 {
 	return b.Header.SlotNumber()
 }
 
-func (b *ByronEpochBoundaryBlock) IssuerVkey() []byte {
+func (b *ByronEpochBoundaryBlock) IssuerVkey() IssuerVkey {
 	return b.Header.IssuerVkey()
 }
 

ledger/common.go

@@ -322,3 +322,25 @@ func (a Address) String() string {
 func (a Address) MarshalJSON() ([]byte, error) {
 	return []byte(`"` + a.String() + `"`), nil
 }
+
+// IssuerVkey represents the verification key for the stake pool that minted a block
+type IssuerVkey [32]byte
+
+func (i IssuerVkey) Hash() Blake2b224 {
+	hash, _ := blake2b.New(28, nil)
+	hash.Write(i[:])
+	return Blake2b224(hash.Sum(nil))
+}
+
+func (i IssuerVkey) PoolId() string {
+	// Convert data to base32 and encode as bech32
+	convData, err := bech32.ConvertBits(i.Hash().Bytes(), 8, 5, true)
+	if err != nil {
+		panic(fmt.Sprintf("unexpected error converting data to base32: %s", err))
+	}
+	encoded, err := bech32.Encode("pool", convData)
+	if err != nil {
+		panic(fmt.Sprintf("unexpected error encoding data as bech32: %s", err))
+	}
+	return encoded
+}

ledger/mary.go

@@ -56,7 +56,7 @@ func (b *MaryBlock) SlotNumber() uint64 {
 	return b.Header.SlotNumber()
 }
 
-func (b *MaryBlock) IssuerVkey() []byte {
+func (b *MaryBlock) IssuerVkey() IssuerVkey {
 	return b.Header.IssuerVkey()
 }
 

ledger/shelley.go

@@ -55,7 +55,7 @@ func (b *ShelleyBlock) SlotNumber() uint64 {
 	return b.Header.SlotNumber()
 }
 
-func (b *ShelleyBlock) IssuerVkey() []byte {
+func (b *ShelleyBlock) IssuerVkey() IssuerVkey {
 	return b.Header.IssuerVkey()
 }
 
@@ -89,7 +89,7 @@ type ShelleyBlockHeader struct {
 		BlockNumber          uint64
 		Slot                 uint64
 		PrevHash             Blake2b256
-		IssuerVkey           []byte
+		IssuerVkey           IssuerVkey
 		VrfKey               []byte
 		NonceVrf             interface{}
 		LeaderVrf            interface{}
@@ -124,7 +124,7 @@ func (h *ShelleyBlockHeader) SlotNumber() uint64 {
 	return h.Body.Slot
 }
 
-func (h *ShelleyBlockHeader) IssuerVkey() []byte {
+func (h *ShelleyBlockHeader) IssuerVkey() IssuerVkey {
 	return h.Body.IssuerVkey
 }