Fix profile request

NostrServices.Client/NostrServicesClient.cs

@@ -18,12 +18,13 @@ public class NostrServicesClient
 
     public async Task<CompactProfile?> Profile(string id)
     {
-        return await Get<CompactProfile>(HttpMethod.Get, $"/api/v1/export/profile/{id}");
+        var ev = await Get<NostrEvent>(HttpMethod.Get, $"https://nostr-rs.api.v0l.io/event/0/{id}");
+        return ev != default ? CompactProfile.FromNostrEvent(ev) : default;
     }
 
     public async Task<NostrEvent?> Event(string id)
     {
-        return await Get<NostrEvent>(HttpMethod.Get, $"/api/v1/export/{id}");
+        return await Get<NostrEvent>(HttpMethod.Get, $"https://nostr-rs.api.v0l.io/event/{id}");
     }
 
     public async Task<LinkPreviewData?> LinkPreview(string url)

NostrServices/Controllers/AvatarController.cs

@@ -0,0 +1,30 @@
+using System.Text;
+using Microsoft.AspNetCore.Mvc;
+
+namespace NostrServices.Controllers;
+
+[Route("/api/v1/avatar")]
+public class AvatarController : Controller
+{
+    /// <summary>
+    /// Robohash avatar endpoints
+    /// </summary>
+    /// <remarks>
+    /// Available sets: `cyberpunks` / `robots` / `zombies`
+    /// </remarks>
+    /// <param name="set"></param>
+    /// <param name="value">Any value, can contain a file extension, response is only image/webp</param>
+    /// <returns></returns>
+    [HttpGet("{set}/{value}")]
+    [ResponseCache(Location = ResponseCacheLocation.Any, Duration = 86400)]
+    public IActionResult GetAvatar([FromRoute] string set, [FromRoute] string value)
+    {
+        var hash = System.Security.Cryptography.SHA256.HashData(
+            Encoding.UTF8.GetBytes(Path.GetFileNameWithoutExtension(value)));
+        var hashInt = BitConverter.ToInt32(hash);
+        var dir = Path.Combine(Directory.GetCurrentDirectory(), "wwwroot", set);
+        var fileList = Directory.EnumerateFiles(dir, "*.webp").ToList();
+        var pickImg = fileList[Math.Abs(hashInt % fileList.Count)];
+        return PhysicalFile(pickImg, "image/webp");
+    }
+}

NostrServices/Controllers/OpenGraphController.cs

@@ -14,17 +14,8 @@ namespace NostrServices.Controllers;
 /// Add OpenGraph tags to html documents
 /// </summary>
 [Route("/api/v1/opengraph")]
