WIP uploads
This commit is contained in:
parent
f378f356e9
commit
cf49211b74
@ -3,6 +3,7 @@
|
|||||||
#[macro_use] extern crate rocket;
|
#[macro_use] extern crate rocket;
|
||||||
use rocket::State;
|
use rocket::State;
|
||||||
use rocket::response::status::NotFound;
|
use rocket::response::status::NotFound;
|
||||||
|
use rocket::Data;
|
||||||
|
|
||||||
use rocket_contrib::json::Json;
|
use rocket_contrib::json::Json;
|
||||||
use serde_json::Value;
|
use serde_json::Value;
|
||||||
@ -103,6 +104,14 @@ fn edit_status(id: Uuid, status: String, shared: State<SharedState>, remote_addr
|
|||||||
Ok("Status changed".to_string())
|
Ok("Status changed".to_string())
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
#[post("/", data = "<video>")]
|
||||||
|
fn upload(video: Data) -> Result<String, std::io::Error> {
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
#[post("/add_job", format = "json", data = "<message>")]
|
#[post("/add_job", format = "json", data = "<message>")]
|
||||||
fn add_job(message: Json<workunit::WDesc>, shared: State<SharedState>) {
|
fn add_job(message: Json<workunit::WDesc>, shared: State<SharedState>) {
|
||||||
println!("{:#?}", message);
|
println!("{:#?}", message);
|
||||||
|
@ -5,7 +5,7 @@ set -euo pipefail
|
|||||||
IFS=$'\n\t'
|
IFS=$'\n\t'
|
||||||
|
|
||||||
base_url="$1"
|
base_url="$1"
|
||||||
version="0.2.0"
|
version="0.3.0"
|
||||||
|
|
||||||
while true; do
|
while true; do
|
||||||
sleep 30
|
sleep 30
|
||||||
@ -127,8 +127,15 @@ while true; do
|
|||||||
set -e
|
set -e
|
||||||
fi
|
fi
|
||||||
|
|
||||||
|
echo "Marking as complete"
|
||||||
|
|
||||||
set +e
|
set +e
|
||||||
curl -s -L "$base_url"/edit_status/"$job_id"/completed
|
curl -s -L "$base_url"/edit_status/"$job_id"/completed
|
||||||
set -e
|
set -e
|
||||||
|
|
||||||
|
echo ""
|
||||||
|
|
||||||
|
echo "Deleting Temporary files"
|
||||||
|
rm "$input" "$input".fpf
|
||||||
|
|
||||||
done
|
done
|
Loading…
Reference in New Issue
Block a user