plugeth/cmd/mist/ext_app.go

149 lines
3.3 KiB
Go
Raw Normal View History

2015-01-06 11:13:57 +00:00
/*
This file is part of go-ethereum
go-ethereum is free software: you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
the Free Software Foundation, either version 3 of the License, or
(at your option) any later version.
go-ethereum is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
GNU General Public License for more details.
You should have received a copy of the GNU General Public License
along with go-ethereum. If not, see <http://www.gnu.org/licenses/>.
*/
/**
* @authors
* Jeffrey Wilcke <i@jev.io>
*/
2014-07-01 22:13:50 +00:00
package main
import (
2014-12-04 09:28:02 +00:00
"github.com/ethereum/go-ethereum/core"
"github.com/ethereum/go-ethereum/core/types"
"github.com/ethereum/go-ethereum/event"
2014-10-31 13:43:14 +00:00
"github.com/ethereum/go-ethereum/state"
"github.com/ethereum/go-ethereum/ui/qt"
2014-10-31 13:30:08 +00:00
"github.com/ethereum/go-ethereum/xeth"
2014-08-15 11:27:43 +00:00
"gopkg.in/qml.v1"
)
type AppContainer interface {
Create() error
Destroy()
Window() *qml.Window
Engine() *qml.Engine
NewBlock(*types.Block)
NewWatcher(chan bool)
2014-10-31 13:43:14 +00:00
Messages(state.Messages, string)
2014-08-17 10:41:23 +00:00
Post(string, int)
}
type ExtApplication struct {
2014-10-31 13:30:08 +00:00
*xeth.JSXEth
2014-12-04 09:28:02 +00:00
eth core.EthManager
2014-10-14 17:38:38 +00:00
events event.Subscription
watcherQuitChan chan bool
2014-12-04 09:28:02 +00:00
filters map[string]*core.Filter
2014-08-15 11:16:07 +00:00
container AppContainer
lib *UiLib
}
func NewExtApplication(container AppContainer, lib *UiLib) *ExtApplication {
2014-10-14 17:38:38 +00:00
return &ExtApplication{
2014-10-31 13:30:08 +00:00
JSXEth: xeth.NewJSXEth(lib.eth),
2014-10-14 17:38:38 +00:00
eth: lib.eth,
watcherQuitChan: make(chan bool),
2014-12-04 09:28:02 +00:00
filters: make(map[string]*core.Filter),
2014-10-14 17:38:38 +00:00
container: container,
lib: lib,
}
}
func (app *ExtApplication) run() {
// Set the "eth" api on to the containers context
context := app.container.Engine().Context()
context.SetVar("eth", app)
context.SetVar("ui", app.lib)
err := app.container.Create()
if err != nil {
2014-10-31 11:56:05 +00:00
guilogger.Errorln(err)
return
}
2014-10-14 17:38:38 +00:00
// Subscribe to events
mux := app.lib.eth.EventMux()
2014-12-04 09:28:02 +00:00
app.events = mux.Subscribe(core.NewBlockEvent{}, state.Messages(nil))
2014-10-14 17:38:38 +00:00
// Call the main loop
go app.mainLoop()
app.container.NewWatcher(app.watcherQuitChan)
win := app.container.Window()
win.Show()
win.Wait()
app.stop()
}
func (app *ExtApplication) stop() {
2014-10-14 17:38:38 +00:00
app.events.Unsubscribe()
// Kill the main loop
app.watcherQuitChan <- true
app.container.Destroy()
}
func (app *ExtApplication) mainLoop() {
2014-10-14 17:38:38 +00:00
for ev := range app.events.Chan() {
switch ev := ev.(type) {
2014-12-04 09:28:02 +00:00
case core.NewBlockEvent:
2014-10-14 17:38:38 +00:00
app.container.NewBlock(ev.Block)
2015-01-28 13:02:36 +00:00
/* TODO remove
case state.Messages:
for id, filter := range app.filters {
msgs := filter.FilterMessages(ev)
if len(msgs) > 0 {
app.container.Messages(msgs, id)
}
}
2015-01-28 13:02:36 +00:00
*/
}
}
}
func (self *ExtApplication) Watch(filterOptions map[string]interface{}, identifier string) {
self.filters[identifier] = qt.NewFilterFromMap(filterOptions, self.eth)
}
2014-08-14 15:01:37 +00:00
func (self *ExtApplication) GetMessages(object map[string]interface{}) string {
2015-01-28 13:02:36 +00:00
/* TODO remove me
filter := qt.NewFilterFromMap(object, self.eth)
2014-08-14 15:01:37 +00:00
messages := filter.Find()
var msgs []javascript.JSMessage
for _, m := range messages {
msgs = append(msgs, javascript.NewJSMessage(m))
}
b, err := json.Marshal(msgs)
if err != nil {
return "{\"error\":" + err.Error() + "}"
}
return string(b)
2015-01-28 13:02:36 +00:00
*/
return ""
2014-08-14 15:01:37 +00:00
}