mirror of
https://framagit.org/veretcle/scootaloo.git
synced 2025-07-21 09:31:19 +02:00
feat: main logic for regex + url filtering
This commit is contained in:
18
src/lib.rs
18
src/lib.rs
@@ -22,6 +22,7 @@ use state::{read_state, write_state, TweetToToot};
|
|||||||
use elefren::{prelude::*, status_builder::StatusBuilder, Language};
|
use elefren::{prelude::*, status_builder::StatusBuilder, Language};
|
||||||
use futures::StreamExt;
|
use futures::StreamExt;
|
||||||
use log::info;
|
use log::info;
|
||||||
|
use regex::Regex;
|
||||||
use rusqlite::Connection;
|
use rusqlite::Connection;
|
||||||
use std::{collections::HashMap, sync::Arc};
|
use std::{collections::HashMap, sync::Arc};
|
||||||
use tokio::{spawn, sync::Mutex};
|
use tokio::{spawn, sync::Mutex};
|
||||||
@@ -58,6 +59,14 @@ pub async fn run(config: Config) {
|
|||||||
})
|
})
|
||||||
.collect();
|
.collect();
|
||||||
|
|
||||||
|
let display_url_re = config
|
||||||
|
.scootaloo
|
||||||
|
.show_url_as_display_url_for
|
||||||
|
.as_ref()
|
||||||
|
.map(|r|
|
||||||
|
// we want to panic in case the RE is not valid
|
||||||
|
Regex::new(r).unwrap());
|
||||||
|
|
||||||
let mut stream = futures::stream::iter(config.mastodon.into_values())
|
let mut stream = futures::stream::iter(config.mastodon.into_values())
|
||||||
.map(|mastodon_config| {
|
.map(|mastodon_config| {
|
||||||
// calculate Twitter page size
|
// calculate Twitter page size
|
||||||
@@ -68,6 +77,8 @@ pub async fn run(config: Config) {
|
|||||||
// create temporary value for each task
|
// create temporary value for each task
|
||||||
let scootaloo_cache_path = config.scootaloo.cache_path.clone();
|
let scootaloo_cache_path = config.scootaloo.cache_path.clone();
|
||||||
let scootaloo_mentions = scootaloo_mentions.clone();
|
let scootaloo_mentions = scootaloo_mentions.clone();
|
||||||
|
let scootaloo_alt_services = config.scootaloo.alternative_services_for.clone();
|
||||||
|
let display_url_re = display_url_re.clone();
|
||||||
let token = get_oauth2_token(&config.twitter);
|
let token = get_oauth2_token(&config.twitter);
|
||||||
let task_conn = conn.clone();
|
let task_conn = conn.clone();
|
||||||
|
|
||||||
@@ -108,7 +119,12 @@ pub async fn run(config: Config) {
|
|||||||
drop(lconn);
|
drop(lconn);
|
||||||
|
|
||||||
// build basic status by just yielding text and dereferencing contained urls
|
// build basic status by just yielding text and dereferencing contained urls
|
||||||
let mut status_text = build_basic_status(tweet, &scootaloo_mentions);
|
let mut status_text = build_basic_status(
|
||||||
|
tweet,
|
||||||
|
&scootaloo_mentions,
|
||||||
|
&display_url_re,
|
||||||
|
&scootaloo_alt_services,
|
||||||
|
);
|
||||||
|
|
||||||
// building associative media list
|
// building associative media list
|
||||||
let (media_url, status_medias) =
|
let (media_url, status_medias) =
|
||||||
|
Reference in New Issue
Block a user