-public class OpenGraphController : Controller
+public class OpenGraphController(ILogger<OpenGraphController> logger, RedisStore redisStore) : Controller
 {
-    private readonly ILogger<OpenGraphController> _logger;
-    private readonly RedisStore _redisStore;
-
-    public OpenGraphController(ILogger<OpenGraphController> logger, RedisStore redisStore)
-    {
-        _logger = logger;
-        _redisStore = redisStore;
-    }
-
     /// <summary>
     /// Inject opengraph tags into provided html
     /// </summary>
@@ -63,7 +54,7 @@ public class OpenGraphController : Controller
             {
                 if (nid.Hrp is "nevent" or "note" or "naddr")
                 {
-                    var ev = await _redisStore.GetEvent(nid);
+                    var ev = await redisStore.GetEvent(nid);
                     if (ev != default)
                     {
                         var tags = MetaTagsToElements(await GetEventTags(ev));
@@ -75,7 +66,7 @@ public class OpenGraphController : Controller
                 }
                 else if (nid.Hrp is "nprofile" or "npub")
                 {
-                    var profile = await _redisStore.GetProfile(nid.Special);
+                    var profile = await redisStore.GetProfile(nid.Special);
 
                     var meta = await GetProfileMeta(profile);
                     var tags = MetaTagsToElements([
@@ -98,7 +89,7 @@ public class OpenGraphController : Controller
             }
             catch (Exception ex) when (ex is not TaskCanceledException)
             {
-                _logger.LogWarning("Failed to inject event tags: {Message}", ex.ToString());
+                logger.LogWarning("Failed to inject event tags: {Message}", ex.ToString());
             }
         }
 
@@ -109,17 +100,20 @@ public class OpenGraphController : Controller
     {
         var ret = new List<KeyValuePair<string, string>>();
 
-        var profile = await _redisStore.GetProfile(ev.PubKey.ToHex());
+        var profile = await redisStore.GetProfile(ev.PubKey.ToHex());
         var name = profile?.Name ?? "Nostrich";
         switch (ev.Kind)
         {
             case (long)NostrKind.LiveEvent:
             {
-                var host = ev.Tags.FirstOrDefault(a => a.Key == "p" && a.Values[1] == "host")?.Values[0] ?? ev.PubKey.ToHex();
-                var hostProfile = await _redisStore.GetProfile(host);
+                var host = ev.Tags.FirstOrDefault(a => a.Key == "p" && a.Values[^1] == "host")
+                               ?.Values[0] ??
+                           ev.PubKey.ToHex();
+                var hostProfile = await redisStore.GetProfile(host);
                 var hostName = hostProfile?.Name ?? profile?.Name ?? "Nostrich";
                 var stream = ev.GetFirstTagValue("streaming") ?? ev.GetFirstTagValue("recording") ?? "";
-                var image = ev.GetFirstTagValue("image") ?? hostProfile?.Picture ?? $"https://robohash.v0l.io/{ev.PubKey.ToHex()}.png";
+                var image = ev.GetFirstTagValue("image") ??
+                            hostProfile?.Picture ?? $"https://robohash.v0l.io/{ev.PubKey.ToHex()}.png";
                 ret.AddRange(new KeyValuePair<string, string>[]
                 {
                     new("og:type", "video.other"),
@@ -145,7 +139,8 @@ public class OpenGraphController : Controller
             case 1_313: // stream clip
             {
                 var stream = ev.GetFirstTagValue("r")!;
-                var image = ev.GetFirstTagValue("image") ?? profile?.Picture ?? $"https://robohash.v0l.io/{ev.PubKey.ToHex()}.png";
+                var image = ev.GetFirstTagValue("image") ??
+                            profile?.Picture ?? $"https://robohash.v0l.io/{ev.PubKey.ToHex()}.png";
                 ret.AddRange(new KeyValuePair<string, string>[]
                 {
                     new("og:type", "video.other"),
@@ -212,14 +207,23 @@ public class OpenGraphController : Controller
 
         foreach (var ex in tags)
         {
-            var tag = doc.CreateElement(ex.Element);
+            IElement tag = doc.Head?.Children.FirstOrDefault(a =>
+            {
+                if (ex.Element == "meta")
+                {
+                    var metaPropertyA = a.Attributes.FirstOrDefault(b => b.Name == "property");
+                    var metaPropertyB = ex.Attributes.FirstOrDefault(b => b is { Key: "property" });
+                    return metaPropertyA?.Value == metaPropertyB.Value;
+                }
+
+                return false;
+            }) ?? AddNewTag(ex);
+
             foreach (var attr in ex.Attributes)
             {
                 tag.SetAttribute(attr.Key, attr.Value);
             }
 
-            doc.Head?.AppendChild(tag);
-
             var isOgTitle = ex.Attributes.Any(a => a is { Key: "property", Value: "og:title" });
             if (isOgTitle && doc.Head != default)
             {
@@ -256,6 +260,15 @@ public class OpenGraphController : Controller
                     descriptionTag.SetAttribute("content", ogDesc.Value);
                 }
             }
+
+            continue;
+
+            IElement AddNewTag(HeadElement he)
+            {
+                var tx = doc!.CreateElement(he.Element);
+                doc.Head?.AppendChild(tx);
+                return tx;
+            }
         }
 
         return doc;

NostrServices/Program.cs

@@ -35,8 +35,8 @@ public static class Program
         builder.Services.AddTransient<CacheRelay>();
         builder.Services.AddNostrEventHandlers();
         builder.Services.AddHostedService<NostrListener.NostrListenerLifetime>();
-        builder.Services.AddHostedService<RelayScraperService>();
-        builder.Services.AddHostedService<PubkeyStatsService>();
+        //builder.Services.AddHostedService<RelayScraperService>();
+        //builder.Services.AddHostedService<PubkeyStatsService>();
 
         builder.Services.AddControllers().AddNewtonsoftJson(opt =>
         {

NostrServices/Services/RedisStore.cs

@@ -1,5 +1,6 @@
 using NBitcoin;
 using Nostr.Client.Identifiers;
+using Nostr.Client.Json;
 using Nostr.Client.Messages;
 using Nostr.Client.Utils;
 using NostrServices.Client;
@@ -13,56 +14,67 @@ public class RedisStore
     private static readonly TimeSpan DefaultExpire = TimeSpan.FromDays(90);
     private readonly IDatabase _database;
     private readonly ConnectionMultiplexer _connection;
+    private readonly HttpClient _client;
 
-    public RedisStore(ConnectionMultiplexer connection)
+    public RedisStore(ConnectionMultiplexer connection, HttpClient client)
     {
         _connection = connection;
+        _client = client;
         _database = connection.GetDatabase();
     }
 
     public async Task<bool> StoreEvent(CompactEvent ev, TimeSpan? expiry = null)
     {
-        if (await _database.SetAsync(EventKey(ev.ToIdentifier()), ev, expiry ?? DefaultExpire))
-        {
-            return await _database.SetAddAsync(UserEventsKey(ev.PubKey.ToHex()), ev.Id);
-        }
-
-        return false;
+        return true;
     }
 
     public async Task<CompactEvent?> GetEvent(NostrIdentifier id)
     {
-        var ek = EventKey(id);
-        var ev = await _database.GetAsync<CompactEvent>(ek);
-        if (ev != default)
+        try
         {
-            await _database.KeyExpireAsync(ek, DefaultExpire);
+            var ev = await _client.GetAsync($"https://nostr-rs.api.v0l.io/event/{id.ToBech32()}");
+            if (ev.IsSuccessStatusCode)
+            {
+                var obj = NostrJson.Deserialize<NostrEvent>(await ev.Content.ReadAsStringAsync());
+                if (obj != default)
+                {
+                    return CompactEvent.FromNostrEvent(obj);
+                }
+            }
+        }
+        catch
+        {
+            // ignored
         }
 
-        return ev;
+        return default;
     }
 
     public async Task<bool> StoreProfile(CompactProfile meta, TimeSpan? expiry = null)
     {
-        var oldProfile = await GetProfile(meta.PubKey.ToHex());
-        if ((oldProfile?.Created ?? new DateTime()) < meta.Created)
-        {
-            return await _database.SetAsync(ProfileKey(meta.PubKey.ToHex()), meta, expiry ?? DefaultExpire);
-        }
-
-        return false;
+        return true;
     }
 
     public async Task<CompactProfile?> GetProfile(string id)
     {
-        var pk = ProfileKey(id);
-        var profile = await _database.GetAsync<CompactProfile>(pk);
-        if (profile != default)
+        try
         {
-            await _database.KeyExpireAsync(pk, DefaultExpire);
+            var ev = await _client.GetAsync($"https://nostr-rs.api.v0l.io/event/0/{id}");
+            if (ev.IsSuccessStatusCode)
+            {
+                var evo = NostrJson.Deserialize<NostrEvent>(await ev.Content.ReadAsStringAsync());
+                if (evo != default)
+                {
+                    return CompactProfile.FromNostrEvent(evo);
+                }
+            }
+        }
+        catch
+        {
+            // ignored
         }
 
-        return profile;
+        return default;
     }
 
     public async Task<HashSet<Uri>> GetKnownRelays()
@@ -95,13 +107,17 @@ public class RedisStore
         if ((old?.Created ?? 0) < relays.Created)
         {
             var removed = old?.Relays.Where(a => relays.Relays.All(b => b.Url != a.Url));
-            var added = old == default ? relays.Relays : relays.Relays.Where(a => old.Relays.All(b => b.Url != a.Url)).ToList();
+            var added = old == default
+                ? relays.Relays
+                : relays.Relays.Where(a => old.Relays.All(b => b.Url != a.Url)).ToList();
             if (removed != default)
             {
-                await Task.WhenAll(removed.Select(a => _database.SetRemoveAsync(RelayUsersKey(a.Url), Convert.FromHexString(pubkey))));
+                await Task.WhenAll(removed.Select(a =>
+                    _database.SetRemoveAsync(RelayUsersKey(a.Url), Convert.FromHexString(pubkey))));
             }
 
-            await Task.WhenAll(added.Select(a => _database.SetAddAsync(RelayUsersKey(a.Url), Convert.FromHexString(pubkey))));
+            await Task.WhenAll(added.Select(a =>
+                _database.SetAddAsync(RelayUsersKey(a.Url), Convert.FromHexString(pubkey))));
             await _database.SetAddAsync("relays", added.Select(a => (RedisValue)a.Url.ToString()).ToArray());
 
             return await _database.SetAsync(UserRelaysKey(pubkey), relays, DefaultExpire);
@@ -136,16 +152,22 @@ public class RedisStore
 
     public async Task<List<RelayDistance>> FindCloseRelays(double lat, double lon, int radius = 50_000, int count = 10)
     {
-        var ret = new List<RelayDistance>();
-        var geoRelays = await _database.GeoSearchAsync(RelayPositionKey(), lon, lat, new GeoSearchCircle(radius), count);
+        var ret = new Dictionary<Uri, RelayDistance>();
+        var geoRelays =
+            await _database.GeoSearchAsync(RelayPositionKey(), lon, lat, new GeoSearchCircle(radius), count * 2);
         foreach (var gr in geoRelays)
         {
+            if (ret.Count == count)
+            {
+                break;
+            }
+
             var id = ((string)gr.Member!).Split('\x1');
             var u = new Uri(id[0]);
             var info = await GetRelay(u);
-            if (info != default)
+            if (info != default && !ret.ContainsKey(u))
             {
-                ret.Add(new()
+                ret.Add(u, new()
                 {
                     Distance = gr.Distance.HasValue ? (long)gr.Distance.Value : 0,
                     Relay = info,
@@ -154,7 +176,7 @@ public class RedisStore
             }
         }
 
-        return ret;
+        return ret.Values.ToList();
     }
 
     public async IAsyncEnumerable<string> EnumerateProfiles()