aboutsummaryrefslogtreecommitdiffstats
path: root/Software/Visual_Studio/Web/Tango.MachineService/Security/RefreshTokenEntity.cs
blob: 2788799aab9e732036e21861daff21ab36c4ad83 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
using Microsoft.WindowsAzure.Storage.Table;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace Tango.MachineService.Security
{
    public class RefreshTokenEntity<T> : TableEntity where T : class
    {
        /// <summary>
        /// Initializes a new instance of the <see cref="RefreshTokenEntity"/> class.
        /// </summary>
        public RefreshTokenEntity()
        {

        }


        public RefreshTokenEntity(String identity, String accessToken, String refreshToken, DateTime expiration, T obj)
        {
            PartitionKey = MachineServiceConfig.REFRESH_TOKENS_TABLE_PARTITION;

            Identity = identity;
            AccessToken = accessToken;
            RefreshToken = refreshToken;
            Expiration = expiration;

            RefreshTokenEncoder<T> encoder = new RefreshTokenEncoder<T>();
            Object = encoder.Encode(obj);
        }

        [IgnoreProperty]
        public String RefreshToken
        {
            get { return RowKey; }
            set { RowKey = value; }
        }

        public String Identity { get; set; }

        public String AccessToken { get; set; }

        public DateTime Expiration { get; set; }

        public String Object { get; set; }

        public T GetObject()
        {
            RefreshTokenEncoder<T> encoder = new RefreshTokenEncoder<T>();
            return encoder.Decode(RefreshToken);
        }
    }
}
span class="w"> } } /// <summary> /// Initializes a new instance of the <see cref="RemoteSqlDataSet"/> class. /// </summary> public RemoteSqlDataSet() { Columns = new RemoteSqlColumnCollection(); Rows = new ObservableCollection<RemoteSqlRow>(); } private void OnRowsChanged() { if (Rows != null) { Rows.CollectionChanged -= Rows_CollectionChanged; Rows.CollectionChanged += Rows_CollectionChanged; InitRows(); } } private void Rows_CollectionChanged(object sender, NotifyCollectionChangedEventArgs e) { InitRows(); } private void InitRows() { if (Rows != null) { foreach (var row in Rows.ToList()) { row.Init( (key) => { return row.Values[Columns.GetIndexOf(key)]; }, (index) => { return row.Values[index]; }); } } } /// <summary> /// Creates a new <see cref="RemoteSqlDataSet"/> using the specified <see cref="SqlDataReader"/>. /// </summary> /// <param name="reader">The reader.</param> /// <returns></returns> public static Task<RemoteSqlDataSet> Load(SqlDataReader reader) { return Task.Factory.StartNew<RemoteSqlDataSet>(() => { bool columnsRead = false; RemoteSqlDataSet dataSet = new RemoteSqlDataSet(); try { while (reader.Read()) { RemoteSqlRow row = new RemoteSqlRow(); for (int i = 0; i < reader.FieldCount; i++) { if (!columnsRead) { dataSet.Columns.Add(new RemoteSqlColumn() { Name = reader.GetName(i) }); } row.Values.Add(reader.GetValue(i)); } columnsRead = true; dataSet.Rows.Add(row); } } finally { reader.Close(); } return dataSet; }); } /// <summary> /// Returns a <see cref="System.String" /> that represents this instance. /// </summary> /// <returns> /// A <see cref="System.String" /> that represents this instance. /// </returns> public override string ToString() { return String.Join(", ", Columns.Select(x => x.Name)) + "\n" + String.Join(Environment.NewLine, Rows.Select(x => x.ToString())); } /// <summary> /// Formats this dataset as a string with columns and rows. /// </summary> /// <returns></returns> public String ToTableString() { Dictionary<int, int> columnsMaxLength = new Dictionary<int, int>(); for (int i = 0; i < Columns.Count; i++) { columnsMaxLength.Add(i, Columns[i].Name.Length); } foreach (var row in Rows) { for (int i = 0; i < row.Values.Count; i++) { int valueLength = row.Values[i].ToStringSafe().Length; if (valueLength > columnsMaxLength[i]) { columnsMaxLength[i] = valueLength; } } } String str = String.Empty; for (int i = 0; i < Columns.Count; i++) { str += $"{Columns[i].Name.PadRight(columnsMaxLength[i])}{(i < Columns.Count - 1 ? " | " : "")}"; } int width = str.Length; str += Environment.NewLine + String.Empty.PadRight(width, '-'); foreach (var row in Rows) { str += Environment.NewLine; for (int i = 0; i < row.Values.Count; i++) { str += $"{row.Values[i].ToStringSafe().PadRight(columnsMaxLength[i])}{(i < Columns.Count - 1 ? " | " : "")}"; } } return str; } } }