Add Channel information to block-listener

1. channel info was notified on each listening 2. unmarshalled transaction data was displayed instead of Block.Data.Data Change-Id: Ibaf15c036194f2d8f1e9f3633fd34eaffb8dbb57 Signed-off-by: Hangyu Li <[email protected]>
hyperledger · Mar 10, 2017 · 626fcd3 · 626fcd3
1 parent 450b122
commit 626fcd3
Showing 1 changed file with 19 additions and 19 deletions.
diff --git a/examples/events/block-listener/block-listener.go b/examples/events/block-listener/block-listener.go
@@ -155,30 +155,30 @@ func main() {
 			fmt.Println("Received block")
 			fmt.Println("--------------")
 			txsFltr := util.TxValidationFlags(b.Block.Metadata.Metadata[common.BlockMetadataIndex_TRANSACTIONS_FILTER])
-
 			for i, r := range b.Block.Data.Data {
-				if txsFltr.IsInvalid(i) {
-					tx, _ := getTxPayload(r)
-					if tx != nil {
-						chdr, err := utils.UnmarshalChannelHeader(tx.Header.ChannelHeader)
-						if err != nil {
-							fmt.Print("Error extracting channel header\n")
-							return
-						}
-
+				tx, _ := getTxPayload(r)
+				if tx != nil {
+					chdr, err := utils.UnmarshalChannelHeader(tx.Header.ChannelHeader)
+					if err != nil {
+						fmt.Print("Error extracting channel header\n")
+						return
+					}
+					if txsFltr.IsInvalid(i) {
 						fmt.Println("")
 						fmt.Println("")
-						fmt.Println("Received invalid transaction")
+						fmt.Printf("Received invalid transaction from channel %s\n", chdr.ChannelId)
 						fmt.Println("--------------")
 						fmt.Printf("Transaction invalid: TxID: %s\n", chdr.TxId)
-					}
-				} else {
-					fmt.Printf("Transaction:\n\t[%v]\n", r)
-					if event, err := getChainCodeEvents(r); err == nil {
-						if len(chaincodeID) != 0 && event.ChaincodeId == chaincodeID {
-							fmt.Println("Received chaincode event")
-							fmt.Println("------------------------")
-							fmt.Printf("Chaincode Event:%+v\n", event)
+					} else {
+						fmt.Printf("Received transaction from channel %s: \n\t[%v]\n", chdr.ChannelId, tx)
+						if event, err := getChainCodeEvents(r); err == nil {
+							if len(chaincodeID) != 0 && event.ChaincodeId == chaincodeID {
+								fmt.Println("")
+								fmt.Println("")
+								fmt.Printf("Received chaincode event from channel %s\n", chdr.ChannelId)
+								fmt.Println("------------------------")
+								fmt.Printf("Chaincode Event:%+v\n", event)
+							}
 						}
 					}
 				}