Twisted API for Koji
Project description
Async interface to Koji, using Twisted
Access Koji’s XML-RPC API asynchronously (non-blocking) using the Twisted framework.
For now this supports unauthenticated access or the GSSAPI login method.
Simple Example: Fetching a user’s name
from txkoji import Connection, KojiException
from twisted.internet import defer, reactor
@defer.inlineCallbacks
def example():
koji = Connection('brew')
# fetch a user
try:
# you may pass an ID or a krb principal here
user = yield koji.getUser(3595)
# user is a Munch (dict-like) object.
print(user.name)
except KojiException as e:
print(e)
if __name__ == '__main__':
example().addCallback(lambda ign: reactor.stop())
reactor.run()
Connecting to a Koji Hub
To connect to a Koji hub, create a new txkoji.Connection instance.
You must pass a string to the constructor. This string is a profile name. For example, if you call Connector('mykoji'), then txkoji will search /etc/koji.conf.d/*.conf for the [mykoji] config section. This matches what the regular Koji client code does.
Making XML-RPC calls
Koji Hub is an XML-RPC server. You can call any method on the Connection class instance and txkoji will treat it as an XML-RPC call to the hub. For example, this Twisted inlineCallbacks-style code looks up information about a given task ID and tag ID:
@defer.inlineCallbacks
def example():
koji = Connection('mykoji')
task = yield koji.getTaskInfo(10000)
print(task.method) # "createImage"
tag = yield koji.getTag(2000)
print(tag.name) # "foo-build"
To learn the full Koji XML-RPC API:
koji list-api
You can also read the koji source code to find out details about how each method works.
Logging in
Your Koji hub must support GSSAPI authentication, and you must have a valid Kerberos ticket.
@defer.inlineCallbacks
def example():
koji = Connection('mykoji')
result = yield login()
print(result) # "True"
print('session-id: %s' % koji.session_id)
# "Who am I?"
user = yield koji.getLoggedInUser()
print(user)
Rich objects
The following RPC methods will return special classes that inherit from the Munch class:
getBuild returns txkoji.build.Build
listBuilds returns a list of txkoji.build.Build
getTaskInfo returns txkoji.task.Task
getPackage returns txkoji.package.Package
These classes have their own special helper methods to implement things I found interesting, like datetime conversions for the start/completion timestamps, or url properties for representing the objects in Kojiweb.
More special return values:
getAverageBuildDuration returns a datetime.timedelta object instead of a raw float, because this is more useful to do time arithmetic.
TODO:
More KojiException subclasses for other possible XML-RPC faults?
Implement krbV and SSL client authentication (low priority).
MikeM noted, the callnum parameter will need special handling. We might need Twisted’s DeferredLock to ensure we only have one auth’d RPC in flight at a time. It’s not really clear to me if we can actually hit a callnum error here. More integration testing needed for this.
Packages that use this package
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.