using System;

using System.Runtime;

using RulesEngine;

using System.Dynamic;

using Newtonsoft.Json;

using Newtonsoft.Json.Converters;

public class Program

{

    private static string[] json = new string[]{@"{

    ""WorkflowName"": ""Average Earnings"",

    ""globalParams"": [{

            ""Name"": ""YrsInAverage"",

            ""Expression"": ""5""

        }

    ],

    ""Rules"": [{

            ""RuleName"": ""Final Average earnings"",

            ""SuccessEvent"": ""AvergeEarnings"",

            ""ErrorMessage"": ""Final Average earnings rule failed."",

            ""ErrorType"": ""Error"",

            ""RuleExpressionType"": ""LambdaExpression"",

            ""Expression"": ""input1.earnings != null && input1.earnings.Count > 0 && YrsInAverage > 0"",

            ""Actions"": {

                ""OnSuccess"": {

                    ""Name"": ""OutputExpression"",

                    ""Context"": {

                        ""Expression"": ""input1.earnings.Skip(input1.earnings.Count() - YrsInAverage).Average(x => x)""

                    }

                }

            }

        }, {

            ""RuleName"": ""Best Average earnings"",

            ""SuccessEvent"": ""AvergeEarnings"",

            ""ErrorMessage"": ""Best Average earnings rule failed."",

            ""ErrorType"": ""Error"",

            ""RuleExpressionType"": ""LambdaExpression"",

            ""Expression"": ""input1.earnings != null && input1.earnings.Count > 0 && YrsInAverage > 0"",

            ""Actions"": {

                ""OnSuccess"": {

                    ""Name"": ""OutputExpression"",

                    ""Context"": {

                        ""Expression"": ""input1.earnings.OrderByDescending(x => x).Take(YrsInAverage).Average(x => x)""

                    }

                }

            }

        }

    ]

}"};

    public static void Main()

    {

        var workflowRules = json;

        var re = new RulesEngine.RulesEngine(workflowRules);

        // Declare inputs

        var inputStr = @"[{

        ""workflows"": [""Eligibility"", ""Time to Retirement"", ""Average Earnings""],

        ""id"": ""1234"",

        ""age"": 67,

        ""service"": 2.1,

        ""earnings"": [60000, 62000]

    }, {

        ""workflows"": [""Eligibility"", ""Time to Retirement"", ""Average Earnings""],

        ""id"": ""2345"",

        ""age"": 60.5,

        ""service"": 9.5,

        ""earnings"": [70000, 72000, 85000, 88000, 91000, 98000, 70000, 72000, 85000]

    }, {

        ""workflows"": [""Eligibility"", ""Time to Retirement"", ""Average Earnings""],

        ""id"": ""3456"",

        ""age"": 56,

        ""service"": 29.25,

        ""earnings"": [70000, 72000, 85000, 88000, 91000, 98000, 70000, 72000, 85000, 70000, 72000, 85000, 70000, 72000, 85000, 70000, 72000, 85000, 91000, 93000, 96000, 101000, 105000, 108000, 120000, 123000, 90000, 95000, 98000]

    }

]";

        dynamic[] inputs = JsonConvert.DeserializeObject<ExpandoObject[]>(inputStr,new ExpandoObjectConverter());

        foreach(var input in inputs){

            Console.WriteLine("****");

            var resultList  = re.ExecuteAllRulesAsync("Average Earnings",input).Result;

​

            //Check success for rule

            foreach(var result in resultList){

              Console.WriteLine($"Rule - {result.Rule.RuleName}, IsSuccess - {result.IsSuccess}, ExceptionMessage - {result.ExceptionMessage}");

              Console.WriteLine($"ActionOutput - {result.ActionResult.Output}, ActionException - {result.ActionResult.Exception}");

            }

        }

    }

}