#include "externals.hh" #include "globals.hh" #include "sync.hh" #include "syncedit.hh" #include "undo.hh" #include #include #include #include using ebcl::T_SRDParserConfig; namespace { const std::map< std::string , T_SyncSegment::E_SegmentType > SegmentTypes_( ([] { std::map< std::string , T_SyncSegment::E_SegmentType > t; t.emplace( "linear" , T_SyncSegment::LINEAR ); t.emplace( "ramp" , T_SyncSegment::RAMP ); t.emplace( "smooth" , T_SyncSegment::SMOOTH ); return t; })()); } /*= SRD parser for the curves ================================================*/ namespace { struct T_ParserOutput_ { T_SyncCurves curves; T_Optional< T_SyncTime > time; ebcl::T_SRDLocation tLocation; }; using namespace ebcl; bool CPEnterCurve_( T_SRDParserData const& data ) { *( data.targetData ) = T_SyncCurve{ (*data.input)[ 0 ].stringValue( ) }; return true; } bool CPExitCurve_( T_SRDParserData const& data ) { auto& curve( data.currentData->value< T_SyncCurve >( ) ); auto& po( *( data.targetData->value< T_SharedPtr< T_ParserOutput_ > >( ) ) ); if ( curve.segments.empty( ) ) { T_StringBuilder sb; sb << "curve '" << curve.name << "' is empty"; data.errors.add( std::move( sb ) , (*data.input)[ 0 ] ); } if ( po.curves.curves.contains( curve.name ) ) { T_StringBuilder sb; sb << "duplicate curve '" << curve.name << "'"; data.errors.add( std::move( sb ) , (*data.input)[ 0 ] ); } else { po.curves.setCurve( std::move( curve ) ); } return true; } void CPHandleSegment_( const T_SyncSegment::E_SegmentType type , T_SRDList const& lValues , T_SRDList const& lDurations , T_SRDErrors& errors , T_SyncCurve& curve ) { bool failed = false; if ( lDurations.size( ) != lValues.size( ) - 1 ) { errors.add( "values / durations count mismatch" , lValues[ 0 ] ); failed = true; } // Check durations const auto nd( lDurations.size( ) ); for ( auto i = 1u ; i < nd ; i ++ ) { auto const& tok( lDurations[ i ] ); const uint64_t v( tok.longValue( ) ); if ( v < 1 || v > UINT32_MAX ) { errors.add( "invalid duration" , tok ); failed = true; } } if ( !failed ) { T_SyncSegment& segment( curve.segments.addNew( ) ); segment.type = type; segment.durations.ensureCapacity( nd - 1 ); for ( auto i = 1u ; i < nd ; i ++ ) { auto const& tok( lDurations[ i ] ); segment.durations.add( uint32_t( tok.longValue( ) ) ); } segment.values.ensureCapacity( nd ); for ( auto i = 1u ; i <= nd ; i ++ ) { auto const& tok( lValues[ i ] ); segment.values.add( tok.floatValue( ) ); } } } bool CPSegmentVD_( T_SRDParserData const& data ) { auto const& input( *data.input ); const auto ev( data.config.enumValue( "segment-type" , input[ 1 ].stringValue( ) ) ); assert( ev ); CPHandleSegment_( (T_SyncSegment::E_SegmentType) *ev , input[ 2 ].list( ) , input[ 3 ].list( ) , data.errors , data.targetData->value< T_SyncCurve >( ) ); return true; } bool CPSegmentDV_( T_SRDParserData const& data ) { auto const& input( *data.input ); const auto ev( data.config.enumValue( "segment-type" , input[ 1 ].stringValue( ) ) ); assert( ev ); CPHandleSegment_( (T_SyncSegment::E_SegmentType) *ev , input[ 3 ].list( ) , input[ 2 ].list( ) , data.errors , data.targetData->value< T_SyncCurve >( ) ); return true; } bool CPSetDuration_( T_SRDParserData const& data ) { auto const& input( *data.input ); auto& po( *( data.currentData->value< T_SharedPtr< T_ParserOutput_ > >( ) ) ); if ( po.time ) { T_StringBuilder eb; eb << "duplicate duration specification; previous: " << po.tLocation; data.errors.add( std::move( eb ) , input[ 0 ].location( ) ); } else { po.time = T_SyncTime( ); po.time->uDuration = std::min( 2. , std::max( 1. / 60. , input[ 1 ].floatValue( ) ) ); po.time->iDuration = std::max( 1l , input[ 2 ].longValue( ) ); } return true; } T_SRDParserConfig MakeCurvesParser_( ) { using namespace ebcl::SRD; T_SRDParserDefs defs( "default" ); defs << OnStart( []( T_SRDParserData const& data ) -> bool { *( data.currentData ) = NewShared< T_ParserOutput_ >( ); return true; } ); defs.enumeration( "segment-type" ) << "linear" << "ramp" << "smooth"; defs.context( "default" ) << ( Rule( ) << Text( ) << EnterContext( "segments" ) << OnEnter( CPEnterCurve_ ) << OnExit( CPExitCurve_ ) ) << ( Rule( ) << "duration" << Float( ) << Int32( ) << CPSetDuration_ ); defs.context( "segments" ) << ( Rule( ) << "segment" << Enum( "segment-type" ) << ( List( ) << "values" << ( AtLeast( 2 ) << Numeric( ) ) ) << ( List( ) << "durations" << ( AtLeast( 1 ) << Integer( ) ) ) << CPSegmentVD_ ) << ( Rule( ) << "segment" << Enum( "segment-type" ) << ( List( ) << "durations" << ( AtLeast( 1 ) << Integer( ) ) ) << ( List( ) << "values" << ( AtLeast( 2 ) << Numeric( ) ) ) << CPSegmentDV_ ); return defs; } } /*= T_SyncTime ===============================================================*/ void T_SyncTime::setDuration( const float uDuration , const uint32_t iDuration ) { this->uDuration = std::max( 1e-3f , uDuration ); this->iDuration = std::max( 1u , iDuration ); time = std::min( time , duration( ) ); } /*= T_SyncCurves =============================================================*/ int32_t T_SyncCurves::indexOf( T_String const& name ) noexcept { const auto idx( curves.indexOf( name ) ); return idx == ebcl::T_HashIndex::INVALID_INDEX ? -1 : int32_t( idx ); } /*= T_SyncCurveCache =========================================================*/ T_SyncCurveCache::T_SyncCurveCache( T_SyncTime const& time , T_SyncCurves const& curves , const uint32_t curve ) noexcept : curve( curve ) , curPos( 0 ) { auto const& c( curves.curves[ curve ] ); const auto ns( c.segments.size( ) ); assert( ns > 0 ); uint32_t s = 0; for ( auto i = 0u ; i < ns ; i ++ ) { auto const& v( c.segments[ i ] ); assert( v.durations.size( ) == v.values.size( ) - 1 ); const auto nd( v.durations.size( ) ); for ( auto j = 0u ; j < nd ; j ++ ) { const auto sStart( s * time.uDuration ); if ( time.time >= sStart ) { curPos = segStarts.size( ); } segStarts.add( sStart ); segRefs.add( std::make_pair( i , j ) ); s += v.durations[ j ]; segEnds.add( std::min( s , time.iDuration ) * time.uDuration ); if ( s > time.iDuration ) { return; } } } } /*----------------------------------------------------------------------------*/ uint32_t T_SyncCurveCache::findSegment( const float time ) const noexcept { const auto ns( segStarts.size( ) ); for ( auto i = 0u ; i < ns ; i ++ ) { if ( segStarts[ i ] <= time && segEnds[ i ] > time ) { return i; } } return ns; } /*----------------------------------------------------------------------------*/ float T_SyncCurveCache::valueAt( T_SyncTime const& time , T_SyncCurves const& curves , const float position ) const noexcept { return segmentValue( time.time , findSegment( position ) , curves.curves[ curve ].segments ); } float T_SyncCurveCache::value( T_SyncTime const& time , T_SyncCurves const& curves ) noexcept { const auto t( time.time ); // Check / update curPos const float ss0( curPos == segStarts.size( ) ? time.duration( ) : segStarts[ curPos ] ); if ( ss0 > t ) { curPos = findSegment( t ); } else { while ( curPos < segStarts.size( ) && t >= segEnds[ curPos ] ) { curPos ++; } } // We got the actual index in curPos, now compute the value. return segmentValue( t , curPos , curves.curves[ curve ].segments ); } /*----------------------------------------------------------------------------*/ float T_SyncCurveCache::segmentValue( float time , uint32_t segIndex , T_Array< T_SyncSegment > const& segments ) const noexcept { const auto sss( segStarts.size( ) ); if ( segIndex >= sss ) { assert( sss != 0 ); segIndex = sss - 1; time = segEnds[ segIndex ]; } auto const& idxp( segRefs[ segIndex ] ); auto const& seg( segments[ idxp.first ] ); // Interpolation factor const float st( segStarts[ segIndex ] ); const float et( segEnds[ segIndex ] ); const float v0 = ( time - st ) / ( et - st ); float v = v0; if ( seg.type != T_SyncSegment::LINEAR ) { v *= v0; if ( seg.type == T_SyncSegment::SMOOTH ) { v *= 3 - 2 * v0; } } const auto pid( idxp.second ); const float sv( seg.values[ pid ] ); const float ev( seg.values[ pid + 1 ] ); #if 0 printf( "[%.2f] gidx %d - seg %d idx %d - %f\n" , time , segIndex , idxp.first , idxp.second , v * ( ev - sv ) + sv ); #endif return v * ( ev - sv ) + sv; } /*= T_SyncValues =============================================================*/ T_SyncValues::T_SyncValues( ) { values.add( 0 ); } // --------------------------------------------------------------------- void T_SyncValues::clear( ) { index.clear( ); identifiers.clear( ); values.clear( ); overriden.clear( ); values.add( 0 ); } bool T_SyncValues::addValue( T_String const& name , const float initial ) noexcept { const uint32_t hash{ ComputeHash( name ) }; uint32_t existing{ index.first( hash ) }; while ( existing != T_HashIndex::INVALID_INDEX ) { if ( name == identifiers[ existing ] ) { return false; } existing = index.next( existing ); } const auto li( values.size( ) ); index.add( hash ); identifiers.add( name ); values.add( initial ); std::swap( values[ li ] , values[ li - 1 ] ); overriden.add( false ); return true; } uint32_t T_SyncValues::indexOf( T_String const& name ) const noexcept { const uint32_t hash{ ComputeHash( name ) }; uint32_t existing{ index.first( hash ) }; while ( existing != T_HashIndex::INVALID_INDEX ) { if ( name == identifiers[ existing ] ) { return existing; } existing = index.next( existing ); } return values.size( ) - 1; } /*= A_SyncOverride ===========================================================*/ A_SyncOverride::A_SyncOverride( char const* const type , T_String const& title ) noexcept : type_( T_String::Pooled( type ) ) , title_( title.size( ) + 1 ) { char const* src( title.data( ) ); for ( auto i = 0u ; i < title_.size( ) - 1 ; i ++ ) { title_[ i ] = src[ i ]; } title_[ title_.size( ) - 1 ] = 0; } A_SyncOverride::~A_SyncOverride( ) { } void A_SyncOverride::setup( ) noexcept { const auto ni( inputs_.size( ) ); assert( ni != 0 ); assert( inputPos_.size( ) == 0 ); T_StringBuilder sb; inputPos_.ensureCapacity( ni ); for ( auto i = 0u ; i < ni ; i ++ ) { // FIXME: insufficient; the manager should be made aware of // the presence of an override for that value (and it should // fail for missing values). inputPos_.add( Globals::Sync( ).inputPos( inputs_[ i ] ) ); if ( sb.size( ) ) { sb << ';'; } sb << inputs_[ i ]; } id_ = std::move( sb ); } char const* A_SyncOverride::buildLabel( uint32_t& counter , T_StringBuilder& sb ) noexcept { sb.clear( ) << "temp label " << counter << '\0'; counter ++; return sb.data( ); } void A_SyncOverride::makeUI( uint32_t& counter , T_StringBuilder& sb ) noexcept { using namespace ImGui; if ( Checkbox( &title_[ 0 ] , &enabled_ ) ) { Globals::Sync( ).setOverridesActive( enabled_ , inputPos_.size( ) , &inputPos_[ 0 ] ); } if ( !enabled_ ) { PushItemFlag( ImGuiItemFlags_Disabled , true ); PushStyleVar( ImGuiStyleVar_Alpha , GetStyle( ).Alpha * 0.5f ); } Indent( ); PushItemWidth( -1 ); makeEditWidgets( counter , sb ); PopItemWidth( ); Unindent( ); if ( !enabled_ ) { PopItemFlag( ); PopStyleVar( ); } } /*= T_SyncOverrideSection ====================================================*/ T_SyncOverrideSection::T_SyncOverrideSection( T_String title ) noexcept : title( std::move( title ) ) , cTitle( this->title.toOSString( ) ) { } void T_SyncOverrideSection::merge( T_SyncOverrideSection& other ) noexcept { for ( auto& os : other.subsections ) { section( os->title ).merge( *os ); } for ( auto& ov : other.overrides ) { overrides.add( ov->clone( ) ); } } void T_SyncOverrideSection::makeUI( uint32_t& counter , T_StringBuilder& tempSb , const bool topLevel ) noexcept { const bool display( topLevel ? ImGui::CollapsingHeader( &cTitle[ 0 ] ) : ImGui::TreeNode( &cTitle[ 0 ] ) ); if ( !display ) { return; } for ( auto& os : subsections ) { os->makeUI( counter , tempSb ); } if ( subsections.size( ) && overrides.size( ) ) { ImGui::Separator( ); } for ( auto& ov : overrides ) { ov->makeUI( counter , tempSb ); } if ( !topLevel ) { ImGui::TreePop( ); } } T_SyncOverrideSection& T_SyncOverrideSection::section( T_String const& name ) noexcept { for ( auto& ov : subsections ) { if ( ov->title == name ) { return *ov; } } return *subsections[ subsections.add( NewOwned< T_SyncOverrideSection >( name ) ) ]; } T_SyncOverrideSection const* T_SyncOverrideSection::section( T_String const& name ) const noexcept { for ( auto& ov : subsections ) { if ( ov->title == name ) { return ov.get( ); } } return nullptr; } /*= T_SyncOverrideVisitor ====================================================*/ T_SyncOverrideVisitor::T_OpElement T_SyncOverrideVisitor::nodeBrowser( const T_Element element , const uint32_t child ) { if ( element.hasType< A_SyncOverride* >( ) ) { return {}; } auto& section( *element.value< T_SyncOverrideSection* >( ) ); const auto nss( section.subsections.size( ) ); if ( child < nss ) { return T_OpElement{ section.subsections[ child ].get( ) }; } if ( child - nss < section.overrides.size( ) ) { return T_OpElement{ section.overrides[ child - nss ].get( ) }; } return {}; } /*= T_SyncManager ============================================================*/ T_SyncManager::T_SyncManager( ) : pConfig_( MakeCurvesParser_( ) ) , watcher_{ Globals::Watcher( ) , [this](){ curvesChanged_( ); } } , soRoot_( "*root*" ) { watcher_.watch( "curves.srd" ); loadCurves( false ); } /*----------------------------------------------------------------------------*/ void T_SyncManager::setDuration( const float uDuration , const uint32_t iDuration ) { time_.setDuration( uDuration , iDuration ); updateCurveCaches( ); } void T_SyncManager::setTime( const float time ) { time_.setTime( time ); updateValues( ); } void T_SyncManager::updateTime( ) noexcept { if ( playing_ ) { const float time( SDL_GetTicks( ) * 1e-3 ); if ( playingPrevious_ ) { timeDelta( time - lastFrame_ ); playing_ = !finished( ); } lastFrame_ = time; } playingPrevious_ = playing_; } /*----------------------------------------------------------------------------*/ void T_SyncManager::clearInputs( ) noexcept { clearOverrides( ); values_.clear( ); } /*----------------------------------------------------------------------------*/ void T_SyncManager::clearCurves( ) { curves_.clear( ); updateCurveCaches( ); modified_ = true; } void T_SyncManager::setCurve( T_SyncCurve curve ) { curves_.setCurve( curve ); updateCurveCaches( ); modified_ = true; } void T_SyncManager::removeCurve( T_String const& curve ) noexcept { if ( curves_.removeCurve( curve ) ) { updateCurveCaches( ); modified_ = true; } } T_SyncCurve const* T_SyncManager::getCurve( T_String const& name ) const noexcept { return curves_.curves.get( name ); } void T_SyncManager::curvesChanged_( ) { if ( modified_ ) { fileChanged_ = true; } else { loadCurves( ); } } bool T_SyncManager::loadCurves( const bool undoable ) { printf( "Loading curves data\n" ); T_SharedPtr< T_ParserOutput_ > p; try { using namespace ebcl; const T_SRDParserConfig cfg( MakeCurvesParser_( ) ); T_File file( "curves.srd" , E_FileMode::READ_ONLY ); file.open( ); T_FileInputStream fis( file ); T_SRDParser parser( cfg ); T_SRDTextReader reader( parser ); reader.read( "curves.srd" , fis ); p = parser.getData< T_SharedPtr< T_ParserOutput_ > >( ); } catch ( ebcl::X_StreamError const& e ) { printf( "... ERR %s\n" , e.what( ) ); return false; } catch ( ebcl::X_SRDErrors const& e ) { T_StringBuilder sb; auto const ne( e.errors.size( ) ); for ( auto i = 0u ; i < ne ; i ++ ) { auto const& err( e.errors[ i ] ); sb << "... ERR " << err.location( ) << ": " << err.error( ) << '\n'; } sb << '\0'; printf( "%s" , sb.data( ) ); return false; } printf( "... success\n" ); assert( p ); if ( undoable ) { addReloadUndoData_( (void*)(T_ParserOutput_*) p ); } curves_ = std::move( p->curves ); if ( p->time ) { time_.iDuration = p->time->iDuration; time_.uDuration = p->time->uDuration; } else { time_.iDuration = 3600; time_.uDuration = 1.f / 60.f; } updateCurveCaches( ); modified_ = fileChanged_ = false; return true; } void T_SyncManager::addReloadUndoData_( void* const data ) const noexcept { T_ParserOutput_& p{ *(T_ParserOutput_*)data }; auto& undo{ Globals::Undo( ).add< T_UndoDurationChanges >( p.time ? p.time->iDuration : 3600 , time_.iDuration , p.time ? p.time->uDuration : ( 1.f / 60.f ) , time_.uDuration ) }; auto& nCurves{ p.curves.curves }; for ( auto const& curve : curves_.curves.values( ) ) { auto const* const nc{ nCurves.get( curve.name ) }; if ( nc ) { undo.curveReplacement( curve , *nc ); } else { undo.curveDeletion( curve ); } } for ( auto const& nc : nCurves.values( ) ) { if ( !curves_.curves.contains( nc.name ) ) { undo.curveCreation( nc ); } } } /*----------------------------------------------------------------------------*/ void T_SyncManager::updateCurveCaches( ) { curveCaches_.clear( ); const uint32_t nv( values_.identifiers.size( ) ); for ( auto i = 0u ; i < nv ; i ++ ) { auto const& id( values_.identifiers[ i ] ); const auto cp( curves_.indexOf( id ) ); if ( cp < 0 ) { curveCaches_.addNew( ); } else { curveCaches_.add( NewOwned< T_SyncCurveCache >( time_ , curves_ , cp ) ); } } updateValues( ); } void T_SyncManager::updateValues( ) { const auto nv( values_.identifiers.size( ) ); assert( nv == curveCaches_.size( ) ); for ( auto i = 0u ; i < nv ; i ++ ) { auto const& cc( curveCaches_[ i ] ); if ( !cc || values_.overriden[ i ] ) { continue; } values_.values[ i ] = cc->value( time_ , curves_ ); } } /*----------------------------------------------------------------------------*/ void T_SyncManager::clearOverrides( ) noexcept { mouseDelegate_ = nullptr; soRoot_.subsections.clear( ); soRoot_.overrides.clear( ); soTable_.clear( ); } void T_SyncManager::mergeOverrides( T_SyncOverrideSection& overrides ) { assert( overrides.overrides.empty( ) ); soRoot_.merge( overrides ); soVisitor_.visitor.visit( &soRoot_ , [this]( T_SyncOverrideVisitor::T_Element node , bool exit ) -> bool { if ( exit || node.hasType< T_SyncOverrideSection* >( ) ) { return true; } auto& ovr( *node.value< A_SyncOverride* >( ) ); ovr.setup( ); soTable_.add( ovr.id( ) , &ovr ); return false; } ); } bool T_SyncManager::overrideExists( T_String const& id ) const noexcept { return soTable_.contains( id ); } A_SyncOverride* T_SyncManager::getOverride( T_String const& id ) const noexcept { const auto rv{ soTable_.get( id ) }; return rv ? *rv : nullptr; } void T_SyncManager::setOverridesActive( const bool active , const uint32_t n , uint32_t const* const pos ) { for ( auto i = 0u ; i < n ; i ++ ) { assert( values_.overriden[ pos[ i ] ] != active ); values_.overriden[ pos[ i ] ] = active; } if ( !active ) { for ( auto i = 0u ; i < n ; i ++ ) { const auto p{ pos[ i ] }; auto const& cc( curveCaches_[ p ] ); if ( cc ) { values_.values[ p ] = cc->value( time_ , curves_ ); } } } } void T_SyncManager::visitOverrides( T_SyncOverrideVisitor::F_NodeAction visitor ) { soVisitor_.visitor.visit( &soRoot_ , visitor ); } /*------------------------------------------------------------------------------*/ void T_SyncManager::makeOverridesWindow( ) { if ( !ovWindow_ ) { return; } using namespace ImGui; auto const& dspSize( GetIO( ).DisplaySize ); SetNextWindowSize( ImVec2( dspSize.x * .25f , dspSize.y * .66f - 20 ) , ImGuiSetCond_Appearing ); SetNextWindowPos( ImVec2( 0 , 20 ) , ImGuiSetCond_Appearing ); Begin( "Input overrides" , &ovWindow_ , ImGuiWindowFlags_NoCollapse ); if ( soRoot_.subsections.empty( ) ) { Text( "No overrides have been defined." ); } else { T_StringBuilder temp; uint32_t counter{ 0 }; for ( auto& section : soRoot_.subsections ) { section->makeUI( counter , temp , true ); } } End( ); } /*------------------------------------------------------------------------------*/ void T_SyncManager::handleDragAndDrop( ImVec2 const& move , T_KeyboardModifiers modifiers , T_MouseButtons buttons ) noexcept { if ( mouseDelegate_ ) { mouseDelegate_->handleDragAndDrop( move , modifiers , buttons ); } } void T_SyncManager::handleWheel( const float wheel , T_KeyboardModifiers modifiers , T_MouseButtons buttons ) noexcept { if ( mouseDelegate_ ) { mouseDelegate_->handleWheel( wheel , modifiers , buttons ); } }