Experiment with Eff runtime

src/Codehard.Functional/CodeHard.Function.FSharp.Tests.Types/CodeHard.Functional.FSharp.Tests.Types.fsproj

@@ -11,7 +11,7 @@
   </ItemGroup>
 
   <ItemGroup>
-    <PackageReference Include="LanguageExt.Core" Version="5.0.0-beta-24" />
+    <PackageReference Include="LanguageExt.Core" Version="5.0.0-beta-27" />
     <PackageReference Update="FSharp.Core" Version="8.0.400" />
   </ItemGroup>
 

src/Codehard.Functional/Codehard.Functional.AspNetCore/ControllerExtensions.cs

@@ -111,9 +111,10 @@ public static IActionResult RunToResult<T>(
     public static async Task<IActionResult> RunToResultAsync<T>(
         this Eff<T> eff,
         HttpStatusCode successStatusCode = HttpStatusCode.OK,
-        ILogger? logger = default)
+        ILogger? logger = default,
+        CancellationToken cancellationToken = default)
     {
-        var fin = await eff.RunAsync();
+        var fin = await eff.RunAsync(EnvIO.New(token: cancellationToken));
 
         return
             fin.MatchToResult(

src/Codehard.Functional/Codehard.Functional.EntityFramework.Tests/Codehard.Functional.EntityFramework.Tests.csproj

@@ -9,7 +9,7 @@
     </PropertyGroup>
 
     <ItemGroup>
-        <PackageReference Include="LanguageExt.Core" Version="5.0.0-beta-24" />
+        <PackageReference Include="LanguageExt.Core" Version="5.0.0-beta-27" />
         <PackageReference Include="Microsoft.CodeAnalysis" Version="4.8.0"/>
         <PackageReference Include="Microsoft.CodeAnalysis.Common" Version="4.8.0" />
         <PackageReference Include="Microsoft.CodeAnalysis.CSharp" Version="4.8.0" />

src/Codehard.Functional/Codehard.Functional.EntityFramework.Tests/QueryableExtensionsTests.cs

@@ -5,6 +5,7 @@
 
 using Codehard.Functional.EntityFramework.Tests.Entities;
 using Codehard.Infrastructure.EntityFramework.Extensions;
+using static Codehard.Functional.EntityFramework.Extensions.QueryablePrelude;
 
 namespace Codehard.Functional.EntityFramework.Tests;
 
@@ -18,7 +19,7 @@ private static SqliteConnection CreateInMemoryDatabase()
     }
 
     [Fact]
-    public async Task ToListEffRt_ShouldReturnList()
+    public async Task ToListEff_ShouldReturnList()
     {
         // Arrange
         var assembly = Assembly.GetExecutingAssembly();
@@ -29,6 +30,7 @@ public async Task ToListEffRt_ShouldReturnList()
         await using var context = new TestDbContext(
             options,
             builder => builder.ApplyConfigurationsFromAssemblyFor<TestDbContext>(assembly));
+
         await context.Database.EnsureCreatedAsync();
 
         var entityId = Guid.NewGuid();
@@ -56,4 +58,44 @@ public async Task ToListEffRt_ShouldReturnList()
         Assert.NotNull(resultEntity);
         Assert.Single(resultEntity);
     }
+
+    [Fact]
+    public async Task FilterRtAndToListEff_ShouldReturnList()
+    {
+        // Arrange
+        var assembly = Assembly.GetExecutingAssembly();
+        var options = new DbContextOptionsBuilder<TestDbContext>()
+            .UseSqlite(CreateInMemoryDatabase())
+            .Options;
+
+        await using var context = new TestDbContext(
+            options,
+            builder => builder.ApplyConfigurationsFromAssemblyFor<TestDbContext>(assembly));
+
+        await context.Database.EnsureCreatedAsync();
+
+        var entityId = Guid.NewGuid();
+        var entity = new EntityA
+        {
+            Id = entityId,
+        };
+
+        context.As.Add(entity);
+        await context.SaveChangesAsync();
+
+        // Act
+        var workflow =
+            from @as in From<EntityA>()
+            from list in
+                @as.Where(a => a.Id == entityId)
+                   .ToListEff()
+            select list;
+
+        // Assert
+        var listResult = await workflow.RunAsync(context);
+        var resultEntity = listResult.ThrowIfFail();
+
+        Assert.NotNull(resultEntity);
+        Assert.Single(resultEntity);
+    }
 }

