Bump json5 from 2.2.1 to 2.2.3 in /TeamHub/src/TeamHub.Web

.gitignore

@@ -347,3 +347,5 @@ MigrationBackup/
 
 # Ionide (cross platform F# VS Code tools) working folder
 .ionide/
+/MicroserviceTemplate/src/.logs
+/MicroserviceTemplate/src/shared-local-instance.db

CodeKata/CSharp/CodeKata.CSharp.csproj

@@ -2,10 +2,12 @@
 
   <PropertyGroup>
     <OutputType>Exe</OutputType>
-    <TargetFramework>net5.0</TargetFramework>
+    <TargetFramework>net6.0</TargetFramework>
   </PropertyGroup>
 
   <ItemGroup>
+    <PackageReference Include="AWSSDK.SQS" Version="3.7.2.117" />
+    <PackageReference Include="BenchmarkDotNet" Version="0.13.2" />
     <PackageReference Include="SmallSharp" Version="1.1.5" />
     <PackageReference Include="System.Security.Principal.Windows" Version="5.0.0" />
   </ItemGroup>

CodeKata/CSharp/Helpers/Benchmark/Kata3_BenchmarkHelper.cs

@@ -0,0 +1,33 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using BenchmarkDotNet.Attributes;
+
+namespace CodeKata.CSharp.Helpers.Benchmark
+{
+    [MemoryDiagnoser(false)]
+    public class Kata3_BenchmarkHelper
+    {
+        private static readonly Random Rng = new(100);
+
+        public int Size { get; set; } = 100;
+
+        private List<int> _items;
+
+        [GlobalSetup]
+        public void Setup()
+        {
+            _items = Enumerable.Range(1, Size).Select(x => Rng.Next()).ToList();
+        }
+
+        [Benchmark]
+        public void ForEach()
+        {
+            foreach (var item in _items)
+            {
+            }
+        }
+    }
+}

CodeKata/CSharp/Helpers/Kata4/JobCreated.cs

@@ -0,0 +1,15 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Text.Json.Serialization;
+using System.Threading.Tasks;
+
+namespace CodeKata.CSharp.Helpers.Kata4
+{
+    internal class JobCreated
+    {
+        [JsonPropertyName("id")]
+        public int Id { get; set; }
+    }
+}

CodeKata/CSharp/Kata3_Iteration_Benchmark.cs

@@ -0,0 +1,6 @@
+using System;
+using BenchmarkDotNet.Running;
+using CodeKata.CSharp.Helpers.Benchmark;
+
+BenchmarkRunner.Run<Kata3_BenchmarkHelper>();
+Console.ReadLine();

CodeKata/CSharp/Kata4_AWS_SQS.cs

@@ -0,0 +1,64 @@
+/*
+ * AWS CLI
+ * aws --endpoint-url=http://localhost:4566 sqs create-queue --queue-name myQueue
+ * aws --endpoint-url=http://localhost:4566 sqs list-queues
+ * aws --endpoint-url=http://localhost:4566 sqs delete-queue --queue-url <value>
+*/
+
+using Amazon.SQS;
+using Amazon.SQS.Model;
+using CodeKata.CSharp.Helpers.Kata4;
+using System;
+using System.Text.Json;
+using System.Collections.Generic;
+using System.Net;
+using System.Threading;
+
+var config = new AmazonSQSConfig();
+config.ServiceURL = "http://localhost:4566";
+var sqsClient = new AmazonSQSClient(config);
+var queueName = "myQueue";
+var queue = await sqsClient.GetQueueUrlAsync(queueName);
+
+//Add 10 items to the queue
+for (int i = 0; i < 100; i++)
+{
+    var payload = new JobCreated() { Id = i };
+
+    var request = new SendMessageRequest()
+    {
+        QueueUrl = queue.QueueUrl,
+        MessageBody = JsonSerializer.Serialize(payload)
+    };
+
+    await sqsClient.SendMessageAsync(request);
+}
+
+
+var ct = new CancellationToken();
+
+while (!ct.IsCancellationRequested)
+{
+    var receiveRequest = new ReceiveMessageRequest()
+    {
+        QueueUrl = queue.QueueUrl,
+        MessageAttributeNames = new List<string>() { "All" },
+        AttributeNames = new List<string>() { "All" }
+    };
+
+    var response = await sqsClient.ReceiveMessageAsync(receiveRequest);
+    if (response.HttpStatusCode != HttpStatusCode.OK)
+    {
+        //handle error
+    }
+
+    foreach (var msg in response.Messages)
+    {
+        Console.WriteLine(msg.Body);
+        //Once the message is processed we need to remove it from the queue, so it's not reprocessed.
+        await sqsClient.DeleteMessageAsync(queue.QueueUrl, msg.ReceiptHandle);
+    }
+}
+
+
+Console.ReadLine();

