flibusta-apps/telegram_files_cache_server
1
0
Fork 0
mirror of https://github.com/flibusta-apps/telegram_files_cache_server.git synced 2025-12-06 06:35:38 +01:00
Code Issues Actions Packages Projects Releases Wiki Activity

Fix minio after update

Browse Source
This commit is contained in:
Bulat Kurbanov
2023-11-07 14:20:34 +01:00
parent c82919f960
commit 0c79b153b2
1 changed files with 6 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
src/services/minio.rs
View File

@@ -2,12 +2,7 @@ use std::io::Read;
use async_stream::stream; use async_stream::stream;
use bytes::Bytes; use bytes::Bytes;
use minio_rsc::{ use minio_rsc::{client::PresignedArgs, error::Error, provider::StaticProvider, Minio};
errors::MinioError,
provider::StaticProvider,
types::args::{ObjectArgs, PresignedArgs},
Minio,
};
use tempfile::SpooledTempFile; use tempfile::SpooledTempFile;
use crate::config; use crate::config;
@@ -20,7 +15,7 @@ pub fn get_minio() -> Minio {
); );
Minio::builder() Minio::builder()
.host(&config::CONFIG.minio_host) .endpoint(&config::CONFIG.minio_host)
.provider(provider) .provider(provider)
.secure(false) .secure(false)
.build() .build()
@@ -29,7 +24,7 @@ pub fn get_minio() -> Minio {
pub fn get_stream( pub fn get_stream(
mut temp_file: Box<dyn Read + Send>, mut temp_file: Box<dyn Read + Send>,
) -> impl futures_core::Stream<Item = Result<Bytes, MinioError>> { ) -> impl futures_core::Stream<Item = Result<Bytes, Error>> {
stream! { stream! {
let mut buf = [0; 2048]; let mut buf = [0; 2048];
@@ -62,8 +57,10 @@ pub async fn upload_to_minio(
if let Err(err) = minio if let Err(err) = minio
.put_object_stream( .put_object_stream(
ObjectArgs::new(&config::CONFIG.minio_bucket, filename.clone()), &config::CONFIG.minio_bucket,
filename.clone(),
Box::pin(data_stream), Box::pin(data_stream),
None,
) )
.await .await
{ {