OpenTween/Extensions.cs

   1 // OpenTween - Client of Twitter
   2 // Copyright (c) 2015 kim_upsilon (@kim_upsilon) <https://upsilo.net/~upsilon/>
   3 // All rights reserved.
   4 //
   5 // This file is part of OpenTween.
   6 //
   7 // This program is free software; you can redistribute it and/or modify it
   8 // under the terms of the GNU General Public License as published by the Free
   9 // Software Foundation; either version 3 of the License, or (at your option)
  10 // any later version.
  11 //
  12 // This program is distributed in the hope that it will be useful, but
  13 // WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY
  14 // or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
  15 // for more details.
  16 //
  17 // You should have received a copy of the GNU General Public License along
  18 // with this program. If not, see <http://www.gnu.org/licenses/>, or write to
  19 // the Free Software Foundation, Inc., 51 Franklin Street - Fifth Floor,
  20 // Boston, MA 02110-1301, USA.
  21
  22 #nullable enable
  23
  24 using System;
  25 using System.Collections.Generic;
  26 using System.Globalization;
  27 using System.Linq;
  28 using System.Text;
  29 using System.Threading;
  30 using System.Threading.Tasks;
  31 using System.Windows.Forms;
  32
  33 namespace OpenTween
  34 {
  35     internal static class Extensions
  36     {
  37         /// <summary>
  38         /// WebBrowserで選択中のテキストを取得します
  39         /// </summary>
  40         public static string GetSelectedText(this WebBrowser webBrowser)
  41         {
  42             dynamic document = webBrowser.Document.DomDocument;
  43             dynamic textRange = document.selection.createRange();
  44             string selectedText = textRange.text;
  45
  46             return selectedText;
  47         }
  48
  49         public static ReadLockTransaction BeginReadTransaction(this ReaderWriterLockSlim lockObj)
  50             => new ReadLockTransaction(lockObj);
  51
  52         public static WriteLockTransaction BeginWriteTransaction(this ReaderWriterLockSlim lockObj)
  53             => new WriteLockTransaction(lockObj);
  54
  55         public static UpgradeableReadLockTransaction BeginUpgradeableReadTransaction(this ReaderWriterLockSlim lockObj)
  56             => new UpgradeableReadLockTransaction(lockObj);
  57
  58         /// <summary>
  59         /// 一方のカルチャがもう一方のカルチャを内包するかを判断します
  60         /// </summary>
  61         public static bool Contains(this CultureInfo @this, CultureInfo that)
  62         {
  63             if (@this.Equals(that))
  64                 return true;
  65
  66             // InvariantCulture の親カルチャは InvariantCulture 自身であるため、false になったら打ち切る
  67             if (!that.Parent.Equals(that))
  68                 return Contains(@this, that.Parent);
  69
  70             return false;
  71         }
  72
  73         public static IEnumerable<(T Value, int Index)> WithIndex<T>(this IEnumerable<T> enumerable)
  74         {
  75             var i = 0;
  76             foreach (var value in enumerable)
  77                 yield return (value, i++);
  78         }
  79
  80         public static void Deconstruct<TKey, TValue>(this KeyValuePair<TKey, TValue> kvp, out TKey key, out TValue value)
  81         {
  82             key = kvp.Key;
  83             value = kvp.Value;
  84         }
  85
  86         /// <summary>
  87         /// 文字列をコードポイント単位に分割して返します
  88         /// </summary>
  89         public static IEnumerable<int> ToCodepoints(this string s)
  90         {
  91             if (s == null)
  92                 throw new ArgumentNullException(nameof(s));
  93
  94             static IEnumerable<int> GetEnumerable(string input)
  95             {
  96                 var i = 0;
  97                 var length = input.Length;
  98                 while (i < length)
  99                 {
 100                     if (char.IsSurrogatePair(input, i))
 101                     {
 102                         yield return char.ConvertToUtf32(input, i);
 103                         i += 2;
 104                     }
 105                     else
 106                     {
 107                         yield return input[i];
 108                         i++;
 109                     }
 110                 }
 111             }
 112
 113             return GetEnumerable(s);
 114         }
 115
 116         /// <summary>
 117         /// 指定された部分文字列のコードポイント単位での文字数を返す
 118         /// </summary>
 119         /// <param name="s">文字列</param>
 120         /// <param name="start">開始位置</param>
 121         /// <param name="end">終了位置</param>
 122         public static int GetCodepointCount(this string s, int start, int end)
 123         {
 124             if (s == null)
 125                 throw new ArgumentNullException(nameof(s));
 126             if (start < 0 || start > s.Length)
 127                 throw new ArgumentOutOfRangeException(nameof(start));
 128             if (end < 0 || end > s.Length)
 129                 throw new ArgumentOutOfRangeException(nameof(end));
 130             if (start > end)
 131                 throw new ArgumentOutOfRangeException(nameof(start));
 132
 133             var count = 0;
 134             for (var i = start; i < end; i += char.IsSurrogatePair(s, i) ? 2 : 1)
 135                 count++;
 136
 137             return count;
 138         }
 139
 140         public static Task ForEachAsync<T>(this IObservable<T> observable, Action<T> subscriber)
 141             => ForEachAsync(observable, value => { subscriber(value); return Task.CompletedTask; });
 142
 143         public static Task ForEachAsync<T>(this IObservable<T> observable, Func<T, Task> subscriber)
 144             => ForEachAsync(observable, subscriber, CancellationToken.None);
 145
 146         public static Task ForEachAsync<T>(this IObservable<T> observable, Action<T> subscriber, CancellationToken cancellationToken)
 147             => ForEachAsync(observable, value => { subscriber(value); return Task.CompletedTask; }, cancellationToken);
 148
 149         public static async Task ForEachAsync<T>(this IObservable<T> observable, Func<T, Task> subscriber, CancellationToken cancellationToken)
 150         {
 151             var observer = new ForEachObserver<T>(subscriber);
 152             using var unsubscriber = observable.Subscribe(observer);
 153
 154             using (cancellationToken.Register(() => unsubscriber.Dispose()))
 155                 await observer.Task.ConfigureAwait(false);
 156         }
 157
 158         private class ForEachObserver<T> : IObserver<T>
 159         {
 160             private readonly Func<T, Task> subscriber;
 161             private readonly TaskCompletionSource<int> tcs = new TaskCompletionSource<int>();
 162
 163             public Task Task
 164                 => this.tcs.Task;
 165
 166             public ForEachObserver(Func<T, Task> subscriber)
 167                 => this.subscriber = subscriber;
 168
 169             public async void OnNext(T value)
 170             {
 171                 try
 172                 {
 173                     await this.subscriber(value);
 174                 }
 175                 catch (Exception ex)
 176                 {
 177                     this.tcs.TrySetException(ex);
 178                 }
 179             }
 180
 181             public void OnCompleted()
 182                 => this.tcs.TrySetResult(1);
 183
 184             public void OnError(Exception error)
 185                 => this.tcs.TrySetException(error);
 186         }
 187     }
 188 }