CodeKata/CSharp/Properties/launchSettings.json

@@ -5,6 +5,12 @@
     },
     "Kata2_EncryptionUsingCertificate.cs": {
       "commandName": "Project"
+    },
+    "Kata3_Iteration_Benchmark.cs": {
+      "commandName": "Project"
+    },
+    "Kata4_AWS_SQS.cs": {
+      "commandName": "Project"
     }
   }
 }

CodeKata/CodeKata.sln

@@ -1,10 +1,15 @@
 
 Microsoft Visual Studio Solution File, Format Version 12.00
-# Visual Studio Version 16
-VisualStudioVersion = 16.0.30717.126
+# Visual Studio Version 17
+VisualStudioVersion = 17.2.32505.173
 MinimumVisualStudioVersion = 10.0.40219.1
 Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "CodeKata.CSharp", "CSharp\CodeKata.CSharp.csproj", "{19C1553D-2D8D-4B63-8DD4-DA2A7A8EF3AD}"
 EndProject
+Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "Solution Items", "Solution Items", "{7D70EF4E-11A4-4C8A-93D2-EFD448BFE1F6}"
+	ProjectSection(SolutionItems) = preProject
+		Readme.md = Readme.md
+	EndProjectSection
+EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
 		Debug|Any CPU = Debug|Any CPU

CodeKata/Readme.md

@@ -0,0 +1,6 @@
+Fluent API: 
+https://www.c-sharpcorner.com/article/creating-a-fluent-api-in-c-sharp-net/
+https://www.youtube.com/watch?v=1JAdZul-aRQ
+
+Object Mapping: 
+https://gist.github.com/leandromonaco/6d05108810efb48c0c27f7c6f8d26d44

IntegrationConnectors/src/IntegrationConnectors.Bitbucket/BitbucketConnector.cs

@@ -0,0 +1,47 @@
+using System.Text.Json;
+using IntegrationConnectors.Common;
+
+namespace IntegrationConnectors.Bitbucket
+{
+    public class BitbucketConnector: HttpConnector
+    {
+        public BitbucketConnector(string baseUrl, string apiKey, AuthenticationType authType) : base(baseUrl, apiKey, authType)
+        {
+
+        }
+
+        public async Task<List<BitbucketBranch>> GetBranchesAsync(string company, string repository)
+        {
+            var pageNumber = 1;
+            var allBranches = new List<BitbucketBranch>();
+            var branches = new BitbucketBranches() { Values = new List<BitbucketBranch>() { new BitbucketBranch() } };
+
+            while (branches.Values.Count > 0)
+            {
+                var response = await GetAsync($"{_url}/2.0/repositories/{company}/{repository}/refs/branches?page={pageNumber}&pagelen=100");
+                branches = JsonSerializer.Deserialize<BitbucketBranches>(response, _jsonSerializerOptions);
+                allBranches.AddRange(branches.Values);
+                pageNumber++;
+            }
+
+            return allBranches.OrderByDescending(b => b.Target.Date).ToList();
+        }
+
+        public async Task<List<BitBucketPullRequest>> GetPullRequestsAsync(string company, string repository)
+        {
+            var pageNumber = 1;
+            var allPullRequests = new List<BitBucketPullRequest>();
+            var pullRequests = new BitBucketPullRequests() { Values = new List<BitBucketPullRequest>() { new BitBucketPullRequest() } };
+
+            while (pullRequests.Values.Count > 0)
+            {
+                var response = await GetAsync($"{_url}/2.0/repositories/{company}/{repository}/pullrequests?page={pageNumber}");
+                pullRequests = JsonSerializer.Deserialize<BitBucketPullRequests>(response, _jsonSerializerOptions);
+                allPullRequests.AddRange(pullRequests.Values);
+                pageNumber++;
+            }
+
+            return allPullRequests.OrderByDescending(pr => pr.Created).ToList();
+        }
+    }
+}

