1 files changed, 41 insertions, 16 deletions

diff --git a/cmd/testclient/main.go b/cmd/testclient/main.go
index 571751e..224d9d9 100644
--- a/cmd/testclient/main.go
+++ b/cmd/testclient/main.go
@@ -2,8 +2,11 @@ package main
 
 import (
         "context"
+        "encoding/json"
         "flag"
+        "io"
         "log"
+        "os"
         "time"
 
         "google.golang.org/grpc"
@@ -26,23 +29,45 @@ func main() {
         client := pb.NewNostrRelayClient(conn)
         ctx := context.Background()
 
-        key, err := nostr.GenerateKey()
-        if err != nil {
-                log.Fatalf("failed to generate key: %v", err)
-        }
+        var event *nostr.Event
+
+        stat, _ := os.Stdin.Stat()
+        if (stat.Mode() & os.ModeCharDevice) == 0 {
+                data, err := io.ReadAll(os.Stdin)
+                if err != nil {
+                        log.Fatalf("failed to read stdin: %v", err)
+                }
+
+                event = &nostr.Event{}
+                if err := json.Unmarshal(data, event); err != nil {
+                        log.Fatalf("failed to parse JSON event: %v", err)
+                }
+
+                log.Printf("Read event from stdin: %s", event.ID[:16])
+        } else {
+                key, err := nostr.GenerateKey()
+                if err != nil {
+                        log.Fatalf("failed to generate key: %v", err)
+                }
+
+                log.Printf("Generated key: %s", key.Npub())
 
-        log.Printf("Generated key: %s", key.Npub())
+                event = &nostr.Event{
+                        PubKey:    key.Public(),
+                        CreatedAt: time.Now().Unix(),
+                        Kind:      1,
+                        Tags:      nostr.Tags{},
+                        Content:   "Hello from gRPC client!",
+                }
 
-        event := &nostr.Event{
-                PubKey:    key.Public(),
-                CreatedAt: time.Now().Unix(),
-                Kind:      1,
-                Tags:      nostr.Tags{},
-                Content:   "Hello from gRPC client!",
+                if err := key.Sign(event); err != nil {
+                        log.Fatalf("failed to sign event: %v", err)
+                }
         }
 
-        if err := key.Sign(event); err != nil {
-                log.Fatalf("failed to sign event: %v", err)
+        tags := make([]*pb.Tag, len(event.Tags))
+        for i, tag := range event.Tags {
+                tags[i] = &pb.Tag{Values: tag}
         }
 
         pbEvent := &pb.Event{
@@ -50,7 +75,7 @@ func main() {
                 Pubkey:    event.PubKey,
                 CreatedAt: event.CreatedAt,
                 Kind:      int32(event.Kind),
-                Tags:      []*pb.Tag{},
+                Tags:      tags,
                 Content:   event.Content,
                 Sig:       event.Sig,
         }
@@ -71,14 +96,14 @@ func main() {
         log.Println("Querying events...")
         queryResp, err := client.QueryEvents(ctx, &pb.QueryRequest{
                 Filters: []*pb.Filter{
-                        {Authors: []string{key.Public()}},
+                        {Authors: []string{event.PubKey}},
                 },
         })
         if err != nil {
                 log.Fatalf("failed to query: %v", err)
         }
 
-        log.Printf("Found %d events", len(queryResp.Events))
+        log.Printf("Found %d events from author %s", len(queryResp.Events), event.PubKey[:16])
         for _, e := range queryResp.Events {
                 log.Printf("  - %s: %s", e.Id[:16], e.Content)
         }