9336995150

Committed 02 Jun 2024 08:43AM UTC coverage: 81.967% (+0.03%) from 81.942%

Build # 9336995150

Build Type

push

github

Committed by

lucaslorentz

Commit Message

Update to EF Core 8

Run Details

6 of 6 new or added lines in 1 file covered. (100.0%)

2350 of 2867 relevant lines covered (81.97%)

139.01 hits per line

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

57.14

/src/LLL.DurableTask.Worker/ExtendedOrchestrationContext.cs

﻿using System;
using System.Collections.Generic;
using System.Threading;
using System.Threading.Tasks;
using DurableTask.Core;
using DurableTask.Core.Serializing;
using LLL.DurableTask.Worker.Utils;

namespace LLL.DurableTask.Worker;

public class ExtendedOrchestrationContext
{
    private static readonly Guid _orchestrationGuidNamespace = new("93810b2d-3411-4fc0-b51b-47f2233dac7a");
    private int _count = 0;

    private readonly OrchestrationContext _baseContext;

    public ExtendedOrchestrationContext(OrchestrationContext baseContext)
    {
        _baseContext = baseContext;
    }

    public OrchestrationContext BaseContext => _baseContext;

    /// <inheritdoc cref="OrchestrationContext.ContinueAsNew" />
    public void ContinueAsNew(object input)
    {
        BaseContext.ContinueAsNew(input);
    }

    /// <inheritdoc cref="OrchestrationContext.ContinueAsNew" />
    public void ContinueAsNew(string newVersion, object input)
    {
        BaseContext.ContinueAsNew(newVersion, input);
    }

    /// <inheritdoc cref="OrchestrationContext.CreateSubOrchestrationInstance" />
    public Task<T> CreateSubOrchestrationInstance<T>(string name, string version, object input)
    {
        return BaseContext.CreateSubOrchestrationInstance<T>(name, version, input);
    }

    /// <inheritdoc cref="OrchestrationContext.CreateSubOrchestrationInstance" />
    public Task<T> CreateSubOrchestrationInstance<T>(string name, string version, string instanceId, object input)
    {
        return BaseContext.CreateSubOrchestrationInstance<T>(name, version, instanceId, input);
    }

    /// <inheritdoc cref="OrchestrationContext.CreateSubOrchestrationInstance" />
    public Task<T> CreateSubOrchestrationInstance<T>(string name, string version, string instanceId, object input, IDictionary<string, string> tags)
    {
        return BaseContext.CreateSubOrchestrationInstance<T>(name, version, instanceId, input, tags);
    }

    /// <inheritdoc cref="OrchestrationContext.CreateTimer" />
    public Task<T> CreateTimer<T>(DateTime fireAt, T state)
    {
        return BaseContext.CreateTimer(fireAt, state); ;
    }

    /// <inheritdoc cref="OrchestrationContext.CreateTimer" />
    public Task<T> CreateTimer<T>(DateTime fireAt, T state, CancellationToken cancelToken)
    {
        return BaseContext.CreateTimer(fireAt, state, cancelToken);
    }

    /// <inheritdoc cref="OrchestrationContext.ScheduleTask" />
    public Task<TResult> ScheduleTask<TResult>(string name, string version, params object[] parameters)
    {
        return BaseContext.ScheduleTask<TResult>(name, version, parameters);
    }

    /// <inheritdoc cref="OrchestrationContext.SendEvent" />
    public void SendEvent(OrchestrationInstance orchestrationInstance, string eventName, object eventData)
    {
        BaseContext.SendEvent(orchestrationInstance, eventName, eventData);
    }

    /// <inheritdoc cref="OrchestrationContext.CurrentUtcDateTime" />
    public virtual DateTime CurrentUtcDateTime => BaseContext.CurrentUtcDateTime;

    /// <inheritdoc cref="OrchestrationContext.IsReplaying" />
    public bool IsReplaying => BaseContext.IsReplaying;

    /// <inheritdoc cref="OrchestrationContext.MessageDataConverter" />
    public JsonDataConverter MessageDataConverter => _baseContext.MessageDataConverter;

    /// <inheritdoc cref="OrchestrationContext.ErrorDataConverter" />
    public JsonDataConverter ErrorDataConverter => _baseContext.ErrorDataConverter;

    /// <inheritdoc cref="OrchestrationContext.OrchestrationInstance" />
    public OrchestrationInstance OrchestrationInstance => _baseContext.OrchestrationInstance;

    public event Action<string, string> Event;
    public Func<string> StatusProvider { get; set; }

    public Guid NewGuid()
    {
        return DeterministicGuid.Create(_orchestrationGuidNamespace, $"{BaseContext.OrchestrationInstance.ExecutionId}/{++_count}");
    }

    internal void RaiseEvent(string name, string input)
    {
        Event?.Invoke(name, input);
    }
}

