Support 202405

CHANGELOG.md

@@ -2,6 +2,8 @@
 
 
 ## Unreleased
+### Added
+- Client.update_all() method to update all objects in the database - this existed in v1 and has now been readded
 ### Fixed
 - fixes automatic solving of unique constraint errors (#85)
 

CHANGELOG.yaml

@@ -1,5 +1,6 @@
 Unreleased:
-  added: []
+  added:
+  - Client.update_all() method to update all objects in the database - this existed in v1 and has now been readded
   fixed:
   - fixes automatic solving of unique constraint errors (#85)
   changed: []

src/peeringdb/__init__.py

@@ -1,6 +1,7 @@
 """
 PeeringDB API
 """
+
 import logging
 import sys
 from importlib import import_module

src/peeringdb/_sync.py

@@ -1,6 +1,7 @@
 """
 Sync implementation module
 """
+
 from collections import defaultdict
 
 from peeringdb.util import group_fields

src/peeringdb/_update.py

@@ -1,6 +1,7 @@
 """
 Module defining main interface classes for sync
 """
+
 import logging
 from datetime import datetime
 from typing import List, Union
@@ -13,7 +14,6 @@
 
 
 class Updater:
-
     """
     Handles initial and incremental update from a PeeringDB remote API
     to the local backend.

src/peeringdb/backend.py

@@ -41,7 +41,6 @@ def __init__(self, name):
 
 
 class EmptyContext:
-
     """
     We use this to provide a dummy context wherever it's optional
     """
@@ -54,7 +53,6 @@ def __exit__(self, *args):
 
 
 class Base:
-
     """
     Backend base class.
 
@@ -105,7 +103,6 @@ def get_resource(self, cls):
 
 
 class Interface(Base):
-
     """
     backend adapter interface
 

src/peeringdb/client.py

@@ -78,6 +78,10 @@ def all(self, res):
         backend = get_backend()
         return backend.get_objects(backend.get_concrete(res))
 
+    def update_all(self):
+        """Update all resources from the API."""
+        return self.updater.update_all(resource.all_resources())
+
     @property
     def backend(self):
         return get_backend()

src/peeringdb/config.py

@@ -3,6 +3,7 @@
 
 This defines config schemas and related I/O.
 """
+
 import os
 
 import munge
@@ -47,9 +48,11 @@ class SyncSchema(_schema.Schema):
         only = _schema.List(
             "only",
             item=_schema.Str(),
-            default=os.environ.get("PDB_SYNC_ONLY", "").split(",")
-            if os.environ.get("PDB_SYNC_ONLY")
-            else [],
+            default=(
+                os.environ.get("PDB_SYNC_ONLY", "").split(",")
+                if os.environ.get("PDB_SYNC_ONLY")
+                else []
+            ),
         )
         timeout = _schema.Int(
             "timeout", default=int(os.environ.get("PDB_SYNC_TIMEOUT", "0"))

src/peeringdb/resource.py

@@ -1,6 +1,7 @@
 """
 PeeringDB resource definitions
 """
+
 from collections import OrderedDict
 
 # Generate classes

tests/test_client.py

@@ -19,6 +19,11 @@ def test_get(client):
         client.get(resource.Network, 9999)
 
 
+def test_update_all(client):
+    client.update_all()
+    assert client.get(resource.Network, NET0)
+
+
 def test_type_wrap(client):
     assert client.tags.net.get(NET0)
     assert client.tags.net.all()