diff --git a/test/conftest.py b/test/conftest.py
index d6066602f9026880655075df31d45f690fa61460..ae7c9c25ede771a380cb627eca7185bc84f016b2 100644
--- a/test/conftest.py
+++ b/test/conftest.py
@@ -5,6 +5,7 @@ import netifaces
import os
import re
import tempfile
+import threading
from lxml import etree
import pytest
@@ -92,13 +93,21 @@ TEST_DATA_DIRNAME = os.path.realpath(os.path.join(
"data"))
+_bootstrap_semaphore = threading.Semaphore()
+
+
+
class MockedRedis(object):
db = None
def __init__(self, *args, **kwargs):
- if MockedRedis.db is None:
- MockedRedis.prep()
+ _bootstrap_semaphore.acquire()
+ try:
+ if MockedRedis.db is None:
+ MockedRedis.prep()
+ finally:
+ _bootstrap_semaphore.release()
# allows us to create other mocks using a different data source file
@staticmethod
diff --git a/test/test_msr_routes.py b/test/test_msr_routes.py
index 3788bdeb08a03adcb7e1dba504363bffcaab9b99..4babd97d6089f8818b943174722e8d3b0f147dc0 100644
--- a/test/test_msr_routes.py
+++ b/test/test_msr_routes.py
@@ -4,7 +4,7 @@ import jsonschema
import pytest
from inventory_provider.routes.msr import PEERING_LIST_SCHEMA, \
- PEERING_GROUP_LIST_SCHEMA
+ PEERING_GROUP_LIST_SCHEMA, IP_ADDRESS_LIST_SCHEMA
from inventory_provider.routes.poller import SERVICES_LIST_SCHEMA
DEFAULT_REQUEST_HEADERS = {
@@ -135,3 +135,123 @@ def test_peerings_group_list(client, uri):
jsonschema.validate(response_data, PEERING_GROUP_LIST_SCHEMA)
assert response_data # test data is non-empty
+
+
+def test_peering_services(client):
+
+ # sample splunk output
+ payload = [
+ '83.97.93.247',
+ '146.48.78.13',
+ '185.6.36.40',
+ '2a00:1620:c0:4e:146:48:78:13',
+ '62.40.125.102',
+ '62.40.126.11',
+ '62.40.127.141',
+ '62.40.98.11',
+ '62.40.102.19',
+ '202.179.249.33',
+ '202.179.249.209',
+ '138.44.226.6',
+ '138.44.226.8',
+ '203.30.38.92',
+ '195.66.226.140',
+ '195.66.224.122',
+ '62.40.124.226',
+ '80.81.194.138',
+ '62.40.127.139',
+ '80.81.195.40',
+ '80.81.194.152',
+ '62.40.125.154',
+ '62.40.124.147',
+ '62.40.100.39',
+ '62.40.126.222',
+ '83.97.88.197',
+ '83.97.88.166',
+ '91.210.16.114',
+ '62.40.126.146',
+ '62.40.100.45',
+ '62.40.125.198',
+ '2400:4500::1:0:32',
+ '62.40.126.230',
+ '117.103.111.142',
+ '91.210.16.5',
+ '195.66.227.152',
+ '91.210.16.63',
+ '62.40.109.146',
+ '64.57.30.209',
+ '198.124.80.29',
+ '62.40.125.78',
+ '192.84.8.13',
+ '62.40.124.242',
+ '185.1.47.55',
+ '83.97.89.222',
+ '185.1.47.54',
+ '83.97.88.228',
+ '83.97.88.229',
+ '83.97.90.2',
+ '195.66.224.207',
+ '83.97.89.242',
+ '62.40.124.249',
+ '62.40.126.37',
+ '195.66.226.230',
+ '62.40.124.222',
+ '185.6.36.75',
+ '80.249.210.1',
+ '62.40.124.230',
+ '198.124.80.9',
+ '83.97.88.162',
+ '62.40.125.130',
+ '195.66.225.63',
+ '80.81.195.189',
+ '195.66.225.121',
+ '62.40.125.167',
+ '195.66.225.142',
+ '62.40.125.18',
+ '91.210.16.113',
+ '80.249.210.95',
+ '80.249.209.34',
+ '62.40.125.238',
+ '83.97.88.102',
+ '80.81.194.165',
+ '62.40.125.254',
+ '83.97.88.106',
+ '91.210.16.202',
+ '80.249.208.164',
+ '185.1.192.59',
+ '195.66.226.180',
+ '62.40.125.134',
+ '83.97.89.17',
+ '62.40.126.3',
+ '80.249.209.232',
+ '83.97.88.34',
+ '185.1.47.48',
+ '83.97.89.250',
+ '83.97.88.185',
+ '80.249.209.53',
+ '62.40.125.174',
+ '205.189.32.76',
+ '185.6.36.55',
+ '185.6.36.28',
+ '80.81.195.168',
+ '62.40.125.42',
+ '80.81.192.43',
+ '83.97.88.206',
+ '62.40.100.59',
+ '62.40.125.118',
+ '62.40.124.150',
+ '83.97.88.46'
+ ]
+
+ headers = {'Content-Type': 'application/json'}
+ headers.update(DEFAULT_REQUEST_HEADERS)
+ rv = client.post(
+ '/msr/bgp/peering-services',
+ headers=headers,
+ data=json.dumps(payload))
+ assert rv.status_code == 200
+ assert rv.is_json
+ response_data = json.loads(rv.data.decode('utf-8'))
+ # jsonschema.validate(response_data, IP_ADDRESS_LIST_SCHEMA)
+
+ assert response_data # test data is non-empty