Update version number

Bump openssl from 0.10.64 to 0.10.66

Cargo.toml

@@ -1,16 +1,16 @@
 [package]
 name = "ics-proxy"
-version = "0.1.2"
+version = "0.1.6"
 edition = "2021"
 
 # See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
 
 [dependencies]
-actix-web = "4.0"
+actix-web = "4.8"
-uuid = { version = "1.0", features = ["v4"] }
+uuid = { version = "1.10", features = ["v4"] }
-url = "2.2"
+url = "2.5"
-reqwest = { version = "0.11", features = ["blocking"] }
+reqwest = { version = "0.12", features = ["blocking"] }
-tera = "1.15"
+tera = "1.20"
 dotenv = "0.15"
-
+sqlx = { version = "0.8", features = ["sqlite", "any", "tls-rustls", "runtime-tokio"] }
-sqlx = { version = "0.5", features = [ "sqlite", "runtime-actix-rustls" ] }
+chrono = "0.4.38"

Dockerfile

@@ -1,8 +1,10 @@
-FROM rust:1.72 as builder
+FROM rust:1.77 as builder
 RUN apt-get update && apt-get install -y sqlite3 && rm -rf /var/lib/apt/lists/*
+RUN cargo install sqlx-cli
 WORKDIR /usr/src/ics-proxy
 COPY . .
-RUN cd db && ./create_db.sh
+RUN sqlx database create
+RUN sqlx migrate run
 RUN cargo install --path .
 
 FROM debian:stable-slim

migrations/20240425185919_inital_db_scheme.sql

@@ -1,4 +1,5 @@
+-- Add migration script here
 CREATE TABLE IF NOT EXISTS LINKS(
     UUID TEXT NOT NULL PRIMARY KEY,
     DESTINATION TEXT NOT NULL
-);
+);

migrations/20240425193610_add_last_used_column.sql

@@ -0,0 +1,2 @@
+-- Add migration script here
+ALTER TABLE LINKS ADD COLUMN last_used TEXT;

src/main.rs

@@ -5,15 +5,17 @@ use actix_web::http::StatusCode;
 use actix_web::web::Data;
 use actix_web::{error, web, App, Error, HttpRequest, HttpResponse, HttpServer, Responder, Result};
 use sqlx::{Pool, Sqlite, SqlitePool};
+use std::time::SystemTime;
 use tera::Tera;
 use uuid::Uuid;
-
 extern crate dotenv;
+use actix_web::middleware::Logger;
 use dotenv::dotenv;
-
 mod model;
-use model::Link;
+use chrono::DateTime;
 
+use chrono::Utc;
+use model::Link;
 const REDIRECT_TIMEOUT_S: i32 = 2;
 
 #[derive(Clone)]
@@ -23,7 +25,8 @@ struct Config {
 
 async fn make_ics_request(req: HttpRequest, db_pool: web::Data<Pool<Sqlite>>) -> impl Responder {
     let id = req.match_info().get("id").unwrap_or("");
-
+    let now = <SystemTime as Into<DateTime<Utc>>>::into(SystemTime::now()).to_rfc3339();
+    println!("{now} serving ics request");
     match Uuid::parse_str(id) {
         Ok(uuid) => match Link::find_by_uuid(uuid.to_string(), db_pool).await {
             Ok(link) => match reqwest::get(link.destination).await {
@@ -60,6 +63,8 @@ async fn edit_page(
     db_pool: web::Data<Pool<Sqlite>>,
     conf: web::Data<Config>,
 ) -> Result<HttpResponse, Error> {
+    let now = <SystemTime as Into<DateTime<Utc>>>::into(SystemTime::now()).to_rfc3339();
+    println!("{now} serving edit page");
     // one uuid: 9228c1a4-8956-4f1c-8b5f-53cc575bd78
     if let Some(uuid_str) = query.get("uuid") {
         match Uuid::parse_str(uuid_str) {
@@ -257,7 +262,8 @@ async fn index_process(
 // store tera template in application state
 async fn index(tmpl: web::Data<tera::Tera>) -> Result<HttpResponse, Error> {
     // TODO: add option to prefill link with parameter
-
+    let now = <SystemTime as Into<DateTime<Utc>>>::into(SystemTime::now()).to_rfc3339();
+    println!("{now} serving index page");
     let s = tmpl
         .render("index.html", &tera::Context::new())
         .map_err(|_| error::ErrorInternalServerError("Template error"))?;
@@ -292,6 +298,8 @@ async fn main() -> std::io::Result<()> {
         .await
         .expect("could not create db pool");
 
+    sqlx::migrate!("./migrations").run(&db_pool).await.unwrap();
+
     println!(
         "Listening on: {}://{}, open browser and visit have a try!",
         protocol, base_url
@@ -300,6 +308,7 @@ async fn main() -> std::io::Result<()> {
         let tera = Tera::new("templates/**/*.html").unwrap();
 
         App::new()
+            .wrap(Logger::new("%a %{User-Agent}i"))
             .app_data(Data::new(db_pool.clone())) // pass database pool to application so we can access it inside handlers
             .app_data(Data::new(tera))
             .app_data(Data::new(conf.clone()))

src/model.rs

@@ -1,5 +1,8 @@
 use actix_web::web;
+use chrono::DateTime;
+use chrono::Utc;
 use sqlx::{Pool, Sqlite};
+use std::time::SystemTime;
 
 // Change to strings if to much headache
 pub struct Link {
@@ -12,16 +15,27 @@ impl Link {
         uuid: String,
         pool: web::Data<Pool<Sqlite>>,
     ) -> Result<Link, sqlx::Error> {
+        let now = <SystemTime as Into<DateTime<Utc>>>::into(SystemTime::now()).to_rfc3339();
         let mut tx = pool.begin().await?;
+        println!("{now} find by uuid {uuid}");
         let rec = sqlx::query!(
             r#"
                     SELECT * FROM links WHERE uuid = $1
                 "#,
             uuid
         )
-        .fetch_one(&mut tx)
+        .fetch_one(&mut *tx)
         .await?;
 
+        sqlx::query!(
+            r#" UPDATE links SET last_used = $1 WHERE uuid = $2"#,
+            now,
+            uuid,
+        )
+        .execute(&mut *tx)
+        .await?;
+        tx.commit().await?;
+
         Ok(Link {
             uuid: rec.UUID,
             destination: rec.DESTINATION,
@@ -32,9 +46,10 @@ impl Link {
         sqlx::query("UPDATE links SET destination = $2 WHERE uuid = $1;")
             .bind(&link.uuid)
             .bind(&link.destination)
-            .execute(&mut tx)
+            .execute(&mut *tx)
             .await?;
-
+        let now = <SystemTime as Into<DateTime<Utc>>>::into(SystemTime::now()).to_rfc3339();
+        println!("{} update uuid {}", now, link.uuid);
         tx.commit().await?;
         Ok(link)
     }
@@ -43,9 +58,10 @@ impl Link {
         sqlx::query("INSERT INTO links (uuid, destination) VALUES ($1, $2);")
             .bind(&link.uuid)
             .bind(&link.destination)
-            .execute(&mut tx)
+            .execute(&mut *tx)
             .await?;
-
+        let now = <SystemTime as Into<DateTime<Utc>>>::into(SystemTime::now()).to_rfc3339();
+        println!("{} create uuid {}", now, link.uuid);
         tx.commit().await?;
         Ok(link)
     }