-
Notifications
You must be signed in to change notification settings - Fork 1
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Clear response param after group. Update readme.
- Loading branch information
Showing
6 changed files
with
162 additions
and
91 deletions.
There are no files selected for viewing
Loading
Sorry, something went wrong. Reload?
Sorry, we cannot display this file.
Sorry, this file is invalid so it cannot be displayed.
Loading
Sorry, something went wrong. Reload?
Sorry, we cannot display this file.
Sorry, this file is invalid so it cannot be displayed.
176 changes: 91 additions & 85 deletions
176
QAction_1/PollManager/ResponseHandler/Repositories/TagsResponseHandler.cs
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,91 +1,97 @@ | ||
| namespace Skyline.Protocol.PollManager.ResponseHandler.Repositories | ||
| { | ||
| using System; | ||
| using System.Collections.Generic; | ||
| using System.Linq; | ||
| using System.Text.RegularExpressions; | ||
|
|
||
| using Newtonsoft.Json; | ||
|
|
||
| using Skyline.DataMiner.Scripting; | ||
| using Skyline.DataMiner.Utils.Github.API.V20221128.Repositories; | ||
| using Skyline.Protocol; | ||
| using Skyline.Protocol.API.Headers; | ||
| using Skyline.Protocol.Extensions; | ||
| using Skyline.Protocol.PollManager.RequestHandler.Repositories; | ||
| using Skyline.Protocol.Tables; | ||
|
|
||
| public static partial class RepositoriesResponseHandler | ||
| { | ||
| public static void HandleRepositoriesTagsResponse(SLProtocol protocol) | ||
| { | ||
| // Check status code | ||
| if (!protocol.IsSuccessStatusCode()) | ||
| { | ||
| return; | ||
| } | ||
|
|
||
| // Parse response | ||
| var response = JsonConvert.DeserializeObject<List<RepositoryTagsResponse>>(Convert.ToString(protocol.GetParameter(Parameter.getrepositorytagscontent))); | ||
|
|
||
| if (response == null) | ||
| { | ||
| protocol.Log($"QA{protocol.QActionID}|ParseGetRepositoryTagsResponse|response was null.", LogType.Error, LogLevel.Level1); | ||
| return; | ||
| } | ||
|
|
||
| if (!response.Any()) | ||
| { | ||
| using System; | ||
| using System.Collections.Generic; | ||
| using System.Linq; | ||
| using System.Text.RegularExpressions; | ||
|
|
||
| using Newtonsoft.Json; | ||
|
|
||
| using Skyline.DataMiner.Scripting; | ||
| using Skyline.DataMiner.Utils.Github.API.V20221128.Repositories; | ||
| using Skyline.Protocol; | ||
| using Skyline.Protocol.API.Headers; | ||
| using Skyline.Protocol.Extensions; | ||
| using Skyline.Protocol.PollManager.RequestHandler.Repositories; | ||
| using Skyline.Protocol.Tables; | ||
|
|
||
| public static partial class RepositoriesResponseHandler | ||
| { | ||
| public static void HandleRepositoriesTagsResponse(SLProtocol protocol) | ||
| { | ||
| // Check status code | ||
| if (!protocol.IsSuccessStatusCode()) | ||
| { | ||
| return; | ||
| } | ||
|
|
||
| // Parse response | ||
| var response = JsonConvert.DeserializeObject<List<RepositoryTagsResponse>>(Convert.ToString(protocol.GetParameter(Parameter.getrepositorytagscontent))); | ||
|
|
||
| if (response == null) | ||
| { | ||
| protocol.Log($"QA{protocol.QActionID}|ParseGetRepositoryTagsResponse|response was null.", LogType.Error, LogLevel.Level1); | ||
| return; | ||
| } | ||
|
|
||
| if (!response.Any()) | ||
| { | ||
| // No tags for the repository | ||
| protocol.Log($"QA{protocol.QActionID}|ParseGetRepositoryTagsResponse|No tags for the repo.", LogType.Information, LogLevel.Level2); | ||
| return; | ||
| } | ||
|
|
||
| // Parse url to check which respository this issue is linked to | ||
| var pattern = "https:\\/\\/api.github.com\\/repos\\/(.*)\\/(.*)\\/commits\\/(.*)"; | ||
| var options = RegexOptions.Multiline; | ||
|
|
||
| var match = Regex.Match(response[0]?.Commit.Url, pattern, options); | ||
| var owner = match.Groups[1].Value; | ||
| var name = match.Groups[2].Value; | ||
|
|
||
| // Update the tags table | ||
| var table = RepositoryTagsTable.GetTable(); | ||
| foreach (var tag in response) | ||
| { | ||
| if (tag == null) | ||
| { | ||
| protocol.Log($"QA{protocol.QActionID}|GetRepositoryTagsResponse|Tag was null.", LogType.Error, LogLevel.Level1); | ||
| continue; | ||
| } | ||
|
|
||
| table.Rows.Add(new RepositoryTagsTableRow | ||
| { | ||
| ID = $"{owner}/{name}/commits/{tag.Name}", | ||
| Name = tag.Name, | ||
| RepositoryID = $"{owner}/{name}", | ||
| CommitSHA = tag.Commit?.Sha ?? Exceptions.NotAvailable, | ||
| }); | ||
| } | ||
|
|
||
| if (table.Rows.Count > 0) | ||
| { | ||
| table.SaveToProtocol(protocol, true); | ||
| } | ||
|
|
||
| // Check if there are more tags to fetch | ||
| var linkHeader = Convert.ToString(protocol.GetParameter(Parameter.getrepositorytagslinkheader)); | ||
| if (string.IsNullOrEmpty(linkHeader)) return; | ||
|
|
||
| var link = new LinkHeader(linkHeader); | ||
|
|
||
| protocol.Log($"QA{protocol.QActionID}|ParseGetRepositoryTagsResponse|Current page: {link.CurrentPage}", LogType.Information, LogLevel.Level2); | ||
| protocol.Log($"QA{protocol.QActionID}|ParseGetRepositoryTagsResponse|Has next page: {link.HasNext}", LogType.Information, LogLevel.Level2); | ||
|
|
||
| if (link.HasNext) | ||
| { | ||
| RepositoriesRequestHandler.HandleRepositoriesTagsRequest(protocol, owner, name, PollingConstants.PerPage, link.NextPage); | ||
| } | ||
| } | ||
| } | ||
| } | ||
|
|
||
| // Parse url to check which respository this issue is linked to | ||
| var pattern = "https:\\/\\/api.github.com\\/repos\\/(.*)\\/(.*)\\/commits\\/(.*)"; | ||
| var options = RegexOptions.Multiline; | ||
|
|
||
| var match = Regex.Match(response[0]?.Commit.Url, pattern, options); | ||
| var owner = match.Groups[1].Value; | ||
| var name = match.Groups[2].Value; | ||
|
|
||
| // Update the tags table | ||
| var table = RepositoryTagsTable.GetTable(); | ||
| foreach (var tag in response) | ||
| { | ||
| if (tag == null) | ||
| { | ||
| protocol.Log($"QA{protocol.QActionID}|GetRepositoryTagsResponse|Tag was null.", LogType.Error, LogLevel.Level1); | ||
| continue; | ||
| } | ||
|
|
||
| // Update existing workflow if found, otherwise create new one | ||
| var id = $"{owner}/{name}/commits/{tag.Name}"; | ||
| var row = table.Rows.Find(wf => wf.ID == id) ?? new RepositoryTagsTableRow(); | ||
| row.Name = tag.Name; | ||
| row.RepositoryID = $"{owner}/{name}"; | ||
| row.CommitSHA = tag.Commit?.Sha ?? Exceptions.NotAvailable; | ||
|
|
||
| // If its a new row fill in ID and add it to the table. | ||
| if (String.IsNullOrEmpty(row.ID)) | ||
| { | ||
| row.ID = id; | ||
| table.Rows.Add(row); | ||
| } | ||
| } | ||
|
|
||
| if (table.Rows.Count > 0) | ||
| { | ||
| table.SaveToProtocol(protocol, true); | ||
| } | ||
|
|
||
| // Check if there are more tags to fetch | ||
| var linkHeader = Convert.ToString(protocol.GetParameter(Parameter.getrepositorytagslinkheader)); | ||
| if (string.IsNullOrEmpty(linkHeader)) return; | ||
|
|
||
| var link = new LinkHeader(linkHeader); | ||
|
|
||
| protocol.Log($"QA{protocol.QActionID}|ParseGetRepositoryTagsResponse|Current page: {link.CurrentPage}", LogType.Information, LogLevel.Level2); | ||
| protocol.Log($"QA{protocol.QActionID}|ParseGetRepositoryTagsResponse|Has next page: {link.HasNext}", LogType.Information, LogLevel.Level2); | ||
|
|
||
| if (link.HasNext) | ||
| { | ||
| RepositoriesRequestHandler.HandleRepositoriesTagsRequest(protocol, owner, name, PollingConstants.PerPage, link.NextPage); | ||
| } | ||
| } | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters