mirror of
https://github.com/stoatchat/stoatchat.git
synced 2026-07-14 21:47:02 +00:00
* feat: create base of push daemon Signed-off-by: IAmTomahawkx <iamtomahawkx@gmail.com> * Add outbound senders * Make web_push send to rabbit instead (temp stuff) * feat: stability and friend requests * make vapid fr stuff not suck * swap naming of queue * move pushd into daemons folder * fix cargo file for move into daemons folder * feat: probably working fcm push notifs * comment out fcm webpush stuff since the config keys dont exist * fix fcm, name queues according to their prod status and configure routing keys * add pushd to docker * mix: Remove old code, add stuff to pushd * fix: lockfile * feat: update rocket to 5.0.1 * fix: fix queues and ack bugs * Move rabbit messsage processing into ack queue * chore: update readme * chore: optimizations for ack database hits * pushd flowchart * misc: update flowchart * exit dependancy hell * add rocket_impl flag to authifier * make the tests file of delta actually compile * fix: don't silence every push message * fix: don't silence all messages * add debug logging for sending data to rabbit from message events * validate mentions at a server membership level * put back that import that was actually important * minor fix to lockfile * update delta authifier * feat: proper permissions for push notifications * add unit test for mention sanitization * remove local file dependancy on authifier * update ports to proper defaults * fixTM the node bindings * Theoretically configure docker releases for pushd Signed-off-by: IAmTomahawkx <iamtomahawkx@gmail.com> * declare exchange in pushd and delta * fix createbuckets script Signed-off-by: IAmTomahawkx <iamtomahawkx@gmail.com> * fix: reference db implementation Signed-off-by: IAmTomahawkx <iamtomahawkx@gmail.com> * fix: remove finally redundant code Signed-off-by: IAmTomahawkx <iamtomahawkx@gmail.com> * fix: changes Signed-off-by: IAmTomahawkx <iamtomahawkx@gmail.com> * fix: other changes Signed-off-by: IAmTomahawkx <iamtomahawkx@gmail.com> * fix: make channel name return result Signed-off-by: IAmTomahawkx <iamtomahawkx@gmail.com> * Add role mention parsing * feat: update to mongo 3.1, add member generator. * integrate mass mentions into pushd * patch redis-rs with updated versions * feat: chunk role mentions * move permission bits to 37/38 to avoid livekit conflict * change role mention format to <%id> * fix the lockfile from merge * fix: PR change requests * feat: add tests * fix: i am a dumbass * fix: tests, again --------- Signed-off-by: IAmTomahawkx <iamtomahawkx@gmail.com>
111 lines
5.2 KiB
Rust
111 lines
5.2 KiB
Rust
use std::io::Cursor;
|
|
|
|
use rocket::{
|
|
http::{ContentType, Status},
|
|
response::{self, Responder},
|
|
Request, Response,
|
|
};
|
|
|
|
use crate::{Error, ErrorType};
|
|
|
|
/// HTTP response builder for Error enum
|
|
impl<'r> Responder<'r, 'static> for Error {
|
|
fn respond_to(self, _: &'r Request<'_>) -> response::Result<'static> {
|
|
let status = match self.error_type {
|
|
ErrorType::LabelMe => Status::InternalServerError,
|
|
|
|
ErrorType::AlreadyOnboarded => Status::Forbidden,
|
|
|
|
ErrorType::UnknownUser => Status::NotFound,
|
|
ErrorType::InvalidUsername => Status::BadRequest,
|
|
ErrorType::UsernameTaken => Status::Conflict,
|
|
ErrorType::DiscriminatorChangeRatelimited => Status::TooManyRequests,
|
|
ErrorType::AlreadyFriends => Status::Conflict,
|
|
ErrorType::AlreadySentRequest => Status::Conflict,
|
|
ErrorType::Blocked => Status::Conflict,
|
|
ErrorType::BlockedByOther => Status::Forbidden,
|
|
ErrorType::NotFriends => Status::Forbidden,
|
|
ErrorType::TooManyPendingFriendRequests { .. } => Status::BadRequest,
|
|
|
|
ErrorType::UnknownChannel => Status::NotFound,
|
|
ErrorType::UnknownMessage => Status::NotFound,
|
|
ErrorType::UnknownAttachment => Status::BadRequest,
|
|
ErrorType::CannotEditMessage => Status::Forbidden,
|
|
ErrorType::CannotJoinCall => Status::BadRequest,
|
|
ErrorType::TooManyAttachments { .. } => Status::BadRequest,
|
|
ErrorType::TooManyReplies { .. } => Status::BadRequest,
|
|
ErrorType::EmptyMessage => Status::UnprocessableEntity,
|
|
ErrorType::PayloadTooLarge => Status::UnprocessableEntity,
|
|
ErrorType::CannotRemoveYourself => Status::BadRequest,
|
|
ErrorType::GroupTooLarge { .. } => Status::Forbidden,
|
|
ErrorType::AlreadyInGroup => Status::Conflict,
|
|
ErrorType::NotInGroup => Status::NotFound,
|
|
ErrorType::AlreadyPinned => Status::BadRequest,
|
|
ErrorType::NotPinned => Status::BadRequest,
|
|
ErrorType::InvalidFlagValue => Status::BadRequest,
|
|
|
|
ErrorType::UnknownServer => Status::NotFound,
|
|
ErrorType::InvalidRole => Status::NotFound,
|
|
ErrorType::Banned => Status::Forbidden,
|
|
ErrorType::AlreadyInServer => Status::Conflict,
|
|
ErrorType::CannotTimeoutYourself => Status::BadRequest,
|
|
|
|
ErrorType::TooManyServers { .. } => Status::BadRequest,
|
|
ErrorType::TooManyEmbeds { .. } => Status::BadRequest,
|
|
ErrorType::TooManyEmoji { .. } => Status::BadRequest,
|
|
ErrorType::TooManyChannels { .. } => Status::BadRequest,
|
|
ErrorType::TooManyRoles { .. } => Status::BadRequest,
|
|
|
|
ErrorType::ReachedMaximumBots => Status::BadRequest,
|
|
ErrorType::IsBot => Status::BadRequest,
|
|
ErrorType::IsNotBot => Status::BadRequest,
|
|
ErrorType::BotIsPrivate => Status::Forbidden,
|
|
|
|
ErrorType::CannotReportYourself => Status::BadRequest,
|
|
|
|
ErrorType::MissingPermission { .. } => Status::Forbidden,
|
|
ErrorType::MissingUserPermission { .. } => Status::Forbidden,
|
|
ErrorType::NotElevated => Status::Forbidden,
|
|
ErrorType::NotPrivileged => Status::Forbidden,
|
|
ErrorType::CannotGiveMissingPermissions => Status::Forbidden,
|
|
ErrorType::NotOwner => Status::Forbidden,
|
|
|
|
ErrorType::DatabaseError { .. } => Status::InternalServerError,
|
|
ErrorType::InternalError => Status::InternalServerError,
|
|
ErrorType::InvalidOperation => Status::BadRequest,
|
|
ErrorType::InvalidCredentials => Status::Unauthorized,
|
|
ErrorType::InvalidProperty => Status::BadRequest,
|
|
ErrorType::InvalidSession => Status::Unauthorized,
|
|
ErrorType::NotAuthenticated => Status::Unauthorized,
|
|
ErrorType::DuplicateNonce => Status::Conflict,
|
|
ErrorType::NotFound => Status::NotFound,
|
|
ErrorType::NoEffect => Status::Ok,
|
|
ErrorType::FailedValidation { .. } => Status::BadRequest,
|
|
ErrorType::LiveKitUnavailable => Status::BadRequest,
|
|
ErrorType::NotAVoiceChannel => Status::BadRequest,
|
|
ErrorType::AlreadyConnected => Status::BadRequest,
|
|
ErrorType::NotConnected => Status::BadRequest,
|
|
ErrorType::UnknownNode => Status::BadRequest,
|
|
ErrorType::FeatureDisabled { .. } => Status::BadRequest,
|
|
|
|
ErrorType::ProxyError => Status::BadRequest,
|
|
ErrorType::FileTooSmall => Status::UnprocessableEntity,
|
|
ErrorType::FileTooLarge { .. } => Status::UnprocessableEntity,
|
|
ErrorType::FileTypeNotAllowed => Status::BadRequest,
|
|
ErrorType::ImageProcessingFailed => Status::InternalServerError,
|
|
ErrorType::NoEmbedData => Status::BadRequest,
|
|
ErrorType::VosoUnavailable => Status::BadRequest,
|
|
};
|
|
|
|
// Serialize the error data structure into JSON.
|
|
let string = serde_json::to_string(&self).unwrap();
|
|
|
|
// Build and send the request.
|
|
Response::build()
|
|
.sized_body(string.len(), Cursor::new(string))
|
|
.header(ContentType::new("application", "json"))
|
|
.status(status)
|
|
.ok()
|
|
}
|
|
}
|