service

Documentation

Index

• type AudioProcessingService
  • func NewAudioProcessingService(log logger.Logger, storage port.Storage, downloader downloader.Downloader, ...) *AudioProcessingService
  • func (a *AudioProcessingService) ProcessAudio(ctx context.Context, operationID string, youtubeMetadata *api.VideoDetails) error
  • func (a *AudioProcessingService) StartOperation(ctx context.Context, songID string) (string, string, error)
• type AudioProcessor

Types

type AudioProcessingService

type AudioProcessingService struct {
	// contains filtered or unexported fields
}

AudioProcessingService es un servicio que maneja la descarga, codificación y almacenamiento de audio.

func NewAudioProcessingService

func NewAudioProcessingService(log logger.Logger, storage port.Storage,
	downloader downloader.Downloader,
	operationStore port.OperationRepository,
	metadataStore port.MetadataRepository,
	messaging port.MessageQueue,
	config *config.Config) *AudioProcessingService

NewAudioProcessingService crea una nueva instancia de AudioProcessingService con las configuraciones proporcionadas.

func (*AudioProcessingService) ProcessAudio

func (a *AudioProcessingService) ProcessAudio(ctx context.Context, operationID string, youtubeMetadata *api.VideoDetails) error

ProcessAudio procesa el audio descargando, codificando y almacenando en S3, con reintentos en caso de fallos.

func (*AudioProcessingService) StartOperation

func (a *AudioProcessingService) StartOperation(ctx context.Context, songID string) (string, string, error)

StartOperation inicia una nueva operación de procesamiento de audio y guarda su estado inicial.

type AudioProcessor

type AudioProcessor interface {
	StartOperation(ctx context.Context, song string) (string, string, error)
	ProcessAudio(ctx context.Context, operationID string, metadata *api.VideoDetails) error
}

AudioProcessingService es un servicio que maneja la descarga, codificación y almacenamiento de audio.