Compare commits
28 commits
rocket-sta
...
main
Author | SHA1 | Date | |
---|---|---|---|
Antoine Martin | 24c0156b97 | ||
Antoine Martin | 298e895a0b | ||
Antoine Martin | b6445e6707 | ||
Antoine Martin | 926f48f979 | ||
Antoine Martin | b04748a804 | ||
Antoine Martin | 77e5214561 | ||
Antoine Martin | 689c57a140 | ||
Antoine Martin | 66d965beee | ||
Antoine Martin | 708c350c9a | ||
Antoine Martin | 075ca9a23c | ||
Antoine Martin | 25eba69b16 | ||
Antoine Martin | 88609b24fe | ||
Antoine Martin | 26eefe2ebe | ||
Antoine Martin | 58503cc8b9 | ||
Antoine Martin | a48e59bedc | ||
Antoine Martin | c37a390f6c | ||
Antoine Martin | cd85ace566 | ||
Antoine Martin | 964975bada | ||
Antoine Martin | b78c486a0e | ||
Antoine Martin | 7fad5a6a87 | ||
Antoine Martin | 5f7d140b61 | ||
Antoine Martin | 1f6fe74d03 | ||
Antoine Martin | fd50523f11 | ||
Antoine Martin | d942dc1098 | ||
Antoine Martin | bc32f8a565 | ||
Antoine Martin | 6c4a496ede | ||
Antoine Martin | 264b7baccd | ||
Antoine Martin | 776876233f |
20
.github/workflows/cachix.yaml
vendored
Normal file
20
.github/workflows/cachix.yaml
vendored
Normal file
|
@ -0,0 +1,20 @@
|
||||||
|
name: "Cachix build"
|
||||||
|
on:
|
||||||
|
workflow_dispatch:
|
||||||
|
push:
|
||||||
|
paths:
|
||||||
|
- 'flake.nix'
|
||||||
|
- 'flake.lock'
|
||||||
|
|
||||||
|
jobs:
|
||||||
|
build:
|
||||||
|
runs-on: ubuntu-latest
|
||||||
|
steps:
|
||||||
|
- uses: actions/checkout@v4
|
||||||
|
- uses: cachix/install-nix-action@v24
|
||||||
|
- uses: cachix/cachix-action@v12
|
||||||
|
with:
|
||||||
|
name: alarsyo
|
||||||
|
authToken: '${{ secrets.CACHIX_AUTH_TOKEN }}'
|
||||||
|
- run: |
|
||||||
|
nix build --verbose
|
50
.github/workflows/ci.yaml
vendored
50
.github/workflows/ci.yaml
vendored
|
@ -1,4 +1,4 @@
|
||||||
on: [push, pull_request]
|
on: [push, pull_request, workflow_dispatch]
|
||||||
|
|
||||||
name: CI
|
name: CI
|
||||||
|
|
||||||
|
@ -8,62 +8,34 @@ jobs:
|
||||||
runs-on: ubuntu-latest
|
runs-on: ubuntu-latest
|
||||||
steps:
|
steps:
|
||||||
- name: Checkout sources
|
- name: Checkout sources
|
||||||
uses: actions/checkout@v2
|
uses: actions/checkout@v4
|
||||||
|
|
||||||
- name: Install stable toolchain
|
- name: Install stable toolchain
|
||||||
uses: actions-rs/toolchain@v1
|
uses: dtolnay/rust-toolchain@stable
|
||||||
with:
|
|
||||||
profile: minimal
|
|
||||||
toolchain: stable
|
|
||||||
override: true
|
|
||||||
|
|
||||||
- name: Run cargo check
|
- run: cargo check
|
||||||
uses: actions-rs/cargo@v1
|
|
||||||
with:
|
|
||||||
command: check
|
|
||||||
|
|
||||||
test:
|
test:
|
||||||
name: Test Suite
|
name: Test Suite
|
||||||
runs-on: ubuntu-latest
|
runs-on: ubuntu-latest
|
||||||
steps:
|
steps:
|
||||||
- name: Checkout sources
|
- name: Checkout sources
|
||||||
uses: actions/checkout@v2
|
uses: actions/checkout@v4
|
||||||
|
|
||||||
- name: Install stable toolchain
|
- name: Install stable toolchain
|
||||||
uses: actions-rs/toolchain@v1
|
uses: dtolnay/rust-toolchain@stable
|
||||||
with:
|
|
||||||
profile: minimal
|
|
||||||
toolchain: stable
|
|
||||||
override: true
|
|
||||||
|
|
||||||
- name: Run cargo test
|
- run: cargo test
|
||||||
uses: actions-rs/cargo@v1
|
|
||||||
with:
|
|
||||||
command: test
|
|
||||||
|
|
||||||
lints:
|
lints:
|
||||||
name: Lints
|
name: Lints
|
||||||
runs-on: ubuntu-latest
|
runs-on: ubuntu-latest
|
||||||
steps:
|
steps:
|
||||||
- name: Checkout sources
|
- name: Checkout sources
|
||||||
uses: actions/checkout@v2
|
uses: actions/checkout@v4
|
||||||
|
|
||||||
- name: Install stable toolchain
|
- name: Install stable toolchain
|
||||||
uses: actions-rs/toolchain@v1
|
uses: dtolnay/rust-toolchain@stable
|
||||||
with:
|
|
||||||
profile: minimal
|
|
||||||
toolchain: stable
|
|
||||||
override: true
|
|
||||||
components: rustfmt, clippy
|
|
||||||
|
|
||||||
- name: Run cargo fmt
|
- run: cargo fmt --all -- --check
|
||||||
uses: actions-rs/cargo@v1
|
- run: cargo clippy --all-features -- -D warnings
|
||||||
with:
|
|
||||||
command: fmt
|
|
||||||
args: --all -- --check
|
|
||||||
|
|
||||||
- name: Run cargo clippy
|
|
||||||
uses: actions-rs/clippy-check@v1
|
|
||||||
with:
|
|
||||||
token: ${{ secrets.GITHUB_TOKEN }}
|
|
||||||
args: --all-features -- -D warnings
|
|
||||||
|
|
1395
Cargo.lock
generated
1395
Cargo.lock
generated
File diff suppressed because it is too large
Load diff
|
@ -1,12 +1,13 @@
|
||||||
[package]
|
[package]
|
||||||
name = "lohr"
|
name = "lohr"
|
||||||
version = "0.3.3"
|
version = "0.4.5"
|
||||||
authors = ["Antoine Martin <antoine@alarsyo.net>"]
|
authors = ["Antoine Martin <antoine@alarsyo.net>"]
|
||||||
edition = "2018"
|
edition = "2018"
|
||||||
license = "Apache-2.0 OR MIT"
|
license = "Apache-2.0 OR MIT"
|
||||||
description = "A Git mirroring daemon"
|
description = "A Git mirroring daemon"
|
||||||
homepage = "https://github.com/alarsyo/lohr"
|
homepage = "https://github.com/alarsyo/lohr"
|
||||||
repository = "https://github.com/alarsyo/lohr"
|
repository = "https://github.com/alarsyo/lohr"
|
||||||
|
resolver = "2"
|
||||||
|
|
||||||
# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
|
# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
|
||||||
|
|
||||||
|
@ -23,7 +24,7 @@ serde_yaml = "0.8.17"
|
||||||
sha2 = "0.9.3"
|
sha2 = "0.9.3"
|
||||||
|
|
||||||
[dependencies.rocket]
|
[dependencies.rocket]
|
||||||
version = "0.5.0-dev"
|
version = "0.5.0"
|
||||||
# don't need private-cookies
|
# don't need private-cookies
|
||||||
default-features = false
|
default-features = false
|
||||||
|
|
||||||
|
@ -31,6 +32,3 @@ default-features = false
|
||||||
version = "2.33.3"
|
version = "2.33.3"
|
||||||
# no need for suggestions or color with only one argument
|
# no need for suggestions or color with only one argument
|
||||||
default-features = false
|
default-features = false
|
||||||
|
|
||||||
[patch.crates-io]
|
|
||||||
rocket = { git = "https://github.com/SergioBenitez/Rocket", rev = "2893ce754d6535e0a752586e60d7e292343016c0" }
|
|
||||||
|
|
|
@ -28,6 +28,10 @@ install it with `cargo install`:
|
||||||
|
|
||||||
$ cargo install lohr
|
$ cargo install lohr
|
||||||
|
|
||||||
|
Note: currently this method won't get you the latest version of `lohr`, as it
|
||||||
|
depends on Rocket v0.5.0, which isn't released yet. Updated versions of `lohr`
|
||||||
|
will be published on crates.io as soon as Rocket v0.5.0 releases.
|
||||||
|
|
||||||
## Setup
|
## Setup
|
||||||
|
|
||||||
### Quickstart
|
### Quickstart
|
||||||
|
|
36
flake.lock
36
flake.lock
|
@ -3,11 +3,11 @@
|
||||||
"flake-compat": {
|
"flake-compat": {
|
||||||
"flake": false,
|
"flake": false,
|
||||||
"locked": {
|
"locked": {
|
||||||
"lastModified": 1606424373,
|
"lastModified": 1696426674,
|
||||||
"narHash": "sha256-oq8d4//CJOrVj+EcOaSXvMebvuTkmBJuT5tzlfewUnQ=",
|
"narHash": "sha256-kvjfFW7WAETZlt09AgDn1MrtKzP7t90Vf7vypd3OL1U=",
|
||||||
"owner": "edolstra",
|
"owner": "edolstra",
|
||||||
"repo": "flake-compat",
|
"repo": "flake-compat",
|
||||||
"rev": "99f1c2157fba4bfe6211a321fd0ee43199025dbf",
|
"rev": "0f9255e01c2351cc7d116c072cb317785dd33b33",
|
||||||
"type": "github"
|
"type": "github"
|
||||||
},
|
},
|
||||||
"original": {
|
"original": {
|
||||||
|
@ -17,12 +17,15 @@
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
"flake-utils": {
|
"flake-utils": {
|
||||||
|
"inputs": {
|
||||||
|
"systems": "systems"
|
||||||
|
},
|
||||||
"locked": {
|
"locked": {
|
||||||
"lastModified": 1614513358,
|
"lastModified": 1701680307,
|
||||||
"narHash": "sha256-LakhOx3S1dRjnh0b5Dg3mbZyH0ToC9I8Y2wKSkBaTzU=",
|
"narHash": "sha256-kAuep2h5ajznlPMD9rnQyffWG8EM/C73lejGofXvdM8=",
|
||||||
"owner": "numtide",
|
"owner": "numtide",
|
||||||
"repo": "flake-utils",
|
"repo": "flake-utils",
|
||||||
"rev": "5466c5bbece17adaab2d82fae80b46e807611bf3",
|
"rev": "4022d587cbbfd70fe950c1e2083a02621806a725",
|
||||||
"type": "github"
|
"type": "github"
|
||||||
},
|
},
|
||||||
"original": {
|
"original": {
|
||||||
|
@ -33,11 +36,11 @@
|
||||||
},
|
},
|
||||||
"nixpkgs": {
|
"nixpkgs": {
|
||||||
"locked": {
|
"locked": {
|
||||||
"lastModified": 1616670887,
|
"lastModified": 1702272962,
|
||||||
"narHash": "sha256-wn+l9qJfR5sj5Gq4DheJHAcBDfOs9K2p9seW2f35xzs=",
|
"narHash": "sha256-D+zHwkwPc6oYQ4G3A1HuadopqRwUY/JkMwHz1YF7j4Q=",
|
||||||
"owner": "NixOS",
|
"owner": "NixOS",
|
||||||
"repo": "nixpkgs",
|
"repo": "nixpkgs",
|
||||||
"rev": "c0e881852006b132236cbf0301bd1939bb50867e",
|
"rev": "e97b3e4186bcadf0ef1b6be22b8558eab1cdeb5d",
|
||||||
"type": "github"
|
"type": "github"
|
||||||
},
|
},
|
||||||
"original": {
|
"original": {
|
||||||
|
@ -53,6 +56,21 @@
|
||||||
"flake-utils": "flake-utils",
|
"flake-utils": "flake-utils",
|
||||||
"nixpkgs": "nixpkgs"
|
"nixpkgs": "nixpkgs"
|
||||||
}
|
}
|
||||||
|
},
|
||||||
|
"systems": {
|
||||||
|
"locked": {
|
||||||
|
"lastModified": 1681028828,
|
||||||
|
"narHash": "sha256-Vy1rq5AaRuLzOxct8nz4T6wlgyUR7zLU309k9mBC768=",
|
||||||
|
"owner": "nix-systems",
|
||||||
|
"repo": "default",
|
||||||
|
"rev": "da67096a3b9bf56a91d16901293e51ba5b49a27e",
|
||||||
|
"type": "github"
|
||||||
|
},
|
||||||
|
"original": {
|
||||||
|
"owner": "nix-systems",
|
||||||
|
"repo": "default",
|
||||||
|
"type": "github"
|
||||||
|
}
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
"root": "root",
|
"root": "root",
|
||||||
|
|
|
@ -16,11 +16,11 @@
|
||||||
{
|
{
|
||||||
defaultPackage = pkgs.rustPlatform.buildRustPackage {
|
defaultPackage = pkgs.rustPlatform.buildRustPackage {
|
||||||
pname = "lohr";
|
pname = "lohr";
|
||||||
version = "0.3.1";
|
version = "0.4.5";
|
||||||
|
|
||||||
src = ./.;
|
src = ./.;
|
||||||
|
|
||||||
cargoSha256 = "sha256-XnBvb13Pv7bNTLCL3WV+bxRK0/uMEKA1/Bk0Tfua3Rs=";
|
cargoHash = "sha256-hext0S0o9D9pN9epzXtD5dwAYMPCLpBBOBT4FX0mTMk=";
|
||||||
|
|
||||||
meta = with pkgs.lib; {
|
meta = with pkgs.lib; {
|
||||||
description = "A Git mirroring tool";
|
description = "A Git mirroring tool";
|
||||||
|
@ -43,6 +43,7 @@
|
||||||
rustPackages.clippy
|
rustPackages.clippy
|
||||||
rustc
|
rustc
|
||||||
rustfmt
|
rustfmt
|
||||||
|
rust-analyzer
|
||||||
];
|
];
|
||||||
|
|
||||||
RUST_SRC_PATH = pkgs.rustPlatform.rustLibSrc;
|
RUST_SRC_PATH = pkgs.rustPlatform.rustLibSrc;
|
||||||
|
|
|
@ -1 +0,0 @@
|
||||||
stable
|
|
2
rust-toolchain.toml
Normal file
2
rust-toolchain.toml
Normal file
|
@ -0,0 +1,2 @@
|
||||||
|
[toolchain]
|
||||||
|
channel = "stable"
|
|
@ -2,9 +2,8 @@ use serde::Deserialize;
|
||||||
|
|
||||||
#[derive(Clone, Deserialize)]
|
#[derive(Clone, Deserialize)]
|
||||||
pub(crate) struct Repository {
|
pub(crate) struct Repository {
|
||||||
pub(crate) name: String,
|
|
||||||
pub(crate) full_name: String,
|
pub(crate) full_name: String,
|
||||||
pub(crate) clone_url: String,
|
pub(crate) ssh_url: String,
|
||||||
}
|
}
|
||||||
|
|
||||||
#[derive(Deserialize)]
|
#[derive(Deserialize)]
|
||||||
|
|
|
@ -38,7 +38,7 @@ impl Job {
|
||||||
let output = Command::new("git")
|
let output = Command::new("git")
|
||||||
.arg("clone")
|
.arg("clone")
|
||||||
.arg("--mirror")
|
.arg("--mirror")
|
||||||
.arg(&self.repo.clone_url)
|
.arg(&self.repo.ssh_url)
|
||||||
.arg(format!("{}", self.local_path.as_ref().unwrap().display()))
|
.arg(format!("{}", self.local_path.as_ref().unwrap().display()))
|
||||||
.output()?;
|
.output()?;
|
||||||
|
|
||||||
|
|
|
@ -30,8 +30,8 @@ struct Secret(String);
|
||||||
#[post("/", data = "<payload>")]
|
#[post("/", data = "<payload>")]
|
||||||
fn gitea_webhook(
|
fn gitea_webhook(
|
||||||
payload: SignedJson<GiteaWebHook>,
|
payload: SignedJson<GiteaWebHook>,
|
||||||
sender: State<JobSender>,
|
sender: &State<JobSender>,
|
||||||
config: State<GlobalSettings>,
|
config: &State<GlobalSettings>,
|
||||||
) -> Status {
|
) -> Status {
|
||||||
if config
|
if config
|
||||||
.blacklist
|
.blacklist
|
||||||
|
@ -121,7 +121,7 @@ async fn main() -> anyhow::Result<()> {
|
||||||
repo_updater(receiver, homedir, config);
|
repo_updater(receiver, homedir, config);
|
||||||
});
|
});
|
||||||
|
|
||||||
rocket::ignite()
|
rocket::build()
|
||||||
.mount("/", routes![gitea_webhook])
|
.mount("/", routes![gitea_webhook])
|
||||||
.manage(JobSender(Mutex::new(sender)))
|
.manage(JobSender(Mutex::new(sender)))
|
||||||
.manage(Secret(secret))
|
.manage(Secret(secret))
|
||||||
|
|
|
@ -8,7 +8,7 @@ use rocket::{
|
||||||
http::ContentType,
|
http::ContentType,
|
||||||
State,
|
State,
|
||||||
};
|
};
|
||||||
use rocket::{http::Status, local_cache};
|
use rocket::{http::Status, request::local_cache};
|
||||||
use rocket::{Data, Request};
|
use rocket::{Data, Request};
|
||||||
|
|
||||||
use anyhow::{anyhow, Context};
|
use anyhow::{anyhow, Context};
|
||||||
|
@ -72,15 +72,15 @@ where
|
||||||
{
|
{
|
||||||
type Error = anyhow::Error;
|
type Error = anyhow::Error;
|
||||||
|
|
||||||
async fn from_data(request: &'r Request<'_>, data: Data) -> Outcome<Self, Self::Error> {
|
async fn from_data(request: &'r Request<'_>, data: Data<'r>) -> Outcome<'r, Self> {
|
||||||
let json_ct = ContentType::new("application", "json");
|
let json_ct = ContentType::new("application", "json");
|
||||||
if request.content_type() != Some(&json_ct) {
|
if request.content_type() != Some(&json_ct) {
|
||||||
return Outcome::Failure((Status::BadRequest, anyhow!("wrong content type")));
|
return Outcome::Error((Status::BadRequest, anyhow!("wrong content type")));
|
||||||
}
|
}
|
||||||
|
|
||||||
let signatures = request.headers().get(X_GITEA_SIGNATURE).collect::<Vec<_>>();
|
let signatures = request.headers().get(X_GITEA_SIGNATURE).collect::<Vec<_>>();
|
||||||
if signatures.len() != 1 {
|
if signatures.len() != 1 {
|
||||||
return Outcome::Failure((
|
return Outcome::Error((
|
||||||
Status::BadRequest,
|
Status::BadRequest,
|
||||||
anyhow!("request header needs exactly one signature"),
|
anyhow!("request header needs exactly one signature"),
|
||||||
));
|
));
|
||||||
|
@ -91,26 +91,24 @@ where
|
||||||
Ok(s) if s.is_complete() => s.into_inner(),
|
Ok(s) if s.is_complete() => s.into_inner(),
|
||||||
Ok(_) => {
|
Ok(_) => {
|
||||||
let eof = io::ErrorKind::UnexpectedEof;
|
let eof = io::ErrorKind::UnexpectedEof;
|
||||||
return Outcome::Failure((
|
return Outcome::Error((
|
||||||
Status::PayloadTooLarge,
|
Status::PayloadTooLarge,
|
||||||
io::Error::new(eof, "data limit exceeded").into(),
|
io::Error::new(eof, "data limit exceeded").into(),
|
||||||
));
|
));
|
||||||
}
|
}
|
||||||
Err(e) => return Outcome::Failure((Status::BadRequest, e.into())),
|
Err(e) => return Outcome::Error((Status::BadRequest, e.into())),
|
||||||
};
|
};
|
||||||
|
|
||||||
let signature = signatures[0];
|
let signature = signatures[0];
|
||||||
let secret = request.guard::<State<Secret>>().await.unwrap();
|
let secret = request.guard::<&State<Secret>>().await.unwrap();
|
||||||
|
|
||||||
if !validate_signature(&secret.0, &signature, &content) {
|
if !validate_signature(&secret.0, signature, &content) {
|
||||||
return Outcome::Failure((Status::BadRequest, anyhow!("couldn't verify signature")));
|
return Outcome::Error((Status::BadRequest, anyhow!("couldn't verify signature")));
|
||||||
}
|
}
|
||||||
|
|
||||||
let content = match Self::from_str(local_cache!(request, content)) {
|
match Self::from_str(local_cache!(request, content)) {
|
||||||
Ok(content) => Outcome::Success(content),
|
Ok(content) => Outcome::Success(content),
|
||||||
Err(e) => Outcome::Failure((Status::BadRequest, e)),
|
Err(e) => Outcome::Error((Status::BadRequest, e)),
|
||||||
};
|
}
|
||||||
|
|
||||||
content
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in a new issue