Return completed rx messages instead of relying on callbacks.
[apps/low-level-can-service.git] / tests / test_receive.c
1 #include <isotp/isotp.h>
2 #include <check.h>
3 #include <stdint.h>
4 #include <stdio.h>
5 #include <stdlib.h>
6 #include <stdarg.h>
7
8 extern IsoTpShims SHIMS;
9 extern IsoTpHandle HANDLE;
10
11 extern uint16_t last_can_frame_sent_arb_id;
12 extern uint8_t last_can_payload_sent;
13 extern uint8_t last_can_payload_size;
14 extern bool can_frame_was_sent;
15
16 extern bool message_was_received;
17 extern uint16_t last_message_received_arb_id;
18 extern uint8_t* last_message_received_payload;
19 extern uint8_t last_message_received_payload_size;
20
21 extern uint16_t last_message_sent_arb_id;
22 extern bool last_message_sent_status;
23 extern uint8_t* last_message_sent_payload;
24 extern uint8_t last_message_sent_payload_size;
25
26 extern void setup();
27
28 START_TEST (test_receive_wrong_id)
29 {
30     const uint8_t data[CAN_MESSAGE_BYTE_SIZE] = {0};
31     IsoTpMessage message = isotp_receive_can_frame(&SHIMS, &HANDLE, 0x100, data, 1);
32     fail_if(message.completed);
33     fail_if(message_was_received);
34 }
35 END_TEST
36
37 START_TEST (test_receive_bad_pci)
38 {
39     // 4 is a reserved number for the PCI field - only 0-3 are allowed
40     const uint8_t data[CAN_MESSAGE_BYTE_SIZE] = {0x40};
41     IsoTpMessage message = isotp_receive_can_frame(&SHIMS, &HANDLE, 0x2a, data, 1);
42     fail_if(message.completed);
43     fail_if(message_was_received);
44 }
45 END_TEST
46
47 START_TEST (test_receive_single_frame_empty_payload)
48 {
49     const uint8_t data[CAN_MESSAGE_BYTE_SIZE] = {0x00, 0x12, 0x34};
50     IsoTpMessage message = isotp_receive_can_frame(&SHIMS, &HANDLE, 0x2a, data, 3);
51     fail_unless(message.completed);
52     fail_unless(message_was_received);
53     ck_assert_int_eq(last_message_received_arb_id, 0x2a);
54     ck_assert_int_eq(last_message_received_payload_size, 0);
55 }
56 END_TEST
57
58 START_TEST (test_receive_single_frame)
59 {
60     const uint8_t data[CAN_MESSAGE_BYTE_SIZE] = {0x02, 0x12, 0x34};
61     IsoTpMessage message = isotp_receive_can_frame(&SHIMS, &HANDLE, 0x2a, data, 3);
62     fail_unless(message.completed);
63     fail_unless(message_was_received);
64     ck_assert_int_eq(last_message_received_arb_id, 0x2a);
65     ck_assert_int_eq(last_message_received_payload_size, 2);
66     ck_assert_int_eq(last_message_received_payload[0], 0x12);
67     ck_assert_int_eq(last_message_received_payload[1], 0x34);
68 }
69 END_TEST
70
71 Suite* testSuite(void) {
72     Suite* s = suite_create("iso15765");
73     TCase *tc_core = tcase_create("receive");
74     tcase_add_checked_fixture(tc_core, setup, NULL);
75     tcase_add_test(tc_core, test_receive_wrong_id);
76     tcase_add_test(tc_core, test_receive_bad_pci);
77     tcase_add_test(tc_core, test_receive_single_frame);
78     tcase_add_test(tc_core, test_receive_single_frame_empty_payload);
79     suite_add_tcase(s, tc_core);
80
81     return s;
82 }
83
84 int main(void) {
85     int numberFailed;
86     Suite* s = testSuite();
87     SRunner *sr = srunner_create(s);
88     // Don't fork so we can actually use gdb
89     srunner_set_fork_status(sr, CK_NOFORK);
90     srunner_run_all(sr, CK_NORMAL);
91     numberFailed = srunner_ntests_failed(sr);
92     srunner_free(sr);
93     return (numberFailed == 0) ? 0 : 1;
94 }