#ifndef BLENDERCONNECTION_HPP #define BLENDERCONNECTION_HPP #if _WIN32 #ifndef WIN32_LEAN_AND_MEAN #define WIN32_LEAN_AND_MEAN 1 #endif #ifndef NOMINMAX #define NOMINMAX #endif #include #else #include #endif #include #include #include #include #include #include #include "HECL/HECL.hpp" #include "HECL/HMDLMeta.hpp" #include #include namespace HECL { extern LogVisor::LogModule BlenderLog; extern class BlenderConnection* SharedBlenderConnection; class HMDLBuffers; class BlenderConnection { public: enum class BlendType { None, Mesh, Actor, Area, World, MapArea, MapUniverse }; private: bool m_lock = false; #if _WIN32 HANDLE m_blenderProc; #else pid_t m_blenderProc; #endif int m_readpipe[2]; int m_writepipe[2]; BlendType m_loadedType = BlendType::None; ProjectPath m_loadedBlend; std::string m_startupBlend; size_t _readLine(char* buf, size_t bufSz); size_t _writeLine(const char* buf); size_t _readBuf(void* buf, size_t len); size_t _writeBuf(const void* buf, size_t len); void _closePipe(); public: BlenderConnection(int verbosityLevel=1); ~BlenderConnection(); bool createBlend(const ProjectPath& path, BlendType type); BlendType getBlendType() const {return m_loadedType;} bool openBlend(const ProjectPath& path, bool force=false); bool saveBlend(); void deleteBlend(); enum class ANIMCurveType { Rotate, Translate, Scale }; class PyOutStream : public std::ostream { friend class BlenderConnection; BlenderConnection* m_parent; bool m_deleteOnError; struct StreamBuf : std::streambuf { PyOutStream& m_parent; std::string m_lineBuf; bool m_deleteOnError; StreamBuf(PyOutStream& parent, bool deleteOnError) : m_parent(parent), m_deleteOnError(deleteOnError) {} StreamBuf(const StreamBuf& other) = delete; StreamBuf(StreamBuf&& other) = default; int_type overflow(int_type ch) { if (!m_parent.m_parent || !m_parent.m_parent->m_lock) BlenderLog.report(LogVisor::FatalError, "lock not held for PyOutStream writing"); if (ch != traits_type::eof() && ch != '\n' && ch != '\0') { m_lineBuf += char_type(ch); return ch; } //printf("FLUSHING %s\n", m_lineBuf.c_str()); m_parent.m_parent->_writeLine(m_lineBuf.c_str()); char readBuf[16]; m_parent.m_parent->_readLine(readBuf, 16); if (strcmp(readBuf, "OK")) { if (m_deleteOnError) m_parent.m_parent->deleteBlend(); BlenderLog.report(LogVisor::FatalError, "error sending '%s' to blender", m_lineBuf.c_str()); } m_lineBuf.clear(); return ch; } } m_sbuf; PyOutStream(BlenderConnection* parent, bool deleteOnError) : std::ostream(&m_sbuf), m_parent(parent), m_deleteOnError(deleteOnError), m_sbuf(*this, deleteOnError) { m_parent->m_lock = true; m_parent->_writeLine("PYBEGIN"); char readBuf[16]; m_parent->_readLine(readBuf, 16); if (strcmp(readBuf, "READY")) BlenderLog.report(LogVisor::FatalError, "unable to open PyOutStream with blender"); } public: PyOutStream(const PyOutStream& other) = delete; PyOutStream(PyOutStream&& other) : std::ostream(&m_sbuf), m_parent(other.m_parent), m_sbuf(std::move(other.m_sbuf)) {other.m_parent = nullptr;} ~PyOutStream() {close();} void close() { if (m_parent && m_parent->m_lock) { m_parent->_writeLine("PYEND"); char readBuf[16]; m_parent->_readLine(readBuf, 16); if (strcmp(readBuf, "DONE")) BlenderLog.report(LogVisor::FatalError, "unable to close PyOutStream with blender"); m_parent->m_lock = false; } } #if __GNUC__ __attribute__((__format__ (__printf__, 2, 3))) #endif void format(const char* fmt, ...) { if (!m_parent || !m_parent->m_lock) BlenderLog.report(LogVisor::FatalError, "lock not held for PyOutStream::format()"); va_list ap; va_start(ap, fmt); char* result = nullptr; #ifdef _WIN32 int length = _vscprintf(fmt, ap); result = (char*)malloc(length); vsnprintf(result, length, fmt, ap); #else int length = vasprintf(&result, fmt, ap); #endif va_end(ap); if (length > 0) this->write(result, length); free(result); } void linkBlend(const char* target, const char* objName, bool link=true); void linkBackground(const char* target, const char* sceneName); void AABBToBMesh(const atVec3f& min, const atVec3f& max) { format("bm = bmesh.new()\n" "bm.verts.new((%f,%f,%f))\n" "bm.verts.new((%f,%f,%f))\n" "bm.verts.new((%f,%f,%f))\n" "bm.verts.new((%f,%f,%f))\n" "bm.verts.new((%f,%f,%f))\n" "bm.verts.new((%f,%f,%f))\n" "bm.verts.new((%f,%f,%f))\n" "bm.verts.new((%f,%f,%f))\n" "bm.verts.ensure_lookup_table()\n" "bm.edges.new((bm.verts[0], bm.verts[1]))\n" "bm.edges.new((bm.verts[0], bm.verts[2]))\n" "bm.edges.new((bm.verts[0], bm.verts[4]))\n" "bm.edges.new((bm.verts[3], bm.verts[1]))\n" "bm.edges.new((bm.verts[3], bm.verts[2]))\n" "bm.edges.new((bm.verts[3], bm.verts[7]))\n" "bm.edges.new((bm.verts[5], bm.verts[1]))\n" "bm.edges.new((bm.verts[5], bm.verts[4]))\n" "bm.edges.new((bm.verts[5], bm.verts[7]))\n" "bm.edges.new((bm.verts[6], bm.verts[2]))\n" "bm.edges.new((bm.verts[6], bm.verts[4]))\n" "bm.edges.new((bm.verts[6], bm.verts[7]))\n", min.vec[0], min.vec[1], min.vec[2], max.vec[0], min.vec[1], min.vec[2], min.vec[0], max.vec[1], min.vec[2], max.vec[0], max.vec[1], min.vec[2], min.vec[0], min.vec[1], max.vec[2], max.vec[0], min.vec[1], max.vec[2], min.vec[0], max.vec[1], max.vec[2], max.vec[0], max.vec[1], max.vec[2]); } void centerView() { *this << "bpy.context.user_preferences.view.smooth_view = 0\n" "for window in bpy.context.window_manager.windows:\n" " screen = window.screen\n" " for area in screen.areas:\n" " if area.type == 'VIEW_3D':\n" " for region in area.regions:\n" " if region.type == 'WINDOW':\n" " override = {'scene': bpy.context.scene, 'window': window, 'screen': screen, 'area': area, 'region': region}\n" " bpy.ops.view3d.view_all(override)\n" " break\n"; } class ANIMOutStream { BlenderConnection* m_parent; unsigned m_curCount = 0; unsigned m_totalCount = 0; bool m_inCurve = false; public: using CurveType = ANIMCurveType; ANIMOutStream(BlenderConnection* parent) : m_parent(parent) { m_parent->_writeLine("PYANIM"); char readBuf[16]; m_parent->_readLine(readBuf, 16); if (strcmp(readBuf, "ANIMREADY")) BlenderLog.report(LogVisor::FatalError, "unable to open ANIMOutStream"); } ~ANIMOutStream() { char tp = -1; m_parent->_writeBuf(&tp, 1); char readBuf[16]; m_parent->_readLine(readBuf, 16); if (strcmp(readBuf, "ANIMDONE")) BlenderLog.report(LogVisor::FatalError, "unable to close ANIMOutStream"); } void changeCurve(CurveType type, unsigned crvIdx, unsigned keyCount) { if (m_curCount != m_totalCount) BlenderLog.report(LogVisor::FatalError, "incomplete ANIMOutStream for change"); m_curCount = 0; m_totalCount = keyCount; char tp = char(type); m_parent->_writeBuf(&tp, 1); struct { uint32_t ci; uint32_t kc; } info = {uint32_t(crvIdx), uint32_t(keyCount)}; m_parent->_writeBuf(reinterpret_cast(&info), 8); m_inCurve = true; } void write(unsigned frame, float val) { if (!m_inCurve) BlenderLog.report(LogVisor::FatalError, "changeCurve not called before write"); if (m_curCount < m_totalCount) { struct { uint32_t frm; float val; } key = {uint32_t(frame), val}; m_parent->_writeBuf(reinterpret_cast(&key), 8); ++m_curCount; } else BlenderLog.report(LogVisor::FatalError, "ANIMOutStream keyCount overflow"); } }; ANIMOutStream beginANIMCurve() { return ANIMOutStream(m_parent); } }; PyOutStream beginPythonOut(bool deleteOnError=false) { if (m_lock) BlenderLog.report(LogVisor::FatalError, "lock already held for BlenderConnection::beginPythonOut()"); return PyOutStream(this, deleteOnError); } class DataStream { friend class BlenderConnection; BlenderConnection* m_parent; DataStream(BlenderConnection* parent) : m_parent(parent) { m_parent->m_lock = true; m_parent->_writeLine("DATABEGIN"); char readBuf[16]; m_parent->_readLine(readBuf, 16); if (strcmp(readBuf, "READY")) BlenderLog.report(LogVisor::FatalError, "unable to open DataStream with blender"); } public: DataStream(const DataStream& other) = delete; DataStream(DataStream&& other) : m_parent(other.m_parent) {other.m_parent = nullptr;} ~DataStream() {close();} void close() { if (m_parent && m_parent->m_lock) { m_parent->_writeLine("DATAEND"); char readBuf[16]; m_parent->_readLine(readBuf, 16); if (strcmp(readBuf, "DONE")) BlenderLog.report(LogVisor::FatalError, "unable to close DataStream with blender"); m_parent->m_lock = false; } } std::vector getMeshList() { m_parent->_writeLine("MESHLIST"); uint32_t count; m_parent->_readBuf(&count, 4); std::vector retval; retval.reserve(count); for (uint32_t i=0 ; i_readLine(name, 128); retval.push_back(name); } return retval; } /* Vector types with integrated stream reading constructor */ struct Vector2f { atVec2f val; Vector2f() = default; void read(BlenderConnection& conn) {conn._readBuf(&val, 8);} Vector2f(BlenderConnection& conn) {read(conn);} operator const atVec2f&() const {return val;} }; struct Vector3f { atVec3f val; Vector3f() = default; void read(BlenderConnection& conn) {conn._readBuf(&val, 12);} Vector3f(BlenderConnection& conn) {read(conn);} operator const atVec3f&() const {return val;} }; struct Vector4f { atVec4f val; Vector4f() = default; void read(BlenderConnection& conn) {conn._readBuf(&val, 16);} Vector4f(BlenderConnection& conn) {read(conn);} operator const atVec4f&() const {return val;} }; struct Index { uint32_t val; Index() = default; void read(BlenderConnection& conn) {conn._readBuf(&val, 4);} Index(BlenderConnection& conn) {read(conn);} operator const uint32_t&() const {return val;} }; /** Intermediate mesh representation prepared by blender from a single mesh object */ struct Mesh { HMDLTopology topology; /* Cumulative AABB */ Vector3f aabbMin; Vector3f aabbMax; /** HECL source and metadata of each material */ struct Material { std::string name; std::string source; std::vector texs; std::unordered_map iprops; Material(BlenderConnection& conn); }; std::vector> materialSets; /* Vertex buffer data */ std::vector pos; std::vector norm; uint32_t colorLayerCount = 0; std::vector color; uint32_t uvLayerCount = 0; std::vector uv; /* Skinning data */ std::vector boneNames; struct SkinBind { uint32_t boneIdx; float weight; SkinBind(BlenderConnection& conn) {conn._readBuf(&boneIdx, 8);} }; std::vector> skins; std::vector contiguousSkinVertCounts; /** Islands of the same material/skinBank are represented here */ struct Surface { Vector3f centroid; Index materialIdx; Vector3f aabbMin; Vector3f aabbMax; Vector3f reflectionNormal; uint32_t skinBankIdx; /** Vertex indexing data (all primitives joined as degenerate tri-strip) */ struct Vert { uint32_t iPos; uint32_t iNorm; uint32_t iColor[4] = {uint32_t(-1)}; uint32_t iUv[8] = {uint32_t(-1)}; uint32_t iSkin; uint32_t iBankSkin = -1; Vert(BlenderConnection& conn, const Mesh& parent); bool operator==(const Vert& other) const { if (iPos != other.iPos) return false; if (iNorm != other.iNorm) return false; for (int i=0 ; i<4 ; ++i) if (iColor[i] != other.iColor[i]) return false; for (int i=0 ; i<8 ; ++i) if (iUv[i] != other.iUv[i]) return false; if (iSkin != other.iSkin) return false; return true; } }; std::vector verts; Surface(BlenderConnection& conn, Mesh& parent, int skinSlotCount); }; std::vector surfaces; struct SkinBanks { struct Bank { std::vector m_skinIdxs; std::vector m_boneIdxs; void addSkins(const Mesh& parent, const std::vector& skinIdxs) { for (uint32_t sidx : skinIdxs) { m_skinIdxs.push_back(sidx); for (const SkinBind& bind : parent.skins[sidx]) { bool found = false; for (uint32_t bidx : m_boneIdxs) { if (bidx == bind.boneIdx) { found = true; break; } } if (!found) m_boneIdxs.push_back(bind.boneIdx); } } } size_t lookupLocalBoneIdx(uint32_t boneIdx) const { for (size_t i=0 ; i banks; std::vector::iterator addSkinBank(int skinSlotCount) { banks.emplace_back(); if (skinSlotCount > 0) banks.back().m_skinIdxs.reserve(skinSlotCount); return banks.end() - 1; } uint32_t addSurface(const Mesh& mesh, const Surface& surf, int skinSlotCount); } skinBanks; using SurfProgFunc = std::function; Mesh(BlenderConnection& conn, HMDLTopology topology, int skinSlotCount, SurfProgFunc& surfProg); Mesh getContiguousSkinningVersion() const; /** Prepares mesh representation for indexed access on modern APIs. * Mesh must remain resident for accessing reference members */ HMDLBuffers getHMDLBuffers() const; }; static const char* MeshOutputModeString(HMDLTopology topology) { static const char* STRS[] = {"TRIANGLES", "TRISTRIPS"}; return STRS[int(topology)]; } /** Compile mesh by context (MESH blends only) */ Mesh compileMesh(HMDLTopology topology, int skinSlotCount=10, Mesh::SurfProgFunc surfProg=[](int){}) { if (m_parent->m_loadedType != BlendType::Mesh) BlenderLog.report(LogVisor::FatalError, _S("%s is not a MESH blend"), m_parent->m_loadedBlend.getAbsolutePath().c_str()); char req[128]; snprintf(req, 128, "MESHCOMPILE %s %d", MeshOutputModeString(topology), skinSlotCount); m_parent->_writeLine(req); char readBuf[256]; m_parent->_readLine(readBuf, 256); if (strcmp(readBuf, "OK")) BlenderLog.report(LogVisor::FatalError, "unable to cook mesh: %s", readBuf); return Mesh(*m_parent, topology, skinSlotCount, surfProg); } /** Compile mesh by name (AREA blends only) */ Mesh compileMesh(const std::string& name, HMDLTopology topology, int skinSlotCount=10, Mesh::SurfProgFunc surfProg=[](int){}) { if (m_parent->m_loadedType != BlendType::Area) BlenderLog.report(LogVisor::FatalError, _S("%s is not an AREA blend"), m_parent->m_loadedBlend.getAbsolutePath().c_str()); char req[128]; snprintf(req, 128, "MESHCOMPILENAME %s %s %d", name.c_str(), MeshOutputModeString(topology), skinSlotCount); m_parent->_writeLine(req); char readBuf[256]; m_parent->_readLine(readBuf, 256); if (strcmp(readBuf, "OK")) BlenderLog.report(LogVisor::FatalError, "unable to cook mesh '%s': %s", name.c_str(), readBuf); return Mesh(*m_parent, topology, skinSlotCount, surfProg); } /** Compile all meshes into one (AREA blends only) */ Mesh compileAllMeshes(HMDLTopology topology, int skinSlotCount=10, float maxOctantLength=5.0, Mesh::SurfProgFunc surfProg=[](int){}) { if (m_parent->m_loadedType != BlendType::Area) BlenderLog.report(LogVisor::FatalError, _S("%s is not an AREA blend"), m_parent->m_loadedBlend.getAbsolutePath().c_str()); char req[128]; snprintf(req, 128, "MESHCOMPILEALL %s %d %f", MeshOutputModeString(topology), skinSlotCount, maxOctantLength); m_parent->_writeLine(req); char readBuf[256]; m_parent->_readLine(readBuf, 256); if (strcmp(readBuf, "OK")) BlenderLog.report(LogVisor::FatalError, "unable to cook all meshes: %s", readBuf); return Mesh(*m_parent, topology, skinSlotCount, surfProg); } /** Intermediate actor representation prepared by blender from a single HECL actor blend */ struct Actor { struct Armature { std::string name; struct Bone { std::string name; Vector3f origin; int32_t parent = -1; std::vector children; Bone(BlenderConnection& conn); }; std::vector bones; Bone* lookupBone(const char* name) { for (Bone& b : bones) if (!b.name.compare(name)) return &b; return nullptr; } Armature(BlenderConnection& conn); }; std::vector armatures; struct Subtype { std::string name; ProjectPath mesh; int32_t armature = -1; std::vector> overlayMeshes; Subtype(BlenderConnection& conn); }; std::vector subtypes; struct Action { std::string name; float interval; bool additive; std::vector frames; struct Channel { std::string boneName; uint32_t attrMask; struct Key { Vector4f rotation; Vector3f position; Vector3f scale; Key(BlenderConnection& conn, uint32_t attrMask); }; std::vector keys; Channel(BlenderConnection& conn); }; std::vector channels; std::vector> subtypeAABBs; Action(BlenderConnection& conn); }; std::vector actions; Actor(BlenderConnection& conn); }; Actor compileActor() { if (m_parent->m_loadedType != BlendType::Actor) BlenderLog.report(LogVisor::FatalError, _S("%s is not an ACTOR blend"), m_parent->m_loadedBlend.getAbsolutePath().c_str()); m_parent->_writeLine("ACTORCOMPILE"); char readBuf[256]; m_parent->_readLine(readBuf, 256); if (strcmp(readBuf, "OK")) BlenderLog.report(LogVisor::FatalError, "unable to compile actor: %s", readBuf); return Actor(*m_parent); } }; DataStream beginData() { if (m_lock) BlenderLog.report(LogVisor::FatalError, "lock already held for BlenderConnection::beginDataIn()"); return DataStream(this); } void quitBlender(); static BlenderConnection& SharedConnection() { if (!SharedBlenderConnection) SharedBlenderConnection = new BlenderConnection(HECL::VerbosityLevel); return *SharedBlenderConnection; } void closeStream() { if (m_lock) deleteBlend(); } static void Shutdown() { if (SharedBlenderConnection) { SharedBlenderConnection->closeStream(); SharedBlenderConnection->quitBlender(); delete SharedBlenderConnection; SharedBlenderConnection = nullptr; BlenderLog.report(LogVisor::Info, "BlenderConnection Shutdown Successful"); } } }; class HMDLBuffers { public: struct Surface; private: friend struct BlenderConnection::DataStream::Mesh; HMDLBuffers(HMDLMeta&& meta, size_t vboSz, const std::vector& iboData, std::vector&& surfaces, const BlenderConnection::DataStream::Mesh::SkinBanks& skinBanks) : m_meta(std::move(meta)), m_vboSz(vboSz), m_vboData(new uint8_t[vboSz]), m_iboSz(iboData.size()*4), m_iboData(new uint8_t[iboData.size()*4]), m_surfaces(std::move(surfaces)), m_skinBanks(skinBanks) { { Athena::io::MemoryWriter w(m_iboData.get(), m_iboSz); w.enumerateLittle(iboData); } } public: HMDLMeta m_meta; size_t m_vboSz; std::unique_ptr m_vboData; size_t m_iboSz; std::unique_ptr m_iboData; struct Surface { Surface(const BlenderConnection::DataStream::Mesh::Surface& origSurf, atUint32 start, atUint32 count) : m_origSurf(origSurf), m_start(start), m_count(count) {} const BlenderConnection::DataStream::Mesh::Surface& m_origSurf; atUint32 m_start; atUint32 m_count; }; std::vector m_surfaces; const BlenderConnection::DataStream::Mesh::SkinBanks& m_skinBanks; }; } #endif // BLENDERCONNECTION_HPP