Update TODO references: #3, #4, #5, #6, #7, #8, #9, #10, #11, #12, #13, #14, #15, #16

Author: todo-actions[bot]

cmd/worker/main.go

@@ -25,7 +25,7 @@ func main() {
 	mb := rabbitmq.NewRepository(cfg.MessageBroker.GetMessageBrokerUri(), rabbitClient)
 	workerSvc := worker.NewWorkerService(mb, cfg)
 
-	// TODO [$609358567c9cf10008f93510]:  this initiation should be handled by storage service
+	// TODO [#3]:  this initiation should be handled by storage service
 	if _, err := os.Stat(worker.TmpPath); os.IsNotExist(err) {
 		err = os.Mkdir(worker.TmpPath, 0700)
 		if err != nil {
@@ -50,7 +50,7 @@ func main() {
 }
 
 func (wrk *svc) processNewTask(newTaskData chan interface{}) {
-	// TODO [$609358567c9cf10008f93511]:  refactor ack and publish part of this loop
+	// TODO [#4]:  refactor ack and publish part of this loop
 	for t := range newTaskData {
 		msg := t.(amqp.Delivery)
 		var task models.Task

pkg/apiserver/services/scheduler_logic.go

@@ -74,7 +74,7 @@ func (s schedulerServices) GetAllTaskProgress() (result []*models.TaskProgressRe
 	}
 	sort.Strings(keys)
 
-	// TODO [$609358567c9cf10008f93512]:  create model for this return response
+	// TODO [#5]:  create model for this return response
 	for _, k := range keys {
 		originVideo := tempOriginVideo[k]
 		result = append(result, &models.TaskProgressResponse{
@@ -179,7 +179,7 @@ func (s schedulerServices) CreateTranscodeTask(task *models.Task) error {
 		go func(t *models.Task) {
 			defer wg.Done()
 
-			// TODO [$609358567c9cf10008f93513]:  add retry mechanism
+			// TODO [#6]:  add retry mechanism
 			err := s.taskRepo.Add(t)
 			if err != nil {
 				log.Error(err)
@@ -354,7 +354,7 @@ func (s *schedulerServices) createSplitTask(video *models.Video, scheduler Sched
 	var sizePerVid int64
 	var sizeLeft int64
 
-	// TODO [$609358567c9cf10008f93514]:  make the chunk file size is dynamic base on number of worker, worker failure rate, etc
+	// TODO [#7]:  make the chunk file size is dynamic base on number of worker, worker failure rate, etc
 	// since lots of smaller task with same number of worker will just add overhead
 	// in processing. The pros is, in case of pod failure in the middle of a processing,
 	// the task that need to be re-processed is in smaller chunk. Currently I'll set this dynamically
@@ -367,7 +367,7 @@ func (s *schedulerServices) createSplitTask(video *models.Video, scheduler Sched
 	minSize := int64(fileSize * 1e+6) // convert Megabyte to Byte
 	// if video size less than min file size, forward to transcode task
 	if video.Size < minSize {
-		// TODO [$609358567c9cf10008f93515]:  make this task definition not redundant.
+		// TODO [#8]:  make this task definition not redundant.
 		// Task is re-defined on CreateTranscodeTask, but
 		// this is a current workaround for preserve origin
 		// video field, later please redesign the data models
@@ -464,7 +464,7 @@ func (s schedulerServices) updateTaskStatus(updateTaskStatusQueue chan interface
 }
 
 func (s schedulerServices) scheduleTaskFromQueue(finishedTask chan interface{}) {
-	// TODO [$609358567c9cf10008f93516]:  Refactor this repetitive message ack
+	// TODO [#9]:  Refactor this repetitive message ack
 	for t := range finishedTask {
 		msg := t.(amqp.Delivery)
 		var task models.Task

pkg/apiserver/services/worker_logic.go

@@ -50,7 +50,7 @@ func (wrk workerServices) workerStateUpdate(workerQueue chan interface{}, action
 		if err != nil {
 			log.Error(err)
 		}
-		// TODO [$609358567c9cf10008f93517]:  add bulk upsert to reduce write
+		// TODO [#10]:  add bulk upsert to reduce write
 		if err := wrk.workerRepo.Upsert(&worker); err != nil {
 			log.Errorf("Worker %s failed to %s, err %s", worker.WorkerPodName, action, err)
 		} else {
@@ -90,7 +90,7 @@ func (wrk workerServices) publishWorkerEvent() {
 	if err != nil {
 		log.Error(err)
 	}
-	// TODO [$609358567c9cf10008f93518]:  only publish 1 data for every worker update
+	// TODO [#11]:  only publish 1 data for every worker update
 	// instead off all worker result
 	wrk.sse.Publish(WorkerHTTPEventStream, &sse.Event{
 		Data: resp,

pkg/apiserver/util/healthcheck.go

@@ -45,7 +45,7 @@ func MongoDBPingCheck(mongoClient *mongo.Client, timeout time.Duration) hc.Check
 
 func RabbitPingCheck(connection *amqp.Connection) hc.Check {
 	return func() error {
-		// TODO [$609358567c9cf10008f93519]:  try to reuse the channel instead of opening new channel everytime this endpoint got hit
+		// TODO [#12]:  try to reuse the channel instead of opening new channel everytime this endpoint got hit
 		ch, err := connection.Channel()
 		if err != nil {
 			log.Errorf("failed to get rabbitmq channel: %s", err)

pkg/worker/merge.go

@@ -158,7 +158,7 @@ func (s Svc) ProcessTaskMerge(task *models.Task) error {
 		}(f)
 	}
 	//Removing named pipe file
-	// TODO [$609358567c9cf10008f9351a]:  (improvement) make the pipe generic name (eg: temp1)
+	// TODO [#13]:  (improvement) make the pipe generic name (eg: temp1)
 	// and can be reused to next process, might reducing io if the
 	// created pipe file is a lot
 	log.Debug("removing pipe file")

pkg/worker/worker.go

@@ -25,7 +25,7 @@ const (
 
 type Svc struct {
 	messageBroker repositories.Messenger
-	// TODO [$609358567c9cf10008f9351b]:  implement this storage repository
+	// TODO [#14]:  implement this storage repository
 	storage repositories.StorageRepository
 	worker  *models.Worker
 	config  *config.Configuration

web/src/Pages/VideoPlayer/VideoTile.js

@@ -14,7 +14,7 @@ class VideoTile extends Component {
         // passed in `props` by a parent component
         this.props.setActiveVideo(this.props.video);
     }
-    // TODO [$609358567c9cf10008f9351c]:  add small thumbnail for each video
+    // TODO [#15]:  add small thumbnail for each video
     render() {
         return (
             <div className='videoTile' onClick={this.onClickVideoTile}>

web/src/Pages/Worker/WorkerPage.js

@@ -10,7 +10,7 @@ class WorkerPage extends Component {
     }
 
 
-    // TODO [$609358567c9cf10008f9351d]:  this stupid, need to apply websocket or sse
+    // TODO [#16]:  this stupid, need to apply websocket or sse
     // instead of requesting every 100ms
     async componentDidMount() {
         try {