notifier.py

#!/usr/bin/env python
# -*- coding: utf-8 -*-
from restarter import miners

"""Simple Bot to send timed Telegram messages.

# This program is dedicated to the public domain under the CC0 license.

This Bot uses the Updater class to handle the bot and the JobQueue to send
timed messages.

First, a few handler functions are defined. Then, those functions are passed to
the Dispatcher and registered at their respective places.
Then, the bot is started and runs until we press Ctrl-C on the command line.

Usage:
Basic Alarm Bot example, sends a message after a set time.
Press Ctrl-C on the command line or send a signal to the process to stop the
bot.
"""

from telegram.ext import Updater, CommandHandler, MessageHandler, Filters
import logging

# Enable logging
logging.basicConfig(format='%(asctime)s - %(name)s - %(levelname)s - %(message)s',
                    level=logging.INFO)

logger = logging.getLogger(__name__)

# Define a few command handlers. These usually take the two arguments bot and
# update. Error handlers also receive the raised TelegramError object in error.
def start(bot, update):
    update.message.reply_text('Hi! Use /list to check status of all machines')

def list(bot, update):
    update.message.reply_text('List of current machines on watch:')
    for miner in miners:
        update.message.reply_text(miner.name + " IP: " + miner.ip + " " + miner.getStatus())
    update.message.reply_text('Thats`s all - looking forward to hear from you soon!') 

#def alarm(bot, job):
#    """Send the alarm message."""
#    bot.send_message(job.context, text='Beep!')


#def set_timer(bot, update, args, job_queue, chat_data):
#    """Add a job to the queue."""
#    chat_id = update.message.chat_id
#    try:
#        # args[0] should contain the time for the timer in seconds
#        due = int(args[0])
#        if due < 0:
#            update.message.reply_text('Sorry we can not go back to future!')
#            return
#
#        # Add job to queue
#        job = job_queue.run_once(alarm, due, context=chat_id)
#        chat_data['job'] = job

#        update.message.reply_text('Timer successfully set!')

#   except (IndexError, ValueError):
#        update.message.reply_text('Usage: /set <seconds>')


#def unset(bot, update, chat_data):
#    """Remove the job if the user changed their mind."""
#    if 'job' not in chat_data:
#        update.message.reply_text('You have no active timer')
#        return

#    job = chat_data['job']
#    job.schedule_removal()
#    del chat_data['job']
#
#    update.message.reply_text('Timer successfully unset!')


def error(bot, update, error):
    """Log Errors caused by Updates."""
    logger.warning('Update "%s" caused error "%s"', update, error)