receivepack/service, format/pack/ingest: Progress uniform

1 files changed, 20 insertions, 1 deletions

diff --git a/receivepack/service/run_hook.go b/receivepack/service/run_hook.go
index 3c76906e..1c265f52 100644
--- a/receivepack/service/run_hook.go
+++ b/receivepack/service/run_hook.go
@@ -1,6 +1,10 @@
 package service
 
-import "context"
+import (
+	"context"
+
+	"codeberg.org/lindenii/furgit/internal/utils"
+)
 
 func (service *Service) runHook(
 	ctx context.Context,
@@ -26,8 +30,12 @@ func (service *Service) runHook(
 		return allowedCommands, allowedIndices, rejected, true, ""
 	}
 
+	utils.WriteProgressf(service.opts.Progress, "running hooks...\r")
+
 	quarantinedObjects, err := service.openQuarantinedObjects(quarantineName)
 	if err != nil {
+		utils.WriteProgressf(service.opts.Progress, "running hooks: failed: %v\n", err)
+
 		return nil, nil, nil, false, err.Error()
 	}
 
@@ -44,10 +52,14 @@ func (service *Service) runHook(
 		IO:                 service.opts.HookIO,
 	})
 	if err != nil {
+		utils.WriteProgressf(service.opts.Progress, "running hooks: failed: %v\n", err)
+
 		return nil, nil, nil, false, err.Error()
 	}
 
 	if len(decisions) != len(commands) {
+		utils.WriteProgressf(service.opts.Progress, "running hooks: failed: wrong decision count\n")
+
 		return nil, nil, nil, false, "hook returned wrong number of update decisions"
 	}
 
@@ -70,5 +82,12 @@ func (service *Service) runHook(
 		rejected[index] = message
 	}
 
+	utils.WriteProgressf(
+		service.opts.Progress,
+		"running hooks: done (%d/%d accepted).\n",
+		len(allowedCommands),
+		len(commands),
+	)
+
 	return allowedCommands, allowedIndices, rejected, true, ""
 }