init push for list address (#445)

diff --git a/blockchain/account/accounts.go b/blockchain/account/accounts.go
index 1bf13ba..eb3e052 100755 (executable)
--- a/blockchain/account/accounts.go
+++ b/blockchain/account/accounts.go
@@ -443,3 +443,20 @@ func (m *Manager) ListAccounts(id string) ([]*Account, error) {
 
        return accounts, nil
 }
+
+// ListControlProgram return all the local control program
+func (m *Manager) ListControlProgram() ([]*CtrlProgram, error) {
+       cps := []*CtrlProgram{}
+       cpIter := m.db.IteratorPrefix([]byte(accountCPPrefix))
+       defer cpIter.Release()
+
+       for cpIter.Next() {
+               cp := &CtrlProgram{}
+               if err := json.Unmarshal(cpIter.Value(), cp); err != nil {
+                       return nil, err
+               }
+               cps = append(cps, cp)
+       }
+
+       return cps, nil
+}

diff --git a/blockchain/accounts.go b/blockchain/accounts.go
index f6d4aba..251f367 100644 (file)
--- a/blockchain/accounts.go
+++ b/blockchain/accounts.go
@@ -95,3 +95,24 @@ func (bcr *BlockchainReactor) validateAddress(ctx context.Context, ins struct {
        resp.IsLocal = bcr.accounts.IsLocalControlProgram(program)
        return NewSuccessResponse(resp)
 }
+
+type addressResp struct {
+       AccountID string `json:"account_id"`
+       Address   string `json:"address"`
+}
+
+func (bcr *BlockchainReactor) listAddresses(ctx context.Context) Response {
+       cps, err := bcr.accounts.ListControlProgram()
+       if err != nil {
+               return NewErrorResponse(err)
+       }
+
+       addresses := []*addressResp{}
+       for _, cp := range cps {
+               if cp.Address == "" {
+                       continue
+               }
+               addresses = append(addresses, &addressResp{AccountID: cp.AccountID, Address: cp.Address})
+       }
+       return NewSuccessResponse(addresses)
+}

diff --git a/blockchain/rpc_reactor.go b/blockchain/rpc_reactor.go
index 5a3917d..8ca8754 100644 (file)
--- a/blockchain/rpc_reactor.go
+++ b/blockchain/rpc_reactor.go
@@ -58,6 +58,7 @@ func (bcr *BlockchainReactor) BuildHandler() {
                m.Handle("/update-account-tags", jsonHandler(bcr.updateAccountTags))
                m.Handle("/create-account-receiver", jsonHandler(bcr.createAccountReceiver))
                m.Handle("/list-accounts", jsonHandler(bcr.listAccounts))
+               m.Handle("/list-addresses", jsonHandler(bcr.listAddresses))
                m.Handle("/delete-account", jsonHandler(bcr.deleteAccount))
                m.Handle("/validate-address", jsonHandler(bcr.validateAddress))