From 550a8b05c4c12bde31929b404243fdaa3a13beb8 Mon Sep 17 00:00:00 2001 From: blank X Date: Tue, 23 Mar 2021 16:18:56 +0700 Subject: [PATCH] Initial commit --- .gitignore | 1 + Cargo.lock | 1043 +++++++++++++++++++++++++++++++++++++++++ Cargo.toml | 19 + LICENSE | 21 + src/github/mod.rs | 292 ++++++++++++ src/github/structs.rs | 80 ++++ src/gitlab/mod.rs | 256 ++++++++++ src/gitlab/structs.rs | 136 ++++++ src/main.rs | 18 + 9 files changed, 1866 insertions(+) create mode 100644 .gitignore create mode 100644 Cargo.lock create mode 100644 Cargo.toml create mode 100644 LICENSE create mode 100644 src/github/mod.rs create mode 100644 src/github/structs.rs create mode 100644 src/gitlab/mod.rs create mode 100644 src/gitlab/structs.rs create mode 100644 src/main.rs diff --git a/.gitignore b/.gitignore new file mode 100644 index 0000000..ea8c4bf --- /dev/null +++ b/.gitignore @@ -0,0 +1 @@ +/target diff --git a/Cargo.lock b/Cargo.lock new file mode 100644 index 0000000..eaeeddf --- /dev/null +++ b/Cargo.lock @@ -0,0 +1,1043 @@ +# This file is automatically @generated by Cargo. +# It is not intended for manual editing. +[[package]] +name = "autocfg" +version = "1.0.1" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "cdb031dd78e28731d87d56cc8ffef4a8f36ca26c38fe2de700543e627f8a464a" + +[[package]] +name = "base64" +version = "0.13.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "904dfeac50f3cdaba28fc6f57fdcddb75f49ed61346676a78c4ffe55877802fd" + +[[package]] +name = "bitflags" +version = "1.2.1" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "cf1de2fe8c75bc145a2f577add951f8134889b4795d47466a54a5c846d691693" + +[[package]] +name = "bumpalo" +version = "3.6.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "099e596ef14349721d9016f6b80dd3419ea1bf289ab9b44df8e4dfd3a005d5d9" + +[[package]] +name = "bytes" +version = "1.0.1" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "b700ce4376041dcd0a327fd0097c41095743c4c8af8887265942faf1100bd040" + +[[package]] +name = "cc" +version = "1.0.67" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "e3c69b077ad434294d3ce9f1f6143a2a4b89a8a2d54ef813d85003a4fd1137fd" + +[[package]] +name = "cfg-if" +version = "1.0.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "baf1de4339761588bc0619e3cbc0120ee582ebb74b53b4efbf79117bd2da40fd" + +[[package]] +name = "chrono" +version = "0.4.19" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "670ad68c9088c2a963aaa298cb369688cf3f9465ce5e2d4ca10e6e0098a1ce73" +dependencies = [ + "num-integer", + "num-traits", +] + +[[package]] +name = "core-foundation" +version = "0.9.1" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "0a89e2ae426ea83155dccf10c0fa6b1463ef6d5fcb44cee0b224a408fa640a62" +dependencies = [ + "core-foundation-sys", + "libc", +] + +[[package]] +name = "core-foundation-sys" +version = "0.8.2" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "ea221b5284a47e40033bf9b66f35f984ec0ea2931eb03505246cd27a963f981b" + +[[package]] +name = "encoding_rs" +version = "0.8.28" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "80df024fbc5ac80f87dfef0d9f5209a252f2a497f7f42944cff24d8253cac065" +dependencies = [ + "cfg-if", +] + +[[package]] +name = "fnv" +version = "1.0.7" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "3f9eec918d3f24069decb9af1554cad7c880e2da24a9afd88aca000531ab82c1" + +[[package]] +name = "foreign-types" +version = "0.3.2" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "f6f339eb8adc052cd2ca78910fda869aefa38d22d5cb648e6485e4d3fc06f3b1" +dependencies = [ + "foreign-types-shared", +] + +[[package]] +name = "foreign-types-shared" +version = "0.1.1" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "00b0228411908ca8685dba7fc2cdd70ec9990a6e753e89b6ac91a84c40fbaf4b" + +[[package]] +name = "form_urlencoded" +version = "1.0.1" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "5fc25a87fa4fd2094bffb06925852034d90a17f0d1e05197d4956d3555752191" +dependencies = [ + "matches", + "percent-encoding", +] + +[[package]] +name = "futures-channel" +version = "0.3.13" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "8c2dd2df839b57db9ab69c2c9d8f3e8c81984781937fe2807dc6dcf3b2ad2939" +dependencies = [ + "futures-core", +] + +[[package]] +name = "futures-core" +version = "0.3.13" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "15496a72fabf0e62bdc3df11a59a3787429221dd0710ba8ef163d6f7a9112c94" + +[[package]] +name = "futures-sink" +version = "0.3.13" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "85754d98985841b7d4f5e8e6fbfa4a4ac847916893ec511a2917ccd8525b8bb3" + +[[package]] +name = "futures-task" +version = "0.3.13" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "fa189ef211c15ee602667a6fcfe1c1fd9e07d42250d2156382820fba33c9df80" + +[[package]] +name = "futures-util" +version = "0.3.13" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "1812c7ab8aedf8d6f2701a43e1243acdbcc2b36ab26e2ad421eb99ac963d96d1" +dependencies = [ + "futures-core", + "futures-task", + "pin-project-lite", + "pin-utils", +] + +[[package]] +name = "getopts" +version = "0.2.21" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "14dbbfd5c71d70241ecf9e6f13737f7b5ce823821063188d7e46c41d371eebd5" +dependencies = [ + "unicode-width", +] + +[[package]] +name = "getrandom" +version = "0.2.2" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "c9495705279e7140bf035dde1f6e750c162df8b625267cd52cc44e0b156732c8" +dependencies = [ + "cfg-if", + "libc", + "wasi", +] + +[[package]] +name = "h2" +version = "0.3.1" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "d832b01df74254fe364568d6ddc294443f61cbec82816b60904303af87efae78" +dependencies = [ + "bytes", + "fnv", + "futures-core", + "futures-sink", + "futures-util", + "http", + "indexmap", + "slab", + "tokio", + "tokio-util", + "tracing", +] + +[[package]] +name = "hashbrown" +version = "0.9.1" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "d7afe4a420e3fe79967a00898cc1f4db7c8a49a9333a29f8a4bd76a253d5cd04" + +[[package]] +name = "http" +version = "0.2.3" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "7245cd7449cc792608c3c8a9eaf69bd4eabbabf802713748fd739c98b82f0747" +dependencies = [ + "bytes", + "fnv", + "itoa", +] + +[[package]] +name = "http-body" +version = "0.4.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "2861bd27ee074e5ee891e8b539837a9430012e249d7f0ca2d795650f579c1994" +dependencies = [ + "bytes", + "http", +] + +[[package]] +name = "httparse" +version = "1.3.5" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "615caabe2c3160b313d52ccc905335f4ed5f10881dd63dc5699d47e90be85691" + +[[package]] +name = "httpdate" +version = "0.3.2" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "494b4d60369511e7dea41cf646832512a94e542f68bb9c49e54518e0f468eb47" + +[[package]] +name = "hyper" +version = "0.14.4" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "e8e946c2b1349055e0b72ae281b238baf1a3ea7307c7e9f9d64673bdd9c26ac7" +dependencies = [ + "bytes", + "futures-channel", + "futures-core", + "futures-util", + "h2", + "http", + "http-body", + "httparse", + "httpdate", + "itoa", + "pin-project", + "socket2", + "tokio", + "tower-service", + "tracing", + "want", +] + +[[package]] +name = "hyper-tls" +version = "0.5.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "d6183ddfa99b85da61a140bea0efc93fdf56ceaa041b37d553518030827f9905" +dependencies = [ + "bytes", + "hyper", + "native-tls", + "tokio", + "tokio-native-tls", +] + +[[package]] +name = "idna" +version = "0.2.2" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "89829a5d69c23d348314a7ac337fe39173b61149a9864deabd260983aed48c21" +dependencies = [ + "matches", + "unicode-bidi", + "unicode-normalization", +] + +[[package]] +name = "indexmap" +version = "1.6.2" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "824845a0bf897a9042383849b02c1bc219c2383772efcd5c6f9766fa4b81aef3" +dependencies = [ + "autocfg", + "hashbrown", +] + +[[package]] +name = "ipnet" +version = "2.3.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "47be2f14c678be2fdcab04ab1171db51b2762ce6f0a8ee87c8dd4a04ed216135" + +[[package]] +name = "issuerss" +version = "0.1.0" +dependencies = [ + "chrono", + "pulldown-cmark", + "quick-xml", + "reqwest", + "serde", + "serde_json", + "tokio", +] + +[[package]] +name = "itoa" +version = "0.4.7" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "dd25036021b0de88a0aff6b850051563c6516d0bf53f8638938edbb9de732736" + +[[package]] +name = "js-sys" +version = "0.3.47" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "5cfb73131c35423a367daf8cbd24100af0d077668c8c2943f0e7dd775fef0f65" +dependencies = [ + "wasm-bindgen", +] + +[[package]] +name = "lazy_static" +version = "1.4.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "e2abad23fbc42b3700f2f279844dc832adb2b2eb069b2df918f455c4e18cc646" + +[[package]] +name = "libc" +version = "0.2.90" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "ba4aede83fc3617411dc6993bc8c70919750c1c257c6ca6a502aed6e0e2394ae" + +[[package]] +name = "log" +version = "0.4.14" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "51b9bbe6c47d51fc3e1a9b945965946b4c44142ab8792c50835a980d362c2710" +dependencies = [ + "cfg-if", +] + +[[package]] +name = "matches" +version = "0.1.8" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "7ffc5c5338469d4d3ea17d269fa8ea3512ad247247c30bd2df69e68309ed0a08" + +[[package]] +name = "memchr" +version = "2.3.4" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "0ee1c47aaa256ecabcaea351eae4a9b01ef39ed810004e298d2511ed284b1525" + +[[package]] +name = "mime" +version = "0.3.16" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "2a60c7ce501c71e03a9c9c0d35b861413ae925bd979cc7a4e30d060069aaac8d" + +[[package]] +name = "mio" +version = "0.7.10" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "2182a122f3b7f3f5329cb1972cee089ba2459a0a80a56935e6e674f096f8d839" +dependencies = [ + "libc", + "log", + "miow", + "ntapi", + "winapi", +] + +[[package]] +name = "miow" +version = "0.3.6" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "5a33c1b55807fbed163481b5ba66db4b2fa6cde694a5027be10fb724206c5897" +dependencies = [ + "socket2", + "winapi", +] + +[[package]] +name = "native-tls" +version = "0.2.7" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "b8d96b2e1c8da3957d58100b09f102c6d9cfdfced01b7ec5a8974044bb09dbd4" +dependencies = [ + "lazy_static", + "libc", + "log", + "openssl", + "openssl-probe", + "openssl-sys", + "schannel", + "security-framework", + "security-framework-sys", + "tempfile", +] + +[[package]] +name = "ntapi" +version = "0.3.6" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "3f6bb902e437b6d86e03cce10a7e2af662292c5dfef23b65899ea3ac9354ad44" +dependencies = [ + "winapi", +] + +[[package]] +name = "num-integer" +version = "0.1.44" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "d2cc698a63b549a70bc047073d2949cce27cd1c7b0a4a862d08a8031bc2801db" +dependencies = [ + "autocfg", + "num-traits", +] + +[[package]] +name = "num-traits" +version = "0.2.14" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "9a64b1ec5cda2586e284722486d802acf1f7dbdc623e2bfc57e65ca1cd099290" +dependencies = [ + "autocfg", +] + +[[package]] +name = "once_cell" +version = "1.7.2" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "af8b08b04175473088b46763e51ee54da5f9a164bc162f615b91bc179dbf15a3" + +[[package]] +name = "openssl" +version = "0.10.33" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "a61075b62a23fef5a29815de7536d940aa35ce96d18ce0cc5076272db678a577" +dependencies = [ + "bitflags", + "cfg-if", + "foreign-types", + "libc", + "once_cell", + "openssl-sys", +] + +[[package]] +name = "openssl-probe" +version = "0.1.2" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "77af24da69f9d9341038eba93a073b1fdaaa1b788221b00a69bce9e762cb32de" + +[[package]] +name = "openssl-sys" +version = "0.9.61" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "313752393519e876837e09e1fa183ddef0be7735868dced3196f4472d536277f" +dependencies = [ + "autocfg", + "cc", + "libc", + "pkg-config", + "vcpkg", +] + +[[package]] +name = "percent-encoding" +version = "2.1.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "d4fd5641d01c8f18a23da7b6fe29298ff4b55afcccdf78973b24cf3175fee32e" + +[[package]] +name = "pin-project" +version = "1.0.5" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "96fa8ebb90271c4477f144354485b8068bd8f6b78b428b01ba892ca26caf0b63" +dependencies = [ + "pin-project-internal", +] + +[[package]] +name = "pin-project-internal" +version = "1.0.5" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "758669ae3558c6f74bd2a18b41f7ac0b5a195aea6639d6a9b5e5d1ad5ba24c0b" +dependencies = [ + "proc-macro2", + "quote", + "syn", +] + +[[package]] +name = "pin-project-lite" +version = "0.2.6" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "dc0e1f259c92177c30a4c9d177246edd0a3568b25756a977d0632cf8fa37e905" + +[[package]] +name = "pin-utils" +version = "0.1.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "8b870d8c151b6f2fb93e84a13146138f05d02ed11c7e7c54f8826aaaf7c9f184" + +[[package]] +name = "pkg-config" +version = "0.3.19" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "3831453b3449ceb48b6d9c7ad7c96d5ea673e9b470a1dc578c2ce6521230884c" + +[[package]] +name = "ppv-lite86" +version = "0.2.10" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "ac74c624d6b2d21f425f752262f42188365d7b8ff1aff74c82e45136510a4857" + +[[package]] +name = "proc-macro2" +version = "1.0.24" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "1e0704ee1a7e00d7bb417d0770ea303c1bccbabf0ef1667dae92b5967f5f8a71" +dependencies = [ + "unicode-xid", +] + +[[package]] +name = "pulldown-cmark" +version = "0.8.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "ffade02495f22453cd593159ea2f59827aae7f53fa8323f756799b670881dcf8" +dependencies = [ + "bitflags", + "getopts", + "memchr", + "unicase", +] + +[[package]] +name = "quick-xml" +version = "0.22.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "8533f14c8382aaad0d592c812ac3b826162128b65662331e1127b45c3d18536b" +dependencies = [ + "memchr", +] + +[[package]] +name = "quote" +version = "1.0.9" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "c3d0b9745dc2debf507c8422de05d7226cc1f0644216dfdfead988f9b1ab32a7" +dependencies = [ + "proc-macro2", +] + +[[package]] +name = "rand" +version = "0.8.3" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "0ef9e7e66b4468674bfcb0c81af8b7fa0bb154fa9f28eb840da5c447baeb8d7e" +dependencies = [ + "libc", + "rand_chacha", + "rand_core", + "rand_hc", +] + +[[package]] +name = "rand_chacha" +version = "0.3.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "e12735cf05c9e10bf21534da50a147b924d555dc7a547c42e6bb2d5b6017ae0d" +dependencies = [ + "ppv-lite86", + "rand_core", +] + +[[package]] +name = "rand_core" +version = "0.6.2" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "34cf66eb183df1c5876e2dcf6b13d57340741e8dc255b48e40a26de954d06ae7" +dependencies = [ + "getrandom", +] + +[[package]] +name = "rand_hc" +version = "0.3.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "3190ef7066a446f2e7f42e239d161e905420ccab01eb967c9eb27d21b2322a73" +dependencies = [ + "rand_core", +] + +[[package]] +name = "redox_syscall" +version = "0.2.4" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "05ec8ca9416c5ea37062b502703cd7fcb207736bc294f6e0cf367ac6fc234570" +dependencies = [ + "bitflags", +] + +[[package]] +name = "remove_dir_all" +version = "0.5.3" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "3acd125665422973a33ac9d3dd2df85edad0f4ae9b00dafb1a05e43a9f5ef8e7" +dependencies = [ + "winapi", +] + +[[package]] +name = "reqwest" +version = "0.11.2" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "bf12057f289428dbf5c591c74bf10392e4a8003f993405a902f20117019022d4" +dependencies = [ + "base64", + "bytes", + "encoding_rs", + "futures-core", + "futures-util", + "http", + "http-body", + "hyper", + "hyper-tls", + "ipnet", + "js-sys", + "lazy_static", + "log", + "mime", + "native-tls", + "percent-encoding", + "pin-project-lite", + "serde", + "serde_urlencoded", + "tokio", + "tokio-native-tls", + "url", + "wasm-bindgen", + "wasm-bindgen-futures", + "web-sys", + "winreg", +] + +[[package]] +name = "ryu" +version = "1.0.5" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "71d301d4193d031abdd79ff7e3dd721168a9572ef3fe51a1517aba235bd8f86e" + +[[package]] +name = "schannel" +version = "0.1.19" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "8f05ba609c234e60bee0d547fe94a4c7e9da733d1c962cf6e59efa4cd9c8bc75" +dependencies = [ + "lazy_static", + "winapi", +] + +[[package]] +name = "security-framework" +version = "2.0.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "c1759c2e3c8580017a484a7ac56d3abc5a6c1feadf88db2f3633f12ae4268c69" +dependencies = [ + "bitflags", + "core-foundation", + "core-foundation-sys", + "libc", + "security-framework-sys", +] + +[[package]] +name = "security-framework-sys" +version = "2.0.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "f99b9d5e26d2a71633cc4f2ebae7cc9f874044e0c351a27e17892d76dce5678b" +dependencies = [ + "core-foundation-sys", + "libc", +] + +[[package]] +name = "serde" +version = "1.0.124" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "bd761ff957cb2a45fbb9ab3da6512de9de55872866160b23c25f1a841e99d29f" +dependencies = [ + "serde_derive", +] + +[[package]] +name = "serde_derive" +version = "1.0.124" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "1800f7693e94e186f5e25a28291ae1570da908aff7d97a095dec1e56ff99069b" +dependencies = [ + "proc-macro2", + "quote", + "syn", +] + +[[package]] +name = "serde_json" +version = "1.0.64" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "799e97dc9fdae36a5c8b8f2cae9ce2ee9fdce2058c57a93e6099d919fd982f79" +dependencies = [ + "itoa", + "ryu", + "serde", +] + +[[package]] +name = "serde_urlencoded" +version = "0.7.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "edfa57a7f8d9c1d260a549e7224100f6c43d43f9103e06dd8b4095a9b2b43ce9" +dependencies = [ + "form_urlencoded", + "itoa", + "ryu", + "serde", +] + +[[package]] +name = "slab" +version = "0.4.2" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "c111b5bd5695e56cffe5129854aa230b39c93a305372fdbb2668ca2394eea9f8" + +[[package]] +name = "socket2" +version = "0.3.19" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "122e570113d28d773067fab24266b66753f6ea915758651696b6e35e49f88d6e" +dependencies = [ + "cfg-if", + "libc", + "winapi", +] + +[[package]] +name = "syn" +version = "1.0.64" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "3fd9d1e9976102a03c542daa2eff1b43f9d72306342f3f8b3ed5fb8908195d6f" +dependencies = [ + "proc-macro2", + "quote", + "unicode-xid", +] + +[[package]] +name = "tempfile" +version = "3.2.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "dac1c663cfc93810f88aed9b8941d48cabf856a1b111c29a40439018d870eb22" +dependencies = [ + "cfg-if", + "libc", + "rand", + "redox_syscall", + "remove_dir_all", + "winapi", +] + +[[package]] +name = "tinyvec" +version = "1.1.1" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "317cca572a0e89c3ce0ca1f1bdc9369547fe318a683418e42ac8f59d14701023" +dependencies = [ + "tinyvec_macros", +] + +[[package]] +name = "tinyvec_macros" +version = "0.1.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "cda74da7e1a664f795bb1f8a87ec406fb89a02522cf6e50620d016add6dbbf5c" + +[[package]] +name = "tokio" +version = "1.4.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "134af885d758d645f0f0505c9a8b3f9bf8a348fd822e112ab5248138348f1722" +dependencies = [ + "autocfg", + "bytes", + "libc", + "memchr", + "mio", + "pin-project-lite", +] + +[[package]] +name = "tokio-native-tls" +version = "0.3.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "f7d995660bd2b7f8c1568414c1126076c13fbb725c40112dc0120b78eb9b717b" +dependencies = [ + "native-tls", + "tokio", +] + +[[package]] +name = "tokio-util" +version = "0.6.4" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "ec31e5cc6b46e653cf57762f36f71d5e6386391d88a72fd6db4508f8f676fb29" +dependencies = [ + "bytes", + "futures-core", + "futures-sink", + "log", + "pin-project-lite", + "tokio", +] + +[[package]] +name = "tower-service" +version = "0.3.1" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "360dfd1d6d30e05fda32ace2c8c70e9c0a9da713275777f5a4dbb8a1893930c6" + +[[package]] +name = "tracing" +version = "0.1.25" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "01ebdc2bb4498ab1ab5f5b73c5803825e60199229ccba0698170e3be0e7f959f" +dependencies = [ + "cfg-if", + "pin-project-lite", + "tracing-core", +] + +[[package]] +name = "tracing-core" +version = "0.1.17" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "f50de3927f93d202783f4513cda820ab47ef17f624b03c096e86ef00c67e6b5f" +dependencies = [ + "lazy_static", +] + +[[package]] +name = "try-lock" +version = "0.2.3" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "59547bce71d9c38b83d9c0e92b6066c4253371f15005def0c30d9657f50c7642" + +[[package]] +name = "unicase" +version = "2.6.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "50f37be617794602aabbeee0be4f259dc1778fabe05e2d67ee8f79326d5cb4f6" +dependencies = [ + "version_check", +] + +[[package]] +name = "unicode-bidi" +version = "0.3.4" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "49f2bd0c6468a8230e1db229cff8029217cf623c767ea5d60bfbd42729ea54d5" +dependencies = [ + "matches", +] + +[[package]] +name = "unicode-normalization" +version = "0.1.17" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "07fbfce1c8a97d547e8b5334978438d9d6ec8c20e38f56d4a4374d181493eaef" +dependencies = [ + "tinyvec", +] + +[[package]] +name = "unicode-width" +version = "0.1.8" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "9337591893a19b88d8d87f2cec1e73fad5cdfd10e5a6f349f498ad6ea2ffb1e3" + +[[package]] +name = "unicode-xid" +version = "0.2.1" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "f7fe0bb3479651439c9112f72b6c505038574c9fbb575ed1bf3b797fa39dd564" + +[[package]] +name = "url" +version = "2.2.1" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "9ccd964113622c8e9322cfac19eb1004a07e636c545f325da085d5cdde6f1f8b" +dependencies = [ + "form_urlencoded", + "idna", + "matches", + "percent-encoding", +] + +[[package]] +name = "vcpkg" +version = "0.2.11" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "b00bca6106a5e23f3eee943593759b7fcddb00554332e856d990c893966879fb" + +[[package]] +name = "version_check" +version = "0.9.3" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "5fecdca9a5291cc2b8dcf7dc02453fee791a280f3743cb0905f8822ae463b3fe" + +[[package]] +name = "want" +version = "0.3.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "1ce8a968cb1cd110d136ff8b819a556d6fb6d919363c61534f6860c7eb172ba0" +dependencies = [ + "log", + "try-lock", +] + +[[package]] +name = "wasi" +version = "0.10.0+wasi-snapshot-preview1" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "1a143597ca7c7793eff794def352d41792a93c481eb1042423ff7ff72ba2c31f" + +[[package]] +name = "wasm-bindgen" +version = "0.2.70" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "55c0f7123de74f0dab9b7d00fd614e7b19349cd1e2f5252bbe9b1754b59433be" +dependencies = [ + "cfg-if", + "serde", + "serde_json", + "wasm-bindgen-macro", +] + +[[package]] +name = "wasm-bindgen-backend" +version = "0.2.70" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "7bc45447f0d4573f3d65720f636bbcc3dd6ce920ed704670118650bcd47764c7" +dependencies = [ + "bumpalo", + "lazy_static", + "log", + "proc-macro2", + "quote", + "syn", + "wasm-bindgen-shared", +] + +[[package]] +name = "wasm-bindgen-futures" +version = "0.4.20" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "3de431a2910c86679c34283a33f66f4e4abd7e0aec27b6669060148872aadf94" +dependencies = [ + "cfg-if", + "js-sys", + "wasm-bindgen", + "web-sys", +] + +[[package]] +name = "wasm-bindgen-macro" +version = "0.2.70" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "3b8853882eef39593ad4174dd26fc9865a64e84026d223f63bb2c42affcbba2c" +dependencies = [ + "quote", + "wasm-bindgen-macro-support", +] + +[[package]] +name = "wasm-bindgen-macro-support" +version = "0.2.70" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "4133b5e7f2a531fa413b3a1695e925038a05a71cf67e87dafa295cb645a01385" +dependencies = [ + "proc-macro2", + "quote", + "syn", + "wasm-bindgen-backend", + "wasm-bindgen-shared", +] + +[[package]] +name = "wasm-bindgen-shared" +version = "0.2.70" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "dd4945e4943ae02d15c13962b38a5b1e81eadd4b71214eee75af64a4d6a4fd64" + +[[package]] +name = "web-sys" +version = "0.3.47" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "c40dc691fc48003eba817c38da7113c15698142da971298003cac3ef175680b3" +dependencies = [ + "js-sys", + "wasm-bindgen", +] + +[[package]] +name = "winapi" +version = "0.3.9" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "5c839a674fcd7a98952e593242ea400abe93992746761e38641405d28b00f419" +dependencies = [ + "winapi-i686-pc-windows-gnu", + "winapi-x86_64-pc-windows-gnu", +] + +[[package]] +name = "winapi-i686-pc-windows-gnu" +version = "0.4.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "ac3b87c63620426dd9b991e5ce0329eff545bccbbb34f3be09ff6fb6ab51b7b6" + +[[package]] +name = "winapi-x86_64-pc-windows-gnu" +version = "0.4.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "712e227841d057c1ee1cd2fb22fa7e5a5461ae8e48fa2ca79ec42cfc1931183f" + +[[package]] +name = "winreg" +version = "0.7.0" +source = "registry+https://github.com/rust-lang/crates.io-index" +checksum = "0120db82e8a1e0b9fb3345a539c478767c0048d842860994d96113d5b667bd69" +dependencies = [ + "winapi", +] diff --git a/Cargo.toml b/Cargo.toml new file mode 100644 index 0000000..2124ed3 --- /dev/null +++ b/Cargo.toml @@ -0,0 +1,19 @@ +[package] +name = "issuerss" +version = "0.1.0" +authors = ["blank X "] +edition = "2018" + +# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html + +[profile.release] +lto = true + +[dependencies] +tokio = { version = "1.4", features = ["rt"] } +reqwest = "0.11" +serde = { version = "1.0", features = ["derive"] } +serde_json = "1.0" +chrono = { version = "0.4", default-features = false, features = ["std", "alloc"] } +pulldown-cmark = "0.8" +quick-xml = "0.22" diff --git a/LICENSE b/LICENSE new file mode 100644 index 0000000..211185a --- /dev/null +++ b/LICENSE @@ -0,0 +1,21 @@ +MIT License + +Copyright (c) 2021 blank X + +Permission is hereby granted, free of charge, to any person obtaining a copy +of this software and associated documentation files (the "Software"), to deal +in the Software without restriction, including without limitation the rights +to use, copy, modify, merge, publish, distribute, sublicense, and/or sell +copies of the Software, and to permit persons to whom the Software is +furnished to do so, subject to the following conditions: + +The above copyright notice and this permission notice shall be included in all +copies or substantial portions of the Software. + +THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR +IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, +FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE +AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER +LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, +OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE +SOFTWARE. diff --git a/src/github/mod.rs b/src/github/mod.rs new file mode 100644 index 0000000..cad3955 --- /dev/null +++ b/src/github/mod.rs @@ -0,0 +1,292 @@ +mod structs; + +use pulldown_cmark::{Options, Parser}; +use quick_xml::events::{BytesEnd, BytesStart, BytesText, Event}; +use quick_xml::Writer; +use reqwest::{ + header::{HeaderMap, HeaderValue}, + ClientBuilder, +}; +use std::env; +use std::io::Cursor; +use std::iter::Skip; +extern crate serde_json; + +pub async fn run(mut args: Skip) { + let repo = args.next().expect("Missing repo"); + let issue_number = args.next().expect("Missing issue number"); + let mut header_map = HeaderMap::new(); + header_map.insert( + "accept", + HeaderValue::from_static("application/vnd.github.v3+json"), + ); + let client = ClientBuilder::new() + .default_headers(header_map) + .user_agent(&format!( + "{}/{}", + env!("CARGO_PKG_NAME"), + env!("CARGO_PKG_VERSION") + )) + .build() + .unwrap(); + let text = client + .get(&format!( + "https://api.github.com/repos/{}/issues/{}", + repo, issue_number + )) + .send() + .await + .unwrap() + .text() + .await + .unwrap(); + let issue: structs::Issue = serde_json::from_str(&text).unwrap(); + let text = client + .get(&issue.events_url) + .send() + .await + .unwrap() + .text() + .await + .unwrap(); + let mut events: Vec = serde_json::from_str(&text).unwrap(); + let text = client + .get(&issue.comments_url) + .send() + .await + .unwrap() + .text() + .await + .unwrap(); + let comments: Vec = serde_json::from_str(&text).unwrap(); + events.extend(comments); + events.sort_by(|i, j| { + let i = match i { + structs::EventType::Comment(comment) => comment.created_at, + structs::EventType::Event(event) => event.created_at, + }; + let j = match j { + structs::EventType::Comment(comment) => comment.created_at, + structs::EventType::Event(event) => event.created_at, + }; + i.partial_cmp(&j).unwrap() + }); + + let mut writer = Writer::new(Cursor::new(Vec::new())); + { + let mut elem = BytesStart::owned(b"rss".to_vec(), 3); + elem.push_attribute(("version", "2.0")); + writer.write_event(Event::Start(elem)).unwrap(); + + let elem = BytesStart::owned(b"channel".to_vec(), 7); + writer.write_event(Event::Start(elem)).unwrap(); + + let elem = BytesStart::owned(b"title".to_vec(), 5); + writer.write_event(Event::Start(elem)).unwrap(); + + let elem = BytesText::from_plain_str(&issue.title).into_owned(); + writer.write_event(Event::Text(elem)).unwrap(); + + let elem = BytesEnd::owned(b"title".to_vec()); + writer.write_event(Event::End(elem)).unwrap(); + + let elem = BytesStart::owned(b"link".to_vec(), 4); + writer.write_event(Event::Start(elem)).unwrap(); + + let elem = BytesText::from_plain_str(&issue.html_url).into_owned(); + writer.write_event(Event::Text(elem)).unwrap(); + + let elem = BytesEnd::owned(b"link".to_vec()); + writer.write_event(Event::End(elem)).unwrap(); + + let elem = BytesStart::owned(b"description".to_vec(), 11); + writer.write_event(Event::Start(elem)).unwrap(); + + let elem = BytesText::from_plain_str(&format!("Comments and events from {}", &issue.title)) + .into_owned(); + writer.write_event(Event::Text(elem)).unwrap(); + + let elem = BytesEnd::owned(b"description".to_vec()); + writer.write_event(Event::End(elem)).unwrap(); + + let elem = BytesStart::owned(b"item".to_vec(), 4); + writer.write_event(Event::Start(elem)).unwrap(); + + let elem = BytesStart::owned(b"title".to_vec(), 5); + writer.write_event(Event::Start(elem)).unwrap(); + + let elem = BytesText::from_plain_str(&issue.title).into_owned(); + writer.write_event(Event::Text(elem)).unwrap(); + + let elem = BytesEnd::owned(b"title".to_vec()); + writer.write_event(Event::End(elem)).unwrap(); + + let elem = BytesStart::owned(b"link".to_vec(), 4); + writer.write_event(Event::Start(elem)).unwrap(); + + let elem = BytesText::from_plain_str(&issue.html_url).into_owned(); + writer.write_event(Event::Text(elem)).unwrap(); + + let elem = BytesEnd::owned(b"link".to_vec()); + writer.write_event(Event::End(elem)).unwrap(); + + let mut elem = BytesStart::owned(b"guid".to_vec(), 4); + elem.push_attribute(("isPermaLink", "false")); + writer.write_event(Event::Start(elem)).unwrap(); + + let elem = BytesText::from_plain_str(&issue.node_id).into_owned(); + writer.write_event(Event::Text(elem)).unwrap(); + + let elem = BytesEnd::owned(b"guid".to_vec()); + writer.write_event(Event::End(elem)).unwrap(); + + let elem = BytesStart::owned(b"author".to_vec(), 6); + writer.write_event(Event::Start(elem)).unwrap(); + + let elem = BytesText::from_plain_str(&issue.user.login).into_owned(); + writer.write_event(Event::Text(elem)).unwrap(); + + let elem = BytesEnd::owned(b"author".to_vec()); + writer.write_event(Event::End(elem)).unwrap(); + + let elem = BytesStart::owned(b"pubDate".to_vec(), 7); + writer.write_event(Event::Start(elem)).unwrap(); + + let elem = BytesText::from_plain_str(&issue.created_at.to_rfc2822()).into_owned(); + writer.write_event(Event::Text(elem)).unwrap(); + + let elem = BytesEnd::owned(b"pubDate".to_vec()); + writer.write_event(Event::End(elem)).unwrap(); + + if !issue.body.is_empty() { + let elem = BytesStart::owned(b"description".to_vec(), 11); + writer.write_event(Event::Start(elem)).unwrap(); + + let parser = Parser::new_ext(&issue.body, Options::all()); + let mut html_buf = String::with_capacity(issue.body.len()); + pulldown_cmark::html::push_html(&mut html_buf, parser); + let elem = BytesText::from_plain_str(html_buf.trim()).into_owned(); + writer.write_event(Event::Text(elem)).unwrap(); + + let elem = BytesEnd::owned(b"description".to_vec()); + writer.write_event(Event::End(elem)).unwrap(); + } + + let elem = BytesEnd::owned(b"item".to_vec()); + writer.write_event(Event::End(elem)).unwrap(); + } + + for event in events { + let (title, link, description, author, guid, pub_date) = match event { + structs::EventType::Comment(comment) => { + let parser = Parser::new_ext(&comment.body, Options::all()); + let mut html_buf = String::with_capacity(comment.body.len()); + pulldown_cmark::html::push_html(&mut html_buf, parser); + let mut title = comment.body.splitn(2, '\n').next().unwrap().to_string(); + if title.len() > 80 { + title = format!("{}...", title.split_at(80).0); + } + ( + title, + Some(comment.html_url), + html_buf.trim().to_string(), + comment.user.login, + comment.node_id, + comment.created_at.to_rfc2822(), + ) + } + structs::EventType::Event(event) => { + let mut text = "Extra fields:\n
".to_string();
+                pulldown_cmark::escape::escape_html(
+                    &mut text,
+                    &serde_json::to_string_pretty(&event.extra)
+                        .unwrap_or_else(|_| format!("{:?}", &event.extra)),
+                )
+                .unwrap();
+                text.push_str("
"); + ( + format!("New event: {}", &event.event), + None, + text, + event.actor.login, + event.node_id, + event.created_at.to_rfc2822(), + ) + } + }; + + let elem = BytesStart::owned(b"item".to_vec(), 4); + writer.write_event(Event::Start(elem)).unwrap(); + + let elem = BytesStart::owned(b"title".to_vec(), 5); + writer.write_event(Event::Start(elem)).unwrap(); + + let elem = BytesText::from_plain_str(&title).into_owned(); + writer.write_event(Event::Text(elem)).unwrap(); + + let elem = BytesEnd::owned(b"title".to_vec()); + writer.write_event(Event::End(elem)).unwrap(); + + if let Some(link) = link { + let elem = BytesStart::owned(b"link".to_vec(), 4); + writer.write_event(Event::Start(elem)).unwrap(); + + let elem = BytesText::from_plain_str(&link).into_owned(); + writer.write_event(Event::Text(elem)).unwrap(); + + let elem = BytesEnd::owned(b"link".to_vec()); + writer.write_event(Event::End(elem)).unwrap(); + } + + let mut elem = BytesStart::owned(b"guid".to_vec(), 4); + elem.push_attribute(("isPermaLink", "false")); + writer.write_event(Event::Start(elem)).unwrap(); + + let elem = BytesText::from_plain_str(&guid).into_owned(); + writer.write_event(Event::Text(elem)).unwrap(); + + let elem = BytesEnd::owned(b"guid".to_vec()); + writer.write_event(Event::End(elem)).unwrap(); + + let elem = BytesStart::owned(b"author".to_vec(), 6); + writer.write_event(Event::Start(elem)).unwrap(); + + let elem = BytesText::from_plain_str(&author).into_owned(); + writer.write_event(Event::Text(elem)).unwrap(); + + let elem = BytesEnd::owned(b"author".to_vec()); + writer.write_event(Event::End(elem)).unwrap(); + + let elem = BytesStart::owned(b"pubDate".to_vec(), 7); + writer.write_event(Event::Start(elem)).unwrap(); + + let elem = BytesText::from_plain_str(&pub_date).into_owned(); + writer.write_event(Event::Text(elem)).unwrap(); + + let elem = BytesEnd::owned(b"pubDate".to_vec()); + writer.write_event(Event::End(elem)).unwrap(); + + let elem = BytesStart::owned(b"description".to_vec(), 11); + writer.write_event(Event::Start(elem)).unwrap(); + + let elem = BytesText::from_plain_str(&description).into_owned(); + writer.write_event(Event::Text(elem)).unwrap(); + + let elem = BytesEnd::owned(b"description".to_vec()); + writer.write_event(Event::End(elem)).unwrap(); + + let elem = BytesEnd::owned(b"item".to_vec()); + writer.write_event(Event::End(elem)).unwrap(); + } + + let elem = BytesEnd::owned(b"channel".to_vec()); + writer.write_event(Event::End(elem)).unwrap(); + + let elem = BytesEnd::owned(b"rss".to_vec()); + writer.write_event(Event::End(elem)).unwrap(); + + println!( + "{}", + String::from_utf8(writer.into_inner().into_inner()).unwrap() + ); +} diff --git a/src/github/structs.rs b/src/github/structs.rs new file mode 100644 index 0000000..24bb774 --- /dev/null +++ b/src/github/structs.rs @@ -0,0 +1,80 @@ +use chrono::{DateTime, FixedOffset}; +use serde::de::{self, Visitor}; +use serde::{Deserialize, Deserializer}; +use std::collections::HashMap; +use std::fmt; +use std::marker::PhantomData; + +#[derive(Deserialize, Debug)] +pub struct Issue { + pub comments_url: String, + pub events_url: String, + pub html_url: String, + pub node_id: String, + pub title: String, + pub user: User, + pub state: String, + pub body: String, + #[serde(deserialize_with = "deserialize_datetime")] + pub created_at: DateTime, +} + +#[derive(Deserialize, Debug)] +#[serde(untagged)] +pub enum EventType { + Comment(Comment), + Event(Event), +} + +#[derive(Deserialize, Debug)] +pub struct Comment { + pub html_url: String, + pub node_id: String, + pub user: User, + #[serde(deserialize_with = "deserialize_datetime")] + pub created_at: DateTime, + pub body: String, +} + +#[derive(Deserialize, Debug)] +pub struct Event { + pub url: String, + pub id: usize, + pub node_id: String, + pub actor: User, + #[serde(deserialize_with = "deserialize_datetime")] + pub created_at: DateTime, + pub event: String, + #[serde(flatten)] + pub extra: HashMap, +} + +#[derive(Deserialize, Debug)] +pub struct User { + pub login: String, +} + +fn deserialize_datetime<'de, D>(deserializer: D) -> Result, D::Error> +where + D: Deserializer<'de>, +{ + struct DeserializeDateTime(PhantomData T>); + + impl<'de> Visitor<'de> for DeserializeDateTime> { + type Value = DateTime; + + fn expecting(&self, formatter: &mut fmt::Formatter) -> fmt::Result { + formatter.write_str("RFC3339 datetime string") + } + + fn visit_str(self, value: &str) -> Result + where + E: de::Error, + { + // https://brokenco.de/2020/08/03/serde-deserialize-with-string.html + DateTime::parse_from_rfc3339(value).map_err(serde::de::Error::custom) + } + } + + deserializer.deserialize_any(DeserializeDateTime(PhantomData)) +} diff --git a/src/gitlab/mod.rs b/src/gitlab/mod.rs new file mode 100644 index 0000000..7c4185a --- /dev/null +++ b/src/gitlab/mod.rs @@ -0,0 +1,256 @@ +mod structs; + +use quick_xml::events::{BytesEnd, BytesStart, BytesText, Event}; +use quick_xml::{Reader, Writer}; +use reqwest::{Client, Url}; +use std::borrow::Cow; +use std::env; +use std::io::Cursor; +use std::iter::Skip; +extern crate serde_json; + +pub async fn run(mut args: Skip) { + let repo = args.next().expect("Missing repo"); + let issue_number = args.next().expect("Missing issue number"); + let query = match args.next().expect("Missing type").as_str() { + "issue" => structs::ISSUE_QUERY, + "mr" => structs::MR_QUERY, + _ => panic!("Unknown type"), + }; + let client = Client::new(); + let text = client + .post("https://gitlab.com/api/graphql") + .body( + serde_json::json!({"query": query, "variables": {"repo": &repo, "id": &issue_number}}) + .to_string(), + ) + .header("Content-Type", "application/json") + .send() + .await + .unwrap() + .text() + .await + .unwrap(); + let issue: structs::Data = serde_json::from_str(&text).unwrap(); + let issue = match issue.data.project { + structs::IssueOrMR::Issue(i) => i, + structs::IssueOrMR::MergeRequest(i) => i, + }; + + let mut writer = Writer::new(Cursor::new(Vec::new())); + { + let mut elem = BytesStart::owned(b"rss".to_vec(), 3); + elem.push_attribute(("version", "2.0")); + writer.write_event(Event::Start(elem)).unwrap(); + + let elem = BytesStart::owned(b"channel".to_vec(), 7); + writer.write_event(Event::Start(elem)).unwrap(); + + let elem = BytesStart::owned(b"title".to_vec(), 5); + writer.write_event(Event::Start(elem)).unwrap(); + + let elem = BytesText::from_plain_str(&issue.title).into_owned(); + writer.write_event(Event::Text(elem)).unwrap(); + + let elem = BytesEnd::owned(b"title".to_vec()); + writer.write_event(Event::End(elem)).unwrap(); + + let elem = BytesStart::owned(b"link".to_vec(), 4); + writer.write_event(Event::Start(elem)).unwrap(); + + let elem = BytesText::from_plain_str(&issue.web_url).into_owned(); + writer.write_event(Event::Text(elem)).unwrap(); + + let elem = BytesEnd::owned(b"link".to_vec()); + writer.write_event(Event::End(elem)).unwrap(); + + let elem = BytesStart::owned(b"description".to_vec(), 11); + writer.write_event(Event::Start(elem)).unwrap(); + + let elem = BytesText::from_plain_str(&format!("Comments and events from {}", &issue.title)) + .into_owned(); + writer.write_event(Event::Text(elem)).unwrap(); + + let elem = BytesEnd::owned(b"description".to_vec()); + writer.write_event(Event::End(elem)).unwrap(); + + let elem = BytesStart::owned(b"item".to_vec(), 4); + writer.write_event(Event::Start(elem)).unwrap(); + + let elem = BytesStart::owned(b"title".to_vec(), 5); + writer.write_event(Event::Start(elem)).unwrap(); + + let elem = BytesText::from_plain_str(&issue.title).into_owned(); + writer.write_event(Event::Text(elem)).unwrap(); + + let elem = BytesEnd::owned(b"title".to_vec()); + writer.write_event(Event::End(elem)).unwrap(); + + let elem = BytesStart::owned(b"link".to_vec(), 4); + writer.write_event(Event::Start(elem)).unwrap(); + + let elem = BytesText::from_plain_str(&issue.web_url).into_owned(); + writer.write_event(Event::Text(elem)).unwrap(); + + let elem = BytesEnd::owned(b"link".to_vec()); + writer.write_event(Event::End(elem)).unwrap(); + + let mut elem = BytesStart::owned(b"guid".to_vec(), 4); + elem.push_attribute(("isPermaLink", "false")); + writer.write_event(Event::Start(elem)).unwrap(); + + let elem = BytesText::from_plain_str(&issue.id).into_owned(); + writer.write_event(Event::Text(elem)).unwrap(); + + let elem = BytesEnd::owned(b"guid".to_vec()); + writer.write_event(Event::End(elem)).unwrap(); + + let elem = BytesStart::owned(b"author".to_vec(), 6); + writer.write_event(Event::Start(elem)).unwrap(); + + let elem = BytesText::from_plain_str(&issue.author.username).into_owned(); + writer.write_event(Event::Text(elem)).unwrap(); + + let elem = BytesEnd::owned(b"author".to_vec()); + writer.write_event(Event::End(elem)).unwrap(); + + let elem = BytesStart::owned(b"pubDate".to_vec(), 7); + writer.write_event(Event::Start(elem)).unwrap(); + + let elem = BytesText::from_plain_str(&issue.created_at.to_rfc2822()).into_owned(); + writer.write_event(Event::Text(elem)).unwrap(); + + let elem = BytesEnd::owned(b"pubDate".to_vec()); + writer.write_event(Event::End(elem)).unwrap(); + + if !issue.description_html.is_empty() { + let elem = BytesStart::owned(b"description".to_vec(), 11); + writer.write_event(Event::Start(elem)).unwrap(); + + let elem = BytesText::from_plain_str(&fix_description( + &issue.description_html, + &issue.web_url, + )) + .into_owned(); + writer.write_event(Event::Text(elem)).unwrap(); + + let elem = BytesEnd::owned(b"description".to_vec()); + writer.write_event(Event::End(elem)).unwrap(); + } + + let elem = BytesEnd::owned(b"item".to_vec()); + writer.write_event(Event::End(elem)).unwrap(); + } + + for note in issue.notes.nodes { + let mut title = note.body.splitn(2, '\n').next().unwrap().to_string(); + if title.len() > 80 { + title = format!("{}...", title.split_at(80).0); + } + let pub_date = note.created_at.to_rfc2822(); + + let elem = BytesStart::owned(b"item".to_vec(), 4); + writer.write_event(Event::Start(elem)).unwrap(); + + let elem = BytesStart::owned(b"title".to_vec(), 5); + writer.write_event(Event::Start(elem)).unwrap(); + + let elem = BytesText::from_plain_str(&title).into_owned(); + writer.write_event(Event::Text(elem)).unwrap(); + + let elem = BytesEnd::owned(b"title".to_vec()); + writer.write_event(Event::End(elem)).unwrap(); + + let elem = BytesStart::owned(b"link".to_vec(), 4); + writer.write_event(Event::Start(elem)).unwrap(); + + let elem = BytesText::from_plain_str(¬e.url).into_owned(); + writer.write_event(Event::Text(elem)).unwrap(); + + let elem = BytesEnd::owned(b"link".to_vec()); + writer.write_event(Event::End(elem)).unwrap(); + + let mut elem = BytesStart::owned(b"guid".to_vec(), 4); + elem.push_attribute(("isPermaLink", "false")); + writer.write_event(Event::Start(elem)).unwrap(); + + let elem = BytesText::from_plain_str(¬e.id).into_owned(); + writer.write_event(Event::Text(elem)).unwrap(); + + let elem = BytesEnd::owned(b"guid".to_vec()); + writer.write_event(Event::End(elem)).unwrap(); + + let elem = BytesStart::owned(b"author".to_vec(), 6); + writer.write_event(Event::Start(elem)).unwrap(); + + let elem = BytesText::from_plain_str(¬e.author.username).into_owned(); + writer.write_event(Event::Text(elem)).unwrap(); + + let elem = BytesEnd::owned(b"author".to_vec()); + writer.write_event(Event::End(elem)).unwrap(); + + let elem = BytesStart::owned(b"pubDate".to_vec(), 7); + writer.write_event(Event::Start(elem)).unwrap(); + + let elem = BytesText::from_plain_str(&pub_date).into_owned(); + writer.write_event(Event::Text(elem)).unwrap(); + + let elem = BytesEnd::owned(b"pubDate".to_vec()); + writer.write_event(Event::End(elem)).unwrap(); + + let elem = BytesStart::owned(b"description".to_vec(), 11); + writer.write_event(Event::Start(elem)).unwrap(); + + let elem = + BytesText::from_plain_str(&fix_description(¬e.body_html, ¬e.url)).into_owned(); + writer.write_event(Event::Text(elem)).unwrap(); + + let elem = BytesEnd::owned(b"description".to_vec()); + writer.write_event(Event::End(elem)).unwrap(); + + let elem = BytesEnd::owned(b"item".to_vec()); + writer.write_event(Event::End(elem)).unwrap(); + } + + let elem = BytesEnd::owned(b"channel".to_vec()); + writer.write_event(Event::End(elem)).unwrap(); + + let elem = BytesEnd::owned(b"rss".to_vec()); + writer.write_event(Event::End(elem)).unwrap(); + + println!( + "{}", + String::from_utf8(writer.into_inner().into_inner()).unwrap() + ); +} + +fn fix_description(text: &str, html_url: &str) -> String { + let mut reader = Reader::from_str(text); + reader.check_end_names(false); + let mut writer = Writer::new(Cursor::new(Vec::new())); + let mut buf = Vec::new(); + loop { + match reader.read_event(&mut buf) { + Ok(Event::Start(ref e)) if e.name() == b"a" => { + let mut elem = BytesStart::owned(b"a".to_vec(), 1); + for mut attribute in e.attributes().filter_map(|i| i.ok()) { + if attribute.key == b"href" { + if let Ok(unescaped) = attribute.unescape_and_decode_value(&reader) { + if let Ok(url) = Url::parse(html_url).unwrap().join(&unescaped) { + attribute.value = Cow::Owned(url.as_str().as_bytes().to_vec()); + } + } + } + elem.push_attribute((attribute.key, &attribute.value[..])); + } + writer.write_event(Event::Start(elem)) + } + Ok(Event::Eof) => break, + Ok(e) => writer.write_event(e), + Err(e) => panic!("Error at position {}: {:?}", reader.buffer_position(), e), + } + .unwrap(); + buf.clear(); + } + String::from_utf8(writer.into_inner().into_inner()).unwrap() +} diff --git a/src/gitlab/structs.rs b/src/gitlab/structs.rs new file mode 100644 index 0000000..ef8f046 --- /dev/null +++ b/src/gitlab/structs.rs @@ -0,0 +1,136 @@ +use chrono::{DateTime, FixedOffset}; +use serde::de::{self, Visitor}; +use serde::{Deserialize, Deserializer}; +use std::fmt; +use std::marker::PhantomData; + +pub const ISSUE_QUERY: &str = r#"query ($repo: ID!, $id: String) { + project (fullPath: $repo) { + issue (iid: $id) { + id + descriptionHtml + author { + username + } + title + createdAt + webUrl + notes { + nodes { + id + author { + username + } + body + bodyHtml + createdAt + url + } + } + } + } +}"#; + +pub const MR_QUERY: &str = r#"query ($repo: ID!, $id: String!) { + project (fullPath: $repo) { + mergeRequest (iid: $id) { + id + descriptionHtml + author { + username + } + title + createdAt + webUrl + notes { + nodes { + id + author { + username + } + body + bodyHtml + createdAt + url + } + } + } + } +}"#; + +#[derive(Deserialize, Debug)] +pub struct Data { + pub data: Project, +} + +#[derive(Deserialize, Debug)] +pub struct Project { + pub project: IssueOrMR, +} + +#[derive(Deserialize, Debug)] +#[serde(rename_all = "camelCase")] +pub enum IssueOrMR { + Issue(IssueInfo), + MergeRequest(IssueInfo), +} + +#[derive(Deserialize, Debug)] +#[serde(rename_all = "camelCase")] +pub struct IssueInfo { + pub id: String, + pub description_html: String, + pub author: Author, + pub title: String, + #[serde(deserialize_with = "deserialize_datetime")] + pub created_at: DateTime, + pub web_url: String, + pub notes: NoteConnection, +} + +#[derive(Deserialize, Debug)] +pub struct Author { + pub username: String, +} + +#[derive(Deserialize, Debug)] +pub struct NoteConnection { + pub nodes: Vec, +} + +#[derive(Deserialize, Debug)] +#[serde(rename_all = "camelCase")] +pub struct Note { + pub id: String, + pub author: Author, + pub body: String, + pub body_html: String, + #[serde(deserialize_with = "deserialize_datetime")] + pub created_at: DateTime, + pub url: String, +} + +fn deserialize_datetime<'de, D>(deserializer: D) -> Result, D::Error> +where + D: Deserializer<'de>, +{ + struct DeserializeDateTime(PhantomData T>); + + impl<'de> Visitor<'de> for DeserializeDateTime> { + type Value = DateTime; + + fn expecting(&self, formatter: &mut fmt::Formatter) -> fmt::Result { + formatter.write_str("RFC3339 datetime string") + } + + fn visit_str(self, value: &str) -> Result + where + E: de::Error, + { + // https://brokenco.de/2020/08/03/serde-deserialize-with-string.html + DateTime::parse_from_rfc3339(value).map_err(serde::de::Error::custom) + } + } + + deserializer.deserialize_any(DeserializeDateTime(PhantomData)) +} diff --git a/src/main.rs b/src/main.rs new file mode 100644 index 0000000..a1c007f --- /dev/null +++ b/src/main.rs @@ -0,0 +1,18 @@ +mod github; +mod gitlab; + +use std::env; +extern crate tokio; + +fn main() { + let mut args = env::args().skip(1); + let rt = tokio::runtime::Builder::new_current_thread() + .enable_all() + .build() + .unwrap(); + match args.next().expect("Missing service").as_str() { + "github" => rt.block_on(github::run(args)), + "gitlab" => rt.block_on(gitlab::run(args)), + _ => panic!("Unknown service"), + }; +}