Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Update speedcomplainer.py #17

Open
wants to merge 6 commits into
base: master
Choose a base branch
from
Open

Update speedcomplainer.py #17

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
6 commits
Select commit Hold shift + click to select a range
b770986
Update speedcomplainer.py
engFelipeMonteiro Jul 13, 2016
17b0316
speedcomplainer works
engFelipeMonteiro Jul 17, 2016
ef1e650
installation file
engFelipeMonteiro Jul 17, 2016
5c1b870
Added windows suport, testing needed
engFelipeMonteiro Jul 21, 2016
68ae391
Add files via upload
engFelipeMonteiro Jul 21, 2016
c5acf87
Add files via upload
engFelipeMonteiro Jul 21, 2016
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 6 additions & 0 deletions installation
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -0,0 +1,6 @@
sudo pip install daemon

sudo pip install twython

sudo pip install speedtest-cli
sudo pip install oauth
126 changes: 100 additions & 26 deletions speedcomplainer.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -5,11 +5,11 @@
import daemon
import signal
import threading
import twitter
import json
import random
from logger import Logger

#import oauth as OAuth
from twython import Twython
shutdownFlag = False

def main(filename, argv):
Expand All @@ -22,23 +22,27 @@ def main(filename, argv):
signal.signal(signal.SIGINT, shutdownHandler)

monitor = Monitor()

time.sleep(10)
while not shutdownFlag:
try:

print ("*********************##**************************")
print("runing monitor time: "+str(datetime.now()))
monitor.run()

for i in range(0, 5):
#print("runed monitor time: ",datetime.now())
for i in range(0, 6):
if shutdownFlag:
break
time.sleep(1)

time.sleep(10)
#print("click sleep time: ",datetime.now())
print ("####################**#######################")
except Exception as e:
print 'Error: %s' % e
print 'Error01: %s' % e
sys.exit(1)

sys.exit()



def shutdownHandler(signo, stack_frame):
global shutdownFlag
print 'Got shutdown signal (%s: %s).' % (signo, stack_frame)
Expand All @@ -48,15 +52,37 @@ class Monitor():
def __init__(self):
self.lastPingCheck = None
self.lastSpeedTest = None
#testing twitter connection purpose
#self.twitterAuth()

def twitterAuth(self):

print ("twitter api initialization")
self.config = json.load(open('./config.json'))
TOKEN=self.config['twitter']['twitterTokenSecret']
CON_SEC_KEY=self.config['twitter']['twitterConsumerKey']
CON_SEC=self.config['twitter']['twitterConsumerSecret']
TOKEN_KEY=self.config['twitter']['twitterToken']
twitter = Twython(CON_SEC_KEY, CON_SEC,TOKEN_KEY, TOKEN)
twitter.update_status(status='See how easy using Twython is!')
#import twitter
#my_auth = twitter.OAuth(TOKEN,TOKEN_KEY,CON_SEC,CON_SEC_KEY)
#twit = twitter.Twitter(auth=my_auth)
#twit.statuses.update(status="I'm tweeting from Python!")
#api = twitter.api.Twitter(auth=OAuth(consumer_key=tck,consumer_secret=tcs,access_token_key=ttk,access_token_secret=tts))
print ("twitter api initialized")

def run(self):
if not self.lastPingCheck or (datetime.now() - self.lastPingCheck).total_seconds() >= 60:
self.runPingTest()
self.lastPingCheck = datetime.now()
print("ping test started")

if not self.lastSpeedTest or (datetime.now() - self.lastSpeedTest).total_seconds() >= 3600:
#if not self.lastSpeedTest or (datetime.now() - self.lastSpeedTest).total_seconds() >= 3600:
if not self.lastSpeedTest or (datetime.now() - self.lastSpeedTest).total_seconds() >= 300:
self.runSpeedTest()
self.lastSpeedTest = datetime.now()
print("Speed test started\n")

def runPingTest(self):
pingThread = PingTest()
Expand All @@ -80,10 +106,24 @@ def run(self):
self.logPingResults(pingResults)

def doPingTest(self):
response = os.system("ping -c %s -W %s -w %s 8.8.8.8 > /dev/null 2>&1" % (self.numPings, (self.pingTimeout * 1000), self.maxWaitTime))
print ("["+str(self.ident)+"] executando ping \n")
#import pdb; pdb.set_trace()
if "win" in sys.platform:
#Windows response
response = os.system("ping -n %s -w %s www.google.com " % (self.numPings, self.maxWaitTime))
elif "linux" in sys.platform:
#linux response
response = os.system("ping -c %s -W %s -w %s 8.8.8.8 > /dev/null 2>&1" % (self.numPings, (self.pingTimeout * 1000), self.maxWaitTime))
else:
print("["+str(self.ident)+"] Sistema nao suportado")
print("["+str(self.ident)+"] "+str(sys.platform))
response=1

print ("["+(str(self.ident)+"] Response:"+str(response)+"\n"))
success = 0
if response == 0:
success = 1
print("["+str(self.ident)+"] success:"+str(success)+"\n")
return { 'date': datetime.now(), 'success': success }

