|
| 1 | +/* |
| 2 | + * Copyright 2025 Sayed Naser Moravej <seyednasermoravej@gmail.com> |
| 3 | + * |
| 4 | + * SPDX-License-Identifier: Apache-2.0 |
| 5 | + */ |
| 6 | + |
| 7 | +#include <zephyr/kernel.h> |
| 8 | +#include <zephyr/net/socket.h> |
| 9 | +#include <zephyr/logging/log.h> |
| 10 | +#include <zephyr/net/net_ip.h> |
| 11 | + |
| 12 | +#include <config.h> |
| 13 | +#include "srtp.h" |
| 14 | +#include "rtp.h" |
| 15 | +#include "util.h" |
| 16 | + |
| 17 | +#define MAX_WORD_LEN 128 |
| 18 | +#define MAX_KEY_LEN 96 |
| 19 | + |
| 20 | +LOG_MODULE_REGISTER(rtpw_sample, LOG_LEVEL_INF); |
| 21 | + |
| 22 | +int main(void) |
| 23 | +{ |
| 24 | + char word[MAX_WORD_LEN]; |
| 25 | + int sock, ret; |
| 26 | + struct in_addr rcvr_addr; |
| 27 | + struct sockaddr_in name; |
| 28 | + char key[MAX_KEY_LEN]; |
| 29 | + srtp_policy_t policy; |
| 30 | + srtp_err_status_t status; |
| 31 | + uint32_t ssrc = 0xdeadbeef; /* ssrc value hardcoded for now */ |
| 32 | + |
| 33 | + memset(&policy, 0x0, sizeof(srtp_policy_t)); |
| 34 | + |
| 35 | + LOG_INF("Using %s [0x%x]\n", srtp_get_version_string(), srtp_get_version()); |
| 36 | + |
| 37 | + /* initialize srtp library */ |
| 38 | + status = srtp_init(); |
| 39 | + if (status) { |
| 40 | + LOG_ERR("srtp initialization failed with error code %d.", status); |
| 41 | + return 0; |
| 42 | + } |
| 43 | + |
| 44 | + /* set address */ |
| 45 | + LOG_INF("peer IPv4 address: %s.", CONFIG_NET_CONFIG_PEER_IPV4_ADDR); |
| 46 | + LOG_INF("my IPv4 address: %s.", CONFIG_NET_CONFIG_MY_IPV4_ADDR); |
| 47 | + |
| 48 | + if (inet_pton(AF_INET, CONFIG_NET_CONFIG_PEER_IPV4_ADDR, &rcvr_addr) != 1) { |
| 49 | + LOG_ERR("Invalid IPv4 address: %s.", CONFIG_NET_CONFIG_PEER_IPV4_ADDR); |
| 50 | + return 0; |
| 51 | + } |
| 52 | + |
| 53 | + /* open socket */ |
| 54 | + sock = socket(PF_INET, SOCK_DGRAM, IPPROTO_UDP); |
| 55 | + if (sock < 0) { |
| 56 | + LOG_ERR("couldn't open socket."); |
| 57 | + return 0; |
| 58 | + } |
| 59 | + |
| 60 | + memset(&name, 0, sizeof(struct sockaddr_in)); |
| 61 | + name.sin_addr = rcvr_addr; |
| 62 | + name.sin_family = PF_INET; |
| 63 | + name.sin_port = htons(CONFIG_NET_SAMPLE_SRTP_SERVER_PORT); |
| 64 | + |
| 65 | + /* set up the srtp policy and master key |
| 66 | + * create policy structure, using the default mechanisms. |
| 67 | + */ |
| 68 | + srtp_crypto_policy_set_rtp_default(&policy.rtp); |
| 69 | + srtp_crypto_policy_set_rtcp_default(&policy.rtcp); |
| 70 | + policy.ssrc.type = ssrc_specific; |
| 71 | + policy.ssrc.value = ssrc; |
| 72 | + policy.key = (uint8_t *)key; |
| 73 | + policy.next = NULL; |
| 74 | + policy.window_size = 128; |
| 75 | + policy.allow_repeat_tx = 0; |
| 76 | + policy.rtp.sec_serv = sec_serv_conf_and_auth; |
| 77 | + policy.rtcp.sec_serv = sec_serv_none; /* we don't do RTCP anyway */ |
| 78 | + size_t key_len = hex2bin(CONFIG_NET_SAMPLE_SRTP_KEY, |
| 79 | + strlen(CONFIG_NET_SAMPLE_SRTP_KEY), key, sizeof(key)); |
| 80 | + |
| 81 | + /* check that hex string is the right length */ |
| 82 | + if (key_len != policy.rtp.cipher_key_len) { |
| 83 | + LOG_ERR("wrong number of digits in key (should be %d digits, found %d).", |
| 84 | + 2 * policy.rtp.cipher_key_len, 2 * key_len); |
| 85 | + return 0; |
| 86 | + } |
| 87 | + |
| 88 | +#ifdef CONFIG_NET_SAMPLE_SENDER |
| 89 | + /* initialize sender's rtp and srtp contexts */ |
| 90 | + rtp_sender_t snd; |
| 91 | + |
| 92 | + snd = rtp_sender_alloc(); |
| 93 | + if (snd == NULL) { |
| 94 | + LOG_ERR("malloc() failed."); |
| 95 | + return 0; |
| 96 | + } |
| 97 | + rtp_sender_init(snd, sock, name, ssrc); |
| 98 | + status = rtp_sender_init_srtp(snd, &policy); |
| 99 | + if (status) { |
| 100 | + LOG_ERR("srtp_create() failed with code %d.", status); |
| 101 | + return 0; |
| 102 | + } |
| 103 | + |
| 104 | + size_t word_len; |
| 105 | + /* Up-count the buffer, then send them off */ |
| 106 | + for (int i = 0; i < 1000; i++) { |
| 107 | + sprintf(word, "SRTP test%d.", i); |
| 108 | + word_len = strlen(word) + 1; /* plus one for null */ |
| 109 | + |
| 110 | + if (word_len > MAX_WORD_LEN) { |
| 111 | + LOG_ERR("word %s too large to send.", word); |
| 112 | + } else { |
| 113 | + rtp_sendto(snd, word, word_len); |
| 114 | + LOG_INF("sending word: %s", word); |
| 115 | + } |
| 116 | + k_msleep(500); |
| 117 | + } |
| 118 | + |
| 119 | + rtp_sender_deinit_srtp(snd); |
| 120 | + rtp_sender_dealloc(snd); |
| 121 | + |
| 122 | +#elif defined(CONFIG_NET_SAMPLE_RECEIVER) |
| 123 | + rtp_receiver_t rcvr; |
| 124 | + |
| 125 | + if (bind(sock, (struct sockaddr *)&name, sizeof(name)) < 0) { |
| 126 | + close(sock); |
| 127 | + LOG_ERR("socket bind error."); |
| 128 | + return 0; |
| 129 | + } |
| 130 | + |
| 131 | + rcvr = rtp_receiver_alloc(); |
| 132 | + if (rcvr == NULL) { |
| 133 | + LOG_ERR("malloc() failed."); |
| 134 | + return 0; |
| 135 | + } |
| 136 | + rtp_receiver_init(rcvr, sock, name, ssrc); |
| 137 | + status = rtp_receiver_init_srtp(rcvr, &policy); |
| 138 | + if (status) { |
| 139 | + LOG_ERR("srtp_create() failed with code %d.", status); |
| 140 | + return 0; |
| 141 | + } |
| 142 | + |
| 143 | + /* get next word and loop */ |
| 144 | + size_t word_len; |
| 145 | + |
| 146 | + while (true) { |
| 147 | + len = MAX_WORD_LEN; |
| 148 | + if (rtp_recvfrom(rcvr, word, &word_len) > -1) { |
| 149 | + LOG_INF("receiving word: %s", word); |
| 150 | + } |
| 151 | + } |
| 152 | + |
| 153 | + rtp_receiver_deinit_srtp(rcvr); |
| 154 | + rtp_receiver_dealloc(rcvr); |
| 155 | +#else |
| 156 | +#error "Either SENDER or RECEIVER should be defined." |
| 157 | +#endif |
| 158 | + ret = close(sock); |
| 159 | + if (ret < 0) { |
| 160 | + LOG_ERR("Failed to close socket"); |
| 161 | + } |
| 162 | + |
| 163 | + status = srtp_shutdown(); |
| 164 | + if (status) { |
| 165 | + LOG_ERR("srtp shutdown failed with error code %d.", status); |
| 166 | + return 0; |
| 167 | + } |
| 168 | + return 0; |
| 169 | +} |
0 commit comments