Subversion Repositories SmartDukaan

Rev

Rev 14803 | Rev 14845 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 14803 Rev 14843
Line -... Line 1...
- 
 
 1 
import StringIO
- 
 
 2 
import base64
1 
import time
 3 
import gzip
2 
import pymongo
 4 
import pymongo
- 
 
 5 
import time
- 
 
 6 
import urllib
3 
import urllib2
 7 
import urllib2
4 
import gzip
 - 
 
5 
import StringIO
 - 
 
6 
 
 8 
 
7 
#TODO Need to add messy stuff to conf.
 9 
#TODO Need to add messy stuff to conf.
8 
con=None
 10 
con=None
9 
headers = {
11 
headers = {
10 
            'User-agent':'Mozilla/5.0 (X11; Linux i686) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/37.0.2062.120 Safari/537.36',
 12 
            'User-agent':'Mozilla/5.0 (X11; Linux i686) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/37.0.2062.120 Safari/537.36',
Line 13... Line 15...
13 
            'Accept-Charset' : 'ISO-8859-1,utf-8;q=0.7,*;q=0.3',
 15 
            'Accept-Charset' : 'ISO-8859-1,utf-8;q=0.7,*;q=0.3',
14 
            'Connection':'keep-alive',
 16 
            'Connection':'keep-alive',
15 
            'Accept-Encoding' : 'gzip,deflate,sdch'
 17 
            'Accept-Encoding' : 'gzip,deflate,sdch'
16 
        }
 18 
        }
17 
PROXY_URL = "http://192.161.160.203:8800/"
 19 
PROXY_URL = "http://192.161.160.203:8800/"
- 
 
 20 
PUSH_NOTIFICATION_URL='http://api.profittill.com/admin/users/push'
- 
 
 21 
DTR_API_BASIC_AUTH = base64.encodestring('%s:%s' % ("dtr", "dtr18Feb2015")).replace('\n', '')
18 
 
 22 
 
19 
def get_mongo_connection(host='localhost', port=27017):
 23 
def get_mongo_connection(host='localhost', port=27017):
20 
    global con
 24 
    global con
21 
    if con is None:
 25 
    if con is None:
22 
        print "Establishing connection %s host and port %d" %(host,port)
 26 
        print "Establishing connection %s host and port %d" %(host,port)
Line 100... Line 104...
100 
    response = urllib2.urlopen(req)
 104 
    response = urllib2.urlopen(req)
101 
    response_data = ungzipResponse(response)
 105 
    response_data = ungzipResponse(response)
102 
    response.close()
 106 
    response.close()
103 
    return response_data
 107 
    return response_data
104 
 
 108 
 
- 
 
 109 
def sendNotification(userIds, campaignName, title, message,notificationtype, url):
- 
 
 110 
    usertuples = ()
- 
 
 111 
    count = -1
- 
 
 112 
    for userId in userIds:
- 
 
 113 
        count += 1
- 
 
 114 
        usertuples += (("userIds[" + str(count) + "]", userId),)
- 
 
 115 
    parameters = usertuples + (
- 
 
 116 
                   ("User[name]", campaignName),
- 
 
 117 
                   ("User[title]", title ),
- 
 
 118 
                   ("User[message]", message),
- 
 
 119 
                   ("User[type]", notificationtype),
- 
 
 120 
                   ("User[url]", url),)
- 
 
 121 
    parameters = urllib.urlencode(parameters)
- 
 
 122 
    print parameters
- 
 
 123 
    pushpostrequest = urllib2.Request(PUSH_NOTIFICATION_URL, parameters, headers=headers)
- 
 
 124 
    pushpostrequest.add_header("Authorization", "Basic %s" % DTR_API_BASIC_AUTH)
- 
 
 125 
    print urllib2.urlopen(pushpostrequest).read()
- 
 
 126
105 

            127