authentication.py

Go to the documentation of this file.

from __future__ import print_function
 
 
from sys import version_info
from os import getenv
from os.path import exists
if version_info[0]==2:
  from httplib import HTTPSConnection
  from urllib2  import AbstractHTTPHandler
else:
  from http.client import HTTPSConnection
  from urllib.request  import AbstractHTTPHandler
#-------------------------------------------------------------------------------  
 
class X509CertAuth(HTTPSConnection):
  '''Class to authenticate via Grid Certificate'''
  def __init__(self, host, *args, **kwargs):
    key_file = None
    cert_file = None
 
    x509_path = getenv("X509_USER_PROXY", None)
    if x509_path and exists(x509_path):
      key_file = cert_file = x509_path
 
    if not key_file:
      x509_path = getenv("X509_USER_KEY", None)
      if x509_path and exists(x509_path):
        key_file = x509_path
 
    if not cert_file:
      x509_path = getenv("X509_USER_CERT", None)
      if x509_path and exists(x509_path):
        cert_file = x509_path
 
    if not key_file:
      x509_path = getenv("HOME") + "/.globus/userkey.pem"
      if exists(x509_path):
        key_file = x509_path
 
    if not cert_file:
      x509_path = getenv("HOME") + "/.globus/usercert.pem"
      if exists(x509_path):
        cert_file = x509_path
 
    if not key_file or not exists(key_file):
      print("No certificate private key file found", file=stderr)
      exit(1)
 
    if not cert_file or not exists(cert_file):
      print("No certificate public key file found", file=stderr)
      exit(1)
 
    #print "Using SSL private key", key_file
    #print "Using SSL public key", cert_file
    
    HTTPSConnection.__init__(self, 
                              host,
                              key_file = key_file,
                              cert_file = cert_file,
                              **kwargs)
 
#-----------------------------------------------------------------------------
 
class X509CertOpen(AbstractHTTPHandler):
  def default_open(self, req):
    return self.do_open(X509CertAuth, req)