StockSharp/Algo/ExtendedInfoStorageMessageAdapter.cs at master · StockSharp/StockSharp · GitHub

History

60 lines (51 loc) · 2.07 KB

Raw

namespace StockSharp.Algo;

/// <summary>

/// The message adapter, that save extension info into <see cref="IExtendedInfoStorage"/>.

/// </summary>

public class ExtendedInfoStorageMessageAdapter : MessageAdapterWrapper

{

private readonly IExtendedInfoStorage _extendedInfoStorage;

private readonly string _storageName;

private readonly IEnumerable<(string, Type)> _fields;

private readonly AsyncLock _sync = new();

private IExtendedInfoStorageItem _storage;

/// <summary>

/// Initializes a new instance of the <see cref="MessageAdapterWrapper"/>.

/// </summary>

/// <param name="innerAdapter">Underlying adapter.</param>

/// <param name="extendedInfoStorage">Extended info storage.</param>

public ExtendedInfoStorageMessageAdapter(IMessageAdapter innerAdapter, IExtendedInfoStorage extendedInfoStorage)

: base(innerAdapter)

{

if (InnerAdapter.StorageName.IsEmpty())

throw new ArgumentException(nameof(innerAdapter));

_extendedInfoStorage = extendedInfoStorage ?? throw new ArgumentNullException(nameof(extendedInfoStorage));

_storageName = InnerAdapter.StorageName;

_fields = [.. InnerAdapter.SecurityExtendedFields];

}

private async ValueTask<IExtendedInfoStorageItem> GetStorageAsync(CancellationToken cancellationToken)

{

if (_storage == null)

{

using (await _sync.LockAsync(cancellationToken))

_storage ??= await _extendedInfoStorage.CreateAsync(_storageName, _fields, cancellationToken);

}

return _storage;

}

/// <inheritdoc />

protected override async ValueTask OnInnerAdapterNewOutMessageAsync(Message message, CancellationToken cancellationToken)

{

var secMsg = message as SecurityMessage;

//if (secMsg?.ExtensionInfo != null)

// GetStorageAsync().Add(secMsg.SecurityId, secMsg.ExtensionInfo);

await base.OnInnerAdapterNewOutMessageAsync(message, cancellationToken);

}

/// <summary>

/// Create a copy of <see cref="ExtendedInfoStorageMessageAdapter"/>.

/// </summary>

/// <returns>Copy.</returns>

public override IMessageAdapter Clone()

{

return new ExtendedInfoStorageMessageAdapter(InnerAdapter.TypedClone(), _extendedInfoStorage);

}

StockSharp/Algo/ExtendedInfoStorageMessageAdapter.cs at master · StockSharp/StockSharp · GitHub

Uh oh!

Expand file tree

Breadcrumbs

ExtendedInfoStorageMessageAdapter.cs

Latest commit

History

Breadcrumbs

ExtendedInfoStorageMessageAdapter.cs

File metadata and controls