aboutsummaryrefslogtreecommitdiffstats
path: root/ethutil
diff options
context:
space:
mode:
authorobscuren <geffobscura@gmail.com>2014-06-27 01:55:14 +0800
committerobscuren <geffobscura@gmail.com>2014-06-27 01:55:14 +0800
commit9d5a3f013121c319f9cf679d9afc4e40661a0284 (patch)
treef57ecbea40ca0354bb050d70a10851669412a581 /ethutil
parent3f1f8438ed8bf7b63ea5172090a5c7025cb093f0 (diff)
parenta98e6a262a21ff08c28495bab5180a1c15826d40 (diff)
downloadgo-tangerine-9d5a3f013121c319f9cf679d9afc4e40661a0284.tar
go-tangerine-9d5a3f013121c319f9cf679d9afc4e40661a0284.tar.gz
go-tangerine-9d5a3f013121c319f9cf679d9afc4e40661a0284.tar.bz2
go-tangerine-9d5a3f013121c319f9cf679d9afc4e40661a0284.tar.lz
go-tangerine-9d5a3f013121c319f9cf679d9afc4e40661a0284.tar.xz
go-tangerine-9d5a3f013121c319f9cf679d9afc4e40661a0284.tar.zst
go-tangerine-9d5a3f013121c319f9cf679d9afc4e40661a0284.zip
Merge branch 'release/0.5.15'
Diffstat (limited to 'ethutil')
-rw-r--r--ethutil/config.go198
-rw-r--r--ethutil/encoding_test.go2
-rw-r--r--ethutil/script.go50
-rw-r--r--ethutil/trie.go2
4 files changed, 44 insertions, 208 deletions
diff --git a/ethutil/config.go b/ethutil/config.go
index a573e108b..aa4ae9c3e 100644
--- a/ethutil/config.go
+++ b/ethutil/config.go
@@ -4,10 +4,7 @@ import (
"flag"
"fmt"
"github.com/rakyll/globalconf"
- "log"
"os"
- "os/user"
- "path"
"runtime"
)
@@ -15,7 +12,6 @@ import (
type config struct {
Db Database
- Log *Logger
ExecPath string
Debug bool
Ver string
@@ -26,62 +22,31 @@ type config struct {
conf *globalconf.GlobalConf
}
-const defaultConf = `
-id = ""
-port = 30303
-upnp = true
-maxpeer = 10
-rpc = false
-rpcport = 8080
-`
-
var Config *config
-func ApplicationFolder(base string) string {
- usr, _ := user.Current()
- p := path.Join(usr.HomeDir, base)
-
- if len(base) > 0 {
- //Check if the logging directory already exists, create it if not
- _, err := os.Stat(p)
- if err != nil {
- if os.IsNotExist(err) {
- log.Printf("Debug logging directory %s doesn't exist, creating it\n", p)
- os.Mkdir(p, 0777)
-
- }
- }
-
- iniFilePath := path.Join(p, "conf.ini")
- _, err = os.Stat(iniFilePath)
- if err != nil && os.IsNotExist(err) {
- file, err := os.Create(iniFilePath)
- if err != nil {
- fmt.Println(err)
- } else {
- assetPath := path.Join(os.Getenv("GOPATH"), "src", "github.com", "ethereum", "go-ethereum", "ethereal", "assets")
- file.Write([]byte(defaultConf + "\nasset_path = " + assetPath))
- }
- }
- }
-
- return p
-}
-
// Read config
//
-// Initialize the global Config variable with default settings
-func ReadConfig(base string, logTypes LoggerType, g *globalconf.GlobalConf, id string) *config {
+// Initialize Config from Config File
+func ReadConfig(ConfigFile string, Datadir string, Identifier string, EnvPrefix string) *config {
if Config == nil {
- path := ApplicationFolder(base)
-
- Config = &config{ExecPath: path, Debug: true, Ver: "0.5.14"}
- Config.conf = g
- Config.Identifier = id
- Config.Log = NewLogger(logTypes, LogLevelDebug)
+ // create ConfigFile if does not exist, otherwise globalconf panic when trying to persist flags
+ _, err := os.Stat(ConfigFile)
+ if err != nil && os.IsNotExist(err) {
+ fmt.Printf("config file '%s' doesn't exist, creating it\n", ConfigFile)
+ os.Create(ConfigFile)
+ }
+ g, err := globalconf.NewWithOptions(&globalconf.Options{
+ Filename: ConfigFile,
+ EnvPrefix: EnvPrefix,
+ })
+ if err != nil {
+ fmt.Println(err)
+ } else {
+ g.ParseAll()
+ }
+ Config = &config{ExecPath: Datadir, Debug: true, Ver: "0.5.14", conf: g, Identifier: Identifier}
Config.SetClientString("Ethereum(G)")
}
-
return Config
}
@@ -98,137 +63,12 @@ func (c *config) SetIdentifier(id string) {
c.Set("id", id)
}
+// provides persistence for flags
func (c *config) Set(key, value string) {
f := &flag.Flag{Name: key, Value: &confValue{value}}
c.conf.Set("", f)
}
-type LoggerType byte
-
-const (
- LogFile = 0x1
- LogStd = 0x2
-)
-
-type LogSystem interface {
- Println(v ...interface{})
- Printf(format string, v ...interface{})
-}
-
-type Logger struct {
- logSys []LogSystem
- logLevel int
-}
-
-func NewLogger(flag LoggerType, level int) *Logger {
- var loggers []LogSystem
-
- flags := log.LstdFlags
-
- if flag&LogFile > 0 {
- file, err := os.OpenFile(path.Join(Config.ExecPath, "debug.log"), os.O_RDWR|os.O_CREATE|os.O_APPEND, os.ModePerm)
- if err != nil {
- log.Panic("unable to create file logger", err)
- }
-
- log := log.New(file, "", flags)
-
- loggers = append(loggers, log)
- }
- if flag&LogStd > 0 {
- log := log.New(os.Stdout, "", flags)
- loggers = append(loggers, log)
- }
-
- return &Logger{logSys: loggers, logLevel: level}
-}
-
-func (self *Logger) SetLevel(level int) {
- self.logLevel = level
-}
-
-func (log *Logger) AddLogSystem(logger LogSystem) {
- log.logSys = append(log.logSys, logger)
-}
-
-const (
- LogLevelSystem = iota
- LogLevelDebug
- LogLevelInfo
-)
-
-func (log *Logger) Debugln(v ...interface{}) {
- if log.logLevel != LogLevelDebug {
- return
- }
-
- for _, logger := range log.logSys {
- logger.Println(v...)
- }
-}
-
-func (log *Logger) Debugf(format string, v ...interface{}) {
- if log.logLevel != LogLevelDebug {
- return
- }
-
- for _, logger := range log.logSys {
- logger.Printf(format, v...)
- }
-}
-
-func (log *Logger) Infoln(v ...interface{}) {
- if log.logLevel > LogLevelInfo {
- return
- }
-
- for _, logger := range log.logSys {
- logger.Println(v...)
- }
-}
-
-func (log *Logger) Infof(format string, v ...interface{}) {
- if log.logLevel > LogLevelInfo {
- return
- }
-
- for _, logger := range log.logSys {
- logger.Printf(format, v...)
- }
-}
-
-func (log *Logger) Fatal(v ...interface{}) {
- if log.logLevel > LogLevelInfo {
- return
- }
-
- for _, logger := range log.logSys {
- logger.Println(v...)
- }
-
- os.Exit(1)
-}
-
-func (log *Logger) Println(level int, v ...interface{}) {
- if log.logLevel > level {
- return
- }
-
- for _, logger := range log.logSys {
- logger.Println(v...)
- }
-}
-
-func (log *Logger) Printf(level int, format string, v ...interface{}) {
- if log.logLevel > level {
- return
- }
-
- for _, logger := range log.logSys {
- logger.Printf(format, v...)
- }
-}
-
type confValue struct {
value string
}
diff --git a/ethutil/encoding_test.go b/ethutil/encoding_test.go
index cbfbc0eaf..10e1995c0 100644
--- a/ethutil/encoding_test.go
+++ b/ethutil/encoding_test.go
@@ -64,4 +64,4 @@ func TestCompactDecode(t *testing.T) {
if !CompareIntSlice(res, exp) {
t.Error("even terminated compact decode. Expected", exp, "got", res)
}
-} \ No newline at end of file
+}
diff --git a/ethutil/script.go b/ethutil/script.go
index 94e401406..af4ca6a38 100644
--- a/ethutil/script.go
+++ b/ethutil/script.go
@@ -3,39 +3,35 @@ package ethutil
import (
"fmt"
"github.com/obscuren/mutan"
+ "github.com/obscuren/mutan/backends"
+ "github.com/obscuren/serpent-go"
"strings"
)
// General compile function
-func Compile(script string) ([]byte, error) {
- byteCode, errors := mutan.Compile(strings.NewReader(script), false)
- if len(errors) > 0 {
- var errs string
- for _, er := range errors {
- if er != nil {
- errs += er.Error()
- }
- }
- return nil, fmt.Errorf("%v", errs)
- }
+func Compile(script string) (ret []byte, err error) {
+ c := strings.Split(script, "\n")[0]
- return byteCode, nil
-}
+ if c == "#!serpent" {
+ byteCode, err := serpent.Compile(script)
+ if err != nil {
+ return nil, err
+ }
-func CompileScript(script string) ([]byte, []byte, error) {
- // Preprocess
- mainInput, initInput := mutan.PreParse(script)
- // Compile main script
- mainScript, err := Compile(mainInput)
- if err != nil {
- return nil, nil, err
- }
+ return byteCode, nil
+ } else {
+ compiler := mutan.NewCompiler(backend.NewEthereumBackend())
+ byteCode, errors := compiler.Compile(strings.NewReader(script))
+ if len(errors) > 0 {
+ var errs string
+ for _, er := range errors {
+ if er != nil {
+ errs += er.Error()
+ }
+ }
+ return nil, fmt.Errorf("%v", errs)
+ }
- // Compile init script
- initScript, err := Compile(initInput)
- if err != nil {
- return nil, nil, err
+ return byteCode, nil
}
-
- return mainScript, initScript, nil
}
diff --git a/ethutil/trie.go b/ethutil/trie.go
index 18d0a5f0a..0c1a6d260 100644
--- a/ethutil/trie.go
+++ b/ethutil/trie.go
@@ -47,7 +47,7 @@ func (cache *Cache) Put(v interface{}) interface{} {
value := NewValue(v)
enc := value.Encode()
- if len(enc) >= 32 {
+ if len(enc) < 32 {
sha := Sha3Bin(enc)
cache.nodes[string(sha)] = NewNode(sha, value, true)