engine 1.0

engine/settings.py

@@ -0,0 +1,156 @@
+# Django settings for engine project.
+
+DEBUG = True
+TEMPLATE_DEBUG = DEBUG
+
+ADMINS = (
+    # ('Your Name', '[email protected]'),
+)
+
+MANAGERS = ADMINS
+
+DATABASES = {
+    'default': {
+        'ENGINE': 'django.db.backends.sqlite3', # Add 'postgresql_psycopg2', 'mysql', 'sqlite3' or 'oracle'.
+        'NAME': '/home/os/workspace/engine/sqlite.db',                      # Or path to database file if using sqlite3.
+        # The following settings are not used with sqlite3:
+        'USER': '',
+        'PASSWORD': '',
+        'HOST': '',                      # Empty for localhost through domain sockets or '127.0.0.1' for localhost through TCP.
+        'PORT': '',                      # Set to empty string for default.
+    }
+}
+
+# Hosts/domain names that are valid for this site; required if DEBUG is False
+# See https://docs.djangoproject.com/en/1.5/ref/settings/#allowed-hosts
+ALLOWED_HOSTS = []
+
+# Local time zone for this installation. Choices can be found here:
+# http://en.wikipedia.org/wiki/List_of_tz_zones_by_name
+# although not all choices may be available on all operating systems.
+# In a Windows environment this must be set to your system time zone.
+TIME_ZONE = 'America/Chicago'
+
+# Language code for this installation. All choices can be found here:
+# http://www.i18nguy.com/unicode/language-identifiers.html
+LANGUAGE_CODE = 'en-us'
+
+SITE_ID = 1
+
+# If you set this to False, Django will make some optimizations so as not
+# to load the internationalization machinery.
+USE_I18N = True
+
+# If you set this to False, Django will not format dates, numbers and
+# calendars according to the current locale.
+USE_L10N = True
+
+# If you set this to False, Django will not use timezone-aware datetimes.
+USE_TZ = True
+
+# Absolute filesystem path to the directory that will hold user-uploaded files.
+# Example: "/var/www/example.com/media/"
+MEDIA_ROOT = ''
+
+# URL that handles the media served from MEDIA_ROOT. Make sure to use a
+# trailing slash.
+# Examples: "http://example.com/media/", "http://media.example.com/"
+MEDIA_URL = ''
+
+# Absolute path to the directory static files should be collected to.
+# Don't put anything in this directory yourself; store your static files
+# in apps' "static/" subdirectories and in STATICFILES_DIRS.
+# Example: "/var/www/example.com/static/"
+STATIC_ROOT = ''
+
+# URL prefix for static files.
+# Example: "http://example.com/static/", "http://static.example.com/"
+STATIC_URL = '/static/'
+
+# Additional locations of static files
+STATICFILES_DIRS = (
+    # Put strings here, like "/home/html/static" or "C:/www/django/static".
+    # Always use forward slashes, even on Windows.
+    # Don't forget to use absolute paths, not relative paths.
+)
+
+# List of finder classes that know how to find static files in
+# various locations.
+STATICFILES_FINDERS = (
+    'django.contrib.staticfiles.finders.FileSystemFinder',
+    'django.contrib.staticfiles.finders.AppDirectoriesFinder',
+#    'django.contrib.staticfiles.finders.DefaultStorageFinder',
+)
+
+# Make this unique, and don't share it with anybody.
+SECRET_KEY = '2%f!$mjf2u#8(idq%#-yo9s22r@-lsax-$wdjw3ycsfb93zb_x'
+
+# List of callables that know how to import templates from various sources.
+TEMPLATE_LOADERS = (
+    'django.template.loaders.filesystem.Loader',
+    'django.template.loaders.app_directories.Loader',
+#     'django.template.loaders.eggs.Loader',
+)
+
+MIDDLEWARE_CLASSES = (
+    'django.middleware.common.CommonMiddleware',
+    'django.contrib.sessions.middleware.SessionMiddleware',
+    'django.middleware.csrf.CsrfViewMiddleware',
+    'django.contrib.auth.middleware.AuthenticationMiddleware',
+    'django.contrib.messages.middleware.MessageMiddleware',
+    # Uncomment the next line for simple clickjacking protection:
+    # 'django.middleware.clickjacking.XFrameOptionsMiddleware',
+)
+
+ROOT_URLCONF = 'engine.urls'
+
+# Python dotted path to the WSGI application used by Django's runserver.
+WSGI_APPLICATION = 'engine.wsgi.application'
+
+TEMPLATE_DIRS = (
+    # Put strings here, like "/home/html/django_templates" or "C:/www/django/templates".
+    # Always use forward slashes, even on Windows.
+    # Don't forget to use absolute paths, not relative paths.
+)
+
+INSTALLED_APPS = (
+    'django.contrib.auth',
+    'django.contrib.contenttypes',
+    'django.contrib.sessions',
+    'django.contrib.sites',
+    'django.contrib.messages',
+    'django.contrib.staticfiles',
+    # Uncomment the next line to enable the admin:
+    # 'django.contrib.admin',
+    # Uncomment the next line to enable admin documentation:
+    # 'django.contrib.admindocs',
+)
+
+# A sample logging configuration. The only tangible logging
+# performed by this configuration is to send an email to
+# the site admins on every HTTP 500 error when DEBUG=False.
+# See http://docs.djangoproject.com/en/dev/topics/logging for
+# more details on how to customize your logging configuration.
+LOGGING = {
+    'version': 1,
+    'disable_existing_loggers': False,
+    'filters': {
+        'require_debug_false': {
+            '()': 'django.utils.log.RequireDebugFalse'
+        }
+    },
+    'handlers': {
+        'mail_admins': {
+            'level': 'ERROR',
+            'filters': ['require_debug_false'],
+            'class': 'django.utils.log.AdminEmailHandler'
+        }
+    },
+    'loggers': {
+        'django.request': {
+            'handlers': ['mail_admins'],
+            'level': 'ERROR',
+            'propagate': True,
+        },
+    }
+}

