Skip to content

Commit

Permalink
remove support for migrating peers from legacy file format
Browse files Browse the repository at this point in the history
  • Loading branch information
arvidn committed Feb 7, 2024
1 parent 9ed9abe commit b9ec672
Show file tree
Hide file tree
Showing 2 changed files with 0 additions and 145 deletions.
118 changes: 0 additions & 118 deletions chia/server/address_manager_sqlite_store.py

This file was deleted.

27 changes: 0 additions & 27 deletions chia/server/node_discovery.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,6 @@
from chia.protocols.introducer_protocol import RequestPeersIntroducer
from chia.protocols.protocol_message_types import ProtocolMessageTypes
from chia.server.address_manager import AddressManager, ExtendedPeerInfo
from chia.server.address_manager_sqlite_store import create_address_manager_from_db
from chia.server.address_manager_store import AddressManagerStore
from chia.server.outbound_message import Message, NodeType, make_msg
from chia.server.peer_store_resolver import PeerStoreResolver
Expand Down Expand Up @@ -90,30 +89,6 @@ def __init__(
if default_port is None and selected_network in NETWORK_ID_DEFAULT_PORTS:
self.default_port = NETWORK_ID_DEFAULT_PORTS[selected_network]

async def migrate_address_manager_if_necessary(self) -> None:
if (
self.legacy_peer_db_migrated
or self.peers_file_path.exists()
or self.legacy_peer_db_path is None
or not self.legacy_peer_db_path.exists()
):
# No need for migration if:
# - we've already migrated
# - we have a peers file
# - we don't have a legacy peer db
return
try:
self.log.info(f"Migrating legacy peer database from {self.legacy_peer_db_path}")
# Attempt to create an AddressManager from the legacy peer database
address_manager: Optional[AddressManager] = await create_address_manager_from_db(self.legacy_peer_db_path)
if address_manager is not None:
self.log.info(f"Writing migrated peer data to {self.peers_file_path}")
# Write the AddressManager data to the new peers file
await AddressManagerStore.serialize(address_manager, self.peers_file_path)
self.legacy_peer_db_migrated = True
except Exception:
self.log.exception("Error migrating legacy peer database")

async def initialize_address_manager(self) -> None:
self.address_manager = await AddressManagerStore.create_address_manager(self.peers_file_path)
if self.enable_private_networks:
Expand Down Expand Up @@ -552,7 +527,6 @@ def __init__(
self.key = randbits(256)

async def start(self) -> None:
await self.migrate_address_manager_if_necessary()
await self.initialize_address_manager()
self.self_advertise_task = asyncio.create_task(self._periodically_self_advertise_and_clean_data())
self.address_relay_task = asyncio.create_task(self._address_relay())
Expand Down Expand Up @@ -731,7 +705,6 @@ def __init__(

async def start(self) -> None:
self.initial_wait = 1
await self.migrate_address_manager_if_necessary()
await self.initialize_address_manager()
await self.start_tasks()

Expand Down

0 comments on commit b9ec672

Please sign in to comment.