You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
84 lines
3.6 KiB
84 lines
3.6 KiB
#!/usr/bin/env python3 |
|
import subprocess |
|
import datetime |
|
import json |
|
import sys |
|
|
|
now = datetime.datetime.now() |
|
date = now.strftime('%Y%m%d') |
|
|
|
server_name = 'lala.cayangqu.com' |
|
|
|
try: |
|
nama_log = f"auto_replytoaccNretweet.log.{sys.argv[2]}" |
|
except: |
|
nama_log = "auto_replytoaccNretweet.log" |
|
|
|
def twit_sent(): |
|
ls_process = subprocess.Popen(["cat",f"/home/ditolak/buzz/{sys.argv[1]}/log/{nama_log}"], stdout=subprocess.PIPE, text=True) |
|
grep_process = subprocess.Popen(["grep", "twit sent with text"], stdin=ls_process.stdout, stdout=subprocess.PIPE, text=True) |
|
wc_process = subprocess.Popen(["wc", "-l"], stdin=grep_process.stdout, stdout=subprocess.PIPE, text=True) |
|
output, error = wc_process.communicate() |
|
return f"Twit sent: {output}" |
|
|
|
def twit_failed(): |
|
ls_process = subprocess.Popen(["cat",f"/home/ditolak/buzz/{sys.argv[1]}/log/{nama_log}"], stdout=subprocess.PIPE, text=True) |
|
grep_process = subprocess.Popen(["grep", "twit failed"], stdin=ls_process.stdout, stdout=subprocess.PIPE, text=True) |
|
wc_process = subprocess.Popen(["wc", "-l"], stdin=grep_process.stdout, stdout=subprocess.PIPE, text=True) |
|
output, error = wc_process.communicate() |
|
return f"Twit failed: {output}" |
|
|
|
def quote_tweet(): |
|
ls_process = subprocess.Popen(["cat",f"/home/ditolak/buzz/{sys.argv[1]}/log/{nama_log}"], stdout=subprocess.PIPE, text=True) |
|
grep_process = subprocess.Popen(["grep", "quote twit sent"], stdin=ls_process.stdout, stdout=subprocess.PIPE, text=True) |
|
wc_process = subprocess.Popen(["wc", "-l"], stdin=grep_process.stdout, stdout=subprocess.PIPE, text=True) |
|
output, error = wc_process.communicate() |
|
return f"Twit quoted: {output}" |
|
|
|
def reply_tweet(): |
|
ls_process = subprocess.Popen(["cat",f"/home/ditolak/buzz/{sys.argv[1]}/log/{nama_log}"], stdout=subprocess.PIPE, text=True) |
|
grep_process = subprocess.Popen(["grep", "reply twit sent"], stdin=ls_process.stdout, stdout=subprocess.PIPE, text=True) |
|
wc_process = subprocess.Popen(["wc", "-l"], stdin=grep_process.stdout, stdout=subprocess.PIPE, text=True) |
|
output, error = wc_process.communicate() |
|
return f"Twit replied: {output}" |
|
|
|
def twit_failed2(): |
|
with open(f"/home/ditolak/twitmonitor/twit_failed.txt", 'w') as f: |
|
ls_process = subprocess.Popen(["cat",f"/home/ditolak/buzz/{sys.argv[1]}/log/{nama_log}"], stdout=subprocess.PIPE, text=True) |
|
grep_process = subprocess.Popen(["grep", "twit failed"], stdin=ls_process.stdout, stdout=subprocess.PIPE, text=True) |
|
output, error = grep_process.communicate() |
|
#print(output) |
|
f.write(output) |
|
f = open("/home/ditolak/twitmonitor/twit_failed.txt", "r") |
|
result = { |
|
"error_401":0, |
|
"error_403":0, |
|
"error_400":0, |
|
"error_429":0, |
|
"error_503":0, |
|
} |
|
for x in f: |
|
error=x.split() |
|
raw_error=error[14] |
|
clean_error = raw_error[1:4] |
|
if(int(clean_error) == 401): |
|
result["error_401"]+=1 |
|
elif(int(clean_error) == 403): |
|
result["error_403"]+=1 |
|
elif(int(clean_error) == 400): |
|
result["error_400"]+=1 |
|
elif(int(clean_error) == 429): |
|
result["error_429"]+=1 |
|
else: |
|
result["error_503"]+=1 |
|
return result |
|
|
|
with open(f"/home/ditolak/twitmonitor/twit_monitor.txt", 'w') as f: |
|
f.write(quote_tweet()) |
|
f.write(reply_tweet()) |
|
error = twit_failed2() |
|
f.write(f"Error 401: {error['error_401']}\n") |
|
f.write(f"Error 403: {error['error_403']}\n") |
|
f.write(f"Error 400: {error['error_400']}\n") |
|
f.write(f"Error 429: {error['error_429']}\n") |
|
f.write(f"Error 503: {error['error_503']}\n") |