sdoutil.py

import logging
logging.basicConfig(level=logging.INFO) # dev_appserver.py --log_level debug .
log = logging.getLogger(__name__)

import io
import threading
import os
import os.path
import fnmatch

SDOCONFIG=None

from google.appengine.api import app_identity
from google.appengine.api import mail
def sdo_send_mail(to=None,subject=None,msg=None):
    if not to:
        log.error("No mail recipient!")
        return
    if not subject:
        subject = "Infomation from " + app_identity.get_application_id()
    if not msg:
        msg = "Empty message"
    sender = 'manager@{}.appspotmail.com'.format(app_identity.get_application_id())
    log.info("sdo_send_mail To: %s From: %s Subject: %s Msg: %s" % (to,sender,subject,msg))
    try:
        mail.send_mail(sender=sender,to=to,subject=subject,body=msg)
    except Exception as e:
        log.error("Exception from within mail.send_mail: %s: %s" % (e,e.message))
    
# Wrap io.SringIO to ensure that all things written are of type unicode
class sdoStringIO(io.StringIO):
    
    def write(self,s):
        if isinstance(s,str):
            s = s.decode('utf-8')
            
        if not isinstance(s,unicode):
            s = unicode(s)
            
        ret = super(sdoStringIO,self).write(s)
        return ret
        
#On thread varible storage        
ThreadVars = threading.local()
def getAppVar(var):
    ret = getattr(ThreadVars, var, None)
    #log.debug("got var %s as %s" % (var,ret))
    return ret

def setAppVar(var,val):
    #log.debug("Setting var %s to %s" % (var,val))
    setattr(ThreadVars,var,val)

CLOUDSTAT = "CloudStat"
CLOUDEXTRAMETA = "CloudExtraMeta"


def full_path(filename):
	"""convert local file name to full path."""
	import os.path
	folder = os.path.dirname(os.path.realpath(__file__))
	return os.path.join(folder, filename)

def glob_from_dir(adir, pattern, source="local"):
    log.info("glob-from-dir '%s', '%s', %s" % (adir,pattern,source))
    files = []
    if os.path.isdir(adir):
        try:
            if source == "local":
                for file in os.listdir(adir):
                    if fnmatch.fnmatch(file,pattern):
                        files.append(adir + "/" + file)
        except Exception as e:
            log.error("Exception from within glob_from_dir: %s: %s" % (e,e.message))
    else:
        log.error("No such directory: %s" % adir)
        
    return files