Function dm_send_custom_req

modules/aaa_diameter/dm_peer.c:453–509

static int dm_send_custom_req(struct dm_message *msg)
{
	str tid_str;
	struct msg *dmsg;
	struct avp *avp;
	struct avp_hdr *h;
	union avp_value val;
	struct dict_object *req; /* a custom Diameter request */
	int rc;

	FD_CHECK(fd_dict_search(fd_g_config->cnf_dict, DICT_COMMAND, CMD_BY_CODE_R,
	      &msg->cmd_code, &req, ENOENT));

	FD_CHECK(fd_msg_new(req, MSGFL_ALLOC_ETEID, &dmsg));

	/* App id */
	{
		struct msg_hdr *h;
		FD_CHECK(fd_msg_hdr(dmsg, &h));
		h->msg_appl = msg->app_id;
	}

	/* include all AVPs from the input JSON */
	if (dm_pack_avps(dmsg, &msg->avps) != 0) {
		LM_ERR("failed to pack AVPs\n");
		return -1;
	}

	/* check if we already have a Session-Id in the message - if so, use it! */
	rc = fd_msg_search_avp(dmsg, dm_dict.Session_Id, &avp);
	if (rc != 0) {
		/* Transaction-Id */
		struct timeval now;
		char tid[16 + 1];
		LM_DBG("No Session-Id in Answer, forcing Transaction-Id\n");

		FD_CHECK(fd_msg_avp_new(dm_dict.Transaction_Id, 0, &avp));

		gettimeofday(&now, NULL);
		sprintf(tid, "%ld%ld", now.tv_sec, now.tv_usec);

		memset(&val, 0, sizeof val);
		val.os.data = (unsigned char *)tid;
		val.os.len = strlen(tid);
		FD_CHECK(fd_msg_avp_setvalue(avp, &val));
		FD_CHECK(fd_msg_avp_add(dmsg, MSG_BRW_LAST_CHILD, avp));

		tid_str = (str){(char *)val.os.data, val.os.len};
	} else {
		FD_CHECK(fd_msg_avp_hdr(avp, &h));
		tid_str = (str){(char *)h->avp_value->os.data, h->avp_value->os.len};
	}
	FD_CHECK(dm_add_pending_reply(&tid_str, msg->reply_cond));

	FD_CHECK(fd_msg_send(&dmsg, NULL, NULL));
	return 0;
}