waku-org/go-multiaddr
1
0
Fork 0
mirror of https://github.com/waku-org/go-multiaddr.git synced 2025-02-23 19:48:18 +00:00
Code Issues Packages Projects Releases Wiki Activity

Create NewTranscoderFromFunctions function and use it

Browse Source
This commit is contained in:
Jakub Sztandera 2016-11-02 17:49:29 +01:00
parent 1919305418
commit 72b4a6ce81
No known key found for this signature in database
GPG Key ID: 9A9AF56F8B3879BA
1 changed files with 12 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
transcoders.go
View File

@ -17,6 +17,12 @@ type Transcoder interface {
BytesToString([]byte) (string, error) BytesToString([]byte) (string, error)
} }
func NewTranscoderFromFunctions(s2b func(string) ([]byte, error),
b2s func([]byte) (string, error)) Transcoder {
return twrp{s2b, b2s}
}
type twrp struct { type twrp struct {
strtobyte func(string) ([]byte, error) strtobyte func(string) ([]byte, error)
bytetostr func([]byte) (string, error) bytetostr func([]byte) (string, error)
@ -29,8 +35,8 @@ func (t twrp) BytesToString(b []byte) (string, error) {
return t.bytetostr(b) return t.bytetostr(b)
} }
var TranscoderIP4 = (Transcoder)(twrp{ip4StB, ipBtS}) var TranscoderIP4 = NewTranscoderFromFunctions(ip4StB, ipBtS)
var TranscoderIP6 = (Transcoder)(twrp{ip6StB, ipBtS}) var TranscoderIP6 = NewTranscoderFromFunctions(ip6StB, ipBtS)
func ip4StB(s string) ([]byte, error) { func ip4StB(s string) ([]byte, error) {
i := net.ParseIP(s).To4() i := net.ParseIP(s).To4()
@ -52,7 +58,7 @@ func ipBtS(b []byte) (string, error) {
return net.IP(b).String(), nil return net.IP(b).String(), nil
} }
var TranscoderPort = (Transcoder)(twrp{portStB, portBtS}) var TranscoderPort = NewTranscoderFromFunctions(portStB, portBtS)
func portStB(s string) ([]byte, error) { func portStB(s string) ([]byte, error) {
i, err := strconv.Atoi(s) i, err := strconv.Atoi(s)
@ -72,7 +78,7 @@ func portBtS(b []byte) (string, error) {
return strconv.Itoa(int(i)), nil return strconv.Itoa(int(i)), nil
} }
var TranscoderOnion = (Transcoder)(twrp{onionStB, onionBtS}) var TranscoderOnion = NewTranscoderFromFunctions(onionStB, onionBtS)
func onionStB(s string) ([]byte, error) { func onionStB(s string) ([]byte, error) {
addr := strings.Split(s, ":") addr := strings.Split(s, ":")
@ -115,7 +121,7 @@ func onionBtS(b []byte) (string, error) {
return addr + ":" + strconv.Itoa(int(port)), nil return addr + ":" + strconv.Itoa(int(port)), nil
} }
var TranscoderIPFS = (Transcoder)(twrp{ipfsStB, ipfsBtS}) var TranscoderIPFS = NewTranscoderFromFunctions(ipfsStB, ipfsBtS)
func ipfsStB(s string) ([]byte, error) { func ipfsStB(s string) ([]byte, error) {
// the address is a varint prefixed multihash string representation // the address is a varint prefixed multihash string representation
@ -146,7 +152,7 @@ func ipfsBtS(b []byte) (string, error) {
return m.B58String(), nil return m.B58String(), nil
} }
var TranscoderUnix = (Transcoder)(twrp{unixStB, unixBtS}) var TranscoderUnix = NewTranscoderFromFunctions(unixStB, unixBtS)
func unixStB(s string) ([]byte, error) { func unixStB(s string) ([]byte, error) {
// the address is the whole remaining string, prefixed by a varint len // the address is the whole remaining string, prefixed by a varint len