[WIP] Fix symbol visibility for user extensions

cpp/csp/adapters/kafka/KafkaAdapterManager.h

@@ -3,6 +3,7 @@
 
 #include <csp/core/Enum.h>
 #include <csp/core/Hash.h>
+#include <csp/core/Platform.h>
 #include <csp/engine/AdapterManager.h>
 #include <csp/engine/Dictionary.h>
 #include <csp/engine/PushInputAdapter.h>
@@ -11,6 +12,7 @@
 #include <unordered_map>
 #include <vector>
 
+
 namespace RdKafka
 {
 
@@ -47,7 +49,7 @@ struct KafkaStatusMessageTypeTraits
 using KafkaStatusMessageType = csp::Enum<KafkaStatusMessageTypeTraits>;
 
 //Top level AdapterManager object for all kafka adapters in the engine
-class CSP_PUBLIC KafkaAdapterManager final : public csp::AdapterManager
+class CSPKAFKAADAPTERIMPL_EXPORT KafkaAdapterManager final : public csp::AdapterManager
 {
 public:
     KafkaAdapterManager( csp::Engine * engine, const Dictionary & properties );

cpp/csp/adapters/parquet/DialectGenericListReaderInterface.h

@@ -2,14 +2,15 @@
 #define _IN_CSP_ADAPTERS_PARQUET_DialectGenericListReaderInterface_H
 
 #include <memory>
+#include <csp/core/Platform.h>
 #include <csp/engine/DialectGenericType.h>
 #include <csp/adapters/parquet/ParquetReaderColumnAdapter.h>
 #include <arrow/array/builder_base.h>
 
 namespace csp::adapters::parquet
 {
 
-class DialectGenericListReaderInterface
+class CSPPARQUETADAPTERIMPL_EXPORT DialectGenericListReaderInterface
 {
 public:
     using Ptr = std::shared_ptr<DialectGenericListReaderInterface>;
@@ -25,7 +26,7 @@ class DialectGenericListReaderInterface
 };
 
 template< typename T >
-class CSP_PUBLIC TypedDialectGenericListReaderInterface : public DialectGenericListReaderInterface
+class CSPPARQUETADAPTERIMPL_EXPORT TypedDialectGenericListReaderInterface : public DialectGenericListReaderInterface
 {
 public:
     using Ptr = std::shared_ptr<TypedDialectGenericListReaderInterface<T>>;

cpp/csp/adapters/parquet/ParquetInputAdapterManager.h

@@ -4,6 +4,7 @@
 #include <csp/adapters/parquet/ParquetReader.h>
 #include <csp/adapters/utils/StructAdapterInfo.h>
 #include <csp/core/Generator.h>
+#include <csp/core/Platform.h>
 #include <csp/engine/AdapterManager.h>
 #include <csp/engine/Dictionary.h>
 #include <unordered_map>
@@ -18,7 +19,7 @@ namespace csp::adapters::parquet
 
 
 //Top level AdapterManager object for all parquet adapters in the engine
-class CSP_PUBLIC ParquetInputAdapterManager final : public csp::AdapterManager
+class CSPPARQUETADAPTERIMPL_EXPORT ParquetInputAdapterManager final : public csp::AdapterManager
 {
 public:
     using GeneratorPtr = csp::Generator<std::string, csp::DateTime, csp::DateTime>::Ptr;

cpp/csp/adapters/parquet/ParquetOutputAdapterManager.h

@@ -4,6 +4,7 @@
 #include <csp/adapters/parquet/ParquetReader.h>
 #include <csp/adapters/utils/StructAdapterInfo.h>
 #include <csp/core/Generator.h>
+#include <csp/core/Platform.h>
 #include <csp/engine/AdapterManager.h>
 #include <csp/engine/Dictionary.h>
 #include <set>
@@ -21,7 +22,7 @@ class ParquetOutputFilenameAdapter;
 class ParquetDictBasketOutputWriter;
 
 //Top level AdapterManager object for all parquet adapters in the engine
-class CSP_PUBLIC ParquetOutputAdapterManager final : public csp::AdapterManager
+class CSPPARQUETADAPTERIMPL_EXPORT ParquetOutputAdapterManager final : public csp::AdapterManager
 {
 public:
     using FileVisitorCallback = std::function<void(const std::string &)>;

cpp/csp/adapters/websocket/ClientAdapterManager.h

@@ -40,7 +40,7 @@ struct WebsocketClientStatusTypeTraits
 
 using ClientStatusType = Enum<WebsocketClientStatusTypeTraits>;
 
-class CSP_PUBLIC ClientAdapterManager final : public AdapterManager
+class CSPWEBSOCKETADAPTERIMPL_EXPORT ClientAdapterManager final : public AdapterManager
 {
 public:
     ClientAdapterManager(

cpp/csp/core/BasicAllocator.h

@@ -15,7 +15,7 @@ namespace csp
 {
 
 // Extremely basic non-thread safe fixed-size allocator
-class BasicAllocator
+class CSPCORE_EXPORT BasicAllocator
 {
 public:
     //elemsize is size of a single alloc, blockSize is number of elements to 

cpp/csp/core/CMakeLists.txt

@@ -1,3 +1,5 @@
+include(GenerateExportHeader)
+
 set(CORE_PUBLIC_HEADERS
       BasicAllocator.h
       Config.h.in
@@ -25,7 +27,11 @@ set(CORE_SOURCE_FILES
 
 configure_file(Config.h.in ${CMAKE_CURRENT_BINARY_DIR}/cpp/csp/core/Config.h)
 
-add_library(csp_core STATIC ${CORE_SOURCE_FILES})
+add_library(csp_core SHARED ${CORE_SOURCE_FILES})
+generate_export_header(csp_core
+        BASE_NAME cspcore
+        EXPORT_MACRO_NAME CSPCORE_EXPORT
+)
 set_target_properties(csp_core PROPERTIES PUBLIC_HEADER "${CORE_PUBLIC_HEADERS}")
 
 install(TARGETS csp_core
@@ -34,3 +40,4 @@ install(TARGETS csp_core
         LIBRARY DESTINATION lib/
        )
 install(FILES ${CMAKE_CURRENT_BINARY_DIR}/cpp/csp/core/Config.h DESTINATION include/csp/core)
+install(FILES ${CMAKE_CURRENT_BINARY_DIR}/cspcore_export.h DESTINATION include/csp/core)

cpp/csp/core/DynamicBitSet.h

@@ -9,7 +9,7 @@ namespace csp
 {
 
 template<typename NodeT = uint64_t, typename IndexT = int32_t>
-class DynamicBitSet
+class CSPCORE_EXPORT DynamicBitSet
 {
 
 public:

cpp/csp/core/Enum.h

@@ -73,7 +73,7 @@ bool UnknownOnInvalidValue(long) { return false; }
 
 START_PACKED
 template<typename EnumTraits>
-struct Enum : public EnumTraits
+struct CSPCORE_EXPORT Enum : public EnumTraits
 {
     using EnumV = typename EnumTraits::_enum;
     using Mapping = std::vector<std::string>;

cpp/csp/core/EnumBitSet.h

@@ -1,6 +1,8 @@
 #ifndef _IN_CSP_CORE_ENUMBITSET_H
 #define _IN_CSP_CORE_ENUMBITSET_H
 
+#include <csp/core/Platform.h>
+
 #include <stddef.h>
 #include <stdint.h>
 #include <initializer_list>
@@ -12,7 +14,7 @@ namespace csp
 //Utility class to hold enums as a bitmask ( where enum values are incremental from 0 )
 //enum must have a NUM_TYPES entry for number of entries
 template< typename EnumT >
-class EnumBitSet
+class CSPCORE_EXPORT EnumBitSet
 {
     using value_type = uint64_t;
 

cpp/csp/core/Generator.h

@@ -1,12 +1,13 @@
 #ifndef _IN_CSP_CORE_GENERATOR_H
 #define _IN_CSP_CORE_GENERATOR_H
 
+#include <csp/core/Platform.h>
 #include <memory>
 
 namespace csp
 {
 template< typename V, typename ...Args >
-class Generator
+class CSPCORE_EXPORT Generator
 {
 public:
     using Ptr = std::shared_ptr<Generator<V, Args...>>;

cpp/csp/core/Platform.h

@@ -4,6 +4,19 @@
 #include <stdint.h>
 #include <time.h>
 
+// cmake autogenerated export files
+#include <csp/core/cspcore_export.h>
+#include <csp/engine/cspengine_export.h>
+#include <csp/engine/csptypes_export.h>
+
+#include <csp/python/cspimpl_export.h>
+#include <csp/python/csptypesimpl_export.h>
+
+#include <csp/python/adapters/cspkafkaadapterimpl_export.h>
+#include <csp/python/adapters/cspparquetadapterimpl_export.h>
+#include <csp/python/adapters/cspwebsocketadapterimpl_export.h>
+
+
 //TODO move Likely.h defines into Platform.h
 #ifdef WIN32
 #define NOMINMAX
@@ -14,20 +27,7 @@
 #undef ERROR
 #undef GetMessage
 
-#define CSP_LOCAL
-#define CSP_PUBLIC __declspec(dllexport)
-
-#ifdef CSPTYPESIMPL_EXPORTS
-#define CSPTYPESIMPL_EXPORT __declspec(dllexport)
-#else
-#define CSPTYPESIMPL_EXPORT __declspec(dllimport)
-#endif
-
-#ifdef CSPIMPL_EXPORTS
-#define CSPIMPL_EXPORT __declspec(dllexport)
-#else
-#define CSPIMPL_EXPORT __declspec(dllimport)
-#endif
+#define CSP_PUBLIC __declspec(dllexport) // just for exceptions!
 
 #define START_PACKED __pragma( pack(push, 1) )
 #define END_PACKED   __pragma( pack(pop))
@@ -90,10 +90,7 @@ inline uint8_t ffs(uint64_t n)
 }
 
 #else
-#define CSPIMPL_EXPORT      __attribute__ ((visibility ("default")))
-#define CSPTYPESIMPL_EXPORT __attribute__ ((visibility ("default")))
 
-#define CSP_LOCAL  __attribute__ ((visibility ("hidden")))
 #define CSP_PUBLIC __attribute__ ((visibility ("default")))
 
 #define START_PACKED

cpp/csp/core/QueueWaiter.h

@@ -1,17 +1,20 @@
 #ifndef _IN_CSP_CORE_QUEUEBLOCKINGWAIT_H
 #define _IN_CSP_CORE_QUEUEBLOCKINGWAIT_H
 
+#include <csp/core/Platform.h>
+#include <csp/core/System.h>
+#include <csp/core/Time.h>
+
 #include <mutex>
 #include <condition_variable>
-#include <csp/core/Time.h>
-#include <csp/core/System.h>
+
 
 namespace csp
 {
 
 class TimeDelta;
 
-class QueueWaiter
+class CSPCORE_EXPORT QueueWaiter
 {
 public:
     QueueWaiter() : m_eventsPending( false )

cpp/csp/core/TaggedPointerUnion.h

@@ -1,6 +1,7 @@
 #ifndef _IN_CSP_CORE_TAGGEDPOINTERUNION_H
 #define _IN_CSP_CORE_TAGGEDPOINTERUNION_H
 
+#include <csp/core/Platform.h>
 #include <csp/core/System.h>
 
 namespace csp
@@ -25,7 +26,7 @@ struct IndexOf<T, TypeList<TOther, Ts...> >
 
 
 template<typename... Ts>
-class TaggedPointerUnion
+class CSPCORE_EXPORT TaggedPointerUnion
 {
 public:
     static inline constexpr size_t NUM_TAGS = sizeof...(Ts);

cpp/csp/core/Time.h

@@ -21,7 +21,7 @@ const int64_t NANOS_PER_SECOND      = 1000000000;
 const int64_t SECONDS_PER_DAY       = 86400;
 const int64_t NANOS_PER_DAY         = NANOS_PER_SECOND * SECONDS_PER_DAY;
 
-class TimeDelta
+class CSPCORE_EXPORT TimeDelta
 {
 public:
     constexpr TimeDelta() : TimeDelta( TimeDelta::NONE() ) {}
@@ -165,7 +165,7 @@ inline std::ostream & operator <<( std::ostream &os, const TimeDelta & d )
     return os;
 }
 
-class Date
+class CSPCORE_EXPORT Date
 {
 public:
     Date() : Date( NONE() ) {}
@@ -316,7 +316,7 @@ inline std::ostream & operator <<( std::ostream &os, const Date & d )
     return os;
 }
 
-class Time
+class CSPCORE_EXPORT Time
 {
 public:
     Time() : Time( -1 ) {} //NONE
@@ -446,7 +446,7 @@ inline std::ostream & operator <<( std::ostream &os, const Time & t )
 
 // Time is internally stored as an int64_t nanoseconds since 1970. 
 // All DateTime objects are stored as UTC and should be treated as such
-class DateTime
+class CSPCORE_EXPORT DateTime
 {
 public:
     DateTime() : DateTime( DateTime::NONE() ) {}
@@ -597,7 +597,7 @@ inline std::ostream & operator <<( std::ostream &os, const DateTime & dt )
 //Helper class to extract day/month/year/etc info from raw timestamp
 //ie DateTimeEx dte( existingDt )
 //dte.day, etc etc
-class DateTimeEx : public DateTime
+class CSPCORE_EXPORT DateTimeEx : public DateTime
 {
 public:
     DateTimeEx( const DateTime & dt );

cpp/csp/engine/AdapterManager.h

@@ -1,6 +1,7 @@
 #ifndef _IN_CSP_ADAPTER_MANAGER_H
 #define _IN_CSP_ADAPTER_MANAGER_H
 
+#include <csp/core/Platform.h>
 #include <csp/core/Time.h>
 #include <csp/engine/InputAdapter.h>
 #include <csp/engine/PushInputAdapter.h>
@@ -16,7 +17,7 @@ class AdapterManager;
 
 class Engine;
 
-class ManagedSimInputAdapter : public InputAdapter
+class CSPENGINE_EXPORT ManagedSimInputAdapter : public InputAdapter
 {
 public:
     ManagedSimInputAdapter( csp::Engine *engine, const CspTypePtr &type, AdapterManager *manager, PushMode pushMode );
@@ -93,7 +94,7 @@ bool ManagedSimInputAdapter::pushNullTick()
     return true;
 }
 
-class CSP_PUBLIC AdapterManager : public EngineOwned
+class CSPENGINE_EXPORT AdapterManager : public EngineOwned
 {
 public:
     AdapterManager( csp::Engine * );

cpp/csp/engine/AlarmInputAdapter.h

@@ -1,14 +1,15 @@
 #ifndef _IN_CSP_ENGINE_ALARMINPUTADAPTER_H
 #define _IN_CSP_ENGINE_ALARMINPUTADAPTER_H
 
+#include <csp/core/Platform.h>
 #include <csp/engine/InputAdapter.h>
 #include <unordered_set>
 
 namespace csp
 {
 
 template<typename T>
-class AlarmInputAdapter final : public InputAdapter
+class CSPENGINE_EXPORT AlarmInputAdapter final : public InputAdapter
 {
 public:
     AlarmInputAdapter( Engine * engine, CspTypePtr & type ) : InputAdapter( engine, type, PushMode::NON_COLLAPSING )