Commit 43981431 authored by Greg Williams's avatar Greg Williams
Browse files

Converted initial proto buf pack/unpack test to a Unity integration test. 

Converted output format to teamcity for CI.
Restructured repo for tests.
parent d3794af4

project.yml

+16 −4
Original line number Diff line number Diff line
@@ -57,10 +57,22 @@ 
    int8:     INT8

    bool:     UINT8



#:tools:

# Ceedling defaults to using gcc for compiling, linking, etc.

# As [:tools] is blank, gcc will be used (so long as it's in your system path)

# See documentation to configure a given toolchain for use

:tools:

  :test_includes_preprocessor:

    :executable: gcc

    :arguments:

      - -E

      - -MM

      - -MG

      - -I"$": COLLECTION_PATHS_TEST_SUPPORT_SOURCE_INCLUDE_VENDOR

      - -I"$": COLLECTION_PATHS_TEST_TOOLCHAIN_INCLUDE

      - -D"$": COLLECTION_DEFINES_TEST_AND_VENDOR

      - -D"$": DEFINES_TEST_PREPROCESS

      - -DGNU_COMPILER

      - -w

      - -nostdinc

      - ${1}





:plugins:

  :load_paths:

src/integration-test/README.md

deleted100644 → 0
+0 −2
Original line number Diff line number Diff line 
Kinetic C Client Integration Test Suite

=======================================

src/test/README.md

deleted100644 → 0
+0 −2
Original line number Diff line number Diff line 
Kinetic C Client Unit Test Suite

================================

test/integration/.gitkeep

0 → 100644
+0 −0

Empty file added.

test/integration/test_KineticProto.c

0 → 100644
+81 −0
Original line number Diff line number Diff line 
#include <stdio.h>

#include <string.h>

#include <stdlib.h>

#include <protobuf-c/protobuf-c.h>

#include "KineticProto.h"

#include "unity.h"



#ifndef TRUE

#define TRUE 1

#endif

#ifndef FALSE

#define FALSE 0

#endif



void setUp(void)

{

}



void tearDown(void)

{

}



void test_KineticProto_should_pack_and_unpack_protocol_buffers(void)

{

	size_t i, j;

    size_t len, len1, len2;

    KineticProto proto = KINETIC_PROTO_INIT;

    KineticProto* pproto;

    KineticProto_Command cmd = KINETIC_PROTO_COMMAND__INIT;

    KineticProto_Header header = KINETIC_PROTO_HEADER__INIT;

    uint8_t buffer[1024];

    ProtobufCBufferSimple bs = PROTOBUF_C_BUFFER_SIMPLE_INIT(buffer);

    uint8_t* packed;



    KineticProto_init(&proto);

    KineticProto_command__init(&cmd);

    KineticProto_header__init(&header);



    header.clusterversion = 12345678;

    header.has_clusterversion = TRUE;

    header.identity = -12345678;

    header.has_identity = TRUE;

    cmd.header = &header;

    proto.command = &cmd;



    len = KineticProto_get_packed_size(&proto);

    packed = malloc(KineticProto_get_packed_size(&proto));

    TEST_ASSERT_NOT_NULL_MESSAGE(packed, "Failed dynamically allocating buffer");

    len1 = KineticProto_pack(&proto, packed);

    TEST_ASSERT_EQUAL_MESSAGE(len, len1, "Packed size invalid");

    TEST_ASSERT_EQUAL_MESSAGE(len, KineticProto_get_packed_size(&proto), "Inspected packed size invalid");



    len2 = KineticProto_pack_to_buffer(&proto, &bs.base);

    TEST_ASSERT_EQUAL_MESSAGE(len, len2, "SimpleBuffer packed size invalid");

    TEST_ASSERT_EQUAL_MESSAGE(len, bs.len, "SimpleBuffer 'len' packed size invalid");

    TEST_ASSERT_EQUAL_MESSAGE(len, KineticProto_get_packed_size(&proto), "SimpleBuffer inspected packed size invalid");



    // Validate the both packed buffers are equal

    TEST_ASSERT_EQUAL_HEX8_ARRAY_MESSAGE(bs.data, packed, len, "Packed proto buffers do not match");

    PROTOBUF_C_BUFFER_SIMPLE_CLEAR (&bs);



    // Unpack and verify the simple buffer results

    pproto = KineticProto_unpack(NULL, len, bs.data);

    TEST_ASSERT_NOT_NULL_MESSAGE(pproto, "Unpack method returned NULL");

    TEST_ASSERT_TRUE_MESSAGE(pproto->command->header->has_identity, "Command header identity reported as unavailable");

    TEST_ASSERT_EQUAL_INT64_MESSAGE(-12345678ul, pproto->command->header->identity, "Command header identity invalid");

    TEST_ASSERT_TRUE_MESSAGE(pproto->command->header->has_clusterversion, "Command header cluster version reported as unavailable");

    TEST_ASSERT_EQUAL_INT64_MESSAGE(12345678ul, pproto->command->header->clusterversion, "Command header cluster version invalid");



    // Unpack and verify the raw buffer results

    pproto = KineticProto_unpack(NULL, len, packed);

    TEST_ASSERT_NOT_NULL_MESSAGE(pproto, "Unpack method returned NULL");

    TEST_ASSERT_TRUE_MESSAGE(pproto->command->header->has_identity, "Command header identity reported as unavailable");

    TEST_ASSERT_EQUAL_INT64_MESSAGE(-12345678ul, pproto->command->header->identity, "Command header identity invalid");

    TEST_ASSERT_TRUE_MESSAGE(pproto->command->header->has_clusterversion, "Command header cluster version reported as unavailable");

    TEST_ASSERT_EQUAL_INT64_MESSAGE(12345678ul, pproto->command->header->clusterversion, "Command header cluster version invalid");



    // Free dynamically allocated memory

    KineticProto_free_unpacked(pproto, NULL);

    free(packed);

}