arnaucube
arnaucube/hermez-nodePublic Self-hosted repository
hermez-node/common/l1tx_test.go
common/l1tx_test.goRaw
  1package common
  2
  3import (
  4	"crypto/ecdsa"
  5	"encoding/hex"
  6	"log"
  7	"math/big"
  8	"testing"
  9
 10	ethCommon "github.com/ethereum/go-ethereum/common"
 11	"github.com/ethereum/go-ethereum/crypto"
 12	"github.com/iden3/go-iden3-crypto/babyjub"
 13	"github.com/iden3/go-iden3-crypto/utils"
 14	"github.com/stretchr/testify/assert"
 15	"github.com/stretchr/testify/require"
 16)
 17
 18func TestNewL1UserTx(t *testing.T) {
 19	toForge := int64(123456)
 20	l1Tx := &L1Tx{
 21		ToForgeL1TxsNum: &toForge,
 22		Position:        71,
 23		UserOrigin:      true,
 24		ToIdx:           301,
 25		TokenID:         5,
 26		Amount:          big.NewInt(1),
 27		LoadAmount:      big.NewInt(2),
 28		FromIdx:         Idx(300),
 29	}
 30	l1Tx, err := NewL1Tx(l1Tx)
 31	assert.Nil(t, err)
 32	assert.Equal(t, "0x00000000000001e240004700", l1Tx.TxID.String())
 33}
 34
 35func TestNewL1CoordinatorTx(t *testing.T) {
 36	batchNum := BatchNum(51966)
 37	l1Tx := &L1Tx{
 38		Position:   88,
 39		UserOrigin: false,
 40		ToIdx:      301,
 41		TokenID:    5,
 42		Amount:     big.NewInt(1),
 43		LoadAmount: big.NewInt(2),
 44		FromIdx:    Idx(300),
 45		BatchNum:   &batchNum,
 46	}
 47	l1Tx, err := NewL1Tx(l1Tx)
 48	assert.Nil(t, err)
 49	assert.Equal(t, "0x01000000000000cafe005800", l1Tx.TxID.String())
 50}
 51
 52func TestL1TxCompressedData(t *testing.T) {
 53	tx := L1Tx{
 54		FromIdx: 2,
 55		ToIdx:   3,
 56		Amount:  big.NewInt(4),
 57		TokenID: 5,
 58	}
 59	txCompressedData, err := tx.TxCompressedData()
 60	assert.Nil(t, err)
 61
 62	// test vector value generated from javascript implementation
 63	expectedStr := "7307597389635308713748674793997299267459594577423"
 64	assert.Equal(t, expectedStr, txCompressedData.String())
 65	assert.Equal(t, "0500040000000000030000000000020000c60be60f", hex.EncodeToString(txCompressedData.Bytes()))
 66}
 67
 68func TestBytesDataAvailability(t *testing.T) {
 69	tx := L1Tx{
 70		FromIdx: 2,
 71		ToIdx:   3,
 72		Amount:  big.NewInt(4),
 73		TokenID: 5,
 74	}
 75	txCompressedData, err := tx.BytesDataAvailability(32)
 76	assert.Nil(t, err)
 77	assert.Equal(t, "0000000200000003000000", hex.EncodeToString(txCompressedData))
 78
 79	tx = L1Tx{
 80		FromIdx:         2,
 81		ToIdx:           3,
 82		EffectiveAmount: big.NewInt(4),
 83		TokenID:         5,
 84	}
 85	txCompressedData, err = tx.BytesDataAvailability(32)
 86	assert.Nil(t, err)
 87	assert.Equal(t, "0000000200000003000400", hex.EncodeToString(txCompressedData))
 88}
 89
 90func TestL1TxFromDataAvailability(t *testing.T) {
 91	tx := L1Tx{
 92		FromIdx: 2,
 93		ToIdx:   3,
 94		Amount:  big.NewInt(4),
 95	}
 96	txCompressedData, err := tx.BytesDataAvailability(32)
 97	assert.Nil(t, err)
 98	l1tx, err := L1TxFromDataAvailability(txCompressedData, 32)
 99	assert.Equal(t, tx.FromIdx, l1tx.FromIdx)
100	assert.Equal(t, tx.ToIdx, l1tx.ToIdx)
101
102	tx = L1Tx{
103		FromIdx:         2,
104		ToIdx:           3,
105		EffectiveAmount: big.NewInt(4),
106	}
107	txCompressedData, err = tx.BytesDataAvailability(32)
108	assert.Nil(t, err)
109	l1tx, err = L1TxFromDataAvailability(txCompressedData, 32)
110	assert.Equal(t, tx.FromIdx, l1tx.FromIdx)
111	assert.Equal(t, tx.ToIdx, l1tx.ToIdx)
112	assert.Equal(t, tx.EffectiveAmount, l1tx.EffectiveAmount)
113}
114
115func TestL1userTxByteParsers(t *testing.T) {
116	var pkComp babyjub.PublicKeyComp
117	pkCompL := []byte("0x56ca90f80d7c374ae7485e9bcc47d4ac399460948da6aeeb899311097925a72c")
118	err := pkComp.UnmarshalText(pkCompL)
119	require.Nil(t, err)
120
121	pk, err := pkComp.Decompress()
122	require.Nil(t, err)
123
124	l1Tx := &L1Tx{
125		UserOrigin:  true,
126		ToIdx:       3,
127		TokenID:     5,
128		Amount:      big.NewInt(1),
129		LoadAmount:  big.NewInt(2),
130		FromIdx:     2,
131		FromBJJ:     pk,
132		FromEthAddr: ethCommon.HexToAddress("0xc58d29fA6e86E4FAe04DDcEd660d45BCf3Cb2370"),
133	}
134
135	encodedData, err := l1Tx.BytesUser()
136	require.Nil(t, err)
137	decodedData, err := L1UserTxFromBytes(encodedData)
138	require.Nil(t, err)
139	assert.Equal(t, l1Tx, decodedData)
140	encodedData2, err := decodedData.BytesUser()
141	require.Nil(t, err)
142	assert.Equal(t, encodedData, encodedData2)
143
144	// expect error if length!=68
145	_, err = L1UserTxFromBytes(encodedData[:66])
146	require.NotNil(t, err)
147	_, err = L1UserTxFromBytes([]byte{})
148	require.NotNil(t, err)
149	_, err = L1UserTxFromBytes(nil)
150	require.NotNil(t, err)
151}
152
153func TestL1TxByteParsersCompatibility(t *testing.T) {
154	// Data from compatibility test
155	var pkComp babyjub.PublicKeyComp
156	pkCompB, err := hex.DecodeString("0dd02deb2c81068e7a0f7e327df80b4ab79ee1f41a7def613e73a20c32eece5a")
157	require.Nil(t, err)
158	pkCompL := SwapEndianness(pkCompB)
159	err = pkComp.UnmarshalText([]byte(hex.EncodeToString(pkCompL)))
160	require.Nil(t, err)
161
162	pk, err := pkComp.Decompress()
163	require.Nil(t, err)
164
165	loadAmount := new(big.Int)
166	loadAmount.SetString("100000000000000000000", 10)
167	l1Tx := &L1Tx{
168		ToIdx:       87865485,
169		TokenID:     2098076,
170		Amount:      big.NewInt(2400000000000000000),
171		LoadAmount:  loadAmount,
172		FromIdx:     Idx(29767899),
173		FromBJJ:     pk,
174		FromEthAddr: ethCommon.HexToAddress("0x85dab5b9e2e361d0c208d77be90efcc0439b0a53"),
175		UserOrigin:  true,
176	}
177
178	expected, err := utils.HexDecode("85dab5b9e2e361d0c208d77be90efcc0439b0a530dd02deb2c81068e7a0f7e327df80b4ab79ee1f41a7def613e73a20c32eece5a000001c638db8be880f00020039c0000053cb88d")
179	require.Nil(t, err)
180
181	encodedData, err := l1Tx.BytesUser()
182	require.Nil(t, err)
183	assert.Equal(t, expected, encodedData)
184}
185
186func TestL1CoordinatorTxByteParsers(t *testing.T) {
187	hermezAddress := ethCommon.HexToAddress("0xD6C850aeBFDC46D7F4c207e445cC0d6B0919BDBe")
188	chainID := big.NewInt(1337)
189	chainIDBytes := ethCommon.LeftPadBytes(chainID.Bytes(), 2)
190
191	privateKey, err := crypto.HexToECDSA("fad9c8855b740a0b7ed4c221dbad0f33a83a49cad6b3fe8d5817ac83d38b6a19")
192	require.Nil(t, err)
193
194	publicKey := privateKey.Public()
195	publicKeyECDSA, ok := publicKey.(*ecdsa.PublicKey)
196	if !ok {
197		log.Fatal("error casting public key to ECDSA")
198	}
199	publicKeyBytes := crypto.FromECDSAPub(publicKeyECDSA)
200	pubKey, err := crypto.UnmarshalPubkey(publicKeyBytes)
201	require.Nil(t, err)
202	fromEthAddr := crypto.PubkeyToAddress(*pubKey)
203	var pkComp babyjub.PublicKeyComp
204	pkCompL := []byte("56ca90f80d7c374ae7485e9bcc47d4ac399460948da6aeeb899311097925a72c")
205	err = pkComp.UnmarshalText(pkCompL)
206	require.Nil(t, err)
207	pk, err := pkComp.Decompress()
208	require.Nil(t, err)
209	bytesMessage1 := []byte("\x19Ethereum Signed Message:\n120")
210	bytesMessage2 := []byte("I authorize this babyjubjub key for hermez rollup account creation")
211
212	babyjub := pk.Compress()
213	babyjubB := SwapEndianness(babyjub[:])
214	var data []byte
215	data = append(data, bytesMessage1...)
216	data = append(data, bytesMessage2...)
217	data = append(data, babyjubB[:]...)
218	data = append(data, chainIDBytes...)
219	data = append(data, hermezAddress.Bytes()...)
220	hash := crypto.Keccak256Hash(data)
221	signature, err := crypto.Sign(hash.Bytes(), privateKey)
222	require.Nil(t, err)
223	// Ethereum adds 27 to v
224	v := int(signature[64])
225	signature[64] = byte(v + 27)
226
227	l1Tx := &L1Tx{
228		TokenID:     231,
229		FromBJJ:     pk,
230		FromEthAddr: fromEthAddr,
231		Amount:      big.NewInt(0),
232		LoadAmount:  big.NewInt(0),
233	}
234
235	bytesCoordinatorL1, err := l1Tx.BytesCoordinatorTx(signature)
236	require.Nil(t, err)
237	l1txDecoded, err := L1CoordinatorTxFromBytes(bytesCoordinatorL1, chainID, hermezAddress)
238	require.Nil(t, err)
239	assert.Equal(t, l1Tx, l1txDecoded)
240	bytesCoordinatorL12, err := l1txDecoded.BytesCoordinatorTx(signature)
241	require.Nil(t, err)
242	assert.Equal(t, bytesCoordinatorL1, bytesCoordinatorL12)
243
244	// expect error if length!=68
245	_, err = L1CoordinatorTxFromBytes(bytesCoordinatorL1[:66], chainID, hermezAddress)
246	require.NotNil(t, err)
247	_, err = L1CoordinatorTxFromBytes([]byte{}, chainID, hermezAddress)
248	require.NotNil(t, err)
249	_, err = L1CoordinatorTxFromBytes(nil, chainID, hermezAddress)
250	require.NotNil(t, err)
251}
252
253func TestL1CoordinatorTxByteParsersCompatibility(t *testing.T) {
254	// Data from compatibility test
255	var signature []byte
256	r, err := hex.DecodeString("da71e5eb097e115405d84d1e7b464009b434b32c014a2df502d1f065ced8bc3b")
257	require.Nil(t, err)
258	s, err := hex.DecodeString("186d7122ff7f654cfed3156719774898d573900c86599a885a706dbdffe5ea8c")
259	require.Nil(t, err)
260	v, err := hex.DecodeString("1b")
261	require.Nil(t, err)
262
263	signature = append(signature, r[:]...)
264	signature = append(signature, s[:]...)
265	signature = append(signature, v[:]...)
266
267	var pkComp babyjub.PublicKeyComp
268	pkCompB, err := hex.DecodeString("a2c2807ee39c3b3378738cff85a46a9465bb8fcf44ea597c33da9719be7c259c")
269	require.Nil(t, err)
270	pkCompL := SwapEndianness(pkCompB)
271	err = pkComp.UnmarshalText([]byte(hex.EncodeToString(pkCompL)))
272	require.Nil(t, err)
273	// Data from the compatibility test
274	require.Nil(t, err)
275	pk, err := pkComp.Decompress()
276	require.Nil(t, err)
277	l1Tx := &L1Tx{
278		TokenID: 231,
279		FromBJJ: pk,
280	}
281
282	encodeData, err := l1Tx.BytesCoordinatorTx(signature)
283	require.Nil(t, err)
284
285	expected, err := utils.HexDecode("1b186d7122ff7f654cfed3156719774898d573900c86599a885a706dbdffe5ea8cda71e5eb097e115405d84d1e7b464009b434b32c014a2df502d1f065ced8bc3ba2c2807ee39c3b3378738cff85a46a9465bb8fcf44ea597c33da9719be7c259c000000e7")
286	require.Nil(t, err)
287
288	assert.Equal(t, expected, encodeData)
289}