AlphaBlending.go

package kurento

import "fmt"

type IAlphaBlending interface {
	SetMaster(source HubPort, zOrder int) error
	SetPortProperties(relativeX float64, relativeY float64, zOrder int, relativeWidth float64, relativeHeight float64, port HubPort) error
}

// A `Hub` that mixes the :rom:attr:`MediaType.AUDIO` stream of its connected
// sources and constructs one output with :rom:attr:`MediaType.VIDEO`
// streams of its connected sources into its sink
type AlphaBlending struct {
	Hub
}

// Return contructor params to be called by "Create".
func (elem *AlphaBlending) 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 the master entry to the mixer
func (elem *AlphaBlending) SetMaster(source HubPort, zOrder int) error {
	req := elem.getInvokeRequest()

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

	setIfNotEmpty(params, "source", source)
	setIfNotEmpty(params, "zOrder", zOrder)

	reqparams := map[string]interface{}{
		"operation":       "setMaster",
		"object":          elem.Id,
		"operationParams": params,
	}
	if elem.connection.SessionId != "" {
		reqparams["sessionId"] = elem.connection.SessionId
	}
	req["params"] = reqparams

	// Call server and wait response
	response := <-elem.connection.Request(req)

	// Returns error or nil
	if response.Error != nil {
		return response.Error
	} else {
		return nil
	}

}

// Configure the blending mode of one port.
func (elem *AlphaBlending) SetPortProperties(relativeX float64, relativeY float64, zOrder int, relativeWidth float64, relativeHeight float64, port HubPort) error {
	req := elem.getInvokeRequest()

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

	setIfNotEmpty(params, "relativeX", relativeX)
	setIfNotEmpty(params, "relativeY", relativeY)
	setIfNotEmpty(params, "zOrder", zOrder)
	setIfNotEmpty(params, "relativeWidth", relativeWidth)
	setIfNotEmpty(params, "relativeHeight", relativeHeight)
	setIfNotEmpty(params, "port", port)

	reqparams := map[string]interface{}{
		"operation":       "setPortProperties",
		"object":          elem.Id,
		"operationParams": params,
	}
	if elem.connection.SessionId != "" {
		reqparams["sessionId"] = elem.connection.SessionId
	}
	req["params"] = reqparams

	// Call server and wait response
	response := <-elem.connection.Request(req)

	// Returns error or nil
	if response.Error != nil {
		return response.Error
	} else {
		return nil
	}

}