django-sms-gateway / sms / views.py

from django.http import HttpResponse
from django.views.decorators.csrf import csrf_exempt
from django.utils import simplejson as json

from decimal import Decimal
import datetime
import logging

from sms.models import Message, MessageSet, Gateway

logger = logging.getLogger('sms-gateway')

@csrf_exempt
def update_delivery_status(request):
    logger.debug("Status update received. %s" % request.GET)
    
    # If this request was 'empty', it was a ping test by the server.
    if not request.GET:
        return HttpResponse("OK")
        
    data = {}
    for k,v in request.GET.items():
        if isinstance(v, list) and len(v) == 1:
            data[k] = v[0]
        else:
            data[k] = v
    
    logger.debug('%s' % data)
    
    msg = Message.objects.get_matching_message(data)
    
    if not msg:
        logger.warn("Message could not be found: %s" % data)
        # Need to respond with OK, else remote server will keep trying.
        return HttpResponse('OK')
        
    logger.debug("Found message %i" % msg.pk)
    gateway = msg.gateway
    
    if  not gateway.status_mapping or (
        data.get(gateway.status_status) not in gateway.status_mapping.keys()
    ):
        msg.status = "Failed"
    else:
        msg.status = gateway.status_mapping[data.get(gateway.status_status)]
    logger.debug("Updated status to %s" % msg.status)
    if msg.status == "Delivered":
        if gateway.status_date:
            if gateway.status_date_format:
                msg.delivery_date = datetime.datetime.strptime(
                    data.get(gateway.status_date),
                    gateway.status_date_format,
                )
            else:
                msg.delivery_date = datetime.datetime.fromtimestamp(
                    float(data.get(gateway.status_date))
                )
        else:
            msg.delivery_date = datetime.datetime.now()
        logger.debug("Message was delivered at %s" % msg.delivery_date)
    else:
        msg.status_message = data.get(gateway.status_error_code)
        logger.debug("Error message was %s" % msg.status_message)
    
    # If the gateway told us how much it cost, we can store that.
    if gateway.charge_keyword:
        charge = data.get(gateway.charge_keyword)
        if charge:
            msg.gateway_charge = charge
    
    msg.save()
    return HttpResponse('OK')

@csrf_exempt
def handle_reply(request):
    logger.debug("SMS Reply received.")
    
    # If this request was 'empty', it was a ping test by the server.
    if not request.GET:
        return HttpResponse("OK")
    
    data = {}
    for k,v in request.GET.items():
        if isinstance(v, list) and len(v) == 1:
            data[k] = v[0]
        else:
            data[k] = v
    
    msg = Message.objects.get_original_for_reply(data)
    
    if not msg:
        logger.warn("Original message could not be found: %s" % data)
        return HttpResponse('OK')
        
    logger.debug("Found message %i" % msg.pk)
    gateway = msg.gateway
    if gateway.reply_date_format:
        reply_date = datetime.datetime.strptime(
            data.get(gateway.reply_date),
            gateway.reply_date_format,
        )
    else:
        reply_date = datetime.datetime.fromtimestamp(float(
            data.get(gateway.reply_date)
        ))
        
    reply = msg.replies.create(
        content=data.get(gateway.reply_content),
        date=reply_date,
    )
    logger.debug("Reply created")

    logger.debug("Message content was: %s" % reply.content)
    
    if msg.reply_callback:
        logger.debug("Callback found, running that.")
        msg.reply_callback(reply)
    
    return HttpResponse('OK')


def get_message_set_status(request, uuid):
    message_set = MessageSet.objects.get(uuid=uuid)
    message_set.update_data()
    if message_set.is_complete():
        return HttpResponse(json.dumps(message_set.data.values()))
    return HttpResponse(json.dumps({"percent_complete": message_set.percentage_complete}))
Tip: Filter by directory path e.g. /media app.js to search for public/media/app.js.
Tip: Use camelCasing e.g. ProjME to search for ProjectModifiedEvent.java.
Tip: Filter by extension type e.g. /repo .js to search for all .js files in the /repo directory.
Tip: Separate your search with spaces e.g. /ssh pom.xml to search for src/ssh/pom.xml.
Tip: Use ↑ and ↓ arrow keys to navigate and return to view the file.
Tip: You can also navigate files with Ctrl+j (next) and Ctrl+k (previous) and view the file with Ctrl+o.
Tip: You can also navigate files with Alt+j (next) and Alt+k (previous) and view the file with Alt+o.