9 Commits
0.2.0 ... 0.4.0

Author SHA1 Message Date
72c1cf7120 prefixed 2020-12-16 15:23:19 +01:00
a2a3a8bc48 quote args 2020-12-13 21:52:52 +01:00
6d4af5f82c update crate2nix 2020-12-13 10:49:01 +01:00
3b5bf84b18 make script addable to path 2020-12-12 14:46:06 +01:00
a91d1225d9 outputs 2020-12-12 14:43:22 +01:00
c02abb516c client script 2020-12-12 14:23:37 +01:00
65fc17d331 update 2020-09-26 20:54:58 +02:00
92ae649cf6 args 2020-09-26 18:42:41 +02:00
0ff92614c5 add default.nix 2020-08-12 12:53:58 +02:00
7 changed files with 666 additions and 529 deletions

1092
Cargo.lock generated

File diff suppressed because it is too large Load Diff

View File

@@ -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"

View File

@@ -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
View 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
View 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; }

View File

@@ -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(),
);
} }

View File

@@ -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,