Install templates

.gitignore

@@ -0,0 +1,8 @@
+.idea/*
+*.pyc
+build/*
+dist/*
+django_monitio.egg-info/*
+chromedriver.log
+test_project/components
+test_project/venv

.travis.yml

@@ -0,0 +1,25 @@
+language:
+  python
+
+python:
+  - "2.7"
+#  - "3.3"
+
+env:
+  - DJANGO_VERSION=Django==1.6
+#  - DJANGO_VERSION=Django==1.7
+
+before_install:
+  - export DISPLAY=:99.0
+  - sh -e /etc/init.d/xvfb start
+  - "sh -e install_OS_test_dependencies.sh"
+  - "export PATH=`pwd`:$PATH"
+
+install:
+  - pip install $DJANGO_VERSION
+  - pip install -r test_project/requirements.txt
+
+script:
+  - cd test_project
+  - python manage.py collectstatic --noinput
+  - python manage.py test

MANIFEST.in

@@ -0,0 +1,7 @@
+include monitio
+global-include *.js
+global-include *.html
+global-include *.mo
+global-include *.po
+prune test_app
+prune test_project

PLAN.txt

@@ -0,0 +1,8 @@
+** MSIE 10 does not work in... compatibility OR quirks mode, I have localized
+version and have no idea, which is which :-)
+
+** tests for dispatch(), sse and e-mail notifications
+
+** tests for eventsource (currently disabled in tests, because it block devserver)
+
+Better documentation

droneio_build.sh

@@ -0,0 +1,4 @@
+pip install -r requirements_test.txt --use-mirrors
+sudo start xvfb &
+python manage.py test
+

install_OS_test_dependencies.sh

@@ -0,0 +1,41 @@
+#!/bin/bash
+
+# ugly fix to chrome, chrome-driver on travis -
+# see more info:
+# https://github.com/travis-ci/travis-ci/issues/938
+# based on: https://github.com/jsdevel/webdriver-sync/blob/master/.travis.yml
+sudo apt-get remove chromium-browser
+sudo apt-get install libappindicator1
+echo ttf-mscorefonts-installer msttcorefonts/accepted-mscorefonts-eula select true | sudo debconf-set-selections
+sudo apt-get install ttf-mscorefonts-installer
+sudo apt-get install x-ttcidfont-conf
+sudo mkfontdir
+sudo apt-get install defoma libgl1-mesa-dri xfonts-100dpi xfonts-75dpi xfonts-scalable xfonts-cyrillic
+wget https://dl.google.com/linux/direct/google-chrome-stable_current_amd64.deb
+sudo mkdir -p /usr/share/desktop-directories
+sudo dpkg -i google-chrome-stable_current_amd64.deb
+sudo apt-get install -f
+sudo dpkg -i google-chrome-stable_current_amd64.deb
+export CHROME_SANDBOX=/opt/google/chrome/chrome-sandbox
+sudo rm -f $CHROME_SANDBOX
+sudo wget https://googledrive.com/host/0B5VlNZ_Rvdw6NTJoZDBSVy1ZdkE -O $CHROME_SANDBOX
+sudo chown root:root $CHROME_SANDBOX; sudo chmod 4755 $CHROME_SANDBOX
+sudo md5sum $CHROME_SANDBOX
+export DISPLAY=:99.0
+Xvfb :99.0 -extension RANDR > /dev/null &
+sudo chmod 1777 /dev/shm
+export WEBDRIVER_SYNC_ENABLE_SELENIUM_STDOUT=true
+export WEBDRIVER_SYNC_ENABLE_SELENIUM_STDERR=true
+# end ugly fix to chrome, chrome-driver on travis
+
+# echo "installing browsers..."
+# wget -q -O - https://dl-ssl.google.com/linux/linux_signing_key.pub | sudo apt-key add -
+# sudo sh -c 'echo "deb http://dl.google.com/linux/chrome/deb/ stable main" >> /etc/apt/sources.list.d/google.list'
+# sudo apt-get update
+# sudo apt-get install google-chrome-stable firefox
+# sudo apt-get install -f
+# echo "downloading chromedriver..."
+wget http://chromedriver.storage.googleapis.com/2.9/chromedriver_linux64.zip
+unzip -o chromedriver_linux64.zip
+echo "adding execution permission to chromedriver binary file"
+chmod +x chromedriver

monitio/__init__.py

@@ -0,0 +1,24 @@
+# This must be imported first - the DEFAULT_TAGS must be updated
+# before import of monitio.api
+import constants
+import notify
+from django.contrib import messages
+
+messages.DEFAULT_TAGS.update(constants.DEFAULT_TAGS)
+
+from monitio.api import *
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+

monitio/admin.py

@@ -0,0 +1,10 @@
+from monitio.models import Monit
+from django.contrib import admin
+
+
+class MessageAdmin(admin.ModelAdmin):
+    list_display = ['level', 'user', 'from_user', 'subject', 'message',
+                    'created', 'read', 'is_persistent']
+
+
+admin.site.register(Monit, MessageAdmin)

monitio/api.py

@@ -0,0 +1,62 @@
+import constants
+
+def add_message(request, level, message, extra_tags='', fail_silently=False,
+                subject='', user=None, email=False, sse=False, from_user=None,
+                expires=None, close_timeout=None, url=None):
+    return request._messages.add(level, message, extra_tags, subject, user,
+                                 from_user, expires, close_timeout,
+                                 sse, email, url)
+
+
+def info(request, message, extra_tags='', fail_silently=False, subject='',
+         user=None, email=False, sse=False, from_user=None, expires=None,
+         close_timeout=None, url=None):
+    """
+    """
+    level = constants.INFO
+    return add_message(request, level, message, extra_tags, fail_silently,
+                       subject, user, email, sse, from_user, expires,
+                       close_timeout, url)
+
+
+def warning(request, message, extra_tags='', fail_silently=False, subject='',
+            user=None, email=False, sse=False, from_user=None, expires=None,
+            close_timeout=None, url=None):
+    """
+    """
+    level = constants.WARNING
+    return add_message(request, level, message, extra_tags, fail_silently,
+                       subject, user, email, sse, from_user, expires,
+                       close_timeout, url)
+
+
+def debug(request, message, extra_tags='', fail_silently=False, subject='',
+          user=None, email=False, sse=False, from_user=None, expires=None,
+          close_timeout=None, url=None):
+    """
+    """
+    level = constants.DEBUG
+    return add_message(request, level, message, extra_tags, fail_silently,
+                       subject, user, email, sse, from_user, expires,
+                       close_timeout, url)
+
+
+def create_message(to_user, level, message, from_user=None, extra_tags='',
+                   subject='', expires=None, close_timeout=None, sse=False,
+                   email=False, url=None):
+    """
+    Use this method to create message without a request object - this can
+    be used in command-line utilities, celery backend or for testing.
+    """
+
+    from monitio.storage import PersistentMessageStorage
+    class request:
+        user = to_user
+        session = {}
+
+    request.messages = PersistentMessageStorage(request)
+
+    return request.messages.add(level=level, message=message, extra_tags=extra_tags,
+                         subject=subject, from_user=from_user, expires=expires,
+                         close_timeout=close_timeout, sse=sse, email=email,
+                         url=url)

monitio/conf/__init__.py

@@ -0,0 +1,2 @@
+# -*- encoding: utf-8 -*-
+

monitio/conf/settings.py

@@ -0,0 +1,28 @@
+# -*- encoding: utf-8 -*-
+
+#
+# This package, django-monitio, needs to know, if we are runing the tests
+# or not.
+#
+# This is pretty important, as by the time of this writing, LiveServerTestCase
+# will block when testing monitio-enabled web pages, because sse view
+# will block the server thread. So, let's set this value and give
+# sse views a hint to behave differently.
+#
+# This is a new issue, I suppose, as there are no googleable rants about
+# this limitation of LiveServerTestCase at this moment. Perhaps "one thread
+# should be enough for everybody", just like 640k :-)
+#
+
+import sys
+
+from django.conf import settings
+
+TESTING = getattr(settings, 'TESTING', 'test' in sys.argv[:2])
+
+if TESTING:
+    # This seems to be another problem. We should attach to this list
+    # every possible port of testserver.
+    settings.CORS_ORIGIN_WHITELIST = (
+        'localhost:8081'
+    )

monitio/locale/pl/LC_MESSAGES/django.po

@@ -0,0 +1,49 @@
+# SOME DESCRIPTIVE TITLE.
+# Copyright (C) YEAR THE PACKAGE'S COPYRIGHT HOLDER
+# This file is distributed under the same license as the PACKAGE package.
+# FIRST AUTHOR <EMAIL@ADDRESS>, YEAR.
+#
+msgid ""
+msgstr ""
+"Project-Id-Version: 1.0\n"
+"Report-Msgid-Bugs-To: \n"
+"POT-Creation-Date: 2013-12-13 22:31+0100\n"
+"PO-Revision-Date: 2013-12-13 22:32+0100\n"
+"Last-Translator: Michał Pasternak <[email protected]>\n"
+"Language-Team: LANGUAGE <[email protected]>\n"
+"MIME-Version: 1.0\n"
+"Content-Type: text/plain; charset=UTF-8\n"
+"Content-Transfer-Encoding: 8bit\n"
+"Plural-Forms: nplurals=3; plural=(n==1 ? 0 : n%10>=2 && n%10<=4 && (n%100<10 "
+"|| n%100>=20) ? 1 : 2);\n"
+"X-Generator: Poedit 1.6.2\n"
+"Language: pl\n"
+
+#: .\models.py:62
+#, python-format
+msgid "%(subject)s: %(message)s"
+msgstr "%(subject)s: %(message)s"
+
+#: .\views.py:109
+msgid ""
+"Cannot connect to Redis server. Please contact your system administrator. In "
+"case you are the system administrator, please make sure, that the Redis "
+"server is configured and running correctly."
+msgstr ""
+"Nie mogę połączyć się z serwerem Redis. Proszę, skontaktuj się ze swoim "
+"administratorem systemu. Jeżeli to Ty jesteś administratorem systemu, "
+"proszę, upewnij się, że serwer Redis jest skonfigurowany i funkcjonuje "
+"poprawnie."
+
+#: .\views.py:113
+msgid "Redis server error"
+msgstr "Błąd serwera Redis"
+
+#: .\templates\monitio\message_li.html:20
+#: .\templates\monitio\sse_template.html:13
+msgid "close"
+msgstr "zamknij"
+
+#: .\templates\monitio\messages.html:22
+msgid "close all messages"
+msgstr "zamknij wszystkie komunikaty"

monitio/locale/pl/LC_MESSAGES/djangojs.po

@@ -0,0 +1,33 @@
+# SOME DESCRIPTIVE TITLE.
+# Copyright (C) YEAR THE PACKAGE'S COPYRIGHT HOLDER
+# This file is distributed under the same license as the PACKAGE package.
+# FIRST AUTHOR <EMAIL@ADDRESS>, YEAR.
+#
+msgid ""
+msgstr ""
+"Project-Id-Version: 1/0\n"
+"Report-Msgid-Bugs-To: \n"
+"POT-Creation-Date: 2013-12-13 22:33+0100\n"
+"PO-Revision-Date: 2013-12-13 22:32+0100\n"
+"Last-Translator: Michał Pasternak <[email protected]>\n"
+"Language-Team: LANGUAGE <[email protected]>\n"
+"MIME-Version: 1.0\n"
+"Content-Type: text/plain; charset=UTF-8\n"
+"Content-Transfer-Encoding: 8bit\n"
+"Plural-Forms: nplurals=3; plural=(n==1 ? 0 : n%10>=2 && n%10<=4 && (n%100<10 "
+"|| n%100>=20) ? 1 : 2);\n"
+"X-Generator: Poedit 1.6.2\n"
+"Language: pl\n"
+
+#: .\static\monitio\js\themes\foundation.js:32
+msgid "Close all: "
+msgstr "Zamknij wszystkie: "
+
+#: .\static\monitio\js\themes\foundation.js:33
+#: .\static\monitio\js\themes\jqueryui.js:65
+msgid "close all messages"
+msgstr "zamknij wszystkie powiadomienia"
+
+#: .\static\monitio\js\themes\jqueryui.js:32
+msgid "<a>close</a>"
+msgstr "<a>zamknij</a>"

monitio/management/commands/__init__.py

@@ -0,0 +1 @@
+# 

monitio/management/commands/send_message.py

@@ -0,0 +1,42 @@
+import sys
+
+from django.core.management.base import BaseCommand
+
+from django.contrib import auth
+
+User = auth.get_user_model()
+
+from monitio import api
+
+
+def err(msg, status=-1):
+    sys.stderr.write('%s: %s\n' % (sys.argv[0], msg))
+    sys.exit(status)
+
+
+def get_user(username):
+    try:
+        return User.objects.get(username=username)
+    except User.DoesNotExist:
+        err("No such user: %r" % username)
+
+
+class Command(BaseCommand):
+    args = 'from_user to_user message'
+    help = '''This tool creates a persistent message in the database.
+
+    Usage: send_message [from user] [to user] [level=INFO,ERROR,DEBUG...] [message]'''
+
+    def handle(self, *args, **options):
+        try:
+            from_user, to_user = [get_user(username) for username in args[:2]]
+        except ValueError:
+            err(self.help)
+
+        message = " ".join(args[3:])
+        level = getattr(api.constants, args[2])
+        api.create_message(level=level,
+                           from_user=from_user, to_user=to_user,
+                           message=message,
+                           subject="%s message" % args[2],
+                           sse=True)

monitio/management/commands/sse_test.py

@@ -0,0 +1,27 @@
+# -*- encoding: utf-8 -*-
+
+from django.core.management import BaseCommand
+from django.contrib.auth import get_user_model
+from monitio import constants
+from monitio.notify import sse
+from monitio.views import SSE_ANONYMOUS
+
+
+class Command(BaseCommand):
+    help = '''This utility lets you send dynamic notifications (via Redis)
+    to a logged-in OR anonymous user.
+
+    Uwage: sse_test [user]'''
+
+    def handle(self, *args, **options):
+        User = get_user_model()
+        try:
+            user = User.objects.get(username=args[0]).username
+        except (IndexError, User.DoesNotExist):
+            user = SSE_ANONYMOUS
+
+        print "Will send messages from ", user, "to", user
+        while True:
+            message = raw_input("message> ")
+            sse(constants.INFO, -1, message, "", "SSE message",
+                user, user)