feat: allow override completed task

app/actor/subscription/actor.go

@@ -342,7 +342,7 @@ func (a *Actor) handleTaskCompletedEvent(data map[string]interface{}) {
 		return
 	}
 
-	if err := a.store.ManualCompleteTask(a.ctx, e.Validator, e.Phase, e.Task, e.Points); err != nil {
+	if err := a.store.ManualCompleteTask(a.ctx, e.Validator, e.Phase, e.Task, e.Points, e.Override); err != nil {
 		log.Err(err).Interface("data", data).Msg("🤕 Couldn't manually complete task")
 	}
 }

app/nemeton/store.go

@@ -519,6 +519,7 @@ func (s *Store) ManualCompleteTask(
 	phaseNB int,
 	taskID string,
 	rewards *uint64,
+	override bool,
 ) error {
 	phase := s.GetPhase(phaseNB)
 	var task *Task
@@ -531,6 +532,12 @@ func (s *Store) ManualCompleteTask(
 		return fmt.Errorf("task '%s' not found in phase '%d'", taskID, phaseNB)
 	}
 
+	if override {
+		if err := s.resetTaskPoints(ctx, valoper, phaseNB, taskID); err != nil {
+			return err
+		}
+	}
+
 	points := uint64(0)
 	if rewards != nil {
 		points = *rewards
@@ -564,6 +571,33 @@ func (s *Store) ensureTaskCompleted(ctx context.Context, filter bson.M, phase in
 	return err
 }
 
+func (s *Store) resetTaskPoints(ctx context.Context, valoper types.ValAddress, phase int, task string) error {
+	val, err := s.GetValidatorByValoper(ctx, valoper)
+	if err != nil {
+		return err
+	}
+
+	taskState := val.Task(phase, task)
+	if taskState != nil && taskState.Completed {
+		_, err := s.db.Collection(validatorsCollectionName).UpdateOne(
+			ctx,
+			bson.M{
+				"valoper": valoper,
+			},
+			bson.M{
+				"$unset": bson.M{
+					fmt.Sprintf("tasks.%d.%s", phase, task): 1,
+				},
+				"$inc": bson.M{
+					"points": int64(taskState.EarnedPoints) * -1,
+				},
+			},
+		)
+		return err
+	}
+	return nil
+}
+
 // getTaskPhaseByType return the current phase at the given time and the current **first** task for the given task type.
 func (s *Store) getTaskPhaseByType(id string, at time.Time) (*Phase, *Task) {
 	phase, tasks := s.getTasksPhaseByType(id, at)

graphql/event.go

@@ -182,6 +182,7 @@ type TaskCompletedEvent struct {
 	Phase     int              `json:"phase"`
 	Task      string           `json:"task"`
 	Points    *uint64          `json:"points,omitempty"`
+	Override  bool             `json:"override"`
 }
 
 func (e *TaskCompletedEvent) Marshal() (map[string]interface{}, error) {

graphql/schema.graphqls

@@ -319,6 +319,11 @@ type Mutation {
         The points to attribute, if applicable. The priority will be given to the static rewards amount specified in the task definition.
         """
         points: UInt64
+
+        """
+        Allow updating points even if the task was already completed.
+        """
+        override: Boolean = False
     ): Void @auth
 
     """