+300 -73

Cargo.lock

··· 112 112 113 113 [[package]] 114 114 name = "anyhow" 115 115 - version = "1.0.97" 115 115 + version = "1.0.100" 116 116 source = "registry+https://github.com/rust-lang/crates.io-index" 117 117 - checksum = "dcfed56ad506cb2c684a14971b8861fdc3baaaae314b9e5f9bb532cbe3ba7a4f" 117 117 + checksum = "a23eb6b1614318a8071c9b2521f36b424b2c83db5eb3a0fead4a6c0809af6e61" 118 118 119 119 [[package]] 120 120 name = "arbitrary" ··· 127 127 version = "1.7.1" 128 128 source = "registry+https://github.com/rust-lang/crates.io-index" 129 129 checksum = "69f7f8c3906b62b754cd5326047894316021dcfe5a194c8ea52bdd94934a3457" 130 130 + 131 131 + [[package]] 132 132 + name = "arrayref" 133 133 + version = "0.3.9" 134 134 + source = "registry+https://github.com/rust-lang/crates.io-index" 135 135 + checksum = "76a2e8124351fda1ef8aaaa3bbd7ebbcb486bbcd4225aca0aa0d84bb2db8fecb" 130 136 131 137 [[package]] 132 138 name = "arrayvec" ··· 192 198 "nom", 193 199 "num-traits", 194 200 "rusticata-macros", 195 195 - "thiserror 2.0.16", 201 201 + "thiserror 2.0.17", 196 202 "time", 197 203 ] 198 204 ··· 644 650 "axum", 645 651 "handlebars", 646 652 "serde", 647 647 - "thiserror 2.0.16", 653 653 + "thiserror 2.0.17", 648 654 ] 649 655 650 656 [[package]] ··· 673 679 version = "0.2.0" 674 680 source = "registry+https://github.com/rust-lang/crates.io-index" 675 681 checksum = "4c7f02d4ea65f2c1853089ffd8d2787bdbc63de2f0d29dedbcf8ccdfa0ccd4cf" 682 682 + 683 683 + [[package]] 684 684 + name = "base256emoji" 685 685 + version = "1.0.2" 686 686 + source = "registry+https://github.com/rust-lang/crates.io-index" 687 687 + checksum = "b5e9430d9a245a77c92176e649af6e275f20839a48389859d1661e9a128d077c" 688 688 + dependencies = [ 689 689 + "const-str", 690 690 + "match-lookup", 691 691 + ] 676 692 677 693 [[package]] 678 694 name = "base64" ··· 812 828 checksum = "5c8214115b7bf84099f1309324e63141d4c5d7cc26862f97a0a857dbefe165bd" 813 829 814 830 [[package]] 831 831 + name = "blake3" 832 832 + version = "1.8.2" 833 833 + source = "registry+https://github.com/rust-lang/crates.io-index" 834 834 + checksum = "3888aaa89e4b2a40fca9848e400f6a658a5a3978de7be858e209cafa8be9a4a0" 835 835 + dependencies = [ 836 836 + "arrayref", 837 837 + "arrayvec", 838 838 + "cc", 839 839 + "cfg-if", 840 840 + "constant_time_eq", 841 841 + ] 842 842 + 843 843 + [[package]] 815 844 name = "block-buffer" 816 845 version = "0.10.4" 817 846 source = "registry+https://github.com/rust-lang/crates.io-index" ··· 839 868 checksum = "1fd0f2584146f6f2ef48085050886acf353beff7305ebd1ae69500e27c67f64b" 840 869 841 870 [[package]] 871 871 + name = "byteorder-lite" 872 872 + version = "0.1.0" 873 873 + source = "registry+https://github.com/rust-lang/crates.io-index" 874 874 + checksum = "8f1fe948ff07f4bd06c30984e69f5b4899c516a3ef74f34df92a2df2ab535495" 875 875 + 876 876 + [[package]] 842 877 name = "bytes" 843 878 version = "1.10.1" 844 879 source = "registry+https://github.com/rust-lang/crates.io-index" ··· 851 886 checksum = "6236364b88b9b6d0bc181ba374cf1ab55ba3ef97a1cb6f8cddad48a273767fb5" 852 887 853 888 [[package]] 889 889 + name = "byteview" 890 890 + version = "0.8.0" 891 891 + source = "registry+https://github.com/rust-lang/crates.io-index" 892 892 + checksum = "1e6b0e42e210b794e14b152c6fe1a55831e30ef4a0f5dc39d73d714fb5f1906c" 893 893 + 894 894 + [[package]] 854 895 name = "bzip2-sys" 855 896 version = "0.1.13+1.0.8" 856 897 source = "registry+https://github.com/rust-lang/crates.io-index" ··· 890 931 "enum_dispatch", 891 932 "serde", 892 933 ] 934 934 + 935 935 + [[package]] 936 936 + name = "cbor4ii" 937 937 + version = "0.2.14" 938 938 + source = "registry+https://github.com/rust-lang/crates.io-index" 939 939 + checksum = "b544cf8c89359205f4f990d0e6f3828db42df85b5dac95d09157a250eb0749c4" 940 940 + dependencies = [ 941 941 + "serde", 942 942 + ] 943 943 + 944 944 + [[package]] 945 945 + name = "cbor4ii" 946 946 + version = "1.2.0" 947 947 + source = "registry+https://github.com/rust-lang/crates.io-index" 948 948 + checksum = "b28d2802395e3bccd95cc4ae984bff7444b6c1f5981da46a41360c42a2c7e2d9" 893 949 894 950 [[package]] 895 951 name = "cc" ··· 976 1032 "multihash", 977 1033 "serde", 978 1034 "serde_bytes", 979 979 - "unsigned-varint", 1035 1035 + "unsigned-varint 0.8.0", 980 1036 ] 981 1037 982 1038 [[package]] ··· 992 1048 993 1049 [[package]] 994 1050 name = "clap" 995 995 - version = "4.5.47" 1051 1051 + version = "4.5.48" 996 1052 source = "registry+https://github.com/rust-lang/crates.io-index" 997 997 - checksum = "7eac00902d9d136acd712710d71823fb8ac8004ca445a89e73a41d45aa712931" 1053 1053 + checksum = "e2134bb3ea021b78629caa971416385309e0131b351b25e01dc16fb54e1b5fae" 998 1054 dependencies = [ 999 1055 "clap_builder", 1000 1056 "clap_derive", ··· 1002 1058 1003 1059 [[package]] 1004 1060 name = "clap_builder" 1005 1005 - version = "4.5.47" 1061 1061 + version = "4.5.48" 1006 1062 source = "registry+https://github.com/rust-lang/crates.io-index" 1007 1007 - checksum = "2ad9bbf750e73b5884fb8a211a9424a1906c1e156724260fdae972f31d70e1d6" 1063 1063 + checksum = "c2ba64afa3c0a6df7fa517765e31314e983f51dda798ffba27b988194fb65dc9" 1008 1064 dependencies = [ 1009 1065 "anstream", 1010 1066 "anstyle", ··· 1085 1141 version = "0.9.6" 1086 1142 source = "registry+https://github.com/rust-lang/crates.io-index" 1087 1143 checksum = "c2459377285ad874054d797f3ccebf984978aa39129f6eafde5cdc8315b612f8" 1144 1144 + 1145 1145 + [[package]] 1146 1146 + name = "const-str" 1147 1147 + version = "0.4.3" 1148 1148 + source = "registry+https://github.com/rust-lang/crates.io-index" 1149 1149 + checksum = "2f421161cb492475f1661ddc9815a745a1c894592070661180fdec3d4872e9c3" 1150 1150 + 1151 1151 + [[package]] 1152 1152 + name = "constant_time_eq" 1153 1153 + version = "0.3.1" 1154 1154 + source = "registry+https://github.com/rust-lang/crates.io-index" 1155 1155 + checksum = "7c74b8349d32d297c9134b8c88677813a227df8f779daa29bfc29c183fe3dca6" 1088 1156 1089 1157 [[package]] 1090 1158 name = "constellation" ··· 1353 1421 ] 1354 1422 1355 1423 [[package]] 1424 1424 + name = "dasl" 1425 1425 + version = "0.2.0" 1426 1426 + source = "registry+https://github.com/rust-lang/crates.io-index" 1427 1427 + checksum = "b59666035a4386b0fd272bd78da4cbc3ccb558941e97579ab00f0eb4639f2a49" 1428 1428 + dependencies = [ 1429 1429 + "blake3", 1430 1430 + "cbor4ii 1.2.0", 1431 1431 + "data-encoding", 1432 1432 + "data-encoding-macro", 1433 1433 + "scopeguard", 1434 1434 + "serde", 1435 1435 + "serde_bytes", 1436 1436 + "sha2", 1437 1437 + "thiserror 2.0.17", 1438 1438 + ] 1439 1439 + 1440 1440 + [[package]] 1356 1441 name = "data-encoding" 1357 1357 - version = "2.8.0" 1442 1442 + version = "2.9.0" 1358 1443 source = "registry+https://github.com/rust-lang/crates.io-index" 1359 1359 - checksum = "575f75dfd25738df5b91b8e43e14d44bda14637a58fae779fd2b064f8bf3e010" 1444 1444 + checksum = "2a2330da5de22e8a3cb63252ce2abb30116bf5265e89c0e01bc17015ce30a476" 1360 1445 1361 1446 [[package]] 1362 1447 name = "data-encoding-macro" 1363 1363 - version = "0.1.17" 1448 1448 + version = "0.1.18" 1364 1449 source = "registry+https://github.com/rust-lang/crates.io-index" 1365 1365 - checksum = "9f9724adfcf41f45bf652b3995837669d73c4d49a1b5ac1ff82905ac7d9b5558" 1450 1450 + checksum = "47ce6c96ea0102f01122a185683611bd5ac8d99e62bc59dd12e6bda344ee673d" 1366 1451 dependencies = [ 1367 1452 "data-encoding", 1368 1453 "data-encoding-macro-internal", ··· 1370 1455 1371 1456 [[package]] 1372 1457 name = "data-encoding-macro-internal" 1373 1373 - version = "0.1.15" 1458 1458 + version = "0.1.16" 1374 1459 source = "registry+https://github.com/rust-lang/crates.io-index" 1375 1375 - checksum = "18e4fdb82bd54a12e42fb58a800dcae6b9e13982238ce2296dc3570b92148e1f" 1460 1460 + checksum = "8d162beedaa69905488a8da94f5ac3edb4dd4788b732fadb7bd120b2625c1976" 1376 1461 dependencies = [ 1377 1462 "data-encoding", 1378 1378 - "syn 1.0.109", 1463 1463 + "syn 2.0.106", 1379 1464 ] 1380 1465 1381 1466 [[package]] ··· 1579 1664 "slog-bunyan", 1580 1665 "slog-json", 1581 1666 "slog-term", 1582 1582 - "thiserror 2.0.16", 1667 1667 + "thiserror 2.0.17", 1583 1668 "tokio", 1584 1669 "tokio-rustls 0.25.0", 1585 1670 "toml 0.9.7", ··· 1783 1868 checksum = "0b25ad44cd4360a0448a9b5a0a6f1c7a621101cca4578706d43c9a821418aebc" 1784 1869 dependencies = [ 1785 1870 "byteorder", 1786 1786 - "byteview", 1871 1871 + "byteview 0.6.1", 1787 1872 "dashmap", 1788 1873 "log", 1789 1789 - "lsm-tree", 1874 1874 + "lsm-tree 2.10.4", 1790 1875 "path-absolutize", 1791 1876 "std-semaphore", 1792 1877 "tempfile", ··· 1799 1884 source = "git+https://github.com/fjall-rs/fjall.git#42d811f7c8cc9004407d520d37d2a1d8d246c03d" 1800 1885 dependencies = [ 1801 1886 "byteorder", 1802 1802 - "byteview", 1887 1887 + "byteview 0.6.1", 1803 1888 "dashmap", 1804 1889 "log", 1805 1805 - "lsm-tree", 1890 1890 + "lsm-tree 2.10.4", 1806 1891 "path-absolutize", 1807 1892 "std-semaphore", 1808 1893 "tempfile", ··· 1810 1895 ] 1811 1896 1812 1897 [[package]] 1898 1898 + name = "fjall" 1899 1899 + version = "3.0.0-pre.0" 1900 1900 + source = "registry+https://github.com/rust-lang/crates.io-index" 1901 1901 + checksum = "467588c1f15d1cfa9e43f02a45cf55d82fa1f12a6ae961b848c520458525600c" 1902 1902 + dependencies = [ 1903 1903 + "byteorder-lite", 1904 1904 + "byteview 0.8.0", 1905 1905 + "dashmap", 1906 1906 + "log", 1907 1907 + "lsm-tree 3.0.0-pre.0", 1908 1908 + "std-semaphore", 1909 1909 + "tempfile", 1910 1910 + "xxhash-rust", 1911 1911 + ] 1912 1912 + 1913 1913 + [[package]] 1813 1914 name = "flate2" 1814 1915 version = "1.1.2" 1815 1916 source = "registry+https://github.com/rust-lang/crates.io-index" ··· 1891 1992 "mixtrics", 1892 1993 "pin-project", 1893 1994 "serde", 1894 1894 - "thiserror 2.0.16", 1995 1995 + "thiserror 2.0.17", 1895 1996 "tokio", 1896 1997 "tracing", 1897 1998 ] ··· 1911 2012 "parking_lot", 1912 2013 "pin-project", 1913 2014 "serde", 1914 1914 - "thiserror 2.0.16", 2015 2015 + "thiserror 2.0.17", 1915 2016 "tokio", 1916 2017 "twox-hash", 1917 2018 ] ··· 1944 2045 "parking_lot", 1945 2046 "pin-project", 1946 2047 "serde", 1947 1947 - "thiserror 2.0.16", 2048 2048 + "thiserror 2.0.17", 1948 2049 "tokio", 1949 2050 "tracing", 1950 2051 ] ··· 1976 2077 "pin-project", 1977 2078 "rand 0.9.1", 1978 2079 "serde", 1979 1979 - "thiserror 2.0.16", 2080 2080 + "thiserror 2.0.17", 1980 2081 "tokio", 1981 2082 "tracing", 1982 2083 "twox-hash", ··· 2220 2321 "pest_derive", 2221 2322 "serde", 2222 2323 "serde_json", 2223 2223 - "thiserror 2.0.16", 2324 2324 + "thiserror 2.0.17", 2224 2325 "walkdir", 2225 2326 ] 2226 2327 ··· 2345 2446 "once_cell", 2346 2447 "rand 0.9.1", 2347 2448 "ring", 2348 2348 - "thiserror 2.0.16", 2449 2449 + "thiserror 2.0.17", 2349 2450 "tinyvec", 2350 2451 "tokio", 2351 2452 "tracing", ··· 2368 2469 "rand 0.9.1", 2369 2470 "resolv-conf", 2370 2471 "smallvec", 2371 2371 - "thiserror 2.0.16", 2472 2472 + "thiserror 2.0.17", 2372 2473 "tokio", 2373 2474 "tracing", 2374 2475 ] ··· 2800 2901 ] 2801 2902 2802 2903 [[package]] 2904 2904 + name = "iroh-car" 2905 2905 + version = "0.5.1" 2906 2906 + source = "registry+https://github.com/rust-lang/crates.io-index" 2907 2907 + checksum = "cb7f8cd4cb9aa083fba8b52e921764252d0b4dcb1cd6d120b809dbfe1106e81a" 2908 2908 + dependencies = [ 2909 2909 + "anyhow", 2910 2910 + "cid", 2911 2911 + "futures", 2912 2912 + "serde", 2913 2913 + "serde_ipld_dagcbor", 2914 2914 + "thiserror 1.0.69", 2915 2915 + "tokio", 2916 2916 + "unsigned-varint 0.7.2", 2917 2917 + ] 2918 2918 + 2919 2919 + [[package]] 2803 2920 name = "is-terminal" 2804 2921 version = "0.4.16" 2805 2922 source = "registry+https://github.com/rust-lang/crates.io-index" ··· 2863 2980 "metrics", 2864 2981 "serde", 2865 2982 "serde_json", 2866 2866 - "thiserror 2.0.16", 2983 2983 + "thiserror 2.0.17", 2867 2984 "tokio", 2868 2985 "tokio-tungstenite 0.26.2", 2869 2986 "url", ··· 3045 3162 checksum = "fc2f4eb4bc735547cfed7c0a4922cbd04a4655978c09b54f1f7b228750664c34" 3046 3163 dependencies = [ 3047 3164 "cfg-if", 3048 3048 - "windows-targets 0.48.5", 3165 3165 + "windows-targets 0.52.6", 3049 3166 ] 3050 3167 3051 3168 [[package]] ··· 3116 3233 version = "0.1.0" 3117 3234 dependencies = [ 3118 3235 "anyhow", 3236 3236 + "dasl", 3119 3237 "fluent-uri", 3120 3238 "nom", 3121 3121 - "thiserror 2.0.16", 3239 3239 + "serde", 3240 3240 + "thiserror 2.0.17", 3122 3241 "tinyjson", 3123 3242 ] 3124 3243 ··· 3186 3305 3187 3306 [[package]] 3188 3307 name = "lsm-tree" 3189 3189 - version = "2.10.2" 3308 3308 + version = "2.10.4" 3190 3309 source = "registry+https://github.com/rust-lang/crates.io-index" 3191 3191 - checksum = "55b6d7475a8dd22e749186968daacf8e2a77932b061b1bd263157987bbfc0c6c" 3310 3310 + checksum = "799399117a2bfb37660e08be33f470958babb98386b04185288d829df362ea15" 3192 3311 dependencies = [ 3193 3312 "byteorder", 3194 3313 "crossbeam-skiplist", ··· 3209 3328 ] 3210 3329 3211 3330 [[package]] 3331 3331 + name = "lsm-tree" 3332 3332 + version = "3.0.0-pre.0" 3333 3333 + source = "registry+https://github.com/rust-lang/crates.io-index" 3334 3334 + checksum = "be375d45e348328e78582dffbda4f1709dd52fca27c1a81c7bf6ca134e6335f7" 3335 3335 + dependencies = [ 3336 3336 + "byteorder-lite", 3337 3337 + "byteview 0.8.0", 3338 3338 + "crossbeam-skiplist", 3339 3339 + "enum_dispatch", 3340 3340 + "interval-heap", 3341 3341 + "log", 3342 3342 + "lz4_flex", 3343 3343 + "quick_cache", 3344 3344 + "rustc-hash 2.1.1", 3345 3345 + "self_cell", 3346 3346 + "sfa", 3347 3347 + "tempfile", 3348 3348 + "varint-rs", 3349 3349 + "xxhash-rust", 3350 3350 + ] 3351 3351 + 3352 3352 + [[package]] 3212 3353 name = "lz4" 3213 3354 version = "1.28.1" 3214 3355 source = "registry+https://github.com/rust-lang/crates.io-index" ··· 3229 3370 3230 3371 [[package]] 3231 3372 name = "lz4_flex" 3232 3232 - version = "0.11.3" 3373 3373 + version = "0.11.5" 3233 3374 source = "registry+https://github.com/rust-lang/crates.io-index" 3234 3234 - checksum = "75761162ae2b0e580d7e7c390558127e5f01b4194debd6221fd8c207fc80e3f5" 3375 3375 + checksum = "08ab2867e3eeeca90e844d1940eab391c9dc5228783db2ed999acbc0a9ed375a" 3235 3376 3236 3377 [[package]] 3237 3378 name = "mach2" ··· 3297 3438 ] 3298 3439 3299 3440 [[package]] 3441 3441 + name = "match-lookup" 3442 3442 + version = "0.1.1" 3443 3443 + source = "registry+https://github.com/rust-lang/crates.io-index" 3444 3444 + checksum = "1265724d8cb29dbbc2b0f06fffb8bf1a8c0cf73a78eede9ba73a4a66c52a981e" 3445 3445 + dependencies = [ 3446 3446 + "proc-macro2", 3447 3447 + "quote", 3448 3448 + "syn 1.0.109", 3449 3449 + ] 3450 3450 + 3451 3451 + [[package]] 3300 3452 name = "match_cfg" 3301 3453 version = "0.1.0" 3302 3454 source = "registry+https://github.com/rust-lang/crates.io-index" ··· 3384 3536 "metrics", 3385 3537 "metrics-util 0.20.0", 3386 3538 "quanta", 3387 3387 - "thiserror 2.0.16", 3539 3539 + "thiserror 2.0.17", 3388 3540 "tokio", 3389 3541 "tracing", 3390 3542 ] ··· 3531 3683 3532 3684 [[package]] 3533 3685 name = "multibase" 3534 3534 - version = "0.9.1" 3686 3686 + version = "0.9.2" 3535 3687 source = "registry+https://github.com/rust-lang/crates.io-index" 3536 3536 - checksum = "9b3539ec3c1f04ac9748a260728e855f261b4977f5c3406612c884564f329404" 3688 3688 + checksum = "8694bb4835f452b0e3bb06dbebb1d6fc5385b6ca1caf2e55fd165c042390ec77" 3537 3689 dependencies = [ 3538 3690 "base-x", 3691 3691 + "base256emoji", 3539 3692 "data-encoding", 3540 3693 "data-encoding-macro", 3541 3694 ] ··· 3548 3701 dependencies = [ 3549 3702 "core2", 3550 3703 "serde", 3551 3551 - "unsigned-varint", 3704 3704 + "unsigned-varint 0.8.0", 3552 3705 ] 3553 3706 3554 3707 [[package]] ··· 3926 4079 checksum = "1db05f56d34358a8b1066f67cbb203ee3e7ed2ba674a6263a1d5ec6db2204323" 3927 4080 dependencies = [ 3928 4081 "memchr", 3929 3929 - "thiserror 2.0.16", 4082 4082 + "thiserror 2.0.17", 3930 4083 "ucd-trie", 3931 4084 ] 3932 4085 ··· 4036 4189 "rusqlite", 4037 4190 "serde", 4038 4191 "serde_json", 4039 4039 - "thiserror 2.0.16", 4192 4192 + "thiserror 2.0.17", 4040 4193 "tokio", 4041 4194 "tracing-subscriber", 4042 4195 ] ··· 4079 4232 "smallvec", 4080 4233 "sync_wrapper", 4081 4234 "tempfile", 4082 4082 - "thiserror 2.0.16", 4235 4235 + "thiserror 2.0.17", 4083 4236 "tokio", 4084 4237 "tokio-rustls 0.26.2", 4085 4238 "tokio-stream", ··· 4123 4276 "serde_json", 4124 4277 "serde_urlencoded", 4125 4278 "serde_yaml", 4126 4126 - "thiserror 2.0.16", 4279 4279 + "thiserror 2.0.17", 4127 4280 "tokio", 4128 4281 ] 4129 4282 ··· 4142 4295 "quote", 4143 4296 "regex", 4144 4297 "syn 2.0.106", 4145 4145 - "thiserror 2.0.16", 4298 4298 + "thiserror 2.0.17", 4146 4299 ] 4147 4300 4148 4301 [[package]] ··· 4269 4422 4270 4423 [[package]] 4271 4424 name = "quick_cache" 4272 4272 - version = "0.6.12" 4425 4425 + version = "0.6.16" 4273 4426 source = "registry+https://github.com/rust-lang/crates.io-index" 4274 4274 - checksum = "8f8ed0655cbaf18a26966142ad23b95d8ab47221c50c4f73a1db7d0d2d6e3da8" 4427 4427 + checksum = "9ad6644cb07b7f3488b9f3d2fde3b4c0a7fa367cafefb39dff93a659f76eb786" 4275 4428 dependencies = [ 4276 4429 "equivalent", 4277 4430 "hashbrown 0.15.2", ··· 4291 4444 "rustc-hash 2.1.1", 4292 4445 "rustls 0.23.31", 4293 4446 "socket2 0.5.9", 4294 4294 - "thiserror 2.0.16", 4447 4447 + "thiserror 2.0.17", 4295 4448 "tokio", 4296 4449 "tracing", 4297 4450 "web-time", ··· 4312 4465 "rustls 0.23.31", 4313 4466 "rustls-pki-types", 4314 4467 "slab", 4315 4315 - "thiserror 2.0.16", 4468 4468 + "thiserror 2.0.17", 4316 4469 "tinyvec", 4317 4470 "tracing", 4318 4471 "web-time", ··· 4538 4691 checksum = "2b15c43186be67a4fd63bee50d0303afffcef381492ebe2c5d87f324e1b8815c" 4539 4692 4540 4693 [[package]] 4694 4694 + name = "repo-stream" 4695 4695 + version = "0.2.2" 4696 4696 + source = "registry+https://github.com/rust-lang/crates.io-index" 4697 4697 + checksum = "093b48e604c138949bf3d4a1a9bc1165feb1db28a73af0101c84eb703d279f43" 4698 4698 + dependencies = [ 4699 4699 + "bincode 2.0.1", 4700 4700 + "futures", 4701 4701 + "futures-core", 4702 4702 + "ipld-core", 4703 4703 + "iroh-car", 4704 4704 + "log", 4705 4705 + "multibase", 4706 4706 + "rusqlite", 4707 4707 + "serde", 4708 4708 + "serde_bytes", 4709 4709 + "serde_ipld_dagcbor", 4710 4710 + "sha2", 4711 4711 + "thiserror 2.0.17", 4712 4712 + "tokio", 4713 4713 + ] 4714 4714 + 4715 4715 + [[package]] 4541 4716 name = "reqwest" 4542 4542 - version = "0.12.22" 4717 4717 + version = "0.12.24" 4543 4718 source = "registry+https://github.com/rust-lang/crates.io-index" 4544 4544 - checksum = "cbc931937e6ca3a06e3b6c0aa7841849b160a90351d6ab467a8b9b9959767531" 4719 4719 + checksum = "9d0946410b9f7b082a427e4ef5c8ff541a88b357bc6c637c40db3a68ac70a36f" 4545 4720 dependencies = [ 4546 4721 "async-compression", 4547 4722 "base64 0.22.1", ··· 4581 4756 "url", 4582 4757 "wasm-bindgen", 4583 4758 "wasm-bindgen-futures", 4759 4759 + "wasm-streams", 4584 4760 "web-sys", 4585 4761 ] 4586 4762 ··· 4962 5138 4963 5139 [[package]] 4964 5140 name = "self_cell" 4965 4965 - version = "1.1.0" 5141 5141 + version = "1.2.0" 4966 5142 source = "registry+https://github.com/rust-lang/crates.io-index" 4967 4967 - checksum = "c2fdfc24bc566f839a2da4c4295b82db7d25a24253867d5c64355abb5799bdbe" 5143 5143 + checksum = "0f7d95a54511e0c7be3f51e8867aa8cf35148d7b9445d44de2f943e2b206e749" 4968 5144 4969 5145 [[package]] 4970 5146 name = "semver" ··· 4984 5160 4985 5161 [[package]] 4986 5162 name = "serde_bytes" 4987 4987 - version = "0.11.17" 5163 5163 + version = "0.11.19" 4988 5164 source = "registry+https://github.com/rust-lang/crates.io-index" 4989 4989 - checksum = "8437fd221bde2d4ca316d61b90e337e9e702b3820b87d63caa9ba6c02bd06d96" 5165 5165 + checksum = "a5d440709e79d88e51ac01c4b72fc6cb7314017bb7da9eeff678aa94c10e3ea8" 4990 5166 dependencies = [ 4991 5167 "serde", 5168 5168 + "serde_core", 4992 5169 ] 4993 5170 4994 5171 [[package]] ··· 5036 5213 ] 5037 5214 5038 5215 [[package]] 5216 5216 + name = "serde_ipld_dagcbor" 5217 5217 + version = "0.6.4" 5218 5218 + source = "registry+https://github.com/rust-lang/crates.io-index" 5219 5219 + checksum = "46182f4f08349a02b45c998ba3215d3f9de826246ba02bb9dddfe9a2a2100778" 5220 5220 + dependencies = [ 5221 5221 + "cbor4ii 0.2.14", 5222 5222 + "ipld-core", 5223 5223 + "scopeguard", 5224 5224 + "serde", 5225 5225 + ] 5226 5226 + 5227 5227 + [[package]] 5039 5228 name = "serde_json" 5040 5229 version = "1.0.145" 5041 5230 source = "registry+https://github.com/rust-lang/crates.io-index" ··· 5068 5257 "percent-encoding", 5069 5258 "ryu", 5070 5259 "serde", 5071 5071 - "thiserror 2.0.16", 5260 5260 + "thiserror 2.0.17", 5072 5261 ] 5073 5262 5074 5263 [[package]] ··· 5157 5346 ] 5158 5347 5159 5348 [[package]] 5349 5349 + name = "sfa" 5350 5350 + version = "0.0.1" 5351 5351 + source = "registry+https://github.com/rust-lang/crates.io-index" 5352 5352 + checksum = "e5f5f9dc21f55409f15103d5a7e7601b804935923c7fe4746dc806c3a422a038" 5353 5353 + dependencies = [ 5354 5354 + "byteorder-lite", 5355 5355 + "log", 5356 5356 + "xxhash-rust", 5357 5357 + ] 5358 5358 + 5359 5359 + [[package]] 5160 5360 name = "sha1" 5161 5361 version = "0.10.6" 5162 5362 source = "registry+https://github.com/rust-lang/crates.io-index" ··· 5220 5420 dependencies = [ 5221 5421 "num-bigint", 5222 5422 "num-traits", 5223 5223 - "thiserror 2.0.16", 5423 5423 + "thiserror 2.0.17", 5224 5424 "time", 5225 5425 ] 5226 5426 ··· 5262 5462 "rustls 0.23.31", 5263 5463 "serde", 5264 5464 "serde_json", 5265 5265 - "thiserror 2.0.16", 5465 5465 + "thiserror 2.0.17", 5266 5466 "time", 5267 5467 "tokio", 5268 5468 "tokio-util", ··· 5355 5555 name = "spacedust" 5356 5556 version = "0.1.0" 5357 5557 dependencies = [ 5558 5558 + "anyhow", 5559 5559 + "async-channel", 5358 5560 "async-trait", 5359 5561 "clap", 5360 5562 "ctrlc", 5563 5563 + "dasl", 5361 5564 "dropshot", 5362 5565 "env_logger", 5566 5566 + "fjall 3.0.0-pre.0", 5363 5567 "futures", 5364 5568 "http", 5569 5569 + "ipld-core", 5365 5570 "jetstream", 5366 5571 "links", 5367 5572 "log", 5368 5573 "metrics", 5369 5574 "metrics-exporter-prometheus 0.17.2", 5370 5575 "rand 0.9.1", 5576 5576 + "repo-stream", 5577 5577 + "reqwest", 5371 5578 "schemars", 5372 5579 "semver", 5373 5580 "serde", 5581 5581 + "serde_ipld_dagcbor", 5374 5582 "serde_json", 5375 5583 "serde_qs", 5376 5376 - "thiserror 2.0.16", 5584 5584 + "thiserror 2.0.17", 5377 5585 "tinyjson", 5378 5586 "tokio", 5379 5587 "tokio-tungstenite 0.27.0", ··· 5506 5714 5507 5715 [[package]] 5508 5716 name = "tempfile" 5509 5509 - version = "3.19.1" 5717 5717 + version = "3.23.0" 5510 5718 source = "registry+https://github.com/rust-lang/crates.io-index" 5511 5511 - checksum = "7437ac7763b9b123ccf33c338a5cc1bac6f69b45a136c19bdd8a65e3916435bf" 5719 5719 + checksum = "2d31c77bdf42a745371d260a26ca7163f1e0924b64afa0b688e61b5a9fa02f16" 5512 5720 dependencies = [ 5513 5721 "fastrand", 5514 5722 "getrandom 0.3.3", ··· 5539 5747 5540 5748 [[package]] 5541 5749 name = "thiserror" 5542 5542 - version = "2.0.16" 5750 5750 + version = "2.0.17" 5543 5751 source = "registry+https://github.com/rust-lang/crates.io-index" 5544 5544 - checksum = "3467d614147380f2e4e374161426ff399c91084acd2363eaf549172b3d5e60c0" 5752 5752 + checksum = "f63587ca0f12b72a0600bcba1d40081f830876000bb46dd2337a3051618f4fc8" 5545 5753 dependencies = [ 5546 5546 - "thiserror-impl 2.0.16", 5754 5754 + "thiserror-impl 2.0.17", 5547 5755 ] 5548 5756 5549 5757 [[package]] ··· 5559 5767 5560 5768 [[package]] 5561 5769 name = "thiserror-impl" 5562 5562 - version = "2.0.16" 5770 5770 + version = "2.0.17" 5563 5771 source = "registry+https://github.com/rust-lang/crates.io-index" 5564 5564 - checksum = "6c5e1be1c48b9172ee610da68fd9cd2770e7a4056cb3fc98710ee6906f0c7960" 5772 5772 + checksum = "3ff15c8ecd7de3849db632e14d18d2571fa09dfc5ed93479bc4485c7a517c913" 5565 5773 dependencies = [ 5566 5774 "proc-macro2", 5567 5775 "quote", ··· 5993 6201 "native-tls", 5994 6202 "rand 0.9.1", 5995 6203 "sha1", 5996 5996 - "thiserror 2.0.16", 6204 6204 + "thiserror 2.0.17", 5997 6205 "url", 5998 6206 "utf-8", 5999 6207 ] ··· 6011 6219 "log", 6012 6220 "rand 0.9.1", 6013 6221 "sha1", 6014 6014 - "thiserror 2.0.16", 6222 6222 + "thiserror 2.0.17", 6015 6223 "utf-8", 6016 6224 ] 6017 6225 ··· 6054 6262 "http", 6055 6263 "jetstream", 6056 6264 "log", 6057 6057 - "lsm-tree", 6265 6265 + "lsm-tree 2.10.4", 6058 6266 "metrics", 6059 6267 "metrics-exporter-prometheus 0.17.2", 6060 6268 "schemars", ··· 6064 6272 "serde_qs", 6065 6273 "sha2", 6066 6274 "tempfile", 6067 6067 - "thiserror 2.0.16", 6275 6275 + "thiserror 2.0.17", 6068 6276 "tikv-jemallocator", 6069 6277 "tokio", 6070 6278 "tokio-util", ··· 6117 6325 6118 6326 [[package]] 6119 6327 name = "unsigned-varint" 6328 6328 + version = "0.7.2" 6329 6329 + source = "registry+https://github.com/rust-lang/crates.io-index" 6330 6330 + checksum = "6889a77d49f1f013504cec6bf97a2c730394adedaeb1deb5ea08949a50541105" 6331 6331 + 6332 6332 + [[package]] 6333 6333 + name = "unsigned-varint" 6120 6334 version = "0.8.0" 6121 6335 source = "registry+https://github.com/rust-lang/crates.io-index" 6122 6336 checksum = "eb066959b24b5196ae73cb057f45598450d2c5f71460e98c49b738086eff9c06" ··· 6193 6407 checksum = "62fc7c4ce161f049607ecea654dca3f2d727da5371ae85e2e4f14ce2b98ed67c" 6194 6408 dependencies = [ 6195 6409 "byteorder", 6196 6196 - "byteview", 6410 6410 + "byteview 0.6.1", 6197 6411 "interval-heap", 6198 6412 "log", 6199 6413 "path-absolutize", ··· 6342 6556 ] 6343 6557 6344 6558 [[package]] 6559 6559 + name = "wasm-streams" 6560 6560 + version = "0.4.2" 6561 6561 + source = "registry+https://github.com/rust-lang/crates.io-index" 6562 6562 + checksum = "15053d8d85c7eccdbefef60f06769760a563c7f0a9d6902a13d35c7800b0ad65" 6563 6563 + dependencies = [ 6564 6564 + "futures-util", 6565 6565 + "js-sys", 6566 6566 + "wasm-bindgen", 6567 6567 + "wasm-bindgen-futures", 6568 6568 + "web-sys", 6569 6569 + ] 6570 6570 + 6571 6571 + [[package]] 6345 6572 name = "web-sys" 6346 6573 version = "0.3.77" 6347 6574 source = "registry+https://github.com/rust-lang/crates.io-index" ··· 6400 6627 "reqwest", 6401 6628 "serde", 6402 6629 "serde_json", 6403 6403 - "thiserror 2.0.16", 6630 6630 + "thiserror 2.0.17", 6404 6631 "tokio", 6405 6632 "tokio-util", 6406 6633 "url", ··· 6440 6667 source = "registry+https://github.com/rust-lang/crates.io-index" 6441 6668 checksum = "cf221c93e13a30d793f7645a0e7762c55d169dbb0a49671918a2319d289b10bb" 6442 6669 dependencies = [ 6443 6443 - "windows-sys 0.48.0", 6670 6670 + "windows-sys 0.59.0", 6444 6671 ] 6445 6672 6446 6673 [[package]] ··· 6758 6985 "nom", 6759 6986 "oid-registry", 6760 6987 "rusticata-macros", 6761 6761 - "thiserror 2.0.16", 6988 6988 + "thiserror 2.0.17", 6762 6989 "time", 6763 6990 ] 6764 6991

+1 -1

constellation/src/bin/main.rs

··· 123 123 let rocks = rocks.clone(); 124 124 let stay_alive = stay_alive.clone(); 125 125 s.spawn(move || { 126 126 - let rep = rocks.run_repair(time::Duration::from_millis(1), stay_alive); 126 126 + let rep = rocks.run_repair(time::Duration::from_millis(0), stay_alive); 127 127 eprintln!("repair finished: {rep:?}"); 128 128 rep 129 129 });

+8 -6

constellation/src/server/filters.rs

··· 5 5 Ok({ 6 6 if let Some(link) = parse_any_link(s) { 7 7 match link { 8 8 - Link::AtUri(at_uri) => at_uri.strip_prefix("at://").map(|noproto| { 9 9 - format!("https://atproto-browser-plus-links.vercel.app/at/{noproto}") 10 10 - }), 11 11 - Link::Did(did) => Some(format!( 12 12 - "https://atproto-browser-plus-links.vercel.app/at/{did}" 13 13 - )), 8 8 + Link::AtUri(at_uri) => at_uri 9 9 + .strip_prefix("at://") 10 10 + .map(|noproto| format!("https://pdsls.dev/at://{noproto}")), 11 11 + Link::Did(did) => Some(format!("https://pdsls.dev/at://{did}")), 14 12 Link::Uri(uri) => Some(uri), 15 13 } 16 14 } else { ··· 22 20 pub fn human_number(n: &u64) -> askama::Result<String> { 23 21 Ok(n.to_formatted_string(&Locale::en)) 24 22 } 23 23 + 24 24 + pub fn to_u64(n: usize) -> askama::Result<u64> { 25 25 + Ok(n as u64) 26 26 + }

+3 -1

constellation/src/server/mod.rs

··· 293 293 }; 294 294 let path = format!(".{path}"); 295 295 296 296 + let path_to_other = format!(".{}", query.path_to_other); 297 297 + 296 298 let paged = store 297 299 .get_many_to_many_counts( 298 300 &query.subject, 299 301 collection, 300 302 &path, 301 301 - &query.path_to_other, 303 303 + &path_to_other, 302 304 limit, 303 305 cursor_key, 304 306 &filter_dids,

+7 -1

constellation/src/storage/rocks_store.rs

··· 358 358 359 359 let mut maybe_done = false; 360 360 361 361 + let mut write_fast = rocksdb::WriteOptions::default(); 362 362 + write_fast.set_sync(false); 363 363 + write_fast.disable_wal(true); 364 364 + 361 365 while !stay_alive.is_cancelled() && !maybe_done { 362 366 // let mut batch = WriteBatch::default(); 363 367 ··· 386 390 let target_id: TargetId = _vr(iter.value().unwrap())?; 387 391 388 392 self.db 389 389 - .put_cf(&cf, target_id.id().to_be_bytes(), _rv(&target))?; 393 393 + .put_cf_opt(&cf, target_id.id().to_be_bytes(), _rv(&target), &write_fast)?; 390 394 any_written = true; 391 395 iter.next(); 392 396 } ··· 955 959 let after = after.map(|s| s.parse::<u64>().map(TargetId)).transpose()?; 956 960 957 961 let Some(target_id) = self.target_id_table.get_id_val(&self.db, &target_key)? else { 962 962 + eprintln!("nothin doin for this target, {target_key:?}"); 958 963 return Ok(Default::default()); 959 964 }; 960 965 ··· 1015 1020 .take(1) 1016 1021 .next() 1017 1022 else { 1023 1023 + eprintln!("no forward match"); 1018 1024 continue; 1019 1025 }; 1020 1026

+1 -1

constellation/templates/dids.html.j2

··· 27 27 {% for did in linking_dids %} 28 28 <pre style="display: block; margin: 1em 2em" class="code"><strong>DID</strong>: {{ did.0 }} 29 29 -> see <a href="/links/all?target={{ did.0|urlencode }}">links to this DID</a> 30 30 - -> browse <a href="https://atproto-browser-plus-links.vercel.app/at/{{ did.0|urlencode }}">this DID record</a></pre> 30 30 + -> browse <a href="https://pdsls.dev/at://{{ did.0|urlencode }}">this DID record</a></pre> 31 31 {% endfor %} 32 32 33 33 {% if let Some(c) = cursor %}

+1 -1

constellation/templates/get-backlinks.html.j2

··· 1 1 {% extends "base.html.j2" %} 2 2 {% import "try-it-macros.html.j2" as try_it %} 3 3 4 4 - {% block title %}Links{% endblock %} 4 4 + {% block title %}Backlinks{% endblock %} 5 5 {% block description %}All {{ query.source }} records with links to {{ query.subject }}{% endblock %} 6 6 7 7 {% block content %}

+67

constellation/templates/get-many-to-many-counts.html.j2

··· 1 1 + {% extends "base.html.j2" %} 2 2 + {% import "try-it-macros.html.j2" as try_it %} 3 3 + 4 4 + {% block title %}Many to Many counts{% endblock %} 5 5 + {% block description %}Counts of many-to-many {{ query.source }} join records with links to {{ query.subject }} and a secondary target at {{ query.path_to_other }}{% endblock %} 6 6 + 7 7 + {% block content %} 8 8 + 9 9 + {% call try_it::get_many_to_many_counts( 10 10 + query.subject, 11 11 + query.source, 12 12 + query.path_to_other, 13 13 + query.did, 14 14 + query.other_subject, 15 15 + query.limit, 16 16 + ) %} 17 17 + 18 18 + <h2> 19 19 + Many-to-many links to <code>{{ query.subject }}</code> joining through <code>{{ query.path_to_other }}</code> 20 20 + {% if let Some(browseable_uri) = query.subject|to_browseable %} 21 21 + <small style="font-weight: normal; font-size: 1rem"><a href="{{ browseable_uri }}">browse record</a></small> 22 22 + {% endif %} 23 23 + </h2> 24 24 + 25 25 + <p><strong>{% if cursor.is_some() || query.cursor.is_some() %}more than {% endif %}{{ counts_by_other_subject.len()|to_u64|human_number }} joins</strong> <code>{{ query.source }}→{{ query.path_to_other }}</code></p> 26 26 + 27 27 + <ul> 28 28 + <li>See direct backlinks at <code>/xrpc/blue.microcosm.links.getBacklinks</code>: <a href="/xrpc/blue.microcosm.links.getBacklinks?subject={{ query.subject|urlencode }}&source={{ query.source|urlencode }}">/xrpc/blue.microcosm.links.getBacklinks?subject={{ query.subject }}&source={{ query.source }}</a></li> 29 29 + <li>See all links to this target at <code>/links/all</code>: <a href="/links/all?target={{ query.subject|urlencode }}">/links/all?target={{ query.subject }}</a></li> 30 30 + </ul> 31 31 + 32 32 + <h3>Counts by other subject:</h3> 33 33 + 34 34 + {% for counts in counts_by_other_subject %} 35 35 + <pre style="display: block; margin: 1em 2em" class="code"><strong>Joined subject</strong>: {{ counts.subject }} 36 36 + <strong>Joining records</strong>: {{ counts.total }} 37 37 + <strong>Unique joiner ids</strong>: {{ counts.distinct }} 38 38 + -> {% if let Some(browseable_uri) = counts.subject|to_browseable -%} 39 39 + <a href="{{ browseable_uri }}">browse record</a> 40 40 + {%- endif %}</pre> 41 41 + {% endfor %} 42 42 + 43 43 + {% if let Some(c) = cursor %} 44 44 + <form method="get" action="/xrpc/blue.microcosm.links.getManyToManyCounts"> 45 45 + <input type="hidden" name="subject" value="{{ query.subject }}" /> 46 46 + <input type="hidden" name="source" value="{{ query.source }}" /> 47 47 + <input type="hidden" name="pathToOther" value="{{ query.path_to_other }}" /> 48 48 + {% for did in query.did %} 49 49 + <input type="hidden" name="did" value="{{ did }}" /> 50 50 + {% endfor %} 51 51 + {% for otherSubject in query.other_subject %} 52 52 + <input type="hidden" name="otherSubject" value="{{ otherSubject }}" /> 53 53 + {% endfor %} 54 54 + <input type="hidden" name="limit" value="{{ query.limit }}" /> 55 55 + <input type="hidden" name="cursor" value={{ c|json|safe }} /> 56 56 + <button type="submit">next page&hellip;</button> 57 57 + </form> 58 58 + {% else %} 59 59 + <button disabled><em>end of results</em></button> 60 60 + {% endif %} 61 61 + 62 62 + <details> 63 63 + <summary>Raw JSON response</summary> 64 64 + <pre class="code">{{ self|tojson }}</pre> 65 65 + </details> 66 66 + 67 67 + {% endblock %}

+26

constellation/templates/hello.html.j2

··· 55 55 {% call try_it::get_backlinks("at://did:plc:a4pqq234yw7fqbddawjo7y35/app.bsky.feed.post/3m237ilwc372e", "app.bsky.feed.like:subject.uri", [""], 16) %} 56 56 57 57 58 58 + <h3 class="route"><code>GET /xrpc/blue.microcosm.links.getManyToManyCounts</code></h3> 59 59 + 60 60 + <p>TODO: description</p> 61 61 + 62 62 + <h4>Query parameters:</h4> 63 63 + 64 64 + <ul> 65 65 + <li><p><code>subject</code>: required, must url-encode. Example: <code>at://did:plc:vc7f4oafdgxsihk4cry2xpze/app.bsky.feed.post/3lgwdn7vd722r</code></p></li> 66 66 + <li><p><code>source</code>: required. Example: <code>app.bsky.feed.like:subject.uri</code></p></li> 67 67 + <li><p><code>pathToOther</code>: required. Path to the secondary link in the many-to-many record. Example: <code>otherThing.uri</code></p></li> 68 68 + <li><p><code>did</code>: optional, filter links to those from specific users. Include multiple times to filter by multiple users. Example: <code>did=did:plc:vc7f4oafdgxsihk4cry2xpze&did=did:plc:vc7f4oafdgxsihk4cry2xpze</code></p></li> 69 69 + <li><p><code>otherSubject</code>: optional, filter secondary links to specific subjects. Include multiple times to filter by multiple users. Example: <code>at://did:plc:vc7f4oafdgxsihk4cry2xpze/app.bsky.feed.post/3lgwdn7vd722r</code></p></li> 70 70 + <li><p><code>limit</code>: optional. Default: <code>16</code>. Maximum: <code>100</code></p></li> 71 71 + </ul> 72 72 + 73 73 + <p style="margin-bottom: 0"><strong>Try it:</strong></p> 74 74 + {% call try_it::get_many_to_many_counts( 75 75 + "at://did:plc:wshs7t2adsemcrrd4snkeqli/sh.tangled.label.definition/good-first-issue", 76 76 + "sh.tangled.label.op:add[].key", 77 77 + "subject", 78 78 + [""], 79 79 + [""], 80 80 + 25, 81 81 + ) %} 82 82 + 83 83 + 58 84 <h3 class="route"><code>GET /links</code></h3> 59 85 60 86 <p>A list of records linking to a target.</p>

+43 -1

constellation/templates/try-it-macros.html.j2

··· 1 1 {% macro get_backlinks(subject, source, dids, limit) %} 2 2 <form method="get" action="/xrpc/blue.microcosm.links.getBacklinks"> 3 3 - <pre class="code"><strong>GET</strong> /links 3 3 + <pre class="code"><strong>GET</strong> /xrpc/blue.microcosm.links.getBacklinks 4 4 ?subject= <input type="text" name="subject" value="{{ subject }}" placeholder="at-uri, did, uri..." /> 5 5 &source= <input type="text" name="source" value="{{ source }}" placeholder="app.bsky.feed.like:subject.uri" /> 6 6 {%- for did in dids %}{% if !did.is_empty() %} ··· 20 20 p.insertBefore(document.createTextNode('&did= '), didPlaceholder); 21 21 p.insertBefore(i, didPlaceholder); 22 22 p.insertBefore(document.createTextNode('\n '), didPlaceholder); 23 23 + }); 24 24 + </script> 25 25 + {% endmacro %} 26 26 + 27 27 + {% macro get_many_to_many_counts(subject, source, pathToOther, dids, otherSubjects, limit) %} 28 28 + <form method="get" action="/xrpc/blue.microcosm.links.getManyToManyCounts"> 29 29 + <pre class="code"><strong>GET</strong> /xrpc/blue.microcosm.links.getManyToManyCounts 30 30 + ?subject= <input type="text" name="subject" value="{{ subject }}" placeholder="at-uri, did, uri..." /> 31 31 + &source= <input type="text" name="source" value="{{ source }}" placeholder="app.bsky.feed.like:subject.uri" /> 32 32 + &pathToOther= <input type="text" name="pathToOther" value="{{ pathToOther }}" placeholder="otherThing.uri" /> 33 33 + {%- for did in dids %}{% if !did.is_empty() %} 34 34 + &did= <input type="text" name="did" value="{{ did }}" placeholder="did:plc:..." />{% endif %}{% endfor %} 35 35 + <span id="m2m-subject-placeholder"></span> <button id="m2m-add-subject">+ other subject filter</button> 36 36 + {%- for otherSubject in otherSubjects %}{% if !otherSubject.is_empty() %} 37 37 + &otherSubject= <input type="text" name="did" value="{{ otherSubject }}" placeholder="at-uri, did, uri..." />{% endif %}{% endfor %} 38 38 + <span id="m2m-did-placeholder"></span> <button id="m2m-add-did">+ did filter</button> 39 39 + &limit= <input type="number" name="limit" value="{{ limit }}" max="100" placeholder="100" /> <button type="submit">get links</button></pre> 40 40 + </form> 41 41 + <script> 42 42 + const m2mAddDidButton = document.getElementById('m2m-add-did'); 43 43 + const m2mDidPlaceholder = document.getElementById('m2m-did-placeholder'); 44 44 + m2mAddDidButton.addEventListener('click', e => { 45 45 + e.preventDefault(); 46 46 + const i = document.createElement('input'); 47 47 + i.placeholder = 'did:plc:...'; 48 48 + i.name = "did" 49 49 + const p = m2mAddDidButton.parentNode; 50 50 + p.insertBefore(document.createTextNode('&did= '), m2mDidPlaceholder); 51 51 + p.insertBefore(i, m2mDidPlaceholder); 52 52 + p.insertBefore(document.createTextNode('\n '), m2mDidPlaceholder); 53 53 + }); 54 54 + const m2mAddSubjectButton = document.getElementById('m2m-add-subject'); 55 55 + const m2mSubjectPlaceholder = document.getElementById('m2m-subject-placeholder'); 56 56 + m2mAddSubjectButton.addEventListener('click', e => { 57 57 + e.preventDefault(); 58 58 + const i = document.createElement('input'); 59 59 + i.placeholder = 'at-uri, did, uri...'; 60 60 + i.name = "otherSubject" 61 61 + const p = m2mAddSubjectButton.parentNode; 62 62 + p.insertBefore(document.createTextNode('&otherSubject= '), m2mSubjectPlaceholder); 63 63 + p.insertBefore(i, m2mSubjectPlaceholder); 64 64 + p.insertBefore(document.createTextNode('\n '), m2mSubjectPlaceholder); 23 65 }); 24 66 </script> 25 67 {% endmacro %}

+2

links/Cargo.toml

··· 5 5 6 6 [dependencies] 7 7 anyhow = "1.0.95" 8 8 + dasl = "0.2.0" 8 9 fluent-uri = "0.3.2" 9 10 nom = "7.1.3" 11 11 + serde = { version = "1.0.228", features = ["derive"] } 10 12 thiserror = "2.0.9" 11 13 tinyjson = "2.5.1"

+3 -2

links/src/lib.rs

··· 1 1 use fluent_uri::Uri; 2 2 + use serde::{Deserialize, Serialize}; 2 3 3 4 pub mod at_uri; 4 5 pub mod did; ··· 6 7 7 8 pub use record::collect_links; 8 9 9 9 - #[derive(Debug, Clone, Ord, Eq, PartialOrd, PartialEq)] 10 10 + #[derive(Debug, Clone, Ord, Eq, PartialOrd, PartialEq, Serialize, Deserialize)] 10 11 pub enum Link { 11 12 AtUri(String), 12 13 Uri(String), ··· 59 60 } 60 61 } 61 62 62 62 - #[derive(Debug, PartialEq)] 63 63 + #[derive(Debug, Clone, PartialEq, Serialize, Deserialize)] 63 64 pub struct CollectedLink { 64 65 pub path: String, 65 66 pub target: Link,

+41

links/src/record.rs

··· 1 1 + use dasl::drisl::Value as DrislValue; 1 2 use tinyjson::JsonValue; 2 3 3 4 use crate::{parse_any_link, CollectedLink}; ··· 36 37 } 37 38 } 38 39 40 40 + pub fn walk_drisl(path: &str, v: &DrislValue, found: &mut Vec<CollectedLink>) { 41 41 + match v { 42 42 + DrislValue::Map(o) => { 43 43 + for (key, child) in o { 44 44 + walk_drisl(&format!("{path}.{key}"), child, found) 45 45 + } 46 46 + } 47 47 + DrislValue::Array(a) => { 48 48 + for child in a { 49 49 + let child_p = match child { 50 50 + DrislValue::Map(o) => { 51 51 + if let Some(DrislValue::Text(t)) = o.get("$type") { 52 52 + format!("{path}[{t}]") 53 53 + } else { 54 54 + format!("{path}[]") 55 55 + } 56 56 + } 57 57 + _ => format!("{path}[]"), 58 58 + }; 59 59 + walk_drisl(&child_p, child, found) 60 60 + } 61 61 + } 62 62 + DrislValue::Text(s) => { 63 63 + if let Some(link) = parse_any_link(s) { 64 64 + found.push(CollectedLink { 65 65 + path: path.to_string(), 66 66 + target: link, 67 67 + }); 68 68 + } 69 69 + } 70 70 + _ => {} 71 71 + } 72 72 + } 73 73 + 39 74 pub fn collect_links(v: &JsonValue) -> Vec<CollectedLink> { 40 75 let mut found = vec![]; 41 76 walk_record("", v, &mut found); 77 77 + found 78 78 + } 79 79 + 80 80 + pub fn collect_links_drisl(v: &DrislValue) -> Vec<CollectedLink> { 81 81 + let mut found = vec![]; 82 82 + walk_drisl("", v, &mut found); 42 83 found 43 84 } 44 85

+8

spacedust/Cargo.toml

··· 4 4 edition = "2024" 5 5 6 6 [dependencies] 7 7 + anyhow = "1.0.100" 8 8 + async-channel = "2.5.0" 7 9 async-trait = "0.1.88" 8 10 clap = { version = "4.5.40", features = ["derive"] } 9 11 ctrlc = "3.4.7" 12 12 + dasl = "0.2.0" 10 13 dropshot = "0.16.2" 11 14 env_logger = "0.11.8" 15 15 + fjall = "3.0.0-pre.0" 12 16 futures = "0.3.31" 13 17 http = "1.3.1" 18 18 + ipld-core = { version = "0.4.2", features = ["serde"] } 14 19 jetstream = { path = "../jetstream", features = ["metrics"] } 15 20 links = { path = "../links" } 16 21 log = "0.4.27" 17 22 metrics = "0.24.2" 18 23 metrics-exporter-prometheus = { version = "0.17.1", features = ["http-listener"] } 19 24 rand = "0.9.1" 25 25 + repo-stream = "0.2.2" 26 26 + reqwest = { version = "0.12.24", features = ["json", "stream"] } 20 27 schemars = "0.8.22" 21 28 semver = "1.0.26" 22 29 serde = { version = "1.0.219", features = ["derive"] } 30 30 + serde_ipld_dagcbor = "0.6.4" 23 31 serde_json = "1.0.140" 24 32 serde_qs = "1.0.0-rc.3" 25 33 thiserror = "2.0.12"

+21

spacedust/src/bin/import_car_file.rs

··· 1 1 + use clap::Parser; 2 2 + use std::path::PathBuf; 3 3 + 4 4 + type Result<T> = std::result::Result<T, Box<dyn std::error::Error>>; 5 5 + 6 6 + #[derive(Debug, Parser)] 7 7 + struct Args { 8 8 + #[arg()] 9 9 + file: PathBuf, 10 10 + } 11 11 + 12 12 + #[tokio::main] 13 13 + async fn main() -> Result<()> { 14 14 + env_logger::init(); 15 15 + 16 16 + let Args { file } = Args::parse(); 17 17 + 18 18 + let _reader = tokio::fs::File::open(file).await?; 19 19 + 20 20 + Ok(()) 21 21 + }

+258

spacedust/src/bin/import_scraped.rs

··· 1 1 + use clap::Parser; 2 2 + use links::CollectedLink; 3 3 + use repo_stream::{ 4 4 + DiskBuilder, DiskStore, Driver, DriverBuilder, Processable, drive::DriverBuilderWithProcessor, 5 5 + drive::NeedDisk, 6 6 + }; 7 7 + use std::path::PathBuf; 8 8 + use std::sync::{ 9 9 + Arc, 10 10 + atomic::{AtomicUsize, Ordering}, 11 11 + }; 12 12 + use tokio::{io::AsyncRead, task::JoinSet}; 13 13 + 14 14 + type Result<T> = anyhow::Result<T>; //std::result::Result<T, Box<dyn std::error::Error>>; 15 15 + 16 16 + #[derive(Debug, Clone, serde::Serialize, serde::Deserialize)] 17 17 + struct CollectedProcessed(CollectedLink); 18 18 + 19 19 + impl Processable for CollectedProcessed { 20 20 + fn get_size(&self) -> usize { 21 21 + self.0.path.capacity() + self.0.target.as_str().len() 22 22 + } 23 23 + } 24 24 + 25 25 + #[derive(Debug, Clone, serde::Serialize, serde::Deserialize)] 26 26 + struct ErrString(String); 27 27 + 28 28 + impl Processable for ErrString { 29 29 + fn get_size(&self) -> usize { 30 30 + self.0.capacity() 31 31 + } 32 32 + } 33 33 + 34 34 + type Processed = std::result::Result<Vec<CollectedProcessed>, ErrString>; 35 35 + 36 36 + /// hacky for now: put errors in strings 🤷‍♀️ 37 37 + fn process(block: Vec<u8>) -> Processed { 38 38 + let value: dasl::drisl::Value = dasl::drisl::from_slice(&block) 39 39 + .map_err(|e| ErrString(format!("failed to parse block with drisl: {e:?}")))?; 40 40 + let links = links::record::collect_links_drisl(&value) 41 41 + .into_iter() 42 42 + .map(CollectedProcessed) 43 43 + .collect(); 44 44 + Ok(links) 45 45 + } 46 46 + 47 47 + #[derive(Debug, Parser)] 48 48 + struct Args { 49 49 + #[arg(long)] 50 50 + cars_folder: PathBuf, 51 51 + #[arg(long)] 52 52 + mem_workers: usize, 53 53 + #[arg(long)] 54 54 + disk_workers: usize, 55 55 + #[arg(long)] 56 56 + disk_folder: PathBuf, 57 57 + } 58 58 + 59 59 + async fn get_cars( 60 60 + cars_folder: PathBuf, 61 61 + tx: async_channel::Sender<tokio::io::BufReader<tokio::fs::File>>, 62 62 + ) -> Result<()> { 63 63 + let mut dir = tokio::fs::read_dir(cars_folder).await?; 64 64 + while let Some(entry) = dir.next_entry().await? { 65 65 + if !entry.file_type().await?.is_file() { 66 66 + continue; 67 67 + } 68 68 + let reader = tokio::fs::File::open(&entry.path()).await?; 69 69 + let reader = tokio::io::BufReader::new(reader); 70 70 + tx.send(reader).await?; 71 71 + } 72 72 + Ok(()) 73 73 + } 74 74 + 75 75 + async fn drive_mem<R: AsyncRead + Unpin + Send + Sync + 'static>( 76 76 + f: R, 77 77 + builder: &DriverBuilderWithProcessor<Processed>, 78 78 + disk_tx: &async_channel::Sender<NeedDisk<R, Processed>>, 79 79 + ) -> Result<Option<(usize, usize)>> { 80 80 + let mut n = 0; 81 81 + let mut n_records = 0; 82 82 + match builder.load_car(f).await? { 83 83 + Driver::Memory(_commit, mut driver) => { 84 84 + while let Some(chunk) = driver.next_chunk(512).await? { 85 85 + n_records += chunk.len(); 86 86 + for (_key, links) in chunk { 87 87 + match links { 88 88 + Ok(links) => n += links.len(), 89 89 + Err(e) => eprintln!("wat: {e:?}"), 90 90 + } 91 91 + } 92 92 + } 93 93 + Ok(Some((n, n_records))) 94 94 + } 95 95 + Driver::Disk(need_disk) => { 96 96 + disk_tx.send(need_disk).await?; 97 97 + Ok(None) 98 98 + } 99 99 + } 100 100 + } 101 101 + 102 102 + async fn mem_worker<R: AsyncRead + Unpin + Send + Sync + 'static>( 103 103 + car_rx: async_channel::Receiver<R>, 104 104 + disk_tx: async_channel::Sender<NeedDisk<R, Processed>>, 105 105 + n: Arc<AtomicUsize>, 106 106 + n_records: Arc<AtomicUsize>, 107 107 + ) -> Result<()> { 108 108 + let builder = DriverBuilder::new() 109 109 + .with_block_processor(process) // don't care just counting records 110 110 + .with_mem_limit_mb(128); 111 111 + while let Ok(f) = car_rx.recv().await { 112 112 + let driven = match drive_mem(f, &builder, &disk_tx).await { 113 113 + Ok(d) => d, 114 114 + Err(e) => { 115 115 + eprintln!("failed to drive mem: {e:?}. skipping..."); 116 116 + continue; 117 117 + } 118 118 + }; 119 119 + if let Some((drove, recs)) = driven { 120 120 + n.fetch_add(drove, Ordering::Relaxed); 121 121 + n_records.fetch_add(recs, Ordering::Relaxed); 122 122 + } 123 123 + } 124 124 + Ok(()) 125 125 + } 126 126 + 127 127 + async fn drive_disk<R: AsyncRead + Unpin>( 128 128 + needed: NeedDisk<R, Processed>, 129 129 + store: DiskStore, 130 130 + ) -> Result<(usize, usize, DiskStore)> { 131 131 + let (_commit, mut driver) = needed.finish_loading(store).await?; 132 132 + let mut n = 0; 133 133 + let mut n_records = 0; 134 134 + while let Some(chunk) = driver.next_chunk(512).await? { 135 135 + n_records += chunk.len(); 136 136 + for (_key, links) in chunk { 137 137 + match links { 138 138 + Ok(links) => n += links.len(), 139 139 + Err(e) => eprintln!("wat: {e:?}"), 140 140 + } 141 141 + } 142 142 + } 143 143 + let store = driver.reset_store().await?; 144 144 + Ok((n, n_records, store)) 145 145 + } 146 146 + 147 147 + async fn disk_worker<R: AsyncRead + Unpin>( 148 148 + worker_id: usize, 149 149 + disk_rx: async_channel::Receiver<NeedDisk<R, Processed>>, 150 150 + folder: PathBuf, 151 151 + n: Arc<AtomicUsize>, 152 152 + n_records: Arc<AtomicUsize>, 153 153 + disk_workers_active: Arc<AtomicUsize>, 154 154 + ) -> Result<()> { 155 155 + let mut file = folder; 156 156 + file.push(format!("disk-worker-{worker_id}.sqlite")); 157 157 + let builder = DiskBuilder::new().with_cache_size_mb(128); 158 158 + let mut store = builder.open(file.clone()).await?; 159 159 + while let Ok(needed) = disk_rx.recv().await { 160 160 + let active = disk_workers_active.fetch_add(1, Ordering::AcqRel); 161 161 + println!("-> disk workers active: {}", active + 1); 162 162 + let (drove, records) = match drive_disk(needed, store).await { 163 163 + Ok((d, r, s)) => { 164 164 + store = s; 165 165 + (d, r) 166 166 + } 167 167 + Err(e) => { 168 168 + eprintln!("failed to drive disk: {e:?}. skipping..."); 169 169 + store = builder.open(file.clone()).await?; 170 170 + continue; 171 171 + } 172 172 + }; 173 173 + n.fetch_add(drove, Ordering::Relaxed); 174 174 + n_records.fetch_add(records, Ordering::Relaxed); 175 175 + let were_active = disk_workers_active.fetch_sub(1, Ordering::AcqRel); 176 176 + println!("<- disk workers active: {}", were_active - 1); 177 177 + } 178 178 + Ok(()) 179 179 + } 180 180 + 181 181 + #[tokio::main] 182 182 + async fn main() -> Result<()> { 183 183 + env_logger::init(); 184 184 + 185 185 + let Args { 186 186 + cars_folder, 187 187 + disk_folder, 188 188 + disk_workers, 189 189 + mem_workers, 190 190 + } = Args::parse(); 191 191 + 192 192 + let mut set = JoinSet::<Result<()>>::new(); 193 193 + 194 194 + let (cars_tx, cars_rx) = async_channel::bounded(2); 195 195 + set.spawn(get_cars(cars_folder, cars_tx)); 196 196 + 197 197 + let n: Arc<AtomicUsize> = Arc::new(0.into()); 198 198 + let n_records: Arc<AtomicUsize> = Arc::new(0.into()); 199 199 + let disk_workers_active: Arc<AtomicUsize> = Arc::new(0.into()); 200 200 + 201 201 + set.spawn({ 202 202 + let n = n.clone(); 203 203 + let n_records = n_records.clone(); 204 204 + let mut interval = tokio::time::interval(std::time::Duration::from_secs(10)); 205 205 + async move { 206 206 + let mut last_n = n.load(Ordering::Relaxed); 207 207 + let mut last_n_records = n.load(Ordering::Relaxed); 208 208 + loop { 209 209 + interval.tick().await; 210 210 + let n = n.load(Ordering::Relaxed); 211 211 + let n_records = n_records.load(Ordering::Relaxed); 212 212 + let diff_n = n - last_n; 213 213 + let diff_records = n_records - last_n_records; 214 214 + println!("rate: {} rec/sec; {} n/sec", diff_records / 10, diff_n / 10); 215 215 + if n_records > 0 && diff_records == 0 { 216 216 + println!("zero encountered, stopping rate calculation polling."); 217 217 + break Ok(()); 218 218 + } 219 219 + last_n = n; 220 220 + last_n_records = n_records; 221 221 + } 222 222 + } 223 223 + }); 224 224 + 225 225 + let (needs_disk_tx, needs_disk_rx) = async_channel::bounded(disk_workers); 226 226 + 227 227 + for _ in 0..mem_workers { 228 228 + set.spawn(mem_worker( 229 229 + cars_rx.clone(), 230 230 + needs_disk_tx.clone(), 231 231 + n.clone(), 232 232 + n_records.clone(), 233 233 + )); 234 234 + } 235 235 + drop(cars_rx); 236 236 + drop(needs_disk_tx); 237 237 + 238 238 + tokio::fs::create_dir_all(disk_folder.clone()).await?; 239 239 + for id in 0..disk_workers { 240 240 + set.spawn(disk_worker( 241 241 + id, 242 242 + needs_disk_rx.clone(), 243 243 + disk_folder.clone(), 244 244 + n.clone(), 245 245 + n_records.clone(), 246 246 + disk_workers_active.clone(), 247 247 + )); 248 248 + } 249 249 + drop(needs_disk_rx); 250 250 + 251 251 + while let Some(res) = set.join_next().await { 252 252 + println!("task from set joined: {res:?}"); 253 253 + } 254 254 + 255 255 + eprintln!("total records processed: {n_records:?}; total n: {n:?}"); 256 256 + 257 257 + Ok(()) 258 258 + }

+137

spacedust/src/bin/scrape_pds.rs

··· 1 1 + use clap::Parser; 2 2 + use reqwest::Url; 3 3 + use serde::Deserialize; 4 4 + use std::path::PathBuf; 5 5 + use tokio::io::AsyncWriteExt; 6 6 + use tokio::{sync::mpsc, time}; 7 7 + 8 8 + type Result<T> = std::result::Result<T, Box<dyn std::error::Error>>; 9 9 + 10 10 + use futures::StreamExt; 11 11 + 12 12 + #[derive(Debug, Parser)] 13 13 + struct Args { 14 14 + #[arg(long)] 15 15 + pds: Url, 16 16 + #[arg(long)] 17 17 + throttle_ms: u64, // 100ms per pds? 18 18 + #[arg(long)] 19 19 + folder: PathBuf, 20 20 + } 21 21 + 22 22 + async fn download_repo( 23 23 + client: &reqwest::Client, 24 24 + mut pds: Url, 25 25 + did: String, 26 26 + mut path: PathBuf, 27 27 + ) -> Result<()> { 28 28 + path.push(format!("{did}.car")); 29 29 + let f = tokio::fs::File::create(path).await?; 30 30 + let mut w = tokio::io::BufWriter::new(f); 31 31 + 32 32 + pds.set_path("/xrpc/com.atproto.sync.getRepo"); 33 33 + pds.set_query(Some(&format!("did={did}"))); 34 34 + let mut byte_stream = client.get(pds).send().await?.bytes_stream(); 35 35 + 36 36 + while let Some(stuff) = byte_stream.next().await { 37 37 + tokio::io::copy(&mut stuff?.as_ref(), &mut w).await?; 38 38 + } 39 39 + w.flush().await?; 40 40 + 41 41 + Ok(()) 42 42 + } 43 43 + 44 44 + #[derive(Debug, Deserialize)] 45 45 + struct RepoInfo { 46 46 + did: String, 47 47 + active: bool, 48 48 + } 49 49 + 50 50 + #[derive(Debug, Deserialize)] 51 51 + struct ListReposResponse { 52 52 + cursor: Option<String>, 53 53 + repos: Vec<RepoInfo>, 54 54 + } 55 55 + 56 56 + fn get_pds_dids(client: reqwest::Client, mut pds: Url) -> mpsc::Receiver<String> { 57 57 + let (tx, rx) = mpsc::channel(2); 58 58 + tokio::task::spawn(async move { 59 59 + pds.set_path("/xrpc/com.atproto.sync.listRepos"); 60 60 + let mut cursor = None; 61 61 + 62 62 + loop { 63 63 + if let Some(c) = cursor { 64 64 + pds.set_query(Some(&format!("cursor={c}"))); 65 65 + } 66 66 + let res: ListReposResponse = client 67 67 + .get(pds.clone()) 68 68 + .send() 69 69 + .await 70 70 + .expect("to send request") 71 71 + .error_for_status() 72 72 + .expect("to be ok") 73 73 + .json() 74 74 + .await 75 75 + .expect("json response"); 76 76 + for repo in res.repos { 77 77 + if repo.active { 78 78 + tx.send(repo.did) 79 79 + .await 80 80 + .expect("to be able to send on the channel"); 81 81 + } 82 82 + } 83 83 + cursor = res.cursor; 84 84 + if cursor.is_none() { 85 85 + break; 86 86 + } 87 87 + } 88 88 + }); 89 89 + rx 90 90 + } 91 91 + 92 92 + #[tokio::main] 93 93 + async fn main() -> Result<()> { 94 94 + env_logger::init(); 95 95 + 96 96 + let Args { 97 97 + pds, 98 98 + throttle_ms, 99 99 + folder, 100 100 + } = Args::parse(); 101 101 + 102 102 + tokio::fs::create_dir_all(folder.clone()).await?; 103 103 + 104 104 + let client = reqwest::Client::builder() 105 105 + .user_agent("microcosm/spacedust-testing") 106 106 + .build()?; 107 107 + 108 108 + let mut dids = get_pds_dids(client.clone(), pds.clone()); 109 109 + 110 110 + let mut interval = time::interval(time::Duration::from_millis(throttle_ms)); 111 111 + let mut oks = 0; 112 112 + let mut single_fails = 0; 113 113 + let mut double_fails = 0; 114 114 + 115 115 + while let Some(did) = dids.recv().await { 116 116 + interval.tick().await; 117 117 + println!("did: {did:?}"); 118 118 + if let Err(e) = download_repo(&client, pds.clone(), did.clone(), folder.clone()).await { 119 119 + single_fails += 1; 120 120 + eprintln!("failed to download repo for did: {did:?}: {e:?}. retrying in a moment..."); 121 121 + tokio::time::sleep(time::Duration::from_secs(3)).await; 122 122 + interval.reset(); 123 123 + if let Err(e) = download_repo(&client, pds.clone(), did.clone(), folder.clone()).await { 124 124 + double_fails += 1; 125 125 + eprintln!("failed again: {e:?}. moving on in a moment..."); 126 126 + tokio::time::sleep(time::Duration::from_secs(1)).await; 127 127 + continue; 128 128 + } 129 129 + } 130 130 + oks += 1; 131 131 + println!(" -> done. did: {did:?}"); 132 132 + } 133 133 + 134 134 + eprintln!("got {oks} repos. single fails: {single_fails}; doubles: {double_fails}."); 135 135 + 136 136 + Ok(()) 137 137 + }

+1

spacedust/src/lib.rs

··· 3 3 pub mod error; 4 4 pub mod removable_delay_queue; 5 5 pub mod server; 6 6 + pub mod storage; 6 7 pub mod subscriber; 7 8 8 9 use jetstream::events::CommitEvent;

spacedust/src/storage/car/drive.rs

This is a binary file and will not be displayed.

+1

spacedust/src/storage/car/mod.rs

··· 1 1 +

spacedust/src/storage/car/walk.rs

This is a binary file and will not be displayed.

+9

spacedust/src/storage/fjall/mod.rs

··· 1 1 + use crate::storage::Storage; 2 2 + 3 3 + pub struct FjallStorage {} 4 4 + 5 5 + impl Storage for FjallStorage { 6 6 + fn import_car() { 7 7 + todo!() 8 8 + } 9 9 + }

+6

spacedust/src/storage/mod.rs

··· 1 1 + pub mod car; 2 2 + pub mod fjall; 3 3 + 4 4 + pub trait Storage { 5 5 + fn import_car() {} 6 6 + }