medulla.py

import os
import sys

import cortex
import thalamus
import cellphone

from config import load_config
from time import sleep, mktime, localtime
from hyperthymesia import Hyperthymesia
from cybernetics import metacortex


# Welcome to the beginning of a very strained brain metaphor!
# This is the shell for running the cortex. Ideally, this will never
# fail and you never have to reboot. Hah! I make funny, yes? More
# important, if you make changes to this file, you have to reboot as
# a reload won't change it. Same goes for changes to thalamus.py
class Medulla:

    # Used by thalamus
    sock = False
    radio = False

    def __init__(self):

        print '* Becoming self-aware'
        self.settings = load_config('/usr/home/peter/bots/mongo/config/settings.yaml')
        self.secrets = load_config('/usr/home/peter/bots/mongo/config/secrets.yaml')
        self.active = True
        self.logger = Hyperthymesia()

        try:
            self.brain = cortex.Cortex(self)
        except Exception as e:
            self.logger.warn('Drain bamaged... Stroking... out...')
            sys.exit()

        self.thalamus = thalamus.Thalamus(self, self.brain)
        self.thalamus.connect()
        self.brain.thalamus = self.thalamus
        self.cellphone = cellphone.Cellphone(self, self.brain)
        self.cellphone.connect()
        self.brain.cellphone = self.cellphone
        self.brain.logger = self.logger

        metacortex.cx = self.brain

        # The pulse file is set as a measure of how
        # long the bot has been spinning its gears
        # in a process. If it can't set the pulse
        # for too long, a signal kills it and reboots.
        # Note: this has become less of an issue
        # since all the bot's commands became threaded
        print '* Establishing pulse'
        self.setpulse()

        print '* Running monitor'

        while True:
            sleep(0.1)

            # Slight race condition on reloads
            if not self.brain.thalamus: continue

            self.brain.monitor()
            if mktime(localtime()) - self.lastpulse > 10:
                self.setpulse()


    # Reload has to be run from here to update the
    # cortex.
    def reload(self, quiet=False):
        if self.brain.values and len(self.brain.values[0]):
            quiet = True

        if not quiet:
            self.brain.act('strokes out.')
        else:
            self.brain.act('strokes out.', False, self.secrets.owner)

        # TODO broken.
        #for channel in self.secrets.channels:
        #    name, attr = channel.popitem()
        #    if attr.primary:
        #        continue
        #    self.brain.brainmeats['channeling'].leave(name)

        self.active = False

        self.settings = settings = load_config('config/settings.yaml')
        self.secrets = secrets = load_config('config/secrets.yaml')

        import datastore
        import util
        import staff
        import autonomic
        import cortex
        import thalamus
        import id

        reload(datastore)
        reload(autonomic)
        reload(util)
        reload(staff)
        reload(cortex)
        reload(thalamus)
        reload(id)

        self.brain = cortex.Cortex(self, True)
        self.thalamus = thalamus.Thalamus(self, self.brain)

        self.brain.thalamus = self.thalamus
        self.active = True

        metacortex.cx = self.brain

        if not quiet:
            self.brain.act('comes to.')
        else:
            self.brain.act('comes to.', False, self.secrets.owner)


    def setpulse(self):
        self.lastpulse = mktime(localtime())
        pulse = open(self.settings.sys.pulse, 'w')
        pulse.write(str(self.lastpulse))
        pulse.close()


    def die(self, msg=None):
        if msg is not None:
            print msg
        os._exit(1)

connect = Medulla()