summaryrefslogtreecommitdiffstats
path: root/internal/storage/deletions.go
diff options
context:
space:
mode:
authorbndw <ben@bdw.to>2026-02-13 20:36:12 -0800
committerbndw <ben@bdw.to>2026-02-13 20:36:12 -0800
commit89b8948195f24df127b7ae656ab3f60bd1b49ac7 (patch)
tree2c6fc91e053039e4ad53ee0a72038b1b99f8c50c /internal/storage/deletions.go
parent656748ea286ff7eac6cbe1b241ad31212892ba61 (diff)
refactor: simplify deletion handling (remove NIP-09 processing)
Remove deletion processing logic in favor of simpler approach: - Remove deletions table from schema - Delete deletions.go and deletions_test.go - Remove ProcessDeletion from EventStore interface - Kind 5 events now stored like any other event (no special handling) - Update storage test to expect 2 tables instead of 3 - All 41 tests passing
Diffstat (limited to 'internal/storage/deletions.go')
-rw-r--r--internal/storage/deletions.go70
1 files changed, 0 insertions, 70 deletions
diff --git a/internal/storage/deletions.go b/internal/storage/deletions.go
deleted file mode 100644
index 1a07e3c..0000000
--- a/internal/storage/deletions.go
+++ /dev/null
@@ -1,70 +0,0 @@
1package storage
2
3import (
4 "context"
5 "fmt"
6
7 pb "northwest.io/nostr-grpc/api/nostr/v1"
8)
9
10const KindDeletion = 5
11
12func (s *Storage) ProcessDeletion(ctx context.Context, deletionEvent *pb.Event) error {
13 if deletionEvent.Kind != KindDeletion {
14 return fmt.Errorf("not a deletion event")
15 }
16
17 var eventIDsToDelete []string
18 for _, tag := range deletionEvent.Tags {
19 if len(tag.Values) >= 2 && tag.Values[0] == "e" {
20 eventIDsToDelete = append(eventIDsToDelete, tag.Values[1])
21 }
22 }
23
24 if len(eventIDsToDelete) == 0 {
25 return nil
26 }
27
28 tx, err := s.db.BeginTx(ctx, nil)
29 if err != nil {
30 return fmt.Errorf("failed to begin transaction: %w", err)
31 }
32 defer tx.Rollback()
33
34 for _, eventID := range eventIDsToDelete {
35 var eventPubkey string
36 err := tx.QueryRowContext(ctx,
37 "SELECT pubkey FROM events WHERE id = ? AND deleted = 0",
38 eventID,
39 ).Scan(&eventPubkey)
40
41 if err != nil {
42 continue
43 }
44
45 if eventPubkey != deletionEvent.Pubkey {
46 continue
47 }
48
49 _, err = tx.ExecContext(ctx,
50 "UPDATE events SET deleted = 1 WHERE id = ?",
51 eventID,
52 )
53 if err != nil {
54 return fmt.Errorf("failed to mark event as deleted: %w", err)
55 }
56
57 _, err = tx.ExecContext(ctx,
58 "INSERT OR IGNORE INTO deletions (deleted_event_id, deletion_event_id, pubkey, created_at) VALUES (?, ?, ?, ?)",
59 eventID,
60 deletionEvent.Id,
61 deletionEvent.Pubkey,
62 deletionEvent.CreatedAt,
63 )
64 if err != nil {
65 return fmt.Errorf("failed to record deletion: %w", err)
66 }
67 }
68
69 return tx.Commit()
70}