mirror of
https://github.com/stoatchat/stoatchat.git
synced 2026-07-14 05:26:59 +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> --------- Signed-off-by: IAmTomahawkx <iamtomahawkx@gmail.com>
100 lines
1.9 KiB
Rust
100 lines
1.9 KiB
Rust
#[macro_use]
|
|
extern crate serde;
|
|
|
|
#[macro_use]
|
|
extern crate async_recursion;
|
|
|
|
#[macro_use]
|
|
extern crate async_trait;
|
|
|
|
#[macro_use]
|
|
extern crate log;
|
|
|
|
#[macro_use]
|
|
extern crate revolt_optional_struct;
|
|
|
|
#[macro_use]
|
|
extern crate revolt_result;
|
|
|
|
pub use iso8601_timestamp;
|
|
|
|
#[cfg(feature = "mongodb")]
|
|
pub use mongodb;
|
|
|
|
#[cfg(feature = "mongodb")]
|
|
#[macro_use]
|
|
extern crate bson;
|
|
|
|
macro_rules! database_derived {
|
|
( $( $item:item )+ ) => {
|
|
$(
|
|
#[derive(Clone)]
|
|
$item
|
|
)+
|
|
};
|
|
}
|
|
|
|
macro_rules! auto_derived {
|
|
( $( $item:item )+ ) => {
|
|
$(
|
|
#[derive(Serialize, Deserialize, Debug, Clone, Eq, PartialEq)]
|
|
$item
|
|
)+
|
|
};
|
|
}
|
|
|
|
macro_rules! auto_derived_partial {
|
|
( $item:item, $name:expr ) => {
|
|
#[derive(OptionalStruct, Serialize, Deserialize, Debug, Clone, Eq, PartialEq)]
|
|
#[optional_derive(Serialize, Deserialize, Debug, Clone, Default, Eq, PartialEq)]
|
|
#[optional_name = $name]
|
|
#[opt_skip_serializing_none]
|
|
#[opt_some_priority]
|
|
$item
|
|
};
|
|
}
|
|
|
|
mod drivers;
|
|
pub use drivers::*;
|
|
|
|
#[cfg(test)]
|
|
macro_rules! database_test {
|
|
( | $db: ident | $test:expr ) => {
|
|
let db = $crate::DatabaseInfo::Test(format!(
|
|
"{}:{}",
|
|
file!().replace('/', "_").replace(".rs", ""),
|
|
line!()
|
|
))
|
|
.connect()
|
|
.await
|
|
.expect("Database connection failed.");
|
|
|
|
db.drop_database().await;
|
|
|
|
#[allow(clippy::redundant_closure_call)]
|
|
(|$db: $crate::Database| $test)(db.clone()).await;
|
|
|
|
db.drop_database().await
|
|
};
|
|
}
|
|
|
|
mod models;
|
|
pub mod util;
|
|
pub use models::*;
|
|
|
|
pub mod events;
|
|
pub mod tasks;
|
|
|
|
mod amqp;
|
|
pub use amqp::amqp::AMQP;
|
|
|
|
/// Utility function to check if a boolean value is false
|
|
pub fn if_false(t: &bool) -> bool {
|
|
!t
|
|
}
|
|
|
|
/// Utility function to check if an option doesnt contain true
|
|
pub fn if_option_false(t: &Option<bool>) -> bool {
|
|
t != &Some(true)
|
|
}
|