diff options
author | obscuren <geffobscura@gmail.com> | 2014-07-02 06:13:50 +0800 |
---|---|---|
committer | obscuren <geffobscura@gmail.com> | 2014-07-02 06:13:50 +0800 |
commit | c4f9151c67b1481490978a9dca0599b3e92680d5 (patch) | |
tree | f02199cf5a2f87595937c5f8c94bda343347fa9f /ethereal/ext_app.go | |
parent | 283532137713d20ca82d264bd105cf7cb0e47b65 (diff) | |
download | dexon-c4f9151c67b1481490978a9dca0599b3e92680d5.tar dexon-c4f9151c67b1481490978a9dca0599b3e92680d5.tar.gz dexon-c4f9151c67b1481490978a9dca0599b3e92680d5.tar.bz2 dexon-c4f9151c67b1481490978a9dca0599b3e92680d5.tar.lz dexon-c4f9151c67b1481490978a9dca0599b3e92680d5.tar.xz dexon-c4f9151c67b1481490978a9dca0599b3e92680d5.tar.zst dexon-c4f9151c67b1481490978a9dca0599b3e92680d5.zip |
Moved files
Diffstat (limited to 'ethereal/ext_app.go')
-rw-r--r-- | ethereal/ext_app.go | 132 |
1 files changed, 132 insertions, 0 deletions
diff --git a/ethereal/ext_app.go b/ethereal/ext_app.go new file mode 100644 index 000000000..17c342a1b --- /dev/null +++ b/ethereal/ext_app.go @@ -0,0 +1,132 @@ +package main + +import ( + "fmt" + "github.com/ethereum/eth-go/ethchain" + "github.com/ethereum/eth-go/ethpub" + "github.com/ethereum/eth-go/ethutil" + "github.com/go-qml/qml" +) + +type AppContainer interface { + Create() error + Destroy() + + Window() *qml.Window + Engine() *qml.Engine + + NewBlock(*ethchain.Block) + ObjectChanged(*ethchain.StateObject) + StorageChanged(*ethchain.StorageState) + NewWatcher(chan bool) +} + +type ExtApplication struct { + *ethpub.PEthereum + + blockChan chan ethutil.React + changeChan chan ethutil.React + quitChan chan bool + watcherQuitChan chan bool + + container AppContainer + lib *UiLib + registeredEvents []string +} + +func NewExtApplication(container AppContainer, lib *UiLib) *ExtApplication { + app := &ExtApplication{ + ethpub.NewPEthereum(lib.eth), + make(chan ethutil.React, 1), + make(chan ethutil.React, 1), + make(chan bool), + make(chan bool), + container, + lib, + nil, + } + + return app +} + +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 { + fmt.Println(err) + + return + } + + // Call the main loop + go app.mainLoop() + + // Subscribe to events + reactor := app.lib.eth.Reactor() + reactor.Subscribe("newBlock", app.blockChan) + + app.container.NewWatcher(app.watcherQuitChan) + + win := app.container.Window() + win.Show() + win.Wait() + + app.stop() +} + +func (app *ExtApplication) stop() { + // Clean up + reactor := app.lib.eth.Reactor() + reactor.Unsubscribe("newBlock", app.blockChan) + for _, event := range app.registeredEvents { + reactor.Unsubscribe(event, app.changeChan) + } + + // Kill the main loop + app.quitChan <- true + app.watcherQuitChan <- true + + close(app.blockChan) + close(app.quitChan) + close(app.changeChan) + + app.container.Destroy() +} + +func (app *ExtApplication) mainLoop() { +out: + for { + select { + case <-app.quitChan: + break out + case block := <-app.blockChan: + if block, ok := block.Resource.(*ethchain.Block); ok { + app.container.NewBlock(block) + } + case object := <-app.changeChan: + if stateObject, ok := object.Resource.(*ethchain.StateObject); ok { + app.container.ObjectChanged(stateObject) + } else if storageObject, ok := object.Resource.(*ethchain.StorageState); ok { + app.container.StorageChanged(storageObject) + } + } + } + +} + +func (app *ExtApplication) Watch(addr, storageAddr string) { + var event string + if len(storageAddr) == 0 { + event = "object:" + string(ethutil.Hex2Bytes(addr)) + app.lib.eth.Reactor().Subscribe(event, app.changeChan) + } else { + event = "storage:" + string(ethutil.Hex2Bytes(addr)) + ":" + string(ethutil.Hex2Bytes(storageAddr)) + app.lib.eth.Reactor().Subscribe(event, app.changeChan) + } + + app.registeredEvents = append(app.registeredEvents, event) +} |