initial commit

Author: pahlie

README.md

@@ -0,0 +1,3 @@
+from django.contrib import admin
+
+# Register your models here.

accounts/__init__.py

@@ -0,0 +1,5 @@
+from django.apps import AppConfig
+
+
+class AccountsConfig(AppConfig):
+    name = 'accounts'

accounts/__pycache__/__init__.cpython-37.pyc

@@ -0,0 +1,3 @@
+from django.db import models
+
+# Create your models here.

accounts/__pycache__/admin.cpython-37.pyc

@@ -0,0 +1,3 @@
+from django.test import TestCase
+
+# Create your tests here.

accounts/__pycache__/apps.cpython-37.pyc

@@ -0,0 +1,7 @@
+from django.urls import path
+
+from . import views
+
+urlpatterns = [
+    path('signup/', views.SignUp.as_view(), name='signup')
+]

accounts/__pycache__/models.cpython-37.pyc

@@ -0,0 +1,11 @@
+from django.shortcuts import render
+from django.contrib.auth.forms import UserCreationForm
+from django.urls import reverse_lazy
+from django.views import generic
+
+# accounts views.py
+
+class SignUp(generic.CreateView):
+    form_class = UserCreationForm
+    success_url = reverse_lazy('login')
+    template_name = 'signup.html'

accounts/__pycache__/urls.cpython-37.pyc

@@ -0,0 +1,3 @@
+from django.contrib import admin
+
+# Register your models here.

accounts/__pycache__/views.cpython-37.pyc

@@ -0,0 +1,5 @@
+from django.apps import AppConfig
+
+
+class ChatConfig(AppConfig):
+    name = 'chat'

accounts/admin.py

@@ -0,0 +1,48 @@
+from asgiref.sync import async_to_sync
+from channels.generic.websocket import WebsocketConsumer
+import json
+
+class ChatConsumer(WebsocketConsumer):
+    def connect(self):
+        self.room_name = self.scope['url_route']['kwargs']['room_name']
+        self.room_group_name = 'chat_%s' % self.room_name
+        
+        # Join room group
+        async_to_sync(self.channel_layer.group_add)(
+            self.room_group_name,
+            self.channel_name
+        )
+        
+        self.accept()
+
+    def disconnect(self, close_code):
+        # Leave room group
+        async_to_sync(self.channel_layer.group_discard)(
+            self.room_group_name,
+            self.channel_name
+        )
+
+    # Receive message from WebSocket
+    def receive(self, text_data):
+        text_data_json = json.loads(text_data)
+        message = text_data_json['message']
+
+        # Send message to room group
+        async_to_sync(self.channel_layer.group_send)(
+            self.room_group_name,
+            {
+                'type': 'chat_message',
+                'message': message
+            }
+        )
+
+    # Receive message from room group
+    def chat_message(self, event):
+        message = event['message']
+
+        # Send message to WebSocket
+        self.send(text_data=json.dumps(
+            {
+                'message': message
+            }
+        ))

accounts/apps.py

@@ -0,0 +1,9 @@
+from django.db import models
+
+# Create your models here.
+
+
+#class User(models.Model):
+
+
+#class ChatRoom(models.Model):

accounts/migrations/__init__.py

@@ -0,0 +1,6 @@
+from django.urls import path
+from chat import consumers
+
+websocket_urlpatterns = [
+     path('ws/chat/<str:room_name>/', consumers.ChatConsumer),
+]

accounts/migrations/__pycache__/__init__.cpython-37.pyc

@@ -0,0 +1,32 @@
+
+{% extends 'base.html' %}
+
+{% block title %}Chat List{% endblock %}
+
+{% block content %}
+    <h1>Welcome to the chat room list, {{user.username}}.</h1>
+    <h2>Pick a room to join:</h2>
+    {% comment %} 
+    {% for room in room_list %}
+    <div>
+        <span>{{room.name}}</span>
+        <span> | Users: {{ room.users.count }} </span>
+        <a href="{% url room.name %}">Enter</a>
+    </div>
+    {% endfor %} 
+    {% endcomment %}
+
+   <h2>Or make a new room:</h2>
+    {% comment %} <form method="post">
+        {% csrf_token %}
+        <input type="text" name="room-name" placeholder="Enter room name.."><br/>
+        <input type="submit" value="Create Room">
+    </form> {% endcomment %}
+{% endblock %}
+
+{% block scripts %}
+<script type="text/javascript">
+
+
+</script>
+{% endblock %}

