plugeth/cmd/mist/ext_app.go

144 lines
3.4 KiB
Go
Raw Normal View History

2014-10-23 13:48:53 +00:00
// Copyright (c) 2013-2014, Jeffrey Wilcke. All rights reserved.
//
// This library 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 2.1 of the License, or (at your option) any later version.
//
// This library 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 this library; if not, write to the Free Software
// Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston,
// MA 02110-1301 USA
2014-07-01 22:13:50 +00:00
package main
import (
2014-08-14 15:01:37 +00:00
"encoding/json"
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-08-14 15:01:37 +00:00
"github.com/ethereum/go-ethereum/javascript"
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)
2014-10-31 13:43:14 +00:00
case state.Messages:
2014-10-14 17:38:38 +00:00
for id, filter := range app.filters {
msgs := filter.FilterMessages(ev)
if len(msgs) > 0 {
app.container.Messages(msgs, id)
}
}
}
}
}
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 {
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)
}