Adding rowId to StoreRecords Entity and table

juanfranblanco · juanfranblanco · commit f8602913a48c · 2024-09-26T18:19:36.000+01:00
diff --git a/src/Nethereum.Mud.Repositories.EntityFramework/BlockProgressRepository.cs b/src/Nethereum.Mud.Repositories.EntityFramework/BlockProgressRepository.cs
@@ -38,7 +38,7 @@ public async Task UpsertProgressAsync(BigInteger blockNumber)
             catch (DbUpdateException ex) when (ex.InnerException?.Message.Contains("String or binary data would be truncated") ?? false)
             {
                 throw new DbUpdateException(
-                    $"{nameof(BlockProgressRepository<TDbContext>)} Data Truncation Rrror. Ensure that the LastBlockProcessed column length is {ColumnLengths.BigIntegerLength}."
+                    $"{nameof(BlockProgressRepository<TDbContext>)} Data Truncation Error. Ensure that the LastBlockProcessed column length is {ColumnLengths.BigIntegerLength}."
                     , ex);
             }
         }
diff --git a/src/Nethereum.Mud.Repositories.Postgres/MudPostgresStoreRecordsDbContext.cs b/src/Nethereum.Mud.Repositories.Postgres/MudPostgresStoreRecordsDbContext.cs
@@ -4,6 +4,8 @@
 using Microsoft.Extensions.Configuration;
 using Nethereum.BlockchainProcessing.BlockStorage.Entities;
 using Nethereum.Mud.Repositories.EntityFramework;
+using System.Collections.Generic;
+using System.Threading.Tasks;
 
 namespace Nethereum.Mud.Repositories.Postgres
 {
@@ -17,10 +19,12 @@ public MudPostgresStoreRecordsDbContext()
         public MudPostgresStoreRecordsDbContext(DbContextOptions<MudPostgresStoreRecordsDbContext> options)
            : base(options) { 
         
-            
+           
         
         }
-       
+
+        
+
         protected override void OnConfiguring(DbContextOptionsBuilder optionsBuilder)
         {
             if (!optionsBuilder.IsConfigured)
@@ -36,6 +40,14 @@ protected override void OnModelCreating(ModelBuilder modelBuilder)
 
             modelBuilder.Entity<BlockProgress>().HasKey(r => r.RowIndex);
 
+            modelBuilder.Entity<StoredRecord>()
+                    .Property(e => e.RowId)
+                        .ValueGeneratedOnAdd();
+
+            modelBuilder.Entity<StoredRecord>()
+                .HasIndex(r => new { r.RowId })
+                .HasDatabaseName("IX_RowId");
+
             // Set primary key based on Address, TableId, and Key
             modelBuilder.Entity<StoredRecord>()
                 .HasKey(r => new { r.AddressBytes, r.TableIdBytes, r.KeyBytes });
diff --git a/src/Nethereum.Mud.Repositories.Postgres/MudPostgresStoreRecordsProcessingService.cs b/src/Nethereum.Mud.Repositories.Postgres/MudPostgresStoreRecordsProcessingService.cs
@@ -2,14 +2,14 @@
 using Nethereum.Web3;
 using System.Numerics;
 using Microsoft.Extensions.Logging;
-using Nethereum.Mud;
 using Nethereum.Mud.EncodingDecoding;
 using Nethereum.Mud.Repositories.EntityFramework;
 using System.Threading.Tasks;
 using System.Threading;
 
 namespace Nethereum.Mud.Repositories.Postgres
 {
+
     public class MudPostgresStoreRecordsProcessingService
     {
         public MudPostgresStoreRecordsProcessingService(MudPostgresStoreRecordsDbContext context, ILogger logger)
@@ -19,10 +19,10 @@ public MudPostgresStoreRecordsProcessingService(MudPostgresStoreRecordsDbContext
         }
 
         public MudPostgresStoreRecordsDbContext Context { get; }
-        public ILogger Logger { get; set;  }
+        public ILogger Logger { get; set; }
         public string Address { get; set; }
         public string RpcUrl { get; set; }
-        public BigInteger StartAtBlockNumberIfNotProcessed { get; set; }  = 0;
+        public BigInteger StartAtBlockNumberIfNotProcessed { get; set; } = 0;
         public int NumberOfBlocksToProcessPerRequest { get; set; } = 1000;
         public int RetryWeight { get; set; } = 50;
 
@@ -42,4 +42,8 @@ await processor.ExecuteAsync(
 
         }
     }
+
 }
+
+
+

Original file line number	Diff line number	Diff line change
`@@ -38,7 +38,7 @@ public async Task UpsertProgressAsync(BigInteger blockNumber)`
`38`	`38`	`catch (DbUpdateException ex) when (ex.InnerException?.Message.Contains("String or binary data would be truncated") ?? false)`
`39`	`39`	`{`
`40`	`40`	`throw new DbUpdateException(`
`41`		`- $"{nameof(BlockProgressRepository<TDbContext>)} Data Truncation Rrror. Ensure that the LastBlockProcessed column length is {ColumnLengths.BigIntegerLength}."`
	`41`	`+ $"{nameof(BlockProgressRepository<TDbContext>)} Data Truncation Error. Ensure that the LastBlockProcessed column length is {ColumnLengths.BigIntegerLength}."`
`42`	`42`	`, ex);`
`43`	`43`	`}`
`44`	`44`	`}`
Original file line number	Diff line number	Diff line change
`@@ -2,14 +2,14 @@`
`2`	`2`	`using Nethereum.Web3;`
`3`	`3`	`using System.Numerics;`
`4`	`4`	`using Microsoft.Extensions.Logging;`
`5`		`-using Nethereum.Mud;`
`6`	`5`	`using Nethereum.Mud.EncodingDecoding;`
`7`	`6`	`using Nethereum.Mud.Repositories.EntityFramework;`
`8`	`7`	`using System.Threading.Tasks;`
`9`	`8`	`using System.Threading;`
`10`	`9`
`11`	`10`	`namespace Nethereum.Mud.Repositories.Postgres`
`12`	`11`	`{`
	`12`	`+`
`13`	`13`	`public class MudPostgresStoreRecordsProcessingService`
`14`	`14`	`{`
`15`	`15`	`public MudPostgresStoreRecordsProcessingService(MudPostgresStoreRecordsDbContext context, ILogger logger)`
`@@ -19,10 +19,10 @@ public MudPostgresStoreRecordsProcessingService(MudPostgresStoreRecordsDbContext`
`19`	`19`	`}`
`20`	`20`
`21`	`21`	`public MudPostgresStoreRecordsDbContext Context { get; }`
`22`		`- public ILogger Logger { get; set; }`
	`22`	`+ public ILogger Logger { get; set; }`
`23`	`23`	`public string Address { get; set; }`
`24`	`24`	`public string RpcUrl { get; set; }`
`25`		`- public BigInteger StartAtBlockNumberIfNotProcessed { get; set; } = 0;`
	`25`	`+ public BigInteger StartAtBlockNumberIfNotProcessed { get; set; } = 0;`
`26`	`26`	`public int NumberOfBlocksToProcessPerRequest { get; set; } = 1000;`
`27`	`27`	`public int RetryWeight { get; set; } = 50;`
`28`	`28`
`@@ -42,4 +42,8 @@ await processor.ExecuteAsync(`
`42`	`42`
`43`	`43`	`}`
`44`	`44`	`}`
	`45`	`+`
`45`	`46`	`}`
	`47`	`+`
	`48`	`+`
	`49`	`+`