mirror of
https://gitlab.com/NebulousLabs/go-upnp.git
synced 2025-10-31 01:56:19 +08:00
95 lines
3.1 KiB
Go
95 lines
3.1 KiB
Go
package goupnp
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"net/url"
|
|
|
|
"gitlab.com/NebulousLabs/go-upnp/goupnp/soap"
|
|
)
|
|
|
|
// ServiceClient is a SOAP client, root device and the service for the SOAP
|
|
// client rolled into one value. The root device, location, and service are
|
|
// intended to be informational. Location can be used to later recreate a
|
|
// ServiceClient with NewServiceClientByURL if the service is still present;
|
|
// bypassing the discovery process.
|
|
type ServiceClient struct {
|
|
SOAPClient *soap.SOAPClient
|
|
RootDevice *RootDevice
|
|
Location *url.URL
|
|
Service *Service
|
|
}
|
|
|
|
// NewServiceClients is deprecated. Use NewServiceClientsCtx instead.
|
|
func NewServiceClients(searchTarget string) (clients []ServiceClient, errors []error, err error) {
|
|
return NewServiceClientsCtx(context.Background(), searchTarget)
|
|
}
|
|
|
|
// NewServiceClientsCtx discovers services, and returns clients for them. err will
|
|
// report any error with the discovery process (blocking any device/service
|
|
// discovery), errors reports errors on a per-root-device basis.
|
|
func NewServiceClientsCtx(ctx context.Context, searchTarget string) (clients []ServiceClient, errors []error, err error) {
|
|
var maybeRootDevices []MaybeRootDevice
|
|
if maybeRootDevices, err = DiscoverDevicesCtx(ctx, searchTarget); err != nil {
|
|
return
|
|
}
|
|
|
|
clients = make([]ServiceClient, 0, len(maybeRootDevices))
|
|
|
|
for _, maybeRootDevice := range maybeRootDevices {
|
|
if maybeRootDevice.Err != nil {
|
|
errors = append(errors, maybeRootDevice.Err)
|
|
continue
|
|
}
|
|
|
|
deviceClients, err := NewServiceClientsFromRootDevice(maybeRootDevice.Root, maybeRootDevice.Location, searchTarget)
|
|
if err != nil {
|
|
errors = append(errors, err)
|
|
continue
|
|
}
|
|
clients = append(clients, deviceClients...)
|
|
}
|
|
|
|
return
|
|
}
|
|
|
|
// NewServiceClientsByURL creates client(s) for the given service URN, for a
|
|
// root device at the given URL.
|
|
func NewServiceClientsByURL(loc *url.URL, searchTarget string) ([]ServiceClient, error) {
|
|
rootDevice, err := DeviceByURL(loc)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
return NewServiceClientsFromRootDevice(rootDevice, loc, searchTarget)
|
|
}
|
|
|
|
// NewServiceClientsFromDevice creates client(s) for the given service URN, in
|
|
// a given root device. The loc parameter is simply assigned to the
|
|
// Location attribute of the returned ServiceClient(s).
|
|
func NewServiceClientsFromRootDevice(rootDevice *RootDevice, loc *url.URL, searchTarget string) ([]ServiceClient, error) {
|
|
device := &rootDevice.Device
|
|
srvs := device.FindService(searchTarget)
|
|
if len(srvs) == 0 {
|
|
return nil, fmt.Errorf("goupnp: service %q not found within device %q (UDN=%q)",
|
|
searchTarget, device.FriendlyName, device.UDN)
|
|
}
|
|
|
|
clients := make([]ServiceClient, 0, len(srvs))
|
|
for _, srv := range srvs {
|
|
clients = append(clients, ServiceClient{
|
|
SOAPClient: srv.NewSOAPClient(),
|
|
RootDevice: rootDevice,
|
|
Location: loc,
|
|
Service: srv,
|
|
})
|
|
}
|
|
return clients, nil
|
|
}
|
|
|
|
// GetServiceClient returns the ServiceClient itself. This is provided so that the
|
|
// service client attributes can be accessed via an interface method on a
|
|
// wrapping type.
|
|
func (client *ServiceClient) GetServiceClient() *ServiceClient {
|
|
return client
|
|
}
|