Merge the indexer changes into the 2.0.3 release branch (#728)

* Prepare beta release build 9 (#673)

* add lease to asset cmds (#575)

* fix Disassemble when multiple bnz have the same target label (#612)

add test

* Add PeerConnections to network telemetry (#607)

* Add PeerConnections to network telemetry.

* omit Endpoint for incoming connections.

* fix asset unit name display in goal account list (#633)

* Add --no-sig flag to goal clerk multisig sign (#647)

* add --no-sig flag to goal clerk multisig sign

* update err message

* change preimage -> template

* change template -> information

* Scan for ledger wallets more often (#638)

* add more robust ledger scanning, fix infinite recursion bug

* fix comment

* undo scan change

* still delete wallets we fail to close

* Improve missing msig preimage error message (#648)

* improve missing msig preimage error message

* improve err msg

* Add support for https for telemetry servers (#649)

* Add support for https for telemetry servers.

* typo : udo -> udp

* Fixed few typos.

* goal listpartkeys display error (#641)

* Add logging for the telemetry server connections (#661)

* Add logging for the telemetry server connections.

* Revert unintended change.

* Improve error message.

* Avoid upgrading boost on travis Mac builds (#669)

* specify a boost version for the mac build.

* try to prevent boost update on travis mac builds.

* Build 9

* Abort algod startup if logging.config file has bad permissions (#662)

* This should prevent telemetry event loses on systems with
  invalid permissions on ~/.algorand/logging.config file
* Another possible workaround is to relax default config path mask in
  **cmd/goal/commands.go:ensureCacheDir** from 700 to 744.
  This is not implemented because of possible security risk.

Co-authored-by: Max Justicz <[email protected]>
Co-authored-by: algobolson <[email protected]>
Co-authored-by: Evan Richard <[email protected]>
Co-authored-by: pzbitskiy <[email protected]>

* update predicate

* Fix - Indexer now shows received transactions (#684) (#688)

-- Adding receiver function to transaction that returns the receiver of a transaction
-- Fix indexer to show received transactions

Co-authored-by: Rotem Hemo <[email protected]>

Co-authored-by: Max Justicz <[email protected]>
Co-authored-by: algobolson <[email protected]>
Co-authored-by: Evan Richard <[email protected]>
Co-authored-by: pzbitskiy <[email protected]>
Co-authored-by: Rotem Hemo <[email protected]>

Author: 6 people

data/transactions/transaction.go

@@ -412,6 +412,18 @@ func (tx Transaction) TxAmount() basics.MicroAlgos {
 	}
 }
 
+// GetReceiverAddress returns the address of the receiver. If the transaction has no receiver, it returns the empty address.
+func (tx Transaction) GetReceiverAddress() basics.Address {
+	switch tx.Type {
+	case protocol.PaymentTx:
+		return tx.PaymentTxnFields.Receiver
+	case protocol.AssetTransferTx:
+		return tx.AssetTransferTxnFields.AssetReceiver
+	default:
+		return basics.Address{}
+	}
+}
+
 // EstimateEncodedSize returns the estimated encoded size of the transaction including the signature.
 // This function is to be used for calculating the fee
 func (tx Transaction) EstimateEncodedSize() int {

node/indexer/db.go

@@ -124,7 +124,7 @@ func (idb *DB) AddBlock(b bookkeeping.Block) error {
 		}
 		for _, txad := range payset {
 			txn := txad.SignedTxn
-			_, err = stmt.Exec(txn.ID().String(), txn.Txn.Sender.String(), txn.Txn.Receiver.String(), b.Round(), b.TimeStamp)
+			_, err = stmt.Exec(txn.ID().String(), txn.Txn.Sender.String(), txn.Txn.GetReceiverAddress().String(), b.Round(), b.TimeStamp)
 			if err != nil {
 				return err
 			}

node/indexer/indexer_test.go

@@ -124,6 +124,31 @@ func (s *IndexSuite) TestIndexer_DuplicateRounds() {
 	}
 }
 
+func (s *IndexSuite) TestIndexer_Asset() {
+	query := "SELECT txid from transactions where (from_addr = $1 OR to_addr = $1)"
+	rows, err := s.idx.IDB.dbr.Handle.Query(query, s.addrs[0].String())
+	require.NoError(s.T(), err)
+	defer rows.Close()
+
+	txids := make(map[string]bool, 0)
+	var txid string
+	for rows.Next() {
+		err := rows.Scan(&txid)
+		require.NoError(s.T(), err)
+		txids[txid] = true
+	}
+
+	// make sure all txns are in list
+	for _, txn := range s.txns {
+		if txn.Txn.Type == protocol.AssetTransferTx {
+			if txn.Txn.Sender == s.addrs[0] || txn.Txn.AssetReceiver == s.addrs[0] {
+				require.True(s.T(), txids[txn.ID().String()])
+			}
+		}
+	}
+
+}
+
 func TestExampleTestSuite(t *testing.T) {
 	suite.Run(t, new(IndexSuite))
 }
@@ -201,17 +226,28 @@ func generateTestObjects(numTxs, numAccs int) ([]transactions.Transaction, []tra
 		exp := iss + 10
 
 		txs[i] = transactions.Transaction{
-			Type: protocol.PaymentTx,
 			Header: transactions.Header{
 				Sender:     addresses[s],
 				Fee:        basics.MicroAlgos{Raw: f},
 				FirstValid: basics.Round(iss),
 				LastValid:  basics.Round(exp),
 			},
-			PaymentTxnFields: transactions.PaymentTxnFields{
+		}
+
+		// Create half assets and half payment
+		if i%2 == 0 {
+			txs[i].Type = protocol.PaymentTx
+			txs[i].PaymentTxnFields = transactions.PaymentTxnFields{
 				Receiver: addresses[r],
 				Amount:   basics.MicroAlgos{Raw: uint64(a)},
-			},
+			}
+		} else {
+			txs[i].Type = protocol.AssetTransferTx
+			txs[i].AssetTransferTxnFields = transactions.AssetTransferTxnFields{
+				AssetReceiver: addresses[r],
+				AssetAmount:   uint64(a),
+				XferAsset:     basics.AssetIndex(uint64(rand.Intn(20000))),
+			}
 		}
 		signed[i] = txs[i].Sign(secrets[s])
 	}