Idea: use python to directly generate rules files

Tutorials & Examples
23

While relaxing tonight, I whipped up an example of using scripted automation with Jython and the helper libraries to scrape the webpage to update DateTimeItems and send notifications through Telegram (the OH 1.x action version). The easiest way to install Jython is to use the beta bundle. Hopefully this is useful for you!

"""
This script contains a rule that will scrape https://afvalkalender.waalre.nl
for collection times twice a day and update Items with the dates. The script
will create the Items needed, if they do not exist.
"""
import re

from core.rules import rule
from core.triggers import when
from core.items import add_item
from core.actions import HTTP, Telegram

URI = "https://afvalkalender.waalre.nl/adres/5581BG:17"

def monthToNum(shortMonth):
    return{
        'jan' : 1,
        'feb' : 2,
        'mrt' : 3,
        'apr' : 4,
        'mei' : 5,
        'jun' : 6,
        'jul' : 7,
        'aug' : 8,
        'sep' : 9,
        'okt' : 10,
        'nov' : 11,
        'dec' : 12
    }[shortMonth]

def convert_date(day_text):
    day_list = day_text.split(" ")
    new_date = DateTimeType().zonedDateTime.withMonth(monthToNum(day_list[2])).withDayOfMonth(int(day_list[1])).withHour(0).withMinute(0).withSecond(0).withNano(0)
    return new_date

if ir.getItems("Afval_gft") == []:
    add_item("Afval_gft", item_type="DateTime", label="Groente [%s]", category="Calendar", groups=[], tags=[])
if ir.getItems("Afval_pmd") == []:
    add_item("Afval_pmd", item_type="DateTime", label="Plastic [%s]", category="Calendar", groups=[], tags=[])
if ir.getItems("Afval_papier") == []:
    add_item("Afval_papier", item_type="DateTime", label="Papier [%s]", category="Calendar", groups=[], tags=[])
if ir.getItems("Afval_kga") == []:
    add_item("Afval_kga", item_type="DateTime", label="Chemisch [%s]", category="Calendar", groups=[], tags=[])
if ir.getItems("Afval_rest") == []:
    add_item("Afval_rest", item_type="DateTime", label="Restafval [%s]", category="Calendar", groups=[], tags=[])

@rule("Send trash pickup notifications")
@when("Time cron 0 30 7 * * ?")
@when("Time cron 0 30 19 * * ?")
def send_trash_pickup_notifications(event):
    # get the page
    the_page = HTTP.sendHttpGetRequest(URI, 5000)
    if the_page:
        contents = the_page.decode('utf-8')

        # Find the part of the page with id=ophaaldata
        START = '<ul id="ophaaldata" class="line">'
        END = '</ul>'
        section = re.search("{}(.*?){}".format(START, END), contents, re.DOTALL).group(1)

        # Split the section based on "\n" into lines.
        section_list = section.split("\n")

        for index, line in enumerate(section_list):
            dag_text = re.search('<i class="date">(.*?)</i>', line, re.DOTALL)
            if dag_text:
                dag_text = dag_text.group(1)
                pickup_date = convert_date(dag_text)
                pickup_type = None
                soort_afval = re.search('<i>(.*?)</i>', section_list[index + 1], re.DOTALL).group(1)

                if "Groente" in soort_afval:
                    pickup_type = "Groente"
                    item_name = "Afval_gft"
                elif "Plastic" in soort_afval:
                    pickup_type = "Plastic"
                    item_name = "Afval_pmd"
                elif "Papier" in soort_afval:
                    pickup_type = "Papier"
                    item_name = "Afval_papier"
                elif "Chemisch" in soort_afval:
                    pickup_type = "Chemisch"
                    item_name = "Afval_kga"
                elif "Restafval" in soort_afval:
                    pickup_type = "Restafval"
                    item_name = "Afval_rest"

                send_trash_pickup_notifications.log.debug("{}: {}".format(pickup_type, pickup_date))
                events.sendCommand(item_name, pickup_date.toString())
                if pickup_type and DateTimeType().zonedDateTime.toLocalDate() == pickup_date.toLocalDate():
                    Telegram.sendTelegram("domoticahajerstijn", "Afval notificatie: {}".format(pickup_type))
    else:
        send_trash_pickup_notifications.log.warn("Communication failure")
2 Likes