# -*- coding: utf-8 -*-
from waveapi import model
from waveapi import document
from urquell.invocation import execute
from wave.session import SessionWrapper
from wave.display import FrameDisplay
from wave.display import ModuleDisplay
from wave.display import HelpDisplay
import traceback

class WaveHandler(object):
  content = None
  blip = None
  wavelet = None
  wave = None

  def on_robot_added(self,properties, context):
    """Invoked when the robot has been added."""
    doc = context.GetRootWavelet().CreateBlip().GetDocument()
    doc.SetText("\nLurquell calling - !help for help")
    doc = context.GetRootWavelet().CreateBlip().GetDocument()
    doc.SetText('Lurquell gadget ')
    doc.InsertElement(15,document.Gadget('http://urquell-fn.appspot.com/assets/wave-gadget.xml'))
	
  def on_blip_submitted(self,properties, context):
    blipid = properties['blipId']
    self.blip = context.GetBlipById(blipid)
    self.content = self.blip.GetDocument().GetText()
    self.wavelet = context.GetWaveletById(self.blip.GetWaveletId())
    self.wave = context.GetWaveById(self.blip.GetWaveId())
	
    last_line = self.content.strip().split('\n')[-1].strip()
    
    if last_line.find('http') > -1:
      self.handle_expr(last_line)
    elif last_line.find('*') > -1:
      self.handle_hash(last_line)	
    elif last_line.find('!') > -1:
      self.handle_cmnd(last_line)

  def handle_expr(self,expr):
    doc = self.blip.GetDocument()
    stack_frame = u''
    formatted_args = u''

    try:
      sess = SessionWrapper(self.blip.GetId() + self.wave.GetId())
      result = execute(expr)
      if result and result.has_key('hash'):
        result['url'] = expr
        result['fnum'] = sess.last_fnum() + 1
        sess.frames[result['hash']] = result
        sess.save()
        FrameDisplay(self.blip,sess).display()
        doc.AppendText('\nhttp://urquell-fn.appspot.com/lib %s' % result['hash'])
      elif result and result.has_key('value'):
        ModuleDisplay(self.blip,sess).display(result)
        doc.AppendText('\n%s' % expr)
      elif result and result.has_key('error'):
        data = result['headers']['Host'],result['path'],result['error']['message']
        self.wavelet.CreateBlip().GetDocument().SetText('\n\nExecution error:\nHost: %s\nPath: %s\nError: %s' % data)
    except Exception, e:
      self.wavelet.CreateBlip().GetDocument().SetText('\n\nException thrown:\n%s' % traceback.format_exc())

  def handle_hash(self,ihash):
    doc = self.blip.GetDocument()
    url = u''

    try:
      sess = SessionWrapper(self.blip.GetId() + self.wave.GetId())
      result = execute('http://urquell-fn.appspot.com/lib/unresolve/' + ihash[1:])
      FrameDisplay(self.blip,sess).display()
      if result and result.has_key('hash'):
        doc.AppendText('\n%s resolves to: %s' % (ihash,result.get('value','None')))
    except Exception, e:
      self.wavelet.CreateBlip().GetDocument().SetText('\n\nException thrown:\n%s' % traceback.format_exc())
	
  def handle_cmnd(self,cmnd):
    sess = SessionWrapper(self.blip.GetId() + self.wave.GetId())
    if cmnd == '!reset':
      sess.frames = {}
    # if cmnd == '!content errors':
    #   sess.settings['content'] = '__errors__'
    # if cmnd == '!content all':
    #   sess.settings['content'] = '__all__'
    # if cmnd.startswith('!filter'):
    #   sess.settings['content'] = cmnd.split(' ')[1]
    if cmnd == '!help':
      HelpDisplay(self.blip,sess).display()
      return
    sess.save()
    FrameDisplay(self.blip,sess).display()