engine/urls.py

@@ -0,0 +1,19 @@
+from django.conf.urls import patterns, include, url
+
+# Uncomment the next two lines to enable the admin:
+# from django.contrib import admin
+# admin.autodiscover()
+
+urlpatterns = patterns('',
+    # Examples:
+    # url(r'^$', 'engine.views.home', name='home'),
+    # url(r'^engine/', include('engine.foo.urls')),
+
+    # Uncomment the admin/doc line below to enable admin documentation:
+    # url(r'^admin/doc/', include('django.contrib.admindocs.urls')),
+
+    # Uncomment the next line to enable the admin:
+    # url(r'^admin/', include(admin.site.urls)),
+    url(r'^install/$', 'engine.views.install', name='install'),
+    url(r'^query_op/$', 'engine.views.query_op', name='query_op'),
+)

engine/views.py

@@ -0,0 +1,55 @@
+'''
+Created on 7 Mar, 2014
+
+@author: qiren
+'''
+
+
+from django.http import HttpResponse
+from django.utils import simplejson
+from django.views.decorators.csrf import csrf_exempt
+from router import router
+import log as logging
+import worker
+import copy
+
+logger = logging.getLogger('engine')
+
+
+@csrf_exempt
+def query_op(request):
+    if request.method == 'POST':
+        req = simplejson.loads(request.body.decode())
+        try:
+            resp = router.tmpl_forward(req['template_id'])
+            logger.info('query template %s' % req['template_id'])
+        except KeyError as ex:
+            logger.error(ex)
+        else:
+            if resp:
+                logger.info('%s forward successfully' % req['template_id'])
+                return HttpResponse(simplejson.dumps(resp, ensure_ascii=False))
+            else:
+                logger.info('no such template in route table should forward')
+    return HttpResponse(simplejson.dumps({'result': 'fail'}))
+
+
+@csrf_exempt
+def install(request):
+    if request.method == 'POST':
+        data = simplejson.loads(request.body.decode())
+
+        req = copy.deepcopy(data)
+        try:
+            res = router.tmpl_store(data)
+        except Exception as ex:
+            logger.error(ex)
+        else:
+            if res:
+                logger.info('store request successfully')
+                work = worker.Worker(req['param']['template_id'], req['param']['template_type'],
+                                     req['param']['template_name'], req['param']['template_is_public'])
+                work.start()
+                return HttpResponse(simplejson.dumps({'result': 'success'}))
+    return HttpResponse(simplejson.dumps({'result': 'fail'}))
+

engine/wsgi.py