src/Codehard.Functional/Codehard.Functional.EntityFramework/Codehard.Functional.EntityFramework.csproj

@@ -14,7 +14,7 @@
     </PropertyGroup>
 
     <ItemGroup>
-        <PackageReference Include="LanguageExt.Core" Version="5.0.0-beta-24" />
+        <PackageReference Include="LanguageExt.Core" Version="5.0.0-beta-27" />
         <PackageReference Include="Microsoft.CodeAnalysis.Common" Version="4.8.0" />
         <PackageReference Include="Microsoft.CodeAnalysis.CSharp" Version="4.8.0" />
         <PackageReference Include="Microsoft.EntityFrameworkCore" Version="8.0.8" />

src/Codehard.Functional/Codehard.Functional.EntityFramework/Extensions/QueryableExtensions.cs

@@ -1,6 +1,5 @@
 using System.Linq.Expressions;
 using LanguageExt;
-
 using static LanguageExt.Prelude;
 
 // ReSharper disable once CheckNamespace

src/Codehard.Functional/Codehard.Functional.EntityFramework/Extensions/QueryablePrelude.cs

@@ -0,0 +1,63 @@
+using System.Linq.Expressions;
+using LanguageExt;
+using Microsoft.EntityFrameworkCore;
+
+using Codehard.Common.DomainModel;
+
+using static LanguageExt.Prelude;
+
+namespace Codehard.Functional.EntityFramework.Extensions;
+
+public static class QueryablePrelude
+{
+    /// <summary>
+    /// Asynchronously converts a sequence to a list within an Eff monad.
+    /// </summary>
+    /// <typeparam name="T">The type of the elements of the source sequence.</typeparam>
+    /// <returns>
+    /// An Eff monad that represents the asynchronous operation. The Eff monad wraps a <see cref="System.Collections.Generic.List{T}"/> that contains elements from the input sequence.
+    /// </returns>
+    public static Eff<IQueryable<T>, List<T>> ToListEff<T>()
+    {
+        return
+            LanguageExt.Eff<IQueryable<T>, List<T>>.LiftIO(
+                static source =>
+                    liftIO(env => source.ToListAsync(env.Token)));
+    }
+
+    /// <summary>
+    /// Asynchronously converts a sequence to an array within an Eff monad.
+    /// </summary>
+    /// <typeparam name="T">The type of the elements of the source sequence.</typeparam>
+    /// <returns>
+    /// An Eff monad that represents the asynchronous operation. The Eff monad wraps an array that contains elements from the input sequence.
+    /// </returns>
+    public static Eff<IQueryable<T>, T[]> ToArrayEff<T>()
+    {
+        return
+            LanguageExt.Eff<IQueryable<T>, T[]>.LiftIO(
+                static source =>
+                    liftIO(env => source.ToArrayAsync(env.Token)));
+    }
+
+    public static Eff<DbContext, IQueryable<T>> From<T>()
+        where T : class
+    {
+        return
+            LanguageExt.Eff<DbContext, IQueryable<T>>.Lift(
+                dbContext => dbContext.Set<T>().AsQueryable());
+    }
+
+    public static Eff<DbSet<TEntity>, Option<TEntity>> FindByKey<TEntity, TKey>(
+        TKey key)
+        where TEntity : class, IEntity<TKey>
+        where TKey : struct
+    {
+        return
+            LanguageExt.Eff<DbSet<TEntity>, Option<TEntity>>.LiftIO(
+                source =>
+                    liftIO(async env => Optional(await source.FindAsync(
+                        new object[] { key },
+                        cancellationToken: env.Token))));
+    }
+}

