Function Proc_IndexesInvoke

src/procedures/proc_list_indexes.c:98–156

CALL db.indexes()

// CALL db.indexes()
ProcedureResult Proc_IndexesInvoke
(
	ProcedureCtx *ctx,
	const SIValue *args,
	const char **yield
) {

	ASSERT(ctx   != NULL);
	ASSERT(args  != NULL);
	ASSERT(yield != NULL);

	// TODO: introduce invoke validation, similar to arithmetic expressions
	// expecting no arguments
	uint arg_count = array_len((SIValue *)args);
	if(arg_count != 0) return PROCEDURE_ERR;

	GraphContext *gc = QueryCtx_GetGraphCtx();

	IndexesContext *pdata = rm_malloc(sizeof(IndexesContext));

	pdata->gc      = gc;
	pdata->out     = array_new(SIValue, 8);
	pdata->indices = array_new(Index, 0);

	//--------------------------------------------------------------------------
	// collect all indices
	//--------------------------------------------------------------------------

	unsigned short n;            // number of schemas
	Schema         *s;           // current schema
	unsigned short idx_count;    // number of indicies in schema
	Index          indicies[4];  // schema indicies

	// collect indices from node schemas
	n = GraphContext_SchemaCount(gc, SCHEMA_NODE);
	for(unsigned short i = 0; i < n; i++) {
		s = GraphContext_GetSchemaByID(gc, i, SCHEMA_NODE);
		idx_count = Schema_GetIndicies(s, indicies);
		for(unsigned short j = 0; j < idx_count; j++) {
			array_append(pdata->indices, indicies[j]);
		}
	}

	// collect indices from edge schemas
	n = GraphContext_SchemaCount(gc, SCHEMA_EDGE);
	for(unsigned short i = 0; i < n; i++) {
		s = GraphContext_GetSchemaByID(gc, i, SCHEMA_EDGE);
		idx_count = Schema_GetIndicies(s, indicies);
		for(uint j = 0; j < idx_count; j++) {
			array_append(pdata->indices, indicies[j]);
		}
	}

	_process_yield(pdata, yield);

	ctx->privateData = pdata;

	return PROCEDURE_OK;