adding opus codec. (#143)

Author: jamescyeh

provider/bitmovin/bitmovin.go

@@ -40,6 +40,7 @@ const (
 
 	codecVorbis = "vorbis"
 	codecAAC    = "aac"
+	codecOpus   = "opus"
 	codecVP8    = "vp8"
 	codecH264   = "h264"
 	codecH265   = "h265"
@@ -58,6 +59,7 @@ const (
 	cfgStoreH265      cfgStore = "h265"
 	cfgStoreAV1       cfgStore = "av1"
 	cfgStoreAAC       cfgStore = "aac"
+	cfgStoreOpus      cfgStore = "opus"
 
 	filterVideoDeinterlace = iota + 1
 )
@@ -155,6 +157,7 @@ func bitmovinFactory(cfg *config.Config) (provider.TranscodingProvider, error) {
 			cfgStoreH265AAC:   configuration.NewH265AAC(api, dbRepo),
 			cfgStoreVP8Vorbis: configuration.NewVP8Vorbis(api, dbRepo),
 			cfgStoreAAC:       configuration.NewAAC(api, dbRepo),
+			cfgStoreOpus:      configuration.NewOpus(api, dbRepo),
 		},
 		containerSvcs: map[mediaContainer]containerSvc{
 			containerHLS: {
@@ -680,6 +683,8 @@ func (p *bitmovinProvider) cfgServiceFrom(vcodec, acodec string) (configuration.
 		return p.cfgStores[cfgStoreAV1], nil
 	case codecAAC:
 		return p.cfgStores[cfgStoreAAC], nil
+	case codecOpus:
+		return p.cfgStores[cfgStoreOpus], nil
 	}
 
 	return nil, fmt.Errorf("the pair of vcodec: %q and acodec: %q is not yet supported", vcodec, acodec)

provider/bitmovin/internal/configuration/codec/aac.go

@@ -11,7 +11,7 @@ import (
 
 const defaultAACSampleRate = 48000
 
-// NewAAC creates a AAC codec configuration and returns its ID
+// NewAAC creates an AAC codec configuration and returns its ID
 func NewAAC(api *bitmovin.BitmovinApi, bitrate string) (string, error) {
 	createCfg, err := aacConfigFrom(bitrate)
 	if err != nil {

provider/bitmovin/internal/configuration/codec/opus.go

@@ -0,0 +1,40 @@
+package codec
+
+import (
+	"fmt"
+	"strconv"
+
+	"github.com/bitmovin/bitmovin-api-sdk-go"
+	"github.com/bitmovin/bitmovin-api-sdk-go/model"
+	"github.com/pkg/errors"
+)
+
+const defaultOpusSampleRate = 48000
+
+// NewOpus creates an Opus codec configuration and returns its ID
+func NewOpus(api *bitmovin.BitmovinApi, bitrate string) (string, error) {
+	createCfg, err := opusConfigFrom(bitrate)
+	if err != nil {
+		return "", err
+	}
+
+	cfg, err := api.Encoding.Configurations.Audio.Opus.Create(createCfg)
+	if err != nil {
+		return "", errors.Wrap(err, "creating audio cfg")
+	}
+
+	return cfg.Id, nil
+}
+
+func opusConfigFrom(bitrate string) (model.OpusAudioConfiguration, error) {
+	convertedBitrate, err := strconv.ParseInt(bitrate, 10, 64)
+	if err != nil {
+		return model.OpusAudioConfiguration{}, errors.Wrapf(err, "parsing audio bitrate %q to int64", bitrate)
+	}
+
+	return model.OpusAudioConfiguration{
+		Name:    fmt.Sprintf("opus_%s_%d", bitrate, defaultOpusSampleRate),
+		Bitrate: &convertedBitrate,
+		Rate:    floatToPtr(defaultOpusSampleRate),
+	}, nil
+}

provider/bitmovin/internal/configuration/opus.go

@@ -0,0 +1,67 @@
+package configuration
+
+import (
+	"fmt"
+
+	"github.com/bitmovin/bitmovin-api-sdk-go"
+	"github.com/bitmovin/bitmovin-api-sdk-go/model"
+	"github.com/cbsinteractive/video-transcoding-api/db"
+	"github.com/cbsinteractive/video-transcoding-api/provider/bitmovin/internal/configuration/codec"
+	"github.com/pkg/errors"
+)
+
+// Opus is a configuration service for content using only this codec
+type Opus struct {
+	api  *bitmovin.BitmovinApi
+	repo db.PresetSummaryRepository
+}
+
+// NewOpus returns a service for managing Opus audio only configurations
+func NewOpus(api *bitmovin.BitmovinApi, repo db.PresetSummaryRepository) *Opus {
+	return &Opus{api: api, repo: repo}
+}
+
+// Create will create a new Opus configuration based on a preset
+func (c *Opus) Create(preset db.Preset) (string, error) {
+	audCfgID, err := codec.NewOpus(c.api, preset.Audio.Bitrate)
+	if err != nil {
+		return "", err
+	}
+
+	err = c.repo.CreatePresetSummary(&db.PresetSummary{
+		Name:          preset.Name,
+		Container:     preset.Container,
+		AudioCodec:    string(model.CodecConfigType_OPUS),
+		AudioConfigID: audCfgID,
+	})
+	if err != nil {
+		return "", err
+	}
+
+	return preset.Name, nil
+}
+
+// Get retrieves a stored db.PresetSummary by its name
+func (c *Opus) Get(presetName string) (db.PresetSummary, error) {
+	return c.repo.GetPresetSummary(presetName)
+}
+
+// Delete removes the audio configurations
+func (c *Opus) Delete(presetName string) error {
+	summary, err := c.Get(presetName)
+	if err != nil {
+		return err
+	}
+
+	_, err = c.api.Encoding.Configurations.Audio.Opus.Delete(summary.AudioConfigID)
+	if err != nil {
+		return errors.Wrap(err, "removing the audio config")
+	}
+
+	err = c.repo.DeletePresetSummary(presetName)
+	if err != nil {
+		return fmt.Errorf("deleting preset summary: %w", err)
+	}
+
+	return nil
+}