Function Proc_FulltextQueryNodeInvoke

src/procedures/proc_fulltext_query.c:57–107

}

ProcedureResult Proc_FulltextQueryNodeInvoke
(
	ProcedureCtx *ctx,
	const SIValue *args,
	const char **yield
) {
	if(array_len((SIValue *)args) != 2) return PROCEDURE_ERR;
	if(!(SI_TYPE(args[0]) & SI_TYPE(args[1]) & T_STRING)) return PROCEDURE_ERR;

	ctx->privateData = NULL;
	GraphContext *gc = QueryCtx_GetGraphCtx();

	// see if there's a full-text index for given label
	char *err = NULL;
	const char *label = args[0].stringval;
	const char *query = args[1].stringval;

	// get full-text index from schema
	Index idx = GraphContext_GetIndex(gc, label, NULL, 0, IDX_FULLTEXT,
			SCHEMA_NODE);
	if(!idx) return PROCEDURE_ERR; // TODO: this should cause an error to be emitted

	ctx->privateData = rm_malloc(sizeof(QueryNodeContext));
	QueryNodeContext *pdata = ctx->privateData;

	pdata->g      = gc->g;
	pdata->n      = GE_NEW_NODE();
	pdata->idx    = idx;
	pdata->output = array_new(SIValue,  2);

	_process_yield(pdata, yield);

	// execute query
	pdata->iter = Index_Query(pdata->idx, query, &err);

	// raise runtime exception if err != NULL
	if(err) {
		// RediSearch error message is allocated using `rm_strdup`
		// QueryCtx is expecting to free `error` using `free`
		// in which case we have no option but to clone error
		ErrorCtx_SetError("RediSearch: %s", err);
		rm_free(err);
		// raise the exception, we expect an exception handler to be set
		// as procedure invocation is done at runtime
		ErrorCtx_RaiseRuntimeException(NULL);
	}

	ASSERT(pdata->iter != NULL);

	return PROCEDURE_OK;
}

SIValue *Proc_FulltextQueryNodeStep
(