uppal/cgrates
1
0
Fork 1
mirror of https://github.com/cgrates/cgrates.git synced 2026-02-11 18:16:24 +05:00
Code Issues Packages Projects Releases Wiki Activity

Revise nats reader integration tests

Browse Source 
They were failing after the ERs structure changes.

Added a commented helper program at the end of the test to
help generate credentials for testing nats JWT functionality
This commit is contained in:
ionutboangiu
2024-09-19 17:18:56 +03:00
committed by Dan Christian Bogos
parent d801352cce
commit edfe2b5ef7
2 changed files with 612 additions and 764 deletions
Download Patch File Download Diff File Expand all files Collapse all files

93
data/conf/samples/ers_nats/cgrates.json
View File

@@ -1,9 +1,4 @@
{
"logger": {
"level": 7
},
"data_db": {
"db_type": "*internal"
},
@@ -12,58 +7,68 @@
"db_type": "*internal"
},
"ers": {
"enabled": true,
"sessions_conns":[],
"ees": {
"enabled": true,
"exporters": [
{
"id": "nats_processed",
"type": "*natsJSONMap",
"export_path": "nats://localhost:4222",
"attempts": 1,
"opts": {
"natsJetStream": true,
"natsSubject": "cgrates_cdrs_processed"
}
}
]
},
"ers": {
"enabled": true,
"sessions_conns":[],
"ees_conns": ["*localhost"],
"readers": [
{
"id": "nats_reader1",
"type": "*natsJSONMap",
"source_path": "nats://127.0.0.1:4222",
"processed_path": "nats://127.0.0.1:4222",
"id": "nats_reader1",
"type": "*natsJSONMap",
"source_path": "nats://127.0.0.1:4222",
"processed_path": "nats://127.0.0.1:4222",
"ees_success_ids": ["nats_processed"],
"opts": {
"natsJetStream": true,
"natsConsumerName": "cgrates",
"natsStreamName": "stream",
"natsSubject": "cgrates_cdrs",
"natsQueueID": "queue",
"natsJetStreamMaxWait": "5s",
"natsJetStreamProcessed": true,
"natsSubjectProcessed": "cgrates_cdrs_processed",
"natsJetStreamMaxWaitProcessed": "5s"
"natsJetStream": true,
"natsConsumerName": "cgrates",
"natsStreamName": "stream",
"natsSubject": "cgrates_cdrs",
"natsQueueID": "queue",
"natsJetStreamMaxWait": "5s"
},
"flags": ["*dryRun"],
"fields":[
"flags": ["*dryRun"],
"fields":[
{"tag": "cdr_template", "type": "*template", "value": "cdr_template"}
]
},
{
"id": "nats_reader2",
"type": "*natsJSONMap",
"source_path": "nats://127.0.0.1:4222",
"processed_path": "nats://127.0.0.1:4222",
"id": "nats_reader2",
"type": "*natsJSONMap",
"source_path": "nats://127.0.0.1:4222",
"processed_path": "nats://127.0.0.1:4222",
"ees_success_ids": ["nats_processed"],
"opts": {
"natsJetStream": true,
"natsConsumerName": "cgrates",
"natsStreamName": "stream",
"natsSubject": "cgrates_cdrs",
"natsQueueID": "queue",
"natsJetStreamMaxWait": "5s",
"natsJetStreamProcessed": true,
"natsSubjectProcessed": "cgrates_cdrs_processed",
"natsJetStreamMaxWaitProcessed": "5s"
"natsJetStream": true,
"natsConsumerName": "cgrates",
"natsStreamName": "stream",
"natsSubject": "cgrates_cdrs",
"natsQueueID": "queue",
"natsJetStreamMaxWait": "5s"
},
"flags": ["*dryRun"],
"fields":[
"flags": ["*dryRun"],
"fields":[
{"tag": "cdr_template", "type": "*template", "value": "cdr_template"}
]
}
]
},
"templates": {
"cdr_template": [
{"tag": "Account", "path": "*cgreq.Account", "type": "*variable", "value": "~*req.Account", "mandatory": true},
@@ -71,5 +76,5 @@
{"tag": "Destination", "path": "*cgreq.Destination", "type": "*variable", "value": "~*req.Destination", "mandatory": true}
]
}
}
}

1283
ers/nats_it_test.go
View File

File diff suppressed because it is too large Load Diff