Class CustomAggregate

src/util/custom-aggregate.cpp:1–121

class CustomAggregate : public CustomFunction {
public:

	explicit CustomAggregate(
		Napi::Env env,
		Database* db,
		const char* name,
		Napi::Value start,
		Napi::Function step,
		Napi::Value inverse,
		Napi::Value result,
		bool safe_ints
	) :
		CustomFunction(env, db, name, step, safe_ints),
		invoke_result(result.IsFunction()),
		invoke_start(start.IsFunction()),
		inverse(inverse.IsFunction() ? Napi::Persistent(inverse.As<Napi::Function>()) : Napi::FunctionReference()),
		result(result.IsFunction() ? Napi::Persistent(result.As<Napi::Function>()) : Napi::FunctionReference()),
		start(Napi::Persistent(start)) {}

	static void xStep(sqlite3_context* invocation, int argc, sqlite3_value** argv) {
		xStepBase(invocation, argc, argv, &CustomAggregate::fn);
	}

	static void xInverse(sqlite3_context* invocation, int argc, sqlite3_value** argv) {
		xStepBase(invocation, argc, argv, &CustomAggregate::inverse);
	}

	static void xValue(sqlite3_context* invocation) {
		xValueBase(invocation, false);
	}

	static void xFinal(sqlite3_context* invocation) {
		xValueBase(invocation, true);
	}

private:

	static inline void xStepBase(sqlite3_context* invocation, int argc, sqlite3_value** argv, const Napi::FunctionReference CustomAggregate::*ptrtm) {
		AGGREGATE_START();

		napi_value args_fast[5];
		napi_value* args = argc <= 4 ? args_fast : ALLOC_ARRAY<napi_value>(argc + 1);
		args[0] = acc->value.Value();
		if (argc != 0) Data::GetArgumentsJS(env, args + 1, argv, argc, self->safe_ints);

		Napi::Value returnValue = SafeCall(env, (self->*ptrtm).Value(), env.Undefined(), argc + 1, args);
		if (args != args_fast) delete[] args;

		if (env.IsExceptionPending()) {
			self->PropagateJSError(invocation);
		} else {
			if (!returnValue.IsUndefined()) acc->value.Reset(returnValue, 1);
		}
	}

	static inline void xValueBase(sqlite3_context* invocation, bool is_final) {
		AGGREGATE_START();

		if (!is_final) {