Skip to content

Commit 25bc170

Browse files
authored
Adapt to aws_base64_encode() no longer adding a null terminator (#124)
1 parent 52fdfeb commit 25bc170

File tree

2 files changed

+13
-11
lines changed

2 files changed

+13
-11
lines changed

bin/event_stream_write_test_case.c

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -45,7 +45,7 @@ static void write_negative_test_case(
4545

4646
FILE *enc = fopen(enc_output_file, "w");
4747
if (!enc) {
48-
fprintf(stderr, "couldn't write to %s", enc_output_file);
48+
fprintf(stderr, "couldn't write to %s\n", enc_output_file);
4949
exit(-1);
5050
}
5151

@@ -56,7 +56,7 @@ static void write_negative_test_case(
5656

5757
FILE *dec = fopen(dec_output_file, "w");
5858
if (!dec) {
59-
fprintf(stderr, "couldn't write to %s", dec_output_file);
59+
fprintf(stderr, "couldn't write to %s\n", dec_output_file);
6060
exit(-1);
6161
}
6262

@@ -87,7 +87,7 @@ static void write_positive_test_case(
8787

8888
FILE *enc = fopen(enc_output_file, "w");
8989
if (!enc) {
90-
fprintf(stderr, "couldn't write to %s", enc_output_file);
90+
fprintf(stderr, "couldn't write to %s\n", enc_output_file);
9191
exit(-1);
9292
}
9393

@@ -99,7 +99,7 @@ static void write_positive_test_case(
9999

100100
FILE *dec = fopen(dec_output_file, "w");
101101
if (!dec) {
102-
fprintf(stderr, "couldn't write to %s", dec_output_file);
102+
fprintf(stderr, "couldn't write to %s\n", dec_output_file);
103103
exit(-1);
104104
}
105105

source/event_stream.c

Lines changed: 9 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -593,9 +593,9 @@ int aws_event_stream_message_to_debug_str(FILE *fd, const struct aws_event_strea
593593
} else {
594594
size_t buffer_len = 0;
595595
aws_base64_compute_encoded_len(header->header_value_len, &buffer_len);
596-
char *encoded_buffer = (char *)aws_mem_acquire(message->alloc, buffer_len);
597596

598-
struct aws_byte_buf encode_output = aws_byte_buf_from_array((uint8_t *)encoded_buffer, buffer_len);
597+
struct aws_byte_buf encode_output;
598+
aws_byte_buf_init(&encode_output, message->alloc, buffer_len);
599599

600600
if (header->header_value_type == AWS_EVENT_STREAM_HEADER_UUID) {
601601
struct aws_byte_cursor to_encode =
@@ -607,8 +607,8 @@ int aws_event_stream_message_to_debug_str(FILE *fd, const struct aws_event_strea
607607
aws_byte_cursor_from_array(header->header_value.variable_len_val, header->header_value_len);
608608
aws_base64_encode(&to_encode, &encode_output);
609609
}
610-
fprintf(fd, " " DEBUG_STR_HEADER_VALUE "\"%s\"\n", encoded_buffer);
611-
aws_mem_release(message->alloc, encoded_buffer);
610+
fprintf(fd, " " DEBUG_STR_HEADER_VALUE "\"" PRInSTR "\"\n", AWS_BYTE_BUF_PRI(encode_output));
611+
aws_byte_buf_clean_up(&encode_output);
612612
}
613613

614614
fprintf(fd, " }");
@@ -627,13 +627,15 @@ int aws_event_stream_message_to_debug_str(FILE *fd, const struct aws_event_strea
627627
const uint8_t *payload = aws_event_stream_message_payload(message);
628628
size_t encoded_len = 0;
629629
aws_base64_compute_encoded_len(payload_len, &encoded_len);
630-
char *encoded_payload = (char *)aws_mem_acquire(message->alloc, encoded_len);
631630

632631
struct aws_byte_cursor payload_buffer = aws_byte_cursor_from_array(payload, payload_len);
633-
struct aws_byte_buf encoded_payload_buffer = aws_byte_buf_from_array((uint8_t *)encoded_payload, encoded_len);
632+
struct aws_byte_buf encoded_payload_buffer;
633+
aws_byte_buf_init(&encoded_payload_buffer, message->alloc, encoded_len);
634634

635635
aws_base64_encode(&payload_buffer, &encoded_payload_buffer);
636-
fprintf(fd, " \"payload\": \"%s\",\n", encoded_payload);
636+
fprintf(fd, " \"payload\": \"" PRInSTR "\",\n", AWS_BYTE_BUF_PRI(encoded_payload_buffer));
637+
aws_byte_buf_clean_up(&encoded_payload_buffer);
638+
637639
fprintf(fd, " " DEBUG_STR_MESSAGE_CRC "%d\n}\n", aws_event_stream_message_message_crc(message));
638640

639641
return AWS_OP_SUCCESS;

0 commit comments

Comments
 (0)