// Copyright 2020 The OPA Authors.  All rights reserved.
// Use of this source code is governed by an Apache2
// license that can be found in the LICENSE file.

package opa

import (
	"encoding/json"
	"os"

	"github.com/open-policy-agent/opa/internal/wasm/sdk/opa/errors"
	"github.com/open-policy-agent/opa/internal/wasm/util"
)

// WithPolicyFile configures a policy file to load.
func (o *OPA) WithPolicyFile(fileName string) *OPA {
	policy, err := os.ReadFile(fileName)
	if err != nil {
		o.configErr = errors.New(errors.InvalidConfigErr, err.Error())
		return o
	}

	o.policy = policy
	return o
}

// WithPolicyBytes configures the compiled policy to load.
func (o *OPA) WithPolicyBytes(policy []byte) *OPA {
	o.policy = policy
	return o
}

// WithDataFile configures the JSON data file to load.
func (o *OPA) WithDataFile(fileName string) *OPA {
	data, err := os.ReadFile(fileName)
	if err != nil {
		o.configErr = errors.New(errors.InvalidConfigErr, err.Error())
		return o
	}

	o.data = data
	return o
}

// WithDataBytes configures the JSON data to load.
func (o *OPA) WithDataBytes(data []byte) *OPA {
	o.data = data
	return o
}

// WithDataJSON configures the JSON data to load.
func (o *OPA) WithDataJSON(data any) *OPA {
	v, err := json.Marshal(data)
	if err != nil {
		o.configErr = errors.New(errors.InvalidConfigErr, err.Error())
		return o
	}

	o.data = v
	return o
}

// WithMemoryLimits configures the memory limits (in bytes) for a single policy
// evaluation.
func (o *OPA) WithMemoryLimits(min, max uint32) *OPA {
	if min < 2*util.PageSize {
		o.configErr = errors.New(errors.InvalidConfigErr, "too low minimum memory limit")
		return o
	}

	if max == 0 {
		max = 0xffffffff
	}

	if min > max {
		o.configErr = errors.New(errors.InvalidConfigErr, "too low maximum memory limit")
		return o
	}

	o.memoryMinPages, o.memoryMaxPages = util.Pages(min), util.Pages(max)
	return o
}

// WithPoolSize configures the maximum number of simultaneous policy
// evaluations, i.e., the maximum number of underlying WASM instances
// active at any time. The default is the number of logical CPUs
// usable for the process as per runtime.NumCPU().
func (o *OPA) WithPoolSize(size uint32) *OPA {
	if size == 0 {
		o.configErr = errors.New(errors.InvalidConfigErr, "pool size")
		return o
	}

	o.poolSize = size
	return o
}

// WithErrorLogger configures an error logger invoked with all the errors.
func (o *OPA) WithErrorLogger(logger func(error)) *OPA {
	o.logError = logger
	return o
}