def logPingResults(self, pingResults):
Expand All @@ -101,46 +141,80 @@ def run(self):
self.tweetResults(speedTestResults)

def doSpeedTest(self):
print ("["+str(self.ident)+"] Starting speedtest \n")
# run a speed test
result = os.popen("/usr/local/bin/speedtest-cli --simple").read()
result = os.popen("speedtest-cli --simple").read()
if 'Cannot' in result:
return { 'date': datetime.now(), 'uploadResult': 0, 'downloadResult': 0, 'ping': 0 }

print "result: "+str(result)
# Result:
# Ping: 529.084 ms
# Download: 0.52 Mbit/s
# Upload: 1.79 Mbit/s

#import pdb; pdb.set_trace()

resultSet = result.split('\n')
pingResult = resultSet[0]
downloadResult = resultSet[1]
uploadResult = resultSet[2]

try:
pingResult = resultSet[0]
downloadResult = resultSet[1]
uploadResult = resultSet[2]
except Exception as e:
pingResult = "Ping: 0.0 ms"
downloadResult = "Download: 0.0 Mbit/s"
uploadResult = "Upload: 0.0 Mbit/s"
print "["+str(self.ident)+"] ErrorISP Tratado: %s" % e

pingResult = float(pingResult.replace('Ping: ', '').replace(' ms', ''))
downloadResult = float(downloadResult.replace('Download: ', '').replace(' Mbit/s', ''))
uploadResult = float(uploadResult.replace('Upload: ', '').replace(' Mbit/s', ''))

print ("["+str(self.ident)+"] Done speedtest")
return { 'date': datetime.now(), 'uploadResult': uploadResult, 'downloadResult': downloadResult, 'ping': pingResult }

def logSpeedTestResults(self, speedTestResults):
self.logger.log([ speedTestResults['date'].strftime('%Y-%m-%d %H:%M:%S'), str(speedTestResults['uploadResult']), str(speedTestResults['downloadResult']), str(speedTestResults['ping']) ])
print("["+str(self.ident)+"] Done log")


def tweetResults(self, speedTestResults):
thresholdMessages = self.config['tweetThresholds']
message = None
for (threshold, messages) in thresholdMessages.items():
threshold = float(threshold)
if speedTestResults['downloadResult'] < threshold:
message = messages[random.randint(0, len(messages) - 1)].replace('{tweetTo}', self.config['tweetTo']).replace('{internetSpeed}', self.config['internetSpeed']).replace('{downloadResult}', str(speedTestResults['downloadResult']))

if speedTestResults['downloadResult'] < threshold and speedTestResults['downloadResult'] != 0.0:
message = messages[random.randint(0, len(messages) - 1)].replace('{tweetTo}', self.config['tweetTo']).replace('{internetSpeed}', self.config['internetSpeed']).replace('{downloadResult}', str(speedTestResults['downloadResult']))
print ("["+str(self.ident)+"] message:",message)
if message:
api = twitter.Api(consumer_key=self.config['twitter']['twitterConsumerKey'],
consumer_secret=self.config['twitter']['twitterConsumerSecret'],
access_token_key=self.config['twitter']['twitterToken'],
access_token_secret=self.config['twitter']['twitterTokenSecret'])

#import twitter
#api = twitter.api(consumer_key=self.config['twitter']['twitterConsumerKey'],
# consumer_secret=self.config['twitter']['twitterConsumerSecret'],
# access_token_key=self.config['twitter']['twitterToken'],
# access_token_secret=self.config['twitter']['twitterTokenSecret'])
#TOKEN_KEY=self.config['twitter']['twitterTokenSecret']
#CON_SEC_KEY=self.config['twitter']['twitterConsumerKey']
#CON_SEC=self.config['twitter']['twitterConsumerSecret']
#TOKEN=self.config['twitter']['twitterToken']
#my_auth = twitter.OAuth(TOKEN,TOKEN_KEY,CON_SEC,CON_SEC_KEY)
#twit = twitter.Twitter(auth=my_auth)
TOKEN=self.config['twitter']['twitterTokenSecret']
CON_SEC_KEY=self.config['twitter']['twitterConsumerKey']
CON_SEC=self.config['twitter']['twitterConsumerSecret']
TOKEN_KEY=self.config['twitter']['twitterToken']
api = Twython(CON_SEC_KEY, CON_SEC,TOKEN_KEY, TOKEN)

if api:
status = api.PostUpdate(message)
#status = api.PostUpdate(message)
#twit.statuses.update(status=message)
api.update_status(status=message)
else:
print ("["+str(self.ident)+"] No API")
else:
if speedTestResults['downloadResult'] == 0.0:
print("["+str(self.ident)+"] speedtest-cli: Mensasen nao enviada do por fala de conectividade ou plataforma nao suportada")
else:
print ("["+str(self.ident)+"] Internet dentro dos padroes estabelecidos")
print("["+str(self.ident)+"] Done tweetResult")

class DaemonApp():
def __init__(self, pidFilePath, stdout_path='/dev/null', stderr_path='/dev/null'):
Expand Down