[web] Introduce `Subchannels` action in thread menu
ClosedPublic
Actions

#![allow(unused)]		#![allow(unused)]
use std::ops::{Bound, Range, RangeBounds, RangeInclusive};		use std::ops::{Bound, Range, RangeBounds, RangeInclusive};
use std::sync::Arc;		use std::sync::Arc;

use async_stream::try_stream;		use async_stream::try_stream;
use chrono::Duration;		use chrono::Duration;
		use comm_services_lib::http::ByteStream;
		use comm_services_lib::tools::BoxedError;
use tokio_stream::StreamExt;		use tokio_stream::StreamExt;
use tonic::codegen::futures_core::Stream;		use tonic::codegen::futures_core::Stream;
use tracing::{debug, error, trace, warn};		use tracing::{debug, error, trace, warn};

use crate::constants::S3_MULTIPART_UPLOAD_MINIMUM_CHUNK_SIZE;		use crate::constants::S3_MULTIPART_UPLOAD_MINIMUM_CHUNK_SIZE;
use crate::database::types::{		use crate::database::types::{
BlobItemInput, BlobItemRow, PrimaryKey, UncheckedKind,		BlobItemInput, BlobItemRow, PrimaryKey, UncheckedKind,
};		};
use crate::database::DBError;		use crate::database::DBError;
use crate::s3::{Error as S3Error, S3Client, S3Path};		use crate::s3::{Error as S3Error, S3Client, S3Path};
use crate::tools::{BoxedError, ByteStream, MemOps};		use crate::tools::MemOps;
use crate::{constants::BLOB_DOWNLOAD_CHUNK_SIZE, database::DatabaseClient};		use crate::{constants::BLOB_DOWNLOAD_CHUNK_SIZE, database::DatabaseClient};

#[derive(		#[derive(
Debug, derive_more::Display, derive_more::From, derive_more::Error,		Debug, derive_more::Display, derive_more::From, derive_more::Error,
)]		)]
pub enum BlobServiceError {		pub enum BlobServiceError {
BlobNotFound,		BlobNotFound,
BlobAlreadyExists,		BlobAlreadyExists,
▲ Show 20 Lines • Show All 101 Lines • ▼ Show 20 Lines	) -> Result<(), BlobServiceError> {
}		}

let mut upload_session =		let mut upload_session =
self.s3.start_upload_session(&blob_item.s3_path).await?;		self.s3.start_upload_session(&blob_item.s3_path).await?;
trace!(?blob_item, "Started S3 upload session");		trace!(?blob_item, "Started S3 upload session");

tokio::pin!(blob_data_stream);		tokio::pin!(blob_data_stream);
let mut s3_chunk: Vec<u8> = Vec::new();		let mut s3_chunk: Vec<u8> = Vec::new();
while let Some(mut chunk) =		while let Some(chunk) =
blob_data_stream.try_next().await.map_err(\|err\| {		blob_data_stream.try_next().await.map_err(\|err\| {
warn!("Failed to get data chunk: {:?}", err);		warn!("Failed to get data chunk: {:?}", err);
BlobServiceError::InputError(err)		BlobServiceError::InputError(err)
})?		})?
{		{
s3_chunk.append(&mut chunk);		s3_chunk.extend_from_slice(&chunk);

// New parts should be added to AWS only if they exceed minimum part size,		// New parts should be added to AWS only if they exceed minimum part size,
// Otherwise AWS returns error		// Otherwise AWS returns error
if s3_chunk.len() as u64 > S3_MULTIPART_UPLOAD_MINIMUM_CHUNK_SIZE {		if s3_chunk.len() as u64 > S3_MULTIPART_UPLOAD_MINIMUM_CHUNK_SIZE {
trace!(		trace!(
chunk_size = s3_chunk.len(),		chunk_size = s3_chunk.len(),
"Chunk size exceeded, adding new S3 part"		"Chunk size exceeded, adding new S3 part"
);		);
▲ Show 20 Lines • Show All 135 Lines • Show Last 20 Lines

[web] Introduce `Subchannels` action in thread menuClosedPublicActions

Details

Diff Detail

Event Timeline

Revision ContentsChangeset List

Diff 11216

web/chat/thread-menu.react.js

[web] Introduce `Subchannels` action in thread menu
ClosedPublic
Actions

Revision Contents
Changeset List