File size: 3,649 Bytes
ee888e1 | 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 | import {
CHINA_MACRO_REQUIRED_SERIES,
CHINA_MACRO_SCHEMA_VERSION,
CHINA_MACRO_SERIES_IDS,
} from '../_china-macro-contract.mjs';
const PILLARS = [
'activity',
'investment_property',
'credit_liquidity',
'external_pressure',
'trade',
];
export function buildChinaMacroPillars(observations) {
return PILLARS.map((pillar) => {
const candidates = observations.filter((observation) => observation.pillar === pillar);
const comparable = candidates.filter((observation) => (
Number.isFinite(observation.value)
&& !observation.stale
&& observation.direction !== 'unavailable'
));
const comparisonFrames = new Set(comparable.map((observation) => (
`${observation.observationPeriod}|${observation.periodKind}|${observation.comparisonBasis}`
)));
const directions = [...new Set(comparable.map((observation) => observation.direction))];
const comparableFrame = comparisonFrames.size <= 1;
return {
pillar,
direction: comparableFrame && directions.length === 1 ? directions[0] : 'unavailable',
reason: !comparableFrame
? 'INCOMPARABLE_PERIOD_OR_BASIS'
: directions.length === 0
? 'NO_AVAILABLE_OFFICIAL_OBSERVATION'
: directions.length === 1
? 'CONSISTENT_AVAILABLE_OBSERVATIONS'
: 'MIXED_OFFICIAL_SIGNALS',
observationIds: candidates.map((observation) => observation.seriesId),
};
});
}
export function buildChinaMacroSnapshot({
observations,
sourceDecisions,
generatedAt = new Date().toISOString(),
transportLastSuccessAt,
}) {
const seriesOrder = new Map(CHINA_MACRO_SERIES_IDS.map((seriesId, index) => [seriesId, index]));
observations = [...observations].sort((left, right) => (
(seriesOrder.get(left.seriesId) ?? Number.MAX_SAFE_INTEGER)
- (seriesOrder.get(right.seriesId) ?? Number.MAX_SAFE_INTEGER)
));
const launchReady = CHINA_MACRO_REQUIRED_SERIES.every((seriesId) => {
const observation = observations.find((item) => item.seriesId === seriesId);
return observation
&& Number.isFinite(observation.value)
&& !observation.stale
&& !observation.unavailableReason
&& observation.provenance
&& typeof observation.provenance === 'object'
&& !Array.isArray(observation.provenance);
});
const requiredDates = CHINA_MACRO_REQUIRED_SERIES
.map((seriesId) => observations.find((item) => item.seriesId === seriesId)?.observationPeriod)
.filter(Boolean)
.sort();
const hasUnavailable = observations.some((observation) => !Number.isFinite(observation.value));
const requiredTransportTimes = CHINA_MACRO_REQUIRED_SERIES
.map((seriesId) => {
const observation = observations.find((item) => item.seriesId === seriesId);
return observation?.provenance
?.claims?.transport_freshness?.value?.lastSuccessAt
|| observation?.retrievalTime;
})
.filter((value) => Number.isFinite(Date.parse(value)))
.sort();
return {
schemaVersion: CHINA_MACRO_SCHEMA_VERSION,
countryCode: 'CN',
generatedAt,
transportLastSuccessAt: transportLastSuccessAt || requiredTransportTimes[0] || '',
status: launchReady
? (hasUnavailable ? 'degraded' : 'ready')
: (observations.some((observation) => Number.isFinite(observation.value)) ? 'degraded' : 'unavailable'),
launchReady,
contentObservationDate: launchReady && requiredDates.length === CHINA_MACRO_REQUIRED_SERIES.length
? requiredDates[0]
: '',
latestObservationDate: requiredDates.at(-1) || '',
observations,
pillars: buildChinaMacroPillars(observations),
sourceDecisions,
};
}
|