🚚 [MIGRATION] Use pkg/io instead of poly-go/io

backend/ethereum/channel/backend_test.go

@@ -31,9 +31,9 @@ import (
 	ethwallettest "perun.network/go-perun/backend/ethereum/wallet/test"
 	perunchannel "perun.network/go-perun/channel"
 	"perun.network/go-perun/channel/test"
+	iotest "perun.network/go-perun/pkg/io/test"
 	perunwallet "perun.network/go-perun/wallet"
 	wallettest "perun.network/go-perun/wallet/test"
-	iotest "polycry.pt/poly-go/io/test"
 	pkgtest "polycry.pt/poly-go/test"
 )
 

backend/ethereum/wallet/backend.go

@@ -20,8 +20,8 @@ import (
 	"github.com/ethereum/go-ethereum/crypto"
 	"github.com/pkg/errors"
 
+	perunio "perun.network/go-perun/pkg/io"
 	"perun.network/go-perun/wallet"
-	perunio "polycry.pt/poly-go/io"
 )
 
 // Backend implements the utility interface defined in the wallet package.

backend/sim/channel/asset.go

@@ -19,7 +19,7 @@ import (
 	"math/rand"
 
 	"perun.network/go-perun/channel"
-	perunio "polycry.pt/poly-go/io"
+	perunio "perun.network/go-perun/pkg/io"
 )
 
 // Asset simulates a `channel.Asset` by only containing an `ID`.

backend/sim/channel/backend.go

@@ -23,8 +23,8 @@ import (
 
 	"perun.network/go-perun/channel"
 	"perun.network/go-perun/log"
+	perunio "perun.network/go-perun/pkg/io"
 	"perun.network/go-perun/wallet"
-	perunio "polycry.pt/poly-go/io"
 )
 
 // backend implements the utility interface defined in the channel package.

backend/sim/wallet/address.go

@@ -25,8 +25,8 @@ import (
 	"github.com/pkg/errors"
 
 	"perun.network/go-perun/log"
+	perunio "perun.network/go-perun/pkg/io"
 	"perun.network/go-perun/wallet"
-	perunio "polycry.pt/poly-go/io"
 )
 
 // Address represents a simulated address.

backend/sim/wallet/backend.go

@@ -23,8 +23,8 @@ import (
 	"github.com/pkg/errors"
 
 	"perun.network/go-perun/log"
+	perunio "perun.network/go-perun/pkg/io"
 	"perun.network/go-perun/wallet"
-	perunio "polycry.pt/poly-go/io"
 )
 
 var curve = elliptic.P256()

channel/allocation.go

