feat(pipeline): add external notifications for pipeline creation and start

backend/server/services/pipeline.go

@@ -292,6 +292,14 @@ func dequeuePipeline(runningParallelLabels []string) (pipeline *models.Pipeline,
 		if err != nil {
 			panic(err)
 		}
+
+		// Notify that the pipeline has started
+		go func(pipelineId uint64) {
+			if notifyErr := NotifyExternal(pipelineId); notifyErr != nil {
+				globalPipelineLog.Error(notifyErr, "failed to send pipeline started notification for pipeline #%d", pipelineId)
+			}
+		}(pipeline.ID)
+
 		return
 	}
 	if tx.IsErrorNotFound(err) {
@@ -363,6 +371,7 @@ func getProjectName(pipeline *models.Pipeline) (string, errors.Error) {
 	}
 	blueprintId := pipeline.BlueprintId
 	if blueprintId == 0 {
+		// skip get project name if pipeline is not bound to a blueprint
 		return "", nil
 	}
 	dbBlueprint := &models.Blueprint{}

backend/server/services/pipeline_helper.go

@@ -110,6 +110,14 @@ func CreateDbPipeline(newPipeline *models.NewPipeline) (pipeline *models.Pipelin
 	// update tasks state
 	errors.Must(tx.Update(dbPipeline))
 	dbPipeline.Labels = newPipeline.Labels
+
+	// Notify that the pipeline has been created
+	go func(pipelineId uint64) {
+		if notifyErr := NotifyExternal(pipelineId); notifyErr != nil {
+			globalPipelineLog.Error(notifyErr, "failed to send pipeline created notification for pipeline #%d", pipelineId)
+		}
+	}(dbPipeline.ID)
+
 	return dbPipeline, nil
 }