change time.Time to int64 (#19)

* change time.Time to int64

* fix

cmd/main.go

@@ -57,7 +57,7 @@ func runServer(*cli.Context) error {
 	log.Info(">> App begin")
 
 	// Create stream server
-	s, err := datastreamer.New(1337, StSequencer, "streamfile.bin")
+	s, err := datastreamer.New(6900, StSequencer, "streamfile.bin")
 	if err != nil {
 		os.Exit(1)
 	}
@@ -91,7 +91,7 @@ func runServer(*cli.Context) error {
 	l2block := db.L2Block{
 		BatchNumber:    1,
 		L2BlockNumber:  1000,
-		Timestamp:      time.Now(),
+		Timestamp:      time.Now().Unix(),
 		GlobalExitRoot: [32]byte{10, 11, 12, 13, 14},
 		Coinbase:       [20]byte{20, 21, 22, 23, 24},
 	}
@@ -167,7 +167,7 @@ func runServer(*cli.Context) error {
 
 func runClient(*cli.Context) error {
 	// Create client
-	c, err := datastreamer.NewClient("127.0.0.1:1337", StSequencer)
+	c, err := datastreamer.NewClient("127.0.0.1:6900", StSequencer)
 	if err != nil {
 		return err
 	}

tool/db/db.go

@@ -3,6 +3,7 @@ package db
 import (
 	"context"
 	"fmt"
+	"time"
 
 	"github.com/0xPolygonHermez/zkevm-data-streamer/log"
 	"github.com/ethereum/go-ethereum/common"
@@ -70,18 +71,20 @@ func scanL2Block(row pgx.Row) (*L2Block, error) {
 	var (
 		gerStr      string
 		coinbaseStr string
+		timestamp   time.Time
 	)
 	if err := row.Scan(
 		&l2Block.BatchNumber,
 		&l2Block.L2BlockNumber,
-		&l2Block.Timestamp,
+		&timestamp,
 		&gerStr,
 		&coinbaseStr,
 	); err != nil {
 		return &l2Block, err
 	}
 	l2Block.GlobalExitRoot = common.HexToHash(gerStr)
 	l2Block.Coinbase = common.HexToAddress(coinbaseStr)
+	l2Block.Timestamp = timestamp.Unix()
 	return &l2Block, nil
 }
 

tool/db/types.go

@@ -1,7 +1,6 @@
 package db
 
 import (
-	"time"
 	"unsafe"
 
 	"github.com/0xPolygonHermez/zkevm-data-streamer/datastreamer"
@@ -21,7 +20,7 @@ const (
 type L2Block struct {
 	BatchNumber    uint64
 	L2BlockNumber  uint64
-	Timestamp      time.Time
+	Timestamp      int64
 	GlobalExitRoot common.Hash
 	Coinbase       common.Address
 }

tool/main.go

@@ -92,6 +92,10 @@ func start(cliCtx *cli.Context) error {
 	}
 
 	streamServer.SetEntriesDefinition(entriesDefinition)
+	err = streamServer.Start()
+	if err != nil {
+		log.Fatal(err)
+	}
 
 	// Connect to the database
 	stateSqlDB, err := db.NewSQLDB(c.StateDB)