| 582 | } |
| 583 | |
| 584 | func (n *EsNode) initDatabase(cfg *Config) error { |
| 585 | var db ethdb.Database |
| 586 | if cfg.DataDir == "" { |
| 587 | db = rawdb.NewMemoryDatabase() |
| 588 | } else { |
| 589 | rdb, err := leveldb.New( |
| 590 | cfg.ResolvePath(cfg.DBConfig.Name), |
| 591 | cfg.DBConfig.DatabaseCache, |
| 592 | cfg.DBConfig.DatabaseHandles, |
| 593 | cfg.DBConfig.NameSpace, |
| 594 | false, |
| 595 | ) |
| 596 | if err != nil { |
| 597 | return err |
| 598 | } |
| 599 | db = rawdb.NewDatabase(rdb) |
| 600 | } |
| 601 | n.db = db |
| 602 | return nil |
| 603 | } |
| 604 | |
| 605 | func sendMessage(url string, data string) (string, error) { |
| 606 | contentType := "application/json" |