heckyel/mediagoblin
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

We handle exceptions if PuSH fails

Browse Source
This commit is contained in:
Michele Azzolari 2012-01-17 22:42:36 +01:00
parent 6d13314e99
commit 77b91efcc2
1 changed files with 14 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
mediagoblin/submit/views.py
View File

@ -21,6 +21,7 @@ from cgi import FieldStorage
from celery import registry from celery import registry
import urllib,urllib2 import urllib,urllib2
import logging
from werkzeug.utils import secure_filename from werkzeug.utils import secure_filename
@ -131,15 +132,24 @@ def submit_start(request):
'mediagoblin.user_pages.atom_feed', 'mediagoblin.user_pages.atom_feed',
qualified=True,user=request.user.username) qualified=True,user=request.user.username)
hubparameters = { hubparameters = {
'hub.mode': 'publish', 'hub.mode': 'publish',
'hub.url': feed_url} 'hub.url': feed_url}
hubdata = urllib.urlencode(hubparameters) hubdata = urllib.urlencode(hubparameters)
hubheaders = { hubheaders = {
"Content-type": "application/x-www-form-urlencoded", "Content-type": "application/x-www-form-urlencoded",
"Connection": "close"} "Connection": "close"}
for huburl in mg_globals.app_config["push_urls"]: for huburl in mg_globals.app_config["push_urls"]:
hubrequest = urllib2.Request(huburl, hubdata,hubheaders) hubrequest = urllib2.Request(huburl, hubdata, hubheaders)
hubresponse = urllib2.urlopen(hubrequest) try:
hubresponse = urllib2.urlopen(hubrequest)
except urllib2.HTTPError as exc:
# This is not a big issue, the item will be fetched
# by the PuSH server next time we hit it
logging.getLogger(__name__).warning(
"push url %r gave error %r", huburl, exc.code)
except urllib2.URLError as exc:
logging.getLogger(__name__).warning(
"push url %r is unreachable %r", huburl, exc.reason)
add_message(request, SUCCESS, _('Woohoo! Submitted!')) add_message(request, SUCCESS, _('Woohoo! Submitted!'))