src/Codehard.Functional/Codehard.Functional.FSharp/Codehard.Functional.FSharp.csproj

@@ -15,7 +15,7 @@
 
   <ItemGroup>
     <PackageReference Include="FSharp.Core" Version="8.0.400" />
-    <PackageReference Include="LanguageExt.Core" Version="5.0.0-beta-24" />
+    <PackageReference Include="LanguageExt.Core" Version="5.0.0-beta-27" />
   </ItemGroup>
 
 </Project>

src/Codehard.Functional/Codehard.Functional.Marten/Codehard.Functional.Marten.csproj

@@ -13,7 +13,7 @@
     </PropertyGroup>
 
     <ItemGroup>
-      <PackageReference Include="LanguageExt.Core" Version="5.0.0-beta-24" />
+      <PackageReference Include="LanguageExt.Core" Version="5.0.0-beta-27" />
       <PackageReference Include="Marten" Version="7.26.3" />
       <PackageReference Include="Microsoft.CodeAnalysis" Version="4.8.0"/>
       <PackageReference Include="Microsoft.CodeAnalysis.Common" Version="4.8.0" />

src/Codehard.Functional/Codehard.Functional.MediatR/Codehard.Functional.MediatR.csproj

@@ -14,7 +14,7 @@
     </PropertyGroup>
 
     <ItemGroup>
-      <PackageReference Include="LanguageExt.Core" Version="5.0.0-beta-24" />
+      <PackageReference Include="LanguageExt.Core" Version="5.0.0-beta-27" />
       <PackageReference Include="MediatR" Version="12.4.0" />
     </ItemGroup>
 

src/Codehard.Functional/Codehard.Functional.Tests/EffGuardExtTests.cs

@@ -33,4 +33,34 @@ public void WhenGuardNoneOnNullValue_ShouldGoToFailCase()
         // Assert
         Assert.False(fin.IsSucc);
     }
+
+    [Fact]
+    public async Task WhenGuardNoneOnSomeValueAsync_ShouldStayOnSuccCase()
+    {
+        // Act
+        var eff =
+            EffOption(() => ValueTask.FromResult((int?)1))
+                .GuardNotNone("There is something wrong");
+
+        var fin = await eff.RunAsync();
+
+        // Assert
+        var a = fin.ThrowIfFail();
+
+        Assert.Equal(1, a);
+    }
+
+    [Fact]
+    public async Task WhenGuardNoneOnNullValueAsync_ShouldGoToFailCase()
+    {
+        // Act
+        var eff =
+            EffOption(() => ValueTask.FromResult((int?)null))
+                .GuardNotNone("There is no value");
+
+        var fin = await eff.RunAsync();
+
+        // Assert
+        Assert.False(fin.IsSucc);
+    }
 }

src/Codehard.Functional/Codehard.Functional/Codehard.Functional.csproj

@@ -14,7 +14,7 @@
     </PropertyGroup>
 
     <ItemGroup>
-        <PackageReference Include="LanguageExt.Core" Version="5.0.0-beta-24" />
+        <PackageReference Include="LanguageExt.Core" Version="5.0.0-beta-27" />
     </ItemGroup>
 
     <ItemGroup>

src/Codehard.Infrastructure/Codehard.Infrastructure.EntityFramework.Tests/ModelBuilderExtensionsTests.cs

@@ -35,6 +35,8 @@ public void WhenUseApplyConfigurationsFromAssemblyForSpecificContext_ShouldApply
 
         // +2 because of the Money type and the Nullable Money type
         Assert.Equal(expectedEntityTypes + 3, actualEntityTypes);
+
+        return;
 
         static SqliteConnection CreateInMemoryDatabase()
         {