forked from ethereum/go-ethereum
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Made the verification texts use the new mining pool + app (ethereum#4)
* Switched to new mobile mining app. * Fixed a bug. * Cleaned up some code and added comments. * Added todo and reformatted. * Small changes.
- Loading branch information
1 parent
b22967e
commit b507ead
Showing
2 changed files
with
102 additions
and
64 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,99 @@ | ||
| // Copyright 2017 The Celo Authors | ||
| // This file is part of the celo library. | ||
| // | ||
| // The celo library is free software: you can redistribute it and/or modify | ||
| // it under the terms of the GNU Lesser General Public License as published by | ||
| // the Free Software Foundation, either version 3 of the License, or | ||
| // (at your option) any later version. | ||
| // | ||
| // The celo 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 Lesser General Public License for more details. | ||
| // | ||
| // You should have received a copy of the GNU Lesser General Public License | ||
| // along with the celo library. If not, see <http://www.gnu.org/licenses/>. | ||
|
|
||
| package abe | ||
|
|
||
| import ( | ||
| "bytes" | ||
| "encoding/json" | ||
| "fmt" | ||
| "net/http" | ||
| "strconv" | ||
| "strings" | ||
| "time" | ||
|
|
||
| "github.com/ethereum/go-ethereum/accounts" | ||
| "github.com/ethereum/go-ethereum/common" | ||
| "github.com/ethereum/go-ethereum/common/hexutil" | ||
| "github.com/ethereum/go-ethereum/core/types" | ||
| "github.com/ethereum/go-ethereum/log" | ||
| ) | ||
|
|
||
| func SendVerificationTexts(block *types.Block, coinbase common.Address, accountManager *accounts.Manager) { | ||
| numTransactions := 0 | ||
| for range block.Transactions() { | ||
| numTransactions += 1 | ||
| } | ||
| log.Debug("\n[Celo] New block: "+block.Hash().Hex()+", "+strconv.Itoa(numTransactions), nil, nil) | ||
|
|
||
| wallet, err := accountManager.Find(accounts.Account{Address: coinbase}) | ||
| if err != nil { | ||
| log.Error("[Celo] Failed to get account", "err", err) | ||
| return | ||
| } | ||
|
|
||
| // Iterate through all transactions in the currently sealed block to find verification | ||
| // transactions. | ||
| for _, tx := range block.Transactions() { | ||
| data := string(tx.Data()) | ||
| log.Debug("[Celo] Block transaction:: "+tx.Hash().Hex()+" "+data, nil, nil) | ||
|
|
||
| if len(data) > 0 && (strings.HasPrefix(data, "reqVerify") || strings.HasPrefix(data, "reqAndVerify")) { | ||
| // Get the phone number to send the secret to. | ||
| dataArray := strings.Split(data, "-") | ||
| phone := dataArray[len(dataArray)-1] | ||
| log.Debug("[Celo] Sending text to phone: "+phone, nil, nil) | ||
|
|
||
| if len(phone) <= 0 { | ||
| log.Error("[Celo] Invalid phone number: "+phone, nil, nil) | ||
| continue | ||
| } | ||
|
|
||
| // Construct the secret code to be sent via SMS. | ||
| nonce := tx.Nonce() | ||
| unsignedCode := common.BytesToHash([]byte(string(phone) + string(nonce))) | ||
| code, err := wallet.SignHash(accounts.Account{Address: coinbase}, unsignedCode.Bytes()) | ||
| if err != nil { | ||
| log.Error("[Celo] Failed to sign phone number for sending over SMS", "err", err) | ||
| continue | ||
| } | ||
| hexCode := hexutil.Encode(code[:]) | ||
| log.Debug("[Celo] Secret code: "+hexCode+" "+string(len(code)), nil, nil) | ||
| secret := fmt.Sprintf("Gem verification code: %s", hexCode) | ||
| log.Debug("[Celo] New verification request: "+tx.Hash().Hex()+" "+phone, nil, nil) | ||
|
|
||
| // Send the actual text message using our mining pool. | ||
| // TODO: Make mining pool be configurable via command line arguments. | ||
| url := "https://mining-pool.celo.org/send-text" | ||
| values := map[string]string{"phoneNumber": phone, "message": secret} | ||
| jsonValue, _ := json.Marshal(values) | ||
| _, err = http.Post(url, "application/json", bytes.NewBuffer(jsonValue)) | ||
| log.Debug("[Celo] SMS send Url: "+url, nil, nil) | ||
|
|
||
| // Retry 5 times if we fail. | ||
| for i := 0; i < 5; i++ { | ||
| if err == nil { | ||
| break | ||
| } | ||
| log.Debug("[Celo] Got an error when trying to send SMS to: "+url, nil, nil) | ||
| time.Sleep(100 * time.Millisecond) | ||
| _, err = http.Post(url, "application/json", bytes.NewBuffer(jsonValue)) | ||
| } | ||
|
|
||
| log.Debug("[Celo] Sent SMS", nil, nil) | ||
| } | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters