Overview
Comment: | 0.1.17: update deps, only process messages, fetch delay goes down from 5 min to 1 minute |
---|---|
Downloads: | Tarball | ZIP archive | SQL archive |
Timelines: | family | ancestors | descendants | both | trunk |
Files: | files | file ages | folders |
SHA3-256: |
fcf57ccb362756524206ef60e97e2bbe |
User & Date: | arcade on 2021-07-25 08:18:50.710 |
Other Links: | manifest | tags |
Context
2021-09-19
| ||
07:21 | 0.1.18: bump crates check-in: 9143c728f3 user: arcade tags: trunk | |
2021-07-25
| ||
08:18 | 0.1.17: update deps, only process messages, fetch delay goes down from 5 min to 1 minute check-in: fcf57ccb36 user: arcade tags: trunk | |
2021-06-28
| ||
08:27 | fix building on rust 1.53 check-in: 5609487b23 user: arcade tags: trunk | |
Changes
Modified Cargo.lock
from [8e35f56334]
to [6b1a1c820f].
︙ | ︙ | |||
35 36 37 38 39 40 41 | checksum = "1e37cfd5e7657ada45f742d6e99ca5788580b5c529dc78faf11ece6dc702656f" dependencies = [ "memchr", ] [[package]] name = "anyhow" | | | | 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 | checksum = "1e37cfd5e7657ada45f742d6e99ca5788580b5c529dc78faf11ece6dc702656f" dependencies = [ "memchr", ] [[package]] name = "anyhow" version = "1.0.42" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "595d3cfa7a60d4555cb5067b99f07142a08ea778de5cf993f7b75c7d8fabc486" [[package]] name = "arrayvec" version = "0.5.2" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "23b62fc65de8e4e7f52534fb52b0f3ed04746ae267519eef2a83941e8085068b" |
︙ | ︙ | |||
88 89 90 91 92 93 94 | "futures-lite", "num_cpus", "once_cell", ] [[package]] name = "async-io" | | | < | 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 | "futures-lite", "num_cpus", "once_cell", ] [[package]] name = "async-io" version = "1.6.0" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "a811e6a479f2439f0c04038796b5cfb3d2ad56c230e0f2d3f7b04d68cfee607b" dependencies = [ "concurrent-queue", "futures-lite", "libc", "log 0.4.14", "once_cell", "parking", "polling", "slab", |
︙ | ︙ | |||
334 335 336 337 338 339 340 | name = "cache-padded" version = "1.1.1" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "631ae5198c9be5e753e5cc215e1bd73c2b466a3565173db433f52bb9d3e66dba" [[package]] name = "cc" | | | | 333 334 335 336 337 338 339 340 341 342 343 344 345 346 347 348 349 | name = "cache-padded" version = "1.1.1" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "631ae5198c9be5e753e5cc215e1bd73c2b466a3565173db433f52bb9d3e66dba" [[package]] name = "cc" version = "1.0.69" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "e70cc2f62c6ce1868963827bd677764c62d07c3d9a3e1fb1177ee1a9ab199eb2" [[package]] name = "cfg-if" version = "0.1.10" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "4785bdd1c96b2a846b2bd7cc02e86b6b3dbf14e7e53446c4f54c92a361040822" |
︙ | ︙ | |||
548 549 550 551 552 553 554 | dependencies = [ "cfg-if 1.0.0", "lazy_static", ] [[package]] name = "crypto-mac" | | | | 547 548 549 550 551 552 553 554 555 556 557 558 559 560 561 562 563 | dependencies = [ "cfg-if 1.0.0", "lazy_static", ] [[package]] name = "crypto-mac" version = "0.10.1" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "bff07008ec701e8028e2ceb8f83f0e4274ee62bd2dbdc4fefff2e9a91824081a" dependencies = [ "generic-array", "subtle", ] [[package]] name = "ctor" |
︙ | ︙ | |||
712 713 714 715 716 717 718 | "quote", "syn", "synstructure", ] [[package]] name = "fastrand" | | | | 711 712 713 714 715 716 717 718 719 720 721 722 723 724 725 726 727 | "quote", "syn", "synstructure", ] [[package]] name = "fastrand" version = "1.5.0" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "b394ed3d285a429378d3b384b9eb1285267e7df4b166df24b7a6939a04dc392e" dependencies = [ "instant", ] [[package]] name = "flate2" version = "1.0.20" |
︙ | ︙ | |||
798 799 800 801 802 803 804 | name = "futures" version = "0.1.31" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "3a471a38ef8ed83cd6e40aa59c1ffe17db6855c18e3604d9c4ed8c08ebc28678" [[package]] name = "futures" | | | | | | | | | | | | | | | | | | | | 797 798 799 800 801 802 803 804 805 806 807 808 809 810 811 812 813 814 815 816 817 818 819 820 821 822 823 824 825 826 827 828 829 830 831 832 833 834 835 836 837 838 839 840 841 842 843 844 845 846 847 848 849 850 851 852 853 854 855 856 857 858 859 860 861 862 863 864 865 866 867 868 869 870 871 872 873 874 875 876 877 878 879 880 881 882 883 884 885 886 887 888 889 890 891 892 893 894 895 896 897 898 899 900 901 902 903 904 905 906 907 908 909 910 911 | name = "futures" version = "0.1.31" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "3a471a38ef8ed83cd6e40aa59c1ffe17db6855c18e3604d9c4ed8c08ebc28678" [[package]] name = "futures" version = "0.3.16" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "1adc00f486adfc9ce99f77d717836f0c5aa84965eb0b4f051f4e83f7cab53f8b" dependencies = [ "futures-channel", "futures-core", "futures-executor", "futures-io", "futures-sink", "futures-task", "futures-util", ] [[package]] name = "futures-channel" version = "0.3.16" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "74ed2411805f6e4e3d9bc904c95d5d423b89b3b25dc0250aa74729de20629ff9" dependencies = [ "futures-core", "futures-sink", ] [[package]] name = "futures-core" version = "0.3.16" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "af51b1b4a7fdff033703db39de8802c673eb91855f2e0d47dcf3bf2c0ef01f99" [[package]] name = "futures-cpupool" version = "0.1.8" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "ab90cde24b3319636588d0c35fe03b1333857621051837ed769faefb4c2162e4" dependencies = [ "futures 0.1.31", "num_cpus", ] [[package]] name = "futures-executor" version = "0.3.16" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "4d0d535a57b87e1ae31437b892713aee90cd2d7b0ee48727cd11fc72ef54761c" dependencies = [ "futures-core", "futures-task", "futures-util", ] [[package]] name = "futures-io" version = "0.3.16" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "0b0e06c393068f3a6ef246c75cdca793d6a46347e75286933e5e75fd2fd11582" [[package]] name = "futures-lite" version = "1.12.0" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "7694489acd39452c77daa48516b894c153f192c3578d5a839b62c58099fcbf48" dependencies = [ "fastrand", "futures-core", "futures-io", "memchr", "parking", "pin-project-lite 0.2.7", "waker-fn", ] [[package]] name = "futures-macro" version = "0.3.16" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "c54913bae956fb8df7f4dc6fc90362aa72e69148e3f39041fbe8742d21e0ac57" dependencies = [ "autocfg 1.0.1", "proc-macro-hack", "proc-macro2", "quote", "syn", ] [[package]] name = "futures-sink" version = "0.3.16" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "c0f30aaa67363d119812743aa5f33c201a7a66329f97d1a887022971feea4b53" [[package]] name = "futures-task" version = "0.3.16" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "bbe54a98670017f3be909561f6ad13e810d9a51f3f061b902062ca3da80799f2" [[package]] name = "futures-util" version = "0.3.16" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "67eb846bfd58e44a8481a00049e82c43e0ccb5d61f8dc071057cb19249dd4d78" dependencies = [ "autocfg 1.0.1", "futures-channel", "futures-core", "futures-io", "futures-macro", "futures-sink", |
︙ | ︙ | |||
993 994 995 996 997 998 999 | "slab", "tokio 0.2.25", "tokio-util", "tracing", "tracing-futures", ] | < < < < < < | | 992 993 994 995 996 997 998 999 1000 1001 1002 1003 1004 1005 1006 1007 1008 1009 1010 1011 1012 1013 1014 1015 1016 1017 1018 1019 1020 1021 | "slab", "tokio 0.2.25", "tokio-util", "tracing", "tracing-futures", ] [[package]] name = "hashbrown" version = "0.11.2" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "ab5ef0d4909ef3724cc8cce6ccc8572c5c817592e9285f5464f8e86f8bd3726e" dependencies = [ "ahash", ] [[package]] name = "hashlink" version = "0.7.0" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "7249a3129cbc1ffccd74857f81464a323a152173cdb134e0fd81bc803b29facf" dependencies = [ "hashbrown", ] [[package]] name = "heck" version = "0.3.3" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "6d621efb26863f0e9924c6ac577e8275e5e6b77455db64ffa6c65c904e9e132c" |
︙ | ︙ | |||
1217 1218 1219 1220 1221 1222 1223 | "matches", "unicode-bidi", "unicode-normalization", ] [[package]] name = "indexmap" | | | | | | | 1210 1211 1212 1213 1214 1215 1216 1217 1218 1219 1220 1221 1222 1223 1224 1225 1226 1227 1228 1229 1230 1231 1232 1233 1234 1235 1236 | "matches", "unicode-bidi", "unicode-normalization", ] [[package]] name = "indexmap" version = "1.7.0" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "bc633605454125dec4b66843673f01c7df2b89479b32e0ed634e43a91cff62a5" dependencies = [ "autocfg 1.0.1", "hashbrown", ] [[package]] name = "instant" version = "0.1.10" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "bee0328b1209d157ef001c94dd85b4f8f64139adb0eac2659f4b08382b2f474d" dependencies = [ "cfg-if 1.0.0", ] [[package]] name = "iovec" version = "0.1.4" |
︙ | ︙ | |||
1298 1299 1300 1301 1302 1303 1304 | "cfg-if 1.0.0", "ryu", "static_assertions", ] [[package]] name = "libc" | | | | 1291 1292 1293 1294 1295 1296 1297 1298 1299 1300 1301 1302 1303 1304 1305 1306 1307 | "cfg-if 1.0.0", "ryu", "static_assertions", ] [[package]] name = "libc" version = "0.2.98" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "320cfe77175da3a483efed4bc0adc1968ca050b098ce4f2f1c13a56626128790" [[package]] name = "linked-hash-map" version = "0.5.4" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "7fb9b38af92608140b86b693604b9ffcc5824240a484d1ecd4795bacb2fe88f3" |
︙ | ︙ | |||
1744 1745 1746 1747 1748 1749 1750 | dependencies = [ "siphasher", "unicase 1.4.2", ] [[package]] name = "pin-project" | | | | | | 1737 1738 1739 1740 1741 1742 1743 1744 1745 1746 1747 1748 1749 1750 1751 1752 1753 1754 1755 1756 1757 1758 1759 1760 1761 1762 | dependencies = [ "siphasher", "unicase 1.4.2", ] [[package]] name = "pin-project" version = "1.0.8" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "576bc800220cc65dac09e99e97b08b358cfab6e17078de8dc5fee223bd2d0c08" dependencies = [ "pin-project-internal", ] [[package]] name = "pin-project-internal" version = "1.0.8" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "6e8fe8163d14ce7f0cdac2e040116f22eac817edabff0be91e8aff7e9accf389" dependencies = [ "proc-macro2", "quote", "syn", ] [[package]] |
︙ | ︙ | |||
1819 1820 1821 1822 1823 1824 1825 | name = "proc-macro-nested" version = "0.1.7" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "bc881b2c22681370c6a780e47af9840ef841837bc98118431d4e1868bd0c1086" [[package]] name = "proc-macro2" | | | | 1812 1813 1814 1815 1816 1817 1818 1819 1820 1821 1822 1823 1824 1825 1826 1827 1828 | name = "proc-macro-nested" version = "0.1.7" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "bc881b2c22681370c6a780e47af9840ef841837bc98118431d4e1868bd0c1086" [[package]] name = "proc-macro2" version = "1.0.28" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "5c7ed8b8c7b886ea3ed7dde405212185f423ab44682667c8c6dd14aa1d9f6612" dependencies = [ "unicode-xid", ] [[package]] name = "publicsuffix" version = "1.5.6" |
︙ | ︙ | |||
2114 2115 2116 2117 2118 2119 2120 | "derive_builder", "quick-xml", "reqwest", ] [[package]] name = "rsstg" | | | | 2107 2108 2109 2110 2111 2112 2113 2114 2115 2116 2117 2118 2119 2120 2121 2122 2123 2124 2125 2126 | "derive_builder", "quick-xml", "reqwest", ] [[package]] name = "rsstg" version = "0.1.17" dependencies = [ "anyhow", "chrono", "config", "futures 0.3.16", "futures-util", "lazy_static", "regex", "rss", "sqlx", "telegram-bot", "tokio 0.2.25", |
︙ | ︙ | |||
2283 2284 2285 2286 2287 2288 2289 | "itoa", "serde 1.0.126", "url 1.7.2", ] [[package]] name = "sha-1" | | | | 2276 2277 2278 2279 2280 2281 2282 2283 2284 2285 2286 2287 2288 2289 2290 2291 2292 | "itoa", "serde 1.0.126", "url 1.7.2", ] [[package]] name = "sha-1" version = "0.9.7" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "1a0c8611594e2ab4ebbf06ec7cbbf0a99450b8570e96cbf5188b5d5f6ef18d81" dependencies = [ "block-buffer", "cfg-if 1.0.0", "cpufeatures", "digest", "opaque-debug", ] |
︙ | ︙ | |||
2452 2453 2454 2455 2456 2457 2458 | name = "sqlx-macros" version = "0.5.5" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "47e4a2349d1ffd60a03ca0de3f116ba55d7f406e55a0d84c64a5590866d94c06" dependencies = [ "dotenv", "either", | | | 2445 2446 2447 2448 2449 2450 2451 2452 2453 2454 2455 2456 2457 2458 2459 | name = "sqlx-macros" version = "0.5.5" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "47e4a2349d1ffd60a03ca0de3f116ba55d7f406e55a0d84c64a5590866d94c06" dependencies = [ "dotenv", "either", "futures 0.3.16", "heck", "once_cell", "proc-macro2", "quote", "sha2", "sqlx-core", "sqlx-rt", |
︙ | ︙ | |||
2508 2509 2510 2511 2512 2513 2514 | name = "strsim" version = "0.9.3" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "6446ced80d6c486436db5c078dde11a9f73d42b57fb273121e160b84f63d894c" [[package]] name = "subtle" | | | | | | | | | 2501 2502 2503 2504 2505 2506 2507 2508 2509 2510 2511 2512 2513 2514 2515 2516 2517 2518 2519 2520 2521 2522 2523 2524 2525 2526 2527 2528 2529 2530 2531 2532 2533 2534 2535 2536 2537 2538 2539 2540 2541 2542 2543 2544 2545 2546 2547 2548 2549 2550 2551 2552 2553 2554 2555 | name = "strsim" version = "0.9.3" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "6446ced80d6c486436db5c078dde11a9f73d42b57fb273121e160b84f63d894c" [[package]] name = "subtle" version = "2.4.1" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "6bdef32e8150c2a081110b42772ffe7d7c9032b606bc226c8260fd97e0976601" [[package]] name = "syn" version = "1.0.74" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "1873d832550d4588c3dbc20f01361ab00bfe741048f71e3fecf145a7cc18b29c" dependencies = [ "proc-macro2", "quote", "unicode-xid", ] [[package]] name = "synstructure" version = "0.12.5" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "474aaa926faa1603c40b7885a9eaea29b444d1cb2850cb7c0e37bb1a4182f4fa" dependencies = [ "proc-macro2", "quote", "syn", "unicode-xid", ] [[package]] name = "tap" version = "1.0.1" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "55937e1799185b12863d447f42597ed69d9928686b8d88a1df17376a097d8369" [[package]] name = "telegram-bot" version = "0.8.0" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "fc9552e972bcb551705fcad45bd0b86eca12a22379db36cdfa6d053e1a19b2de" dependencies = [ "bytes 0.5.6", "futures 0.3.16", "hyper 0.13.10", "hyper-tls 0.4.3", "multipart", "telegram-bot-raw", "tokio 0.2.25", "tracing", "tracing-futures", |
︙ | ︙ | |||
2587 2588 2589 2590 2591 2592 2593 | "redox_syscall 0.2.9", "remove_dir_all", "winapi 0.3.9", ] [[package]] name = "thiserror" | | | | | | | | 2580 2581 2582 2583 2584 2585 2586 2587 2588 2589 2590 2591 2592 2593 2594 2595 2596 2597 2598 2599 2600 2601 2602 2603 2604 2605 2606 2607 2608 2609 2610 2611 2612 2613 2614 2615 2616 2617 2618 2619 2620 2621 2622 2623 2624 2625 2626 | "redox_syscall 0.2.9", "remove_dir_all", "winapi 0.3.9", ] [[package]] name = "thiserror" version = "1.0.26" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "93119e4feac1cbe6c798c34d3a53ea0026b0b1de6a120deef895137c0529bfe2" dependencies = [ "thiserror-impl", ] [[package]] name = "thiserror-impl" version = "1.0.26" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "060d69a0afe7796bf42e9e2ff91f5ee691fb15c53d38b4b62a9a53eb23164745" dependencies = [ "proc-macro2", "quote", "syn", ] [[package]] name = "time" version = "0.1.43" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "ca8a50ef2360fbd1eeb0ecd46795a87a19024eb4b53c5dc916ca1fd95fe62438" dependencies = [ "libc", "winapi 0.3.9", ] [[package]] name = "tinyvec" version = "1.3.1" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "848a1e1181b9f6753b5e96a092749e29b11d19ede67dfbbd6c7dc7e0f49b5338" dependencies = [ "tinyvec_macros", ] [[package]] name = "tinyvec_macros" version = "0.1.0" |
︙ | ︙ | |||
2933 2934 2935 2936 2937 2938 2939 | checksum = "d54590932941a9e9266f0832deed84ebe1bf2e4c9e4a3554d393d18f5e854bf9" dependencies = [ "tinyvec", ] [[package]] name = "unicode-segmentation" | | | | 2926 2927 2928 2929 2930 2931 2932 2933 2934 2935 2936 2937 2938 2939 2940 2941 2942 | checksum = "d54590932941a9e9266f0832deed84ebe1bf2e4c9e4a3554d393d18f5e854bf9" dependencies = [ "tinyvec", ] [[package]] name = "unicode-segmentation" version = "1.8.0" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "8895849a949e7845e06bd6dc1aa51731a103c42707010a5b591c0038fb73385b" [[package]] name = "unicode-xid" version = "0.2.2" source = "registry+https://github.com/rust-lang/crates.io-index" checksum = "8ccb82d61f80a663efe1f787a51b16b5a51e3314d6ac365b08639f52387b33f3" |
︙ | ︙ |
Modified Cargo.toml
from [34be446701]
to [cc71d84a8c].
1 2 | [package] name = "rsstg" | | | 1 2 3 4 5 6 7 8 9 10 | [package] name = "rsstg" version = "0.1.17" authors = ["arcade"] edition = "2018" [dependencies] chrono = "*" config = "*" futures = "*" |
︙ | ︙ |
Modified src/main.rs
from [cd18fd479e]
to [8391fce4ec].
︙ | ︙ | |||
260 261 262 263 264 265 266 | Err(err) => { bail!("Sorry, unknown error:\n{:#?}\n", err); }, }; } async fn autofetch(&self) -> Result<()> { | | | | 260 261 262 263 264 265 266 267 268 269 270 271 272 273 274 275 276 277 278 279 280 | Err(err) => { bail!("Sorry, unknown error:\n{:#?}\n", err); }, }; } async fn autofetch(&self) -> Result<()> { let mut delay = chrono::Duration::minutes(1); let mut now; loop { let mut conn = self.pool.acquire().await .with_context(|| format!("Autofetch fetch conn:\n{:?}", &self.pool))?; now = chrono::Local::now(); let mut queue = sqlx::query("select source_id, next_fetch, owner from rsstg_order natural left join rsstg_source where next_fetch < now() + interval '1 minute';") .fetch_all(&mut conn).await?; for row in queue.iter() { let source_id: i32 = row.try_get("source_id")?; let owner: i64 = row.try_get("owner")?; let next_fetch: DateTime<chrono::Local> = row.try_get("next_fetch")?; if next_fetch < now { //let clone = self.clone(); |
︙ | ︙ | |||
294 295 296 297 298 299 300 | if next_fetch - now < delay { delay = next_fetch - now; } } }; queue.clear(); tokio::time::delay_for(delay.to_std()?).await; | | | 294 295 296 297 298 299 300 301 302 303 304 305 306 307 308 | if next_fetch - now < delay { delay = next_fetch - now; } } }; queue.clear(); tokio::time::delay_for(delay.to_std()?).await; delay = chrono::Duration::minutes(1); } } async fn list<S>(&self, owner: S) -> Result<Vec<String>> where S: Into<i64> { let owner = owner.into(); let mut reply = vec![]; |
︙ | ︙ | |||
335 336 337 338 339 340 341 342 343 344 345 346 347 348 | async fn main() -> Result<()> { let mut settings = config::Config::default(); settings.merge(config::File::with_name("rsstg"))?; let core = Core::new(settings).await?; let mut stream = core.stream(); let mut reply_to: Option<UserId>; loop { reply_to = None; match stream.next().await { Some(update) => { if let Err(err) = handle(update?, &core, &mut reply_to).await { | > | 335 336 337 338 339 340 341 342 343 344 345 346 347 348 349 | async fn main() -> Result<()> { let mut settings = config::Config::default(); settings.merge(config::File::with_name("rsstg"))?; let core = Core::new(settings).await?; let mut stream = core.stream(); stream.allowed_updates(&[AllowedUpdate::Message]); let mut reply_to: Option<UserId>; loop { reply_to = None; match stream.next().await { Some(update) => { if let Err(err) = handle(update?, &core, &mut reply_to).await { |
︙ | ︙ |