@@ -19,7 +19,7 @@ import (
 	"log"
 	"math/big"
 
-	perunio "polycry.pt/poly-go/io"
+	perunio "perun.network/go-perun/pkg/io"
 	perunbig "polycry.pt/poly-go/math/big"
 
 	"github.com/ethereum/go-ethereum/accounts/abi"

channel/allocation_test.go

@@ -24,8 +24,8 @@ import (
 
 	"perun.network/go-perun/channel"
 	"perun.network/go-perun/channel/test"
-	perunio "polycry.pt/poly-go/io"
-	iotest "polycry.pt/poly-go/io/test"
+	perunio "perun.network/go-perun/pkg/io"
+	iotest "perun.network/go-perun/pkg/io/test"
 	pkgbig "polycry.pt/poly-go/math/big"
 	pkgtest "polycry.pt/poly-go/test"
 )

channel/app.go

@@ -19,8 +19,8 @@ import (
 
 	"github.com/pkg/errors"
 
+	perunio "perun.network/go-perun/pkg/io"
 	"perun.network/go-perun/wallet"
-	perunio "polycry.pt/poly-go/io"
 )
 
 type (

channel/machine.go

@@ -21,8 +21,8 @@ import (
 	"github.com/pkg/errors"
 
 	"perun.network/go-perun/log"
+	"perun.network/go-perun/pkg/io"
 	"perun.network/go-perun/wallet"
-	"polycry.pt/poly-go/io"
 	"polycry.pt/poly-go/math/big"
 )
 

channel/mock_app.go

@@ -19,8 +19,8 @@ import (
 
 	"github.com/pkg/errors"
 
+	perunio "perun.network/go-perun/pkg/io"
 	"perun.network/go-perun/wallet"
-	perunio "polycry.pt/poly-go/io"
 )
 
 // MockApp a mocked App whose behaviour is determined by the MockOp passed to it either as State.Data or Action.

channel/mock_app_internal_test.go

@@ -19,8 +19,8 @@ import (
 
 	"github.com/stretchr/testify/assert"
 
+	iotest "perun.network/go-perun/pkg/io/test"
 	wallettest "perun.network/go-perun/wallet/test"
-	iotest "polycry.pt/poly-go/io/test"
 	pkgtest "polycry.pt/poly-go/test"
 )
 

channel/params.go

@@ -22,8 +22,8 @@ import (
 	"github.com/pkg/errors"
 
 	"perun.network/go-perun/log"
+	"perun.network/go-perun/pkg/io"
 	"perun.network/go-perun/wallet"
-	"polycry.pt/poly-go/io"
 )
 
 // IDLen the length of a channelID.

channel/params_test.go

@@ -19,8 +19,8 @@ import (
 
 	"perun.network/go-perun/channel"
 	"perun.network/go-perun/channel/test"
-	"polycry.pt/poly-go/io"
-	iotest "polycry.pt/poly-go/io/test"
+	"perun.network/go-perun/pkg/io"
+	iotest "perun.network/go-perun/pkg/io/test"
 	pkgtest "polycry.pt/poly-go/test"
 )
 

channel/persistence/keyvalue/persistedstate.go

@@ -18,7 +18,7 @@ import (
 	"io"
 
 	"perun.network/go-perun/channel"
-	perunio "polycry.pt/poly-go/io"
+	perunio "perun.network/go-perun/pkg/io"
 )
 
 var (

channel/persistence/keyvalue/persister.go

@@ -26,8 +26,8 @@ import (
 	"github.com/pkg/errors"
 
 	"perun.network/go-perun/channel"
+	perunio "perun.network/go-perun/pkg/io"
 	"perun.network/go-perun/wire"
-	perunio "polycry.pt/poly-go/io"
 	"polycry.pt/poly-go/sortedkv"
 )
 

channel/persistence/keyvalue/restorer.go

@@ -24,9 +24,9 @@ import (
 
 	"perun.network/go-perun/channel"
 	"perun.network/go-perun/channel/persistence"
+	perunio "perun.network/go-perun/pkg/io"
 	"perun.network/go-perun/wallet"
 	"perun.network/go-perun/wire"
-	perunio "polycry.pt/poly-go/io"
 	"polycry.pt/poly-go/sortedkv"
 )
 

channel/state.go

@@ -19,7 +19,7 @@ import (
 
 	"github.com/pkg/errors"
 
-	perunio "polycry.pt/poly-go/io"
+	perunio "perun.network/go-perun/pkg/io"
 )
 
 type (

channel/state_test.go

@@ -20,7 +20,7 @@ import (
 	_ "perun.network/go-perun/backend/sim" // backend init
 	"perun.network/go-perun/channel"
 	"perun.network/go-perun/channel/test"
-	iotest "polycry.pt/poly-go/io/test"
+	iotest "perun.network/go-perun/pkg/io/test"
 	pkgtest "polycry.pt/poly-go/test"
 )
 

channel/transaction.go

@@ -19,8 +19,8 @@ import (
 
 	"github.com/pkg/errors"
 
+	perunio "perun.network/go-perun/pkg/io"
 	"perun.network/go-perun/wallet"
-	perunio "polycry.pt/poly-go/io"
 )
 
 // Transaction is a channel state together with valid signatures from the

channel/transaction_test.go

@@ -19,7 +19,7 @@ import (
 
 	"perun.network/go-perun/channel"
 	"perun.network/go-perun/channel/test"
-	iotest "polycry.pt/poly-go/io/test"
+	iotest "perun.network/go-perun/pkg/io/test"
 	pkgtest "polycry.pt/poly-go/test"
 )
 

client/proposal.go

@@ -24,10 +24,10 @@ import (
 
 	"perun.network/go-perun/channel"
 	"perun.network/go-perun/log"
+	"perun.network/go-perun/pkg/io"
 	"perun.network/go-perun/wallet"
 	"perun.network/go-perun/wire"
 	pcontext "polycry.pt/poly-go/context"
-	"polycry.pt/poly-go/io"
 	"polycry.pt/poly-go/sync/atomic"
 )
 

client/proposalmsgs.go

@@ -24,9 +24,9 @@ import (
 
 	"perun.network/go-perun/channel"
 	"perun.network/go-perun/log"
+	perunio "perun.network/go-perun/pkg/io"
 	"perun.network/go-perun/wallet"
 	"perun.network/go-perun/wire"
-	perunio "polycry.pt/poly-go/io"
 	perunbig "polycry.pt/poly-go/math/big"
 )
 

client/serialize.go

@@ -19,7 +19,7 @@ import (
 
 	"github.com/pkg/errors"
 	"perun.network/go-perun/channel"
-	perunio "polycry.pt/poly-go/io"
+	perunio "perun.network/go-perun/pkg/io"
 )
 
 type (

client/syncmsgs.go

@@ -18,8 +18,8 @@ import (
 	"io"
 
 	"perun.network/go-perun/channel"
+	perunio "perun.network/go-perun/pkg/io"
 	"perun.network/go-perun/wire"
-	perunio "polycry.pt/poly-go/io"
 )
 
 func init() {

client/test/backend.go

@@ -25,8 +25,8 @@ import (
 
 	"perun.network/go-perun/channel"
 	"perun.network/go-perun/log"
+	"perun.network/go-perun/pkg/io"
 	"perun.network/go-perun/wallet"
-	"polycry.pt/poly-go/io"
 )
 
 type (

client/updatemsgs.go

@@ -18,9 +18,9 @@ import (
 	"io"
 
 	"perun.network/go-perun/channel"
+	perunio "perun.network/go-perun/pkg/io"
 	"perun.network/go-perun/wallet"
 	"perun.network/go-perun/wire"
-	perunio "polycry.pt/poly-go/io"
 )
 
 func init() {

pkg/io/bigint.go

@@ -0,0 +1,86 @@
+// Copyright 2019 - See NOTICE file for copyright holders.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package io
+
+import (
+	"io"
+	"math/big"
+
+	"github.com/pkg/errors"
+)
+
+// MaxBigIntLength defines the maximum length of a big integer.
+// 1024bit -> 128 bytes.
+const MaxBigIntLength = 128
+
+// BigInt is a serializer big integer.
+type BigInt struct {
+	*big.Int
+}
+
+// Decode reads a big.Int from the given stream.
+func (b *BigInt) Decode(reader io.Reader) error {
+	// Read length
+	lengthData := make([]byte, 1)
+	if _, err := reader.Read(lengthData); err != nil {
+		return errors.Wrap(err, "failed to decode length of big.Int")
+	}
+
+	length := lengthData[0]
+	if length > MaxBigIntLength {
+		return errors.New("big.Int too big to decode")
+	}
+
+	bytes := make([]byte, length)
+	if n, err := io.ReadFull(reader, bytes); err != nil {
+		return errors.Wrapf(err, "failed to read bytes for big.Int, read %d/%d", n, length)
+	}
+
+	if b.Int == nil {
+		b.Int = new(big.Int)
+	}
+	b.Int.SetBytes(bytes)
+	return nil
+}
+
+// Encode writes a big.Int to the stream.
+func (b BigInt) Encode(writer io.Writer) error {
+	if b.Int == nil {
+		panic("logic error: tried to encode nil big.Int")
+	}
+	if b.Int.Sign() == -1 {
+		panic("encoding of negative big.Int not implemented")
+	}
+
+	bytes := b.Bytes()
+	length := len(bytes)
+	// we serialize the length as uint8
+	if length > MaxBigIntLength {
+		return errors.New("big.Int too big to encode")
+	}
+
+	// Write length
+	if _, err := writer.Write([]byte{uint8(length)}); err != nil {
+		return errors.Wrap(err, "failed to write length")
+	}
+
+	if length == 0 {
+		return nil
+	}
+
+	// Write bytes
+	n, err := writer.Write(bytes)
+	return errors.Wrapf(err, "failed to write big.Int, wrote %d bytes of %d", n, length)
+}