Function _Graph_Bulk_Begin

src/commands/cmd_bulk_insert.c:14–49

process "BEGIN" token, expected to be present only on first bulk-insert batch, make sure graph key doesn't exists, fails if "BEGIN" token is present and graph key 'graphname' already exists

// batch, make sure graph key doesn't exists, fails if "BEGIN" token is present
// and graph key 'graphname' already exists
static int _Graph_Bulk_Begin(RedisModuleCtx *ctx, RedisModuleString ***argv,
							  int *argc, RedisModuleString *rs_graph_name, const char *graphname,
							  bool *begin) {
	ASSERT(argv           !=  NULL);
	ASSERT(argc           !=  NULL);
	ASSERT(begin          !=  NULL);
	ASSERT(graphname      !=  NULL);
	ASSERT(rs_graph_name  !=  NULL);

	const char *token = RedisModule_StringPtrLen(**argv, NULL);
	*begin = strcmp(token, "BEGIN") == 0;

	// do nothing if this is not the first BULK call
	if(*begin == false) return BULK_OK;

	// "BEGIN" token present, skip "BEGIN" token
	(*argv) ++;
	(*argc) --;

	// lock GIL, verify that graph does not already exist
	RedisModuleKey *key = NULL;
	key = RedisModule_OpenKey(ctx, rs_graph_name, REDISMODULE_READ);
	RedisModule_CloseKey(key);

	if(key) {
		char *err;
		int rc __attribute__((unused));
		rc = asprintf(&err, "Graph with name '%s' cannot be created, "\
                      "as key '%s' already exists.", graphname, graphname);
		RedisModule_ReplyWithError(ctx, err);
		free(err);
		return BULK_FAIL;
	}

	return BULK_OK;
}

int Graph_BulkInsert(RedisModuleCtx *ctx, RedisModuleString **argv, int argc) {
	if(argc < 3) return RedisModule_WrongArity(ctx);