Some UI fixes

server/logging/log.go

@@ -79,9 +79,15 @@
 	l.Lock()
 	s, ok := l.streams[stepID]
 	l.Unlock()
+
+	// auto open the stream if it does not exist
 	if !ok {
-		return l.Open(ctx, stepID)
+		err := l.Open(ctx, stepID)
+		if err != nil {
+			return err
+		}
 	}
+
 	s.Lock()
 	s.list = append(s.list, logEntry)
 	for sub := range s.subs {

server/pipeline/create.go

@@ -79,12 +79,17 @@
 	err = _store.CreatePipeline(pipeline)
 	if err != nil {
 		msg := fmt.Errorf("failed to save pipeline for %s", repo.FullName)
-		log.Error().Err(err).Msg(msg.Error())
+		log.Error().Str("repo", repo.FullName).Err(err).Msg(msg.Error())
 		return nil, msg
 	}
 
 	pipeline = setPipelineStepsOnPipeline(pipeline, pipelineItems)
 
+	if err := _store.WorkflowsCreate(pipeline.Workflows); err != nil {
+		log.Error().Err(err).Str("repo", repo.FullName).Msgf("error persisting steps for %s#%d", repo.FullName, pipeline.Number)
+		return nil, err
+	}
+
 	// persist the pipeline config for historical correctness, restarts, etc
 	var configs []*model.Config
 	for _, forgeYamlConfig := range forgeYamlConfigs {

server/pipeline/decline.go

@@ -30,7 +30,7 @@
 		return nil, fmt.Errorf("cannot decline a pipeline with status %s", pipeline.Status)
 	}
 
-	_, err := UpdateToStatusDeclined(store, *pipeline, user.Login)
+	pipeline, err := UpdateToStatusDeclined(store, *pipeline, user.Login)
 	if err != nil {
 		return nil, fmt.Errorf("error updating pipeline. %w", err)
 	}

server/pipeline/start.go

@@ -20,7 +20,6 @@ import (
 	"github.com/rs/zerolog/log"
 
 	"github.com/woodpecker-ci/woodpecker/pipeline"
-	"github.com/woodpecker-ci/woodpecker/server"
 	"github.com/woodpecker-ci/woodpecker/server/model"
 	"github.com/woodpecker-ci/woodpecker/server/store"
 )
@@ -33,30 +32,13 @@ func start(ctx context.Context, store store.Store, activePipeline *model.Pipelin
 		log.Error().Err(err).Msg("Failed to cancel previous pipelines")
 	}
 
-	if err := store.WorkflowsCreate(activePipeline.Workflows); err != nil {
-		log.Error().Err(err).Str("repo", repo.FullName).Msgf("error persisting steps for %s#%d", repo.FullName, activePipeline.Number)
-		return nil, err
-	}
-
 	publishPipeline(ctx, activePipeline, repo, user)
 
 	if err := queuePipeline(repo, pipelineItems); err != nil {
 		log.Error().Err(err).Msg("queuePipeline")
 		return nil, err
 	}
 
-	// open logs streamer for each step
-	for _, wf := range activePipeline.Workflows {
-		for _, step := range wf.Children {
-			stepID := step.ID
-			go func() {
-				if err := server.Config.Services.Logs.Open(context.Background(), stepID); err != nil {
-					log.Error().Err(err).Msgf("could not open log stream for step %d", stepID)
-				}
-			}()
-		}
-	}
-
 	return activePipeline, nil
 }
 

web/src/views/repo/pipeline/PipelineWrapper.vue

@@ -8,7 +8,17 @@
       :fluid-content="activeTab === 'tasks'"
       full-width-header
     >
-      <template #title>{{ repo.full_name }}</template>
+      <template #title>
+        <span>
+          <router-link :to="{ name: 'org', params: { orgId: repo.org_id } }" class="hover:underline">
+            {{ repo.owner }}
+          </router-link>
+          /
+          <router-link :to="{ name: 'repo' }" class="hover:underline">
+            {{ repo.name }}
+          </router-link>
+        </span>
+      </template>
 
       <template #titleActions>
         <div class="flex md:items-center flex-col gap-2 md:flex-row md:justify-between min-w-0">