Organize commands under tags

MyApp.ServiceInterface/AiServer/CreateAnswerCommentTaskCommand.cs

@@ -5,6 +5,7 @@
 
 namespace MyApp.ServiceInterface.AiServer;
 
+[Tag(Tags.AI)]
 public class CreateAnswerCommentTaskCommand(AppConfig appConfig) : IAsyncCommand<CreateAnswerCommentTask>
 {
     public const string SystemPrompt = 

MyApp.ServiceInterface/AiServer/CreateAnswerTasksCommand.cs

@@ -6,6 +6,7 @@
 
 namespace MyApp.ServiceInterface.AiServer;
 
+[Tag(Tags.AI)]
 public class CreateAnswerTasksCommand(ILogger<CreateAnswerTasksCommand> log, 
     AppConfig appConfig, QuestionsProvider questions) : IAsyncCommand<CreateAnswerTasks>
 {

MyApp.ServiceInterface/AiServer/CreateRankAnswerTaskCommand.cs

@@ -4,6 +4,7 @@
 
 namespace MyApp.ServiceInterface.AiServer;
 
+[Tag(Tags.AI)]
 public class CreateRankAnswerTaskCommand(AppConfig appConfig, QuestionsProvider questions) : IAsyncCommand<CreateRankAnswerTask>
 {
     //https://github.com/f/awesome-chatgpt-prompts?tab=readme-ov-file#act-as-a-tech-reviewer

MyApp.ServiceInterface/App/AnswerAddedToPostCommand.cs

@@ -6,6 +6,7 @@
 
 namespace MyApp.ServiceInterface.App;
 
+[Tag(Tags.Answers)]
 public class AnswerAddedToPostCommand(IDbConnection db) : IAsyncCommand<AnswerAddedToPost>
 {
     public async Task ExecuteAsync(AnswerAddedToPost request)

MyApp.ServiceInterface/App/AppDbPeriodicTasksCommand.cs

@@ -13,6 +13,7 @@
 
 namespace MyApp.ServiceInterface.App;
 
+[Tag(Tags.Database)]
 public class AppDbPeriodicTasksCommand(ILogger<AppDbPeriodicTasksCommand> log, 
     AppConfig appConfig, IDbConnectionFactory dbFactory, IMessageProducer mq, EmailRenderer renderer) 
     : IAsyncCommand<PeriodicTasks>

MyApp.ServiceInterface/App/CreateAnswerCommand.cs

@@ -6,6 +6,7 @@
 
 namespace MyApp.ServiceInterface.App;
 
+[Tag(Tags.Answers)]
 public class CreateAnswerCommand(AppConfig appConfig, IDbConnection db) : IAsyncCommand<Post>
 {
     public async Task ExecuteAsync(Post answer)

MyApp.ServiceInterface/App/CreateCommentVoteCommand.cs

@@ -6,6 +6,7 @@
 
 namespace MyApp.ServiceInterface.App;
 
+[Tag(Tags.Database)]
 public class CreateCommentVoteCommand(IDbConnection db, QuestionsProvider questions) : IAsyncCommand<Vote>
 {
     public async Task ExecuteAsync(Vote vote)

MyApp.ServiceInterface/App/CreateFlagCommand.cs

@@ -5,6 +5,7 @@
 
 namespace MyApp.ServiceInterface.App;
 
+[Tag(Tags.Database)]
 public class CreateFlagCommand(IDbConnection db) : IAsyncCommand<Flag>
 {
     public async Task ExecuteAsync(Flag request)

MyApp.ServiceInterface/App/CreateNotificationCommand.cs

@@ -6,6 +6,7 @@
 
 namespace MyApp.ServiceInterface.App;
 
+[Tag(Tags.Notifications)]
 public class CreateNotificationCommand(AppConfig appConfig, IDbConnection db) : IAsyncCommand<Notification>
 {
     public async Task ExecuteAsync(Notification request)

MyApp.ServiceInterface/App/CreatePostCommand.cs

@@ -7,6 +7,7 @@
 
 namespace MyApp.ServiceInterface.App;
 
+[Tag(Tags.Questions)]
 public class CreatePostCommand(ILogger<CreatePostCommand> log, AppConfig appConfig, IDbConnection db) : IAsyncCommand<Post>
 {
     public async Task ExecuteAsync(Post post)

MyApp.ServiceInterface/App/CreatePostVoteCommand.cs

@@ -7,6 +7,7 @@
 
 namespace MyApp.ServiceInterface.App;
 
+[Tag(Tags.Database)]
 public class CreatePostVoteCommand(AppConfig appConfig, IDbConnection db, IMessageProducer mqClient) : IAsyncCommand<Vote>
 {
     public async Task ExecuteAsync(Vote vote)

MyApp.ServiceInterface/App/DeleteAnswersCommand.cs

@@ -6,6 +6,7 @@
 
 namespace MyApp.ServiceInterface.App;
 
+[Tag(Tags.Answers)]
 public class DeleteAnswersCommand(IDbConnection db) : IAsyncCommand<DeleteAnswers>
 {
     public async Task ExecuteAsync(DeleteAnswers request)

MyApp.ServiceInterface/App/DeleteCommentCommand.cs

@@ -6,6 +6,7 @@
 
 namespace MyApp.ServiceInterface.App;
 
+[Tag(Tags.Database)]
 public class DeleteCommentCommand(AppConfig appConfig, IDbConnection db) : IAsyncCommand<DeleteComment>
 {
     public async Task ExecuteAsync(DeleteComment request)

MyApp.ServiceInterface/App/DeletePostsCommand.cs

@@ -6,6 +6,7 @@
 
 namespace MyApp.ServiceInterface.App;
 
+[Tag(Tags.Database)]
 public class DeletePostsCommand(AppConfig appConfig, IDbConnection db) : IAsyncCommand<DeletePosts>
 {
     public async Task ExecuteAsync(DeletePosts request)

MyApp.ServiceInterface/App/ImportQuestionCommand.cs

@@ -7,6 +7,7 @@
 
 namespace MyApp.ServiceInterface.App;
 
+[Tag(Tags.Questions)]
 public class ImportQuestionCommand(ILogger<ImportQuestionCommand> log, AppConfig appConfig) : IAsyncCommand<ImportQuestion>
 {
     static readonly Regex ValidTagCharsRegex = new("[^a-zA-Z0-9#+.]", RegexOptions.Compiled);

MyApp.ServiceInterface/App/MarkAsReadCommand.cs

@@ -6,6 +6,7 @@
 
 namespace MyApp.ServiceInterface.App;
 
+[Tag(Tags.Notifications)]
 public class MarkAsReadCommand(AppConfig appConfig, IDbConnection db) : IAsyncCommand<MarkAsRead>
 {
     public async Task ExecuteAsync(MarkAsRead request)

MyApp.ServiceInterface/App/MarkPostAsReadCommand.cs

@@ -6,6 +6,7 @@
 
 namespace MyApp.ServiceInterface.App;
 
+[Tag(Tags.Notifications)]
 public class MarkPostAsReadCommand(AppConfig appConfig, IDbConnection db, QuestionsProvider questions) : IAsyncCommand<MarkPostAsRead>
 {
     public async Task ExecuteAsync(MarkPostAsRead request)

MyApp.ServiceInterface/App/NewCommentCommand.cs

@@ -6,6 +6,7 @@
 
 namespace MyApp.ServiceInterface.App;
 
+[Tag(Tags.Database)]
 public class NewCommentCommand(AppConfig appConfig, IDbConnection db) : IAsyncCommand<NewComment>
 {
     public async Task ExecuteAsync(NewComment request)

MyApp.ServiceInterface/App/PostSubscriptionsCommand.cs

@@ -5,6 +5,7 @@
 
 namespace MyApp.ServiceInterface.App;
 
+[Tag(Tags.Notifications)]
 public class PostSubscriptionsCommand(IDbConnection db) : IAsyncCommand<PostSubscriptions>
 {
     public async Task ExecuteAsync(PostSubscriptions request)

MyApp.ServiceInterface/App/SaveGradeResultCommand.cs

@@ -7,6 +7,7 @@
 
 namespace MyApp.ServiceInterface.App;
 
+[Tag(Tags.Answers)]
 public class SaveGradeResultCommand(AppConfig appConfig, IDbConnection db, IMessageProducer mq, WorkerAnswerNotifier answerNotifier) 
     : IAsyncCommand<StatTotals>
 {

MyApp.ServiceInterface/App/TagSubscriptionsCommand.cs

@@ -5,6 +5,7 @@
 
 namespace MyApp.ServiceInterface.App;
 
+[Tag(Tags.Notifications)]
 public class TagSubscriptionsCommand(IDbConnection db) : IAsyncCommand<TagSubscriptions>
 {
     public async Task ExecuteAsync(TagSubscriptions request)

MyApp.ServiceInterface/App/UpdatePostCommand.cs

@@ -5,6 +5,7 @@
 
 namespace MyApp.ServiceInterface.App;
 
+[Tag(Tags.Questions)]
 public class UpdatePostCommand(IDbConnection db) : IAsyncCommand<Post>
 {
     public async Task ExecuteAsync(Post question)

MyApp.ServiceInterface/App/UpdateReputationsCommand.cs

@@ -4,6 +4,7 @@
 
 namespace MyApp.ServiceInterface.App;
 
+[Tag(Tags.Notifications)]
 public class UpdateReputationsCommand(AppConfig appConfig, IDbConnection db) : IAsyncCommand<UpdateReputations>
 {
     public async Task ExecuteAsync(UpdateReputations request)

MyApp.ServiceInterface/CreatorKit/SendMailRunCommand.cs

@@ -9,6 +9,7 @@
 
 namespace MyApp.ServiceInterface.CreatorKit;
 
+[Tag(Tags.CreatorKit)]
 public class SendMailRunCommand(
     ILogger<SendMailRunCommand> log,
     IDbConnectionFactory dbFactory,

MyApp.ServiceInterface/CreatorKit/SendMessagesCommand.cs

@@ -1,12 +1,14 @@
 using CreatorKit.ServiceModel.Types;
 using MyApp.Data;
+using MyApp.ServiceInterface;
 using MyApp.ServiceModel;
 using ServiceStack;
 using ServiceStack.Data;
 using ServiceStack.OrmLite;
 
 namespace CreatorKit.ServiceInterface;
 
+[Tag(Tags.CreatorKit)]
 public class SendMessagesCommand(IDbConnectionFactory dbFactory, EmailProvider emailProvider) : IAsyncCommand<SendMailMessages>
 {
     public async Task ExecuteAsync(SendMailMessages request)

MyApp.ServiceInterface/Data/Tasks.cs

@@ -1,6 +1,7 @@
 using MyApp.ServiceInterface;
 using MyApp.ServiceInterface.AiServer;
 using MyApp.ServiceInterface.App;
+using MyApp.ServiceInterface.Jobs;
 using MyApp.ServiceModel;
 using ServiceStack;
 using ServiceStack.DataAnnotations;

MyApp.ServiceInterface/App/CompletePostJobsCommand.cs → MyApp.ServiceInterface/Jobs/CompletePostJobsCommand.cs

@@ -1,28 +1,29 @@
 using System.Data;
+using MyApp.Data;
+using MyApp.ServiceModel;
 using ServiceStack;
 using ServiceStack.Messaging;
 using ServiceStack.OrmLite;
-using MyApp.Data;
-using MyApp.ServiceModel;
 
-namespace MyApp.ServiceInterface.App;
+namespace MyApp.ServiceInterface.Jobs;
 
-public class CompletePostJobsCommand(IDbConnection Db, ModelWorkerQueue modelWorkers, IMessageProducer mqClient) : IAsyncCommand<CompletePostJobs>
+[Tag(Tags.Jobs)]
+public class CompletePostJobsCommand(IDbConnection db, ModelWorkerQueue modelWorkers, IMessageProducer mqClient) : IAsyncCommand<CompletePostJobs>
 {
     public async Task ExecuteAsync(CompletePostJobs request)
     {
         var jobIds = request.Ids;
-        await Db.UpdateOnlyAsync(() => new PostJob {
+        await db.UpdateOnlyAsync(() => new PostJob {
                 CompletedDate = DateTime.UtcNow,
             }, 
             x => jobIds.Contains(x.Id));
-        var postJobs = await Db.SelectAsync(Db.From<PostJob>()
+        var postJobs = await db.SelectAsync(db.From<PostJob>()
             .Where(x => jobIds.Contains(x.Id)));
 
         foreach (var postJob in postJobs)
         {
             // If there's no outstanding model answer jobs for this post, add a rank job
-            if (!await Db.ExistsAsync(Db.From<PostJob>()
+            if (!await db.ExistsAsync(db.From<PostJob>()
                     .Where(x => x.PostId == postJob.PostId && x.CompletedDate == null)))
             {
                 var rankJob = new PostJob
@@ -33,7 +34,7 @@ public async Task ExecuteAsync(CompletePostJobs request)
                     CreatedDate = DateTime.UtcNow,
                     CreatedBy = nameof(DbWrites),
                 };
-                await Db.InsertAsync(rankJob);
+                await db.InsertAsync(rankJob);
                 modelWorkers.Enqueue(rankJob);
                 mqClient.Publish(new SearchTasks { AddPostToIndex = postJob.PostId });
             }

MyApp.ServiceInterface/App/CreatePostJobsCommand.cs → MyApp.ServiceInterface/Jobs/CreatePostJobsCommand.cs

@@ -1,10 +1,11 @@
 using System.Data;
+using MyApp.Data;
 using ServiceStack;
 using ServiceStack.OrmLite;
-using MyApp.Data;
 
-namespace MyApp.ServiceInterface.App;
+namespace MyApp.ServiceInterface.Jobs;
 
+[Tag(Tags.Jobs)]
 public class CreatePostJobsCommand(IDbConnection db, ModelWorkerQueue modelWorkers) : IAsyncCommand<CreatePostJobs>
 {
     public async Task ExecuteAsync(CreatePostJobs request)

MyApp.ServiceInterface/App/FailJobCommand.cs → MyApp.ServiceInterface/Jobs/FailJobCommand.cs

@@ -1,11 +1,12 @@
 using System.Data;
-using ServiceStack;
-using ServiceStack.OrmLite;
 using MyApp.Data;
 using MyApp.ServiceModel;
+using ServiceStack;
+using ServiceStack.OrmLite;
 
-namespace MyApp.ServiceInterface.App;
+namespace MyApp.ServiceInterface.Jobs;
 
+[Tag(Tags.Jobs)]
 public class FailJobCommand(IDbConnection db, ModelWorkerQueue modelWorkers) : IAsyncCommand<FailJob>
 {
     public async Task ExecuteAsync(FailJob request)

MyApp.ServiceInterface/App/StartJobCommand.cs → MyApp.ServiceInterface/Jobs/StartJobCommand.cs

@@ -1,11 +1,12 @@
 using System.Data;
-using ServiceStack;
-using ServiceStack.OrmLite;
 using MyApp.Data;
 using MyApp.ServiceModel;
+using ServiceStack;
+using ServiceStack.OrmLite;
 
-namespace MyApp.ServiceInterface.App;
+namespace MyApp.ServiceInterface.Jobs;
 
+[Tag(Tags.Jobs)]
 public class StartJobCommand(IDbConnection db) : IAsyncCommand<StartJob>
 {
     public async Task ExecuteAsync(StartJob job)

MyApp.ServiceInterface/Renderers/RegenerateMetaCommand.cs

@@ -9,6 +9,7 @@
 
 namespace MyApp.ServiceInterface.Renderers;
 
+[Tag(Tags.Renderer)]
 public class RegenerateMetaCommand(
     ILogger<RegenerateMetaCommand> log,
     IDbConnectionFactory dbFactory,

MyApp.ServiceInterface/Tags.cs

@@ -0,0 +1,13 @@
+namespace MyApp.ServiceInterface;
+
+public class Tags
+{
+    public const string Database = nameof(Database);
+    public const string Questions = nameof(Questions);
+    public const string Answers = nameof(Answers);
+    public const string Notifications = nameof(Notifications);
+    public const string Jobs = nameof(Jobs);
+    public const string CreatorKit = nameof(CreatorKit);
+    public const string AI = nameof(AI);
+    public const string Renderer = nameof(Renderer);
+}

MyApp.Tests/Top1KQuestionTasks.cs

@@ -114,6 +114,22 @@ public async Task Recreate_answers_for_Top1K_questions_for_gemini_pro_15()
         apiCreate.Response!.Results.PrintDump();;
     }
 
+    [Test]
+    public async Task Recreate_answers_for_Top1K_questions_for_gemini_flash()
+    {
+        var client = await TestUtils.CreateAuthenticatedProdClientAsync();
+        var apiCreate = await client.ApiAsync(new CreateAnswersForModels
+        {
+            Models = ["gemini-flash"],
+            PostIds = Migration1005.Top1KIds,
+        });
+
+        apiCreate.Error.PrintDump();
+        apiCreate.ThrowIfError();
+        apiCreate.Response!.Errors.PrintDump();
+        apiCreate.Response!.Results.PrintDump();;
+    }
+
     [Test]
     public async Task Find_answers_that_have_not_been_individually_graded()
     {
@@ -176,4 +192,29 @@ public async Task Create_Gemini_Pro_15_User()
         api.Response.PrintDump();
         api.ThrowIfError();
     }
+
+    [Test]
+    public async Task Generate_top_10k_answers_for_gemini_flash()
+    {
+        var txt = await File.ReadAllTextAsync(TestUtils.GetHostDir().CombineWith("App_Data/top10k-6.txt"));
+        var ids = new List<int>();
+        foreach (var line in txt.ReadLines())
+        {
+            ids.Add(int.Parse(line.Trim()));
+        }
+
+        var client = await TestUtils.CreateAuthenticatedProdClientAsync();
+        // client.GetHttpClient().Timeout = TimeSpan.FromMinutes(5);
+        var apiCreate = await client.ApiAsync(new CreateAnswersForModels
+        {
+            // Models = ["gemini-flash","gemini-pro-1.5"],
+            Models = ["gemini-flash"],
+            PostIds = ids,
+        });
+
+        apiCreate.Error.PrintDump();
+        apiCreate.ThrowIfError();
+        apiCreate.Response!.Errors.PrintDump();
+        apiCreate.Response!.Results.PrintDump();;
+    }
 }

MyApp/Configure.Renderer.cs

@@ -52,6 +52,7 @@ protected override void NavigateToCore(string uri, bool forceLoad)
     }
 }
 
+[Tag(Tags.Renderer)]
 public class RenderQuestionPostCommand(BlazorRenderer renderer, RendererCache cache) : IAsyncCommand<QuestionAndAnswers>
 {
     public async Task ExecuteAsync(QuestionAndAnswers request)
@@ -61,6 +62,7 @@ public async Task ExecuteAsync(QuestionAndAnswers request)
     }
 }
 
+[Tag(Tags.Renderer)]
 public class RenderHomeTabCommand(BlazorRenderer renderer, RendererCache cache) : IAsyncCommand<RenderHome>
 {
     public async Task ExecuteAsync(RenderHome request)