#!/usr/bin/env python
#
# Copyright 2009 Google Inc.
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
#     http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
#

"""Simple Publisher client for PubSubHubbub.

Example usage:

  from pubsubhubbub_publish import *
  try:
    publish('http://pubsubhubbub.appspot.com',
            'http://example.com/feed1/atom.xml',
            'http://example.com/feed2/atom.xml',
            'http://example.com/feed3/atom.xml')
  except PublishError, e:
    # handle exception...

Set the 'http_proxy' environment variable on *nix or Windows to use an
HTTP proxy.
"""

__author__ = 'bslatkin@gmail.com (Brett Slatkin)'

import urllib
import urllib2
import logging

from google.appengine.api import urlfetch

class PublishError(Exception):
  """An error occurred while trying to publish to the hub."""


URL_BATCH_SIZE = 100


def publish(hub, *urls):
  """Publishes an event to a hub.

  Args:
    hub: The hub to publish the event to.
    **urls: One or more URLs to publish to. If only a single URL argument is
      passed and that item is an iterable that is not a string, the contents of
      that iterable will be used to produce the list of published URLs. If
      more than URL_BATCH_SIZE URLs are supplied, this function will batch them
      into chunks across multiple requests.

  Raises:
    PublishError if anything went wrong during publishing.
  """
  if len(urls) == 1 and not isinstance(urls[0], basestring):
    urls = list(urls[0])

  for i in xrange(0, len(urls), URL_BATCH_SIZE):
    chunk = urls[i:i+URL_BATCH_SIZE]
    data = urllib.urlencode(
        {'hub.url': chunk, 'hub.mode': 'publish'}, doseq=True)
    try:
      response = urlfetch.fetch(url=hub,
        payload=data,
        method=urlfetch.POST,
        headers={'Content-Type': 'application/x-www-form-urlencoded'})
    except urlfetch.DownloadError:
      logging.warning("PubSubHuhbub ping to '%s' timed out." % hub)
    else:
      if response.status_code == 204:
        continue
      else:
        raise PublishError('PubSubHuhbub hub "%s" returned: "%s"' % (hub, response.status_code))

@@ -1119,23 +1119,8 @@
 lib2
-%0Aimport logging
 %0A%0Afr
@@ -2303,25 +2303,28 @@
     
-logging.warning(%22
+raise PublishError('
 PubS
@@ -2344,12 +2344,12 @@
  to 
-'%25s'
+%22%25s%22
  tim
@@ -2355,17 +2355,17 @@
 med out.
-%22
+'
  %25 hub)%0A

Make this more better Python code.