Skip to content

Commit 626fcd3

Browse files
committed
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]>
1 parent 450b122 commit 626fcd3

File tree

1 file changed

+19
-19
lines changed

1 file changed

+19
-19
lines changed

examples/events/block-listener/block-listener.go

+19-19
Original file line numberDiff line numberDiff line change
@@ -155,30 +155,30 @@ func main() {
155155
fmt.Println("Received block")
156156
fmt.Println("--------------")
157157
txsFltr := util.TxValidationFlags(b.Block.Metadata.Metadata[common.BlockMetadataIndex_TRANSACTIONS_FILTER])
158-
159158
for i, r := range b.Block.Data.Data {
160-
if txsFltr.IsInvalid(i) {
161-
tx, _ := getTxPayload(r)
162-
if tx != nil {
163-
chdr, err := utils.UnmarshalChannelHeader(tx.Header.ChannelHeader)
164-
if err != nil {
165-
fmt.Print("Error extracting channel header\n")
166-
return
167-
}
168-
159+
tx, _ := getTxPayload(r)
160+
if tx != nil {
161+
chdr, err := utils.UnmarshalChannelHeader(tx.Header.ChannelHeader)
162+
if err != nil {
163+
fmt.Print("Error extracting channel header\n")
164+
return
165+
}
166+
if txsFltr.IsInvalid(i) {
169167
fmt.Println("")
170168
fmt.Println("")
171-
fmt.Println("Received invalid transaction")
169+
fmt.Printf("Received invalid transaction from channel %s\n", chdr.ChannelId)
172170
fmt.Println("--------------")
173171
fmt.Printf("Transaction invalid: TxID: %s\n", chdr.TxId)
174-
}
175-
} else {
176-
fmt.Printf("Transaction:\n\t[%v]\n", r)
177-
if event, err := getChainCodeEvents(r); err == nil {
178-
if len(chaincodeID) != 0 && event.ChaincodeId == chaincodeID {
179-
fmt.Println("Received chaincode event")
180-
fmt.Println("------------------------")
181-
fmt.Printf("Chaincode Event:%+v\n", event)
172+
} else {
173+
fmt.Printf("Received transaction from channel %s: \n\t[%v]\n", chdr.ChannelId, tx)
174+
if event, err := getChainCodeEvents(r); err == nil {
175+
if len(chaincodeID) != 0 && event.ChaincodeId == chaincodeID {
176+
fmt.Println("")
177+
fmt.Println("")
178+
fmt.Printf("Received chaincode event from channel %s\n", chdr.ChannelId)
179+
fmt.Println("------------------------")
180+
fmt.Printf("Chaincode Event:%+v\n", event)
181+
}
182182
}
183183
}
184184
}

0 commit comments

Comments
 (0)