112 lines
3.0 KiB
Go
112 lines
3.0 KiB
Go
//nolint:dupl
|
|
package flow_test
|
|
|
|
import (
|
|
"context"
|
|
"testing"
|
|
"time"
|
|
|
|
"gitea.neatflow.kr/biosvos/seven-skies/internal/app/flow"
|
|
"gitea.neatflow.kr/biosvos/seven-skies/internal/pkg/domain"
|
|
"gitea.neatflow.kr/biosvos/seven-skies/internal/pkg/repository/mocks"
|
|
"github.com/stretchr/testify/require"
|
|
"go.uber.org/mock/gomock"
|
|
)
|
|
|
|
func TestFlow_ListDailyWeathers(t *testing.T) {
|
|
t.Parallel()
|
|
|
|
ctrl := gomock.NewController(t)
|
|
mock := mocks.NewMockRepository(ctrl)
|
|
now := time.Now()
|
|
mock.EXPECT().ListWeathers(gomock.Any(), gomock.Any(), gomock.Any()).Return([]*domain.Weather{
|
|
domain.NewWeather(
|
|
"1",
|
|
domain.WeatherSourceOpenWeather,
|
|
now,
|
|
now.Add(time.Hour*24),
|
|
domain.WeatherConditionClear,
|
|
domain.Temperature{Value: domain.Celsius(20)},
|
|
),
|
|
}, nil)
|
|
flow := flow.NewFlow(mock)
|
|
|
|
weathers, err := flow.ListDailyWeathers(context.Background(), "Asia/Seoul", now)
|
|
|
|
require.NoError(t, err)
|
|
require.Len(t, weathers, 1)
|
|
require.InDelta(t, 20.0, weathers[0].High, 0.01)
|
|
require.InDelta(t, 20.0, weathers[0].Low, 0.01)
|
|
require.Equal(t, "CLEAR", weathers[0].Condition)
|
|
}
|
|
|
|
func TestFlow_ListDailyWeathers_SameSourceAndTargetDate(t *testing.T) {
|
|
t.Parallel()
|
|
|
|
ctrl := gomock.NewController(t)
|
|
mock := mocks.NewMockRepository(ctrl)
|
|
now := time.Now()
|
|
mock.EXPECT().ListWeathers(gomock.Any(), gomock.Any(), gomock.Any()).Return([]*domain.Weather{
|
|
domain.NewWeather(
|
|
"1",
|
|
domain.WeatherSourceOpenWeather,
|
|
now,
|
|
now,
|
|
domain.WeatherConditionClear,
|
|
domain.Temperature{Value: domain.Celsius(20)},
|
|
),
|
|
domain.NewWeather(
|
|
"2",
|
|
domain.WeatherSourceOpenWeather,
|
|
now,
|
|
now.Add(time.Hour*24),
|
|
domain.WeatherConditionCloudy,
|
|
domain.Temperature{Value: domain.Celsius(30)},
|
|
),
|
|
}, nil)
|
|
flow := flow.NewFlow(mock)
|
|
|
|
weathers, err := flow.ListDailyWeathers(context.Background(), "Asia/Seoul", time.Now())
|
|
|
|
require.NoError(t, err)
|
|
require.Len(t, weathers, 1)
|
|
require.InDelta(t, 30.0, weathers[0].High, 0.01)
|
|
require.InDelta(t, 30.0, weathers[0].Low, 0.01)
|
|
require.Equal(t, "CLOUDY", weathers[0].Condition)
|
|
}
|
|
|
|
func TestFlow_ListDailyWeathers_DifferentSourceAndTargetDate(t *testing.T) {
|
|
t.Parallel()
|
|
|
|
ctrl := gomock.NewController(t)
|
|
mock := mocks.NewMockRepository(ctrl)
|
|
now := time.Now()
|
|
mock.EXPECT().ListWeathers(gomock.Any(), gomock.Any(), gomock.Any()).Return([]*domain.Weather{
|
|
domain.NewWeather(
|
|
"1",
|
|
domain.WeatherSourceOpenWeather,
|
|
now,
|
|
now,
|
|
domain.WeatherConditionClear,
|
|
domain.Temperature{Value: domain.Celsius(20)},
|
|
),
|
|
domain.NewWeather(
|
|
"2",
|
|
domain.WeatherSourceKMA,
|
|
now,
|
|
now.Add(time.Hour*24),
|
|
domain.WeatherConditionCloudy,
|
|
domain.Temperature{Value: domain.Celsius(30)},
|
|
),
|
|
}, nil)
|
|
flow := flow.NewFlow(mock)
|
|
|
|
weathers, err := flow.ListDailyWeathers(context.Background(), "Asia/Seoul", time.Now())
|
|
|
|
require.NoError(t, err)
|
|
require.Len(t, weathers, 1)
|
|
require.InDelta(t, 30.0, weathers[0].High, 0.01)
|
|
require.InDelta(t, 20.0, weathers[0].Low, 0.01)
|
|
require.Equal(t, "CLOUDY", weathers[0].Condition)
|
|
}
|