@@ -20,6 +20,7 @@ import (
2020 "github.com/hyperledger-labs/fabric-smart-client/platform/fabric/core/generic/rwset"
2121 "github.com/hyperledger-labs/fabric-smart-client/platform/fabric/core/generic/vault"
2222 "github.com/hyperledger-labs/fabric-smart-client/platform/view/services/tracing"
23+ "github.com/hyperledger-labs/fabric-token-sdk/token/services/logging"
2324 "github.com/hyperledger-labs/fabric-token-sdk/token/services/network/common/rws/translator"
2425 "github.com/hyperledger-labs/fabric-token-sdk/token/services/network/driver"
2526 "github.com/hyperledger/fabric-protos-go/common"
@@ -93,10 +94,15 @@ func newEndorserDeliveryBasedLLMProvider(fnsp *fabric.NetworkServiceProvider, tr
9394 if err != nil {
9495 panic (err )
9596 }
97+ setupKey , err := keyTranslator .CreateSetupKey ()
98+ if err != nil {
99+ panic (err )
100+ }
96101 return NewDeliveryBasedLLMProvider (fnsp , tracerProvider , config , func (network , _ string ) events.EventInfoMapper [KeyInfo ] {
97102 return & endorserTxInfoMapper {
98103 network : network ,
99- prefix : prefix ,
104+ prefix1 : prefix ,
105+ prefix2 : setupKey ,
100106 }
101107 })
102108}
@@ -111,6 +117,7 @@ func (p *deliveryBasedLLMProvider) NewManager(network, channel string) (Listener
111117 return nil , err
112118 }
113119 flm , err := events .NewListenerManager [KeyInfo ](
120+ logging .MustGetLogger ("token-sdk.network.fabric.llm" ),
114121 p .config ,
115122 ch .Delivery (),
116123 & DeliveryScanQueryByID {
@@ -149,7 +156,8 @@ func (m *deliveryBasedLLM) RemoveLookupListener(key string, listener Listener) e
149156
150157type endorserTxInfoMapper struct {
151158 network string
152- prefix string
159+ prefix1 string
160+ prefix2 string
153161}
154162
155163func (m * endorserTxInfoMapper ) MapTxData (ctx context.Context , tx []byte , block * common.BlockMetadata , blockNum driver2.BlockNum , txNum driver2.TxNum ) (map [driver2.Namespace ]KeyInfo , error ) {
@@ -193,9 +201,9 @@ func (m *endorserTxInfoMapper) mapTxInfo(rwSet vault2.ReadWriteSet, txID string)
193201 txInfos := make (map [driver2.Namespace ]KeyInfo , len (rwSet .WriteSet .Writes ))
194202 logger .Debugf ("TX [%s] has %d namespaces" , txID , len (rwSet .WriteSet .Writes ))
195203 for ns , writes := range rwSet .WriteSet .Writes {
196- logger .Debugf ("TX [%s:%s] has %d writes" , txID , ns , len (writes ))
204+ logger .Debugf ("TX [%s:%s] has [%d] writes" , txID , ns , len (writes ))
197205 for key , value := range writes {
198- if strings .HasPrefix (key , m .prefix ) {
206+ if strings .HasPrefix (key , m .prefix1 ) || strings . HasPrefix ( key , m . prefix2 ) {
199207 logger .Debugf ("TX [%s:%s] does have key [%s]." , txID , ns , key )
200208 txInfos [ns ] = KeyInfo {
201209 Namespace : ns ,
0 commit comments