Oliver/internet_mapper
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

logging improvements

Browse Source
This commit is contained in:
Rushmore75 2025-03-18 15:25:56 -06:00
parent d11e7dd27c
commit e3e4175f51
4 changed files with 9 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/db.rs
View File

@ -87,9 +87,9 @@ impl Website {
} }
} }
#[instrument(skip_all)] #[instrument(name = "surql_store", skip_all)]
pub async fn store(&self, db: &Surreal<Client>) -> Option<Thing> { pub async fn store(&self, db: &Surreal<Client>) -> Option<Thing> {
let t = Timer::start("Stored page"); let t = Timer::start("Stored link");
let _ = t; let _ = t;
// check if it's been gone thru before // check if it's been gone thru before
let mut response = db let mut response = db

4
src/main.rs
View File

@ -53,8 +53,8 @@ async fn main() {
surreal_username: "root", surreal_username: "root",
surreal_password: "root", surreal_password: "root",
surreal_ns: "test", surreal_ns: "test",
surreal_db: "v1.11.2", surreal_db: "v1.12",
s3_bucket: "v1.11.2", s3_bucket: "v1.12",
s3_url: "http://localhost:9000", s3_url: "http://localhost:9000",
s3_access_key: "8UO76z8wCs9DnpxSbQUY", s3_access_key: "8UO76z8wCs9DnpxSbQUY",
s3_secret_key: "xwKVMpf2jzgprsdo85Dvo74UmO84y0aRrAUorYY5", s3_secret_key: "xwKVMpf2jzgprsdo85Dvo74UmO84y0aRrAUorYY5",

6
src/s3.rs
View File

@ -10,7 +10,7 @@ use minio::s3::{
use tracing::{instrument, trace, warn}; use tracing::{instrument, trace, warn};
use url::Url; use url::Url;
use crate::Config; use crate::{Config, Timer};
const CUSTOM_ENGINE: engine::GeneralPurpose = engine::GeneralPurpose::new(&alphabet::URL_SAFE, general_purpose::NO_PAD); const CUSTOM_ENGINE: engine::GeneralPurpose = engine::GeneralPurpose::new(&alphabet::URL_SAFE, general_purpose::NO_PAD);
@ -60,8 +60,10 @@ impl S3 {
}) })
} }
#[instrument(skip_all)] #[instrument(name = "s3_store", skip_all)]
pub async fn store(&self, data: &str, url: &Url) { pub async fn store(&self, data: &str, url: &Url) {
let t = Timer::start("Stored page");
let _ = t; // prevent compiler drop
if let Some(domain) = url.domain() { if let Some(domain) = url.domain() {
let filename = domain.to_owned() + url.path(); let filename = domain.to_owned() + url.path();

1
src/setup.surql
View File

@ -1,2 +1,3 @@
DEFINE TABLE IF NOT EXISTS website SCHEMALESS; DEFINE TABLE IF NOT EXISTS website SCHEMALESS;
DEFINE FIELD IF NOT EXISTS accessed_at ON TABLE website VALUE time::now(); DEFINE FIELD IF NOT EXISTS accessed_at ON TABLE website VALUE time::now();
DEFINE INDEX IF NOT EXISTS idx ON TABLE website COLUMNS site UNIQUE;