fix: write episode progress timeline (#756)

Author: trim21

ctrl/update_episode_progress.go

@@ -90,7 +90,11 @@ func (ctl Ctrl) UpdateEpisodesCollection(
 		return err
 	}
 
-	err = ctl.timeline.ChangeEpisodeStatus(ctx, u, s, e)
+	if t == 0 {
+		return nil
+	}
+
+	err = ctl.timeline.ChangeEpisodeStatus(ctx, u, s, e, t)
 
 	return errgo.Wrap(err, "timeline.ChangeEpisodeStatus")
 }
@@ -125,7 +129,11 @@ func (ctl Ctrl) UpdateEpisodeCollection(
 		return err
 	}
 
-	err = ctl.timeline.ChangeEpisodeStatus(ctx, u, s, e)
+	if t == 0 {
+		return nil
+	}
+
+	err = ctl.timeline.ChangeEpisodeStatus(ctx, u, s, e, t)
 
 	return errgo.Wrap(err, "timeline.ChangeEpisodeStatus")
 }

internal/mocks/TimeLineService.go

@@ -288,7 +288,8 @@ func MockTimeLineSrv(m timeline.Service) fx.Option {
 
 		mocker.EXPECT().ChangeSubjectCollection(mock.Anything, mock.Anything,
 			mock.Anything, mock.Anything, mock.Anything, mock.Anything, mock.Anything).Return(nil)
-		mocker.EXPECT().ChangeEpisodeStatus(mock.Anything, mock.Anything, mock.Anything, mock.Anything).Return(nil)
+		mocker.EXPECT().
+			ChangeEpisodeStatus(mock.Anything, mock.Anything, mock.Anything, mock.Anything, mock.Anything).Return(nil)
 		mocker.EXPECT().ChangeSubjectProgress(mock.Anything, mock.Anything, mock.Anything,
 			mock.Anything, mock.Anything).Return(nil)
 

internal/pkg/test/web.go

@@ -39,6 +39,7 @@ type Service interface {
 		u auth.Auth,
 		sbj model.Subject,
 		episode episode.Episode,
+		t collection.EpisodeCollection,
 	) error
 
 	ChangeSubjectProgress(

internal/timeline/domain.go

@@ -104,6 +104,7 @@ func (m kafkaClient) ChangeEpisodeStatus(
 	u auth.Auth,
 	sbj model.Subject,
 	episode episode.Episode,
+	t collection.EpisodeCollection,
 ) error {
 	ctx, canal := context.WithTimeout(ctx, defaultTimeout)
 	defer canal()
@@ -121,7 +122,7 @@ func (m kafkaClient) ChangeEpisodeStatus(
 				},
 				Episode: tlEpisode{
 					ID:     episode.ID,
-					Status: int(episode.Sort),
+					Status: t,
 				},
 				CreatedAt: time.Now().Unix(),
 				Source:    timelineSourceAPI,

internal/timeline/kafka.go

@@ -26,8 +26,8 @@ type timelineValue struct {
 }
 
 type tlEpisode struct {
-	ID     model.EpisodeID `json:"id"`
-	Status int             `json:"status"`
+	ID     model.EpisodeID              `json:"id"`
+	Status collection.EpisodeCollection `json:"status"`
 }
 
 type tlSubjectCollect struct {