v2 clean up subscriptions

Signed-off-by: Jack Ding <[email protected]>

v1/subscriber/subscriber.go

@@ -328,8 +328,8 @@ func (p *API) DeleteSubscription(clientID uuid.UUID, subscriptionID string) erro
 	return nil
 }
 
-// DeleteAllSubscriptions  delete all subscriptionOne information
-func (p *API) DeleteAllSubscriptions(clientID uuid.UUID) error {
+// DeleteAllSubscriptionsForClient delete all subscriptionOne for the client
+func (p *API) DeleteAllSubscriptionsForClient(clientID uuid.UUID) error {
 	if subStore, ok := p.SubscriberStore.Get(clientID); ok {
 		if err := deleteAllFromFile(fmt.Sprintf("%s/%s", p.storeFilePath, fmt.Sprintf("%s.json", clientID))); err != nil {
 			return err
@@ -343,6 +343,14 @@ func (p *API) DeleteAllSubscriptions(clientID uuid.UUID) error {
 	return nil
 }
 
+// DeleteAllSubscriptions delete all subscriptions in store
+func (p *API) DeleteAllSubscriptions() error {
+	for clientID := range p.SubscriberStore.Store {
+		p.DeleteClient(clientID)
+	}
+	return nil
+}
+
 // DeleteClient  delete all subscriptionOne information
 func (p *API) DeleteClient(clientID uuid.UUID) error {
 	if _, ok := p.SubscriberStore.Get(clientID); ok { // client found