Krautspace/space_status
Archived
2
0
Fork 0
Code Issues Pull requests 2 Projects Releases Packages Wiki Activity

adds the raspi code and rc.local

Browse source 
adds the raspi code and rc.local.

also moving the licence and readme back that was moved by accident
This commit is contained in:
bernd2k 2019-11-30 19:39:16 +01:00
parent 3054997fe1
commit 7963ee5b24
4 changed files with 122 additions and 115 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

0
raspberry_pi/LICENSE → LICENSE
View file

0
raspberry_pi/README.md → README.md
View file

23
raspberry_pi/etc/rc.local Normal file
View file

@ -0,0 +1,23 @@
#!/bin/sh -e
#
# rc.local
#
# This script is executed at the end of each multiuser runlevel.
# Make sure that the script will "exit 0" on success or any other
# value on error.
#
# In order to enable or disable this script just change the execution
# bits.
#
# By default this script does nothing.
# Print the IP address
_IP=$(hostname -I) || true
if [ "$_IP" ]; then
printf "My IP address is %s\n" "$_IP"
fi
sleep 20
sudo python3 /home/pi/Schreibtisch/button.py &
exit 0

214
raspberry_pi/main.py
View file

@ -1,4 +1,10 @@
# status bot import RPi.GPIO as GPIO
import time
GPIO.setwarnings(False)
GPIO.setmode(GPIO.BOARD)
GPIO.setup(12, GPIO.IN, pull_up_down=GPIO.PUD_DOWN)
import json import json
import os import os
@ -7,17 +13,6 @@ import urllib.request, json
import datetime import datetime
import tweepy import tweepy
import random import random
path = os.path.abspath(__file__)
dir_path = os.path.dirname(path)
print("dir path is", dir_path)
def internet_on(url):
try:
urllib.request.urlopen(url)
return True
except urllib.error.URLError as e:
print(e.reason)
return False
def textselect(min, max): def textselect(min, max):
@ -28,113 +23,102 @@ def textselect(min, max):
else: else:
return random.randint(min, max) return random.randint(min, max)
def log(out):
f = open(dir_path + os.sep + "log.csv", "a") path = os.path.abspath(__file__)
f.write(out) dir_path = os.path.dirname(path)
f.close() print("dir path is", dir_path)
# starting by configuring the bot
file_configure_path = dir_path + os.sep + "config.json"
with open(file_configure_path, 'r') as f:
data_config = json.load(f)
path = data_config["path"]
CONSUMER_KEY = data_config["twitter_api"]["consumer_key"]
CONSUMER_SECRET = data_config["twitter_api"]["consumer_secret"]
ACCESS_KEY = data_config["twitter_api"]["token"]
ACCESS_SECRET = data_config["twitter_api"]["token_secret"]
print(CONSUMER_KEY)
auth = tweepy.OAuthHandler(CONSUMER_KEY, CONSUMER_SECRET)
auth.set_access_token(ACCESS_KEY, ACCESS_SECRET)
api = tweepy.API(auth)
state = 1
state_b4 = 1
while True: while True:
if GPIO.input(12) == GPIO.HIGH:
# starting by configuring the bot #print("button was pushed:")
file_configure_path = dir_path + os.sep + "config.json"
with open(file_configure_path, 'r') as f: state = 1
data_config = json.load(f)
path = data_config["path"] if GPIO.input(12) == GPIO.LOW:
#print("button was not pushed:")
CONSUMER_KEY = data_config["twitter_api"]["consumer_key"] state = 0
CONSUMER_SECRET = data_config["twitter_api"]["consumer_secret"]
ACCESS_KEY = data_config["twitter_api"]["token"]
ACCESS_SECRET = data_config["twitter_api"]["token_secret"] time_now = time.time()
print(CONSUMER_KEY)
file_status_path = dir_path + os.sep + "status.json"
auth = tweepy.OAuthHandler(CONSUMER_KEY, CONSUMER_SECRET) #print(file_status_path)
auth.set_access_token(ACCESS_KEY, ACCESS_SECRET)
api = tweepy.API(auth)
if state == 1 and state_b4 == 0:
if internet_on("http://twitter.com") == True: if os.path.exists(file_status_path) == True:
with open(file_status_path, 'r') as f:
# finding out the status of the space...
api_url = data_config["status_api"]["url"]
with urllib.request.urlopen(api_url) as url:
data_space = json.loads(url.read().decode())
#print(data_space["state"]["open"])
file_path = path + "space.json"
if os.path.exists(file_path) == True:
# Reading data back
with open(file_path, 'r') as f:
data_space_b4 = json.load(f)
#print(data_space_b4["state"]["open"])
if data_space["state"]["open"] != data_space_b4["state"]["open"]:
print("status changed.")
# starting by configuring the bot
file_status_path = path + "status.json"
with open(file_status_path, 'r') as f:
data_status = json.load(f) data_status = json.load(f)
number = len(data_status["opening_text"])
number = textselect(0, number - 1)
time_now = time.time() text = data_status["opening_text"][number]["text"] + " [OPEN:" + datetime.datetime.fromtimestamp(
int( time_now )).strftime('%Y-%m-%d %H:%M:%S') + "]"
# finding out wich state it change and sending out the text
if data_space["state"]["open"] == False:
print("closing at", time.time(), ",last change happend at", datetime.datetime.fromtimestamp(
int(data_space["state"]["lastchange"]) ).strftime('%Y-%m-%d %H:%M:%S'))
number = len(data_status["closing_text"])
number = textselect(0, number - 1)
text = data_status["closing_text"][number]["text"] + " [closed:" + datetime.datetime.fromtimestamp(
int( time_now + 3600 )).strftime('%Y-%m-%d %H:%M:%S') + "]"
print("Text:", text) print("Text:", text)
try:
api.update_status(text) #print("opened")
# same text as before cannot be posted! #text = "#Krautspace was opened. testmode (if you think I am wrong, report to me this bug/observation!) " + datetime.datetime.fromtimestamp(
except: # int( time_now )).strftime('%Y-%m-%d %H:%M:%S') + ""
print(time_now, "did not tweet closing status")
log(str(time_now) + ";" + str(data_space["state"]["lastchange"]) + ";" + str(data_space["state"]["open"])
+ ";" + str(number) + "\n")
else:
print("opening at", time.time(), ",last change happend at", datetime.datetime.fromtimestamp(
int(data_space["state"]["lastchange"]) ).strftime('%Y-%m-%d %H:%M:%S'))
number = len(data_status["opening_text"])
number = textselect(0, number - 1)
text = data_status["opening_text"][number]["text"] + " [open:" + datetime.datetime.fromtimestamp(
int( time_now + 3600 )).strftime('%Y-%m-%d %H:%M:%S') + "]"
print("Text:", text) #print("Text:", text)
try: try:
api.update_status(text) api.update_status(text)
except: # same text as before cannot be posted!
print(time_now, "did not tweet opening status") except:
print(time_now, "did not tweet closing status")
if state == 0 and state_b4 == 1:
#print("closed")
if os.path.exists(file_status_path) == True:
with open(file_status_path, 'r') as f:
data_status = json.load(f)
number = len(data_status["closing_text"])
number = textselect(0, number - 1)
log(str(time_now) + ";" + str(data_space["state"]["lastchange"]) + ";" + str(data_space["state"]["open"]) text = data_status["closing_text"][number]["text"] + " [CLOSED:" + datetime.datetime.fromtimestamp(
+ ";" + str(number) + "\n") int( time_now )).strftime('%Y-%m-%d %H:%M:%S') + "]"
print("Text:", text)
else:
print("status is still the same at", time.time(), datetime.datetime.fromtimestamp(
int(data_space["state"]["lastchange"]) ).strftime('%Y-%m-%d %H:%M:%S')) #text = "#Krautspace was closed. testmode (if you think I am wrong, report to me this bug/observation!) " + datetime.datetime.fromtimestamp(
# int( time_now )).strftime('%Y-%m-%d %H:%M:%S') + ""
else:
print("We're back, baby! #Krautspace space status is active again. @HackspaceJena") #print("Text:", text)
try:
api.update_status(text)
# saving the current space status just too compare them in the next round # same text as before cannot be posted!
with open(file_path, 'w') as outfile: except:
json.dump(data_space, outfile, indent=4) print(time_now, "did not tweet closing status")
else: state_b4 = state
print(time.time(), "internet is off")
time.sleep(10)
# how often shall we check for status?
time.sleep(data_config["status_api"]["checking_period"])