diff --git a/.gitignore b/.gitignore index 40c76ce..300db05 100644 --- a/.gitignore +++ b/.gitignore @@ -16,3 +16,8 @@ # vendor/ cover.out v1/subscriber/subscribers + +.idea +.cache +.dccache + diff --git a/v1/subscriber/subscriber.go b/v1/subscriber/subscriber.go index a2aac0c..66c5d9e 100644 --- a/v1/subscriber/subscriber.go +++ b/v1/subscriber/subscriber.go @@ -272,20 +272,6 @@ func (p *API) GetSubscriberURLByResource(resource string) (urls []string) { return urls } -// GetClientIDByResource get subscriptionOne information -func (p *API) GetClientIDByResource(resource string) (clientIDs []uuid.UUID) { - p.SubscriberStore.RLock() - defer p.SubscriberStore.RUnlock() - for _, subs := range p.SubscriberStore.Store { - for _, sub := range subs.SubStore.Store { - if strings.Contains(sub.GetResource(), resource) { - clientIDs = append(clientIDs, subs.ClientID) - } - } - } - return clientIDs -} - // GetClientIDBySubID ... func (p *API) GetClientIDBySubID(subID string) (clientIDs []uuid.UUID) { p.SubscriberStore.RLock() @@ -300,7 +286,7 @@ func (p *API) GetClientIDBySubID(subID string) (clientIDs []uuid.UUID) { return clientIDs } -// GetClientIDAddressByResource get subscriptionOne information +// GetClientIDAddressByResource get subscriptionOne information func (p *API) GetClientIDAddressByResource(resource string) map[uuid.UUID]*types.URI { clients := map[uuid.UUID]*types.URI{} p.SubscriberStore.RLock()