Method createRequestHandler

erpc/http_server.go:226–808

()

}

func (s *HttpServer) createRequestHandler() http.Handler {
	handleRequest := func(httpCtx context.Context, r *http.Request, w http.ResponseWriter, writeFatalError func(ctx context.Context, statusCode int, body error)) {
		startedAt := time.Now()
		encoder := common.SonicCfg.NewEncoder(w)
		encoder.SetEscapeHTML(false)

		// Get host without port number
		host := r.Host
		if colonIndex := strings.Index(host, ":"); colonIndex != -1 {
			host = host[:colonIndex]
		}

		var projectId, architecture, chainId string
		var isAdmin, isHealthCheck bool
		var err error

		// Check aliasing rules
		if s.serverCfg.Aliasing != nil {
			for _, rule := range s.serverCfg.Aliasing.Rules {
				matched, err := common.WildcardMatch(rule.MatchDomain, host)
				if err != nil {
					s.logger.Error().Err(err).Interface("rule", rule).Msg("failed to match aliasing rule")
					continue
				}
				if matched {
					projectId = rule.ServeProject
					architecture = rule.ServeArchitecture
					chainId = rule.ServeChain
					break
				}
			}
		}

		w.Header().Set("Content-Type", "application/json")
		w.Header().Set("X-ERPC-Version", common.ErpcVersion)
		w.Header().Set("X-ERPC-Commit", common.ErpcCommitSha)

		// Add custom response headers (resolved at startup with env var expansion)
		for key, value := range s.resolvedResponseHeaders {
			w.Header().Set(key, value)
		}

		projectId, architecture, chainId, isAdmin, isHealthCheck, err = s.parseUrlPath(r, projectId, architecture, chainId)
		if err != nil {
			handleErrorResponse(
				httpCtx,
				s.logger,
				&startedAt,
				nil,
				err,
				w,
				encoder,
				writeFatalError,
				&common.TRUE,
				s.executionHeadersMode(),
			)
			return
		}