Merge branch 'dev' into compression

# Conflicts:
#	protobuff/archive.pb.go
#	protobuff/archive_grpc.pb.go

protobuff/archive.proto

@@ -1,6 +1,6 @@
 syntax = "proto3";
 
-package qubic.archiver.archive.pb;
+package org.qubic.archiver.proto;
 
 option go_package = "github.com/qubic/go-archiver/protobuff/";
 import "google/api/annotations.proto";

rpc/rpc_server.go

@@ -56,15 +56,21 @@ func NewServer(listenAddrGRPC, listenAddrHTTP string, syncThreshold int, chainTi
 }
 
 func getTransactionInfo(ctx context.Context, pebbleStore *store.PebbleStore, transactionId string, tickNumber uint32) (*TransactionInfo, error) {
-
-	txStatus, err := pebbleStore.GetTransactionStatus(ctx, transactionId)
+	tickData, err := pebbleStore.GetTickData(ctx, tickNumber)
 	if err != nil {
-		return nil, errors.Wrap(err, "getting transaction status")
+		return nil, errors.Wrap(err, "getting tick data")
 	}
 
-	tickData, err := pebbleStore.GetTickData(ctx, tickNumber)
+	txStatus, err := pebbleStore.GetTransactionStatus(ctx, transactionId)
 	if err != nil {
-		return nil, errors.Wrap(err, "getting tick data")
+		if errors.Is(err, store.ErrNotFound) {
+			return &TransactionInfo{
+				timestamp: tickData.Timestamp,
+				moneyFlew: false,
+			}, nil
+		}
+
+		return nil, errors.Wrap(err, "getting transaction status")
 	}
 
 	return &TransactionInfo{
@@ -642,6 +648,10 @@ func (s *Server) GetTransactionStatus(ctx context.Context, req *protobuff.GetTra
 		return nil, status.Errorf(codes.Internal, "getting tx status: %v", err)
 	}
 
+	if txStatus.MoneyFlew == false {
+		return &protobuff.GetTransactionStatusResponse{TransactionStatus: &protobuff.TransactionStatus{TxId: tx.TxId, MoneyFlew: false}}, nil
+	}
+
 	if tx.InputType == 1 && tx.InputSize == 1000 && tx.DestId == "EAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAVWRF" {
 		moneyFlew, err := recomputeSendManyMoneyFlew(tx)
 		if err != nil {

rpc/v2_endpoints.go

@@ -318,7 +318,7 @@ func (s *Server) GetSendManyTransactionV2(ctx context.Context, req *protobuff.Ge
 func (s *Server) GetIdentityTransfersInTickRangeV2(ctx context.Context, req *protobuff.GetTransferTransactionsPerTickRequestV2) (*protobuff.GetIdentityTransfersInTickRangeResponseV2, error) {
 	txs, err := s.store.GetTransferTransactions(ctx, req.Identity, uint64(req.GetStartTick()), uint64(req.GetEndTick()))
 	if err != nil {
-		return nil, status.Errorf(codes.Internal, "getting transfer transactions: %v", err)
+		return nil, status.Errorf(codes.Internal, "getting transfer transactions: %s", err.Error())
 	}
 
 	var totalTransactions []*protobuff.PerTickIdentityTransfers
@@ -330,7 +330,7 @@ func (s *Server) GetIdentityTransfersInTickRangeV2(ctx context.Context, req *pro
 		for _, transaction := range transactionsPerTick.Transactions {
 			transactionInfo, err := getTransactionInfo(ctx, s.store, transaction.TxId, transaction.TickNumber)
 			if err != nil {
-				return nil, status.Errorf(codes.Internal, "getting transaction info: %v", err)
+				return nil, status.Errorf(codes.Internal, "Got Err: %s when getting transaction info for tx id: %s", err.Error(), transaction.TxId)
 			}
 
 			if req.ScOnly == true && transaction.GetInputType() == 0 {

store/store.go

@@ -300,26 +300,6 @@ func (s *PebbleStore) GetLastProcessedTick(ctx context.Context) (*protobuff.Proc
 	}
 	defer closer.Close()
 
-	// handle old data format, to be removed in the future
-	if len(value) == 8 {
-		tickNumber := uint32(binary.LittleEndian.Uint64(value))
-		ticksPerEpoch, err := s.GetLastProcessedTicksPerEpoch(ctx)
-		if err != nil {
-			return nil, errors.Wrap(err, "getting last processed ticks per epoch")
-		}
-		var epoch uint32
-		for e, tick := range ticksPerEpoch {
-			if tick == tickNumber {
-				epoch = e
-				break
-			}
-		}
-		return &protobuff.ProcessedTick{
-			TickNumber: tickNumber,
-			Epoch:      epoch,
-		}, nil
-	}
-
 	var lpt protobuff.ProcessedTick
 	if err := proto.Unmarshal(value, &lpt); err != nil {
 		return nil, errors.Wrap(err, "unmarshalling lpt to protobuff type")