From 0f9a96b95d5b6735edca08257e267a8db5a1e2f8 Mon Sep 17 00:00:00 2001
From: Yasuhiro Matsumoto <mattn.jp@gmail.com>
Date: Thu, 23 May 2024 13:42:06 +0900
Subject: [PATCH] fix Query

---
 opensearch/query.go | 18 +++++++++++-------
 1 file changed, 11 insertions(+), 7 deletions(-)

diff --git a/opensearch/query.go b/opensearch/query.go
index 2efb1c9..bcc1eaf 100644
--- a/opensearch/query.go
+++ b/opensearch/query.go
@@ -87,9 +87,11 @@ func (oss *OpensearchStorage) getByID(filter nostr.Filter) ([]*nostr.Event, erro
 	for _, e := range mgetResponse.Docs {
 		if e.Found {
 			if b, err := e.Source.MarshalJSON(); err == nil {
-				var ev nostr.Event
-				if err = json.Unmarshal(b, &ev); err == nil {
-					events = append(events, &ev)
+				var payload struct {
+					Event nostr.Event `json:"event"`
+				}
+				if err = json.Unmarshal(b, &payload); err == nil {
+					events = append(events, &payload.Event)
 				}
 			}
 		}
@@ -130,7 +132,7 @@ func (oss *OpensearchStorage) QueryEvents(ctx context.Context, filter nostr.Filt
 			Indices: []string{oss.IndexName},
 			Body:    bytes.NewReader(dsl),
 			Params: opensearchapi.SearchParams{
-				Size: &limit,
+				Size: opensearchapi.ToPointer(limit),
 				Sort: []string{"event.created_at:desc"},
 			},
 		},
@@ -142,9 +144,11 @@ func (oss *OpensearchStorage) QueryEvents(ctx context.Context, filter nostr.Filt
 	go func() {
 		for _, e := range searchResponse.Hits.Hits {
 			if b, err := e.Source.MarshalJSON(); err == nil {
-				var ev nostr.Event
-				if err = json.Unmarshal(b, &ev); err == nil {
-					ch <- &ev
+				var payload struct {
+					Event nostr.Event `json:"event"`
+				}
+				if err = json.Unmarshal(b, &payload); err == nil {
+					ch <- &payload.Event
 				}
 			}
 		}