accounts/models.py

@@ -0,0 +1,64 @@
+
+{% extends 'base.html' %}
+
+{% block title %}Chat Room{% endblock %}
+
+{% block content %}
+    <h1 id="room-name"></h1>
+    <textarea id="chat-log" cols="100" rows="20" style="resize: none;"></textarea><br/>
+    <input id="message-input" type="text" size="100" placeholder="Enter message here..."><br/>
+    <input id="message-submit" type="button" value="Send">
+{% endblock %}
+
+{% block scripts %}
+<script type='text/javascript'>
+
+    // document nodes used in script
+    const chatLog = document.querySelector('#chat-log');
+    const roomNameNode = document.querySelector('#room-name');
+
+    var roomNameValue = {{ room_name_json }};
+
+    changeNodeText(roomNameNode, roomNameValue);
+
+    // helper function
+    function changeNodeText(node, text) {
+        node.innerText = text.trim();
+    } 
+
+    // websocket
+    var chatSocket = new WebSocket(
+        'ws://' + window.location.host + 
+        '/ws/chat/' + roomNameValue + '/'
+    );
+
+    // websocket listeners
+    chatSocket.onmessage = function(e) {
+        var data = JSON.parse(e.data);
+        var message = data['message'];
+        chatLog.value += (message + '\n');
+    };
+
+    chatSocket.onclose = function(e) {
+        console.error('Chat socket closed unexpectedly');
+    };
+
+    // events listeners for message-input and message-submit
+    document.querySelector('#message-input').focus();
+    document.querySelector('#message-input').onkeyup = function(e) {
+        // check if enter key is enter/return
+        if (e.keycode === 13) {
+            document.querySelector('#message-submit').click();
+        }
+    }
+    document.querySelector('#message-submit').onclick = function(e) {
+        var messageInput = document.querySelector('#message-input');
+        var message = messageInput.value;
+        chatSocket.send(JSON.stringify({
+            'message': message
+        }));
+
+        messageInput.value = '';
+    }
+</script>
+{% endblock %}

accounts/tests.py

@@ -0,0 +1,3 @@
+from django.test import TestCase
+
+# Create your tests here.

accounts/urls.py

@@ -0,0 +1,9 @@
+from django.urls import path
+from chat import views
+
+app_name = 'chat'
+
+urlpatterns = [
+    path('', views.index, name='index'),
+    path('<str:room_name>/', views.room, name='room')
+]

accounts/views.py

@@ -0,0 +1,13 @@
+from django.shortcuts import render
+from django.utils.safestring import mark_safe
+import json
+
+# chat views.py
+
+def index(request):
+    return render(request, 'chat/index.html', {})
+
+def room(request, room_name):
+    return render(request, 'chat/room.html', {
+        'room_name_json': mark_safe(json.dumps(room_name))
+    })

chat/__init__.py

@@ -0,0 +1,15 @@
+#!/usr/bin/env python
+import os
+import sys
+
+if __name__ == '__main__':
+    os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'messagingapp.settings')
+    try:
+        from django.core.management import execute_from_command_line
+    except ImportError as exc:
+        raise ImportError(
+            "Couldn't import Django. Are you sure it's installed and "
+            "available on your PYTHONPATH environment variable? Did you "
+            "forget to activate a virtual environment?"
+        ) from exc
+    execute_from_command_line(sys.argv)

chat/__pycache__/__init__.cpython-37.pyc

@@ -0,0 +1,12 @@
+from django.urls import URLPattern
+from channels.routing import ProtocolTypeRouter, URLRouter
+from channels.auth import AuthMiddlewareStack
+import chat.routing
+
+application = ProtocolTypeRouter({
+    'websocket' : AuthMiddlewareStack(
+        URLRouter(
+           chat.routing.websocket_urlpatterns
+        )
+    )
+})