test/agent/scenarios: Add bulk calls

Gitlab: #687

Change-Id: Ib21093ab520165f02631aab483c1a86efc31aae7

test/agent/Makefile.am

@@ -24,6 +24,7 @@ MODULES =                                       \
 	examples/passive-agent.scm              \
 	jami/logger.scm                         \
 	jami/signal.scm                         \
+	scenarios/bulk-calls/scenario.scm       \
 	scenarios/peer-monitor/scenario.scm
 
 GOBJECTS = $(MODULES:%=%.go)

test/agent/scenarios/bulk-calls/agent.scm

+../../agent.scm
\ No newline at end of file

test/agent/scenarios/bulk-calls/jami

+../../jami/
\ No newline at end of file

test/agent/scenarios/bulk-calls/run-scenario

+#!/bin/sh
+
+tmp_alice=$(mktemp --tmpdir --directory "jami-bulk-calls.XXXXXXXXXX")
+tmp_bob=$(mktemp --tmpdir --directory "jami-bulk-calls.XXXXXXXXXX")
+
+export GUILE_AUTO_COMPILE=0
+export SIPLOGLEVEL=5
+
+touch bob.log
+
+export XDG_CONFIG_HOME="$tmp_bob"
+export XDG_CACHE_HOME="$tmp_bob"
+export XDG_DATA_HOME="$tmp_bob"
+
+export JAMI_LOG_FILE="bob.log"
+./scenario.scm "bob" > bob-guile.txt 2>&1 &
+
+bob_pid=$!
+
+bob_id=$(tail -f "bob.log" | grep -m 1 "Bob is ready @" | cut -d '@' -f 2)
+
+export XDG_CONFIG_HOME="$tmp_alice"
+export XDG_CACHE_HOME="$tmp_alice"
+export XDG_DATA_HOME="$tmp_alice"
+export JAMI_LOG_FILE="alice.log"
+./scenario.scm "alice" "$bob_id" > alice-guile.txt 2>&1
+
+wait $bob_pid
+
+exit $?

test/agent/scenarios/bulk-calls/scenario.scm

+#!/usr/bin/env -S ./agent.exe --no-auto-compile -e main -s
+!#
+
+;;; Commentary:
+;;;
+;;; This scenario tests calling a peer in a single registration.
+;;;
+;;; Parameters:
+;;;   CALL-COUNT
+;;;   GRACE-PERIOD
+;;;
+;;; Alice's view:
+;;;   while call-count < CALL-COUNT:
+;;;     call bob
+;;;     wait GRACE-PERIOD
+;;;     hangup bob
+;;;     wait GRACE-PERIOD
+;;;   exit okay
+;;;
+;;; Bob's view:
+;;;   while call-count < CALL-COUNT:
+;;;     wait-call alice -> 1+ call-count
+;;;   exit cal-count = CALL-COUNT
+;;;
+;;; Code:
+
+(use-modules
+ (ice-9 exceptions)
+ (ice-9 match)
+ (ice-9 threads)
+ ((agent) #:prefix agent:)
+ ((jami account) #:prefix account:)
+ ((jami call) #:prefix call:)
+ ((jami signal) #:prefix jami:)
+ ((jami logger) #:prefix jami:))
+
+(define CALL-COUNT 50)
+(define GRACE-PERIOD 4)
+
+(define (make-agent account-id)
+  (agent:make-agent account-id
+                    #:details
+                    '(("Account.upnpEnabled" . "false")
+                      ("TURN.enable" . "true"))))
+
+(define (alice bob-id)
+
+  (jami:info "Alice is starting with bob ~a" bob-id)
+
+  (define me (make-agent "afafafafafafafaf"))
+
+  (unless (agent:make-friend me bob-id)
+    (raise-exception
+     (make-exception
+      (make-exception-with-message "Can't make friend with bob"))))
+
+  ;; Wait for Bob to install call handlers.
+  (sleep (* 2 GRACE-PERIOD))
+
+  (let loop ([cnt 1])
+    (when (<= cnt CALL-COUNT)
+      (jami:info "Alice sending call #~a" cnt)
+      (let ([this-call-id ""])
+        (jami:with-signal-sync
+         'state-changed
+         (lambda (account-id call-id state code)
+           (and (string= account-id (agent:account-id me))
+                (string= call-id this-call-id)
+                (string= state "CURRENT")))
+         GRACE-PERIOD
+         (set! this-call-id (agent:call-friend me bob-id)))
+
+        (sleep GRACE-PERIOD)
+        (call:hang-up (agent:account-id me) this-call-id)
+        (sleep GRACE-PERIOD))
+
+      (loop (1+ cnt)))))
+
+(define (bob)
+
+  (jami:info "Bob is starting")
+
+  (define me (make-agent "bfbfbfbfbfbfbfbf"))
+
+  (jami:info "Bob is ready @~a" (agent:peer-id me))
+
+  ;; Wait for Alice.
+  (jami:with-signal-sync
+   'incoming-trust-request
+   (lambda (account-id conversation-id peer-id payload received)
+     (let ([sync? (string= account-id (agent:account-id me))])
+       (when sync?
+         (jami:info "accepting trust request: ~a ~a" account-id peer-id)
+         (account:accept-trust-request account-id peer-id))
+       sync?)))
+
+
+  ;; Accept all incoming calls with media.
+  (let ([mtx (make-recursive-mutex)]
+        [cnd (make-condition-variable)]
+        [received 0])
+    (with-mutex mtx
+      (jami:with-signal
+       'incoming-call/media
+       (lambda (account-id call-id peer media-lst)
+         (when (string= account-id (agent:account-id me))
+           (call:accept account-id call-id media-lst)
+           (with-mutex mtx
+             (set! received (1+ received))
+             (jami:info "Bob has received: ~a calls" received)
+             (when (= received CALL-COUNT)
+               (signal-condition-variable cnd)))))
+       (let ([success?
+              (wait-condition-variable
+               cnd mtx (+ (current-time) (* 4 GRACE-PERIOD CALL-COUNT)))])
+         (jami:info "Summary: ~a%" (* 100 (/ received CALL-COUNT)))
+         (exit success?))))))
+
+(define (main args)
+
+  (match (cdr args)
+    [("alice" bob-id) (alice bob-id)]
+    [("bob") (bob)]
+    [_
+     (jami:error "Invalid arguments: ~a" args)
+     (jami:error "Usage: ~a alice|bob [ARG]\n" (car args))
+     (exit EXIT_FAILURE)])
+
+  (jami:info "bye bye")
+
+  (exit EXIT_SUCCESS))