internal/repository/channel_bucket.go

Rama main · réplica de lectura del repositorio original.

package repository

import (
	"context"
	"fmt"
	"xprem/internal/providers/expo"
	"xprem/internal/types"
)

type BucketChannelRepository struct{}

func NewBucketChannelRepository() *BucketChannelRepository {
	return &BucketChannelRepository{}
}

func (s *BucketChannelRepository) InsertChannel(ctx context.Context, appId string, branchId *int64, channelName string) (int64, error) {
	return 0, ErrNotSupportedInStatelessMode
}

func (s *BucketChannelRepository) DeleteChannel(ctx context.Context, channelName string, appId string) error {
	return ErrNotSupportedInStatelessMode
}

func (s *BucketChannelRepository) GetChannelNameByBranchName(ctx context.Context, appId string, branchName string) ([]string, error) {
	return nil, ErrNotSupportedInStatelessMode
}

func (s *BucketChannelRepository) GetChannels(ctx context.Context, appId string) ([]types.ChannelMapping, error) {
	allChannels, err := expo.FetchChannels(appId)
	if err != nil {
		return nil, fmt.Errorf("failed to fetch expo channels: %w", err)
	}
	branchesMapping, err := expo.FetchBranchesMapping(appId)
	if err != nil {
		return nil, fmt.Errorf("failed to fetch expo branches mapping: %w", err)
	}
	var channels []types.ChannelMapping
	for _, channel := range allChannels {
		var branchName *string
		var branchId *string
		for _, mapping := range branchesMapping {
			if mapping.ChannelName != nil && *mapping.ChannelName == channel.Name {
				branchName = &mapping.BranchName
				branchId = &mapping.BranchId
				break
			}
		}
		channels = append(channels, types.ChannelMapping{
			ReleaseChannelId:   channel.Id,
			ReleaseChannelName: channel.Name,
			BranchName:         branchName,
			BranchId:           branchId,
		})
	}
	return channels, nil
}

func (s *BucketChannelRepository) GetChannelBranchMapping(ctx context.Context, appId string, channelName string) (*types.ChannelResolution, error) {
	return expo.FetchChannelMapping(appId, channelName)
}

func (s *BucketChannelRepository) GetBranchSurfing(ctx context.Context, appId string, channelName string) (*types.BranchSurfing, error) {
	return nil, ErrNotSupportedInStatelessMode
}

func (s *BucketChannelRepository) SetBranchSurfing(ctx context.Context, appId string, channelName string, surfing types.BranchSurfing) error {
	return ErrNotSupportedInStatelessMode
}