--- /dev/null
+# vim: tabstop=4 shiftwidth=4 softtabstop=4
+
+# Licensed under the Apache License, Version 2.0 (the "License"); you may
+# not use this file except in compliance with the License. You may obtain
+# a copy of the License at
+#
+# http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
+# WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
+# License for the specific language governing permissions and limitations
+# under the License.
+
+import sqlalchemy
+
+
+def upgrade(migrate_engine):
+ meta = sqlalchemy.MetaData()
+ meta.bind = migrate_engine
+ event = sqlalchemy.Table('event', meta, autoload=True)
+ event.c.logical_resource_id.alter(name='resource_name')
+
+
+def downgrade(migrate_engine):
+ meta = sqlalchemy.MetaData()
+ meta.bind = migrate_engine
+ event = sqlalchemy.Table('event', meta, autoload=True)
+ event.c.resource_name.alter(name='logical_resource_id')
resource_action = sqlalchemy.Column(sqlalchemy.String)
resource_status = sqlalchemy.Column(sqlalchemy.String)
- logical_resource_id = sqlalchemy.Column(sqlalchemy.String)
+ resource_name = sqlalchemy.Column(sqlalchemy.String)
physical_resource_id = sqlalchemy.Column(sqlalchemy.String)
resource_status_reason = sqlalchemy.Column(sqlalchemy.String)
resource_type = sqlalchemy.Column(sqlalchemy.String)
api.EVENT_STACK_ID: dict(stack_identifier),
api.EVENT_STACK_NAME: stack_identifier.stack_name,
api.EVENT_TIMESTAMP: timeutils.isotime(event.timestamp),
- api.EVENT_RES_NAME: event.logical_resource_id,
+ api.EVENT_RES_NAME: event.resource_name,
api.EVENT_RES_PHYSICAL_ID: event.physical_resource_id,
api.EVENT_RES_ACTION: event.action,
api.EVENT_RES_STATUS: event.status,
self.status = status
self.reason = reason
self.physical_resource_id = physical_resource_id
- self.logical_resource_id = resource_name
+ self.resource_name = resource_name
self.resource_type = resource_type
try:
self.resource_properties = dict(resource_properties)
return cls(context, st, ev.resource_action, ev.resource_status,
ev.resource_status_reason, ev.physical_resource_id,
- ev.resource_properties, ev.logical_resource_id,
+ ev.resource_properties, ev.resource_name,
ev.resource_type, ev.created_at, ev.id)
def store(self):
'''Store the Event in the database.'''
ev = {
- 'logical_resource_id': self.logical_resource_id,
+ 'resource_name': self.resource_name,
'physical_resource_id': self.physical_resource_id,
'stack_id': self.stack.id,
'resource_action': self.action,
return None
res_id = identifier.ResourceIdentifier(
- resource_name=self.logical_resource_id, **self.stack.identifier())
+ resource_name=self.resource_name, **self.stack.identifier())
return identifier.EventIdentifier(event_id=str(self.id), **res_id)
RES_REQUIRED_BY,
) = (
'description', 'updated_time',
- 'logical_resource_id', 'physical_resource_id', 'metadata',
+ 'resource_name', 'physical_resource_id', 'metadata',
'resource_action', 'resource_status', 'resource_status_reason',
'resource_type', 'resource_identity', STACK_ID, STACK_NAME,
'required_by',
u'stack_name': u'wordpress',
u'stack_id': u'6',
u'path': u''},
- u'logical_resource_id': u'WikiDatabase',
+ u'resource_name': u'WikiDatabase',
u'resource_status_reason': u'state changed',
u'event_identity':
{u'tenant': u't',
u'path': u'resources/WikiDatabase'
},
u'stack_name': u'wordpress',
- u'logical_resource_id': u'WikiDatabase',
+ u'resource_name': u'WikiDatabase',
u'resource_status_reason': None,
u'updated_time': u'2012-07-23T13:06:00Z',
u'stack_identity': {u'tenant': u't',
u'path': u'resources/WikiDatabase'
},
u'stack_name': u'wordpress',
- u'logical_resource_id': u'WikiDatabase',
+ u'resource_name': u'WikiDatabase',
u'resource_status_reason': None,
u'updated_time': u'2012-07-23T13:06:00Z',
u'stack_identity': {u'tenant': u't',
u'path': u'resources/WikiDatabase'
},
u'stack_name': u'wordpress',
- u'logical_resource_id': u'WikiDatabase',
+ u'resource_name': u'WikiDatabase',
u'resource_status_reason': None,
u'updated_time': u'2012-07-23T13:06:00Z',
u'stack_identity': {u'tenant': u't',
u'stack_id': u'6',
u'path': u'/resources/WikiDatabase'},
u'stack_name': u'wordpress',
- u'logical_resource_id': u'WikiDatabase',
+ u'resource_name': u'WikiDatabase',
u'resource_status_reason': None,
u'updated_time': u'2012-07-23T13:06:00Z',
u'stack_identity': {u'tenant': u't',
{
u'resource_identity': dict(res_identity),
u'stack_name': stack_identity.stack_name,
- u'logical_resource_id': res_name,
+ u'resource_name': res_name,
u'resource_status_reason': None,
u'updated_time': u'2012-07-23T13:06:00Z',
u'stack_identity': stack_identity,
'rel': 'self'},
{'href': self._url(stack_identity),
'rel': 'stack'}],
- u'logical_resource_id': res_name,
+ u'resource_name': res_name,
u'resource_status_reason': None,
u'updated_time': u'2012-07-23T13:06:00Z',
u'resource_status': u'CREATE_COMPLETE',
u'description': u'',
u'resource_identity': dict(res_identity),
u'stack_name': stack_identity.stack_name,
- u'logical_resource_id': res_name,
+ u'resource_name': res_name,
u'resource_status_reason': None,
u'updated_time': u'2012-07-23T13:06:00Z',
u'stack_identity': dict(stack_identity),
{'href': self._url(stack_identity), 'rel': 'stack'},
],
u'description': u'',
- u'logical_resource_id': res_name,
+ u'resource_name': res_name,
u'resource_status_reason': None,
u'updated_time': u'2012-07-23T13:06:00Z',
u'resource_status': u'CREATE_COMPLETE',
u'description': u'',
u'resource_identity': dict(res_identity),
u'stack_name': stack_identity.stack_name,
- u'logical_resource_id': res_name,
+ u'resource_name': res_name,
u'resource_status_reason': None,
u'updated_time': u'2012-07-23T13:06:00Z',
u'stack_identity': dict(stack_identity),
u'stack_name': u'wordpress',
u'event_time': u'2012-07-23T13:05:39Z',
u'stack_identity': dict(stack_identity),
- u'logical_resource_id': res_name,
+ u'resource_name': res_name,
u'resource_status_reason': u'state changed',
u'event_identity': dict(ev_identity),
u'resource_action': u'CREATE',
u'stack_name': u'wordpress',
u'event_time': u'2012-07-23T13:05:39Z',
u'stack_identity': dict(stack_identity),
- u'logical_resource_id': 'SomeOtherResource',
+ u'resource_name': 'SomeOtherResource',
u'resource_status_reason': u'state changed',
u'event_identity': dict(ev_identity),
u'resource_action': u'CREATE',
{'href': self._url(res_identity), 'rel': 'resource'},
{'href': self._url(stack_identity), 'rel': 'stack'},
],
- u'logical_resource_id': res_name,
+ u'resource_name': res_name,
u'resource_status_reason': u'state changed',
u'event_time': u'2012-07-23T13:05:39Z',
u'resource_status': u'CREATE_IN_PROGRESS',
u'stack_name': u'wordpress',
u'event_time': u'2012-07-23T13:05:39Z',
u'stack_identity': dict(stack_identity),
- u'logical_resource_id': res_name,
+ u'resource_name': res_name,
u'resource_status_reason': u'state changed',
u'event_identity': dict(ev_identity),
u'resource_action': u'CREATE',
{'href': self._url(res_identity), 'rel': 'resource'},
{'href': self._url(stack_identity), 'rel': 'stack'},
],
- u'logical_resource_id': res_name,
+ u'resource_name': res_name,
u'resource_status_reason': u'state changed',
u'event_time': u'2012-07-23T13:05:39Z',
u'resource_status': u'CREATE_IN_PROGRESS',
u'stack_name': u'wordpress',
u'event_time': u'2012-07-23T13:05:39Z',
u'stack_identity': dict(stack_identity),
- u'logical_resource_id': 'SomeOtherResource',
+ u'resource_name': 'SomeOtherResource',
u'resource_status_reason': u'state changed',
u'event_identity': dict(ev_identity),
u'resource_action': u'CREATE',
u'stack_name': u'wordpress',
u'event_time': u'2012-07-23T13:05:39Z',
u'stack_identity': dict(stack_identity),
- u'logical_resource_id': res_name,
+ u'resource_name': res_name,
u'resource_status_reason': u'state changed',
u'event_identity': dict(ev1_identity),
u'resource_action': u'CREATE',
u'stack_name': u'wordpress',
u'event_time': u'2012-07-23T13:06:00Z',
u'stack_identity': dict(stack_identity),
- u'logical_resource_id': res_name,
+ u'resource_name': res_name,
u'resource_status_reason': u'state changed',
u'event_identity': dict(ev_identity),
u'resource_action': u'CREATE',
{'href': self._url(res_identity), 'rel': 'resource'},
{'href': self._url(stack_identity), 'rel': 'stack'},
],
- u'logical_resource_id': res_name,
+ u'resource_name': res_name,
u'resource_status_reason': u'state changed',
u'event_time': u'2012-07-23T13:06:00Z',
u'resource_status': u'CREATE_COMPLETE',
u'stack_name': u'wordpress',
u'event_time': u'2012-07-23T13:05:39Z',
u'stack_identity': dict(stack_identity),
- u'logical_resource_id': res_name,
+ u'resource_name': res_name,
u'resource_status_reason': u'state changed',
u'event_identity': dict(ev_identity),
u'resource_action': u'CREATE',
u'stack_name': u'wordpress',
u'event_time': u'2012-07-23T13:05:39Z',
u'stack_identity': dict(stack_identity),
- u'logical_resource_id': 'SomeOtherResourceName',
+ u'resource_name': 'SomeOtherResourceName',
u'resource_status_reason': u'state changed',
u'event_identity': dict(ev_identity),
u'resource_action': u'CREATE',
self.assertEqual(dict, type(ev['event_identity']))
self.assertTrue(ev['event_identity']['path'].rsplit('/', 1)[1])
- self.assertTrue('logical_resource_id' in ev)
- self.assertEqual('WebServer', ev['logical_resource_id'])
+ self.assertTrue('resource_name' in ev)
+ self.assertEqual('WebServer', ev['resource_name'])
self.assertTrue('physical_resource_id' in ev)
self.assertEqual(dict, type(ev['event_identity']))
self.assertTrue(ev['event_identity']['path'].rsplit('/', 1)[1])
- self.assertIn('logical_resource_id', ev)
+ self.assertIn('resource_name', ev)
self.assertIn('physical_resource_id', ev)
self.assertIn('resource_properties', ev)
self.assertIn('resource_status_reason', ev)
self.assertThat(ev['event_identity'], matchers.IsInstance(dict))
self.assertTrue(ev['event_identity']['path'].rsplit('/', 1)[1])
- self.assertTrue('logical_resource_id' in ev)
- self.assertEqual('WebServer', ev['logical_resource_id'])
+ self.assertTrue('resource_name' in ev)
+ self.assertEqual('WebServer', ev['resource_name'])
self.assertTrue('physical_resource_id' in ev)
self.assertTrue('resource_status_reason' in r)
self.assertTrue('resource_type' in r)
self.assertTrue('physical_resource_id' in r)
- self.assertTrue('logical_resource_id' in r)
- self.assertEqual('WebServer', r['logical_resource_id'])
+ self.assertTrue('resource_name' in r)
+ self.assertEqual('WebServer', r['resource_name'])
self.m.VerifyAll()
self.assertTrue('resource_status_reason' in r)
self.assertTrue('resource_type' in r)
self.assertTrue('physical_resource_id' in r)
- self.assertTrue('logical_resource_id' in r)
- self.assertEqual('WebServer', r['logical_resource_id'])
+ self.assertTrue('resource_name' in r)
+ self.assertEqual('WebServer', r['resource_name'])
self.m.VerifyAll()
self.assertEqual(1, len(resources))
r = resources[0]
- self.assertTrue('logical_resource_id' in r)
- self.assertEqual('WebServer', r['logical_resource_id'])
+ self.assertTrue('resource_name' in r)
+ self.assertEqual('WebServer', r['resource_name'])
self.m.VerifyAll()
self.assertTrue('resource_identity' in r)
self.assertTrue('updated_time' in r)
self.assertTrue('physical_resource_id' in r)
- self.assertTrue('logical_resource_id' in r)
- self.assertEqual('WebServer', r['logical_resource_id'])
+ self.assertTrue('resource_name' in r)
+ self.assertEqual('WebServer', r['resource_name'])
self.assertTrue('resource_status' in r)
self.assertTrue('resource_status_reason' in r)
self.assertTrue('resource_type' in r)
loaded_e = event.Event.load(self.ctx, e.id)
self.assertEqual(self.stack.id, loaded_e.stack.id)
- self.assertEqual(self.resource.name, loaded_e.logical_resource_id)
+ self.assertEqual(self.resource.name, loaded_e.resource_name)
self.assertEqual('wibble', loaded_e.physical_resource_id)
self.assertEqual('TEST', loaded_e.action)
self.assertEqual('IN_PROGRESS', loaded_e.status)
loaded_e = event.Event.load(self.ctx, e.id, stack=self.stack, event=ev)
self.assertEqual(self.stack.id, loaded_e.stack.id)
- self.assertEqual(self.resource.name, loaded_e.logical_resource_id)
+ self.assertEqual(self.resource.name, loaded_e.resource_name)
self.assertEqual('wibble', loaded_e.physical_resource_id)
self.assertEqual('TEST', loaded_e.action)
self.assertEqual('IN_PROGRESS', loaded_e.status)