Compare commits
9 Commits
Author | SHA1 | Date | |
---|---|---|---|
72c1cf7120
|
|||
a2a3a8bc48
|
|||
6d4af5f82c
|
|||
3b5bf84b18
|
|||
a91d1225d9
|
|||
c02abb516c
|
|||
65fc17d331
|
|||
92ae649cf6
|
|||
0ff92614c5
|
1092
Cargo.lock
generated
1092
Cargo.lock
generated
File diff suppressed because it is too large
Load Diff
@@ -1,6 +1,6 @@
|
|||||||
[package]
|
[package]
|
||||||
name = "brownpaper"
|
name = "brownpaper"
|
||||||
version = "0.2.0"
|
version = "0.4.0"
|
||||||
authors = ["shimun <shimun@shimun.net>"]
|
authors = ["shimun <shimun@shimun.net>"]
|
||||||
edition = "2018"
|
edition = "2018"
|
||||||
|
|
||||||
@@ -16,7 +16,7 @@ rand = "0.4.2"
|
|||||||
|
|
||||||
byteorder = "1.3.2"
|
byteorder = "1.3.2"
|
||||||
chrono = "0.4.9"
|
chrono = "0.4.9"
|
||||||
sequoia-openpgp = "0.9.0"
|
sequoia-openpgp = "0.12.0"
|
||||||
lazy_static = "1.4.0"
|
lazy_static = "1.4.0"
|
||||||
c2-chacha = "0.2.2"
|
c2-chacha = "0.2.2"
|
||||||
sha2 = "0.8.0"
|
sha2 = "0.8.0"
|
||||||
|
14
Dockerfile
14
Dockerfile
@@ -1,9 +1,21 @@
|
|||||||
|
FROM rust:1.41.0 as builder
|
||||||
|
|
||||||
|
COPY . /bp
|
||||||
|
|
||||||
|
RUN apt update
|
||||||
|
|
||||||
|
RUN apt install clang nettle-dev -y
|
||||||
|
|
||||||
|
RUN cargo install --path /bp --root /usr
|
||||||
|
|
||||||
FROM debian:buster-slim
|
FROM debian:buster-slim
|
||||||
|
|
||||||
VOLUME /snips
|
VOLUME /snips
|
||||||
|
|
||||||
EXPOSE 3000
|
EXPOSE 3000
|
||||||
|
|
||||||
COPY bin/brownpaper /bin/
|
COPY --from=builder /usr/bin/brownpaper /bin/
|
||||||
|
|
||||||
|
WORKDIR /
|
||||||
|
|
||||||
ENTRYPOINT [ "/bin/brownpaper" ]
|
ENTRYPOINT [ "/bin/brownpaper" ]
|
||||||
|
9
bp.sh
Executable file
9
bp.sh
Executable file
@@ -0,0 +1,9 @@
|
|||||||
|
#!/usr/bin/env bash
|
||||||
|
BP_ENDPOINT=${BROWNPAPER_ENDPOINT:-https://shimun.net/bp}
|
||||||
|
CURL_ARGS="--write-out %{url_effective}\\n --silent -o /dev/null"
|
||||||
|
GPG_ARGS="$([ ! -z "$BROWNPAPER_KEY" ] && echo "--local-user $BROWNPAPER_KEY")"
|
||||||
|
if [ ! -z "$1" ]; then
|
||||||
|
printf "$1" | gpg --sign -a $GPG_ARGS | curl -s --data @- -X POST $BP_ENDPOINT/new -Ls $CURL_ARGS
|
||||||
|
else
|
||||||
|
gpg --sign -a $GPG_ARGS | curl -s --data @- -X POST $BP_ENDPOINT/new -Ls $CURL_ARGS
|
||||||
|
fi
|
25
default.nix
Normal file
25
default.nix
Normal file
@@ -0,0 +1,25 @@
|
|||||||
|
{ pkgs ? import <nixpkgs> { }
|
||||||
|
, callPackage ? pkgs.callPackage
|
||||||
|
, stdenv ? pkgs.stdenv
|
||||||
|
, fetchgit ? pkgs.fetchgit
|
||||||
|
, name ? "brownpaper"
|
||||||
|
, src ? (builtins.filterSource (path: type: baseNameOf path != "target") ./.)
|
||||||
|
}:
|
||||||
|
let
|
||||||
|
crate2nix_tools = import "${fetchgit { url = "https://github.com/kolloch/crate2nix.git"; rev = "adecff03c53b87255b3299f5a5787327342a69b2"; sha256 = "0l10yqa3gq73fc4xc977vb9zk5jlp70xiz5qd9c1vq873yqk1c7g"; }}/tools.nix" { inherit pkgs; };
|
||||||
|
overrides = pkgs.defaultCrateOverrides // rec {
|
||||||
|
nettle-sys = attrs: with pkgs; {
|
||||||
|
propagatedBuildInputs = [ clang nettle pkg-config ];
|
||||||
|
LIBCLANG_PATH = "${clang.cc.lib}/lib";
|
||||||
|
};
|
||||||
|
sequoia-openpgp = attrs: with pkgs; {
|
||||||
|
nativeBuildInputs = [ clang gmp pkg-config ];
|
||||||
|
LIBCLANG_PATH = "${clang.cc.lib}/lib";
|
||||||
|
};
|
||||||
|
brownpaper = sequoia-openpgp; # requires gmp as well
|
||||||
|
};
|
||||||
|
client = pkgs.writeShellScriptBin "brownpaper" ''
|
||||||
|
PATH=${pkgs.bash}/bin/:${pkgs.gnupg}/bin/:${pkgs.curl}/bin/:$PATH ${./bp.sh} "$@"
|
||||||
|
'';
|
||||||
|
in
|
||||||
|
{ server = callPackage (crate2nix_tools.generatedCargoNix { inherit name src; }) { inherit pkgs; }; inherit client; }
|
23
src/main.rs
23
src/main.rs
@@ -21,18 +21,16 @@ use iron::url::Url;
|
|||||||
use iron::mime::Mime;
|
use iron::mime::Mime;
|
||||||
use sha2::Digest;
|
use sha2::Digest;
|
||||||
|
|
||||||
|
use std::env::{self, args};
|
||||||
use std::io;
|
use std::io;
|
||||||
use std::io::prelude::*;
|
use std::io::prelude::*;
|
||||||
use std::iter::Iterator;
|
use std::iter::Iterator;
|
||||||
|
use std::net::SocketAddr;
|
||||||
use std::path::Path;
|
use std::path::Path;
|
||||||
use std::sync::Arc;
|
use std::sync::Arc;
|
||||||
use std::sync::Mutex;
|
use std::sync::Mutex;
|
||||||
|
|
||||||
#[cfg(not(debug_assertions))]
|
const STORAGE_DIR: &str = "./snips";
|
||||||
const STORAGE_DIR: &str = "/snips";
|
|
||||||
|
|
||||||
#[cfg(debug_assertions)]
|
|
||||||
const STORAGE_DIR: &str = "/tmp";
|
|
||||||
|
|
||||||
lazy_static! {
|
lazy_static! {
|
||||||
static ref KNOWN_KEYS: Arc<Mutex<KnownKeys>> = Arc::new(Mutex::new(
|
static ref KNOWN_KEYS: Arc<Mutex<KnownKeys>> = Arc::new(Mutex::new(
|
||||||
@@ -44,7 +42,7 @@ const VERSION: &str = env!("CARGO_PKG_VERSION");
|
|||||||
|
|
||||||
fn handle(req: &mut Request) -> IronResult<Response> {
|
fn handle(req: &mut Request) -> IronResult<Response> {
|
||||||
println!("{}", req.url);
|
println!("{}", req.url);
|
||||||
let storage = SnippetStorage::new(&Path::new(STORAGE_DIR));
|
let storage = SnippetStorage::new(&Path::new(&STORAGE_DIR));
|
||||||
let segments: Vec<&str> = req.url.path();
|
let segments: Vec<&str> = req.url.path();
|
||||||
match (&req.method, segments.first()) {
|
match (&req.method, segments.first()) {
|
||||||
(Method::Get, Some(&"version")) => Ok(Response::with((iron::status::Ok, VERSION))),
|
(Method::Get, Some(&"version")) => Ok(Response::with((iron::status::Ok, VERSION))),
|
||||||
@@ -127,5 +125,16 @@ fn handle(req: &mut Request) -> IronResult<Response> {
|
|||||||
fn main() {
|
fn main() {
|
||||||
let chain = Chain::new(handle);
|
let chain = Chain::new(handle);
|
||||||
println!("Starting brownpaper: {}", STORAGE_DIR);
|
println!("Starting brownpaper: {}", STORAGE_DIR);
|
||||||
Iron::new(chain).http("0.0.0.0:3000").unwrap();
|
Iron::new(chain).http(
|
||||||
|
args()
|
||||||
|
.skip(1)
|
||||||
|
.next()
|
||||||
|
.map(|ip| {
|
||||||
|
ip.parse::<SocketAddr>()
|
||||||
|
.expect("can't parse socket address")
|
||||||
|
})
|
||||||
|
.unwrap_or("0.0.0.0:3000".parse::<SocketAddr>().unwrap())
|
||||||
|
.to_string()
|
||||||
|
.as_str(),
|
||||||
|
);
|
||||||
}
|
}
|
||||||
|
28
src/pgp.rs
28
src/pgp.rs
@@ -37,8 +37,32 @@ impl KnownKeys {
|
|||||||
pub fn verify(&mut self, r: impl Read) -> io::Result<Vec<u8>> {
|
pub fn verify(&mut self, r: impl Read) -> io::Result<Vec<u8>> {
|
||||||
let mut content = Vec::with_capacity(2048);
|
let mut content = Vec::with_capacity(2048);
|
||||||
let helper = &*self;
|
let helper = &*self;
|
||||||
let mut v = Verifier::<&KnownKeys>::from_reader(r, helper, None)
|
let mut v = Verifier::<&KnownKeys>::from_reader(r, helper, None).map_err(|e| {
|
||||||
.map_err(|e| io::Error::new(io::ErrorKind::InvalidData, "Failed to verify signature"))?;
|
io::Error::new(io::ErrorKind::InvalidData, "Failed to verify signature")
|
||||||
|
})?;
|
||||||
|
let mut buf = [0u8; 512];
|
||||||
|
let bp = "brownpaper".as_bytes();
|
||||||
|
loop {
|
||||||
|
match v.read(&mut buf)? {
|
||||||
|
0 => break,
|
||||||
|
read => {
|
||||||
|
// first buffer read
|
||||||
|
if content.len() == 0 {
|
||||||
|
if !(buf.len() > bp.len() && bp == &buf[0..bp.len()]) {
|
||||||
|
return Err(io::Error::new(
|
||||||
|
io::ErrorKind::InvalidData,
|
||||||
|
"Failed to verify signature(prefix)",
|
||||||
|
));
|
||||||
|
} else {
|
||||||
|
// remove prefix
|
||||||
|
content.extend_from_slice(&buf[bp.len()..read])
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
content.extend_from_slice(&buf[0..read]);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
if v.read_to_end(&mut content).is_err() {
|
if v.read_to_end(&mut content).is_err() {
|
||||||
return Err(io::Error::new(
|
return Err(io::Error::new(
|
||||||
io::ErrorKind::InvalidData,
|
io::ErrorKind::InvalidData,
|
||||||
|
Reference in New Issue
Block a user