DispatcherOneToMany.go

package kurento

import (
	"errors"
	"fmt"
)

type IDispatcherOneToMany interface {
	SetSource(source HubPort) error
	RemoveSource() error
}

// A `Hub` that sends a given source to all the connected sinks
type DispatcherOneToMany struct {
	Hub
}

// Return contructor params to be called by "Create".
func (elem *DispatcherOneToMany) getConstructorParams(from IMediaObject, options map[string]interface{}) map[string]interface{} {

	// Create basic constructor params
	ret := map[string]interface{}{
		"mediaPipeline": fmt.Sprintf("%s", from),
	}

	// then merge options
	mergeOptions(ret, options)

	return ret

}

// Sets the source port that will be connected to the sinks of every `HubPort` of
// the dispatcher
func (elem *DispatcherOneToMany) SetSource(source HubPort) error {
	req := elem.getInvokeRequest()

	params := make(map[string]interface{})

	setIfNotEmpty(params, "source", source)

	req["params"] = map[string]interface{}{
		"operation":       "setSource",
		"object":          elem.Id,
		"operationParams": params,
	}

	// Call server and wait response
	responses, err := elem.connection.Request(req)
	if err != nil {
		return err
	}
	select {
	case response := <-responses:
		// Returns error or nil
		if response.Error != nil {
			return errors.New(fmt.Sprintf("[%d] %s %s", response.Error.Code, response.Error.Message, response.Error.Data))
		}
	case <-elem.connection.closeSig:
		return ErrConnectionClosing
	}

	return nil

}

// Remove the source port and stop the media pipeline.
func (elem *DispatcherOneToMany) RemoveSource() error {
	req := elem.getInvokeRequest()

	req["params"] = map[string]interface{}{
		"operation": "removeSource",
		"object":    elem.Id,
	}

	// Call server and wait response
	responses, err := elem.connection.Request(req)
	if err != nil {
		return err
	}
	select {
	case response := <-responses:
		// Returns error or nil
		if response.Error != nil {
			return errors.New(fmt.Sprintf("[%d] %s %s", response.Error.Code, response.Error.Message, response.Error.Data))
		}
	case <-elem.connection.closeSig:
		return ErrConnectionClosing
	}

	return nil

}