import urllib2
from lxml import objectify
from urllib import urlencode

apiurl = 'http://api.zoominfo.com/PartnerAPI/XmlOutput.aspx?'

class ZoomInfoException(Exception):
    pass

def zoom_query(qtype, key, **kwargs):
    args = {
        'query_type': qtype,
        'pc': key,
    }
    args.update(kwargs)
    resp = urllib2.urlopen(''.join([apiurl, urlencode(args)]))
    resptree = objectify.parse(resp).getroot()
    if hasattr(resptree, 'ErrorMessage'):
        raise ZoomInfoException, resptree.ErrorMessage
    return resptree

def company_competitors(key, **kwargs):
    return zoom_query('company_competitors', key, **kwargs)

def company_detail(key, **kwargs):
    return zoom_query('company_detail', key, **kwargs)

def company_search_query(key, **kwargs):
    return zoom_query('company_search_query', key, **kwargs)

def people_search_query(key, **kwargs):
    return zoom_query('people_search_query', key, **kwargs)

#!/usr/bin/env python
from lxml import etree
from time import sleep
import zoominfo

key = 'Your_API_key_here'

xml = zoominfo.company_search_query(key, companyName="red hat")
for rec in xml.CompanySearchResults.CompanyRecord:
    print rec.CompanyID, rec.CompanyName, rec.Website
sleep(2)

xml = zoominfo.company_detail(key, CompanyDomain='www.redhat.com')
for person in xml.KeyPerson:
    print person.JobTitle, '-', person.FirstName, person.LastName
redhatid = xml.CompanyID
sleep(2)

try:
    xml = zoominfo.company_competitors(key, CompanyID=redhatid)
except zoominfo.ZoomInfoException, e:
    print 'Caught Error from ZoomInfo:', e
    print 'You need to upgrade your ZoomInfo to use this function'
sleep(2)

xml = zoominfo.people_search_query(key, firstName='Paul', lastName='Cormier')
rec = xml.PeopleSearchResults.PersonRecord[0]
print rec.CurrentEmployment.JobTitle, '@', rec.CurrentEmployment.Company.CompanyName

#!/usr/bin/env python
import getopt                     
import sys                        
from mechanize import Browser, _mechanize
from lxml.html import parse              

baseurl = "http://search.twitter.com/search?lang=en&q="

def search_twitter(terms, pages=1):                    
    """                                                
    terms = a list of search terms                     
    pages(optional) = number of pages to retrive       

    returns a list of dictionaries
    """
    br = Browser()
    br.set_handle_robots(False)
    results = []
    response = br.open("".join([baseurl, "+".join(terms)]))
    while(pages > 0):
        doc = parse(response).getroot()
        for msg in doc.cssselect('div.msg'):
            name = msg.cssselect('a')[0].text_content()
            text = msg.cssselect('span')[0].text_content()
            text = text.replace(' (expand)', '')
            results.append({
                'name': name,
                'text': text,
            })
        try:
            response = br.follow_link(text='Older')
        except _mechanize.LinkNotFoundError:
            break # No more pages :(
        pages -= 1
    return results

if __name__ == '__main__':
    optlist, args = getopt.getopt(sys.argv[1:], 'p:', ['pages='])
    optd = dict(optlist)
    pages = 1
    if '-p' in optd:
        pages = int(optd['-p'])
    if '--pages' in optd:
        pages = int(optd['--pages'])
    if len(args) < 1:
        print """
        Usage: %s [-p] [--pages] search terms
            -p, --pages = number of pages to retrieve
        """ % sys.argv[0]
        raise SystemExit, 1
    results = search_twitter(args, pages)
    for result in results:
        print "%(name)-20s%(text)s" % result