refactor(runners): move runners to pro

Author: fiftin

api/projects/runners.go

@@ -108,6 +108,7 @@ func Route(
 	userController := NewUserController(subscriptionService)
 	usersController := NewUsersController(subscriptionService)
 	subscriptionController := proApi.NewSubscriptionController()
+	projectRunnerController := proProjects.NewProjectRunnerController()
 
 	r := mux.NewRouter()
 	r.NotFoundHandler = http.HandlerFunc(servePublic)
@@ -314,17 +315,17 @@ func Route(
 	projectUserAPI.Path("/integrations").HandlerFunc(projects.AddIntegration).Methods("POST")
 	projectUserAPI.Path("/backup").HandlerFunc(projects.GetBackup).Methods("GET", "HEAD")
 
-	projectUserAPI.Path("/runners").HandlerFunc(projects.GetRunners).Methods("GET", "HEAD")
-	projectUserAPI.Path("/runners").HandlerFunc(projects.AddRunner).Methods("POST")
-	projectUserAPI.Path("/runner_tags").HandlerFunc(projects.GetRunnerTags).Methods("GET", "HEAD")
+	projectUserAPI.Path("/runners").HandlerFunc(projectRunnerController.GetRunners).Methods("GET", "HEAD")
+	projectUserAPI.Path("/runners").HandlerFunc(projectRunnerController.AddRunner).Methods("POST")
+	projectUserAPI.Path("/runner_tags").HandlerFunc(projectRunnerController.GetRunnerTags).Methods("GET", "HEAD")
 
 	projectRunnersAPI := projectUserAPI.PathPrefix("/runners").Subrouter()
-	projectRunnersAPI.Use(projects.RunnerMiddleware)
-	projectRunnersAPI.Path("/{runner_id}").HandlerFunc(projects.GetRunner).Methods("GET", "HEAD")
-	projectRunnersAPI.Path("/{runner_id}").HandlerFunc(projects.UpdateRunner).Methods("PUT", "POST")
-	projectRunnersAPI.Path("/{runner_id}/active").HandlerFunc(projects.SetRunnerActive).Methods("POST")
-	projectRunnersAPI.Path("/{runner_id}").HandlerFunc(projects.DeleteRunner).Methods("DELETE")
-	projectRunnersAPI.Path("/{runner_id}/cache").HandlerFunc(projects.ClearRunnerCache).Methods("DELETE")
+	projectRunnersAPI.Use(projectRunnerController.RunnerMiddleware)
+	projectRunnersAPI.Path("/{runner_id}").HandlerFunc(projectRunnerController.GetRunner).Methods("GET", "HEAD")
+	projectRunnersAPI.Path("/{runner_id}").HandlerFunc(projectRunnerController.UpdateRunner).Methods("PUT", "POST")
+	projectRunnersAPI.Path("/{runner_id}/active").HandlerFunc(projectRunnerController.SetRunnerActive).Methods("POST")
+	projectRunnersAPI.Path("/{runner_id}").HandlerFunc(projectRunnerController.DeleteRunner).Methods("DELETE")
+	projectRunnersAPI.Path("/{runner_id}/cache").HandlerFunc(projectRunnerController.ClearRunnerCache).Methods("DELETE")
 
 	//
 	// Updating and deleting project

api/router.go

@@ -0,0 +1,69 @@
+package projects
+
+import (
+	"github.com/semaphoreui/semaphore/api/helpers"
+	"github.com/semaphoreui/semaphore/db"
+	"github.com/semaphoreui/semaphore/pro_interfaces"
+	"net/http"
+)
+
+// NewProjectRunnerController creates a new ProjectRunnerController instance.
+func NewProjectRunnerController() pro_interfaces.ProjectRunnerController {
+	return &ProjectRunnerControllerImpl{}
+}
+
+type ProjectRunnerControllerImpl struct {
+}
+
+func (c *ProjectRunnerControllerImpl) GetRunners(w http.ResponseWriter, r *http.Request) {
+	project := helpers.GetFromContext(r, "project").(db.Project)
+	runners, err := helpers.Store(r).GetRunners(project.ID, false, nil)
+
+	if err != nil {
+		panic(err)
+	}
+
+	helpers.WriteJSON(w, http.StatusOK, runners)
+}
+
+func (c *ProjectRunnerControllerImpl) AddRunner(w http.ResponseWriter, r *http.Request) {
+	w.WriteHeader(http.StatusNotFound)
+}
+
+func (c *ProjectRunnerControllerImpl) RunnerMiddleware(next http.Handler) http.Handler {
+	return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+		next.ServeHTTP(w, r)
+	})
+}
+
+func (c *ProjectRunnerControllerImpl) GetRunner(w http.ResponseWriter, r *http.Request) {
+	w.WriteHeader(http.StatusNotFound)
+}
+
+func (c *ProjectRunnerControllerImpl) UpdateRunner(w http.ResponseWriter, r *http.Request) {
+	w.WriteHeader(http.StatusNotFound)
+}
+
+func (c *ProjectRunnerControllerImpl) DeleteRunner(w http.ResponseWriter, r *http.Request) {
+	w.WriteHeader(http.StatusNotFound)
+}
+
+func (c *ProjectRunnerControllerImpl) SetRunnerActive(w http.ResponseWriter, r *http.Request) {
+	w.WriteHeader(http.StatusNotFound)
+}
+
+func (c *ProjectRunnerControllerImpl) ClearRunnerCache(w http.ResponseWriter, r *http.Request) {
+	w.WriteHeader(http.StatusNotFound)
+}
+
+func (c *ProjectRunnerControllerImpl) GetRunnerTags(w http.ResponseWriter, r *http.Request) {
+	project := helpers.GetFromContext(r, "project").(db.Project)
+	tags, err := helpers.Store(r).GetRunnerTags(project.ID)
+
+	if err != nil {
+		w.WriteHeader(http.StatusInternalServerError)
+		return
+	}
+
+	helpers.WriteJSON(w, http.StatusOK, tags)
+}

pro/api/projects/runners.go

@@ -0,0 +1,15 @@
+package pro_interfaces
+
+import "net/http"
+
+type ProjectRunnerController interface {
+	GetRunners(w http.ResponseWriter, r *http.Request)
+	AddRunner(w http.ResponseWriter, r *http.Request)
+	RunnerMiddleware(next http.Handler) http.Handler
+	GetRunner(w http.ResponseWriter, r *http.Request)
+	UpdateRunner(w http.ResponseWriter, r *http.Request)
+	DeleteRunner(w http.ResponseWriter, r *http.Request)
+	SetRunnerActive(w http.ResponseWriter, r *http.Request)
+	ClearRunnerCache(w http.ResponseWriter, r *http.Request)
+	GetRunnerTags(w http.ResponseWriter, r *http.Request)
+}