1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
|
// Gets the total duration and contribution count from a list of contributions,
// respecting their `countInContributionTotals` and `countInDurationTotals`
// flags.
import {input, templateCompositeFrom} from '#composite';
import {
withFilteredList,
withPropertiesFromList,
withPropertyFromList,
withSum,
withUniqueItemsOnly,
} from '#composite/data';
export default templateCompositeFrom({
annotation: `withContributionListSums`,
inputs: {
list: input({type: 'array'}),
},
outputs: [
'#contributionListCount',
'#contributionListDuration',
],
steps: () => [
withPropertiesFromList({
list: input('list'),
properties: input.value([
'countInContributionTotals',
'countInDurationTotals',
]),
}),
withFilteredList({
list: input('list'),
filter: '#list.countInContributionTotals',
}).outputs({
'#filteredList': '#contributionsForCounting',
}),
withFilteredList({
list: input('list'),
filter: '#list.countInDurationTotals',
}).outputs({
'#filteredList': '#contributionsForDuration',
}),
{
dependencies: ['#contributionsForCounting'],
compute: (continuation, {
['#contributionsForCounting']: contributionsForCounting,
}) => continuation({
['#count']:
contributionsForCounting.length,
}),
},
withPropertyFromList({
list: '#contributionsForDuration',
property: input.value('thing'),
}),
// Don't double-up the durations for a track where the artist has multiple
// contributions.
withUniqueItemsOnly({
list: '#contributionsForDuration.thing',
}),
withPropertyFromList({
list: '#contributionsForDuration.thing',
property: input.value('duration'),
}).outputs({
'#contributionsForDuration.thing.duration': '#durationValues',
}),
{
dependencies: [
input('list'),
'#contributionsForDuration.thing',
'#durationValues',
],
compute: (continuation, opts) => {
console.log(opts);
return continuation();
},
},
withSum({
values: '#durationValues',
}).outputs({
'#sum': '#duration',
}),
{
dependencies: ['#count', '#duration'],
compute: (continuation, {
['#count']: count,
['#duration']: duration,
}) => continuation({
['#contributionListCount']: count,
['#contributionListDuration']: duration,
}),
},
],
});
|
