@@ -12,7 +12,7 @@ import debug from 'debug'
1212
1313import type {
1414 BaseNetworkConfig ,
15- BeaconNetwork ,
15+ LegacyBeaconNetwork ,
1616 ContentLookupResponse ,
1717 EphemeralHeaderKeyValues ,
1818 FindContentMessage ,
@@ -54,7 +54,7 @@ import {
5454 EphemeralHeaderOfferPayload ,
5555 EphemeralHeaderPayload ,
5656 HistoricalRootsBlockProof ,
57- HistoryNetworkContentType ,
57+ LegacyHistoryNetworkContentType ,
5858 MERGE_BLOCK ,
5959 SHANGHAI_BLOCK ,
6060 sszReceiptsListType ,
@@ -73,9 +73,9 @@ import { RunStatusCode } from '@lodestar/light-client'
7373import type { LightClientHeader } from '@lodestar/types/lib/deneb/types.js'
7474import type { Debugger } from 'debug'
7575
76- export class HistoryNetwork extends BaseNetwork {
76+ export class LegacyHistoryNetwork extends BaseNetwork {
7777 networkId : NetworkId
78- networkName = 'HistoryNetwork '
78+ networkName = 'LegacyHistoryNetwork '
7979 logger : Debugger
8080 public ephemeralHeaderIndex : BiMap < bigint , string > // Map of block number to block hashes
8181 public blockHashIndex : Map < string , string >
@@ -86,7 +86,7 @@ export class HistoryNetwork extends BaseNetwork {
8686 PingPongPayloadExtensions . HISTORY_RADIUS_PAYLOAD ,
8787 ]
8888 this . networkId = NetworkIdByChain [ client . chainId ] . HistoryNetwork
89- this . logger = debug ( this . enr . nodeId . slice ( 0 , 5 ) ) . extend ( 'Portal' ) . extend ( 'HistoryNetwork ' )
89+ this . logger = debug ( this . enr . nodeId . slice ( 0 , 5 ) ) . extend ( 'Portal' ) . extend ( 'LegacyHistoryNetwork ' )
9090 this . routingTable . setLogger ( this . logger )
9191 this . blockHashIndex = new Map ( )
9292 this . ephemeralHeaderIndex = new BiMap ( )
@@ -111,13 +111,13 @@ export class HistoryNetwork extends BaseNetwork {
111111 */
112112 public findContentLocally = async ( contentKey : Uint8Array ) : Promise < Uint8Array | undefined > => {
113113 const contentType = contentKey [ 0 ]
114- if ( contentType === HistoryNetworkContentType . BlockHeaderByNumber ) {
114+ if ( contentType === LegacyHistoryNetworkContentType . BlockHeaderByNumber ) {
115115 const blockNumber = decodeHistoryNetworkContentKey ( contentKey ) . keyOpt
116116 const blockHash = this . blockNumberToHash ( < bigint > blockNumber )
117117 if ( blockHash === undefined ) {
118118 return undefined
119119 }
120- const hashKey = getContentKey ( HistoryNetworkContentType . BlockHeader , blockHash )
120+ const hashKey = getContentKey ( LegacyHistoryNetworkContentType . BlockHeader , blockHash )
121121 const value = await this . retrieve ( hashKey )
122122 return value !== undefined ? hexToBytes ( value as PrefixedHexString ) : undefined
123123 }
@@ -145,8 +145,8 @@ export class HistoryNetwork extends BaseNetwork {
145145 ) : Promise < undefined | ( Uint8Array | BlockHeader ) > => {
146146 const contentKey =
147147 'blockHash' in opt
148- ? getContentKey ( HistoryNetworkContentType . BlockHeader , opt . blockHash )
149- : getContentKey ( HistoryNetworkContentType . BlockHeaderByNumber , opt . blockNumber )
148+ ? getContentKey ( LegacyHistoryNetworkContentType . BlockHeader , opt . blockHash )
149+ : getContentKey ( LegacyHistoryNetworkContentType . BlockHeaderByNumber , opt . blockNumber )
150150 const value = await this . findContentLocally ( contentKey )
151151 if ( value === undefined ) return undefined
152152 const header = BlockHeaderWithProof . deserialize ( value ) . header
@@ -155,7 +155,7 @@ export class HistoryNetwork extends BaseNetwork {
155155 }
156156
157157 public getBlockBodyBytes = async ( blockHash : Uint8Array ) : Promise < Uint8Array | undefined > => {
158- const contentKey = getContentKey ( HistoryNetworkContentType . BlockBody , blockHash )
158+ const contentKey = getContentKey ( LegacyHistoryNetworkContentType . BlockBody , blockHash )
159159 const value = await this . retrieve ( contentKey )
160160 return value !== undefined ? hexToBytes ( value as PrefixedHexString ) : undefined
161161 }
@@ -264,7 +264,7 @@ export class HistoryNetwork extends BaseNetwork {
264264 this . logger ( `invalid proof for block ${ bytesToHex ( header . hash ( ) ) } ` )
265265 throw new Error ( `invalid proof for block ${ bytesToHex ( header . hash ( ) ) } ` )
266266 }
267- const beacon = this . portal . network ( ) [ '0x500c' ] as BeaconNetwork | undefined
267+ const beacon = this . portal . network ( ) [ '0x500c' ] as LegacyBeaconNetwork | undefined
268268 if ( beacon !== undefined && beacon . lightClient ?. status === RunStatusCode . started ) {
269269 try {
270270 verifyHistoricalSummariesHeaderProof (
@@ -374,7 +374,7 @@ export class HistoryNetwork extends BaseNetwork {
374374 }
375375 case FoundContent . CONTENT :
376376 this . logger . extend ( 'FOUNDCONTENT' ) (
377- `received ${ HistoryNetworkContentType [ contentType ] } content corresponding to ${ contentKey } ` ,
377+ `received ${ LegacyHistoryNetworkContentType [ contentType ] } content corresponding to ${ contentKey } ` ,
378378 )
379379 try {
380380 await this . store ( key , decoded . value as Uint8Array )
@@ -411,9 +411,9 @@ export class HistoryNetwork extends BaseNetwork {
411411
412412 const contentKey = decodeHistoryNetworkContentKey ( decodedContentMessage . contentKey )
413413 let value : Uint8Array | undefined
414- if ( contentKey . contentType === HistoryNetworkContentType . EphemeralHeaderFindContent ) {
414+ if ( contentKey . contentType === LegacyHistoryNetworkContentType . EphemeralHeaderFindContent ) {
415415 const ck = contentKey as {
416- contentType : HistoryNetworkContentType . EphemeralHeaderFindContent
416+ contentType : LegacyHistoryNetworkContentType . EphemeralHeaderFindContent
417417 keyOpt : EphemeralHeaderKeyValues
418418 }
419419 if ( ck . keyOpt . ancestorCount < 0 || ck . keyOpt . ancestorCount > 255 ) {
@@ -542,7 +542,7 @@ export class HistoryNetwork extends BaseNetwork {
542542 let keyOpt : Uint8Array | bigint = contentKey . slice ( 1 )
543543 this . logger . extend ( 'STORE' ) ( `Storing ${ bytesToHex ( contentKey ) } (${ value . length } bytes)` )
544544 switch ( contentType ) {
545- case HistoryNetworkContentType . BlockHeader : {
545+ case LegacyHistoryNetworkContentType . BlockHeader : {
546546 try {
547547 await this . validateHeader ( value , { blockHash : bytesToHex ( keyOpt ) } )
548548 await this . put ( contentKey , bytesToHex ( value ) )
@@ -552,11 +552,11 @@ export class HistoryNetwork extends BaseNetwork {
552552 }
553553 break
554554 }
555- case HistoryNetworkContentType . BlockBody : {
555+ case LegacyHistoryNetworkContentType . BlockBody : {
556556 await this . addBlockBody ( value , keyOpt )
557557 break
558558 }
559- case HistoryNetworkContentType . Receipt : {
559+ case LegacyHistoryNetworkContentType . Receipt : {
560560 try {
561561 sszReceiptsListType . deserialize ( value )
562562 await this . put ( contentKey , bytesToHex ( value ) )
@@ -566,12 +566,12 @@ export class HistoryNetwork extends BaseNetwork {
566566 }
567567 break
568568 }
569- case HistoryNetworkContentType . BlockHeaderByNumber : {
569+ case LegacyHistoryNetworkContentType . BlockHeaderByNumber : {
570570 const { blockNumber } = BlockNumberKey . deserialize ( keyOpt )
571571 try {
572572 const blockHash = await this . validateHeader ( value , { blockNumber } )
573573 // Store block header using 0x00 key type
574- const hashKey = getContentKey ( HistoryNetworkContentType . BlockHeader , blockHash )
574+ const hashKey = getContentKey ( LegacyHistoryNetworkContentType . BlockHeader , blockHash )
575575 await this . put ( hashKey , bytesToHex ( value ) )
576576 // Switch keyOpt to blockNumber for gossip purposes
577577 keyOpt = blockNumber
@@ -581,7 +581,7 @@ export class HistoryNetwork extends BaseNetwork {
581581 break
582582 }
583583
584- case HistoryNetworkContentType . EphemeralHeaderFindContent : {
584+ case LegacyHistoryNetworkContentType . EphemeralHeaderFindContent : {
585585 const payload = EphemeralHeaderPayload . deserialize ( value )
586586 if ( payload . length === 0 ) {
587587 this . logger . extend ( 'STORE' ) ( 'Received empty ephemeral header payload' )
@@ -629,7 +629,7 @@ export class HistoryNetwork extends BaseNetwork {
629629 return
630630 }
631631 }
632- case HistoryNetworkContentType . EphemeralHeaderOffer : {
632+ case LegacyHistoryNetworkContentType . EphemeralHeaderOffer : {
633633 const payload = EphemeralHeaderOfferPayload . deserialize ( value )
634634 const header = createBlockHeaderFromRLP ( payload . header , { setHardfork : true } )
635635 // Check if we already have this header
@@ -649,24 +649,24 @@ export class HistoryNetwork extends BaseNetwork {
649649 this . portal . emit ( `${ this . networkId } :ContentAdded` , contentKey , value )
650650 if ( this . routingTable . values ( ) . length > 0 ) {
651651 if (
652- contentType !== HistoryNetworkContentType . EphemeralHeader &&
653- contentType !== HistoryNetworkContentType . EphemeralHeaderOffer &&
654- contentType !== HistoryNetworkContentType . EphemeralHeaderFindContent
652+ contentType !== LegacyHistoryNetworkContentType . EphemeralHeader &&
653+ contentType !== LegacyHistoryNetworkContentType . EphemeralHeaderOffer &&
654+ contentType !== LegacyHistoryNetworkContentType . EphemeralHeaderFindContent
655655 ) {
656656 // Gossip new content to network except for ephemeral headers
657657 this . gossipManager . add ( contentKey )
658658 }
659659 }
660660 this . logger (
661- `${ HistoryNetworkContentType [ contentType ] } added for ${ keyOpt instanceof Uint8Array ? bytesToHex ( keyOpt ) : keyOpt
661+ `${ LegacyHistoryNetworkContentType [ contentType ] } added for ${ keyOpt instanceof Uint8Array ? bytesToHex ( keyOpt ) : keyOpt
662662 } `,
663663 )
664664 }
665665
666666 public async saveReceipts ( block : Block ) {
667667 this . logger . extend ( 'BLOCK_BODY' ) ( `added for block #${ block . header . number } ` )
668668 const receipts = await saveReceipts ( block )
669- const contentKey = getContentKey ( HistoryNetworkContentType . Receipt , block . hash ( ) )
669+ const contentKey = getContentKey ( LegacyHistoryNetworkContentType . Receipt , block . hash ( ) )
670670 await this . store ( contentKey , receipts )
671671 return decodeReceipts ( receipts )
672672 }
@@ -689,7 +689,7 @@ export class HistoryNetwork extends BaseNetwork {
689689 `Error: ${ err ?. message } while validating block body for ${ shortId ( bytesToHex ( hashKey ) ) } ` ,
690690 )
691691 }
692- const bodyContentKey = getContentKey ( HistoryNetworkContentType . BlockBody , hashKey )
692+ const bodyContentKey = getContentKey ( LegacyHistoryNetworkContentType . BlockBody , hashKey )
693693 if ( block instanceof Block ) {
694694 await this . put ( bodyContentKey , bytesToHex ( bodyBytes ) )
695695 this . portal . emit ( `${ this . networkId } :ContentAdded` , bodyContentKey , bodyBytes )
@@ -776,7 +776,7 @@ export class HistoryNetwork extends BaseNetwork {
776776 const decodedContentKeys = msg . contentKeys . map ( ( key ) => decodeHistoryNetworkContentKey ( key ) )
777777 // Check to see if the first content key is for ephemeral headers. If so, we expect all
778778 // content keys to be for ephemeral headers.
779- if ( decodedContentKeys [ 0 ] . contentType === HistoryNetworkContentType . EphemeralHeaderOffer ) {
779+ if ( decodedContentKeys [ 0 ] . contentType === LegacyHistoryNetworkContentType . EphemeralHeaderOffer ) {
780780 this . logger . extend ( 'OFFER' ) . extend ( 'EPHEMERALHEADERS' ) (
781781 'Received offer for ephemeral headers starting with block hash: ' +
782782 bytesToHex ( decodedContentKeys [ 0 ] . keyOpt ) ,
@@ -787,7 +787,7 @@ export class HistoryNetwork extends BaseNetwork {
787787 let headHashIndex = - 1
788788 do {
789789 for ( const key of decodedContentKeys ) {
790- if ( key . contentType !== HistoryNetworkContentType . EphemeralHeaderOffer ) {
790+ if ( key . contentType !== LegacyHistoryNetworkContentType . EphemeralHeaderOffer ) {
791791 this . logger . extend ( 'ACCEPT' ) . extend ( 'EPHEMERALHEADERS' ) (
792792 'Received non-ephemeral header in offer for ephemeral headers. Declining offer.' ,
793793 )
@@ -796,7 +796,7 @@ export class HistoryNetwork extends BaseNetwork {
796796 break
797797 }
798798 }
799- const beacon = this . portal . networks . get ( NetworkIdByChain [ this . portal . chainId ] . BeaconChainNetwork ) as BeaconNetwork
799+ const beacon = this . portal . networks . get ( NetworkIdByChain [ this . portal . chainId ] . BeaconChainNetwork ) as LegacyBeaconNetwork
800800 if (
801801 beacon === undefined ||
802802 ( beacon . lightClient ?. status !== RunStatusCode . started &&
0 commit comments