thallada/crawlnicle
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Remove dbg! statements

Browse Source
This commit is contained in:
Tyler Hallada 2023-09-01 19:59:10 -04:00
parent 21cae62714
commit e50e165b87
3 changed files with 1 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/actors/importer.rs
View File

@ -100,7 +100,6 @@ impl Importer {
})?; })?;
let mut crawls = JoinSet::new(); let mut crawls = JoinSet::new();
for url in Self::gather_feed_urls(document.body.outlines) { for url in Self::gather_feed_urls(document.body.outlines) {
dbg!(&url);
let feed = Feed::create( let feed = Feed::create(
&self.pool, &self.pool,
CreateFeed { CreateFeed {
@ -111,7 +110,6 @@ impl Importer {
.await; .await;
if let Err(Error::Sqlx(sqlx::error::Error::Database(err))) = feed { if let Err(Error::Sqlx(sqlx::error::Error::Database(err))) = feed {
if err.is_unique_violation() { if err.is_unique_violation() {
dbg!("already imported", &url);
let _ = respond_to.send(ImporterHandleMessage::AlreadyImported(url)); let _ = respond_to.send(ImporterHandleMessage::AlreadyImported(url));
} }
} else if let Ok(feed) = feed { } else if let Ok(feed) = feed {
@ -125,10 +123,7 @@ impl Importer {
} }
} }
while let Some(feed_id) = crawls.join_next().await { while crawls.join_next().await.is_some() {}
dbg!("done crawling feed", feed_id);
}
dbg!("done import_opml");
Ok(()) Ok(())
} }
@ -153,7 +148,6 @@ impl Importer {
bytes, bytes,
respond_to, respond_to,
} => { } => {
dbg!("handle_message", import_id);
let result = self let result = self
.import_opml(import_id, file_name, bytes, respond_to.clone()) .import_opml(import_id, file_name, bytes, respond_to.clone())
.await; .await;
@ -219,7 +213,6 @@ impl ImporterHandle {
file_name: Option<String>, file_name: Option<String>,
bytes: Bytes, bytes: Bytes,
) -> broadcast::Receiver<ImporterHandleMessage> { ) -> broadcast::Receiver<ImporterHandleMessage> {
dbg!(import_id, &file_name, bytes.len());
let (sender, receiver) = broadcast::channel(8); let (sender, receiver) = broadcast::channel(8);
let msg = ImporterMessage::Import { let msg = ImporterMessage::Import {
import_id, import_id,

2
src/handlers/import.rs
View File

@ -26,9 +26,7 @@ pub async fn opml(
if let Some(field) = multipart.next_field().await? { if let Some(field) = multipart.next_field().await? {
let import_id = Base62Uuid::new(); let import_id = Base62Uuid::new();
let file_name = field.file_name().map(|s| s.to_string()); let file_name = field.file_name().map(|s| s.to_string());
dbg!(&file_name);
let bytes = field.bytes().await?; let bytes = field.bytes().await?;
dbg!(bytes.len());
let receiver = importer.import(import_id.as_uuid(), file_name, bytes).await; let receiver = importer.import(import_id.as_uuid(), file_name, bytes).await;
{ {
let mut imports = imports.lock().await; let mut imports = imports.lock().await;

3
src/partials/layout.rs
View File

@ -94,9 +94,6 @@ impl Layout {
head { head {
meta charset="utf-8"; meta charset="utf-8";
title { (self.title) } title { (self.title) }
// TODO: vendor this before going to prod
script src="https://unpkg.com/htmx.org@1.9.5" integrity="sha384-xcuj3WpfgjlKF+FXhSQFQ0ZNr39ln+hwjN3npfM9VBnUskLolQAcN80McRIVOPuO" crossorigin="anonymous" {}
script src="https://unpkg.com/htmx.org/dist/ext/sse.js" {}
@for js_bundle in js_bundles() { @for js_bundle in js_bundles() {
script type="module" src=(js_bundle) {} script type="module" src=(js_bundle) {}
} }