+1 -1

feedgenerator.go

reviewed

··· 77 77 } 78 78 79 79 func (f *FeedGenerator) GetSubscriptionURIByRKeyAndUserDID(userDID, rkey string) (string, error) { 80 80 - return f.GetSubscriptionURIByRKeyAndUserDID(userDID, rkey) 80 80 + return f.store.GetSubscriptionURIByRKeyAndUserDID(userDID, rkey) 81 81 }

+4 -4

store/subscription.go

reviewed

··· 127 127 128 128 func (s *Store) GetSubscriptionURIByRKeyAndUserDID(userDID, rkey string) (string, error) { 129 129 sql := "SELECT subscribedPostURI FROM subscriptions WHERE subscriptionPostRkey = ? AND userDID = ?;" 130 130 - rows, err := s.db.Query(sql, userDID) 130 130 + rows, err := s.db.Query(sql, rkey, userDID) 131 131 if err != nil { 132 132 return "", fmt.Errorf("run query to get subscribed by rkey and userDID: %w", err) 133 133 } 134 134 defer rows.Close() 135 135 136 136 - var result string 137 136 for rows.Next() { 138 138 - if err := rows.Scan(&result); err != nil { 137 137 + var subscription Subscription 138 138 + if err := rows.Scan(&subscription.SubscribedPostURI); err != nil { 139 139 return "", fmt.Errorf("scan row: %w", err) 140 140 } 141 141 142 142 - return result, nil 142 142 + return subscription.SubscribedPostURI, nil 143 143 } 144 144 return "", nil 145 145 }