GeorgeTsiokos

# ======================
# curl-download.sh  v1.0
# filename
# url
# ======================

if [ -f "$1.etag" ]; then
    HTTPCODE=$(curl --etag-compare $1.etag --url $2 -o $1 -sw '%{http_code}' --retry 9)
    if [ "$HTTPCODE" = "304" ]; then
      echo "$1: not modified"

GeorgeTsiokos

[DebuggerDisplay("Count = {" + nameof(Count) + "}")]
public sealed class TaskCompletionSourceDictionary
{
    private readonly TaskCompletionSourceDictionary<Type> _dictionary = new TaskCompletionSourceDictionary<Type>();

    public int Count => _dictionary.Count;

    public bool TryGetValue<T>(out TaskCompletionSource<T> taskCompletionSource) =>
        _dictionary.TryGetValue(typeof(T), out taskCompletionSource);

GeorgeTsiokos

using System;
using System.Collections;
using System.Collections.Concurrent;
using System.Net;
using System.Reflection;
using System.Threading;
using System.Threading.Tasks;

namespace OpenSource.Net
{

GeorgeTsiokos

public static KeyValuePair<ushort, string>[] Parse(Span<byte> message)
{
    var values = new List<KeyValuePair<ushort, string>>();
    const byte Soh = 1;
    const byte Equals = 61;
    while (0 < message.Length)
    {
        var soh = message.IndexOf(Soh);
        if (-1 == soh)
            break;

GeorgeTsiokos

public static class EnumerableExtensions
{
    public static bool IsOrderedSubsetOf<T>(
        this IEnumerable<T> source,
        IEnumerable<T> target,
        out T missing,
        IEqualityComparer<T> equalityComparer = null)
    {
        if (null == equalityComparer)
            equalityComparer = EqualityComparer<T>.Default;

GeorgeTsiokos

public static class DataProtectionBuilderExtensions
{
    public static IDataProtectionBuilder PersistKeysToStackExchangeRedisCache(this IDataProtectionBuilder builder, RedisKey key)
    {
        builder.Services.AddOptions<KeyManagementOptions>()
            .Configure<IDistributedCache>((options, distributedCache) => options.XmlRepository = new RedisXmlRepository(() => GetDatabase(distributedCache), key));
        return builder;
    }

    private static IDatabase GetDatabase(IDistributedCache store)

GeorgeTsiokos

public sealed class SessionIdDataFormat : ISecureDataFormat<AuthenticationTicket>
{
    private const string SessionIdClaim = "Microsoft.AspNetCore.Authentication.Cookies-SessionId";

    public string Protect(AuthenticationTicket data) => data.Principal.FindFirst(SessionIdClaim).Value;

    public string Protect(AuthenticationTicket data, string purpose) => null != purpose ? null : Protect(data);

    public AuthenticationTicket Unprotect(string protectedText)
    {

GeorgeTsiokos

public void ConfigureServices(IServiceCollection services)
{
    services.AddHttpClient<IRancherClient, RancherClient>();
}

public interface IRancherClient
{
    Task<HttpResponseMessage> ProjectStackActionAsync(string project, string stack, string action,
        HttpContent content = null);

GeorgeTsiokos

public sealed class FileTelemetryChannel : ITelemetryChannel
{
    private readonly ISerializationWriter _serializationWriter;
    private readonly StreamWriter _streamWriter;

    public FileTelemetryChannel(string fileName = null)
    {
        EndpointAddress = fileName;
        _streamWriter = new StreamWriter(
            fileName ?? $"{Path.GetTempPath()}ai-{DateTime.Now:yyyy-M-d}.jsonl",

GeorgeTsiokos

/// <summary>
///     Automatically requests more rows from a QUERY_IMAGE
/// </summary>
/// <param name="session">Fidessa session</param>
/// <param name="queryName">Query name</param>
/// <param name="userName">User name</param>
/// <param name="count">
///     <para>when specified, continue to request rows while the # of rows returns are less than count</para>
///     <para>when null, QUERY_MORE will be sent when MORE = 1</para>
/// </param>