fix: purge dm_ prefix remnants

* fix: purge dm_ prefix remnants in favor of datamachine_

* fix: align migration scaffolding assignments

Author: chubes4

inc/Abilities/Email/EmailAbilities.php

@@ -1334,7 +1334,7 @@ private function saveToSentFolder( array $to, string $subject, string $body, arr
 		 *
 		 * @param string $from The derived From address.
 		 */
-		$from   = apply_filters( 'dm_email_sent_folder_from', $from );
+		$from   = apply_filters( 'datamachine_email_sent_folder_from', $from );
 		$to_str = implode( ', ', $to );
 		$date   = gmdate( 'r' );
 

inc/Abilities/Engine/RunFlowAbility.php

@@ -502,7 +502,7 @@ private static function backpressureDeferSeconds( int $flow_id ): int {
 
 		// Deterministic jitter in [0, base) spreads deferred flows across the
 		// window instead of waking them all at base seconds.
-		$jitter = absint( crc32( 'dm_backpressure_' . $flow_id ) ) % $base;
+		$jitter = absint( crc32( 'datamachine_backpressure_' . $flow_id ) ) % $base;
 
 		return $base + $jitter;
 	}

inc/Abilities/Flow/WebhookTriggerAbility.php

@@ -878,7 +878,7 @@ public function executeSetRateLimit( array $input ): array {
 		}
 
 		// Clear any existing rate limit counter so new config takes effect immediately.
-		delete_transient( 'dm_webhook_rate_' . $flow_id );
+		delete_transient( \DataMachine\Api\WebhookTrigger::rate_limit_transient_key( $flow_id ) );
 
 		$effective_max    = $rate_config['max'] ?? \DataMachine\Api\WebhookTrigger::DEFAULT_RATE_LIMIT_MAX;
 		$effective_window = $rate_config['window'] ?? \DataMachine\Api\WebhookTrigger::DEFAULT_RATE_LIMIT_WINDOW;

inc/Abilities/Media/GDRenderer.php

@@ -787,7 +787,7 @@ public function save_temp( string $format = 'png', int $quality = -1 ): ?string
 			return null;
 		}
 
-		$temp_file = tempnam( sys_get_temp_dir(), 'dm_img_' );
+		$temp_file = tempnam( sys_get_temp_dir(), 'datamachine_img_' );
 		$ext       = 'jpeg' === $format ? '.jpg' : '.png';
 		$path      = $temp_file . $ext;
 

inc/Api/WebhookTrigger.php

@@ -518,7 +518,7 @@ private static function check_rate_limit( int $flow_id, array $scheduling_config
 			return null;
 		}
 
-		$transient_key = 'dm_webhook_rate_' . $flow_id;
+		$transient_key = self::rate_limit_transient_key( $flow_id );
 		$current_count = (int) get_transient( $transient_key );
 
 		if ( $current_count >= $max ) {
@@ -568,6 +568,16 @@ function ( $result ) use ( $window ) {
 		return null;
 	}
 
+	/**
+	 * Build the per-flow rate-limit transient key.
+	 *
+	 * @param int $flow_id Flow ID.
+	 * @return string Transient key.
+	 */
+	public static function rate_limit_transient_key( int $flow_id ): string {
+		return 'datamachine_webhook_rate_' . $flow_id;
+	}
+
 	/**
 	 * Extract Bearer token from Authorization header.
 	 *

inc/Engine/Tasks/RecurringScheduler.php

@@ -527,7 +527,7 @@ public static function calculateStaggerOffset( int $seed, int $interval_seconds
 		if ( $max_offset <= 0 ) {
 			return 0;
 		}
-		return absint( crc32( 'dm_stagger_' . $seed ) ) % $max_offset;
+		return absint( crc32( 'datamachine_stagger_' . $seed ) ) % $max_offset;
 	}
 
 	/**

inc/Engine/Tasks/TaskScheduler.php

@@ -375,7 +375,7 @@ public static function scheduleBatch( string $taskType, array $itemParams, array
 		// so the chain caller → batch_parent is preserved even though
 		// per-item children chain off the caller directly (below).
 		$jobs_db           = new Jobs();
-		$batch_id          = 'dm_batch_' . wp_generate_uuid4();
+		$batch_id          = 'datamachine_batch_' . wp_generate_uuid4();
 		$batch_create_args = array(
 			'pipeline_id' => 'direct',
 			'flow_id'     => 'direct',

inc/migrations/scaffolding.php

@@ -92,10 +92,10 @@ function datamachine_get_scaffold_defaults( string $agent_name = '' ): array {
 	$admin_name  = $admin_user ? $admin_user->display_name : '';
 
 	// --- Versions ---
-	$wp_version  = get_bloginfo( 'version' );
-	$php_version = PHP_MAJOR_VERSION . '.' . PHP_MINOR_VERSION . '.' . PHP_RELEASE_VERSION;
-	$dm_version  = defined( 'DATAMACHINE_VERSION' ) ? DATAMACHINE_VERSION : 'unknown';
-	$created     = wp_date( 'Y-m-d' );
+	$wp_version          = get_bloginfo( 'version' );
+	$php_version         = PHP_MAJOR_VERSION . '.' . PHP_MINOR_VERSION . '.' . PHP_RELEASE_VERSION;
+	$datamachine_version = defined( 'DATAMACHINE_VERSION' ) ? DATAMACHINE_VERSION : 'unknown';
+	$created             = wp_date( 'Y-m-d' );
 
 	// --- Build SOUL.md context lines ---
 	$context_items   = array();
@@ -187,7 +187,7 @@ function datamachine_get_scaffold_defaults( string $agent_name = '' ): array {
 			'This file tracks persistent knowledge. Keep it lean — persistent facts only, not session logs.',
 			'',
 			'## State',
-			"- Data Machine v{$dm_version} activated on {$created}",
+			"- Data Machine v{$datamachine_version} activated on {$created}",
 			"- WordPress {$wp_version}, PHP {$php_version}",
 			'',
 			'## Lessons Learned',

tests/Unit/Abilities/Engine/PipelineBatchSchedulerTest.php

@@ -165,7 +165,7 @@ public function test_fanout_stores_batch_state_in_engine_data(): void {
 		$this->assertEquals( 'step_abc_123', $parent_engine['next_flow_step_id'] );
 
 		// No transient should exist.
-		$this->assertFalse( get_transient( 'dm_pipeline_batch_' . $parent_id ) );
+		$this->assertFalse( get_transient( 'datamachine_pipeline_batch_' . $parent_id ) );
 	}
 
 	/**

tests/Unit/Abilities/TaxonomyAbilityWpErrorTest.php

@@ -16,7 +16,7 @@
 
 class TaxonomyAbilityWpErrorTest extends WP_UnitTestCase {
 
-	private const TEST_TAXONOMY = 'dm_wp_error_terms';
+	private const TEST_TAXONOMY = 'datamachine_wp_error_terms';
 
 	public function set_up(): void {
 		parent::set_up();
@@ -80,7 +80,7 @@ public function test_merge_term_meta_callback_failure_returns_wp_error(): void {
 				'term_id'   => 0,
 				'taxonomy'  => self::TEST_TAXONOMY,
 				'data'      => array( 'name' => 'Charleston' ),
-				'field_map' => array( 'name' => 'dm_name' ),
+				'field_map' => array( 'name' => 'datamachine_name' ),
 			)
 		);
 
@@ -94,7 +94,7 @@ public function test_merge_term_meta_static_helper_preserves_legacy_failure_arra
 			0,
 			self::TEST_TAXONOMY,
 			array( 'name' => 'Charleston' ),
-			array( 'name' => 'dm_name' )
+			array( 'name' => 'datamachine_name' )
 		);
 
 		$this->assertIsArray( $result );