Skip to content

Commit 0182554

Browse files
committed
More statusCallback
1 parent 26ef974 commit 0182554

File tree

3 files changed

+22
-12
lines changed

3 files changed

+22
-12
lines changed

plugins/alignments/src/PileupRPC/methods/GetGlobalValueForTag.ts

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -21,14 +21,17 @@ export default class PileupGetGlobalValueForTag extends PileupBaseRPC {
2121
},
2222
rpcDriver: string,
2323
) {
24-
const { adapterConfig, sessionId, regions, tag } =
25-
await this.deserializeArguments(args, rpcDriver)
24+
const deserializedArgs = await this.deserializeArguments(args, rpcDriver)
25+
const { adapterConfig, sessionId, regions, tag } = deserializedArgs
2626

2727
const dataAdapter = (
2828
await getAdapter(this.pluginManager, sessionId, adapterConfig)
2929
).dataAdapter as BaseFeatureDataAdapter
3030

31-
const features = dataAdapter.getFeaturesInMultipleRegions(regions)
31+
const features = dataAdapter.getFeaturesInMultipleRegions(
32+
regions,
33+
deserializedArgs,
34+
)
3235
const featuresArray = await firstValueFrom(features.pipe(toArray()))
3336
return [
3437
...new Set(

plugins/alignments/src/PileupRPC/methods/GetReducedFeatures.ts

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -25,14 +25,16 @@ export default class PileupGetReducedFeatures extends PileupBaseRPC {
2525
},
2626
rpcDriver: string,
2727
) {
28-
const des = await this.deserializeArguments(args, rpcDriver)
29-
const { adapterConfig, sessionId, regions } = des
28+
const deserializedArgs = await this.deserializeArguments(args, rpcDriver)
29+
const { adapterConfig, sessionId, regions } = deserializedArgs
3030
const dataAdapter = (
3131
await getAdapter(this.pluginManager, sessionId, adapterConfig)
3232
).dataAdapter as BaseFeatureDataAdapter
3333

3434
const featuresArray = await firstValueFrom(
35-
dataAdapter.getFeaturesInMultipleRegions(regions, des).pipe(toArray()),
35+
dataAdapter
36+
.getFeaturesInMultipleRegions(regions, deserializedArgs)
37+
.pipe(toArray()),
3638
)
3739

3840
const reduced = dedupe(

plugins/alignments/src/PileupRPC/methods/GetVisibleModifications.ts

Lines changed: 11 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -24,24 +24,29 @@ export default class PileupGetVisibleModifications extends PileupBaseRPC {
2424
},
2525
rpcDriver: string,
2626
) {
27-
const { adapterConfig, sessionId, regions } =
28-
await this.deserializeArguments(args, rpcDriver)
27+
const deserializeArguments = await this.deserializeArguments(
28+
args,
29+
rpcDriver,
30+
)
31+
const { adapterConfig, sessionId, regions } = deserializeArguments
2932
const dataAdapter = (
3033
await getAdapter(this.pluginManager, sessionId, adapterConfig)
3134
).dataAdapter as BaseFeatureDataAdapter
3235

3336
const featuresArray = await firstValueFrom(
34-
dataAdapter.getFeaturesInMultipleRegions(regions).pipe(toArray()),
37+
dataAdapter
38+
.getFeaturesInMultipleRegions(regions, deserializeArguments)
39+
.pipe(toArray()),
3540
)
3641

3742
const uniqueModifications = new Map<string, ModificationType>()
38-
featuresArray.forEach(f => {
39-
for (const mod of getModTypes(getTagAlt(f, 'MM', 'Mm') || '')) {
43+
for (const feat of featuresArray) {
44+
for (const mod of getModTypes(getTagAlt(feat, 'MM', 'Mm') || '')) {
4045
if (!uniqueModifications.has(mod.type)) {
4146
uniqueModifications.set(mod.type, mod)
4247
}
4348
}
44-
})
49+
}
4550
return [...uniqueModifications.values()]
4651
}
4752
}

0 commit comments

Comments
 (0)