xrubythreadconnector.cpp

/***************************************************************************
        Copyright (C) 2002-2015 Kentaro Kitagawa
                           kitagawa@phys.s.u-tokyo.ac.jp
        
        This program is free software; you can redistribute it and/or
        modify it under the terms of the GNU Library General Public
        License as published by the Free Software Foundation; either
        version 2 of the License, or (at your option) any later version.
        
        You should have received a copy of the GNU Library General 
        Public License and a list of authors along with this program; 
        see the files COPYING and AUTHORS.
***************************************************************************/
#include "xrubysupport.h"
#include "xrubythreadconnector.h"
#include "xrubythread.h"
#include <QPushButton>
#include <QLabel>
#include <QTextBrowser>
#include <QLineEdit>
#include "ui_rubythreadtool.h"
#include "icons/icon.h"

XRubyThreadConnector::XRubyThreadConnector(
    const shared_ptr<XRubyThread> &rbthread, FrmRubyThread *form,
    const shared_ptr<XRuby> &rbsupport) :
    XQConnector(rbthread, form),
    m_resume(XNode::createOrphan<XTouchableNode>("Resume", true)),
    m_kill(XNode::createOrphan<XTouchableNode>("Kill", true)),
    m_pForm(form),
    m_rubyThread(rbthread),
    m_rubySupport(rbsupport),
    m_conFilename(xqcon_create<XQLabelConnector>(
        rbthread->filename(), form->m_plblFilename)),
    m_conStatus(xqcon_create<XQLabelConnector>(
        rbthread->status(), form->m_plblStatus)),
    m_conResume(xqcon_create<XQButtonConnector>(
        m_resume, (form->m_pbtnResume))),
    m_conKill(xqcon_create<XQButtonConnector>(
        m_kill, form->m_pbtnKill)),
    m_conLineinput(xqcon_create<XQLineEditConnector>(
        rbthread->lineinput(), form->m_edLineinput)) {

    form->m_pbtnResume->setIcon(
        QApplication::style()->standardIcon(QStyle::SP_MediaPlay));
    form->m_pbtnKill->setIcon(
        QApplication::style()->standardIcon(QStyle::SP_BrowserStop));
            
    m_pForm->m_ptxtDefout->setReadOnly(true);
    m_pForm->m_ptxtDefout->setOpenLinks(false);
    m_pForm->m_ptxtDefout->setOpenExternalLinks(false);

    m_resume->iterate_commit([=](Transaction &tr){
        m_lsnOnResumeTouched = tr[ *m_resume].onTouch().connectWeakly(
            shared_from_this(), &XRubyThreadConnector::onResumeTouched);
    });
    m_kill->iterate_commit([=](Transaction &tr){
        m_lsnOnKillTouched = tr[ *m_kill].onTouch().connectWeakly(
            shared_from_this(), &XRubyThreadConnector::onKillTouched);
    });
    Snapshot shot = rbthread->iterate_commit([=](Transaction &tr){
        m_lsnOnDefout = tr[ *rbthread].onMessageOut().connectWeakly(
            shared_from_this(), &XRubyThreadConnector::onDefout, XListener::FLAG_MAIN_THREAD_CALL);
        m_lsnOnStatusChanged = tr[ *rbthread->status()].onValueChanged().connectWeakly(
            shared_from_this(), &XRubyThreadConnector::onStatusChanged);
    });
    onStatusChanged(shot, rbthread->status().get());

    form->setWindowIcon( *g_pIconScript);
    form->setWindowTitle(rbthread->getLabel());
}
XRubyThreadConnector::~XRubyThreadConnector() {
    if(isItemAlive()) {
        m_pForm->m_ptxtDefout->clear();
    }
//    m_rubyThread->kill();
    m_rubySupport->release(m_rubyThread);
}
void
XRubyThreadConnector::onStatusChanged(const Snapshot &shot, XValueNodeBase *) {
    bool alive = m_rubyThread->isAlive();
    m_kill->setUIEnabled(alive);
    bool running = m_rubyThread->isRunning();
    m_resume->setUIEnabled(alive && !running);
}
void
XRubyThreadConnector::onResumeTouched(const Snapshot &shot, XTouchableNode *node) {
    m_rubyThread->resume();
}
void
XRubyThreadConnector::onKillTouched(const Snapshot &shot, XTouchableNode *node) {
    m_rubyThread->kill();
}
void
XRubyThreadConnector::onDefout(const Snapshot &shot, const shared_ptr<XString> &str) {
    m_pForm->m_ptxtDefout->append( *str);
}