embeddingsearch/src/Server/Probmethods.cs

using System.Text.Json;
using Server.Exceptions;
using Shared.Models;

namespace Server;

public class ProbMethod
{
    public Probmethods.probMethodDelegate method;
    public ProbMethodEnum probMethodEnum;
    public string name;

    public ProbMethod(ProbMethodEnum probMethodEnum, ILogger logger)
    {
        this.probMethodEnum = probMethodEnum;
        this.name = probMethodEnum.ToString();
        Probmethods.probMethodDelegate? probMethod = Probmethods.GetMethod(name);
        if (probMethod is null)
        {
            logger.LogError("Unable to retrieve probMethod {name}", [name]);
            throw new ProbMethodNotFoundException(probMethodEnum);
        }
        method = probMethod;
    }
}


public static class Probmethods
{
    public delegate float probMethodProtoDelegate(List<(string, float)> list, string parameters);
    public delegate float probMethodDelegate(List<(string, float)> list);
    public static readonly Dictionary<ProbMethodEnum, probMethodProtoDelegate> probMethods;

    static Probmethods()
    {
        probMethods = new Dictionary<ProbMethodEnum, probMethodProtoDelegate>
        {
            [ProbMethodEnum.Mean] = Mean,
            [ProbMethodEnum.HarmonicMean] = HarmonicMean,
            [ProbMethodEnum.QuadraticMean] = QuadraticMean,
            [ProbMethodEnum.GeometricMean] = GeometricMean,
            [ProbMethodEnum.EVEWAvg] = ExtremeValuesEmphasisWeightedAverage,
            [ProbMethodEnum.HVEWAvg] = HighValueEmphasisWeightedAverage,
            [ProbMethodEnum.LVEWAvg] = LowValueEmphasisWeightedAverage,
            [ProbMethodEnum.DictionaryWeightedAverage] = DictionaryWeightedAverage
        };
    }

    public static probMethodDelegate? GetMethod(ProbMethodEnum probMethodEnum)
    {
        return GetMethod(probMethodEnum.ToString());
    }

    public static probMethodDelegate? GetMethod(string name)
    {
        string methodName = name;
        string? jsonArg = "";

        // Detect if parameters are embedded
        int colonIndex = name.IndexOf(':');
        if (colonIndex != -1)
        {
            methodName = name[..colonIndex];
            jsonArg = name[(colonIndex + 1)..];
        }
        ProbMethodEnum probMethodEnum = (ProbMethodEnum)Enum.Parse(
            typeof(ProbMethodEnum),
            methodName
        );

        if (!probMethods.TryGetValue(probMethodEnum, out probMethodProtoDelegate? method))
        {
            return null;
        }
        return list => method(list, jsonArg);
    }

    public static float Mean(List<(string, float)> list, string __)
    {
        if (list.Count == 0) return 0;
        float sum = 0;
        foreach ((_, float value) in list)
        {
            sum += value;
        }
        return sum / list.Count;
    }

    public static float HarmonicMean(List<(string, float)> list, string _)
    {
        int n_T = list.Count;
        float[] nonzeros = [.. list.Select(t => t.Item2).Where(t => t != 0)];
        int n_nz = nonzeros.Length;
        if (n_nz == 0) return 0;

        float nzSum = nonzeros.Sum(x => 1 / x);
        return n_nz / nzSum * (n_nz / (float)n_T);
    }

    public static float QuadraticMean(List<(string, float)> list, string _)
    {
        float sum = 0;
        foreach (var (_, value) in list)
        {
            sum += value * value;
        }
        return (float)Math.Sqrt(sum / list.Count);
    }

    public static float GeometricMean(List<(string, float)> list, string __)
    {
        if (list.Count == 0) return 0;
        float product = 1;
        foreach ((_, float value) in list)
        {
            product *= value;
        }
        return (float)Math.Pow(product, 1f / list.Count);
    }

    public static float ExtremeValuesEmphasisWeightedAverage(List<(string, float)> list, string _)
    {
        float[] arr = [.. list.Select(x => x.Item2)];
        if (arr.Contains(1)) return 1;
        if (arr.Contains(0)) return 0;

        float f = 0, fm = 0;
        foreach (float x in arr)
        {
            f += x / (x * (1 - x));
            fm += 1 / (x * (1 - x));
        }
        return f / fm;
    }

    public static float HighValueEmphasisWeightedAverage(List<(string, float)> list, string _)
    {
        float[] arr = [.. list.Select(x => x.Item2)];
        if (arr.Contains(1)) return 1;

        float f = 0, fm = 0;
        foreach (float x in arr)
        {
            f += x / (1 - x);
            fm += 1 / (1 - x);
        }
        return f / fm;
    }

    public static float LowValueEmphasisWeightedAverage(List<(string, float)> list, string _)
    {
        float[] arr = [.. list.Select(x => x.Item2)];
        if (arr.Contains(0)) return 0;

        float f = 0, fm = 0;
        foreach (float x in arr)
        {
            f += 1;
            fm += 1 / x;
        }
        return f / fm;
    }

    public static float DictionaryWeightedAverage(List<(string, float)> list, string jsonValues)
    {
        var values = JsonSerializer.Deserialize<Dictionary<string, float>>(jsonValues)
                      ?? throw new Exception($"Unable to convert the string to a Dictionary<string,float>: {jsonValues}");

        float f = 0, fm = 0;
        foreach (var (key, value) in list)
        {
            float fact = 1;
            if (values.TryGetValue(key, out float factor))
            {
                fact *= factor;
            }
            f += fact * value;
            fm += fact;
        }
        return f / fm;
    }
}