@@ -0,0 +1,32 @@
+"""
+WSGI config for engine project.
+
+This module contains the WSGI application used by Django's development server
+and any production WSGI deployments. It should expose a module-level variable
+named ``application``. Django's ``runserver`` and ``runfcgi`` commands discover
+this application via the ``WSGI_APPLICATION`` setting.
+
+Usually you will have the standard Django WSGI application here, but it also
+might make sense to replace the whole Django WSGI application with a custom one
+that later delegates to the Django one. For example, you could introduce WSGI
+middleware here, or combine a Django application with an application of another
+framework.
+
+"""
+import os
+
+# We defer to a DJANGO_SETTINGS_MODULE already in the environment. This breaks
+# if running multiple sites in the same mod_wsgi process. To fix this, use
+# mod_wsgi daemon mode with each site in its own daemon process, or use
+# os.environ["DJANGO_SETTINGS_MODULE"] = "engine.settings"
+os.environ.setdefault("DJANGO_SETTINGS_MODULE", "engine.settings")
+
+# This application object is used by any WSGI server configured to use this
+# file. This includes Django's development server, if the WSGI_APPLICATION
+# setting points here.
+from django.core.wsgi import get_wsgi_application
+application = get_wsgi_application()
+
+# Apply WSGI middleware here.
+# from helloworld.wsgi import HelloWorldApplication
+# application = HelloWorldApplication(application)

log.py

@@ -0,0 +1,30 @@
+################################################################################
+#  All Rights Reserves ©2013,Vinzor Co.,Ltd.
+#
+#  History: 1.Create by Qi Ren at 2013-12-23;
+################################################################################
+
+import settings
+import logging
+import os
+
+
+def setup_default_config():
+    logger = logging.getLogger('engine')
+    logger.setLevel(logging.DEBUG)
+    fh = logging.FileHandler(os.path.join(settings.LOG_PATH, settings.LOG_FILE_NAME), encoding='utf-8')
+    fh.setLevel(logging.DEBUG)
+    ch = logging.StreamHandler()
+    ch.setLevel(logging.DEBUG)
+    formatter = logging.Formatter('%(asctime)s %(filename)s %(levelname)s %(lineno)s %(message)s')
+    fh.setFormatter(formatter)
+    ch.setFormatter(formatter)
+    logger.addHandler(fh)
+    logger.addHandler(ch)
+
+
+def getLogger(name):
+    return logging.getLogger(name)
+
+
+setup_default_config()

manage.py

@@ -0,0 +1,10 @@
+#!/usr/bin/env python
+import os
+import sys
+
+if __name__ == "__main__":
+    os.environ.setdefault("DJANGO_SETTINGS_MODULE", "engine.settings")
+
+    from django.core.management import execute_from_command_line
+
+    execute_from_command_line(sys.argv)

router.py

@@ -0,0 +1,78 @@
+'''
+Created on 7 Mar, 2014
+
+@author: qiren
+'''
+import log as logging
+import threading
+import settings
+from multiprocessing import Queue
+
+logger = logging.getLogger('engine')
+
+
+def singleton(cls, *args, **kwargs):
+    instances = {}
+    def _singleton():
+        if cls not in instances:
+            instances[cls] = cls(*args, **kwargs)
+        return instances[cls]
+    return _singleton
+
+
+@singleton
+class Router:
+    """
+    store the messages from vinzor server and forward it to right image
+    """
+    ROUTE_TABLE = {'win7_32_20G_dev_base.img', }
+    __lock = threading.Lock()
+
+    def __init__(self):
+        pass
+
+    def _check(self, data):
+        for i in settings.VINZOR_HEADER:
+            if i not in data:
+                return False
+        if 'template_id' in data['param'] and 'packages' in data['param'] and \
+            'template_name' in data['param'] and 'template_is_public' in data['param'] and \
+            'template_type' in data['param']:
+            for i in settings.ENGINE_RECV_PACKAGES_KEY:
+                for j in data['param']['packages']:
+                    if i not in j:
+                        return False
+            return True
+        return False
+
+    def tmpl_forward(self, template_id):
+        logger.debug(template_id)
+        logger.debug(self.ROUTE_TABLE)
+        if template_id in self.ROUTE_TABLE:
+            resp = self.ROUTE_TABLE[template_id].get()
+            Router.__lock.acquire()
+            if self.ROUTE_TABLE[template_id].empty():
+                del self.ROUTE_TABLE[template_id]
+            Router.__lock.release()
+            return resp
+        return None
+
+    def tmpl_store(self, data):
+        if self._check(data):
+            ss = data['param']['template_id']
+            Router.__lock.acquire()
+            del data['param']['template_id']
+            del data['param']['template_name']
+            del data['param']['template_type']
+            del data['param']['template_is_public']
+            data['param'] = data['param']['packages']
+            if ss not in self.ROUTE_TABLE:
+                self.ROUTE_TABLE[ss] = Queue()
+            self.ROUTE_TABLE[ss].put(data)
+            Router.__lock.release()
+            return True
+        return False
+
+
+# sys.modules[__name__] = Router()
+router = Router()