- args.append(ocloud.Resource.resourceId == data.id)
- ret = uow.resources.list_with_count(res_pool_id, *args)
- if ret[0] != 0:
- logger.debug(
- 'Resource {} skip for subscription {} because of the '
- 'filter.'
- .format(data.id, sub_data['subscriptionId']))
+ filter_hit = False
+ for filter in filters:
+ try:
+ args = gen_orm_filter(ocloud.Resource, filter)
+ except KeyError:
+ logger.warning(
+ 'Subscription {} filter {} has wrong attribute '
+ 'name or value. Ignore the filter.'.format(
+ sub_data['subscriptionId'],
+ sub_data['filter']))
+ continue
+ if len(args) == 0 and 'objectType' in filter:
+ filter_hit = True
+ break
+ args.append(ocloud.Resource.resourceId == data.id)
+ obj_count, _ = uow.resources.list_with_count(
+ res_pool_id, *args)
+ if obj_count > 0:
+ filter_hit = True
+ break
+ if filter_hit:
+ logger.info('Subscription {} filter hit, skip Resource {}.'
+ .format(sub_data['subscriptionId'], data.id))
+ else:
+ callback_smo(notifications, sub, data, res_dict)
+
+
+def handle_filter(filter: str, f_type: str):
+ if not filter:
+ return
+ filter_strip = filter.strip(' []')
+ filter_list = filter_strip.split('|')
+ filters = list()
+ for sub_filter in filter_list:
+ exprs = sub_filter.split(';')
+ objectType = False
+ objectTypeValue = ''
+ for expr in exprs:
+ expr_strip = expr.strip(' ()')
+ items = expr_strip.split(',')
+ item_key = items[1].strip()
+ if item_key != 'objectType':