5835751495

pending completion

Build # 5835751495

Build Type

push

github

Committed by

lucaslorentz

Commit Message

Add husky and apply some code fixes

Run Details

2502 of 2502 new or added lines in 91 files covered. (100.0%)

2286 of 2792 relevant lines covered (81.88%)

143.14 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

91.67

/src/LLL.DurableTask.Worker/OrchestrationBase.cs

﻿using System.Threading.Tasks;
using DurableTask.Core;
using LLL.DurableTask.Core.Serializing;

namespace LLL.DurableTask.Worker;

public abstract class OrchestrationBase<TResult, TInput> : TaskOrchestration
{
    public ExtendedOrchestrationContext Context { get; private set; }

    public sealed override async Task<string> Execute(OrchestrationContext context, string input)
    {
        context.MessageDataConverter = new TypelessJsonDataConverter();
        context.ErrorDataConverter = new TypelessJsonDataConverter();
        Context = new ExtendedOrchestrationContext(context);

        var parameter = context.MessageDataConverter.Deserialize<TInput>(input);

        var result = await Execute(parameter);
        return context.MessageDataConverter.Serialize(result);
    }

    public sealed override string GetStatus()
    {
        if (Context.StatusProvider != null)
            return Context.StatusProvider();

        return Context.MessageDataConverter.Serialize(OnGetStatus());
    }

    public sealed override void RaiseEvent(OrchestrationContext context, string name, string input)
    {
        Context.RaiseEvent(name, input);
    }

    public abstract Task<TResult> Execute(TInput input);

    public virtual object OnGetStatus()
    {
        return null;
    }
}

1	using System.Threading.Tasks;
2	using DurableTask.Core;
3	using LLL.DurableTask.Core.Serializing;
4
5	namespace LLL.DurableTask.Worker;
6
7	public abstract class OrchestrationBase<TResult, TInput> : TaskOrchestration
8	{
9	public ExtendedOrchestrationContext Context { get; private set; }	131✔
10
11	public sealed override async Task<string> Execute(OrchestrationContext context, string input)
12	{
13	context.MessageDataConverter = new TypelessJsonDataConverter();	21✔
14	context.ErrorDataConverter = new TypelessJsonDataConverter();	21✔
15	Context = new ExtendedOrchestrationContext(context);	21✔
16
17	var parameter = context.MessageDataConverter.Deserialize<TInput>(input);	21✔
18
19	var result = await Execute(parameter);	21✔
20	return context.MessageDataConverter.Serialize(result);	17✔
21	}
22
23	public sealed override string GetStatus()
24	{
25	if (Context.StatusProvider != null)	39✔
26	return Context.StatusProvider();	×
27
28	return Context.MessageDataConverter.Serialize(OnGetStatus());	39✔
29	}
30
31	public sealed override void RaiseEvent(OrchestrationContext context, string name, string input)
32	{
33	Context.RaiseEvent(name, input);	7✔
34	}
35
36	public abstract Task<TResult> Execute(TInput input);
37
38	public virtual object OnGetStatus()
39	{
40	return null;	39✔
41	}
42	}

lucaslorentz / durabletask-extensions / 5835751495

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous