@@ -8,7 +8,6 @@ package notifier
8
8
9
9
import (
10
10
driver2 "github.com/hyperledger-labs/fabric-smart-client/platform/common/driver"
11
- "github.com/hyperledger-labs/fabric-smart-client/platform/common/utils"
12
11
"github.com/hyperledger-labs/fabric-smart-client/platform/view/services/db/driver"
13
12
)
14
13
@@ -35,7 +34,7 @@ func (db *UnversionedPersistenceNotifier[P]) SetState(ns driver2.Namespace, key
35
34
if len (val ) == 0 {
36
35
op = driver .Delete
37
36
}
38
- db .Notifier .EnqueueEvent (op , map [driver.ColumnKey ]string {"ns" : ns , "pkey" : utils . EncodeByteA ( key ) })
37
+ db .Notifier .EnqueueEvent (op , map [driver.ColumnKey ]string {"ns" : ns , "pkey" : key })
39
38
return nil
40
39
}
41
40
@@ -48,7 +47,7 @@ func (db *UnversionedPersistenceNotifier[P]) SetStates(ns driver2.Namespace, kvs
48
47
if len (val ) == 0 {
49
48
op = driver .Delete
50
49
}
51
- db .Notifier .EnqueueEvent (op , map [driver.ColumnKey ]string {"ns" : ns , "pkey" : utils . EncodeByteA ( key ) })
50
+ db .Notifier .EnqueueEvent (op , map [driver.ColumnKey ]string {"ns" : ns , "pkey" : key })
52
51
}
53
52
}
54
53
@@ -77,7 +76,7 @@ func (db *UnversionedPersistenceNotifier[P]) DeleteState(ns driver2.Namespace, k
77
76
if err := db .Persistence .DeleteState (ns , key ); err != nil {
78
77
return err
79
78
}
80
- db .Notifier .EnqueueEvent (driver .Delete , map [driver.ColumnKey ]string {"ns" : ns , "pkey" : utils . EncodeByteA ( key ) })
79
+ db .Notifier .EnqueueEvent (driver .Delete , map [driver.ColumnKey ]string {"ns" : ns , "pkey" : key })
81
80
return nil
82
81
}
83
82
@@ -86,7 +85,7 @@ func (db *UnversionedPersistenceNotifier[P]) DeleteStates(namespace driver2.Name
86
85
87
86
for _ , key := range keys {
88
87
if _ , ok := errs [key ]; ! ok {
89
- db .Notifier .EnqueueEvent (driver .Delete , map [driver.ColumnKey ]string {"ns" : namespace , "pkey" : utils . EncodeByteA ( key ) })
88
+ db .Notifier .EnqueueEvent (driver .Delete , map [driver.ColumnKey ]string {"ns" : namespace , "pkey" : key })
90
89
}
91
90
}
92
91
@@ -133,7 +132,7 @@ func (db *VersionedPersistenceNotifier[P]) SetState(namespace driver2.Namespace,
133
132
if err := db .Persistence .SetState (namespace , key , value ); err != nil {
134
133
return err
135
134
}
136
- db .Notifier .EnqueueEvent (driver .Update , map [driver.ColumnKey ]string {"ns" : namespace , "pkey" : utils . EncodeByteA ( key ) })
135
+ db .Notifier .EnqueueEvent (driver .Update , map [driver.ColumnKey ]string {"ns" : namespace , "pkey" : key })
137
136
return nil
138
137
}
139
138
@@ -142,7 +141,7 @@ func (db *VersionedPersistenceNotifier[P]) SetStates(ns driver2.Namespace, kvs m
142
141
143
142
for key := range kvs {
144
143
if _ , ok := errs [key ]; ! ok {
145
- db .Notifier .EnqueueEvent (driver .Update , map [driver.ColumnKey ]string {"ns" : ns , "pkey" : utils . EncodeByteA ( key ) })
144
+ db .Notifier .EnqueueEvent (driver .Update , map [driver.ColumnKey ]string {"ns" : ns , "pkey" : key })
146
145
}
147
146
}
148
147
@@ -154,7 +153,7 @@ func (db *VersionedPersistenceNotifier[P]) DeleteStates(namespace driver2.Namesp
154
153
155
154
for _ , key := range keys {
156
155
if _ , ok := errs [key ]; ! ok {
157
- db .Notifier .EnqueueEvent (driver .Delete , map [driver.ColumnKey ]string {"ns" : namespace , "pkey" : utils . EncodeByteA ( key ) })
156
+ db .Notifier .EnqueueEvent (driver .Delete , map [driver.ColumnKey ]string {"ns" : namespace , "pkey" : key })
158
157
}
159
158
}
160
159
@@ -183,7 +182,7 @@ func (db *VersionedPersistenceNotifier[P]) DeleteState(ns driver2.Namespace, key
183
182
if err := db .Persistence .DeleteState (ns , key ); err != nil {
184
183
return err
185
184
}
186
- db .Notifier .EnqueueEvent (driver .Delete , map [driver.ColumnKey ]string {"ns" : ns , "pkey" : utils . EncodeByteA ( key ) })
185
+ db .Notifier .EnqueueEvent (driver .Delete , map [driver.ColumnKey ]string {"ns" : ns , "pkey" : key })
187
186
return nil
188
187
}
189
188
0 commit comments