prayertimes-go/pkg/diyanetprovider/provider.go

package diyanetprovider

import (
	"context"
	"errors"
	"fmt"
	"time"

	"prayertimes/pkg/prayer"
)

type APIProvider interface {
	Get(ctx context.Context, locationID string) (prayer.TimesResult, error)
	GetByCoords(ctx context.Context, coords prayer.Coordinates) (prayer.TimesResult, error)
}

type FallbackProvider interface {
	GetByCoords(ctx context.Context, coords prayer.Coordinates) (prayer.TimesResult, error)
}

type Provider struct {
	api      APIProvider
	fallback FallbackProvider
	timeout  time.Duration
}

func New(api APIProvider, fallback FallbackProvider) Provider {
	return Provider{
		api:      api,
		fallback: fallback,
		timeout:  1 * time.Second,
	}
}

var ErrEmptyTimes = errors.New("diyanet did not return any prayer times")

func (p Provider) Get(ctx context.Context, locationID string) (prayer.TimesResult, error) {
	ctxWithTimeout, cancel := context.WithTimeout(ctx, p.timeout)
	defer cancel()

	result, err := p.api.Get(ctxWithTimeout, locationID)
	if err != nil {
		return prayer.TimesResult{}, fmt.Errorf("failed to get prayer times from api provider: %w", err)
	}
	if len(result.Times) == 0 {
		return prayer.TimesResult{}, ErrEmptyTimes
	}

	return result, nil
}

func (p Provider) GetByCoords(ctx context.Context, coords prayer.Coordinates) (prayer.TimesResult, error) {
	ctxWithTimeout, cancel := context.WithTimeout(ctx, p.timeout)
	defer cancel()

	result, err := p.api.GetByCoords(ctxWithTimeout, coords)
	if err == nil && len(result.Times) > 0 {
		return result, nil
	}

	result, err = p.fallback.GetByCoords(ctx, coords)
	if err != nil {
		return prayer.TimesResult{}, fmt.Errorf("failed to get prayer times from fallback provider: %w", err)
	}

	if len(result.Times) == 0 {
		return prayer.TimesResult{}, fmt.Errorf("fallback provider did not return any prayer times")
	}

	return result, nil
}