Files
cgrates/agents/janusagent_test.go
2024-08-02 09:36:54 +02:00

94 lines
2.8 KiB
Go

/*
Real-time Online/Offline Charging System (OCS) for Telecom & ISP environments
Copyright (C) ITsysCOM GmbH
This program is free software: you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
the Free Software Foundation, either version 3 of the License, or
(at your option) any later version.
This program is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
GNU General Public License for more details.
You should have received a copy of the GNU General Public License
along with this program. If not, see <http://www.gnu.org/licenses/>
*/
package agents
import (
"net/http"
"net/http/httptest"
"testing"
"github.com/cgrates/birpc/context"
"github.com/cgrates/cgrates/utils"
)
func TestV1WarnDisconnect(t *testing.T) {
ja := &JanusAgent{}
err := ja.V1WarnDisconnect(nil, nil, nil)
if err != utils.ErrNotImplemented {
t.Errorf("Expected error %v, got %v", utils.ErrNotImplemented, err)
}
}
func TestV1DisconnectPeerJanus(t *testing.T) {
ja := &JanusAgent{}
var ctx context.Context
var args *utils.DPRArgs
var msg *string
err := ja.V1DisconnectPeer(&ctx, args, msg)
if err != utils.ErrNotImplemented {
t.Errorf("Expected error %v, got %v", utils.ErrNotImplemented, err)
}
}
func TestV1AlterSession(t *testing.T) {
ja := &JanusAgent{}
var ctx context.Context
var event utils.CGREvent
var msg *string
err := ja.V1AlterSession(&ctx, event, msg)
if err != utils.ErrNotImplemented {
t.Errorf("Expected error %v, got %v", utils.ErrNotImplemented, err)
}
}
func TestV1DisconnectSession(t *testing.T) {
ja := &JanusAgent{}
var ctx context.Context
cgrEv := utils.CGREvent{
Event: map[string]interface{}{},
}
var reply string
err := ja.V1DisconnectSession(&ctx, cgrEv, &reply)
if err == nil {
t.Fatalf("Expected, got %v", err)
}
if reply == utils.OK {
t.Errorf("Expected reply %v, got %v", utils.OK, reply)
}
}
func TestCORSOptions(t *testing.T) {
ja := &JanusAgent{}
rr := httptest.NewRecorder()
req, err := http.NewRequest("OPTIONS", "/test", nil)
if err != nil {
t.Fatal(err)
}
ja.CORSOptions(rr, req)
if origin := rr.Header().Get("Access-Control-Allow-Origin"); origin != "" {
t.Errorf("Expected Access-Control-Allow-Origin header to be empty, got %v", origin)
}
if methods := rr.Header().Get("Access-Control-Allow-Methods"); methods == "POST, GET, OPTIONS, PUT, DELETE" {
t.Errorf("Expected Access-Control-Allow-Methods header to be 'POST, GET, OPTIONS, PUT, DELETE', got %v", methods)
}
if headers := rr.Header().Get("Access-Control-Allow-Headers"); headers == "Accept, Accept-Language, Content-Type" {
t.Errorf("Expected Access-Control-Allow-Headers header to be 'Accept, Accept-Language, Content-Type', got %v", headers)
}
}