mrpmorris

using Microsoft.EntityFrameworkCore;

public abstract class EntityBase<TKey> where TKey : IEquatable<TKey>
{
    public abstract TKey Id { get; set; }
}

public abstract class RepositoryBase<TDbContext, TEntity, TKey>
    where TDbContext : DbContext, new()
    where TEntity : EntityBase<TKey>

mrpmorris

<Project Sdk="Microsoft.NET.Sdk">
    <PropertyGroup>
        <Title>Morris.Extensions.Aspire.ExternalSolutionSupport</Title>
        <PackageId>Morris.Extensions.Aspire.ExternalSolutionSupport</PackageId>
        <Description>Referenced Solutions support for Aspire</Description>
        <Nullable>enable</Nullable>
        <ImplicitUsings>true</ImplicitUsings>
        <IncludeBuildOutput>false</IncludeBuildOutput>
        <IsRoslynComponent>true</IsRoslynComponent>
        <TargetFramework>netstandard2.0</TargetFramework>

mrpmorris

<Project Sdk="Microsoft.NET.Sdk">

  <PropertyGroup>
    <OutputType>Exe</OutputType>
    <TargetFramework>net8.0</TargetFramework>
    <ImplicitUsings>enable</ImplicitUsings>
    <Nullable>enable</Nullable>
  </PropertyGroup>

  <ItemGroup>

mrpmorris

static readonly char[] ExtractFloatsTrimChars = new char[] { '[', ']', ' ' };
static float[] ExtractFloats(string input) =>
    input
        .Trim(ExtractFloatsTrimChars)
        .Split(',')
        .Select(float.Parse)
        .ToArray();

mrpmorris

public class ActivityTrackingMiddleware : IFunctionsWorkerMiddleware
{
    public const string ActivitySourceName = "AzureFunctionsWorker";

    private readonly static ConcurrentDictionary<string, TriggerParameterInfo> FunctionIdToTriggerParameterInfoLookup = new();
    private readonly static ActivitySource ActivitySource = new(ActivitySourceName);
    private readonly HttpTriggerHandler HttpTriggerHandler;
    private readonly ActivityTriggerHandler ActivityTriggerHandler;
    private readonly FrozenDictionary<string, ICustomTriggerHandler> CustomTriggerHandlers;

mrpmorris

using MyApp.Contracts;
using Community.OData.Linq;
using Microsoft.EntityFrameworkCore;

namespace CarePlace.AppLayer.Persistence;

internal static class IQueryableExtensions
{
    public static IQueryable<T> ApplyODataParameters<T>(
        this IQueryable<T> source,

mrpmorris

internal class IdentityService : IIdentityService
{
    // Other properties like the current user etc
    public bool IsRunningWithElevatedPrivileges => ElevatedPrivilegeCount > 0;
    private volatile int ElevatedPrivilegeCount;

    public IDisposable ExecuteWithElevatedPrivileges()
    {
        Interlocked.Increment(ref ElevatedPrivilegeCount);
        return new DisposableCallback(() => Interlocked.Decrement(ref ElevatedPrivilegeCount));

mrpmorris

public sealed class DisposableCallback : IDisposable
{
    private readonly Action Action;
    private readonly string CallerFilePath;
    private readonly int CallerLineNumber;
    private readonly bool WasCreated;
    private bool IsDisposed;

    /// <summary>
    /// Creates an instance of the class

mrpmorris

public static class IntegrationTestsServer
{
	static IntegrationTestsServer()
	{
		ConfigureMocks();
		Environment.SetEnvironmentVariable("ASPNETCORE_ENVIRONMENT", "IntegrationTesting");
		WebApplicationFactory<Program> appBuilder = new WebApplicationFactory<Program>()
			.WithWebHostBuilder(builder =>
			{
				builder.ConfigureTestServices(services =>

mrpmorris

public static class StringHelper
{
    public const byte DefaultUnobscuredLength = 3;

    public enum Keep { Start, End };

    public static string? ObscureEmailAddress(string? value)
    {
        if (string.IsNullOrEmpty(value))
            return value;