The core protocol of WoopChain
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
woop/utils/utils.go

53 lines
1.2 KiB

package utils
7 years ago
import (
6 years ago
"bytes"
"encoding/binary"
"log"
"os/exec"
"regexp"
6 years ago
"strconv"
"github.com/simple-rules/harmony-benchmark/p2p"
7 years ago
)
// ConvertFixedDataIntoByteArray converts an empty interface data to a byte array
func ConvertFixedDataIntoByteArray(data interface{}) []byte {
6 years ago
buff := new(bytes.Buffer)
err := binary.Write(buff, binary.BigEndian, data)
6 years ago
if err != nil {
log.Panic(err)
}
return buff.Bytes()
7 years ago
}
6 years ago
6 years ago
// TODO(minhdoan): this is probably a hack, probably needs some strong non-collision hash.
func GetUniqueIdFromPeer(peer p2p.Peer) uint16 {
reg, err := regexp.Compile("[^0-9]+")
if err != nil {
log.Panic("Regex Compilation Failed", "err", err)
}
socketId := reg.ReplaceAllString(peer.Ip+peer.Port, "") // A integer Id formed by unique IP/PORT pair
value, _ := strconv.Atoi(socketId)
return uint16(value)
}
// RunCmd Runs command `name` with arguments `args`
func RunCmd(name string, args ...string) error {
cmd := exec.Command(name, args...)
if err := cmd.Start(); err != nil {
log.Fatal(err)
return err
}
log.Println("Command running", name, args)
go func() {
if err := cmd.Wait(); err != nil {
log.Printf("Command finished with error: %v", err)
} else {
log.Printf("Command finished successfully")
}
}()
return nil
}