Function dm_send_request

modules/aaa_diameter/aaa_diameter.c:282–360

					(_j)->len, (_j)->s, (_j)->len); \
	} while (0)
static int dm_send_request(struct sip_msg *msg, 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;
	int rc;
	struct dm_cond *rpl = NULL;
	char *rpl_avps = NULL;

	if ((rc = fd_dict_search(fd_g_config->cnf_dict, DICT_COMMAND,CMD_BY_CODE_R,
	      cmd_code, &req, ENOENT)) != 0) {
		LM_ERR("unrecognized Request command code: %d (errno: %d)\n", *cmd_code, rc);
		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;
	}
	cJSON_Delete(avps);

	if (_dm_send_message(NULL, dmsg, &rpl) != 0)
		goto ret;
	rc = _dm_get_message_response(rpl, (rpl_avps_pv?&rpl_avps:NULL));

	if (rpl_avps_pv) {
		pv_value_t val = {(str){rpl_avps, strlen(rpl_avps)}, 0, PV_VAL_STR};
		if (pv_set_value(msg, rpl_avps_pv, 0, &val) != 0)
			LM_ERR("failed to set output rpl_avps pv to: %s\n", rpl_avps);