feat: save reddit post title

Author: kyleratti

ApplicationData/Services/LinkProvider.cs

@@ -164,7 +164,13 @@ SELECT 1 FROM links
 		if (existingLink is true)
 			return Result<int, CreateLinkError>.CreateFailure(new LinkAlreadyExists());
 
-		using var tx = await connection.CreateTransaction(IsolationLevel.Serializable, CancellationToken.None);
+		await using var tx = await connection.CreateTransaction(IsolationLevel.Serializable, CancellationToken.None);
+
+		await tx.Execute("""
+			INSERT INTO reddit_posts (reddit_post_id, post_title)
+			VALUES (@redditPostId, @postTitle)
+			ON CONFLICT DO NOTHING
+			""", new { link.RedditPostId, postTitle = link.RedditPostTitle });
 
 		var linkIdResult = await tx.ExecuteScalar<int?>("""
 			INSERT INTO links (reddit_post_id, link_url, link_type, created_at, is_deleted, owner)

DataClasses/DbModels.fs

@@ -36,6 +36,7 @@ type Link = {
 
 type NewLink = {
     RedditPostId : string
+    RedditPostTitle : string
     LinkUrl : string
     LinkType : LinkKind
     OwnerUserId : int32
@@ -46,4 +47,4 @@ type NewUser = {
     DeveloperUsername : string
     Weight : int32 option
     IsAdministrator : bool
-}
+}

WebApi/Controllers/LinkController.cs

@@ -69,6 +69,7 @@ public async Task<IActionResult> SubmitLink([FromBody] SubmitLinkRequest linkReq
 			async () =>
 				await _linkProvider.CreateLink(new NewLink(
 					redditPostId: linkRequest.RedditPostId,
+					redditPostTitle: submission.Title,
 					linkUrl: validUrl.OriginalString,
 					linkKind,
 					ownerUserId: loggedInUserId

WebApi/Scripts/Script_2024_08_24_01_CreateRedditPostsTable.cs

@@ -0,0 +1,30 @@
+using FruityFoundation.DataAccess.Abstractions;
+
+namespace WebApi.Scripts;
+
+/// <summary>
+/// Create reddit posts table
+/// </summary>
+public class Script_2024_08_24_01_CreateRedditPostsTable : IDbMaintenanceScript
+{
+	/// <inheritdoc />
+	public async Task Run(IDatabaseConnection<ReadWrite> dbConnection)
+	{
+		var tableExists = await dbConnection.ExecuteScalar<bool>(
+			"SELECT EXISTS (SELECT 1 FROM sqlite_master WHERE type='table' AND name = 'reddit_posts')");
+
+		if (tableExists)
+			return;
+
+		await dbConnection.Execute(
+			"""
+				create table reddit_posts
+				(
+				   reddit_post_id TEXT not null
+				       constraint PK_reddit_posts_reddit_post_id
+				           primary key,
+				   post_title     TEXT null -- nullable for now because we have several thousand existing rows. tomorrow's problem.
+				);
+				""");
+	}
+}

WebApi/Scripts/Script_2024_08_24_02_PopulateRedditPostIds.cs

@@ -0,0 +1,25 @@
+using FruityFoundation.DataAccess.Abstractions;
+
+namespace WebApi.Scripts;
+
+/// <summary>
+/// Add foreign key to reddit posts
+/// </summary>
+public class Script_2024_08_24_02_PopulateRedditPostIds : IDbMaintenanceScript
+{
+	/// <inheritdoc />
+	public async Task Run(IDatabaseConnection<ReadWrite> dbConnection)
+	{
+		await dbConnection.Execute(
+			"""
+				INSERT INTO reddit_posts (reddit_post_id, post_title)
+				SELECT rc.reddit_post_id, NULL
+				FROM reddit_comments rc
+				WHERE NOT EXISTS (
+					SELECT 1
+					FROM reddit_posts rp
+					WHERE rp.reddit_post_id = rc.reddit_post_id
+				)
+				""");
+	}
+}

WebApi/Scripts/Script_2024_08_24_03_AddForeignKeyToRedditPosts.cs

@@ -0,0 +1,43 @@
+using FruityFoundation.DataAccess.Abstractions;
+
+namespace WebApi.Scripts;
+
+/// <summary>
+/// Add foreign key to reddit posts
+/// </summary>
+public class Script_2024_08_24_03_AddForeignKeyToRedditPosts : IDbMaintenanceScript
+{
+	/// <inheritdoc />
+	public async Task Run(IDatabaseConnection<ReadWrite> dbConnection)
+	{
+		var foreignKeyExists = await dbConnection.ExecuteScalar<bool>(
+			"SELECT EXISTS (SELECT 1 FROM pragma_foreign_key_list('reddit_comments') WHERE \"table\" = 'reddit_posts' AND \"from\" = 'reddit_post_id')");
+
+		if (foreignKeyExists)
+			return;
+
+		await dbConnection.Execute(
+			"""
+				create table reddit_comments_dg_tmp
+				(
+				    reddit_post_id    TEXT not null
+				        constraint PK_RedditComments_RedditPostId
+				            primary key
+				        constraint FK_reddit_comments_reddit_posts_reddit_post_id
+				            references reddit_posts,
+				    reddit_comment_id TEXT not null,
+				    posted_at         TEXT not null,
+				    last_updated_at   TEXT not null
+				);
+				
+				insert into reddit_comments_dg_tmp(reddit_post_id, reddit_comment_id, posted_at, last_updated_at)
+				select reddit_post_id, reddit_comment_id, posted_at, last_updated_at
+				from reddit_comments;
+				
+				drop table reddit_comments;
+				
+				alter table reddit_comments_dg_tmp
+				    rename to reddit_comments;
+				""");
+	}
+}