| 
									
										
										
										
											2020-11-16 19:43:39 +01:00
										 |  |  | // Copyright 2015 Matthew Holt and The Caddy Authors | 
					
						
							|  |  |  | // | 
					
						
							|  |  |  | // Licensed under the Apache License, Version 2.0 (the "License"); | 
					
						
							|  |  |  | // you may not use this file except in compliance with the License. | 
					
						
							|  |  |  | // You may obtain a copy of the License at | 
					
						
							|  |  |  | // | 
					
						
							|  |  |  | //     http://www.apache.org/licenses/LICENSE-2.0 | 
					
						
							|  |  |  | // | 
					
						
							|  |  |  | // Unless required by applicable law or agreed to in writing, software | 
					
						
							|  |  |  | // distributed under the License is distributed on an "AS IS" BASIS, | 
					
						
							|  |  |  | // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | 
					
						
							|  |  |  | // See the License for the specific language governing permissions and | 
					
						
							|  |  |  | // limitations under the License. | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | package requestbody | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | import ( | 
					
						
							| 
									
										
										
										
											2024-04-23 20:05:57 -04:00
										 |  |  | 	"time" | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2023-08-14 23:41:15 +08:00
										 |  |  | 	"github.com/dustin/go-humanize" | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2020-11-16 19:43:39 +01:00
										 |  |  | 	"github.com/caddyserver/caddy/v2/caddyconfig/httpcaddyfile" | 
					
						
							|  |  |  | 	"github.com/caddyserver/caddy/v2/modules/caddyhttp" | 
					
						
							|  |  |  | ) | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | func init() { | 
					
						
							|  |  |  | 	httpcaddyfile.RegisterHandlerDirective("request_body", parseCaddyfile) | 
					
						
							|  |  |  | } | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | func parseCaddyfile(h httpcaddyfile.Helper) (caddyhttp.MiddlewareHandler, error) { | 
					
						
							| 
									
										
										
										
											2024-01-23 19:36:59 -05:00
										 |  |  | 	h.Next() // consume directive name | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2020-11-16 19:43:39 +01:00
										 |  |  | 	rb := new(RequestBody) | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2024-01-23 19:36:59 -05:00
										 |  |  | 	// configuration should be in a block | 
					
						
							|  |  |  | 	for h.NextBlock(0) { | 
					
						
							|  |  |  | 		switch h.Val() { | 
					
						
							|  |  |  | 		case "max_size": | 
					
						
							|  |  |  | 			var sizeStr string | 
					
						
							|  |  |  | 			if !h.AllArgs(&sizeStr) { | 
					
						
							|  |  |  | 				return nil, h.ArgErr() | 
					
						
							|  |  |  | 			} | 
					
						
							|  |  |  | 			size, err := humanize.ParseBytes(sizeStr) | 
					
						
							|  |  |  | 			if err != nil { | 
					
						
							|  |  |  | 				return nil, h.Errf("parsing max_size: %v", err) | 
					
						
							| 
									
										
										
										
											2020-11-16 19:43:39 +01:00
										 |  |  | 			} | 
					
						
							| 
									
										
										
										
											2024-01-23 19:36:59 -05:00
										 |  |  | 			rb.MaxSize = int64(size) | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2024-04-23 20:05:57 -04:00
										 |  |  | 		case "read_timeout": | 
					
						
							|  |  |  | 			var timeoutStr string | 
					
						
							|  |  |  | 			if !h.AllArgs(&timeoutStr) { | 
					
						
							|  |  |  | 				return nil, h.ArgErr() | 
					
						
							|  |  |  | 			} | 
					
						
							|  |  |  | 			timeout, err := time.ParseDuration(timeoutStr) | 
					
						
							|  |  |  | 			if err != nil { | 
					
						
							|  |  |  | 				return nil, h.Errf("parsing read_timeout: %v", err) | 
					
						
							|  |  |  | 			} | 
					
						
							|  |  |  | 			rb.ReadTimeout = timeout | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 		case "write_timeout": | 
					
						
							|  |  |  | 			var timeoutStr string | 
					
						
							|  |  |  | 			if !h.AllArgs(&timeoutStr) { | 
					
						
							|  |  |  | 				return nil, h.ArgErr() | 
					
						
							|  |  |  | 			} | 
					
						
							|  |  |  | 			timeout, err := time.ParseDuration(timeoutStr) | 
					
						
							|  |  |  | 			if err != nil { | 
					
						
							|  |  |  | 				return nil, h.Errf("parsing write_timeout: %v", err) | 
					
						
							|  |  |  | 			} | 
					
						
							|  |  |  | 			rb.WriteTimeout = timeout | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2024-01-23 19:36:59 -05:00
										 |  |  | 		default: | 
					
						
							| 
									
										
										
										
											2024-04-23 20:05:57 -04:00
										 |  |  | 			return nil, h.Errf("unrecognized request_body subdirective '%s'", h.Val()) | 
					
						
							| 
									
										
										
										
											2020-11-16 19:43:39 +01:00
										 |  |  | 		} | 
					
						
							|  |  |  | 	} | 
					
						
							|  |  |  | 
 | 
					
						
							|  |  |  | 	return rb, nil | 
					
						
							|  |  |  | } |