Struct App 

pub struct App { /* private fields */ }

Implementations

impl App

pub async fn new(mongodb: Database) -> App

Examples found in repository

examples/simple.rs (line 16)

async fn main() {
    let mongo_uri = std::env::var("MONGO_URI").expect("no MONGO_URI env");
    tracing_subscriber::registry()
        .with(tracing_subscriber::fmt::layer())
        .init();

    let db = mongodb::Client::with_uri_str(mongo_uri)
        .await
        .expect("db error")
        .database("kuafu_next");

    let app = service::App::new(db).await;

    hi_push::http::start(app, "0.0.0.0:8080", None)
        .await
        .expect("http start error")
}

pub async fn init(&mut self) -> Result<()>

pub async fn running_ch_ids(&self) -> Vec<String>

Channel ids on running

pub async fn register_client(&self, chan: &Channel) -> Result<()>

Add channel client to memory

pub async fn deregister_client(&self, ch_id: &str)

Remove channel client from memory.

pub async fn new_client(conf: &Channel) -> Result<Client>

Create a new channel client by config.

pub async fn push_message( &self, client_id: &str, msg: Message, ) -> Result<PushResp>

Push message

pub async fn register_token( &self, client_id: &str, group: &str, ch_id: &str, token: &str, _override: Option<bool>, ) -> Result<()>

Register token

pub async fn revoke_token( &self, client_id: &str, group: &str, ch_id: &str, token: &str, ) -> Result<()>

Revoke token

pub async fn create_channel( &self, app_id: &str, params: PublicChannel, ) -> Result<String>

Create a channel.

pub async fn fetch_channels(&self, client_id: &str) -> Result<Vec<Channel>>

Fetch channels from database belong client_id .

pub async fn create_app(&self, name: &str) -> Result<App>

Create application.

pub async fn fetch_apps(&self) -> Result<Vec<App>>

Fecth applications from database.

pub async fn delete_app( &self, client_id: &str, client_secret: &str, ) -> Result<()>

Delete application from database.

pub async fn delete_channel(&self, client_id: &str, ch_id: &str) -> Result<()>

Delete channel from database.

pub async fn validate_app( &self, client_id: &str, client_secret: &str, ) -> Result<()>

Validate client_id and client_secret.