Better account verification.

migrations/20240530173905_better_verification.down.sql

@@ -0,0 +1,2 @@
+ALTER TABLE
+    linked_account DROP COLUMN verification_key, DROP COLUMN verified_at;

migrations/20240530173905_better_verification.up.sql

@@ -0,0 +1,22 @@
+ALTER TABLE
+    linked_account
+ADD
+    COLUMN created_at TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT current_timestamp,
+ADD
+    COLUMN verification_key TEXT,
+ADD
+    COLUMN verified_at TIMESTAMP WITH TIME ZONE;
+
+UPDATE
+    linked_account
+SET
+    verified_at = current_timestamp
+WHERE
+    linked_account.data->'verification_key' IS NULL;
+
+UPDATE
+    linked_account
+SET
+    verification_key = linked_account.data->>'verification_key'
+WHERE
+    linked_account.data->'verification_key' IS NOT NULL;

queries/linked_account/create.sql

@@ -3,7 +3,9 @@ INSERT INTO
         owner_id,
         source_site,
         username,
-        data
+        data,
+        verification_key,
+        verified_at
     )
 VALUES
-    ($1, $2, $3, $4) RETURNING *;
+    ($1, $2, $3, $4, $5, $6) RETURNING *;

queries/linked_account/verify.sql

@@ -0,0 +1,7 @@
+UPDATE
+    linked_account
+SET
+    verification_key = NULL,
+    verified_at = current_timestamp
+WHERE
+    id = $1;

src/jobs.rs

@@ -684,7 +684,7 @@ pub async fn start_job_processing(ctx: JobContext) -> Result<(), Error> {
                 .await?
                 .ok_or(Error::Missing)?;
 
-            let key = match account.verification_key() {
+            let key = match account.verification_key {
                 Some(key) => key,
                 None => return Err(Error::Missing),
             };
@@ -718,10 +718,10 @@ pub async fn start_job_processing(ctx: JobContext) -> Result<(), Error> {
                         .map(|elem| elem.text().collect::<String>())
                         .unwrap_or_default();
 
-                    let verifier_found = text.contains(key);
+                    let verifier_found = text.contains(&key);
 
                     if verifier_found {
-                        models::LinkedAccount::update_data(&ctx.conn, account.id, None).await?;
+                        models::LinkedAccount::verify(&ctx.conn, account.id).await?;
                     }
 
                     verifier_found
@@ -745,10 +745,10 @@ pub async fn start_job_processing(ctx: JobContext) -> Result<(), Error> {
                         .and_then(|profile_text| profile_text.as_str())
                         .ok_or_else(|| Error::unknown_message("Weasyl was missing profile text"))?;
 
-                    let verifier_found = profile_text.contains(key);
+                    let verifier_found = profile_text.contains(&key);
 
                     if verifier_found {
-                        models::LinkedAccount::update_data(&ctx.conn, account.id, None).await?;
+                        models::LinkedAccount::verify(&ctx.conn, account.id).await?;
                     }
 
                     verifier_found