(msg *pb.ChaincodeMessage)
| 571 | } |
| 572 | |
| 573 | func (h *Handler) Notify(msg *pb.ChaincodeMessage) { |
| 574 | tctx := h.TXContexts.Get(msg.ChannelId, msg.Txid) |
| 575 | if tctx == nil { |
| 576 | chaincodeLogger.Debugf("notifier Txid:%s, channelID:%s does not exist for handling message %s", msg.Txid, msg.ChannelId, msg.Type) |
| 577 | return |
| 578 | } |
| 579 | |
| 580 | chaincodeLogger.Debugf("[%s] notifying Txid:%s, channelID:%s", shorttxid(msg.Txid), msg.Txid, msg.ChannelId) |
| 581 | tctx.ResponseNotifier <- msg |
| 582 | tctx.CloseQueryIterators() |
| 583 | } |
| 584 | |
| 585 | // is this a txid for which there is a valid txsim |
| 586 | func (h *Handler) isValidTxSim(channelID string, txid string, fmtStr string, args ...any) (*TransactionContext, error) { |
no test coverage detected