lindeas
/
jilo
1
1
Fork 0
Code Issues Pull Requests Packages Projects Releases 2 Wiki Activity

Adds Jicofo participant joining event.

main
Yasen Pramatarov 2024-06-05 21:01:55 +03:00
parent d558096288
commit 59c8a6f520
1 changed files with 18 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
jilo
View File

@ -51,7 +51,7 @@ MYSQL_DB=${MYSQL_DB:-$DEFAULT_MYSQL_DB}
db_get_state_template="SELECT filename, filetime, filesize, position, inode FROM state WHERE jitsi_component = '%s';" db_get_state_template="SELECT filename, filetime, filesize, position, inode FROM state WHERE jitsi_component = '%s';"
db_set_state_template="UPDATE state SET time=datetime('now'), filename='%s', filetime='%s', filesize='%s', position='%s', inode='%s' WHERE jitsi_component = '%s';" db_set_state_template="UPDATE state SET time=datetime('now'), filename='%s', filetime='%s', filesize='%s', position='%s', inode='%s' WHERE jitsi_component = '%s';"
db_insert_conference_template="INSERT INTO conferences (jitsi_component, conference_name, conference_id, start, end) VALUES ('%s', '%s', '%s', '%s', '%s');" db_insert_conference_template="INSERT INTO conferences (jitsi_component, conference_name, conference_id, start, end) VALUES ('%s', '%s', '%s', '%s', '%s');"
db_insert_participant_template="INSERT INTO participants (conference_id, event_time, event_type, endpoint_id, stats_id, participant_ip) VALUES ('%s', '%s', '%s', '%s', '%s', '%s');" db_insert_participant_template="INSERT INTO participants (jitsi_component, conference_id, event_time, event_type, endpoint_id, stats_id, participant_ip) VALUES ('%s', '%s', '%s', '%s', '%s', '%s', '%s');"
db_drop=" db_drop="
DROP TABLE IF EXISTS conferences; DROP TABLE IF EXISTS conferences;
@ -67,6 +67,7 @@ db_create="CREATE TABLE conferences (
); );
CREATE TABLE participants ( CREATE TABLE participants (
id INTEGER PRIMARY_KEY, id INTEGER PRIMARY_KEY,
jitsi_component TEXT,
conference_id INTEGER, conference_id INTEGER,
event_time TEXT, event_time TEXT,
event_type TEXT, event_type TEXT,
@ -204,7 +205,7 @@ jitsi_log_parse() {
participant_endpoint_id="${BASH_REMATCH[2]}" participant_endpoint_id="${BASH_REMATCH[2]}"
participant_stats_id="${BASH_REMATCH[3]}" participant_stats_id="${BASH_REMATCH[3]}"
if [[ -n "$conference_id" ]]; then if [[ -n "$conference_id" ]]; then
db_insert=$(printf "$db_insert_participant_template" "$conference_id" "$event_time" "$event_type" "$participant_endpoint_id" "$participant_stats_id" "") db_insert=$(printf "$db_insert_participant_template" "$jitsi_component" "$conference_id" "$event_time" "$event_type" "$participant_endpoint_id" "$participant_stats_id" "")
db_query "$db_insert" db_query "$db_insert"
fi fi
@ -214,7 +215,7 @@ jitsi_log_parse() {
event_type='pair selected' event_type='pair selected'
participant_IP="${BASH_REMATCH[3]}" participant_IP="${BASH_REMATCH[3]}"
if [[ -n "$conference_id" ]]; then if [[ -n "$conference_id" ]]; then
db_insert=$(printf "$db_insert_participant_template" "$conference_id" "$event_time" "$event_type" "$participant_endpoint_id" "$participant_stats_id" "$participant_IP") db_insert=$(printf "$db_insert_participant_template" "$jitsi_component" "$conference_id" "$event_time" "$event_type" "$participant_endpoint_id" "$participant_stats_id" "$participant_IP")
db_query "$db_insert" db_query "$db_insert"
fi fi
@ -223,7 +224,7 @@ jitsi_log_parse() {
event_time="${BASH_REMATCH[1]}" event_time="${BASH_REMATCH[1]}"
event_type='participant leaving' event_type='participant leaving'
if [[ -n "$conference_id" ]]; then if [[ -n "$conference_id" ]]; then
db_insert=$(printf "$db_insert_participant_template" "$conference_id" "$event_time" "$event_type" "$participant_endpoint_id" "$participant_stats_id" "$participant_IP") db_insert=$(printf "$db_insert_participant_template" "$jitsi_component" "$conference_id" "$event_time" "$event_type" "$participant_endpoint_id" "$participant_stats_id" "$participant_IP")
db_query "$db_insert" db_query "$db_insert"
# the participant left, forget about him # the participant left, forget about him
unset $event_time $event_type $participant_endpoint_id $participant_stats_id $participant_IP unset $event_time $event_type $participant_endpoint_id $participant_stats_id $participant_IP
@ -252,6 +253,19 @@ jitsi_log_parse() {
conference_name="${BASH_REMATCH[2]}" conference_name="${BASH_REMATCH[2]}"
start_times["$conference_name"]="$timestamp" start_times["$conference_name"]="$timestamp"
# locate participant joining event
elif [[ "$line" =~ ([0-9-]+\ [0-9:.]+)\ [A-Z]+:.*\[room=([^ ]+)@.*\ meeting_id=([a-zA-Z0-9-]+)\]\ .*\.onMemberJoined.*:\ Member\ joined:([a-zA-Z0-9]+)\ stats-id=([a-zA-Z0-9-]+) ]]; then
event_time="${BASH_REMATCH[1]}"
event_type='participant joining'
conference_name="${BASH_REMATCH[2]}"
conference_id="${BASH_REMATCH[3]}"
participant_endpoint_id="${BASH_REMATCH[4]}"
participant_stats_id="${BASH_REMATCH[5]}"
if [[ -n "$conference_id" ]]; then
db_insert=$(printf "$db_insert_participant_template" "$jitsi_component" "$conference_id" "$event_time" "$event_type" "$participant_endpoint_id" "$participant_stats_id" "")
db_query "$db_insert"
fi
# locate the corresponding conference ending event # locate the corresponding conference ending event
elif [[ "$line" =~ ([0-9-]+\ [0-9:.]+)\ [A-Z]+:.*\[room=([^ ]+)@.*\ meeting_id=([a-zA-Z0-9-]+)\]\ JitsiMeetConferenceImpl\.stop ]]; then elif [[ "$line" =~ ([0-9-]+\ [0-9:.]+)\ [A-Z]+:.*\[room=([^ ]+)@.*\ meeting_id=([a-zA-Z0-9-]+)\]\ JitsiMeetConferenceImpl\.stop ]]; then
end_time="${BASH_REMATCH[1]}" end_time="${BASH_REMATCH[1]}"