pkg/administration/publish.go

@@ -12,24 +12,14 @@ import (
 )
 
 func doPublish(c *fiber.Ctx) error {
-	var workdir string
-	var site *sign.SiteConfig
 	var upstream *sign.UpstreamConfig
-	var process *sign.ProcessConfig
+	var site *sign.SiteConfig
 	for _, item := range sign.App.Sites {
 		if item.ID == c.Params("site") {
 			site = item
 			for _, stream := range item.Upstreams {
-				if stream.ID == c.Params("slug") {
+				if stream.ID == c.Params("upstream") {
 					upstream = stream
-					workdir, _ = stream.GetRawURI()
-					break
-				}
-			}
-			for _, proc := range item.Processes {
-				if proc.ID == c.Params("slug") {
-					process = proc
-					workdir = proc.Workdir
 					break
 				}
 			}
@@ -37,9 +27,9 @@ func doPublish(c *fiber.Ctx) error {
 		}
 	}
 
-	if upstream == nil && process == nil {
+	if upstream == nil {
 		return fiber.ErrNotFound
-	} else if upstream != nil && upstream.GetType() != sign.UpstreamTypeFile {
+	} else if upstream.GetType() != sign.UpstreamTypeFile {
 		return fiber.ErrUnprocessableEntity
 	}
 
@@ -47,6 +37,8 @@ func doPublish(c *fiber.Ctx) error {
 		process.StopProcess()
 	}
 
+	workdir, _ := upstream.GetRawURI()
+
 	if c.Query("overwrite", "yes") == "yes" {
 		files, _ := filepath.Glob(filepath.Join(workdir, "*"))
 		for _, file := range files {

pkg/administration/server.go

@@ -19,7 +19,6 @@ func InitAdministration() *fiber.App {
 		EnableIPValidation:    true,
 		EnablePrintRoutes:     viper.GetBool("debug.print_routes"),
 		TrustedProxies:        viper.GetStringSlice("security.administration_trusted_proxies"),
-		BodyLimit:             viper.GetInt("hypertext.limitation.max_body_size"),
 	})
 
 	if viper.GetBool("performance.request_logging") {
@@ -43,7 +42,7 @@ func InitAdministration() *fiber.App {
 
 	webhooks := app.Group("/webhooks").Name("WebHooks")
 	{
-		webhooks.Put("/publish/:site/:slug", doPublish)
+		webhooks.Put("/publish/:site/:upstream", doPublish)
 	}
 
 	return app

pkg/cmd/rds/deploy/commands.go

@@ -70,10 +70,10 @@ var DeployCommands = []*cli.Command{
 				BasicAuth("RoadSign CLI", server.Credential)
 
 			var mistake error
-			if status, data, err := client.Bytes(); len(err) > 0 {
+			if status, _, err := client.Bytes(); len(err) > 0 {
 				mistake = fmt.Errorf("failed to publish to remote: %q", err)
 			} else if status != 200 {
-				mistake = fmt.Errorf("server rejected request, status code %d, response %s", status, string(data))
+				mistake = fmt.Errorf("server rejected request, status code %d", status)
 			}
 
 			// Cleanup

pkg/sign/pm.go

@@ -20,6 +20,7 @@ func (v *ProcessConfig) BootProcess() error {
 	if v.Cmd != nil {
 		return nil
 	}
+
 	if err := v.PreapreProcess(); err != nil {
 		return err
 	}
@@ -68,13 +69,8 @@ func (v *ProcessConfig) StartProcess() error {
 
 func (v *ProcessConfig) StopProcess() error {
 	if v.Cmd != nil && v.Cmd.Process != nil {
-		if err := v.Cmd.Process.Signal(os.Interrupt); err != nil {
+		return v.Cmd.Process.Signal(os.Interrupt)
-			v.Cmd.Process.Kill()
-			return err
 	} else {
-			v.Cmd = nil
-		}
-	}
-
 		return nil
 	}
+}

pkg/sign/router.go

@@ -22,8 +22,6 @@ func (v *AppConfig) Forward(ctx *fiber.Ctx, site *SiteConfig) error {
 		if err := process.BootProcess(); err != nil {
 			log.Warn().Err(err).Msgf("An error occurred when booting process (%s) for %s", process.ID, site.ID)
 			return fiber.ErrBadGateway
-		} else {
-			log.Debug().Msg("process is alive!")
 		}
 	}
 

settings.yml

@@ -10,7 +10,7 @@ hypertext:
         key: ./cert.key
         pem: ./cert.pem
     limitation:
-        max_body_size: 536870912
+        max_body_size: -1
         max_qps: -1
     ports:
         - :8000

test/benchmark/data/.gitignore

@@ -1,2 +1,2 @@
-/ssr
+/.output
-/spa
+/.spa

test/benchmark/roadsign-spa/settings.yml

@@ -9,7 +9,7 @@ hypertext:
         key: ./cert.key
         pem: ./cert.pem
     limitation:
-        max_body_size: 536870912
+        max_body_size: -1
         max_qps: -1
     ports:
         - :8000

test/benchmark/roadsign-ssr/config/example.yaml

@@ -8,5 +8,5 @@ upstreams:
     uri: http://localhost:3000
 processes:
   - id: nuxt-ssr
-    workdir: ../data/ssr
+    workdir: ../data
     command: ["node", ".output/server/index.mjs"]

test/benchmark/roadsign-ssr/settings.yml

@@ -9,7 +9,7 @@ hypertext:
         key: ./cert.key
         pem: ./cert.pem
     limitation:
-        max_body_size: 536870912
+        max_body_size: -1
         max_qps: -1
     ports:
         - :8000

test/benchmark/roadsign-with-prefork/settings.yml

@@ -9,7 +9,7 @@ hypertext:
         key: ./cert.key
         pem: ./cert.pem
     limitation:
-        max_body_size: 536870912
+        max_body_size: -1
         max_qps: -1
     ports:
         - :8000

test/benchmark/roadsign/settings.yml

@@ -9,7 +9,7 @@ hypertext:
         key: ./cert.key
         pem: ./cert.pem
     limitation:
-        max_body_size: 536870912
+        max_body_size: -1
         max_qps: -1
     ports:
         - :8000