particle-os/debian-koji
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

get_tag and accepts "auto" event

Browse source 
If "auto" is passed as an event value, latest record will be returned
without checking "active" status.

"revoke_event" will be then added to returned taginfo. If it is None,
    then it is active record, otherwise it will contain event id.

Fixes: https://pagure.io/koji/issue/1506
This commit is contained in:
Tomas Kopecek 2021-06-22 12:47:18 +02:00
parent f4f42da94c
commit 61ea78cff9
1 changed files with 16 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

19
hub/kojihub.py
View file

@ -3387,6 +3387,9 @@ def get_tag(tagInfo, strict=False, event=None, blocked=False):
Note that in order for a tag to 'exist', it must have an active entry
in tag_config. A tag whose name appears in the tag table but has no
active tag_config entry is considered deleted.
event option can be either event_id or "auto" which will pick last
recorded create_event (option for getting deleted tags)
"""
tables = ['tag_config']
@ -3399,17 +3402,27 @@ def get_tag(tagInfo, strict=False, event=None, blocked=False):
'tag_config.arches': 'arches',
'tag_config.locked': 'locked',
'tag_config.maven_support': 'maven_support',
'tag_config.maven_include_all': 'maven_include_all'
'tag_config.maven_include_all': 'maven_include_all',
}
clauses = [eventCondition(event, table='tag_config')]
data = {'tagInfo': tagInfo}
clauses = []
if isinstance(tagInfo, int):
clauses.append("tag.id = %(tagInfo)i")
elif isinstance(tagInfo, str):
clauses.append("tag.name = %(tagInfo)s")
else:
raise koji.GenericError('Invalid type for tagInfo: %s' % type(tagInfo))
if event == "auto":
# find active event or latest create_event
opts = {'order': '-create_event', 'limit': 1}
query = QueryProcessor(tables=['tag_config'], columns=['create_event'],
joins=['tag on tag.id = tag_config.tag_id'],
clauses=clauses, values=data, opts=opts)
event = query.executeOne()['create_event']
fields['tag_config.revoke_event'] = 'revoke_event'
clauses.append(eventCondition(event, table='tag_config'))
data = {'tagInfo': tagInfo}
fields, aliases = zip(*fields.items())
query = QueryProcessor(columns=fields, aliases=aliases, tables=tables,
joins=joins, clauses=clauses, values=data)