1use std::collections::{BTreeMap, HashMap, HashSet};
2use std::fmt::Debug;
3use std::sync::atomic::AtomicUsize;
4use std::sync::atomic::Ordering;
5use std::sync::{Arc, OnceLock};
6use std::time::{Duration, Instant};
7
8use diesel::prelude::*;
9use serde::Deserialize;
10use serde_json::value::to_raw_value;
11use tokio::sync::{mpsc, Mutex, Semaphore};
12
13use crate::connect;
14use crate::core::appservice::event::{push_events_request, PushEventsReqBody};
15use crate::core::appservice::Registration;
16use crate::core::device::DeviceListUpdateContent;
17use crate::core::events::push_rules::PushRulesEventContent;
18use crate::core::events::receipt::{ReceiptContent, ReceiptData, ReceiptMap, ReceiptType};
19use crate::core::events::GlobalAccountDataEventType;
20use crate::core::federation::transaction::{send_messages_request, Edu, SendMessageReqBody, SendMessageResBody};
21use crate::core::identifiers::*;
22use crate::core::presence::{PresenceContent, PresenceUpdate};
23pub use crate::core::sending::*;
24use crate::core::serde::{CanonicalJsonObject, RawJsonValue};
25use crate::core::{device_id, push, Seqnum, UnixMillis};
26use crate::schema::*;
27
28#[derive(Identifiable, Queryable, Insertable, Debug, Clone)]
29#[diesel(table_name = outgoing_requests)]
30pub struct DbOutgoingRequest {
31 pub id: i64,
32 pub kind: String,
33 pub appservice_id: Option<String>,
34 pub user_id: Option<OwnedUserId>,
35 pub pushkey: Option<String>,
36 pub server_id: Option<OwnedServerName>,
37 pub pdu_id: Option<OwnedEventId>,
38 pub edu_json: Option<Vec<u8>>,
39 pub state: String,
40 pub data: Option<Vec<u8>>,
41}
42#[derive(Insertable, Debug, Clone)]
43#[diesel(table_name = outgoing_requests)]
44pub struct NewDbOutgoingRequest {
45 pub kind: String,
46 pub appservice_id: Option<String>,
47 pub user_id: Option<OwnedUserId>,
48 pub pushkey: Option<String>,
49 pub server_id: Option<OwnedServerName>,
50 pub pdu_id: Option<OwnedEventId>,
51 pub edu_json: Option<Vec<u8>>,
52}