Function esmRouter

server/router.go:61–1579

(esmStorage storage.Storage, logger *log.Logger)

)

func esmRouter(esmStorage storage.Storage, logger *log.Logger) rex.Handle {
	var (
		startTime  = time.Now()
		globalETag = fmt.Sprintf(`W/"%s"`, VERSION)
		buildQueue = NewBuildQueue(int(config.BuildConcurrency))
		npmrc      = DefaultNpmRC()
		metaDB     = NewBuildMetaDB(esmStorage)
	)

	// todo: remove old db code after migration is complete
	{
		oldDbFile := path.Join(config.WorkDir, "esm.db")
		if existsFile(oldDbFile) {
			var err error
			metaDB.oldDB, err = OpenBoltDB(oldDbFile)
			if err != nil {
				logger.Errorf("failed to open old db: %v", err)
			}
		}
	}

	// purge npm cache when disk is low or full
	go func() {
		// run an initial check before waiting for the first ticker event
		purgeNPMCacheWhenDiskIsLowOrFull(npmrc, logger)

		ticker := time.NewTicker(1 * time.Hour)
		defer ticker.Stop()
		for range ticker.C {
			go purgeNPMCacheWhenDiskIsLowOrFull(npmrc, logger)
		}
	}()

	return func(ctx *rex.Context) any {
		pathname := ctx.R.URL.Path

		// ban malicious requests
		if strings.HasSuffix(pathname, ".env") || strings.HasSuffix(pathname, ".php") || strings.Contains(pathname, "/.") {
			ctx.SetHeader("Cache-Control", ccImmutable)
			return rex.Status(404, "not found")
		}

		// handle POST API requests
		switch ctx.R.Method {
		case "HEAD", "GET":
			// continue
		case "POST":
			switch pathname {
			case "/transform":
				var options TransformOptions
				err := json.NewDecoder(io.LimitReader(ctx.R.Body, 2*MB)).Decode(&options)
				ctx.R.Body.Close()
				if err != nil {
					return rex.Err(400, "require valid json body")
				}
				if options.Code == "" {
					return rex.Err(400, "Code is required")
				}