As a workaround, this seems to work and $sht(server=>auth::token) is always
reported back by kamcmd htable.dump server :
route[HTTP_AUTH_REPLY] {
xinfo("[$ci][$rm] HTTP_AUTH_REPLY received");
if($http_ok) {
xinfo("[HTTP_AUTH_REPLY][$http_rs] request was sucessful");
} else {
xinfo("[HTTP_AUTH_REPLY][$http_rs] request was unsucessful");
}
if($http_err) {
xinfo("[HTTP_AUTH_REPLY][ERROR] $http_err");
}
xinfo("[HTTP_AUTH_REPLY][RESPONSE][BODY] $http_rb");
# lock auth token
sht_lock("server=>auth::token");
# set token
$sht(server=>auth::token) = $http_rb;
# unlock auth token
sht_unlock("server=>auth::token");
}
event_route[htable:expired:server] {
xinfo("[HTABLE:expired:server] initializing");
$http_req(all) = $null;
$http_req(timeout) = 100;
$http_req(method) = "POST";
$http_req(suspend) = 1;
$http_req(hdr) = "Content-Type: application/json";
$http_req(body) = '{"email": "bran...@cryy.com", "password":""}';
http_async_query("https://www.cryy.com/api/auth/token;, "HTTP_AUTH
_REPLY");
}
event_route[htable:mod-init] {
# generate auth token into
http_client_query("https://www.cryy.com/api/auth/token;, '{"email": "
bran...@cryy.com", "password":""}', "$var(result)");
# lock auth token
sht_lock("server=>auth::token");
# set auth token
$sht(server=>auth::token) = $var(result);
# unlock auth token
sht_unlock("server=>auth::token");
xinfo("AUTH_TOKEN_RECEIVED, $sht(server=>auth::token)");
}
Is working -- I have to use http_client on htable module initialization, as
http_async_client seems to start its workers after mod-init and results in:
Oct 31 21:04:37 main kamailio[2088]: ERROR: http_async_client
[async_http.c:622]:
async_push_query(): failed to pass the query to async workers
Oct 31 21:04:37 main kamailio[2088]: ERROR: http_async_client
[async_http.c:588]:
async_send_query(): failed to relay query: https://www.cryy.com/api/auth
/token
(workers start after mod-init request) shown here:
Oct 31 21:04:38 main kamailio[2088]: INFO: http_async_client [async_http.c:84]:
async_http_init_worker(): started worker process: 1
Oct 31 21:04:38 main kamailio[2088]: INFO: http_async_client [async_http.c:84]:
async_http_init_worker(): started worker process: 2
Oct 31 21:04:38 main kamailio[2088]: INFO: http_async_client [async_http.c:84]:
async_http_init_worker(): started worker process: 3
Oct 31 21:04:38 main kamailio[2088]: INFO: http_async_client [async_http.c:84]:
async_http_init_worker(): started worker process: 4
So I suspect there are two separate issues going on here, 1) handling htable
in memory between htable-mod-init and htable:expired:server and 2) unable
to use http_async_client inside htable-mod:init. I've also double checked
that these modules are loaded after htable in kamailio config.
I look forward to hearing any input anyone may have on this, thanks for
your time in advance!
- Brandon
On Fri, Oct 30, 2020 at 10:55 PM Brandon Armstead wrote:
> Running 5.5.0-dev3
>
> modparam("htable", "htable", "ipban=>size=8;autoexpire=300;dmqreplicate
> =1;")
> modparam("htable", "enable_dmq", 1)
> modparam("htable", "dmq_init_sync", 1)
> modparam("htable", "timer_procs", 4)
> modparam("htable", "timer_interval", 5)
> modparam("htable", "db_expires", 1)
> modparam("htable", "htable", "account=>size=4;dmqreplicate=1;")
> modparam("htable", "htable", "server=>size=4;autoexpire=15;")
>
> I'm attempting to retrieve an auth token in the init process and also
> refresh the token upon expiration in the htable:expired event.
>
> I'm seeing some behavior where every other execution of htable:expired
> the variable $sht(server=>auth::token) is set per kamcmd htable.dump
> server, however xinfo() reports that the token was retrieved in the
> variable $sht(server=>auth::token).
>
> Please see remaining event route config below:
>
> event_route[htable:mod-init] {
>
> # generate auth token into
>
>
> http_client_query("https://www.cryy.com/api/auth/token;, '{"email": "
> bran...@cryy.com", "password":""}', "$var(result)");
>
>
> sht_lock("server=>auth::token");
>
>
> $sht(server=>auth::token) = $var(result);
>
>
> sht_unlock("server=>auth::token");
>
>
>
> xinfo("AUTH_TOKEN_RECEIVED, $sht(server=>auth::token)");
>
> }
>
>
> event_route[htable:expired:server] {
>
> # process expired htable, renew auth token
>
> xinfo("AUTH_TOKEN_EXPIRED, lets retrieve a new one");
>
>
> http_client_query("https://www.cryy.com/api/auth/token;, '{"email": "
> bran...@cryy.com", "password":""}', "$var(result)");
>
>
> sht_lock("server=>auth::token");
>
> $sht(server=>auth::time) = $TS;
>
> $sht(server=>auth::token) = $var(result);
>
> sht_unlock("server=>auth::token");
>
>
> xinfo("AUTH_TOKEN_RECEIVED, $sht(server=>auth::token)");
>
> xinfo("AUTH_TOKEN_TIME,
