1 files changed, 121 insertions, 0 deletions
diff --git a/GitRepoViewer/Pages/GitLog.razor b/GitRepoViewer/Pages/GitLog.razor
new file mode 100644
index 0000000..e518bb6
--- /dev/null
+++ b/GitRepoViewer/Pages/GitLog.razor
@@ -0,0 +1,121 @@
+@page "/GitLog"
+@using System.Web
+@using LibGit
+@using LibGit.Extensions
+<h3>GitLog</h3>
+<p>Repo: @Repo</p>
+
+@if (heads.Count > 0)
+{
+ <p>
+ Revision:
+ <details>
+ <summary>@Rev</summary>
+ </details>
+ </p>
+}
+
+@if (commits != null)
+{
+ <table class="table">
+ <thead>
+ <tr>
+ <th>Heads</th>
+ <th>Commit</th>
+ <th>Author</th>
+ <th>Message</th>
+ </tr>
+ </thead>
+ <tbody>
+ @foreach (var commit in commits)
+ {
+ <tr>
+ <td>
+ @foreach (var _ref in heads.Where(x=>x.CommitId == commit.CommitId))
+ {
+ <p>@_ref.Name</p>
+ }
+ </td>
+ <td>@commit.CommitId[..7]</td>
+ <td>@commit.AuthorName</td>
+ <td>@commit.Message</td>
+ </tr>
+ }
+ </tbody>
+ </table>
+}
+
+@code {
+
+ string? Repo { get; set; }
+ string? Rev { get; set; }
+
+ List<CommitObject> commits = new();
+ List<GitRef> heads = new();
+
+ protected override async Task OnInitializedAsync()
+ {
+ var query = new Uri(NavigationManager.Uri).Query;
+ var queryDictionary = HttpUtility.ParseQueryString(query);
+ if((Repo = queryDictionary["repo"]) == null)
+ {
+ return;
+ }
+
+ var repo = new GitRepo(new WebRepoSource(queryDictionary["repo"])
+ {
+ SessionStorage = sessionStorage
+ });
+
+ if((Rev = queryDictionary["rev"]) == null)
+ {
+ Rev = "HEAD";
+ }
+
+ var ss = new SemaphoreSlim(2,2);
+
+ var _heads = repo.GetRefs().GetAsyncEnumerator();
+ while (await _heads.MoveNextAsync())
+ {
+ heads.Add(_heads.Current);
+ var isCached = await ((WebRepoSource)repo.RepoSource).HasObjectCached(_heads.Current.CommitId);
+ Console.WriteLine(_heads.Current.Name+ " - cache miss: " + !isCached);
+ if (!isCached)
+ {
+
+ var _c = _heads.Current.CommitId;
+#pragma warning disable CS4014
+ Task.Run(async () =>
+#pragma warning restore CS4014
+ {
+ await ss.WaitAsync();
+ Console.WriteLine("hi from task");
+ var a = new GitRepo(new WebRepoSource(queryDictionary["repo"])
+ {
+ SessionStorage = sessionStorage
+ }).GetCommits(_c).GetAsyncEnumerator();
+ while (
+ await a.MoveNextAsync()
+ && !await ((WebRepoSource)repo.RepoSource)
+ .HasObjectCached(a.Current.CommitId)
+ ) Console.WriteLine($"Prefetched commit {a.Current.CommitId} with {a.Current.ParentIds.Count()} parents");
+ Console.WriteLine($"Reached already-cached log: {a.Current.CommitId}");
+ ss.Release();
+ });
+ }
+ }
+
+
+ var log = repo.GetCommits(heads.First(x=>x.Name == Rev).CommitId).GetAsyncEnumerator();
+ while (await log.MoveNextAsync())
+ {
+ commits.Add(log.Current);
+ if (commits.Count % 50 == 0)
+ {
+ StateHasChanged();
+ await Task.Delay(1);
+ }
+ }
+
+ }
+}
\ No newline at end of file
|
