Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Create route to get hash of all games #39

Open
wants to merge 3 commits into
base: master
Choose a base branch
from
Open

Create route to get hash of all games #39

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
8462454
list hash route
Qelxiros Apr 8, 2024
3f3ac3a
:clown:
Qelxiros Apr 8, 2024
c2fe1d1
:clown: :clown: :clown:
Qelxiros Apr 8, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 2 additions & 0 deletions src/app.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,7 @@ pub fn configure_app(cfg: &mut web::ServiceConfig) {
#[openapi(
paths(
games::get_all_games,
games::get_list_hash,
games::get_game,
games::edit_game,
games::delete_game,
Expand Down Expand Up @@ -70,6 +71,7 @@ pub fn configure_app(cfg: &mut web::ServiceConfig) {
.service(
scope("/games")
.service(games::get_all_games)
.service(games::get_list_hash)
.service(games::get_game)
.service(games::edit_game)
.service(games::delete_game)
Expand Down
121 changes: 87 additions & 34 deletions src/games/routes.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -2,26 +2,26 @@ use crate::{
models::{AppState, Game, GameWithTags},
security::RequireApiKey,
};
use image::{load_from_memory, imageops, ImageBuffer};
use bytes::Bytes;
use actix_multipart::form::{tempfile::TempFile, text::Text, MultipartForm};
use actix_web::{
delete, get, post, put,
web::{Data, Json, Path},
HttpResponse, Responder,
};
use aws_sdk_s3::{types::ByteStream, Client};
use bytes::Bytes;
use chrono::prelude::*;
use image::{imageops, load_from_memory, ImageBuffer};
use lazy_static::lazy_static;
use serde::{Deserialize, Serialize};
use sha1::{Digest, Sha1};
use sqlx::{query, query_as};
use sqlx::{query, query_as, Postgres, Row};
use std::{
env,
error::Error,
fmt,
fs::File,
io::{BufReader, Read, Cursor},
io::{BufReader, Cursor, Read},
};
use utoipa::ToSchema;
use uuid::Uuid;
Expand Down Expand Up @@ -140,6 +140,39 @@ pub async fn get_all_games(state: Data<AppState>) -> impl Responder {
}
}

#[utoipa::path(
context_path = "/games",
responses(
(status = 200, description = "Get a hash of all games", body = [GameWithTags]),
(status = 500, description = "Error Created by Query"),
)
)]
#[get("/hash")]
pub async fn get_list_hash(state: Data<AppState>) -> impl Responder {
let hashes: Vec<String> = match query::<Postgres>("select hash from game order by name asc")
.fetch_all(&state.db)
.await
{
Ok(hashes) => hashes
.iter()
.map(|x| x.get::<String, &str>("hash"))
.collect(),
Err(e) => return HttpResponse::InternalServerError().body(e.to_string()),
};

let hash_string = hashes.join("");

let mut hasher = Sha1::new();
hasher.update(&hash_string);
let hexes = hasher.finalize();
let mut out = String::new();
for hex in hexes {
out.push_str(&format!("{:02x?}", hex));
}

HttpResponse::Ok().json(out)
}

async fn verify_and_upload_game(
game: TempFile,
s3: &Client,
Expand Down Expand Up @@ -194,7 +227,25 @@ async fn verify_and_upload_image(
}
let image_buffer = Vec::new();
let mut cursor = Cursor::new(image_buffer);
imageops::resize(&load_from_memory(&ByteStream::from_path(image.file.path()).await?.collect().await?.into_bytes(),)?,match image_type {ImageComponent::Icon => 150, ImageComponent::Banner => 850,},match image_type {ImageComponent::Icon => 150, ImageComponent::Banner => 400,}, imageops::FilterType::Lanczos3,).write_to(&mut cursor, image::ImageFormat::Png)?;
imageops::resize(
&load_from_memory(
&ByteStream::from_path(image.file.path())
.await?
.collect()
.await?
.into_bytes(),
)?,
match image_type {
ImageComponent::Icon => 150,
ImageComponent::Banner => 850,
},
match image_type {
ImageComponent::Icon => 150,
ImageComponent::Banner => 400,
},
imageops::FilterType::Lanczos3,
)
.write_to(&mut cursor, image::ImageFormat::Png)?;
let _ = s3
.put_object()
.key(format!(
Expand All @@ -203,26 +254,27 @@ async fn verify_and_upload_image(
image_type.filename(),
//image_content_type.subtype()
))
.body(
ByteStream::from(
Bytes::copy_from_slice(
ImageBuffer::into_raw(
imageops::resize(
&load_from_memory(&ByteStream::from_path(image.file.path()).await?.collect().await?.into_bytes())?,
match image_type {
ImageComponent::Banner => 850,
ImageComponent::Icon => 150,
},
match image_type {
ImageComponent::Banner => 400,
ImageComponent::Icon => 150,
},
imageops::FilterType::Lanczos3
)
).as_slice()
)
)
)
.body(ByteStream::from(Bytes::copy_from_slice(
ImageBuffer::into_raw(imageops::resize(
&load_from_memory(
&ByteStream::from_path(image.file.path())
.await?
.collect()
.await?
.into_bytes(),
)?,
match image_type {
ImageComponent::Banner => 850,
ImageComponent::Icon => 150,
},
match image_type {
ImageComponent::Banner => 400,
ImageComponent::Icon => 150,
},
imageops::FilterType::Lanczos3,
))
.as_slice(),
)))
.bucket(&GAMES_BUCKET.to_string())
.send()
.await?;
Expand Down Expand Up @@ -372,12 +424,13 @@ pub async fn edit_game(
{
Ok(_) => {
if let Err(e) = query("DELETE FROM game_tags WHERE game_id = $1")
.bind(&id)
.execute(&mut transaction)
.await {
let _ = transaction.rollback().await;
return HttpResponse::InternalServerError().body(e.to_string());
};
.bind(&id)
.execute(&mut transaction)
.await
{
let _ = transaction.rollback().await;
return HttpResponse::InternalServerError().body(e.to_string());
};
for tag_name in game_data.tags.clone() {
if let Err(e) = query("INSERT INTO game_tags VALUES ($1, $2)")
.bind(&id)
Expand All @@ -398,17 +451,17 @@ pub async fn edit_game(
hash: game.hash,
description: game_data.description.clone(),
})
},
}
Err(e) => {
let _ = transaction.rollback().await;
HttpResponse::InternalServerError().body(e.to_string())
},
}
}
}
Err(_) => {
let _ = transaction.rollback().await;
HttpResponse::BadRequest().body("Game ID Does Not Exist")
},
}
}
}

Expand Down