.with_context(|| format!("Enable fetch conn:\n{:?}", &self.pool))?;
		match sqlx::query("update rsstg_source set enabled = true where source_id = $1 and owner = $2")
			.bind(source_id)
			.bind(owner)
			.execute(&mut conn).await
			.with_context(|| format!("Enable source:\n{:?}", &self.pool))?
			.rows_affected() {
			1 => { Ok("Source disabled\\.") },
			1 => { Ok("Source enabled\\.") },
			0 => { Ok("Source not found\\.") },
			_ => { Err(anyhow!("Database error.")) },
		}
	}

	async fn disable<S>(&self, source_id: &i32, owner: S) -> Result<&str>
	where S: Into<i64> {

	let mut settings = config::Config::default();
	settings.merge(config::File::with_name("rsstg"))?;

	let core = Core::new(settings).await?;

	let mut stream = core.stream();

	loop {
	while let Some(update) = stream.next().await {
		if let Err(err) = handle(update?, &core).await {
			core.debug(&format!("🛑 {:?}", err))?;
		match stream.next().await {
			Some(update) => {
				if let Err(err) = handle(update?, &core).await {
					core.debug(&format!("🛑 {:?}", err))?;
				};
			},
			None => {
				core.debug(&format!("🛑 None error."))?;
			}
		};
	}

	Ok(())
	//Ok(())
}

async fn handle(update: telegram_bot::Update, core: &Core) -> Result<()> {
	lazy_static! {
		static ref RE_USERNAME: Regex = Regex::new(r"^@[a-zA-Z][a-zA-Z0-9_]+$").unwrap();
		static ref RE_LINK: Regex = Regex::new(r"^https?://[a-zA-Z.0-9-]+/[-_a-zA-Z.0-9/?=]+$").unwrap();
		static ref RE_IV_HASH: Regex = Regex::new(r"^[a-f0-9]{14}$").unwrap();