grpc-gateway: remove unused functions

Author: Danielius1922

grpc-gateway/client/client.go

@@ -16,7 +16,6 @@ import (
 	kitNetGrpc "github.com/plgd-dev/hub/pkg/net/grpc"
 	"github.com/plgd-dev/hub/resource-aggregate/commands"
 	"github.com/plgd-dev/hub/resource-aggregate/events"
-	"github.com/plgd-dev/kit/v2/strings"
 )
 
 type ApplicationCallback interface {
@@ -156,46 +155,6 @@ func (c *Client) GetResourceLinksViaCallback(ctx context.Context, deviceIDs, res
 	return it.Err
 }
 
-type TypeCallback struct {
-	Type     string
-	Callback func(*pb.Resource)
-}
-
-func MakeTypeCallback(resourceType string, callback func(*pb.Resource)) TypeCallback {
-	return TypeCallback{Type: resourceType, Callback: callback}
-}
-
-// GetResourcesByType gets contents of resources by resource types. JWT token must be stored in context for grpc call.
-func (c *Client) GetResourcesByType(
-	ctx context.Context,
-	deviceIDs []string,
-	typeCallbacks ...TypeCallback,
-) error {
-	tc := make(map[string]func(*pb.Resource), len(typeCallbacks))
-	resourceTypes := make([]string, 0, len(typeCallbacks))
-	for _, c := range typeCallbacks {
-		tc[c.Type] = c.Callback
-		resourceTypes = append(resourceTypes, c.Type)
-	}
-
-	it := c.GetResourcesIterator(ctx, nil, deviceIDs, resourceTypes...)
-	defer it.Close()
-
-	for {
-		var v pb.Resource
-		if !it.Next(&v) {
-			break
-		}
-		for _, rt := range resourceTypes {
-			if strings.SliceContains(v.Types, rt) {
-				tc[rt](&v)
-				break
-			}
-		}
-	}
-	return it.Err
-}
-
 // GetDevicesIterator gets devices. JWT token must be stored in context for grpc call.
 // Next queries the next resource value.
 // Returns false when failed or having no more items.

grpc-gateway/client/deviceSubscription.go

@@ -49,14 +49,3 @@ func (s *DeviceSubscription) Cancel() (wait func(), err error) {
 func (s *DeviceSubscription) ID() string {
 	return s.id
 }
-
-func ToDeviceSubscription(v interface{}, ok bool) (*DeviceSubscription, bool) {
-	if !ok {
-		return nil, false
-	}
-	if v == nil {
-		return nil, false
-	}
-	s, ok := v.(*DeviceSubscription)
-	return s, ok
-}

grpc-gateway/client/deviceSubscriptions.go

@@ -548,14 +548,3 @@ func (s *DeviceSubscriptions) runRecv() {
 		s.handleEvent(ev)
 	}
 }
-
-func ToDeviceSubscriptions(v interface{}, ok bool) (*DeviceSubscriptions, bool) {
-	if !ok {
-		return nil, false
-	}
-	if v == nil {
-		return nil, false
-	}
-	s, ok := v.(*DeviceSubscriptions)
-	return s, ok
-}

grpc-gateway/client/observeDeviceResources.go

@@ -65,12 +65,3 @@ func (c *Client) stopObservingDeviceResources(observationID string) (wait func()
 	}
 	return s.Cancel()
 }
-
-func (c *Client) StopObservingDeviceResources(ctx context.Context, observationID string) error {
-	wait, err := c.stopObservingDeviceResources(observationID)
-	if err != nil {
-		return err
-	}
-	wait()
-	return nil
-}