diff --git a/nostrdb/src/nostrdb.c b/nostrdb/src/nostrdb.c index 740db11a..380c43f8 100644 --- a/nostrdb/src/nostrdb.c +++ b/nostrdb/src/nostrdb.c @@ -6467,6 +6467,20 @@ int ndb_unsubscribe(struct ndb *ndb, uint64_t subid) return 1; } +struct ndb_filter *ndb_subscription_filters(struct ndb *ndb, uint64_t subid, int *filters) +{ + struct ndb_subscription *sub; + + sub = ndb_find_subscription(ndb, subid, NULL); + if (sub) { + *filters = sub->group.num_filters; + return sub->group.filters; + } + + *filters = 0; + return NULL; +} + int ndb_num_subscriptions(struct ndb *ndb) { return ndb->monitor.num_subscriptions; diff --git a/nostrdb/src/nostrdb.h b/nostrdb/src/nostrdb.h index 7f1fba42..35705121 100644 --- a/nostrdb/src/nostrdb.h +++ b/nostrdb/src/nostrdb.h @@ -521,6 +521,7 @@ int ndb_wait_for_notes(struct ndb *, uint64_t subid, uint64_t *note_ids, int not int ndb_poll_for_notes(struct ndb *, uint64_t subid, uint64_t *note_ids, int note_id_capacity); int ndb_unsubscribe(struct ndb *, uint64_t subid); int ndb_num_subscriptions(struct ndb *); +struct ndb_filter *ndb_subscription_filters(struct ndb *, uint64_t subid, int *filters); // FULLTEXT SEARCH int ndb_text_search(struct ndb_txn *txn, const char *query, struct ndb_text_search_results *, struct ndb_text_search_config *);