MQTTVersion.c

Go to the documentation of this file.

/*******************************************************************************
 * Copyright (c) 2012, 2018 IBM Corp.
 *
 * All rights reserved. This program and the accompanying materials
 * are made available under the terms of the Eclipse Public License v2.0
 * and Eclipse Distribution License v1.0 which accompany this distribution. 
 *
 * The Eclipse Public License is available at 
 *    https://www.eclipse.org/legal/epl-2.0/
 * and the Eclipse Distribution License is available at 
 *   http://www.eclipse.org/org/documents/edl-v10.php.
 *
 * Contributors:
 *    Ian Craggs - initial API and implementation and/or initial documentation
 *******************************************************************************/

#include <stdio.h>

#if !defined(_WRS_KERNEL)

#include <stdlib.h>
#include <string.h>
#include <errno.h>
#include <fcntl.h>
#include <sys/types.h>
#include <ctype.h>
#include "MQTTAsync.h"

#if defined(_WIN32) || defined(_WIN64)
#include <windows.h>
#include <tchar.h>
#include <io.h>
#include <sys/stat.h>
#else
#include <dlfcn.h>
#include <sys/mman.h>
#include <unistd.h>
#endif


 static const char* libraries[] = {"paho-mqtt3c", "paho-mqtt3cs", "paho-mqtt3a", "paho-mqtt3as"};
 static const char* eyecatchers[] = {"MQTTAsyncV3_Version", "MQTTAsyncV3_Timestamp",
                                         "MQTTClientV3_Version", "MQTTClientV3_Timestamp"};
 

char* FindString(char* filename, const char* eyecatcher_input);
int printVersionInfo(MQTTAsync_nameValue* info);
int loadandcall(const char* libname);
void printEyecatchers(char* filename);


char* FindString(char* filename, const char* eyecatcher_input)
{
        FILE* infile = NULL;
        static char value[100];
        const char* eyecatcher = eyecatcher_input;
        
        memset(value, 0, 100);
        if ((infile = fopen(filename, "rb")) != NULL)
        {
                size_t buflen = strlen(eyecatcher);
                char* buffer = (char*) malloc(buflen + 1); /* added space for unused null terminator to stop LGTM complaint */

                if (buffer != NULL)
                {
                        int c = fgetc(infile);

                        while (feof(infile) == 0)
                        {
                                int count = 0;
                                buffer[count++] = c;
                                if (memcmp(eyecatcher, buffer, buflen) == 0)
                                {
                                        char* ptr = value;
                                        c = fgetc(infile); /* skip space */
                                        c = fgetc(infile);
                                        while (isprint(c))
                                        {
                                                *ptr++ = c;
                                                c = fgetc(infile);
                                        }
                                        break;
                                }
                                if (count == buflen)
                                {
                                        memmove(buffer, &buffer[1], buflen - 1);
                                        count--;
                                }
                                c = fgetc(infile);
                        }
                        free(buffer);
                }

                fclose(infile);
        }
        return value;
}


int printVersionInfo(MQTTAsync_nameValue* info)
{
        int rc = 0;
        
        while (info->name)
        {
                printf("%s: %s\n", info->name, info->value);
                info++;
                rc = 1;  /* at least one value printed */
        }
        return rc;
}

typedef MQTTAsync_nameValue* (*func_type)(void);

int loadandcall(const char* libname)
{
        int rc = 0;
        MQTTAsync_nameValue* (*func_address)(void) = NULL;
#if defined(_WIN32) || defined(_WIN64)
        HMODULE APILibrary = LoadLibraryA(libname);
        if (APILibrary == NULL)
                printf("Error loading library %s, error code %d\n", libname, GetLastError());
        else
        {
                func_address = (func_type)GetProcAddress(APILibrary, "MQTTAsync_getVersionInfo");
                if (func_address == NULL) 
                        func_address = (func_type)GetProcAddress(APILibrary, "MQTTClient_getVersionInfo");
                if (func_address)
                        rc = printVersionInfo((*func_address)());
                FreeLibrary(APILibrary);
        }
#else
        void* APILibrary = dlopen(libname, RTLD_LAZY); /* Open the Library in question */
        if (APILibrary == NULL)
                printf("Error loading library %s, error %s\n", libname, dlerror());
        else
        {
                *(void **) (&func_address) = dlsym(APILibrary, "MQTTAsync_getVersionInfo");
                if (func_address == NULL)
                        func_address = dlsym(APILibrary, "MQTTClient_getVersionInfo");
                if (func_address)
                        rc = printVersionInfo((*func_address)());
                dlclose(APILibrary);
        }
#endif
        return rc;
}
 
        
#if !defined(ARRAY_SIZE)
#define ARRAY_SIZE(a) (sizeof(a) / sizeof(a[0]))
#endif

void printEyecatchers(char* filename)
{
        int i = 0;
        
        for (i = 0; i < ARRAY_SIZE(eyecatchers); ++i)
        {
                char* value = FindString(filename, eyecatchers[i]);
                if (value[0]) 
                        printf("%s: %s\n", eyecatchers[i], value);
        }
}


int main(int argc, char** argv)
{
        printf("MQTTVersion: print the version strings of an MQTT client library\n"); 
        printf("Copyright (c) 2012, 2018 IBM Corp.\n");
        
        if (argc == 1)
        {
                int i = 0;
                char namebuf[60];
                
                printf("Specify a particular library name if it is not in the current directory, or not executable on this platform\n");
                 
                for (i = 0; i < ARRAY_SIZE(libraries); ++i)
                {
#if defined(__CYGWIN__)
                        sprintf(namebuf, "cyg%s-1.dll", libraries[i]);
#elif defined(_WIN32) || defined(_WIN64)
                        sprintf(namebuf, "%s.dll", libraries[i]);
#elif defined(OSX)
                        sprintf(namebuf, "lib%s.1.dylib", libraries[i]);
#else
                        sprintf(namebuf, "lib%s.so.1", libraries[i]);
#endif
                        printf("--- Trying library %s ---\n", libraries[i]);
                        if (!loadandcall(namebuf))
                                printEyecatchers(namebuf);
                }
        }
        else
        {
                if (!loadandcall(argv[1]))
                        printEyecatchers(argv[1]);
        }

        return 0;
}
#else
int main(void)
{
    fprintf(stderr, "This tool is not supported on this platform yet.\n");
    return 1;
}
#endif /* !defined(_WRS_KERNEL) */