Add tests

Signed-off-by: Maksym Pavlenko <[email protected]>

Author: mxpv

go.sum

@@ -38,16 +38,13 @@ github.com/felixge/httpsnoop v1.0.4/go.mod h1:m8KPJKqk1gH5J9DgRY2ASl2lWCfGKXixSw
 github.com/fsnotify/fsnotify v1.4.7/go.mod h1:jwhsz4b93w/PPRr/qN1Yymfu8t87LnFCMoQvtojpjFo=
 github.com/gilliek/go-opml v1.0.0 h1:X8xVjtySRXU/x6KvaiXkn7OV3a4DHqxY8Rpv6U/JvCY=
 github.com/gilliek/go-opml v1.0.0/go.mod h1:fOxmtlzyBvUjU6bjpdjyxCGlWz+pgtAHrHf/xRZl3lk=
-<<<<<<< HEAD
 github.com/go-logr/logr v1.2.2/go.mod h1:jdQByPbusPIv2/zmleS9BjJVeZ6kBagPoEUsqbVz/1A=
 github.com/go-logr/logr v1.4.2 h1:6pFjapn8bFcIbiKo3XT4j/BhANplGihG6tvd+8rYgrY=
 github.com/go-logr/logr v1.4.2/go.mod h1:9T104GzyrTigFIr8wt5mBrctHMim0Nb2HLGrmQ40KvY=
 github.com/go-logr/stdr v1.2.2 h1:hSWxHoqTgW2S2qGc0LTAI563KZ5YKYRhT3MFKZMbjag=
 github.com/go-logr/stdr v1.2.2/go.mod h1:mMo/vtBO5dYbehREoey6XUKy/eSumjCCveDpRre4VKE=
-=======
 github.com/golang-jwt/jwt v3.2.1+incompatible h1:73Z+4BJcrTC+KczS6WvTPvRGOp1WmfEP4Q1lOd9Z/+c=
 github.com/golang-jwt/jwt v3.2.1+incompatible/go.mod h1:8pz2t5EyA70fFQQSrl6XZXzqecmYZeUEB8OUGHkxJ+I=
->>>>>>> da8d2ab (feat: add Twitch support)
 github.com/golang/mock v1.6.0 h1:ErTB+efbowRARo13NNdxyJji2egdxLGQhRaY+DUumQc=
 github.com/golang/mock v1.6.0/go.mod h1:p6yTPP+5HYm5mzsMV8JkE6ZKdX+/wYM6Hr+LicevLPs=
 github.com/golang/protobuf v1.3.1/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5yJMmIC1U=

pkg/builder/twitch.go

@@ -33,7 +33,6 @@ func (t *TwitchBuilder) Build(_ctx context.Context, cfg *feed.Config) (*model.Fe
 	}
 
 	if info.LinkType == model.TypeUser {
-
 		users, err := t.client.GetUsers(&helix.UsersParams{
 			Logins: []string{info.ItemID},
 		})
@@ -51,7 +50,7 @@ func (t *TwitchBuilder) Build(_ctx context.Context, cfg *feed.Config) (*model.Fe
 
 		isStreaming := false
 		streamID := ""
-		streams, err := t.client.GetStreams(&helix.StreamsParams{
+		streams, _ := t.client.GetStreams(&helix.StreamsParams{
 			UserIDs: []string{user.ID},
 		})
 		if len(streams.Data.Streams) > 0 {
@@ -72,10 +71,8 @@ func (t *TwitchBuilder) Build(_ctx context.Context, cfg *feed.Config) (*model.Fe
 
 		var added = 0
 		for _, video := range videos.Data.Videos {
-
 			// Do not add the video of an ongoing stream because it will be incomplete
 			if !isStreaming || video.StreamID != streamID {
-
 				date, err := time.Parse(time.RFC3339, video.PublishedAt)
 				if err != nil {
 					return nil, errors.Wrapf(err, "cannot parse PublishedAt time: %s", video.PublishedAt)
@@ -92,7 +89,7 @@ func (t *TwitchBuilder) Build(_ctx context.Context, cfg *feed.Config) (*model.Fe
 
 				feed.Episodes = append(feed.Episodes, &model.Episode{
 					ID:          video.ID,
-					Title:       fmt.Sprintf("%s (%s)", video.Title, date),
+					Title:       fmt.Sprintf("%s (%s)", video.Title, date.Format("2006-01-02 15:04 UTC")),
 					Description: video.Description,
 					Thumbnail:   thumbnailUrl,
 					Duration:    durationSeconds,
@@ -107,11 +104,9 @@ func (t *TwitchBuilder) Build(_ctx context.Context, cfg *feed.Config) (*model.Fe
 					return feed, nil
 				}
 			}
-
 		}
 
 		return feed, nil
-
 	}
 
 	return nil, errors.New("unsupported feed type")

pkg/builder/twitch_test.go

@@ -0,0 +1,51 @@
+package builder
+
+import (
+	"testing"
+
+	"github.com/stretchr/testify/require"
+
+	"github.com/mxpv/podsync/pkg/model"
+)
+
+func TestParseURL_TwitchUser(t *testing.T) {
+	info, err := ParseURL("https://www.twitch.tv/samueletienne")
+	require.NoError(t, err)
+	require.Equal(t, model.TypeUser, info.LinkType)
+	require.Equal(t, model.ProviderTwitch, info.Provider)
+	require.Equal(t, "samueletienne", info.ItemID)
+
+	info, err = ParseURL("https://twitch.tv/testuser")
+	require.NoError(t, err)
+	require.Equal(t, model.TypeUser, info.LinkType)
+	require.Equal(t, model.ProviderTwitch, info.Provider)
+	require.Equal(t, "testuser", info.ItemID)
+}
+
+func TestParseURL_TwitchInvalidLink(t *testing.T) {
+	_, err := ParseURL("https://www.twitch.tv/")
+	require.Error(t, err)
+	require.Contains(t, err.Error(), "invalid id")
+
+	_, err = ParseURL("https://www.twitch.tv//")
+	require.Error(t, err)
+	require.Contains(t, err.Error(), "invald twitch user path")
+
+	_, err = ParseURL("https://www.twitch.tv/user/extra/path")
+	require.Error(t, err)
+	require.Contains(t, err.Error(), "invald twitch user path")
+}
+
+func TestNewTwitchBuilder_InvalidKey(t *testing.T) {
+	_, err := NewTwitchBuilder("invalid_key")
+	require.Error(t, err)
+	require.Contains(t, err.Error(), "invalid twitch key")
+
+	_, err = NewTwitchBuilder("only_one_part")
+	require.Error(t, err)
+	require.Contains(t, err.Error(), "invalid twitch key")
+
+	_, err = NewTwitchBuilder("")
+	require.Error(t, err)
+	require.Contains(t, err.Error(), "invalid twitch key")
+}