Newer
Older
ast_channel_state_set(chan_david, AST_STATE_UP);
bridge = ast_bridge_basic_new();
ast_test_validate(test, bridge != NULL);
do_sleep(&to_sleep);
ast_test_validate(test, !ast_bridge_impart(bridge, chan_charlie, NULL, NULL, AST_BRIDGE_IMPART_CHAN_DEPARTABLE));
do_sleep(&to_sleep);
ast_test_validate(test, !ast_bridge_impart(bridge, chan_david, NULL, NULL, AST_BRIDGE_IMPART_CHAN_DEPARTABLE));
do_sleep(&to_sleep);
ast_test_validate(test, !ast_bridge_impart(bridge, chan_bob, NULL, NULL, AST_BRIDGE_IMPART_CHAN_DEPARTABLE));
do_sleep(&to_sleep);
ast_test_validate(test, !ast_bridge_impart(bridge, chan_alice, NULL, NULL, AST_BRIDGE_IMPART_CHAN_DEPARTABLE));
do_sleep(&to_sleep);
ast_test_validate(test, !ast_bridge_depart(chan_alice));
ast_test_validate(test, !ast_bridge_depart(chan_bob));
ast_test_validate(test, !ast_bridge_depart(chan_charlie));
ast_test_validate(test, !ast_bridge_depart(chan_david));
HANGUP_CHANNEL(chan_alice, AST_CAUSE_NORMAL);
HANGUP_CHANNEL(chan_bob, AST_CAUSE_NORMAL);
HANGUP_CHANNEL(chan_charlie, AST_CAUSE_NORMAL);
HANGUP_CHANNEL(chan_david, AST_CAUSE_NORMAL);
result = verify_mock_cdr_record(test, &alice_expected_one, 6);
return result;
}
AST_TEST_DEFINE(test_cdr_park)
{
RAII_VAR(struct ast_channel *, chan_alice, NULL, safe_channel_release);
RAII_VAR(struct ast_channel *, chan_bob, NULL, safe_channel_release);
RAII_VAR(struct ast_bridge *, bridge, NULL, safe_bridge_destroy);
2035
2036
2037
2038
2039
2040
2041
2042
2043
2044
2045
2046
2047
2048
2049
2050
2051
2052
2053
2054
2055
2056
2057
2058
2059
2060
2061
2062
2063
2064
2065
2066
2067
2068
2069
2070
2071
2072
2073
2074
2075
2076
RAII_VAR(struct ast_cdr_config *, config, ao2_alloc(sizeof(*config), NULL),
ao2_cleanup);
struct timespec to_sleep = {1, 0};
struct ast_party_caller bob_caller = BOB_CALLERID;
struct ast_party_caller alice_caller = ALICE_CALLERID;
struct ast_cdr bob_expected = {
.clid = "\"Bob\" <200>",
.src = "200",
.dst = "200",
.dcontext = "default",
.channel = CHANNEL_TECH_NAME "/Bob",
.lastapp = "Park",
.lastdata = "701",
.billsec = 1,
.amaflags = AST_AMA_DOCUMENTATION,
.disposition = AST_CDR_ANSWERED,
.accountcode = "200",
};
struct ast_cdr alice_expected = {
.clid = "\"Alice\" <100>",
.src = "100",
.dst = "100",
.dcontext = "default",
.channel = CHANNEL_TECH_NAME "/Alice",
.lastapp = "Park",
.lastdata = "700",
.billsec = 1,
.amaflags = AST_AMA_DOCUMENTATION,
.disposition = AST_CDR_ANSWERED,
.accountcode = "100",
.next = &bob_expected,
};
enum ast_test_result_state result = AST_TEST_NOT_RUN;
switch (cmd) {
case TEST_INIT:
info->name = __func__;
info->category = TEST_CATEGORY;
info->summary = "Test cdrs for a single party entering Park";
info->description =
"Test the properties of a CDR for calls that are\n"
"answered, enters Park, and leaves it.";
return AST_TEST_NOT_RUN;
case TEST_EXECUTE:
break;
}
SWAP_CONFIG(config, debug_cdr_config);
CREATE_ALICE_CHANNEL(chan_alice, &alice_caller, &alice_expected);
CREATE_BOB_CHANNEL(chan_bob, &bob_caller, &bob_expected);
ast_channel_lock(chan_alice);
EMULATE_APP_DATA(chan_alice, 1, "Park", "700");
ast_setstate(chan_alice, AST_STATE_UP);
ast_channel_unlock(chan_alice);
ast_channel_lock(chan_bob);
EMULATE_APP_DATA(chan_bob, 1, "Park", "701");
ast_setstate(chan_bob, AST_STATE_UP);
ast_channel_unlock(chan_bob);
bridge = ast_bridge_base_new(AST_BRIDGE_CAPABILITY_HOLDING,
AST_BRIDGE_FLAG_MERGE_INHIBIT_TO | AST_BRIDGE_FLAG_MERGE_INHIBIT_FROM
| AST_BRIDGE_FLAG_SWAP_INHIBIT_FROM | AST_BRIDGE_FLAG_TRANSFER_PROHIBITED,
Richard Mudgett
committed
"test_cdr", "test_cdr_park", NULL);
ast_test_validate(test, bridge != NULL);
do_sleep(&to_sleep);
ast_test_validate(test, !ast_bridge_impart(bridge, chan_alice, NULL, NULL, AST_BRIDGE_IMPART_CHAN_DEPARTABLE));
do_sleep(&to_sleep);
ast_test_validate(test, !ast_bridge_impart(bridge, chan_bob, NULL, NULL, AST_BRIDGE_IMPART_CHAN_DEPARTABLE));
do_sleep(&to_sleep);
2107
2108
2109
2110
2111
2112
2113
2114
2115
2116
2117
2118
2119
2120
2121
2122
2123
2124
2125
2126
2127
2128
2129
2130
2131
2132
2133
2134
2135
2136
2137
2138
2139
2140
2141
2142
2143
2144
2145
2146
2147
2148
2149
2150
2151
2152
2153
2154
2155
2156
2157
2158
2159
2160
2161
2162
2163
2164
2165
2166
2167
2168
2169
2170
2171
2172
2173
2174
2175
2176
2177
2178
2179
2180
2181
2182
2183
2184
ast_bridge_depart(chan_alice);
ast_bridge_depart(chan_bob);
/* And then it hangs up */
HANGUP_CHANNEL(chan_alice, AST_CAUSE_NORMAL);
HANGUP_CHANNEL(chan_bob, AST_CAUSE_NORMAL);
result = verify_mock_cdr_record(test, &alice_expected, 2);
return result;
}
AST_TEST_DEFINE(test_cdr_fields)
{
RAII_VAR(struct ast_channel *, chan, NULL, safe_channel_release);
RAII_VAR(struct ast_cdr_config *, config, ao2_alloc(sizeof(*config), NULL),
ao2_cleanup);
char varbuffer[128];
int int_buffer;
double db_buffer;
struct timespec to_sleep = {2, 0};
struct ast_flags fork_options = { 0, };
struct ast_party_caller caller = ALICE_CALLERID;
struct ast_cdr original = {
.clid = "\"Alice\" <100>",
.src = "100",
.dst = "100",
.dcontext = "default",
.channel = CHANNEL_TECH_NAME "/Alice",
.lastapp = "Wait",
.lastdata = "10",
.billsec = 0,
.amaflags = AST_AMA_OMIT,
.disposition = AST_CDR_FAILED,
.accountcode = "XXX",
.userfield = "yackity",
};
struct ast_cdr fork_expected_one = {
.clid = "\"Alice\" <100>",
.src = "100",
.dst = "100",
.dcontext = "default",
.channel = CHANNEL_TECH_NAME "/Alice",
.lastapp = "Wait",
.lastdata = "10",
.billsec = 0,
.amaflags = AST_AMA_OMIT,
.disposition = AST_CDR_FAILED,
.accountcode = "XXX",
.userfield = "yackity",
};
struct ast_cdr fork_expected_two = {
.clid = "\"Alice\" <100>",
.src = "100",
.dst = "100",
.dcontext = "default",
.channel = CHANNEL_TECH_NAME "/Alice",
.lastapp = "Answer",
.billsec = 0,
.amaflags = AST_AMA_OMIT,
.disposition = AST_CDR_ANSWERED,
.accountcode = "ZZZ",
.userfield = "schmackity",
};
enum ast_test_result_state result = AST_TEST_NOT_RUN;
struct ast_cdr *expected = &original;
original.next = &fork_expected_one;
fork_expected_one.next = &fork_expected_two;
switch (cmd) {
case TEST_INIT:
info->name = __func__;
info->category = TEST_CATEGORY;
info->summary = "Test field access CDRs";
info->description =
"This tests setting/retrieving data on CDR records.";
return AST_TEST_NOT_RUN;
case TEST_EXECUTE:
break;
}
SWAP_CONFIG(config, unanswered_cdr_config);
CREATE_ALICE_CHANNEL(chan, &caller, &original);
ast_copy_string(fork_expected_one.uniqueid, ast_channel_uniqueid(chan), sizeof(fork_expected_one.uniqueid));
ast_copy_string(fork_expected_one.linkedid, ast_channel_linkedid(chan), sizeof(fork_expected_one.linkedid));
ast_copy_string(fork_expected_two.uniqueid, ast_channel_uniqueid(chan), sizeof(fork_expected_two.uniqueid));
ast_copy_string(fork_expected_two.linkedid, ast_channel_linkedid(chan), sizeof(fork_expected_two.linkedid));
/* Channel enters Wait app */
ast_channel_lock(chan);
ast_channel_appl_set(chan, "Wait");
ast_channel_data_set(chan, "10");
ast_channel_priority_set(chan, 1);
ast_channel_publish_snapshot(chan);
/* Set properties on the channel that propagate to the CDR */
ast_channel_amaflags_set(chan, AST_AMA_OMIT);
ast_channel_accountcode_set(chan, "XXX");
ast_channel_unlock(chan);
/* Wait one second so we get a duration. */
do_sleep(&to_sleep);
2213
2214
2215
2216
2217
2218
2219
2220
2221
2222
2223
2224
2225
2226
2227
2228
2229
2230
2231
2232
2233
2234
2235
2236
2237
2238
2239
2240
2241
2242
2243
2244
2245
2246
2247
2248
2249
2250
2251
2252
2253
2254
2255
2256
2257
2258
2259
2260
2261
2262
2263
2264
2265
2266
2267
2268
2269
2270
2271
2272
2273
2274
2275
2276
2277
2278
2279
2280
2281
2282
2283
2284
2285
2286
2287
2288
2289
2290
2291
2292
2293
2294
2295
2296
2297
2298
2299
2300
2301
ast_cdr_setuserfield(ast_channel_name(chan), "foobar");
ast_test_validate(test, ast_cdr_setvar(ast_channel_name(chan), "test_variable", "record_1") == 0);
/* Verify that we can't set read-only fields or other fields directly */
ast_test_validate(test, ast_cdr_setvar(ast_channel_name(chan), "clid", "junk") != 0);
ast_test_validate(test, ast_cdr_setvar(ast_channel_name(chan), "src", "junk") != 0);
ast_test_validate(test, ast_cdr_setvar(ast_channel_name(chan), "dst", "junk") != 0);
ast_test_validate(test, ast_cdr_setvar(ast_channel_name(chan), "dcontext", "junk") != 0);
ast_test_validate(test, ast_cdr_setvar(ast_channel_name(chan), "channel", "junk") != 0);
ast_test_validate(test, ast_cdr_setvar(ast_channel_name(chan), "dstchannel", "junk") != 0);
ast_test_validate(test, ast_cdr_setvar(ast_channel_name(chan), "lastapp", "junk") != 0);
ast_test_validate(test, ast_cdr_setvar(ast_channel_name(chan), "lastdata", "junk") != 0);
ast_test_validate(test, ast_cdr_setvar(ast_channel_name(chan), "start", "junk") != 0);
ast_test_validate(test, ast_cdr_setvar(ast_channel_name(chan), "answer", "junk") != 0);
ast_test_validate(test, ast_cdr_setvar(ast_channel_name(chan), "end", "junk") != 0);
ast_test_validate(test, ast_cdr_setvar(ast_channel_name(chan), "duration", "junk") != 0);
ast_test_validate(test, ast_cdr_setvar(ast_channel_name(chan), "billsec", "junk") != 0);
ast_test_validate(test, ast_cdr_setvar(ast_channel_name(chan), "disposition", "junk") != 0);
ast_test_validate(test, ast_cdr_setvar(ast_channel_name(chan), "amaflags", "junk") != 0);
ast_test_validate(test, ast_cdr_setvar(ast_channel_name(chan), "accountcode", "junk") != 0);
ast_test_validate(test, ast_cdr_setvar(ast_channel_name(chan), "uniqueid", "junk") != 0);
ast_test_validate(test, ast_cdr_setvar(ast_channel_name(chan), "linkedid", "junk") != 0);
ast_test_validate(test, ast_cdr_setvar(ast_channel_name(chan), "userfield", "junk") != 0);
ast_test_validate(test, ast_cdr_setvar(ast_channel_name(chan), "sequence", "junk") != 0);
/* Verify the values */
ast_test_validate(test, ast_cdr_getvar(ast_channel_name(chan), "userfield", varbuffer, sizeof(varbuffer)) == 0);
ast_test_validate(test, strcmp(varbuffer, "foobar") == 0);
ast_test_validate(test, ast_cdr_getvar(ast_channel_name(chan), "test_variable", varbuffer, sizeof(varbuffer)) == 0);
ast_test_validate(test, strcmp(varbuffer, "record_1") == 0);
ast_test_validate(test, ast_cdr_getvar(ast_channel_name(chan), "amaflags", varbuffer, sizeof(varbuffer)) == 0);
sscanf(varbuffer, "%d", &int_buffer);
ast_test_validate(test, int_buffer == AST_AMA_OMIT);
ast_test_validate(test, ast_cdr_getvar(ast_channel_name(chan), "accountcode", varbuffer, sizeof(varbuffer)) == 0);
ast_test_validate(test, strcmp(varbuffer, "XXX") == 0);
ast_test_validate(test, ast_cdr_getvar(ast_channel_name(chan), "clid", varbuffer, sizeof(varbuffer)) == 0);
ast_test_validate(test, strcmp(varbuffer, "\"Alice\" <100>") == 0);
ast_test_validate(test, ast_cdr_getvar(ast_channel_name(chan), "src", varbuffer, sizeof(varbuffer)) == 0);
ast_test_validate(test, strcmp(varbuffer, "100") == 0);
ast_test_validate(test, ast_cdr_getvar(ast_channel_name(chan), "dst", varbuffer, sizeof(varbuffer)) == 0);
ast_test_validate(test, strcmp(varbuffer, "100") == 0);
ast_test_validate(test, ast_cdr_getvar(ast_channel_name(chan), "dcontext", varbuffer, sizeof(varbuffer)) == 0);
ast_test_validate(test, strcmp(varbuffer, "default") == 0);
ast_test_validate(test, ast_cdr_getvar(ast_channel_name(chan), "channel", varbuffer, sizeof(varbuffer)) == 0);
ast_test_validate(test, strcmp(varbuffer, CHANNEL_TECH_NAME "/Alice") == 0);
ast_test_validate(test, ast_cdr_getvar(ast_channel_name(chan), "dstchannel", varbuffer, sizeof(varbuffer)) == 0);
ast_test_validate(test, strcmp(varbuffer, "") == 0);
ast_test_validate(test, ast_cdr_getvar(ast_channel_name(chan), "lastapp", varbuffer, sizeof(varbuffer)) == 0);
ast_test_validate(test, strcmp(varbuffer, "Wait") == 0);
ast_test_validate(test, ast_cdr_getvar(ast_channel_name(chan), "lastdata", varbuffer, sizeof(varbuffer)) == 0);
ast_test_validate(test, strcmp(varbuffer, "10") == 0);
ast_test_validate(test, ast_cdr_getvar(ast_channel_name(chan), "start", varbuffer, sizeof(varbuffer)) == 0);
sscanf(varbuffer, "%lf", &db_buffer);
ast_test_validate(test, fabs(db_buffer) > 0);
ast_test_validate(test, ast_cdr_getvar(ast_channel_name(chan), "answer", varbuffer, sizeof(varbuffer)) == 0);
sscanf(varbuffer, "%lf", &db_buffer);
ast_test_validate(test, fabs(db_buffer) < EPSILON);
ast_test_validate(test, ast_cdr_getvar(ast_channel_name(chan), "end", varbuffer, sizeof(varbuffer)) == 0);
sscanf(varbuffer, "%lf", &db_buffer);
ast_test_validate(test, fabs(db_buffer) < EPSILON);
ast_test_validate(test, ast_cdr_getvar(ast_channel_name(chan), "duration", varbuffer, sizeof(varbuffer)) == 0);
sscanf(varbuffer, "%lf", &db_buffer);
ast_test_validate(test, fabs(db_buffer) > 0);
ast_test_validate(test, ast_cdr_getvar(ast_channel_name(chan), "billsec", varbuffer, sizeof(varbuffer)) == 0);
sscanf(varbuffer, "%lf", &db_buffer);
ast_test_validate(test, fabs(db_buffer) < EPSILON);
ast_test_validate(test, ast_cdr_getvar(ast_channel_name(chan), "disposition", varbuffer, sizeof(varbuffer)) == 0);
sscanf(varbuffer, "%d", &int_buffer);
ast_test_validate(test, int_buffer == AST_CDR_NULL);
ast_test_validate(test, ast_cdr_getvar(ast_channel_name(chan), "uniqueid", varbuffer, sizeof(varbuffer)) == 0);
ast_test_validate(test, strcmp(varbuffer, ast_channel_uniqueid(chan)) == 0);
ast_test_validate(test, ast_cdr_getvar(ast_channel_name(chan), "linkedid", varbuffer, sizeof(varbuffer)) == 0);
ast_test_validate(test, strcmp(varbuffer, ast_channel_linkedid(chan)) == 0);
ast_test_validate(test, ast_cdr_getvar(ast_channel_name(chan), "sequence", varbuffer, sizeof(varbuffer)) == 0);
/* Fork the CDR, and check that we change the properties on both CDRs. */
ast_set_flag(&fork_options, AST_CDR_FLAG_KEEP_VARS);
ast_test_validate(test, ast_cdr_fork(ast_channel_name(chan), &fork_options) == 0);
/* Change some properties */
ast_cdr_setuserfield(ast_channel_name(chan), "yackity");
ast_test_validate(test, ast_cdr_setvar(ast_channel_name(chan), "test_variable", "record_1b") == 0);
/* Fork the CDR again, finalizing all current CDRs */
ast_set_flag(&fork_options, AST_CDR_FLAG_KEEP_VARS | AST_CDR_FLAG_FINALIZE);
ast_test_validate(test, ast_cdr_fork(ast_channel_name(chan), &fork_options) == 0);
/* Channel enters Answer app */
ast_channel_lock(chan);
ast_channel_appl_set(chan, "Answer");
ast_channel_data_set(chan, "");
ast_channel_priority_set(chan, 1);
ast_channel_publish_snapshot(chan);
ast_setstate(chan, AST_STATE_UP);
/* Set properties on the last record */
ast_channel_accountcode_set(chan, "ZZZ");
ast_channel_unlock(chan);
ast_cdr_setuserfield(ast_channel_name(chan), "schmackity");
ast_test_validate(test, ast_cdr_setvar(ast_channel_name(chan), "test_variable", "record_2") == 0);
/* Hang up and verify */
ast_channel_hangupcause_set(chan, AST_CAUSE_NORMAL);
ast_hangup(chan);
chan = NULL;
2319
2320
2321
2322
2323
2324
2325
2326
2327
2328
2329
2330
2331
2332
2333
2334
2335
2336
2337
2338
2339
2340
2341
2342
2343
2344
2345
2346
2347
2348
2349
2350
2351
result = verify_mock_cdr_record(test, expected, 3);
return result;
}
AST_TEST_DEFINE(test_cdr_no_reset_cdr)
{
RAII_VAR(struct ast_channel *, chan, NULL, safe_channel_release);
RAII_VAR(struct ast_cdr_config *, config, ao2_alloc(sizeof(*config), NULL),
ao2_cleanup);
struct ast_flags fork_options = { 0, };
struct timespec to_sleep = {1, 0};
struct ast_party_caller caller = ALICE_CALLERID;
struct ast_cdr expected = {
.clid = "\"Alice\" <100>",
.src = "100",
.dst = "100",
.dcontext = "default",
.channel = CHANNEL_TECH_NAME "/Alice",
.billsec = 0,
.amaflags = AST_AMA_DOCUMENTATION,
.disposition = AST_CDR_FAILED,
.accountcode = "100",
};
enum ast_test_result_state result = AST_TEST_NOT_RUN;
switch (cmd) {
case TEST_INIT:
info->name = __func__;
info->category = TEST_CATEGORY;
info->summary = "Test field access CDRs";
info->description =
"This tests setting/retrieving data on CDR records.";
return AST_TEST_NOT_RUN;
case TEST_EXECUTE:
break;
}
SWAP_CONFIG(config, unanswered_cdr_config);
CREATE_ALICE_CHANNEL(chan, &caller, &expected);
do_sleep(&to_sleep);
2363
2364
2365
2366
2367
2368
2369
2370
2371
2372
2373
2374
2375
2376
2377
2378
2379
2380
2381
2382
2383
2384
2385
2386
/* Disable the CDR */
ast_test_validate(test, ast_cdr_set_property(ast_channel_name(chan), AST_CDR_FLAG_DISABLE) == 0);
/* Fork the CDR. This should be enabled */
ast_set_flag(&fork_options, AST_CDR_FLAG_FINALIZE);
ast_test_validate(test, ast_cdr_fork(ast_channel_name(chan), &fork_options) == 0);
/* Disable and enable the forked CDR */
ast_test_validate(test, ast_cdr_set_property(ast_channel_name(chan), AST_CDR_FLAG_DISABLE) == 0);
ast_test_validate(test, ast_cdr_clear_property(ast_channel_name(chan), AST_CDR_FLAG_DISABLE) == 0);
/* Fork and finalize again. This CDR should be propagated */
ast_test_validate(test, ast_cdr_fork(ast_channel_name(chan), &fork_options) == 0);
/* Disable all future CDRs */
ast_test_validate(test, ast_cdr_set_property(ast_channel_name(chan), AST_CDR_FLAG_DISABLE_ALL) == 0);
/* Fork a few more */
ast_test_validate(test, ast_cdr_fork(ast_channel_name(chan), &fork_options) == 0);
ast_test_validate(test, ast_cdr_fork(ast_channel_name(chan), &fork_options) == 0);
ast_test_validate(test, ast_cdr_fork(ast_channel_name(chan), &fork_options) == 0);
ast_channel_hangupcause_set(chan, AST_CAUSE_NORMAL);
ast_hangup(chan);
chan = NULL;
2389
2390
2391
2392
2393
2394
2395
2396
2397
2398
2399
2400
2401
2402
2403
2404
2405
2406
2407
2408
2409
2410
2411
2412
2413
2414
2415
2416
2417
2418
2419
2420
2421
2422
2423
2424
2425
2426
2427
2428
2429
2430
2431
2432
2433
2434
2435
2436
2437
2438
2439
2440
2441
2442
2443
2444
2445
2446
2447
2448
2449
result = verify_mock_cdr_record(test, &expected, 1);
return result;
}
AST_TEST_DEFINE(test_cdr_fork_cdr)
{
RAII_VAR(struct ast_channel *, chan, NULL, safe_channel_release);
RAII_VAR(struct ast_cdr_config *, config, ao2_alloc(sizeof(*config), NULL),
ao2_cleanup);
char varbuffer[128];
char fork_varbuffer[128];
char answer_time[128];
char fork_answer_time[128];
char start_time[128];
char fork_start_time[128];
struct ast_flags fork_options = { 0, };
struct timespec to_sleep = {1, 10000};
struct ast_party_caller caller = ALICE_CALLERID;
struct ast_cdr original = {
.clid = "\"Alice\" <100>",
.src = "100",
.dst = "100",
.dcontext = "default",
.channel = CHANNEL_TECH_NAME "/Alice",
.amaflags = AST_AMA_DOCUMENTATION,
.disposition = AST_CDR_ANSWERED,
.accountcode = "100",
};
struct ast_cdr fork_expected_one = {
.clid = "\"Alice\" <100>",
.src = "100",
.dst = "100",
.dcontext = "default",
.channel = CHANNEL_TECH_NAME "/Alice",
.amaflags = AST_AMA_DOCUMENTATION,
.disposition = AST_CDR_ANSWERED,
.accountcode = "100",
};
struct ast_cdr fork_expected_two = {
.clid = "\"Alice\" <100>",
.src = "100",
.dst = "100",
.dcontext = "default",
.channel = CHANNEL_TECH_NAME "/Alice",
.amaflags = AST_AMA_DOCUMENTATION,
.disposition = AST_CDR_ANSWERED,
.accountcode = "100",
};
enum ast_test_result_state result = AST_TEST_NOT_RUN;
struct ast_cdr *expected = &original;
original.next = &fork_expected_one;
fork_expected_one.next = &fork_expected_two;
switch (cmd) {
case TEST_INIT:
info->name = __func__;
info->category = TEST_CATEGORY;
info->summary = "Test field access CDRs";
info->description =
"This tests setting/retrieving data on CDR records.";
return AST_TEST_NOT_RUN;
case TEST_EXECUTE:
break;
}
SWAP_CONFIG(config, debug_cdr_config);
CREATE_ALICE_CHANNEL(chan, &caller, &original);
ast_copy_string(fork_expected_one.uniqueid, ast_channel_uniqueid(chan), sizeof(fork_expected_one.uniqueid));
ast_copy_string(fork_expected_one.linkedid, ast_channel_linkedid(chan), sizeof(fork_expected_one.linkedid));
ast_copy_string(fork_expected_two.uniqueid, ast_channel_uniqueid(chan), sizeof(fork_expected_two.uniqueid));
ast_copy_string(fork_expected_two.linkedid, ast_channel_linkedid(chan), sizeof(fork_expected_two.linkedid));
do_sleep(&to_sleep);
/* Test blowing away variables */
ast_test_validate(test, ast_cdr_setvar(ast_channel_name(chan), "test_variable", "record_1") == 0);
ast_test_validate(test, ast_cdr_getvar(ast_channel_name(chan), "test_variable", varbuffer, sizeof(varbuffer)) == 0);
ast_test_validate(test, strcmp(varbuffer, "record_1") == 0);
ast_copy_string(varbuffer, "", sizeof(varbuffer));
ast_test_validate(test, ast_cdr_fork(ast_channel_name(chan), &fork_options) == 0);
ast_test_validate(test, ast_cdr_getvar(ast_channel_name(chan), "test_variable", fork_varbuffer, sizeof(fork_varbuffer)) == 0);
ast_test_validate(test, strcmp(varbuffer, "record_1") != 0);
/* Test finalizing previous CDRs */
ast_set_flag(&fork_options, AST_CDR_FLAG_FINALIZE);
ast_test_validate(test, ast_cdr_fork(ast_channel_name(chan), &fork_options) == 0);
/* Test keep variables; setting a new answer time */
ast_channel_lock(chan);
ast_setstate(chan, AST_STATE_UP);
ast_channel_unlock(chan);
do_sleep(&to_sleep);
2485
2486
2487
2488
2489
2490
2491
2492
2493
2494
2495
2496
2497
2498
2499
2500
2501
2502
2503
2504
2505
2506
2507
2508
2509
2510
ast_test_validate(test, ast_cdr_setvar(ast_channel_name(chan), "test_variable", "record_2") == 0);
ast_test_validate(test, ast_cdr_getvar(ast_channel_name(chan), "test_variable", varbuffer, sizeof(varbuffer)) == 0);
ast_test_validate(test, strcmp(varbuffer, "record_2") == 0);
ast_test_validate(test, ast_cdr_getvar(ast_channel_name(chan), "answer", answer_time, sizeof(answer_time)) == 0);
ast_test_validate(test, ast_cdr_getvar(ast_channel_name(chan), "start", start_time, sizeof(start_time)) == 0);
ast_set_flag(&fork_options, AST_CDR_FLAG_FINALIZE);
ast_set_flag(&fork_options, AST_CDR_FLAG_KEEP_VARS);
ast_set_flag(&fork_options, AST_CDR_FLAG_SET_ANSWER);
ast_test_validate(test, ast_cdr_fork(ast_channel_name(chan), &fork_options) == 0);
ast_test_validate(test, ast_cdr_getvar(ast_channel_name(chan), "answer", fork_answer_time, sizeof(fork_answer_time)) == 0);
ast_test_validate(test, ast_cdr_getvar(ast_channel_name(chan), "start", fork_start_time, sizeof(fork_start_time)) == 0);
ast_test_validate(test, ast_cdr_getvar(ast_channel_name(chan), "test_variable", fork_varbuffer, sizeof(fork_varbuffer)) == 0);
ast_test_validate(test, strcmp(fork_varbuffer, varbuffer) == 0);
ast_test_validate(test, strcmp(fork_start_time, start_time) == 0);
ast_test_validate(test, strcmp(fork_answer_time, answer_time) != 0);
ast_clear_flag(&fork_options, AST_CDR_FLAG_SET_ANSWER);
ast_set_flag(&fork_options, AST_CDR_FLAG_RESET);
ast_test_validate(test, ast_cdr_fork(ast_channel_name(chan), &fork_options) == 0);
ast_test_validate(test, ast_cdr_getvar(ast_channel_name(chan), "answer", fork_answer_time, sizeof(fork_answer_time)) == 0);
ast_test_validate(test, ast_cdr_getvar(ast_channel_name(chan), "start", fork_start_time, sizeof(fork_start_time)) == 0);
ast_test_validate(test, strcmp(fork_start_time, start_time) != 0);
ast_test_validate(test, strcmp(fork_answer_time, answer_time) != 0);
ast_channel_hangupcause_set(chan, AST_CAUSE_NORMAL);
ast_hangup(chan);
chan = NULL;
result = verify_mock_cdr_record(test, expected, 3);
return result;
}
/*!
* \internal
* \brief Callback function called before each test executes
*/
static int test_cdr_init_cb(struct ast_test_info *info, struct ast_test *test)
{
/* Back up the real config */
saved_config = ast_cdr_get_config();
clear_mock_cdr_backend();
return 0;
}
/*!
* \internal
* \brief Callback function called after each test executes
*/
static int test_cdr_cleanup_cb(struct ast_test_info *info, struct ast_test *test)
{
/* Restore the real config */
ast_cdr_set_config(saved_config);
ao2_cleanup(saved_config);
saved_config = NULL;
clear_mock_cdr_backend();
return 0;
}
static int unload_module(void)
{
AST_TEST_UNREGISTER(test_cdr_channel_creation);
AST_TEST_UNREGISTER(test_cdr_unanswered_inbound_call);
AST_TEST_UNREGISTER(test_cdr_unanswered_outbound_call);
AST_TEST_UNREGISTER(test_cdr_single_party);
AST_TEST_UNREGISTER(test_cdr_single_bridge);
AST_TEST_UNREGISTER(test_cdr_single_bridge_continue);
AST_TEST_UNREGISTER(test_cdr_single_twoparty_bridge_a);
AST_TEST_UNREGISTER(test_cdr_single_twoparty_bridge_b);
AST_TEST_UNREGISTER(test_cdr_single_multiparty_bridge);
AST_TEST_UNREGISTER(test_cdr_outbound_bridged_call);
2561
2562
2563
2564
2565
2566
2567
2568
2569
2570
2571
2572
2573
2574
2575
2576
2577
2578
2579
2580
2581
2582
2583
2584
2585
2586
2587
2588
2589
2590
2591
2592
2593
2594
2595
2596
2597
2598
2599
AST_TEST_UNREGISTER(test_cdr_dial_unanswered);
AST_TEST_UNREGISTER(test_cdr_dial_congestion);
AST_TEST_UNREGISTER(test_cdr_dial_busy);
AST_TEST_UNREGISTER(test_cdr_dial_unavailable);
AST_TEST_UNREGISTER(test_cdr_dial_caller_cancel);
AST_TEST_UNREGISTER(test_cdr_dial_parallel_failed);
AST_TEST_UNREGISTER(test_cdr_dial_answer_no_bridge);
AST_TEST_UNREGISTER(test_cdr_dial_answer_twoparty_bridge_a);
AST_TEST_UNREGISTER(test_cdr_dial_answer_twoparty_bridge_b);
AST_TEST_UNREGISTER(test_cdr_dial_answer_multiparty);
AST_TEST_UNREGISTER(test_cdr_park);
AST_TEST_UNREGISTER(test_cdr_fields);
AST_TEST_UNREGISTER(test_cdr_no_reset_cdr);
AST_TEST_UNREGISTER(test_cdr_fork_cdr);
ast_cdr_unregister(MOCK_CDR_BACKEND);
ast_channel_unregister(&test_cdr_chan_tech);
clear_mock_cdr_backend();
return 0;
}
static int load_module(void)
{
ast_cond_init(&mock_cdr_cond, NULL);
AST_TEST_REGISTER(test_cdr_channel_creation);
AST_TEST_REGISTER(test_cdr_unanswered_inbound_call);
AST_TEST_REGISTER(test_cdr_unanswered_outbound_call);
AST_TEST_REGISTER(test_cdr_single_party);
AST_TEST_REGISTER(test_cdr_single_bridge);
AST_TEST_REGISTER(test_cdr_single_bridge_continue);
AST_TEST_REGISTER(test_cdr_single_twoparty_bridge_a);
AST_TEST_REGISTER(test_cdr_single_twoparty_bridge_b);
AST_TEST_REGISTER(test_cdr_single_multiparty_bridge);
AST_TEST_REGISTER(test_cdr_outbound_bridged_call);
2602
2603
2604
2605
2606
2607
2608
2609
2610
2611
2612
2613
2614
2615
2616
2617
2618
2619
2620
2621
2622
2623
2624
2625
2626
2627
2628
AST_TEST_REGISTER(test_cdr_dial_unanswered);
AST_TEST_REGISTER(test_cdr_dial_congestion);
AST_TEST_REGISTER(test_cdr_dial_busy);
AST_TEST_REGISTER(test_cdr_dial_unavailable);
AST_TEST_REGISTER(test_cdr_dial_caller_cancel);
AST_TEST_REGISTER(test_cdr_dial_parallel_failed);
AST_TEST_REGISTER(test_cdr_dial_answer_no_bridge);
AST_TEST_REGISTER(test_cdr_dial_answer_twoparty_bridge_a);
AST_TEST_REGISTER(test_cdr_dial_answer_twoparty_bridge_b);
AST_TEST_REGISTER(test_cdr_dial_answer_multiparty);
AST_TEST_REGISTER(test_cdr_park);
AST_TEST_REGISTER(test_cdr_fields);
AST_TEST_REGISTER(test_cdr_no_reset_cdr);
AST_TEST_REGISTER(test_cdr_fork_cdr);
ast_test_register_init(TEST_CATEGORY, test_cdr_init_cb);
ast_test_register_cleanup(TEST_CATEGORY, test_cdr_cleanup_cb);
ast_channel_register(&test_cdr_chan_tech);
ast_cdr_register(MOCK_CDR_BACKEND, "Mock CDR backend", mock_cdr_backend_cb);
return AST_MODULE_LOAD_SUCCESS;
}
AST_MODULE_INFO_STANDARD(ASTERISK_GPL_KEY, "CDR unit tests");