Skip to content

Commit f486a23

Browse files
committed
Revert "Reducing requirements of ssm/fsm registration message formatting."
This reverts commit 5078a28.
1 parent d9224db commit f486a23

File tree

1 file changed

+13
-2
lines changed

1 file changed

+13
-2
lines changed

son-mano-specificmanager/son-mano-specific-manager-registry/son_mano_specific_manager_registry/specificmanagerregistry.py

Lines changed: 13 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -202,15 +202,26 @@ def on_ssm_register(self, ch, method, properties, message):
202202

203203
# check if the SM is already registered
204204
if sm_repo_id in self.ssm_repo.keys():
205-
LOG.error("Cannot register '{0}', already exists".format(message['specific_manager_id']))
206-
result = {'status': 'Failed', 'error': "Cannot register '{0}', "
205+
# check if the sm is an updating version
206+
if message['update_version'] == 'true':
207+
self.ssm_repo[sm_repo_id]['status']= 'registered'
208+
self.ssm_repo[sm_repo_id]['version'] = message['version']
209+
self.ssm_repo[sm_repo_id]['description'] = message['description']
210+
result = self.ssm_repo[sm_repo_id]
211+
else:
212+
LOG.error("Cannot register '{0}', already exists".format(message['specific_manager_id']))
213+
result = {'status': 'Failed', 'error': "Cannot register '{0}', "
207214
"already exists".format(message['specific_manager_id'])}
208215
else:
209216
pid = str(uuid.uuid4())
210217
response = {
211218
"status": "registered",
219+
"specific_manager_type": message['specific_manager_type'],
220+
"service_name": message['service_name'],
221+
"function_name": message['function_name'],
212222
"specific_manager_id": message['specific_manager_id'],
213223
"version": message['version'],
224+
"description": message['description'],
214225
"uuid": pid,
215226
"sfuuid": message['sf_uuid'],
216227
"error": None

0 commit comments

Comments
 (0)