IntegrationConnectors/src/IntegrationConnectors.Bitbucket/IntegrationConnectors.Bitbucket.csproj

@@ -0,0 +1,13 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <TargetFramework>net6.0</TargetFramework>
+    <ImplicitUsings>enable</ImplicitUsings>
+    <Nullable>enable</Nullable>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\IntegrationConnectors.Common\IntegrationConnectors.Common.csproj" />
+  </ItemGroup>
+
+</Project>

IntegrationConnectors/src/IntegrationConnectors.Bitbucket/Model/Author.cs

@@ -0,0 +1,24 @@
+using System.Text.RegularExpressions;
+
+namespace IntegrationConnectors.Bitbucket
+{
+    public class Author
+    {
+        public string Raw { get; set; }
+
+        public User User { get; set; }
+
+        public string UserEmail
+        {
+            get
+            {
+                // Create a pattern for a word that starts with letter "M"  
+                string pattern = @"<.*>";
+                // Create a Regex  
+                Regex rg = new Regex(pattern);
+                MatchCollection matchedAuthors = rg.Matches(Raw);
+                return matchedAuthors[0].Value;
+            }
+        }
+    }
+}

IntegrationConnectors/src/IntegrationConnectors.Bitbucket/Model/BitBucketDestination.cs

@@ -0,0 +1,7 @@
+namespace IntegrationConnectors.Bitbucket
+{
+    public class BitBucketDestination
+    {
+        public BitBucketRepository Repository { get; set; }
+    }
+}

IntegrationConnectors/src/IntegrationConnectors.Bitbucket/Model/BitBucketLinkHtml.cs

@@ -0,0 +1,7 @@
+namespace IntegrationConnectors.Bitbucket
+{
+    public class BitBucketLinkHtml
+    {
+        public string Href { get; set; }
+    }
+}

IntegrationConnectors/src/IntegrationConnectors.Bitbucket/Model/BitBucketLinks.cs

@@ -0,0 +1,7 @@
+namespace IntegrationConnectors.Bitbucket
+{
+    public class BitBucketLinks
+    {
+        public BitBucketLinkHtml Html { get; set; }
+    }
+}

IntegrationConnectors/src/IntegrationConnectors.Bitbucket/Model/BitBucketPullRequest.cs

@@ -0,0 +1,13 @@
+using System.Text.Json.Serialization;
+
+namespace IntegrationConnectors.Bitbucket
+{
+    public class BitBucketPullRequest
+    {
+        public string Title { get; set; }
+        [JsonPropertyName("created_on")]
+        public DateTime Created { get; set; }
+        public BitBucketLinks Links { get; set; }
+        public BitBucketDestination Destination { get; set; }
+    }
+}

IntegrationConnectors/src/IntegrationConnectors.Bitbucket/Model/BitBucketPullRequests.cs

@@ -0,0 +1,7 @@
+namespace IntegrationConnectors.Bitbucket
+{
+    public class BitBucketPullRequests
+    {
+        public List<BitBucketPullRequest> Values { get; set; }
+    }
+}

IntegrationConnectors/src/IntegrationConnectors.Bitbucket/Model/BitBucketRepository.cs

@@ -0,0 +1,7 @@
+namespace IntegrationConnectors.Bitbucket
+{
+    public class BitBucketRepository
+    {
+        public string Name { get; set; }
+    }
+}

IntegrationConnectors/src/IntegrationConnectors.Bitbucket/Model/BitbucketBranch.cs

@@ -0,0 +1,12 @@
+namespace IntegrationConnectors.Bitbucket
+{
+    public class BitbucketBranch
+    {
+        public string Name { get; set; }
+
+        public Target Target { get; set; }
+
+        public BitBucketLinks Links { get; set; }
+
+    }
+}

IntegrationConnectors/src/IntegrationConnectors.Bitbucket/Model/BitbucketBranches.cs

@@ -0,0 +1,9 @@
+
+
+namespace IntegrationConnectors.Bitbucket
+{
+    public class BitbucketBranches
+    {
+        public List<BitbucketBranch> Values { get; set; }
+    }
+}

IntegrationConnectors/src/IntegrationConnectors.Bitbucket/Model/Target.cs

@@ -0,0 +1,8 @@
+namespace IntegrationConnectors.Bitbucket
+{
+    public class Target
+    {
+        public Author Author { get; set; }
+        public DateTime Date { get; set; }
+    }
+}