1	using System;
2	using System.Collections.Generic;
3	using System.Threading;
4	using System.Threading.Tasks;
5	using DurableTask.Core;
6	using DurableTask.Core.Serializing;
7	using LLL.DurableTask.Worker.Utils;
8
9	namespace LLL.DurableTask.Worker;
10
11	public class ExtendedOrchestrationContext
12	{
13	private static readonly Guid _orchestrationGuidNamespace = new("93810b2d-3411-4fc0-b51b-47f2233dac7a");	1✔
14	private int _count = 0;
15
16	private readonly OrchestrationContext _baseContext;
17
18	public ExtendedOrchestrationContext(OrchestrationContext baseContext)	26✔
19	{
20	_baseContext = baseContext;	26✔
21	}
22
23	public OrchestrationContext BaseContext => _baseContext;	27✔
24
25	/// <inheritdoc cref="OrchestrationContext.ContinueAsNew" />
26	public void ContinueAsNew(object input)
27	{
28	BaseContext.ContinueAsNew(input);	×
29	}
30
31	/// <inheritdoc cref="OrchestrationContext.ContinueAsNew" />
32	public void ContinueAsNew(string newVersion, object input)
33	{
34	BaseContext.ContinueAsNew(newVersion, input);	×
35	}
36
37	/// <inheritdoc cref="OrchestrationContext.CreateSubOrchestrationInstance" />
38	public Task<T> CreateSubOrchestrationInstance<T>(string name, string version, object input)
39	{
40	return BaseContext.CreateSubOrchestrationInstance<T>(name, version, input);	×
41	}
42
43	/// <inheritdoc cref="OrchestrationContext.CreateSubOrchestrationInstance" />
44	public Task<T> CreateSubOrchestrationInstance<T>(string name, string version, string instanceId, object input)
45	{
46	return BaseContext.CreateSubOrchestrationInstance<T>(name, version, instanceId, input);	×
47	}
48
49	/// <inheritdoc cref="OrchestrationContext.CreateSubOrchestrationInstance" />
50	public Task<T> CreateSubOrchestrationInstance<T>(string name, string version, string instanceId, object input, IDictionary<string, string> tags)
51	{
52	return BaseContext.CreateSubOrchestrationInstance<T>(name, version, instanceId, input, tags);	×
53	}
54
55	/// <inheritdoc cref="OrchestrationContext.CreateTimer" />
56	public Task<T> CreateTimer<T>(DateTime fireAt, T state)
57	{
58	return BaseContext.CreateTimer(fireAt, state); ;	3✔
59	}
60
61	/// <inheritdoc cref="OrchestrationContext.CreateTimer" />
62	public Task<T> CreateTimer<T>(DateTime fireAt, T state, CancellationToken cancelToken)
63	{
64	return BaseContext.CreateTimer(fireAt, state, cancelToken);	2✔
65	}
66
67	/// <inheritdoc cref="OrchestrationContext.ScheduleTask" />
68	public Task<TResult> ScheduleTask<TResult>(string name, string version, params object[] parameters)
69	{
70	return BaseContext.ScheduleTask<TResult>(name, version, parameters);	13✔
71	}
72
73	/// <inheritdoc cref="OrchestrationContext.SendEvent" />
74	public void SendEvent(OrchestrationInstance orchestrationInstance, string eventName, object eventData)
75	{
76	BaseContext.SendEvent(orchestrationInstance, eventName, eventData);	×
77	}
78
79	/// <inheritdoc cref="OrchestrationContext.CurrentUtcDateTime" />
80	public virtual DateTime CurrentUtcDateTime => BaseContext.CurrentUtcDateTime;	5✔
81
82	/// <inheritdoc cref="OrchestrationContext.IsReplaying" />
83	public bool IsReplaying => BaseContext.IsReplaying;	×
84
85	/// <inheritdoc cref="OrchestrationContext.MessageDataConverter" />
86	public JsonDataConverter MessageDataConverter => _baseContext.MessageDataConverter;	53✔
87
88	/// <inheritdoc cref="OrchestrationContext.ErrorDataConverter" />
89	public JsonDataConverter ErrorDataConverter => _baseContext.ErrorDataConverter;	×
90
91	/// <inheritdoc cref="OrchestrationContext.OrchestrationInstance" />
92	public OrchestrationInstance OrchestrationInstance => _baseContext.OrchestrationInstance;	×
93
94	public event Action<string, string> Event;
95	public Func<string> StatusProvider { get; set; }	46✔
96
97	public Guid NewGuid()
98	{
99	return DeterministicGuid.Create(_orchestrationGuidNamespace, $"{BaseContext.OrchestrationInstance.ExecutionId}/{++_count}");	4✔
100	}
101
102	internal void RaiseEvent(string name, string input)
103	{
104	Event?.Invoke(name, input);	14✔
105	}
106	}

lucaslorentz / durabletask-extensions / 9336995150

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