Initial commit

ildevelop · ildevelop · commit 8a8a8df04eaf · 2016-11-06T17:32:39.000+02:00
diff --git a/.gitignore b/.gitignore
@@ -0,0 +1,63 @@
+# Created by .ignore support plugin (hsz.mobi)
+### Python template
+# Byte-compiled / optimized / DLL files
+__pycache__/
+*.py[cod]
+*$py.class
+
+# C extensions
+*.so
+
+# Distribution / packaging
+.Python
+env/
+build/
+develop-eggs/
+dist/
+downloads/
+eggs/
+.eggs/
+lib/
+lib64/
+parts/
+sdist/
+var/
+*.egg-info/
+.installed.cfg
+*.egg
+
+# PyInstaller
+#  Usually these files are written by a python script from a template
+#  before PyInstaller builds the exe, so as to inject date/other infos into it.
+*.manifest
+*.spec
+
+# Installer logs
+pip-log.txt
+pip-delete-this-directory.txt
+
+# Unit test / coverage reports
+htmlcov/
+.tox/
+.coverage
+.coverage.*
+.cache
+nosetests.xml
+coverage.xml
+*,cover
+
+# Translations
+*.mo
+*.pot
+
+# Django stuff:
+*.log
+
+# Sphinx documentation
+docs/_build/
+
+# PyBuilder
+target/
+
+db.sqlite3
+.idea/
diff --git a/blog_channels/__init__.py b/blog_channels/__init__.py
diff --git a/blog_channels/asgi.py b/blog_channels/asgi.py
@@ -0,0 +1,5 @@
+import os
+import channels.asgi
+
+os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'blog_channels.settings')
+channel_layer = channels.asgi.get_channel_layer()
diff --git a/blog_channels/routing.py b/blog_channels/routing.py
@@ -0,0 +1,9 @@
+from channels.routing import route
+
+
+channel_routing = {
+    'websocket.connect': 'chat.consumers.ws_connect',
+    'websocket.receive': 'chat.consumers.ws_message',
+    'websocket.disconnect': 'chat.consumers.ws_disconnect',
+    'send_email': 'chat.consumers.send_email_consumer'
+}
diff --git a/blog_channels/settings.py b/blog_channels/settings.py
@@ -0,0 +1,103 @@
+
+import os
+
+BASE_DIR = os.path.dirname(os.path.dirname(os.path.abspath(__file__)))
+
+SECRET_KEY = '03zg-#q0r$3u#6e-%oifn!ea^d+=d+^77ep7xq(!e)jxbiw%%('
+
+DEBUG = True
+
+ALLOWED_HOSTS = []
+
+
+INSTALLED_APPS = [
+    'django.contrib.admin',
+    'django.contrib.auth',
+    'django.contrib.contenttypes',
+    'django.contrib.sessions',
+    'django.contrib.messages',
+    'django.contrib.staticfiles',
+    'channels',
+]
+
+MIDDLEWARE_CLASSES = [
+    'django.middleware.security.SecurityMiddleware',
+    'django.contrib.sessions.middleware.SessionMiddleware',
+    'django.middleware.common.CommonMiddleware',
+    'django.middleware.csrf.CsrfViewMiddleware',
+    'django.contrib.auth.middleware.AuthenticationMiddleware',
+    'django.contrib.auth.middleware.SessionAuthenticationMiddleware',
+    'django.contrib.messages.middleware.MessageMiddleware',
+    'django.middleware.clickjacking.XFrameOptionsMiddleware',
+]
+
+ROOT_URLCONF = 'blog_channels.urls'
+
+TEMPLATES = [
+    {
+        'BACKEND': 'django.template.backends.django.DjangoTemplates',
+        'DIRS': [os.path.join(BASE_DIR, 'templates')]
+        ,
+        'APP_DIRS': True,
+        'OPTIONS': {
+            'context_processors': [
+                'django.template.context_processors.debug',
+                'django.template.context_processors.request',
+                'django.contrib.auth.context_processors.auth',
+                'django.contrib.messages.context_processors.messages',
+            ],
+        },
+    },
+]
+
+WSGI_APPLICATION = 'blog_channels.wsgi.application'
+
+
+DATABASES = {
+    'default': {
+        'ENGINE': 'django.db.backends.sqlite3',
+        'NAME': os.path.join(BASE_DIR, 'db.sqlite3'),
+    }
+}
+
+
+AUTH_PASSWORD_VALIDATORS = [
+    {
+        'NAME': 'django.contrib.auth.password_validation.UserAttributeSimilarityValidator',
+    },
+    {
+        'NAME': 'django.contrib.auth.password_validation.MinimumLengthValidator',
+    },
+    {
+        'NAME': 'django.contrib.auth.password_validation.CommonPasswordValidator',
+    },
+    {
+        'NAME': 'django.contrib.auth.password_validation.NumericPasswordValidator',
+    },
+]
+
+
+LANGUAGE_CODE = 'en-us'
+
+TIME_ZONE = 'UTC'
+
+USE_I18N = True
+
+USE_L10N = True
+
+USE_TZ = True
+
+STATIC_URL = '/static/'
+
+
+CHANNEL_LAYERS = {
+    'default': {
+        'BACKEND': 'asgi_redis.RedisChannelLayer',
+        'CONFIG': {
+            'hosts': [('localhost', 6379)],
+        },
+        'ROUTING': 'blog_channels.routing.channel_routing',
+    },
+}
+
+EMAIL_BACKEND = 'django.core.mail.backends.console.EmailBackend'
diff --git a/blog_channels/urls.py b/blog_channels/urls.py
@@ -0,0 +1,7 @@
+from django.conf.urls import url, include
+from django.contrib import admin
+
+urlpatterns = {
+    url(r'^admin/', admin.site.urls),
+    url(r'^chat/', include('chat.urls', namespace='chat')),
+}
diff --git a/blog_channels/wsgi.py b/blog_channels/wsgi.py
@@ -0,0 +1,16 @@
+"""
+WSGI config for blog_channels project.
+
+It exposes the WSGI callable as a module-level variable named ``application``.
+
+For more information on this file, see
+https://docs.djangoproject.com/en/1.9/howto/deployment/wsgi/
+"""
+
+import os
+
+from django.core.wsgi import get_wsgi_application
+
+os.environ.setdefault("DJANGO_SETTINGS_MODULE", "blog_channels.settings")
+
+application = get_wsgi_application()
diff --git a/chat/__init__.py b/chat/__init__.py
diff --git a/chat/admin.py b/chat/admin.py
@@ -0,0 +1,3 @@
+from django.contrib import admin
+
+# Register your models here.
diff --git a/chat/apps.py b/chat/apps.py
@@ -0,0 +1,5 @@
+from django.apps import AppConfig
+
+
+class ChatConfig(AppConfig):
+    name = 'chat'
diff --git a/chat/consumers.py b/chat/consumers.py
@@ -0,0 +1,34 @@
+import json
+import time
+
+from django.core.mail import send_mail
+from channels.channel import Group
+
+from django.http import HttpResponse
+from channels.handler import AsgiHandler
+
+
+def http_request_consumer(message):
+    response = HttpResponse('Hello world! You asked for %s' % message.content['path'])
+    for chunk in AsgiHandler.encode_response(response):
+        message.reply_channel.send(chunk)
+
+
+def ws_connect(message):
+    Group('chat').add(message.reply_channel)
+
+
+def ws_message(message):
+    Group('chat').send({'text': json.dumps({'message': message.content['text'],
+                                            'sender': message.reply_channel.name})})
+
+
+def ws_disconnect(message):
+    Group('chat').discard(message.reply_channel)
+
+
+def send_email_consumer(message):
+    time.sleep(15)
+    payload = message.content['payload']
+    send_mail(payload['subject'], payload['body'], 'root@localhost', [payload['email']],
+              fail_silently=False)
diff --git a/chat/forms.py b/chat/forms.py
@@ -0,0 +1,7 @@
+from django import forms
+
+
+class MailMeForm(forms.Form):
+    subject = forms.CharField(max_length=100)
+    body = forms.CharField(widget=forms.Textarea)
+    email = forms.EmailField()
diff --git a/chat/migrations/__init__.py b/chat/migrations/__init__.py
diff --git a/chat/models.py b/chat/models.py
@@ -0,0 +1,3 @@
+from django.db import models
+
+# Create your models here.
diff --git a/chat/tests.py b/chat/tests.py
@@ -0,0 +1,3 @@
+from django.test import TestCase
+
+# Create your tests here.
diff --git a/chat/urls.py b/chat/urls.py
@@ -0,0 +1,8 @@
+from django.conf.urls import url
+
+from .views import home, MailMeView
+
+urlpatterns = [
+    url(r'^index$', home),
+    url(r'^email$', MailMeView.as_view(), name='mailme'),
+]
diff --git a/chat/views.py b/chat/views.py
@@ -0,0 +1,24 @@
+from django.http import HttpResponse
+from django.shortcuts import render
+from django.views.generic import View
+
+from channels.channel import Channel
+
+from .forms import MailMeForm
+
+
+def home(request):
+    return render(request, 'chat.html')
+
+
+class MailMeView(View):
+    def get(request):
+        return render(request, 'mailme.html', {'form': MailMeForm()})
+
+    def post(self, request):
+        form = MailMeForm(request.POST)
+        if form.is_valid():
+            Channel('send_email').send({'payload': form.cleaned_data})
+            return HttpResponse('Good job!')
+        else:
+            return render(request, 'mailme.html', {'form': form})
diff --git a/manage.py b/manage.py
@@ -0,0 +1,10 @@
+#!/usr/bin/env python
+import os
+import sys
+
+if __name__ == "__main__":
+    os.environ.setdefault("DJANGO_SETTINGS_MODULE", "blog_channels.settings")
+
+    from django.core.management import execute_from_command_line
+
+    execute_from_command_line(sys.argv)
diff --git a/requirements.txt b/requirements.txt
@@ -0,0 +1,2 @@
+channels==0.11.0
+asgi-redis==0.10.0
diff --git a/templates/chat.html b/templates/chat.html
@@ -0,0 +1,33 @@
+<!DOCTYPE html>
+<html lang="en">
+<head>
+    <meta charset="UTF-8">
+    <title>real time django chat with Django Channels</title>
+    <script src="https://code.jquery.com/jquery-1.12.0.min.js"></script>
+    <script>
+        $(document).ready(function(){
+            var msgArea = $('#msgArea')
+            var elementMessage = $('#message')
+            var webSocket = new WebSocket('ws://' + window.location.host + '/chat/index');
+
+            webSocket.onmessage = function(message) {
+                var data = JSON.parse(message.data)
+                msgArea.append('<p><strong>'+ data.sender + '</strong>: ' + data.message + '</p>')
+            }
+            $('#btnSubmit').click(function(e) {
+                webSocket.send(elementMessage.val())
+            })
+        })
+    </script>
+</head>
+<body>
+
+<div id="msgArea"></div>
+
+<div>
+    <textarea name="message" id="message" cols="30" rows="10"></textarea>
+</div>
+
+<button id="btnSubmit">Submit</button>
+</body>
+</html>
diff --git a/templates/mailme.html b/templates/mailme.html
@@ -0,0 +1,17 @@
+<!DOCTYPE html>
+<html lang="en">
+<head>
+    <meta charset="UTF-8">
+    <title></title>
+</head>
+<body>
+
+
+<form action="{% url 'chat:mailme' %}" method="post">
+    {% csrf_token %}
+    {{ form.as_p }}
+    <input type="submit" value="Send">
+</form>
+
+</body>
+</html>

Original file line number	Diff line number	Diff line change
`@@ -0,0 +1,3 @@`
	`1`	`+from django.contrib import admin`
	`2`	`+`
	`3`	`+# Register your models here.`