Function dm_send_request_async

modules/aaa_diameter/aaa_diameter.c:549–616

}

static int dm_send_request_async(struct sip_msg *msg, async_ctx *ctx,
				int *app_id, int *cmd_code, str *avp_json, pv_spec_t *rpl_avps_pv)
{
	aaa_message *dmsg = NULL;
	struct dict_object *req;
	cJSON *avps;
	struct dm_async_msg *amsg;
	struct dm_cond *cond;

	if (fd_dict_search(fd_g_config->cnf_dict, DICT_COMMAND, CMD_BY_CODE_R,
	      cmd_code, &req, ENOENT) == ENOENT) {
		LM_ERR("unrecognized Request command code: %d\n", *cmd_code);
		LM_ERR("to fix this, you can define the Request/Answer format in the "
		       "'extra-avps-file' config file\n");
		return -1;
	}

	LM_DBG("found a matching dict entry for command code %d\n", *cmd_code);

	if (!avp_json || !avp_json->s) {
		LM_ERR("NULL JSON input\n");
		return -1;
	}

	avps = cJSON_Parse(avp_json->s);
	if (!avps) {
		LM_ERR_DM_JSON("failed to parse input JSON", avp_json);
		return -1;
	}

	if (avps->type != cJSON_Array) {
		LM_ERR_DM_JSON("bad JSON type: must be Array", avp_json);
		goto error;
	}

	dmsg = _dm_create_message(NULL, AAA_CUSTOM_REQ, *app_id, *cmd_code, NULL);
	if (!dmsg) {
		LM_ERR("oom\n");
		goto error;
	}

	if (dm_build_avps(&((struct dm_message *)(dmsg->avpair))->avps,
	                     avps->child) != 0) {
		LM_ERR_DM_JSON("failed to unpack JSON", avp_json);
		_dm_destroy_message(dmsg);
		goto error;
	}
	if (_dm_send_message_async(NULL, dmsg, &async_status, &cond) < 0) {
		LM_ERR("cannot send async message!\n");
		goto error;
	}

	amsg = dm_get_async_msg(rpl_avps_pv, cond);
	if (!amsg)
		goto error;
	cJSON_Delete(avps);

	ASYNC_SET_RESUME_F(ctx, dm_send_request_async_reply);