Commit 47483d4
committed
fix(roads): switch BAB flow feeds to datex2 MeasuredData, drop dead elaborated path
The 7 Autobahn GmbH BAB Mobilithek flow feeds were built against the
ElaboratedDataPublication / PredefinedLocationsPublication profile while
the offers were access-gated. Once granted, the live payloads turned out
to be standard MeasuredDataPublication (siteMeasurements > measuredValue >
basicData) joined to a MeasurementSiteTablePublication for geometry — the
datex-elaborated parser could not read them at all.
Reconfigure all 7 feeds to format "datex2" (+ measurementSiteReference /
MeasurementSiteTable siteTable) and remove the now-dead elaborated machinery:
flow-elaborated.ts, predefined-locations.ts, the datex-elaborated SourceFormat,
RoadFlow.volume, and their tests/fixtures.
firstDataNode now descends through the deeper
measuredValue > measuredValueExtension > measuredValues > basicData nesting
the BAB feeds use (NDW keeps the shallow path). Pinned by
flow-measured-autobahn.test.ts against the real payload shape, covering both
the buffered and streaming (production) parsers plus the Verortung join.1 parent de17e41 commit 47483d4
23 files changed
Lines changed: 165 additions & 815 deletions
File tree
- packages
- core/src
- roads
- atlas
- feeds/roads
- src
- __tests__
- fixtures
- autobahn-bab-datex2
- autobahn-bab
- services/ingest/src
- __tests__
- pipeline
- __tests__
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
26 | 26 | | |
27 | 27 | | |
28 | 28 | | |
29 | | - | |
30 | 29 | | |
31 | 30 | | |
32 | 31 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1236 | 1236 | | |
1237 | 1237 | | |
1238 | 1238 | | |
1239 | | - | |
| 1239 | + | |
1240 | 1240 | | |
1241 | 1241 | | |
1242 | 1242 | | |
| |||
1289 | 1289 | | |
1290 | 1290 | | |
1291 | 1291 | | |
1292 | | - | |
1293 | | - | |
| 1292 | + | |
1294 | 1293 | | |
1295 | 1294 | | |
1296 | 1295 | | |
1297 | 1296 | | |
1298 | 1297 | | |
1299 | | - | |
| 1298 | + | |
1300 | 1299 | | |
1301 | 1300 | | |
1302 | 1301 | | |
| |||
1349 | 1348 | | |
1350 | 1349 | | |
1351 | 1350 | | |
1352 | | - | |
1353 | | - | |
| 1351 | + | |
1354 | 1352 | | |
1355 | 1353 | | |
1356 | 1354 | | |
1357 | 1355 | | |
1358 | 1356 | | |
1359 | | - | |
| 1357 | + | |
1360 | 1358 | | |
1361 | 1359 | | |
1362 | 1360 | | |
| |||
1409 | 1407 | | |
1410 | 1408 | | |
1411 | 1409 | | |
1412 | | - | |
1413 | | - | |
| 1410 | + | |
1414 | 1411 | | |
1415 | 1412 | | |
1416 | 1413 | | |
1417 | 1414 | | |
1418 | 1415 | | |
1419 | | - | |
| 1416 | + | |
1420 | 1417 | | |
1421 | 1418 | | |
1422 | 1419 | | |
| |||
1469 | 1466 | | |
1470 | 1467 | | |
1471 | 1468 | | |
1472 | | - | |
1473 | | - | |
| 1469 | + | |
1474 | 1470 | | |
1475 | 1471 | | |
1476 | 1472 | | |
1477 | 1473 | | |
1478 | 1474 | | |
1479 | | - | |
| 1475 | + | |
1480 | 1476 | | |
1481 | 1477 | | |
1482 | 1478 | | |
| |||
1526 | 1522 | | |
1527 | 1523 | | |
1528 | 1524 | | |
1529 | | - | |
| 1525 | + | |
1530 | 1526 | | |
1531 | 1527 | | |
1532 | 1528 | | |
| |||
1579 | 1575 | | |
1580 | 1576 | | |
1581 | 1577 | | |
1582 | | - | |
1583 | | - | |
| 1578 | + | |
1584 | 1579 | | |
1585 | 1580 | | |
1586 | 1581 | | |
1587 | 1582 | | |
1588 | 1583 | | |
1589 | | - | |
| 1584 | + | |
1590 | 1585 | | |
1591 | 1586 | | |
1592 | 1587 | | |
| |||
1639 | 1634 | | |
1640 | 1635 | | |
1641 | 1636 | | |
1642 | | - | |
1643 | | - | |
| 1637 | + | |
1644 | 1638 | | |
1645 | 1639 | | |
1646 | 1640 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
860 | 860 | | |
861 | 861 | | |
862 | 862 | | |
863 | | - | |
864 | | - | |
| 863 | + | |
| 864 | + | |
865 | 865 | | |
866 | 866 | | |
867 | 867 | | |
868 | 868 | | |
869 | 869 | | |
870 | 870 | | |
871 | | - | |
| 871 | + | |
872 | 872 | | |
873 | 873 | | |
874 | 874 | | |
| |||
880 | 880 | | |
881 | 881 | | |
882 | 882 | | |
883 | | - | |
884 | 883 | | |
885 | 884 | | |
886 | 885 | | |
| |||
918 | 917 | | |
919 | 918 | | |
920 | 919 | | |
921 | | - | |
| 920 | + | |
922 | 921 | | |
923 | 922 | | |
924 | 923 | | |
925 | 924 | | |
926 | | - | |
| 925 | + | |
927 | 926 | | |
928 | 927 | | |
929 | 928 | | |
| |||
932 | 931 | | |
933 | 932 | | |
934 | 933 | | |
935 | | - | |
936 | 934 | | |
937 | 935 | | |
938 | 936 | | |
| |||
970 | 968 | | |
971 | 969 | | |
972 | 970 | | |
973 | | - | |
| 971 | + | |
974 | 972 | | |
975 | 973 | | |
976 | 974 | | |
977 | 975 | | |
978 | | - | |
| 976 | + | |
979 | 977 | | |
980 | 978 | | |
981 | 979 | | |
| |||
984 | 982 | | |
985 | 983 | | |
986 | 984 | | |
987 | | - | |
988 | 985 | | |
989 | 986 | | |
990 | 987 | | |
| |||
1023 | 1020 | | |
1024 | 1021 | | |
1025 | 1022 | | |
1026 | | - | |
| 1023 | + | |
1027 | 1024 | | |
1028 | 1025 | | |
1029 | 1026 | | |
1030 | 1027 | | |
1031 | 1028 | | |
1032 | | - | |
| 1029 | + | |
1033 | 1030 | | |
1034 | 1031 | | |
1035 | 1032 | | |
| |||
1038 | 1035 | | |
1039 | 1036 | | |
1040 | 1037 | | |
1041 | | - | |
1042 | 1038 | | |
1043 | 1039 | | |
1044 | 1040 | | |
| |||
1075 | 1071 | | |
1076 | 1072 | | |
1077 | 1073 | | |
1078 | | - | |
1079 | | - | |
1080 | | - | |
1081 | | - | |
1082 | | - | |
| 1074 | + | |
| 1075 | + | |
| 1076 | + | |
| 1077 | + | |
| 1078 | + | |
| 1079 | + | |
1083 | 1080 | | |
1084 | 1081 | | |
1085 | 1082 | | |
1086 | | - | |
| 1083 | + | |
1087 | 1084 | | |
1088 | 1085 | | |
1089 | 1086 | | |
| |||
1122 | 1119 | | |
1123 | 1120 | | |
1124 | 1121 | | |
1125 | | - | |
1126 | | - | |
| 1122 | + | |
| 1123 | + | |
1127 | 1124 | | |
1128 | 1125 | | |
1129 | 1126 | | |
1130 | 1127 | | |
1131 | | - | |
| 1128 | + | |
1132 | 1129 | | |
1133 | 1130 | | |
1134 | 1131 | | |
| |||
1140 | 1137 | | |
1141 | 1138 | | |
1142 | 1139 | | |
1143 | | - | |
1144 | 1140 | | |
1145 | 1141 | | |
1146 | 1142 | | |
| |||
1183 | 1179 | | |
1184 | 1180 | | |
1185 | 1181 | | |
1186 | | - | |
| 1182 | + | |
1187 | 1183 | | |
1188 | 1184 | | |
1189 | 1185 | | |
| |||
1195 | 1191 | | |
1196 | 1192 | | |
1197 | 1193 | | |
1198 | | - | |
1199 | 1194 | | |
1200 | 1195 | | |
1201 | 1196 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
13 | 13 | | |
14 | 14 | | |
15 | 15 | | |
16 | | - | |
17 | | - | |
| 16 | + | |
18 | 17 | | |
19 | 18 | | |
20 | 19 | | |
| |||
441 | 440 | | |
442 | 441 | | |
443 | 442 | | |
444 | | - | |
445 | | - | |
446 | | - | |
447 | | - | |
448 | | - | |
449 | | - | |
450 | | - | |
451 | | - | |
452 | | - | |
453 | | - | |
454 | | - | |
455 | | - | |
| 443 | + | |
456 | 444 | | |
457 | 445 | | |
458 | 446 | | |
459 | 447 | | |
460 | 448 | | |
461 | 449 | | |
| 450 | + | |
| 451 | + | |
462 | 452 | | |
463 | 453 | | |
464 | 454 | | |
465 | 455 | | |
466 | | - | |
| 456 | + | |
467 | 457 | | |
468 | 458 | | |
469 | 459 | | |
| |||
474 | 464 | | |
475 | 465 | | |
476 | 466 | | |
477 | | - | |
| 467 | + | |
478 | 468 | | |
479 | 469 | | |
480 | 470 | | |
481 | 471 | | |
482 | 472 | | |
| 473 | + | |
| 474 | + | |
483 | 475 | | |
484 | 476 | | |
485 | | - | |
| 477 | + | |
486 | 478 | | |
487 | 479 | | |
488 | 480 | | |
489 | 481 | | |
490 | | - | |
491 | | - | |
492 | | - | |
493 | | - | |
494 | 482 | | |
495 | 483 | | |
496 | 484 | | |
| |||
Lines changed: 22 additions & 0 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
| 1 | + | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
| 6 | + | |
| 7 | + | |
| 8 | + | |
| 9 | + | |
| 10 | + | |
| 11 | + | |
| 12 | + | |
| 13 | + | |
| 14 | + | |
| 15 | + | |
| 16 | + | |
| 17 | + | |
| 18 | + | |
| 19 | + | |
| 20 | + | |
| 21 | + | |
| 22 | + | |
Lines changed: 17 additions & 0 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
| 1 | + | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
| 6 | + | |
| 7 | + | |
| 8 | + | |
| 9 | + | |
| 10 | + | |
| 11 | + | |
| 12 | + | |
| 13 | + | |
| 14 | + | |
| 15 | + | |
| 16 | + | |
| 17 | + | |
0 commit comments