Skip to main content

Twisted API for Koji

Project description

Async interface to Koji, using Twisted

https://travis-ci.org/ktdreyer/txkoji.svg?branch=master https://badge.fury.io/py/txkoji.svg

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


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

txkoji-0.3.0.tar.gz (12.4 kB view hashes)

Uploaded Source

Supported by

AWS AWS Cloud computing and Security Sponsor Datadog Datadog Monitoring Fastly Fastly CDN Google Google Download Analytics Microsoft Microsoft PSF Sponsor Pingdom Pingdom Monitoring Sentry Sentry Error logging StatusPage StatusPage Status page