]> git.ipfire.org Git - thirdparty/asterisk.git/commitdiff
res/res_stasis: Fixed wrong StasisEnd timestamp
authorsungtae kim <sungtae@messagebird.com>
Sun, 10 Mar 2019 22:53:36 +0000 (23:53 +0100)
committersungtae kim <sungtae@messagebird.com>
Fri, 15 Mar 2019 21:44:53 +0000 (22:44 +0100)
Because StasisEnd's timestamp created it's own timestamp, it makes
wrong timestamp, compare to other channel event(ChannelDestroyed).
Fixed to getting a timestamp from the Channel's timestamp.

ASTERISK-28333

Change-Id: I5eb8380fc472f1100535a6bc4983c64767026116

res/res_stasis.c

index c9bbbf3c3a327670111f6d33e0f96bdebe049e29..e040d6440ada088a4d6ba948cb29bc50b142a184 100644 (file)
@@ -118,16 +118,23 @@ static struct ast_json *stasis_end_to_json(struct stasis_message *message,
                const struct stasis_message_sanitizer *sanitize)
 {
        struct ast_channel_blob *payload = stasis_message_data(message);
+       struct ast_json *msg;
 
        if (sanitize && sanitize->channel_snapshot &&
                        sanitize->channel_snapshot(payload->snapshot)) {
                return NULL;
        }
 
-       return ast_json_pack("{s: s, s: o, s: o}",
+       msg = ast_json_pack("{s: s, s: o, s: o}",
                "type", "StasisEnd",
-               "timestamp", ast_json_timeval(ast_tvnow(), NULL),
+               "timestamp", ast_json_copy(ast_json_object_get(payload->blob, "timestamp")),
                "channel", ast_channel_snapshot_to_json(payload->snapshot, sanitize));
+       if (!msg) {
+               ast_log(LOG_ERROR, "Failed to pack JSON for StasisEnd message\n");
+               return NULL;
+       }
+
+       return msg;
 }
 
 STASIS_MESSAGE_TYPE_DEFN_LOCAL(end_message_type,
@@ -1034,7 +1041,10 @@ int app_send_end_msg(struct stasis_app *app, struct ast_channel *chan)
                return 0;
        }
 
-       blob = ast_json_pack("{s: s}", "app", stasis_app_name(app));
+       blob = ast_json_pack("{s: s, s: o}",
+               "app", stasis_app_name(app),
+               "timestamp", ast_json_timeval(ast_tvnow(), NULL)
+               );
        if (!blob) {
                ast_log(LOG_ERROR, "Error packing JSON for StasisEnd message\n");
                return -1;