-
-
-def is_outdated(resource: Resource, stxobj: StxGenericModel):
- return True if resource.hash != stxobj.hash else False
-
-
-def create_by(stxobj: StxGenericModel, parent: Resource, resourcetype_id: str)\
- -> Resource:
- # content = json.loads(stxobj.content)
- resourcetype_id = resourcetype_id
- resourcepool_id = parent.resourcePoolId
- parent_id = parent.resourceId
- gAssetId = '' # TODO: global ID
- # description = "%s : An ethernet resource of the physical server"\
- # % stxobj.name
- content = json.loads(stxobj.content)
- selected_keys = [
- "name", "namedisplay", "dev_id", "pdevice", "capabilities",
- "type", "driver", "mac", "numa_node",
- "pciaddr", "pclass", "psvendor", "psdevice",
- "sriov_totalvfs", "sriov_numvfs", "dpdksupport",
- "sriov_vf_driver", "sriov_vf_pdevice_id", "interface_uuid"
- ]
- filtered = dict(
- filter(lambda item: item[0] in selected_keys, content.items()))
- extensions = json.dumps(filtered)
- description = ";".join([f"{k}:{v}" for k, v in filtered.items()])
- resource = Resource(stxobj.id, resourcetype_id, resourcepool_id,
- parent_id, gAssetId, stxobj.content, description,
- extensions)
- resource.createtime = stxobj.createtime
- resource.updatetime = stxobj.updatetime
- resource.hash = stxobj.hash
-
- return resource
-
-
-def update_by(target: Resource, stxobj: StxGenericModel,
- parentid: str) -> None:
- if target.resourceId != stxobj.id:
- raise MismatchedModel("Mismatched Id")
- target.createtime = stxobj.createtime
- target.updatetime = stxobj.updatetime
- target.hash = stxobj.hash
- target.version_number = target.version_number + 1
- target.events.append(events.ResourceChanged(
- id=stxobj.id,
- resourcePoolId=target.resourcePoolId,
- notificationEventType=NotificationEventEnum.MODIFY,
- updatetime=stxobj.updatetime
- ))