diff --git a/datafiles/schema.sql b/datafiles/schema.sql index c2cf4c6cb425dccae4b86a45f116f97799865281..8cbe7db666ca856cb48e3882bb1b3d14b443e2c9 100644 --- a/datafiles/schema.sql +++ b/datafiles/schema.sql @@ -33,7 +33,7 @@ CREATE TABLE service_connections ( ); -- internal references to connections that are part of a service connection -CREATE TABLE subconnections ( +CREATE TABLE sub_connections ( id serial PRIMARY KEY, service_connection_id integer NOT NULL REFERENCES service_connections(id), connection_id text NOT NULL, diff --git a/opennsa/aggregator.py b/opennsa/aggregator.py index ad151bed4d844d81d20c2a630edf7b740461e149..3b3bfd0fa6bb7cb0f2787c4022e757f3b0a7005d 100644 --- a/opennsa/aggregator.py +++ b/opennsa/aggregator.py @@ -223,7 +223,7 @@ class Aggregator: # only works for calls where handler args is: requester, provider, security_attrs, connection_id # this happens to be quite a lot though - sub_connections = yield conn.subconnections.get() + sub_connections = yield conn.SubConnections.get() defs = [] @@ -359,7 +359,7 @@ class Aggregator: # should probably do some sanity checks here sp = service_params local_link = True if link_provider_nsa == self.nsa_ else False - sc = database.Subconnection(provider_nsa=link_provider_nsa.urn(), + sc = database.SubConnection(provider_nsa=link_provider_nsa.urn(), connection_id=connection_id, local_link=local_link, revision=0, service_connection_id=conn.id, order_id=order_id, global_reservation_id=global_reservation_id, description=description, reservation_state=state.RESERVE_HELD, provision_state=state.SCHEDULED, activation_state=state.INACTIVE, lifecycle_state=state.INITIAL, diff --git a/opennsa/database.py b/opennsa/database.py index cf63210dbfd1f93b5fb745b273508ea1da9d1d19..8a590f842f2070a0ffde528c1caee8f0857ff24f 100644 --- a/opennsa/database.py +++ b/opennsa/database.py @@ -74,12 +74,12 @@ def setupDatabase(database, user, password=None): # ORM Objects class ServiceConnection(DBObject): - HASMANY = ['subconnections'] + HASMANY = ['SubConnections'] -class Subconnection(DBObject): - BELONGSTO = ['serviceconnection'] +class SubConnection(DBObject): + BELONGSTO = ['ServiceConnection'] -Registry.register(ServiceConnection, Subconnection) +Registry.register(ServiceConnection, SubConnection) diff --git a/test/test_aggregator.py b/test/test_aggregator.py index 301b38ac8c4e1770be0f0c58b81675c66d54f0ea..18978729a5acaf4c9f5a9212257a8ec94b5e251f 100644 --- a/test/test_aggregator.py +++ b/test/test_aggregator.py @@ -72,7 +72,7 @@ class DUDBackendTest(unittest.TestCase): from opennsa.backends.common import simplebackend # keep it simple... yield simplebackend.Simplebackendconnection.deleteAll() - yield database.Subconnection.deleteAll() + yield database.SubConnection.deleteAll() yield database.ServiceConnection.deleteAll() yield self.backend.stopService()