Point72 · timkpaine · Jul 19, 2024 · Feb 26, 2025 · Mar 4, 2025
@@ -231,7 +231,6 @@ message("\n${Green}CMake Search Path: ${CMAKE_MODULE_PATH}${ColorReset}")
 ###########
 find_package(csp_autogen REQUIRED)
 
-
 ###################################################################################################################################################
 # Dependencies #
 ################

@@ -18,23 +18,31 @@ function(csp_autogen MODULE_NAME DEST_FILENAME HEADER_NAME_OUTVAR SOURCE_NAME_OU
     cmake_path(SET CSP_AUTOGEN_MODULE_PATH NORMALIZE "${CSP_AUTOGEN}")
     cmake_path(SET CSP_AUTOGEN_DESTINATION_FOLDER NORMALIZE "${CMAKE_CURRENT_BINARY_DIR}/csp_autogen")
     cmake_path(SET CSP_AUTOGEN_CPP_OUT NORMALIZE "${CMAKE_CURRENT_BINARY_DIR}/csp_autogen/${DEST_FILENAME}.cpp")
+    cmake_path(SET CSP_AUTOGEN_CPP_MAYBE_EXISTING NORMALIZE "${CMAKE_CURRENT_SOURCE_DIR}/csp_autogen/${DEST_FILENAME}.cpp")
     cmake_path(SET CSP_AUTOGEN_H_OUT NORMALIZE "${CMAKE_CURRENT_BINARY_DIR}/csp_autogen/${DEST_FILENAME}.h")
+    cmake_path(SET CSP_AUTOGEN_H_MAYBE_EXISTING NORMALIZE "${CMAKE_CURRENT_SOURCE_DIR}/csp_autogen/${DEST_FILENAME}.h")
 
     if(${CMAKE_SYSTEM_NAME} MATCHES "Windows")
         set(CSP_AUTOGEN_PYTHONPATH ${PROJECT_BINARY_DIR}/lib/${CMAKE_BUILD_TYPE};${CMAKE_SOURCE_DIR};%PYTHONPATH%)
     else()
         set(CSP_AUTOGEN_PYTHONPATH ${PROJECT_BINARY_DIR}/lib:${CMAKE_SOURCE_DIR}:$$PYTHONPATH)
     endif()
 
-    add_custom_command(OUTPUT "${CSP_AUTOGEN_CPP_OUT}" "${CSP_AUTOGEN_H_OUT}"
-        COMMAND ${CMAKE_COMMAND} -E env "PYTHONPATH=${CSP_AUTOGEN_PYTHONPATH}" ${Python_EXECUTABLE} ${CSP_AUTOGEN_MODULE_PATH} -m ${MODULE_NAME} -d ${CSP_AUTOGEN_DESTINATION_FOLDER} -o ${DEST_FILENAME} ${CSP_AUTOGEN_EXTRA_ARGS}
-        COMMENT "generating csp c++ types from module ${MODULE_NAME}"
-        DEPENDS mkdir_autogen_${MODULE_TARGETNAME} 
-                    ${CSP_AUTOGEN_MODULE_PATH}
-                    ${CMAKE_SOURCE_DIR}/${MODULE_FILENAME}
-                    ${CSP_TYPES_LIBRARY_FOR_AUTOGEN}
-    )
+    if (EXISTS "${CSP_AUTOGEN_CPP_MAYBE_EXISTING}" AND EXISTS "${CSP_AUTOGEN_H_MAYBE_EXISTING}")
+        # Files exist in-source
+        set(${SOURCE_NAME_OUTVAR} "${CSP_AUTOGEN_CPP_MAYBE_EXISTING}" PARENT_SCOPE )
+        set(${HEADER_NAME_OUTVAR} "${CSP_AUTOGEN_H_MAYBE_EXISTING}" PARENT_SCOPE )
+    else()
+      add_custom_command(OUTPUT "${CSP_AUTOGEN_CPP_OUT}" "${CSP_AUTOGEN_H_OUT}"
+          COMMAND ${CMAKE_COMMAND} -E env "PYTHONPATH=${CSP_AUTOGEN_PYTHONPATH}" ${Python_EXECUTABLE} ${CSP_AUTOGEN_MODULE_PATH} -m ${MODULE_NAME} -d ${CSP_AUTOGEN_DESTINATION_FOLDER} -o ${DEST_FILENAME} ${CSP_AUTOGEN_EXTRA_ARGS}
+          COMMENT "generating csp c++ types from module ${MODULE_NAME}"
+          DEPENDS mkdir_autogen_${MODULE_TARGETNAME} 
+                      ${CSP_AUTOGEN_MODULE_PATH}
+                      ${CMAKE_SOURCE_DIR}/${MODULE_FILENAME}
+                      ${CSP_TYPES_LIBRARY_FOR_AUTOGEN}
+      )
 
-    set(${SOURCE_NAME_OUTVAR} "${CSP_AUTOGEN_CPP_OUT}" PARENT_SCOPE)
-    set(${HEADER_NAME_OUTVAR} "${CSP_AUTOGEN_H_OUT}" PARENT_SCOPE)
+      set(${SOURCE_NAME_OUTVAR} "${CSP_AUTOGEN_CPP_OUT}" PARENT_SCOPE)
+      set(${HEADER_NAME_OUTVAR} "${CSP_AUTOGEN_H_OUT}" PARENT_SCOPE)
+    endif()
 endfunction()
@@ -0,0 +1,87 @@
+
+// AUTOGENERATED BY CSP_AUTOGEN
+// DO NOT MODIFY DIRECTLY
+// command: python csp/build/csp_autogen.py -m csp.adapters.websocket_types -d cpp/csp/adapters/websocket/csp_autogen/ -o websocket_types --omit_asserts
+
+#include "websocket_types.h"
+#include <csp/python/Common.h>
+#include <csp/python/PyStruct.h>
+#include <csp/python/PyCspEnum.h>
+#include <iostream>
+#include <stdlib.h>
+#include <Python.h>
+
+namespace csp::autogen
+{
+
+#define _offsetof( C, M ) ( ( char * ) &( ( C * ) nullptr ) -> M - ( char * ) 0 )
+
+static void assert_or_die( bool assertion, const char * error )
+{
+    if( !assertion )
+    {
+        std::cerr << "Fatal error on import of " << __FILE__ << ": " << error << std::endl;
+        if( PyErr_Occurred() )
+            PyErr_Print();
+        abort();
+    }
+}
+
+
+bool WebsocketStatus::static_init()
+{
+    if( Py_IsInitialized() )
+    {
+        csp::python::AcquireGIL gil;
+
+        // initialize EnumMeta from python type if we're in python
+        PyObject * pymodule = PyImport_ImportModule( "csp.adapters.websocket_types" );
+        assert_or_die( pymodule != nullptr, "failed to import struct module csp.adapters.websocket_types" );
+
+        PyObject * enumType = PyObject_GetAttrString(pymodule, "WebsocketStatus" );
+        assert_or_die( enumType != nullptr, "failed to find num type WebsocketStatus in module csp.adapters.websocket_types" );
+
+        // should add some assertion here..
+        csp::python::PyCspEnumMeta * pymeta = ( csp::python::PyCspEnumMeta * ) enumType;
+        s_meta = pymeta -> enumMeta;
+    }
+
+    return true;
+}
+
+bool static_init_WebsocketStatus = WebsocketStatus::static_init();
+std::shared_ptr<csp::CspEnumMeta> WebsocketStatus::s_meta;
+WebsocketStatus WebsocketStatus::ACTIVE = WebsocketStatus::create("ACTIVE");
+WebsocketStatus WebsocketStatus::GENERIC_ERROR = WebsocketStatus::create("GENERIC_ERROR");
+WebsocketStatus WebsocketStatus::CONNECTION_FAILED = WebsocketStatus::create("CONNECTION_FAILED");
+WebsocketStatus WebsocketStatus::CLOSED = WebsocketStatus::create("CLOSED");
+WebsocketStatus WebsocketStatus::MESSAGE_SEND_FAIL = WebsocketStatus::create("MESSAGE_SEND_FAIL");
+
+
+bool WebsocketHeaderUpdate::static_init()
+{
+
+    if( Py_IsInitialized() )
+    {
+        //Note that windows requires we grab the GIL since the windows DLL loading code releases GIL
+        csp::python::AcquireGIL gil;
+
+        // initialize StructMeta from python type if we're in python
+        PyObject * pymodule = PyImport_ImportModule( "csp.adapters.websocket_types" );
+        assert_or_die( pymodule != nullptr, "failed to import struct module csp.adapters.websocket_types" );
+
+        PyObject * structType = PyObject_GetAttrString(pymodule, "WebsocketHeaderUpdate" );
+        assert_or_die( structType != nullptr, "failed to find struct type WebsocketHeaderUpdate in module csp.adapters.websocket_types" );
+
+        // should add some assertion here..
+        csp::python::PyStructMeta * pymeta = ( csp::python::PyStructMeta * ) structType;
+        s_meta = pymeta -> structMeta;
+    }
+
+    return true;
+}
+
+bool static_init_WebsocketHeaderUpdate = WebsocketHeaderUpdate::static_init();
+csp::StructMetaPtr WebsocketHeaderUpdate::s_meta;
+
+}
@@ -0,0 +1,225 @@
+
+// AUTOGENERATED BY CSP_AUTOGEN
+// DO NOT MODIFY DIRECTLY
+// command: python csp/build/csp_autogen.py -m csp.adapters.websocket_types -d cpp/csp/adapters/websocket/csp_autogen/ -o websocket_types --omit_asserts
+
+#ifndef _IN_CSP_AUTOGEN_CSP_ADAPTERS_WEBSOCKET_TYPES
+#define _IN_CSP_AUTOGEN_CSP_ADAPTERS_WEBSOCKET_TYPES
+
+#include <csp/core/Exception.h>
+#include <csp/core/Platform.h>
+#include <csp/engine/Struct.h>
+#include <cstddef>
+
+namespace csp::autogen
+{
+
+class WebsocketStatus : public csp::CspEnum
+{
+public:
+    // Raw value quick access
+    enum class enum_
+    {
+        ACTIVE = 0,
+        GENERIC_ERROR = 1,
+        CONNECTION_FAILED = 2,
+        CLOSED = 3,
+        MESSAGE_SEND_FAIL = 4
+    };
+
+    // CspEnum types
+    static WebsocketStatus ACTIVE;
+    static WebsocketStatus GENERIC_ERROR;
+    static WebsocketStatus CONNECTION_FAILED;
+    static WebsocketStatus CLOSED;
+    static WebsocketStatus MESSAGE_SEND_FAIL;
+
+    const char * asCString() const                { return name().c_str(); }
+    const std::string & asString() const          { return name(); }
+
+    static WebsocketStatus create( enum_ v )          { return s_meta -> create( ( int64_t ) v ); }
+    static WebsocketStatus create( const char * name) { return s_meta -> fromString( name ); }
+    static WebsocketStatus create( const std::string & s ) { return create( s.c_str() ); }
+
+    enum_ enum_value() const { return ( enum_ ) value(); }
+
+    static constexpr uint32_t num_types() { return 5; }
+
+    static bool static_init();
+
+    WebsocketStatus( const csp::CspEnum & v ) : csp::CspEnum( v ) { CSP_TRUE_OR_THROW( v.meta() == s_meta.get(), AssertionError, "Mismatched enum meta" ); }
+
+private:
+
+    static std::shared_ptr<csp::CspEnumMeta> s_meta;
+};
+
+class WebsocketHeaderUpdate : public csp::Struct
+{
+public:
+
+    using Ptr = csp::TypedStructPtr<WebsocketHeaderUpdate>;
+
+    WebsocketHeaderUpdate()  = delete;
+    ~WebsocketHeaderUpdate() = delete;
+    WebsocketHeaderUpdate( const WebsocketHeaderUpdate & ) = delete;
+    WebsocketHeaderUpdate( WebsocketHeaderUpdate && ) = delete;
+
+    Ptr copy() const { return csp::structptr_cast<WebsocketHeaderUpdate>( Struct::copy() ); }
+
+    static WebsocketHeaderUpdate::Ptr create()
+    {
+        return Ptr( static_cast<WebsocketHeaderUpdate *>( s_meta -> createRaw() ) );
+    }
+
+    static const csp::StructMetaPtr & meta() { return s_meta; }
+
+
+    const std::string & key() const
+    {
+
+
+
+
+        if( !key_isSet() )
+            CSP_THROW( csp::ValueError, "field key on struct WebsocketHeaderUpdate is not set" );
+
+        return m_key;
+    }
+
+    void set_key( const std::string & value )
+    {
+
+
+
+
+
+        m_WebsocketHeaderUpdate_mask[0] |= 1;
+
+
+        //TODO employ move semantics where it makes sense
+        m_key = value;
+    }
+
+
+    void set_key( const char * value )
+    {
+
+
+
+
+
+        m_WebsocketHeaderUpdate_mask[0] |= 1;
+
+        m_key = value;
+    }
+
+    void set_key( std::string_view value )
+    {
+
+
+
+
+
+        m_WebsocketHeaderUpdate_mask[0] |= 1;
+
+        m_key = value;
+    }
+
+
+    bool key_isSet() const
+    {
+
+        return m_WebsocketHeaderUpdate_mask[0] & 1;
+    }
+
+    void clear_key()
+    {
+
+        m_WebsocketHeaderUpdate_mask[0] &= ~1;
+    }
+
+    const std::string & value() const
+    {
+
+
+
+
+        if( !value_isSet() )
+            CSP_THROW( csp::ValueError, "field value on struct WebsocketHeaderUpdate is not set" );
+
+        return m_value;
+    }
+
+    void set_value( const std::string & value )
+    {
+
+
+
+
+
+        m_WebsocketHeaderUpdate_mask[0] |= 2;
+
+
+        //TODO employ move semantics where it makes sense
+        m_value = value;
+    }
+
+
+    void set_value( const char * value )
+    {
+
+
+
+
+
+        m_WebsocketHeaderUpdate_mask[0] |= 2;
+
+        m_value = value;
+    }
+
+    void set_value( std::string_view value )
+    {
+
+
+
+
+
+        m_WebsocketHeaderUpdate_mask[0] |= 2;
+
+        m_value = value;
+    }
+
+
+    bool value_isSet() const
+    {
+
+        return m_WebsocketHeaderUpdate_mask[0] & 2;
+    }
+
+    void clear_value()
+    {
+
+        m_WebsocketHeaderUpdate_mask[0] &= ~2;
+    }
+
+
+    static bool static_init();
+
+private:
+
+    std::string m_key;
+    std::string m_value;
+    char m_WebsocketHeaderUpdate_mask[1];
+
+
+    static csp::StructMetaPtr s_meta;
+
+    static void assert_mask()
+    {
+
+    }
+};
+
+}
+#endif