core

var ErrInvalidPlugin = errors.New("invalid plugin: missing HandleRequest")

var ErrNotFound = errors.New("barry: not found")

var ErrPluginNotFound = errors.New("plugin not found")

var ExecuteAPIFile = func(filePath string, req *http.Request, params map[string]string) ([]byte, error) {
	result, err := LoadPluginAndCallFunc(filePath, req, params)
	if err != nil && err != ErrPluginNotFound {
		return nil, err
	}
	if result != nil {
		return json.Marshal(result)
	}

	return ExecuteAPIFileWithSubprocessFunc(filePath, req, params)
}

var ExecuteAPIFileWithSubprocessFunc = ExecuteAPIFileWithSubprocess

var ExecuteServerFile = func(filePath string, req *http.Request, params map[string]string) (map[string]interface{}, error) {
	result, err := LoadPluginAndCallFunc(filePath, req, params)
	if err != nil && err != ErrPluginNotFound {
		return nil, err
	}
	if result != nil {
		return result, nil
	}

	return ExecuteServerFileWithSubprocessFunc(filePath, req, params)
}

var ExecuteServerFileWithSubprocessFunc = ExecuteServerFileWithSubprocess

var LoadConfig = func(path string) *Config {
	data, err := os.ReadFile(path)
	if err != nil {
		return &Config{
			OutputDir:    "./cache",
			CacheEnabled: false,
			DebugHeaders: false,
			DebugLogs:    false,
		}
	}

	var cfg Config
	yaml.Unmarshal(data, &cfg)

	if cfg.OutputDir == "" {
		cfg.OutputDir = "./cache"
	}

	return &cfg
}

var LoadPluginAndCallFunc = LoadPluginAndCall

var NewLiveReloader = func() LiveReloaderInterface {
	return &LiveReloader{
		clients: make(map[*websocket.Conn]bool),
		upgrader: websocket.Upgrader{
			CheckOrigin: func(r *http.Request) bool {
				return true
			},
		},
	}
}

var NewRouter = func(config Config, ctx RuntimeContext) http.Handler {
	r := &Router{
		config:   config,
		env:      ctx.Env,
		onReload: ctx.OnReload,
	}

	var wg sync.WaitGroup
	wg.Add(3)
	go func() {
		defer wg.Done()
		r.loadRoutes()
	}()
	go func() {
		defer wg.Done()
		r.loadComponentFiles()
	}()
	go func() {
		defer wg.Done()
		r.loadApiRoutes()
	}()
	wg.Wait()

	if ctx.EnableWatch {
		go r.watchEverything()
	}

	return r
}

var SaveCachedHTMLFunc = SaveCachedHTML