@@ -82,27 +82,24 @@ const handleReferenceTokenAssetId = Cardano.AssetId.fromParts(
82
82
describe ( 'createHandlesTracker' , ( ) => {
83
83
it ( 'matches utxo$ assets to given handlePolicyIds and adds context from assetInfo$ and tip$ observables' , ( ) => {
84
84
createTestScheduler ( ) . run ( ( { hot, expectObservable } ) => {
85
- const utxo$ = hot ( '-ab-' , { a : utxo , b : utxo2 } ) ;
85
+ const utxo$ = hot ( '-ab-' , { a : utxo , b : utxo2 } ) ;
86
86
const assetInfo$ = hot ( '-a-b' , {
87
87
a : new Map ( ) ,
88
88
b : new Map ( [ [ handleAssetId , handleAssetInfo ] ] )
89
89
} ) ;
90
90
const handlePolicyIds$ = hot ( '-a--' , { a : [ handlePolicyId ] } ) ;
91
91
92
- const handles$ = createHandlesTracker (
93
- {
94
- assetInfo$,
95
- handlePolicyIds$,
96
- handleProvider : {
97
- getPolicyIds : async ( ) : Promise < Cardano . PolicyId [ ] > => [ handlePolicyId ] ,
98
- healthCheck : jest . fn ( ) ,
99
- resolveHandles : async ( ) => [ ]
100
- } ,
101
- logger,
102
- utxo$
92
+ const handles$ = createHandlesTracker ( {
93
+ assetInfo$,
94
+ handlePolicyIds$,
95
+ handleProvider : {
96
+ getPolicyIds : async ( ) : Promise < Cardano . PolicyId [ ] > => [ handlePolicyId ] ,
97
+ healthCheck : jest . fn ( ) ,
98
+ resolveHandles : async ( ) => [ ]
103
99
} ,
104
- { hydrateHandle : ( ) => hydrateHandle }
105
- ) ;
100
+ logger,
101
+ utxo$
102
+ } , { hydrateHandle : ( ) => hydrateHandle } ) ;
106
103
107
104
expectObservable ( handles$ ) . toBe ( '---ab' , {
108
105
a : [ expectedHandleInfo ] ,
@@ -113,7 +110,7 @@ describe('createHandlesTracker', () => {
113
110
114
111
it ( 'filters out handles that have total supply >1' , ( ) => {
115
112
createTestScheduler ( ) . run ( ( { hot, expectObservable } ) => {
116
- const utxo$ = hot ( '-a' , { a : utxo } ) ;
113
+ const utxo$ = hot ( '-a' , { a : utxo } ) ;
117
114
const assetInfo$ = hot ( '-a' , {
118
115
a : new Map ( [
119
116
[
@@ -127,46 +124,38 @@ describe('createHandlesTracker', () => {
127
124
} ) ;
128
125
const handlePolicyIds$ = hot ( '-a-' , { a : [ handlePolicyId ] } ) ;
129
126
130
- const handles$ = createHandlesTracker (
131
- {
132
- assetInfo$,
133
- handlePolicyIds$,
134
- handleProvider : {
135
- getPolicyIds : async ( ) : Promise < Cardano . PolicyId [ ] > => [ handlePolicyId ] ,
136
- healthCheck : jest . fn ( ) ,
137
- resolveHandles : async ( ) => [ ]
138
- } ,
139
- logger,
140
- utxo$
127
+ const handles$ = createHandlesTracker ( {
128
+ assetInfo$,
129
+ handlePolicyIds$,
130
+ handleProvider : {
131
+ getPolicyIds : async ( ) : Promise < Cardano . PolicyId [ ] > => [ handlePolicyId ] ,
132
+ healthCheck : jest . fn ( ) ,
133
+ resolveHandles : async ( ) => [ ]
141
134
} ,
142
- { hydrateHandle : ( ) => hydrateHandle }
143
- ) ;
135
+ logger,
136
+ utxo$
137
+ } , { hydrateHandle : ( ) => hydrateHandle } ) ;
144
138
145
139
expectObservable ( handles$ ) . toBe ( '-a' , { a : [ ] } ) ;
146
140
} ) ;
147
141
} ) ;
148
142
149
143
it ( 'filters out cip68 reference tokens' , ( ) => {
150
144
createTestScheduler ( ) . run ( ( { hot, expectObservable } ) => {
151
- const utxo$ = hot ( '-a' , {
152
- a : [
153
- [
154
- utxo [ 0 ] [ 0 ] ,
155
- {
156
- address : utxo [ 0 ] [ 1 ] . address ,
157
- value : {
158
- assets : new Map ( [ [ handleReferenceTokenAssetId , 1n ] ] ) ,
159
- coins : 9_825_963n
160
- }
161
- }
162
- ] as Cardano . Utxo
163
- ]
164
- } ) ;
145
+ const utxo$ = hot ( '-a' , { a : [ [ utxo [ 0 ] [ 0 ] , {
146
+ address : utxo [ 0 ] [ 1 ] . address ,
147
+ value : {
148
+ assets : new Map ( [
149
+ [ handleReferenceTokenAssetId , 1n ]
150
+ ] ) ,
151
+ coins : 9_825_963n
152
+ }
153
+ }
154
+ ] as Cardano . Utxo ] } ) ;
165
155
const assetInfo$ = hot ( '-a' , {
166
156
a : new Map ( [
167
157
[
168
- handleReferenceTokenAssetId ,
169
- {
158
+ handleReferenceTokenAssetId , {
170
159
...handleAssetInfo ,
171
160
supply : 1n
172
161
}
@@ -175,45 +164,39 @@ describe('createHandlesTracker', () => {
175
164
} ) ;
176
165
const handlePolicyIds$ = hot ( '-a-' , { a : [ handlePolicyId ] } ) ;
177
166
178
- const handles$ = createHandlesTracker (
179
- {
180
- assetInfo$,
181
- handlePolicyIds$,
182
- handleProvider : {
183
- getPolicyIds : async ( ) : Promise < Cardano . PolicyId [ ] > => [ handlePolicyId ] ,
184
- healthCheck : jest . fn ( ) ,
185
- resolveHandles : async ( ) => [ ]
186
- } ,
187
- logger,
188
- utxo$
167
+ const handles$ = createHandlesTracker ( {
168
+ assetInfo$,
169
+ handlePolicyIds$,
170
+ handleProvider : {
171
+ getPolicyIds : async ( ) : Promise < Cardano . PolicyId [ ] > => [ handlePolicyId ] ,
172
+ healthCheck : jest . fn ( ) ,
173
+ resolveHandles : async ( ) => [ ]
189
174
} ,
190
- { hydrateHandle : ( ) => hydrateHandle }
191
- ) ;
175
+ logger,
176
+ utxo$
177
+ } , { hydrateHandle : ( ) => hydrateHandle } ) ;
192
178
193
179
expectObservable ( handles$ ) . toBe ( '-a' , { a : [ ] } ) ;
194
180
} ) ;
195
181
} ) ;
196
182
197
183
it ( 'does not emit duplicates with no changes' , ( ) => {
198
184
createTestScheduler ( ) . run ( ( { hot, expectObservable } ) => {
199
- const utxo$ = hot ( '-a-' , { a : utxo } ) ;
200
- const assetInfo$ = hot ( '-aa' , { a : new Map ( [ [ handleAssetId , handleAssetInfo ] ] ) } ) ;
185
+ const utxo$ = hot ( '-a-' , { a : utxo } ) ;
186
+ const assetInfo$ = hot ( '-aa' , { a : new Map ( [ [ handleAssetId , handleAssetInfo ] ] ) } ) ;
201
187
const handlePolicyIds$ = hot ( '-a-' , { a : [ handlePolicyId ] } ) ;
202
188
203
- const handles$ = createHandlesTracker (
204
- {
205
- assetInfo$,
206
- handlePolicyIds$,
207
- handleProvider : {
208
- getPolicyIds : async ( ) : Promise < Cardano . PolicyId [ ] > => [ handlePolicyId ] ,
209
- healthCheck : jest . fn ( ) ,
210
- resolveHandles : async ( ) => [ ]
211
- } ,
212
- logger,
213
- utxo$
189
+ const handles$ = createHandlesTracker ( {
190
+ assetInfo$,
191
+ handlePolicyIds$,
192
+ handleProvider : {
193
+ getPolicyIds : async ( ) : Promise < Cardano . PolicyId [ ] > => [ handlePolicyId ] ,
194
+ healthCheck : jest . fn ( ) ,
195
+ resolveHandles : async ( ) => [ ]
214
196
} ,
215
- { hydrateHandle : ( ) => hydrateHandle }
216
- ) ;
197
+ logger,
198
+ utxo$
199
+ } , { hydrateHandle : ( ) => hydrateHandle } ) ;
217
200
218
201
expectObservable ( handles$ ) . toBe ( '-ab' , {
219
202
a : [ expectedHandleInfo ] ,
@@ -224,25 +207,22 @@ describe('createHandlesTracker', () => {
224
207
225
208
it ( 'shares a single subscription to dependency observables' , ( ) => {
226
209
createTestScheduler ( ) . run ( ( { hot, expectSubscriptions } ) => {
227
- const utxo$ = hot ( '-a' , { a : utxo } ) ;
210
+ const utxo$ = hot ( '-a' , { a : utxo } ) ;
228
211
const assetInfo$ = hot ( '-a' , {
229
212
a : new Map ( [ [ handleAssetId , handleAssetInfo ] ] )
230
213
} ) ;
231
214
const handlePolicyIds$ = hot ( 'a-' , { a : [ handlePolicyId ] } ) ;
232
- const handles$ = createHandlesTracker (
233
- {
234
- assetInfo$,
235
- handlePolicyIds$,
236
- handleProvider : {
237
- getPolicyIds : async ( ) : Promise < Cardano . PolicyId [ ] > => [ handlePolicyId ] ,
238
- healthCheck : jest . fn ( ) ,
239
- resolveHandles : async ( ) => [ ]
240
- } ,
241
- logger,
242
- utxo$
215
+ const handles$ = createHandlesTracker ( {
216
+ assetInfo$,
217
+ handlePolicyIds$,
218
+ handleProvider : {
219
+ getPolicyIds : async ( ) : Promise < Cardano . PolicyId [ ] > => [ handlePolicyId ] ,
220
+ healthCheck : jest . fn ( ) ,
221
+ resolveHandles : async ( ) => [ ]
243
222
} ,
244
- { hydrateHandle : ( ) => hydrateHandle }
245
- ) ;
223
+ logger,
224
+ utxo$
225
+ } , { hydrateHandle : ( ) => hydrateHandle } ) ;
246
226
combineLatest ( [ handles$ , handles$ ] ) . pipe ( take ( 1 ) ) . subscribe ( ) ;
247
227
expectSubscriptions ( utxo$ . subscriptions ) . toBe ( '^!' ) ;
248
228
expectSubscriptions ( assetInfo$ . subscriptions ) . toBe ( '^!' ) ;
0 commit comments