hook bug fix

garethgeorge · garethgeorge · commit ae8e6d7e5f6e · 2024-05-27T02:55:23.000-07:00
diff --git a/internal/api/backresthandler_test.go b/internal/api/backresthandler_test.go
@@ -603,7 +603,7 @@ func retry(t *testing.T, times int, backoff time.Duration, f func() error) error
 }
 
 func getOperations(t *testing.T, oplog *oplog.OpLog) []*v1.Operation {
-	t.Logf("Reading oplog")
+	t.Logf("Reading oplog at time %v", time.Now())
 	operations := []*v1.Operation{}
 	if err := oplog.ForAll(func(op *v1.Operation) error {
 		operations = append(operations, op)
diff --git a/internal/hook/hook.go b/internal/hook/hook.go
@@ -45,7 +45,7 @@ func (e *HookExecutor) ExecuteHooks(flowID int64, repo *v1.Repo, plan *v1.Plan,
 
 	operationBase := v1.Operation{
 		Status:     v1.OperationStatus_STATUS_INPROGRESS,
-		PlanId:     plan.GetId(),
+		PlanId:     planId,
 		RepoId:     repo.GetId(),
 		InstanceId: e.config.Instance,
 		FlowId:     flowID,

Original file line number	Diff line number	Diff line change
`@@ -603,7 +603,7 @@ func retry(t *testing.T, times int, backoff time.Duration, f func() error) error`
`603`	`603`	`}`
`604`	`604`
`605`	`605`	`func getOperations(t testing.T, oplog oplog.OpLog) []*v1.Operation {`
`606`		`- t.Logf("Reading oplog")`
	`606`	`+ t.Logf("Reading oplog at time %v", time.Now())`
`607`	`607`	`operations := []*v1.Operation{}`
`608`	`608`	`if err := oplog.ForAll(func(op *v1.Operation) error {`
`609`	`609`	`operations = append(operations, op)`