Add option to reset the lock

Author: goyalmunish

cmd/reminder/main.go

@@ -22,6 +22,7 @@ func Run() error {
 	// initialization
 	var err error
 	var runID = uuid.New()
+	var startInteractiveProcess bool = true
 	// note: setting are loaded before logger is being setup; it will assume only default logrus settings
 	config, err = settings.LoadConfig()
 	if err != nil {
@@ -32,22 +33,30 @@ func Run() error {
 		"app":    "reminder",
 		"run_id": runID,
 	})
+
 	// make sure DataFile exists
 	if err := model.MakeSureFileExists(config.AppInfo.DataFile, true); err != nil {
 		return err
 	}
+
 	// read and parse the existing data
 	reminderData, err := model.ReadDataFile(config.AppInfo.DataFile, false)
 	if err != nil {
 		return err
 	}
+
+	// check if the data file is locked by another session
 	if reminderData.MutexLock {
-		return model.ErrorMutexLockOn
-	}
-	reminderData.MutexLock = true
-	if err := reminderData.UpdateDataFile("Turning ON the Mutex Lock!"); err != nil {
-		return err
+		fmt.Printf("WARNING! %s\n", model.ErrorMutexLockOn.Error())
+		reset := utils.AskBoolean("But, do you want to force reset the lock?")
+		if !reset {
+			// exit now without resetting the lock
+			return model.ErrorMutexLockOn
+		}
+		// proceed forward to reset the lock, but don't start the interactive process
+		startInteractiveProcess = false
 	}
+
 	// make sure lock is released and any uncommitted data is persisted
 	defer func() {
 		if !reminderData.MutexLock {
@@ -60,6 +69,17 @@ func Run() error {
 			utils.LogError(err)
 		}
 	}()
+
+	// early exit if conditions are not met
+	if !startInteractiveProcess {
+		return model.ErrorInteractiveProcessSkipped
+	}
+
+	reminderData.MutexLock = true
+	if err := reminderData.UpdateDataFile("Turning ON the Mutex Lock!"); err != nil {
+		return err
+	}
+
 	// start the repeating interactive process
 	if err := RepeatInteractiveSession(reminderData); err != nil {
 		return err

internal/model/errors.go

@@ -3,6 +3,7 @@ package model
 import "errors"
 
 var (
-	ErrorConflictFile = errors.New("created _CONFLICT file")
-	ErrorMutexLockOn  = errors.New("Mutex Lock is ON; there is already a session running!")
+	ErrorConflictFile              = errors.New("Created _CONFLICT file")
+	ErrorMutexLockOn               = errors.New("Mutex Lock is ON; there is already a session running!")
+	ErrorInteractiveProcessSkipped = errors.New("Skipped running the interactive process. Try again!")
 )

pkg/calendar/calendar.go

@@ -36,7 +36,7 @@ func DeleteEvents(srv *gc.Service, events []*gc.Event, dryMode bool) error {
 				continue
 			}
 			if err := srv.Events.Delete("primary", item.Id).Do(); err != nil {
-				return fmt.Errorf("Couldn't delete the Calendar event %q | %q | %v", item.Id, item.Summary, err)
+				return fmt.Errorf("Couldn't delete the Calendar event %q | %q | %w", item.Id, item.Summary, err)
 			} else {
 				deletionCount += 1
 				fmt.Printf("    - Deleted the Calendar event %q | %q\n", item.Id, EventString(item))
@@ -218,12 +218,12 @@ func getTokenFromWeb(config *oauth2.Config) (*oauth2.Token, error) {
 
 	var authCode string
 	if _, err := fmt.Scan(&authCode); err != nil {
-		return nil, fmt.Errorf("Unable to read authorization code: %v", err)
+		return nil, fmt.Errorf("Unable to read authorization code: %w", err)
 	}
 
 	tok, err := config.Exchange(context.TODO(), authCode)
 	if err != nil {
-		return nil, fmt.Errorf("Unable to retrieve token from web: %v", err)
+		return nil, fmt.Errorf("Unable to retrieve token from web: %w", err)
 	}
 	return tok, nil
 }

pkg/utils/functions.go

@@ -126,14 +126,14 @@ func YearForDueDateDDMM(dateMonth string) (int, error) {
 func StrToTime(tString string, timezone string) (time.Time, error) {
 	t, err := time.Parse(time.RFC3339, tString)
 	if err != nil {
-		return t, fmt.Errorf("Unable to parse the time %v: %v", tString, err)
+		return t, fmt.Errorf("Unable to parse the time %v: %w", tString, err)
 	}
 	if timezone == "" {
 		return t, nil
 	}
 	location, err := time.LoadLocation(timezone)
 	if err != nil {
-		return t, fmt.Errorf("Unable to parse the timezone %v: %v", timezone, err)
+		return t, fmt.Errorf("Unable to parse the timezone %v: %w", timezone, err)
 	}
 	return t.In(location), nil
 }
@@ -515,3 +515,13 @@ func TryConvertTildaBasedPath(path string) string {
 	}
 	return path
 }
+
+// AskBoolean asks a boolean question to the user.
+func AskBoolean(msg string) bool {
+	var response string
+	fmt.Printf("%s (y/n): ", msg)
+	fmt.Scanln(&response)
+	response = strings.Trim(response, " \n\t")
+	response = strings.ToLower(response)
+	return response == "y"
+}