How to use IterativeResultSetResolverArgs method of NBi.Core.ResultSet.Resolver.IterativeResultSetResolverArgs class

Best NBi code snippet using NBi.Core.ResultSet.Resolver.IterativeResultSetResolverArgs.IterativeResultSetResolverArgs

ResultSetResolverArgsBuilder.cs

Source:ResultSetResolverArgsBuilder.cs

...84                return BuildJsonPathResolverArgs(xml.JsonSource);85            else if (xml.Empty != null)86                return BuildEmptyResolverArgs(xml.Empty);87            else if (xml.Iteration != null)88                return BuildIterativeResultSetResolverArgs(xml.Iteration, xml.NestedResultSet);89            else if (xml.Rows != null)90                return BuildEmbeddedResolverArgs(xml.Content);91            throw new ArgumentException();92        }93        private ResultSetResolverArgs BuildResultSetXml(ResultSetXml xml)94        {95            //ResultSet (external flat file)96            if (!string.IsNullOrEmpty(xml.File))97            {98                ParseFileInfo(xml.File, out var filename, out var parserName);99                if (string.IsNullOrEmpty(parserName))100                    return BuildFlatFileResultSetResolverArgs(new FileXml() { Path = filename });101                else102                    return BuildFlatFileResultSetResolverArgs(new FileXml() { Path = filename, Parser = new ParserXml() { Name = parserName } });103            }104            //ResultSet (embedded)105            else if (xml.Rows != null)106                return BuildEmbeddedResolverArgs(xml.Content);107            throw new ArgumentException();108        }109        private ResultSetResolverArgs BuildSequenceCombinationResolverArgs(SequenceCombinationXml sequenceCombinationXml)110        {111            var resolvers = new List<ISequenceResolver>();112            var sequenceFactory = new SequenceResolverFactory(ServiceLocator);113            var builder = new SequenceResolverArgsBuilder(ServiceLocator);114            builder.Setup(settings);115            builder.Setup(Variables);116            foreach (var sequenceXml in sequenceCombinationXml.Sequences)117            {118                builder.Setup(sequenceXml.Type);119                builder.Setup((object)sequenceXml.SentinelLoop ?? sequenceXml.Items);120                builder.Build();121                resolvers.Add(sequenceFactory.Instantiate(sequenceXml.Type, builder.GetArgs()));122            }123            return new SequenceCombinationResultSetResolverArgs(resolvers);124        }125        private ResultSetResolverArgs BuildSequenceResolverArgs(SequenceXml sequenceXml)126        {127            var sequenceFactory = new SequenceResolverFactory(ServiceLocator);128            var builder = new SequenceResolverArgsBuilder(ServiceLocator);129            builder.Setup(settings);130            builder.Setup(Variables);131            builder.Setup(sequenceXml.Type);132            builder.Setup((object)sequenceXml.SentinelLoop ?? sequenceXml.Items);133            builder.Build();134            var resolver = sequenceFactory.Instantiate(sequenceXml.Type, builder.GetArgs());135            return new SequenceResultSetResolverArgs(resolver);136        }137        private void ParseFileInfo(string input, out string filename, out string parserName)138        {139            var split = input.Split(new char[] { '!' }, StringSplitOptions.RemoveEmptyEntries);140            filename = split[0];141            parserName = split.Count() == 1 ? string.Empty : split[1];142        }143        private ResultSetResolverArgs BuildEmbeddedResolverArgs(IContent content)144        {145            Trace.WriteLineIf(Extensibility.NBiTraceSwitch.TraceVerbose, "ResultSet defined in embedded resultSet.");146            return new ContentResultSetResolverArgs(content);147        }148        private ResultSetResolverArgs BuildIterativeResultSetResolverArgs(IterationXml iterationXml, ResultSetSystemXml nestedResultSetXml)149        {150            var sequenceFactory = new SequenceResolverFactory(ServiceLocator);151            var builder = new SequenceResolverArgsBuilder(ServiceLocator);152            builder.Setup(settings);153            builder.Setup(Variables);154            builder.Setup(iterationXml.Sequence.Type);155            builder.Setup((object)iterationXml.Sequence.SentinelLoop ?? iterationXml.Sequence.Items);156            builder.Build();157            var sequenceResolver = sequenceFactory.Instantiate(iterationXml.Sequence.Type, builder.GetArgs());158            var nestedHelper = new ResultSetSystemHelper(ServiceLocator, scope, Variables);159            nestedResultSetXml.Settings = settings;160            var nestedResultSetResolver = nestedHelper.InstantiateResolver(nestedResultSetXml);161            return new IterativeResultSetResolverArgs(sequenceResolver, iterationXml.Sequence.Name, Variables, nestedResultSetResolver);162        }163        private ResultSetResolverArgs BuildQueryResolverArgs(QueryXml queryXml, SettingsXml.DefaultScope scope)164        {165            Trace.WriteLineIf(Extensibility.NBiTraceSwitch.TraceVerbose, "ResultSet defined through a query.");166            var argsBuilder = new QueryResolverArgsBuilder(ServiceLocator);167            argsBuilder.Setup(queryXml, settings, scope, Variables);168            argsBuilder.Build();169            var argsQuery = argsBuilder.GetArgs();170            return new QueryResultSetResolverArgs(argsQuery);171        }172        private ResultSetResolverArgs BuildFlatFileResultSetResolverArgs(FileXml fileMetadata)173        {174            Trace.WriteLineIf(Extensibility.NBiTraceSwitch.TraceVerbose, $"ResultSet defined in an external flat file to be read with {(string.IsNullOrEmpty(fileMetadata.Parser?.Name) ? "the default CSV parser" : fileMetadata.Parser?.Name)}.");175            var helper = new ScalarHelper(ServiceLocator, settings, scope, new Context(Variables));...

ResultSetResolverFactory.cs

Source:ResultSetResolverFactory.cs

...25        public IResultSetResolver Instantiate(ResultSetResolverArgs args)26        {27            switch (args)28            {29                case IterativeResultSetResolverArgs x: return new IterativeResultSetResolver(x.SequenceResolver, x.VariableName, x.Variables, x.ResultSetResolver);30                case ContentResultSetResolverArgs x: return new ContentResultSetResolver(x);31                case RowsResultSetResolverArgs x: return new RowsResultSetResolver(x);32                case QueryResultSetResolverArgs x: return new QueryResultSetResolver(x, serviceLocator);33                case FlatFileResultSetResolverArgs x: return new FlatFileResultSetResolver(x, serviceLocator);34                case DataSerializationResultSetResolverArgs x: return new DataSerializationResultSetResolver(x);35                case ObjectsResultSetResolverArgs x: return new ObjectsResultSetResolver(x);36                case SequenceCombinationResultSetResolverArgs x: return new SequenceCombinationResultSetResolver(x);37                case EmptyResultSetResolverArgs x: return new EmptyResultSetResolver(x);38                case IfUnavailableResultSetResolverArgs x: return new IfUnavailableResultSetResolver(x);39                default: throw new ArgumentOutOfRangeException($"Type '{args.GetType().Name}' is not expected when building a result-set");40            }41        }42    }43}...

IterativeResultSetResolverArgs.cs

Source:IterativeResultSetResolverArgs.cs

...7using System.Text;8using System.Threading.Tasks;9namespace NBi.Core.ResultSet.Resolver10{11    public class IterativeResultSetResolverArgs : ResultSetResolverArgs12    {13        public IResultSetResolver ResultSetResolver { get; }14        public ISequenceResolver SequenceResolver { get; }15        public IMergingEngine MergingEngine { get; }16        public string VariableName { get; }17        public IDictionary<string, IVariable> Variables { get; }18        public IterativeResultSetResolverArgs(ISequenceResolver sequenceResolver, string variableName, IDictionary<string, IVariable> variables, IResultSetResolver resultSetResolver)19        {20            SequenceResolver = sequenceResolver;21            ResultSetResolver = resultSetResolver;22            MergingEngine = new UnionByOrdinalEngine(new ResultSetService(resultSetResolver.Execute, null));23            Variables = variables;24            VariableName = variableName;25        }26    }27}...