PluginProbe
MLSImport: IDX Plugin & MLS Plugin for Real Estate Listings / 7.2.1
MLSImport: IDX Plugin & MLS Plugin for Real Estate Listings v7.2.1
7.2.1 7.2 7.1.2 7.1.1 7.1 7.0.4 7.0.6 7.0.7 6.3.8 6.3.7 6.3.6 6.3.5 6.3.4 6.3.3 6.3.1 trunk 5.7.3 5.7.5 5.8.1 5.8.2 5.8.3 5.8.4 5.8.6 6.0.4 6.0.5 All 36 releases
← All changes | mlsimport.php +546 -114 6.3.8 → 7.2.1 View file →
@@ -2,9 +2,9 @@
2 2 /**
3 3 * Plugin Name: MlsImport
4 4 * Plugin URI: https://mlsimport.com/
5 5 * Description: MLS Import - The MLSImport plugin facilitates the connection to your real estate MLS database, allowing you to download and synchronize real estate property data from the MLS.
6 - * Version: 6.3.8
6 + * Version: 7.2.1
7 7 * Requires at least: 5.2
8 8 * Requires PHP: 7.4
9 9 * License: GPLv3
10 10 * License URI: https://www.gnu.org/licenses/gpl-3.0.html
@@ -12,8 +12,27 @@
12 12 * Text Domain: mlsimport
13 13 * Domain Path: /languages
14 14 */
15 15
16 +/*
17 + * ---------------------------------------------------------------------------
18 + * FILE ROLE: main plugin bootstrap.
19 + * ---------------------------------------------------------------------------
20 + * Responsibilities of this file, in load order:
21 + * 1. Define global constants (version, API endpoint, paths, cron batch size).
22 + * 2. Register activation/deactivation hooks and one-time upgrade notices.
23 + * 3. Track the installed version and flag upgrade modals.
24 + * 4. require_once every plugin PHP file (core, API client, theme/provider
25 + * adapters, onboarding, telemetry, and the whole standalone/ module).
26 + * 5. Wire the standalone (theme_id 990) init/enqueue/template hooks.
27 + * 6. Schedule the WP-Cron events (hourly import, daily reconciliation, daily
28 + * telemetry) and define their handler functions.
29 + * 7. Instantiate the core Mlsimport class and call run() to register hooks.
30 + * 8. Define assorted global helper functions (logging, dropdowns, onboarding
31 + * AJAX save handlers).
32 + * ---------------------------------------------------------------------------
33 + */
34 +
16 35 // If this file is called directly, abort.
17 36
18 37 if ( ! defined( 'WPINC' ) ) {
19 38 die;
@@ -19,16 +38,24 @@
19 38 die;
20 39 }
21 40
22 41
23 -define( 'MLSIMPORT_VERSION', '6.3.8');
42 +// Current plugin version (kept in sync with the header above and the readme).
43 +define( 'MLSIMPORT_VERSION', '7.2.1');
44 +// Marketing/portal host used to build sign-up and affiliate links.
24 45 define( 'MLSIMPORT_CLUBLINK', 'mlsimport.com' );
46 +// Scheme for the portal host links.
25 47 define( 'MLSIMPORT_CLUBLINKSSL', 'https' );
48 +// Default per-request import batch size (listings pulled per cron step).
26 49 define( 'MLSIMPORT_CRON_STEP', 20 );
50 +// Absolute filesystem path to this plugin directory (trailing slash).
27 51 define( 'MLSIMPORT_PLUGIN_PATH', plugin_dir_path( __FILE__ ) );
52 +// Public URL to this plugin directory (trailing slash).
28 53 define( 'MLSIMPORT_PLUGIN_URL', plugin_dir_url( __FILE__ ) );
29 54
30 55
56 +// SaaS API base URL (AWS API Gateway). The two commented lines are the legacy
57 +// vanity host and the old "dev" stage; the active endpoint is the "blue" stage.
31 58 //define( 'MLSIMPORT_API_URL', 'https://requests.mlsimport.com/' );
32 59 //define( 'MLSIMPORT_API_URL', 'https://pyjzsilw7b.execute-api.us-east-1.amazonaws.com/dev/' );
33 60 define( 'MLSIMPORT_API_URL', 'https://srky9ddikl.execute-api.us-east-1.amazonaws.com/blue/');
34 61
@@ -36,8 +63,10 @@
36 63
37 64
38 65
39 66
67 +// Allow a site to pre-define this constant (e.g. in wp-config.php) to hide the
68 +// "finish setup" admin notice; default to showing it when not already defined.
40 69 if ( ! defined( 'MLSIMPORT_HIDE_SETUP_NOTICE' ) ) {
41 70 define( 'MLSIMPORT_HIDE_SETUP_NOTICE', false );
42 71 }
43 72
@@ -50,8 +79,12 @@
50 79 function mlsimport_activate() {
51 80 require_once plugin_dir_path( __FILE__ ) . 'includes/class-mlsimport-activator.php';
52 81 Mlsimport_Activator::activate();
53 82 mlsimport_telemetry_set_once( 'installed_at', time() );
83 +
84 + // Standalone (theme_id 990) search table.
85 + require_once plugin_dir_path( __FILE__ ) . 'includes/standalone/class-mlsimport-standalone-table.php';
86 + Mlsimport_Standalone_Table::create();
54 87 }
55 88
56 89
57 90
@@ -62,9 +95,11 @@
62 95 function mlsimport_deactivate() {
63 96 require_once plugin_dir_path( __FILE__ ) . 'includes/class-mlsimport-deactivator.php';
64 97 wp_clear_scheduled_hook( 'event_mls_import_auto' );
65 98 wp_clear_scheduled_hook( 'mlsimport_reconciliation_event' );
99 + wp_clear_scheduled_hook( 'mlsimport_reconciliation_retry_event' );
66 100 wp_clear_scheduled_hook( 'mlsimport_daily_telemetry_event' );
101 + delete_option( 'mlsimport_reconciliation_running' );
67 102 Mlsimport_Deactivator::deactivate();
68 103 }
69 104
70 105
@@ -76,18 +111,23 @@
76 111 * Show one-time modal about the switch from Delete Statuses to Protected Statuses.
77 112 */
78 113 add_action( 'admin_footer', 'mlsimport_protected_statuses_upgrade_modal' );
79 114 function mlsimport_protected_statuses_upgrade_modal() {
115 + // Bail if the user already acknowledged/dismissed the notice.
80 116 if ( get_option( 'mlsimport_dismiss_protected_status_notice' ) ) {
81 117 return;
82 118 }
83 119 // Only show for sites that had a version before 6.2 (not fresh installs)
84 120 $show_modal = get_option( 'mlsimport_show_protected_status_modal' );
121 + // Bail when the upgrade flag was never set for this site.
85 122 if ( ! $show_modal ) {
86 123 return;
87 124 }
125 + // Nonce for the dismissal AJAX call embedded in the modal's inline script.
88 126 $nonce = wp_create_nonce( 'mlsimport_dismiss_protected_notice' );
127 + // Link the user to their Import Tasks list to set Protected Statuses.
89 128 $import_tasks_url = admin_url( 'edit.php?post_type=mlsimport_item' );
129 + // Emit the modal markup + inline dismissal script into the admin footer.
90 130 ?>
91 131 <div id="mlsimport-protected-status-modal" style="position:fixed;top:0;left:0;width:100%;height:100%;background:rgba(0,0,0,0.7);z-index:999999;display:flex;align-items:center;justify-content:center;">
92 132 <div style="background:#fff;max-width:520px;width:90%;border-radius:8px;padding:30px;box-shadow:0 4px 20px rgba(0,0,0,0.3);">
93 133 <h2 style="margin-top:0;color:#d63638;">MLSImport - Important Change</h2>
@@ -113,12 +153,24 @@
113 153 </script>
114 154 <?php
115 155 }
116 156 add_action( 'wp_ajax_mlsimport_dismiss_protected_notice', 'mlsimport_handle_dismiss_protected_notice' );
157 +/**
158 + * AJAX handler: persist the user's dismissal of the protected-statuses modal.
159 + *
160 + * Verifies the nonce, records the permanent "dismissed" flag, clears the
161 + * "show modal" flag, and returns a success JSON response.
162 + *
163 + * @return void
164 + */
117 165 function mlsimport_handle_dismiss_protected_notice() {
166 + // Verify the nonce created in the modal markup above.
118 167 check_ajax_referer( 'mlsimport_dismiss_protected_notice' );
168 + // Persist that this notice has been acknowledged so it never shows again.
119 169 update_option( 'mlsimport_dismiss_protected_status_notice', true );
170 + // Remove the one-time "show modal" flag.
120 171 delete_option( 'mlsimport_show_protected_status_modal' );
172 + // Return an empty success payload to the inline script.
121 173 wp_send_json_success();
122 174 }
123 175
124 176 /**
@@ -138,15 +190,97 @@
138 190 * The core plugin class that is used to define internationalization,
139 191 * admin-specific hooks, and public-facing site hooks.
140 192 */
141 193
142 -require 'vendor/autoload.php';
194 +/*
195 + * Action Scheduler — the plugin's only third-party runtime dependency.
196 + *
197 + * This is deliberately a direct require rather than `vendor/autoload.php`.
198 + * Composer's generated autoloader is written differently depending on whether
199 + * dev dependencies (phpunit, php_codesniffer, myclabs/deep-copy) happen to be
200 + * installed at the time it was generated. Those dev packages are never shipped,
201 + * so a dev-generated autoloader committed to the repo makes `autoload_files.php`
202 + * eagerly require files that do not exist in the released plugin — a fatal error
203 + * on activation, before any plugin code runs.
204 + *
205 + * Action Scheduler is built to be dropped into a plugin and included directly
206 + * (that is how WooCommerce loads it); it registers its own class loader and
207 + * negotiates versions with any other copy already loaded on the site. So there
208 + * is nothing left for the Composer autoloader to do at runtime, and not shipping
209 + * it removes that whole failure mode. Composer is still used for dev tooling.
210 + */
211 +require_once plugin_dir_path( __FILE__ ) . 'vendor/woocommerce/action-scheduler/action-scheduler.php';
212 +// Core includes: RESO field defs + helpers, provider map, cron/reconciliation
213 +// guards, status taxonomy/normalizer, then the orchestrator and API client.
143 214 require_once plugin_dir_path( __FILE__ ) . 'includes/help_functions.php';
215 +require_once plugin_dir_path( __FILE__ ) . 'includes/mlsimport-theme-detection.php';
216 +require_once plugin_dir_path( __FILE__ ) . 'includes/mlsimport-credentials.php';
144 217 require_once plugin_dir_path( __FILE__ ) . 'includes/mlsimport-provider-map.php';
218 +require_once plugin_dir_path( __FILE__ ) . 'includes/mlsimport-enum-labels.php';
219 +require_once plugin_dir_path( __FILE__ ) . 'includes/mlsimport-country.php';
220 +require_once plugin_dir_path( __FILE__ ) . 'includes/mlsimport-reconciliation-guard.php';
221 +require_once plugin_dir_path( __FILE__ ) . 'includes/mlsimport-cron-guard.php';
222 +require_once plugin_dir_path( __FILE__ ) . 'includes/mlsimport-task-health.php';
145 223 require_once plugin_dir_path( __FILE__ ) . 'includes/mlsimport-status-taxonomy.php';
224 +require_once plugin_dir_path( __FILE__ ) . 'includes/class-mlsimport-reconciliation.php';
225 +require_once plugin_dir_path( __FILE__ ) . 'includes/class-mlsimport-reconciliation-wordpress-environment.php';
226 +require_once plugin_dir_path( __FILE__ ) . 'includes/class-mlsimport-import-task-execution.php';
227 +require_once plugin_dir_path( __FILE__ ) . 'includes/class-mlsimport-import-task-execution-wordpress-environment.php';
146 228 require_once plugin_dir_path( __FILE__ ) . 'includes/mlsimport-status-normalize.php';
229 +require_once plugin_dir_path( __FILE__ ) . 'includes/class-mlsimport-stored-listing-fields.php';
230 +require_once plugin_dir_path( __FILE__ ) . 'includes/class-mlsimport-stored-listing-title.php';
231 +require_once plugin_dir_path( __FILE__ ) . 'includes/class-mlsimport-stored-listing-media.php';
232 +require_once plugin_dir_path( __FILE__ ) . 'includes/mlsimport-listing-key-migration.php';
233 +// Multi-MLS connection registry + the one-time single->multi MLS migration
234 +// (the migration file hooks itself on init, after the listing-key migration).
235 +require_once plugin_dir_path( __FILE__ ) . 'includes/class-mlsimport-connections.php';
236 +require_once plugin_dir_path( __FILE__ ) . 'includes/mlsimport-multimls-migration.php';
237 +// Per-connection option resolution + settings export/import transfer (#275):
238 +// every read/write of the "_{mls_id}"-suffixed per-MLS state goes through these.
239 +require_once plugin_dir_path( __FILE__ ) . 'includes/mlsimport-connection-options.php';
240 +require_once plugin_dir_path( __FILE__ ) . 'includes/mlsimport-settings-transfer.php';
241 +// N-entitlement SaaS contract consumer (#276): entitlements parsing, the
242 +// mls_id echo guard, and the stable not_entitled rejection handling.
243 +require_once plugin_dir_path( __FILE__ ) . 'includes/mlsimport-entitlements.php';
244 +// Import task connection binding + cron isolation (#277): a task belongs to
245 +// ONE connection for life; the hourly cron gates each task on ITS connection.
246 +require_once plugin_dir_path( __FILE__ ) . 'includes/mlsimport-task-binding.php';
247 +// Per-connection reconciliation (#279): the daily event runs the untouched
248 +// decision module once per connection, each with an echo-guarded scoped
249 +// snapshot and an inventory limited to that connection's stamped listings.
250 +require_once plugin_dir_path( __FILE__ ) . 'includes/mlsimport-reconciliation-connections.php';
251 +// Connections screen (#280): the settings-page Connections tab — screen data
252 +// (registry rows + activity + plan cap + account state) and its AJAX handlers
253 +// (drag-reorder priority, per-row connection test, account disconnect).
254 +require_once plugin_dir_path( __FILE__ ) . 'includes/mlsimport-connections-screen.php';
255 +require_once plugin_dir_path( __FILE__ ) . 'includes/mlsimport-connections-ajax.php';
256 +// Add-MLS drawer (#281): connection-scoped metadata gather (shared with the
257 +// admin metadata AJAX) + the drawer's refuse/test/register/seed flow.
258 +require_once plugin_dir_path( __FILE__ ) . 'includes/mlsimport-metadata-gather.php';
259 +require_once plugin_dir_path( __FILE__ ) . 'includes/mlsimport-connections-add.php';
260 +// The follow-up field-mapping seed the drawer posts after a saved add (#325).
261 +require_once plugin_dir_path( __FILE__ ) . 'includes/mlsimport-connections-seed.php';
262 +// Edit-connection drawer (tab consolidation): the retired "MLS Connection"
263 +// credentials tab's replacement — refuse/test/store flow that updates a
264 +// registered connection's credentials (and mirrors the current connection's
265 +// into the flat options).
266 +require_once plugin_dir_path( __FILE__ ) . 'includes/mlsimport-connections-edit.php';
267 +// Remove-connection flow: a row's Remove action — drops the record + its
268 +// per-connection options and promotes the next-priority connection when the
269 +// current one was removed. Imported listings and tasks stay.
270 +require_once plugin_dir_path( __FILE__ ) . 'includes/mlsimport-connections-remove.php';
271 +// Dedupe mechanics (#282): one visible copy per physical address across
272 +// connections — winner by priority, loser hidden (never deleted), promoted
273 +// back automatically when the winner disappears. Address normalization is
274 +// the pure half; the evaluator/hooks half depends on it.
275 +require_once plugin_dir_path( __FILE__ ) . 'includes/mlsimport-dedupe-address.php';
276 +require_once plugin_dir_path( __FILE__ ) . 'includes/mlsimport-dedupe.php';
277 +require_once plugin_dir_path( __FILE__ ) . 'includes/class-mlsimport-stored-listing-wordpress-environment.php';
278 +require_once plugin_dir_path( __FILE__ ) . 'includes/class-mlsimport-stored-listing-write.php';
279 +require_once plugin_dir_path( __FILE__ ) . 'includes/class-mlsimport-stored-listing-adapter-factory.php';
147 280 require_once plugin_dir_path( __FILE__ ) . 'includes/class-mlsimport.php';
148 281 require_once plugin_dir_path( __FILE__ ) . 'includes/ThemeImport.php';
282 +require_once plugin_dir_path( __FILE__ ) . 'enviroment/StandaloneClass.php';
149 283 require_once plugin_dir_path( __FILE__ ) . 'enviroment/ResidenceClass.php';
150 284 require_once plugin_dir_path( __FILE__ ) . 'enviroment/EstateClass.php';
151 285 require_once plugin_dir_path( __FILE__ ) . 'enviroment/HouzezClass.php';
152 286 require_once plugin_dir_path( __FILE__ ) . 'enviroment/RealHomesClass.php';
@@ -154,17 +288,161 @@
154 288 require_once plugin_dir_path( __FILE__ ) . 'enviroment/SparkResoClass.php';
155 289 require_once plugin_dir_path( __FILE__ ) . 'enviroment/BridgeResoClass.php';
156 290 require_once plugin_dir_path( __FILE__ ) . 'enviroment/TresleResoClass.php';
157 291 require_once plugin_dir_path( __FILE__ ) . 'enviroment/MlsgridResoClass.php';
158 -require_once plugin_dir_path( __FILE__ ) . 'enviroment/MlsgridResoClass.php';
292 +require_once plugin_dir_path( __FILE__ ) . 'enviroment/BrightMlsResoClass.php';
293 +require_once plugin_dir_path( __FILE__ ) . 'enviroment/CentrisResoClass.php';
294 +require_once plugin_dir_path( __FILE__ ) . 'enviroment/ProviderResoClasses.php';
295 +require_once plugin_dir_path( __FILE__ ) . 'enviroment/UnsupportedResoClass.php';
159 296 require_once plugin_dir_path( __FILE__ ) . 'includes/addons/agents_offices.php';
297 +// Why the last SaaS login failed (no subscription vs bad password) and the
298 +// one "not connected" box every screen prints.
299 +require_once plugin_dir_path( __FILE__ ) . 'includes/mlsimport-account-status.php';
160 300 require_once plugin_dir_path( __FILE__ ) . 'includes/mlsimport-onboarding.php';
161 301
302 +require_once plugin_dir_path( __FILE__ ) . 'includes/class-mlsimport-field-configuration.php';
162 303 require_once plugin_dir_path( __FILE__ ) . 'includes/mlsimport-field-selector-functions.php';
163 304 require_once plugin_dir_path( __FILE__ ) . 'includes/mlsimport-progressive-save.php';
305 +// Per-connection field-mapping UI: the one scope-resolution rule shared by the
306 +// field_options tab, the field-configuration AJAX, and the metadata-gather AJAX.
307 +require_once plugin_dir_path( __FILE__ ) . 'includes/mlsimport-field-mapping-scope.php';
308 +require_once plugin_dir_path( __FILE__ ) . 'includes/mlsimport-metadata-autotrigger.php';
164 309 require_once plugin_dir_path( __FILE__ ) . 'includes/mlsimport-telemetry.php';
310 +// #283: per-connection telemetry (sync stamps + the connections payload seam).
311 +require_once plugin_dir_path( __FILE__ ) . 'includes/mlsimport-telemetry-connections.php';
165 312 require_once plugin_dir_path( __FILE__ ) . 'includes/mlsimport-activity-log.php';
313 +// #208: internal incident alerts (dedup + resolve) and import/connection health watch.
314 +require_once plugin_dir_path( __FILE__ ) . 'includes/mlsimport-alerts.php';
315 +require_once plugin_dir_path( __FILE__ ) . 'includes/mlsimport-import-health.php';
166 316
317 +/*
318 + * Standalone (theme_id 990) mode — own listings table, CPTs and taxonomies.
319 + * Registered on every load (ADR-0003); the table is created on activation and
320 + * upgraded behind a version guard on admin_init.
321 + */
322 +require_once plugin_dir_path( __FILE__ ) . 'includes/standalone/mlsimport-hooks.php'; // Hook reference + convention (loaded early).
323 +require_once plugin_dir_path( __FILE__ ) . 'includes/standalone/class-mlsimport-standalone-table.php';
324 +require_once plugin_dir_path( __FILE__ ) . 'includes/standalone/class-mlsimport-standalone-cpt.php';
325 +require_once plugin_dir_path( __FILE__ ) . 'includes/standalone/class-mlsimport-term-select.php';
326 +require_once plugin_dir_path( __FILE__ ) . 'includes/standalone/class-mlsimport-standalone-shortcodes.php';
327 +require_once plugin_dir_path( __FILE__ ) . 'includes/standalone/class-mlsimport-standalone-block.php';
328 +require_once plugin_dir_path( __FILE__ ) . 'includes/standalone/class-mlsimport-standalone-ajax.php';
329 +require_once plugin_dir_path( __FILE__ ) . 'includes/standalone/class-mlsimport-standalone-reindex.php';
330 +require_once plugin_dir_path( __FILE__ ) . 'includes/standalone/class-mlsimport-standalone-assets.php';
331 +require_once plugin_dir_path( __FILE__ ) . 'includes/standalone/class-mlsimport-standalone-single.php';
332 +require_once plugin_dir_path( __FILE__ ) . 'includes/standalone/property-section-registry.php';
333 +require_once plugin_dir_path( __FILE__ ) . 'includes/standalone/property-print.php';
334 +require_once plugin_dir_path( __FILE__ ) . 'includes/standalone/class-mlsimport-property-section-shortcodes.php';
335 +require_once plugin_dir_path( __FILE__ ) . 'includes/standalone/class-mlsimport-property-section-blocks.php';
336 +require_once plugin_dir_path( __FILE__ ) . 'includes/standalone/class-mlsimport-property-section-elementor.php';
337 +require_once plugin_dir_path( __FILE__ ) . 'includes/standalone/class-mlsimport-property-lead.php';
338 +require_once plugin_dir_path( __FILE__ ) . 'includes/standalone/agent-sections.php';
339 +require_once plugin_dir_path( __FILE__ ) . 'includes/standalone/property-schema.php';
340 +require_once plugin_dir_path( __FILE__ ) . 'includes/standalone/class-mlsimport-property-metabox.php';
341 +require_once plugin_dir_path( __FILE__ ) . 'includes/standalone/class-mlsimport-agent-metabox.php';
342 +require_once plugin_dir_path( __FILE__ ) . 'includes/standalone/class-mlsimport-term-meta.php';
343 +require_once plugin_dir_path( __FILE__ ) . 'includes/standalone/class-mlsimport-property-columns.php';
344 +require_once plugin_dir_path( __FILE__ ) . 'includes/standalone/class-mlsimport-favorites.php';
345 +require_once plugin_dir_path( __FILE__ ) . 'includes/standalone/page-block-registry.php';
346 +require_once plugin_dir_path( __FILE__ ) . 'includes/standalone/class-mlsimport-page-block-shortcodes.php';
347 +require_once plugin_dir_path( __FILE__ ) . 'includes/standalone/class-mlsimport-page-block-blocks.php';
348 +require_once plugin_dir_path( __FILE__ ) . 'includes/standalone/class-mlsimport-page-block-elementor.php';
349 +require_once plugin_dir_path( __FILE__ ) . 'includes/standalone/class-mlsimport-customizer.php'; // Standalone design settings in the WP Customizer (990 mode).
350 +require_once plugin_dir_path( __FILE__ ) . 'includes/live/live-bootstrap.php'; // Live MLS passthrough mode (seam #1 — its only existing-file require).
351 +add_action( 'init', array( 'Mlsimport_Standalone_Cpt', 'register' ) );
352 +// After register(): drop cached rewrite rules when the standalone-mode signature changed (#206).
353 +add_action( 'init', array( 'Mlsimport_Standalone_Cpt', 'maybe_flush_rewrites' ), 20 );
354 +add_action( 'init', array( 'Mlsimport_Property_Metabox', 'register' ) );
355 +add_action( 'init', array( 'Mlsimport_Agent_Metabox', 'register' ) );
356 +add_action( 'init', array( 'Mlsimport_Term_Meta', 'register' ) );
357 +add_action( 'init', array( 'Mlsimport_Property_Columns', 'register' ) );
358 +add_action( 'init', array( 'Mlsimport_Standalone_Shortcodes', 'register' ) );
359 +add_action( 'init', array( 'Mlsimport_Standalone_Block', 'register' ) );
360 +add_action( 'init', array( 'Mlsimport_Standalone_Ajax', 'register' ) );
361 +add_action( 'init', array( 'Mlsimport_Favorites', 'register' ) );
362 +add_action( 'init', array( 'Mlsimport_Property_Section_Shortcodes', 'register' ) );
363 +// Property-section Gutenberg blocks (mlsimport/property-*, "MLSImport — Property"
364 +// category) are intentionally NOT registered — we don't expose them as blocks.
365 +// The render dispatcher, shortcodes and Elementor widget behind them stay active.
366 +// add_action( 'init', array( 'Mlsimport_Property_Section_Blocks', 'register' ) );
367 +add_action( 'init', array( 'Mlsimport_Page_Block_Shortcodes', 'register' ) );
368 +add_action( 'init', array( 'Mlsimport_Page_Block_Blocks', 'register' ) );
369 +// Two MLSImport categories in the block inserter: single-property section blocks
370 +// ("Property") and the page-builder blocks ("Real Estate").
371 +add_filter(
372 + 'block_categories_all',
373 + static function ( $categories ) {
374 + return array_merge(
375 + array(
376 + array( 'slug' => 'mlsimport-property', 'title' => __( 'MLSImport — Property', 'mlsimport' ) ),
377 + array( 'slug' => 'mlsimport-real-estate', 'title' => __( 'MLSImport — Real Estate', 'mlsimport' ) ),
378 + ),
379 + $categories
380 + );
381 + }
382 +);
383 +add_action( 'init', array( 'Mlsimport_Property_Lead', 'register' ) );
384 +// Priority 20 (not the default 10) so the plugin's self-contained BEM stylesheets
385 +// enqueue AFTER the active theme's own styles. Themes hook wp_enqueue_scripts at 10
386 +// and, because plugins load before the theme, our default-10 callback would print
387 +// FIRST — losing every equal-specificity tie to a theme rule that prints later.
388 +// Hello Elementor's reset.css is the concrete case: it styles bare `button` /
389 +// `[type=button]` (pink #c36, inline-block, width:auto), which ties our single-class
390 +// `.mlsimport-*` button rules (0,1,0) and won on order, so the multiselect control,
391 +// range/beds toggles, popup buttons, submit and the card heart all rendered narrow
392 +// and pink. Printing after the theme lets our base rules win that tie. It stays a
393 +// SINGLE class (0,1,0), so component state rules (:focus / :hover / .is-open at
394 +// 0,1,1+) and any Elementor Style-tab control ({{WRAPPER}} … at 0,2,0+) still win —
395 +// this only reclaims the tie against a generic theme reset, and never matches a
396 +// non-plugin (e.g. Elementor) element.
397 +add_action( 'wp_enqueue_scripts', array( 'Mlsimport_Standalone_Assets', 'enqueue' ), 20 );
398 +add_action( 'wp_enqueue_scripts', array( 'Mlsimport_Property_Section_Assets', 'ensure_registered' ) );
399 +// Pre-enqueue the single-property section assets into the <head>; the single
400 +// template prints the header before any section renders, so the on-demand
401 +// enqueue at render time lands in the footer and flashes unstyled (issue #172).
402 +// Priority 20 for the same after-the-theme reason as the standalone assets above.
403 +add_action( 'wp_enqueue_scripts', array( 'Mlsimport_Property_Section_Assets', 'enqueue_for_single' ), 20 );
404 +// Same for the single-agent page (issue #188).
405 +add_action( 'wp_enqueue_scripts', 'mlsimport_agent_enqueue_for_single', 20 );
406 +// Load the same front-end CSS into the block editor so the dynamic blocks'
407 +// ServerSideRender previews match the front end (editor-guarded inside the method).
408 +add_action( 'enqueue_block_assets', array( 'Mlsimport_Standalone_Assets', 'enqueue_editor' ) );
409 +add_filter( 'template_include', array( 'Mlsimport_Standalone_Single', 'template_include' ) );
410 +add_action( 'wp_head', 'mlsimport_property_print_schema' );
411 +Mlsimport_Property_Section_Elementor::register();
412 +Mlsimport_Page_Block_Elementor::register();
413 +// A contact-form lead carries no property and no agent; route those general
414 +// enquiries to the "Contact form recipients" setting (decision 3).
415 +add_filter(
416 + 'mlsimport_property_lead_recipient',
417 + static function ( $to, $property_id, $agent_id = 0 ) {
418 + if ( $property_id || $agent_id ) {
419 + return $to;
420 + }
421 + $recipients = trim( (string) mlsimport_standalone_option( 'contact_form_recipients', '' ) );
422 + return '' !== $recipients ? $recipients : $to;
423 + },
424 + 10,
425 + 3
426 +);
427 +add_action( 'admin_init', array( 'Mlsimport_Standalone_Table', 'maybe_upgrade' ) );
428 +// One-time repair of comma-glued taxonomy terms written before 7.1.2 (#290).
429 +add_action( 'admin_init', array( 'Mlsimport_Standalone_Cpt', 'maybe_split_packed_terms' ) );
430 +add_action( 'before_delete_post', array( 'StandaloneClass', 'cleanup_on_delete' ) );
431 +// Trash/unpublish (not a permanent delete) must also drop the listings row, so the
432 +// search index only ever holds published listings.
433 +add_action( 'transition_post_status', array( 'StandaloneClass', 'cleanup_on_status_change' ), 10, 3 );
434 +
435 +if ( defined( 'WP_CLI' ) && WP_CLI ) {
436 + WP_CLI::add_command(
437 + 'mlsimport reindex',
438 + function () {
439 + $rebuilt = Mlsimport_Standalone_Reindex::rebuild_all();
440 + WP_CLI::success( "Reindexed {$rebuilt} standalone listings." );
441 + }
442 + );
443 +}
444 +
167 445 if ( ! wp_next_scheduled( 'event_mls_import_auto' ) ) {
168 446 wp_schedule_event( time(), 'hourly', 'event_mls_import_auto' );
169 447 }
170 448
@@ -180,9 +458,11 @@
180 458 * Optimizations:
181 459 * - Uses 'fields' => 'ids' so only post IDs are loaded (saves memory)
182 460 * - Batches with posts_per_page/paged, so memory does not spike for large data sets
183 461 * - Calls gc_collect_cycles() periodically to further reduce memory leaks
184 - * - Skips processing if MLS is not connected or token is missing
462 + * - Bails only when the SaaS token is missing (global, one account); each
463 + * task is then gated on its OWN connection (#277) — a broken or deleted
464 + * connection skips its tasks while healthy connections keep importing
185 465 *
186 466 * @return void
187 467 */
188 468 add_action('event_mls_import_auto', 'mlsimport_saas_event_mls_import_auto_function');
@@ -194,34 +474,89 @@
194 474 global $mlsimport;
195 475
196 476 //error_log('[AutoCron] Start: ' . (memory_get_usage(true) / 1024 / 1024) . ' MB');
197 477
478 + // Watchdog backstop (issue #199): a chunked manual import whose worker
479 + // chain died is normally revived by the polled progress screen, but if
480 + // the administrator closed that screen nothing else watches the run.
481 + // Hourly cron picks it up here; revive() is a cheap no-op for anything
482 + // that is not a silent, stalled manual run.
483 + // Import-health checks (#208) run before anything can bail out below:
484 + // detect a previous cron run that died mid-loop, and a manual run stuck
485 + // at "Preparing". Both open one deduplicated internal incident.
486 + mlsimport_cron_heartbeat_check();
487 + mlsimport_import_health_watch_manual_run();
488 +
489 + $mlsimport_active_lock = get_option( 'mlsimport_import_run_lock', array() );
490 + if ( is_array( $mlsimport_active_lock ) && ! empty( $mlsimport_active_lock['task_id'] ) ) {
491 + $mlsimport_revive = $mlsimport->admin->mlsimport_import_task_execution()->revive( (int) $mlsimport_active_lock['task_id'] );
492 + if ( true === ( $mlsimport_revive['revived'] ?? false ) ) {
493 + mlsimport_saas_single_write_import_custom_logs( 'Hourly watchdog revived the import worker chain for task ' . (int) $mlsimport_active_lock['task_id'] . '.' . PHP_EOL, 'manual' );
494 + } elseif ( 'stalled' === ( $mlsimport_revive['reason'] ?? '' ) ) {
495 + mlsimport_saas_single_write_import_custom_logs( 'Hourly watchdog declared the import run for task ' . (int) $mlsimport_active_lock['task_id'] . ' stalled and failed it.' . PHP_EOL, 'manual' );
496 + // The run was terminated as hopeless — tell the SaaS once (#208).
497 + mlsimport_alert_open(
498 + 'import_stalled:' . (int) $mlsimport_active_lock['task_id'],
499 + 'import_stalled',
500 + array( 'task_id' => (int) $mlsimport_active_lock['task_id'] )
501 + );
502 + }
503 + }
504 +
505 + // 0. Bail if a run is already in progress. Without this guard an overlapping
506 + // cron fire processes the same listings in parallel, causing duplicate
507 + // listing_key inserts and term_relationship/term_count deadlocks. The TTL is
508 + // the safety net if a run dies mid-loop without reaching the release below.
509 + if ( get_transient( 'mlsimport_cron_running' ) ) {
510 + return;
511 + }
512 +
198 513 // 1. Get the API token from transient - exit if not set
199 514 $token = $mlsimport->admin->mlsimport_saas_get_mls_api_token_from_transient();
200 515 //error_log('[AutoCron] After token fetch: ' . (memory_get_usage(true) / 1024 / 1024) . ' MB');
201 516 if (trim($token) === '') {
517 + // Silent exit made frozen sites undiagnosable (issue #207 finding 3):
518 + // record the failed attempt with a real class before bailing.
519 + mlsimport_telemetry_set( 'last_sync_failed', time() );
520 + mlsimport_telemetry_set( 'last_sync_failed_code', 'no_token' );
202 521 //error_log('[AutoCron] No token, exiting.');
203 522 return;
204 523 }
205 524
206 - // 2. Check if MLS connection is valid - exit if not
207 - $is_mls_connected = get_option('mlsimport_connection_test', '');
208 - //error_log('[AutoCron] After connection check: ' . (memory_get_usage(true) / 1024 / 1024) . ' MB');
209 - if ('yes' !== $is_mls_connected) {
210 - //error_log('[AutoCron] No valid connection, exiting.');
211 - return;
212 - }
525 + // 2. The connection-status check is no longer a global bail-out (#277):
526 + // each task is gated on ITS OWN connection inside the loop below, so one
527 + // broken MLS never blocks tasks on healthy connections. Only the SaaS
528 + // token above stays global — one account, one token.
213 529
214 - // Record sync attempt in telemetry
215 - mlsimport_telemetry_bump( 'syncs' );
530 + // Claim the run lock now that we are committed to processing.
531 + set_transient( 'mlsimport_cron_running', 1, 15 * MINUTE_IN_SECONDS );
532 +
533 + // Every operation after lock acquisition belongs to one committed cron
534 + // run. Keep that complete run inside a try/finally boundary so a Throwable
535 + // from task discovery, connection gating, or one Import Run cannot leave
536 + // the site locked until the transient TTL expires (#303).
537 + try {
538 + // Heartbeat (#208): record that a cron import is now running, so the next
539 + // cron entry can tell a clean finish from a process that died mid-loop.
540 + mlsimport_cron_heartbeat_start();
541 +
542 + // Record sync attempt in telemetry. The 'syncs' counter is no longer
543 + // bumped here (#283): a run-level tick belongs to no single connection
544 + // and would double-count against the per-pull tick that
545 + // mlsimport_telemetry_record_sync_result() now records — one pull, one
546 + // tick, attributed to the pull's own connection, so the global syncs sum
547 + // stays equal to the sum of the per-connection buckets.
216 548 mlsimport_telemetry_set( 'last_sync_attempt', time() );
217 549
218 - // 3. Set batch size for processing and initialize loop variables
550 + // 3. Set batch size for gathering and initialize loop variables
219 551 $batch_size = 100;
220 552 $paged = 1;
221 553 $total_processed = 0;
222 554
223 - // 4. Process in batches until no more items are found
555 + // 4. Gather every cron-enabled task id first (ids only — a few bytes each,
556 + // still fetched in paged batches so the query never loads post objects).
557 + // Gathering before processing is what makes fair ordering possible below.
558 + $cron_task_ids = array();
224 559 do {
225 560 // Prepare query: only IDs, filter by meta key, batch, paged, no_found_rows speeds up query
226 561 $args = array(
227 562 'post_type' => 'mlsimport_item',
@@ -240,43 +575,101 @@
240 575 );
241 576
242 577 // Get post IDs for this batch
243 578 $post_ids = get_posts($args);
244 - //error_log("[AutoCron] Batch {$paged} fetched " . count($post_ids) . " items, memory: " . (memory_get_usage(true) / 1024 / 1024) . ' MB');
245 579
246 - // If nothing is returned, break the loop
580 + // If nothing is returned, the gather is complete
247 581 if (empty($post_ids)) {
248 582 break;
249 583 }
250 584
251 - // 5. Loop through each post ID in this batch
252 585 foreach ($post_ids as $prop_id) {
253 - $logs = 'Loop custom post: ' . $prop_id . PHP_EOL;
254 - mlsimport_debuglogs_per_plugin($logs);
586 + $cron_task_ids[] = (int) $prop_id;
587 + }
255 588
256 - // Call processing function for this item. The feed count it pulls
257 - // is recorded inside mlsimport_make_listing_requests() (last_feed_found).
258 - $mlsimport->admin->mlsimport_saas_start_cron_links_per_item($prop_id);
589 + // Prepare next batch
590 + $paged++;
591 + unset($post_ids); // Free memory
259 592
260 - $total_processed++;
593 + } while (true);
261 594
262 - // Free memory every 100 processed items
263 - if ($total_processed % 100 === 0) {
264 - gc_collect_cycles();
265 - //error_log("[AutoCron] Processed {$total_processed} total, memory: " . (memory_get_usage(true) / 1024 / 1024) . ' MB');
595 + // 5. Order by starvation (issue #203): the query above returns tasks in
596 + // the same fixed order every hour, so when an early large task ate the
597 + // whole cycle the bottom tasks were skipped run after run. The queue key
598 + // is the newer of last success and last ATTEMPT (issue #330): ordering
599 + // by success alone let one task whose run never completes keep the
600 + // oldest stamp and hold first place every hour while the rest starved.
601 + $cron_task_watermarks = array();
602 + foreach ($cron_task_ids as $prop_id) {
603 + $cron_task_watermarks[ $prop_id ] = mlsimport_cron_task_queue_key(
604 + (string) get_post_meta( $prop_id, 'mlsimport_last_date', true ),
605 + (string) get_post_meta( $prop_id, 'mlsimport_last_attempt', true )
606 + );
607 + }
608 + unset($cron_task_ids);
609 +
610 + // 6. Process every task, most starved first. A broken connection is
611 + // recorded ONCE per run, not once per task — the entry is identical and
612 + // re-writing telemetry for every skipped task would only amplify writes.
613 + $failed_connections = array();
614 + foreach (mlsimport_cron_task_order($cron_task_watermarks) as $prop_id) {
615 + $logs = 'Loop custom post: ' . $prop_id . PHP_EOL;
616 + mlsimport_debuglogs_per_plugin($logs);
617 +
618 + // Per-connection failure isolation (#277): gate this task on ITS OWN
619 + // connection. A broken connection's tasks skip with a recorded reason;
620 + // a DELETED connection's tasks skip with a deduplicated health
621 + // incident and are never re-defaulted; healthy connections keep
622 + // importing in this same run.
623 + $mlsimport_gate = mlsimport_cron_task_gate( (int) $prop_id );
624 + if ( 'import' !== $mlsimport_gate['action'] ) {
625 + if ( 'skip_missing' === $mlsimport_gate['action'] ) {
626 + mlsimport_alert_open(
627 + 'task_connection_missing:' . (int) $prop_id,
628 + 'task_connection_missing',
629 + array( 'task_id' => (int) $prop_id, 'mls_id' => $mlsimport_gate['mls_id'] )
630 + );
631 + } elseif ( ! isset( $failed_connections[ $mlsimport_gate['mls_id'] ] ) ) {
632 + $failed_connections[ $mlsimport_gate['mls_id'] ] = true;
633 + mlsimport_record_connection_sync_failure( $mlsimport_gate['mls_id'], $mlsimport_gate['code'] );
266 634 }
635 + mlsimport_debuglogs_per_plugin(
636 + 'Task ' . $prop_id . ' skipped: connection ' . $mlsimport_gate['mls_id']
637 + . ' ' . $mlsimport_gate['action'] . ' (' . $mlsimport_gate['code'] . ')' . PHP_EOL
638 + );
639 + continue;
267 640 }
268 641
269 - // 6. Prepare next batch
270 - $paged++;
271 - unset($post_ids); // Free memory
272 - gc_collect_cycles(); // Trigger garbage collection
273 - //error_log("[AutoCron] After batch {$paged}, memory: " . (memory_get_usage(true) / 1024 / 1024) . ' MB');
642 + // Call processing function for this item. The feed count it pulls
643 + // is recorded inside mlsimport_make_listing_requests() (last_feed_found).
644 + $mlsimport->admin->mlsimport_saas_start_cron_links_per_item($prop_id);
274 645
275 - } while (true);
646 + $total_processed++;
276 647
277 - mlsimport_telemetry_set( 'last_sync_success', time() );
648 + // Heartbeat (#208): measurable progress for the stuck-run check.
649 + mlsimport_cron_heartbeat_progress( $total_processed );
278 650
651 + // Free memory every 100 processed items
652 + if ($total_processed % 100 === 0) {
653 + gc_collect_cycles();
654 + //error_log("[AutoCron] Processed {$total_processed} total, memory: " . (memory_get_usage(true) / 1024 / 1024) . ' MB');
655 + }
656 + }
657 +
658 + // Heartbeat (#208): clean finish — also resolves an open died-run incident.
659 + } finally {
660 + // A failed task still ends this cron invocation. Mark the heartbeat as
661 + // finished and release the overlap lock while PHP continues propagating
662 + // the original Throwable to the caller for logging and diagnosis.
663 + mlsimport_cron_heartbeat_finish();
664 + delete_transient( 'mlsimport_cron_running' );
665 + }
666 +
667 + // last_sync_success is no longer stamped here (issue #207 finding 1): the
668 + // end-of-loop stamp reported success even when every request failed, and
669 + // never fired when a run died mid-loop. Each listings request now records
670 + // its own outcome inside mlsimport_make_listing_requests().
671 +
279 672 //error_log('[AutoCron] Done, total processed: ' . $total_processed . ', end memory: ' . (memory_get_usage(true) / 1024 / 1024) . ' MB');
280 673 }
281 674
282 675
@@ -292,8 +685,9 @@
292 685 wp_schedule_event( time(), 'daily', 'mlsimport_reconciliation_event' );
293 686 }
294 687
295 688 add_action( 'mlsimport_reconciliation_event', 'mlsimport_saas_reconciliation_event_function' );
689 +add_action( 'mlsimport_reconciliation_retry_event', 'mlsimport_saas_reconciliation_event_function' );
296 690
297 691 if ( ! wp_next_scheduled( 'mlsimport_daily_telemetry_event' ) ) {
298 692 wp_schedule_event( time(), 'daily', 'mlsimport_daily_telemetry_event' );
299 693 }
@@ -307,8 +701,17 @@
307 701 *
308 702 *
309 703 **/
310 704
705 +/**
706 + * Filter callback stub that returns the transient value unchanged.
707 + *
708 + * Left as a pass-through hook point; the commented `return false;` would force
709 + * a transient miss for debugging.
710 + *
711 + * @param mixed $value Incoming transient value.
712 + * @return mixed The value unchanged.
713 + */
311 714 function mlsimport_force_use_transient( $value ) {
312 715 return $value;
313 716 // return false;
314 717 }
@@ -315,8 +718,9 @@
315 718
316 719
317 720
318 721
722 +// Instantiate the core orchestrator and register all admin/public hooks.
319 723 global $mlsimport;
320 724 $mlsimport = new Mlsimport();
321 725 $mlsimport->run();
322 726
@@ -323,9 +727,12 @@
323 727
324 728
325 729
326 730
731 +// Map of supported theme IDs to human labels. 990 = standalone (no host theme
732 +// dependency); 991-994 are the four supported real-estate themes.
327 733 $supported_theme = array(
734 + 990 => 'Standalone (any theme)',
328 735 991 => 'WpResidence',
329 736 992 => 'Houzez',
330 737 993 => 'Real Homes',
331 738 994 => 'Wpestate',
@@ -331,11 +738,18 @@
331 738 994 => 'Wpestate',
332 739
333 740 );
334 741
742 +// Expose the theme map as a constant for use across the plugin.
335 743 define( 'MLSIMPORT_THEME', $supported_theme );
336 744
337 745 add_filter( 'action_scheduler_failure_period', 'mlsimport_saas_filter_timelimit' );
746 +/**
747 + * Raise the Action Scheduler failure timeout so long imports are not marked failed.
748 + *
749 + * @param int $time_limit Default failure period in seconds (unused).
750 + * @return int Fixed failure period of 3000 seconds.
751 + */
338 752 function mlsimport_saas_filter_timelimit( $time_limit ) {
339 753 return 3000;
340 754 }
341 755
@@ -346,19 +760,29 @@
346 760 * Write logs
347 761 *
348 762 **/
349 763
764 +/**
765 + * Append a timestamped line to a per-type import log file (when logging is on).
766 + *
767 + * @param string|array $message Message to log; arrays are JSON-encoded.
768 + * @param string $tip_import Log bucket: normal|cron|delete|server_cron.
769 + * @return void
770 + */
350 771 function mlsimport_saas_single_write_import_custom_logs( $message, $tip_import = 'normal' ) {
351 772 // Check if logging is enabled
352 773 $enable_logs = intval( get_option( 'mlsimport_disable_logs' ) );
774 + // Bail unless the "logs enabled" option equals exactly 1.
353 775 if ( 1 !== $enable_logs) {
354 776 return;
355 777 }
356 778
779 + // Encode array payloads to JSON so they can be written as text.
357 780 if ( is_array( $message ) ) {
358 781 $message = wp_json_encode( $message );
359 782 }
360 783
784 + // Prefix the message with a UTC timestamp.
361 785 $formatted_message = gmdate( 'F j, Y, g:i a' ) . ' -> ' . $message;
362 786
363 787 // Determine the log file path based on the import type
364 788 $log_file_name = 'cron' === $tip_import ? 'cron_logs' :
@@ -394,10 +818,20 @@
394 818 **/
395 819
396 820
397 821
822 +/**
823 + * Legacy status-log writer (superseded by mlsimport_debuglogs_per_plugin()).
824 + *
825 + * Note: writes with LOCK_EX but no FILE_APPEND, so it overwrites status_logs.log
826 + * on each call. Retained under the _old suffix; not called anywhere.
827 + *
828 + * @param string|array $message Message to log; arrays are JSON-encoded.
829 + * @return void
830 + */
398 831 function mlsimport_debuglogs_per_plugin_old( $message ) {
399 832
833 + // Encode array payloads to JSON.
400 834 if ( is_array( $message ) ) {
401 835 $message = wp_json_encode( $message );
402 836 }
403 837
@@ -409,18 +843,27 @@
409 843
410 844 $path_status = WP_PLUGIN_DIR . '/mlsimport/logs/status_logs.log';
411 845 file_put_contents( $path_status, $message, LOCK_EX );
412 846 }
847 +/**
848 + * Append a status/debug line to logs/status_logs.log.
849 + *
850 + * @param string|array $message Message to log; arrays are JSON-encoded.
851 + * @return void
852 + */
413 853 function mlsimport_debuglogs_per_plugin( $message ) {
414 854
855 + // Encode array payloads to JSON.
415 856 if ( is_array( $message ) ) {
416 857 $message = wp_json_encode( $message );
417 858 }
418 859
860 + // Nothing to write for an empty message.
419 861 if ( empty( $message ) ) {
420 862 return; // Exit the function if there's nothing to log
421 863 }
422 864
865 + // Target log file inside the plugin's logs/ directory.
423 866 $log_file_path = WP_PLUGIN_DIR . '/mlsimport/logs/status_logs.log';
424 867
425 868 // Check and create the directory for logs if it does not exist
426 869 $log_dir = dirname( $log_file_path );
@@ -450,18 +893,32 @@
450 893
451 894
452 895 // */5 * * * * wget http://example.com/check */2
453 896 add_action( 'init', 'mlsimport_trigger_cron_job' );
897 +/**
898 + * Server-cron entry point hit via the ?mlsimport_cron=yes query parameter.
899 + *
900 + * Rate-limited to once every 2 hours. Note: the actual import call on the
901 + * throttled branch is currently commented out, so this only writes a log line.
902 + *
903 + * @return void
904 + */
454 905 function mlsimport_trigger_cron_job() {
455 906 // ?mlsimport_cron=yes
907 + // Only proceed when the request carries mlsimport_cron=yes.
456 908 if ( isset( $_REQUEST['mlsimport_cron'] ) && 'yes' === sanitize_text_field( wp_unslash( $_REQUEST['mlsimport_cron'] ) ) ) {
909 + // Timestamp of the previous server-cron run (0 if never run).
457 910 $last_run = intval( get_option( 'mlsimport_last_server_cron' ) );
911 + // Current time.
458 912 $now = time();
913 + // First-ever call: seed the last-run timestamp.
459 914 if ( 0 === intval($last_run) ) {
460 915 update_option( 'mlsimport_last_server_cron', $now );
461 916 }
462 917
918 + // Only run if at least 2 hours have elapsed since the last run.
463 919 if ( $last_run < $now - ( 60 * 60 * 2 ) ) {
920 + // Build the "triggered" log line and record the new run time.
464 921 $log = 'Server Cron Job triggered on ' . date( 'l jS \of F Y h:i:s A', $last_run ) . ' vs ' . gmdate( 'l jS \of F Y h:i:s A', $now ) . PHP_EOL;
465 922 // mlsimport_saas_event_mls_import_auto_function();
466 923 update_option( 'mlsimport_last_server_cron', $now );
467 924 } else {
@@ -473,13 +930,23 @@
473 930 }
474 931
475 932
476 933
934 +/**
935 + * Render the "Sign up for MLSImport" promo box (30-day free-trial CTA).
936 + *
937 + * Uses a WpResidence-specific affiliate URL when that theme is active.
938 + *
939 + * @return void
940 + */
477 941 function mlsimport_show_signup() {
942 + // Default sign-up URL.
478 943 $affiliate_url = 'https://mlsimport.com';
944 + // Swap in the WpResidence affiliate/campaign link when that theme is active.
479 945 if ( function_exists( 'wp_estate_init' ) ) {
480 946 $affiliate_url = 'https://mlsimport.com/ref/1/?campaign=wpresidence';
481 947 }
948 + // Output the promo markup.
482 949 ?>
483 950 <div class="mlsimport_signup">
484 951 <h3><?php esc_html_e('Import MLS Listings into your Real Estate website', 'mlsimport'); ?></h3>
485 952 <p><?php esc_html_e('Signup now and get 30-Days Free trial, no setup fee & cancel anytime at ', 'mlsimport'); ?><a href="https://mlsimport.com/mls-import-plugin-pricing/" target="_blank">MLSImport.com</a></p>
@@ -489,8 +956,16 @@
489 956 }
490 957
491 958
492 959 //add_action('admin_init', 'force_recount_all_terms');
960 +/**
961 + * Maintenance utility: recalculate term counts for every taxonomy.
962 + *
963 + * Not hooked by default (the add_action above is commented out); intended to be
964 + * run manually to fix drifted term counts. Echoes a completion message.
965 + *
966 + * @return void
967 + */
493 968 function force_recount_all_terms() {
494 969 global $wpdb;
495 970
496 971 // Get all taxonomies
@@ -495,8 +970,9 @@
495 970
496 971 // Get all taxonomies
497 972 $taxonomies = get_taxonomies([], 'names');
498 973
974 + // Recount terms for each registered taxonomy.
499 975 foreach ($taxonomies as $taxonomy) {
500 976 // Get all terms for the taxonomy
501 977 $terms = get_terms([
502 978 'taxonomy' => $taxonomy,
@@ -520,91 +996,35 @@
520 996 echo "Term counts have been recalculated for all taxonomies.";
521 997 }
522 998
523 999
524 -/*
525 - *
526 - * create dropdown list
527 - *
528 - *
529 - */
530 -function mlsiport_mls_select_list( $key, $value, $data_array ) {
531 - $select = '<select class="mlsimport-2025-select" id="' . esc_attr( $key ) . '" name="mlsimport_admin_options[' . $key . ']">';
532 - if ( is_array( $data_array ) ) :
533 - foreach ( $data_array as $key => $mls_item ) {
534 - $select .= '<option value="' .esc_attr( $key ). '"';
535 - if ( intval( $value ) === intval( $key ) ) {
536 - $select .= ' selected ';
537 - }
538 - $select .= '>' .esc_html( $mls_item ). '</option>';
539 - }
540 - endif;
541 - $select .= '</select>';
542 - return $select;
543 -}
1000 +// The theme <select> builder lives in includes/mlsimport-theme-detection.php,
1001 +// next to mlsimport_resolve_theme_id() whose answer it renders (#242).
544 1002
545 1003
546 1004
547 -add_action('wp_ajax_mlsimport_save_account', 'mlsimport_save_account_callback');
548 -function mlsimport_save_account_callback() {
549 - check_ajax_referer('mlsimport_onboarding_nonce', 'security');
1005 +// mlsimport_save_account_callback() (wp_ajax_mlsimport_save_account) lives in
1006 +// includes/mlsimport-onboarding.php with the wizard code that submits it. This
1007 +// also keeps the live credential-save path loadable by the focused credential
1008 +// sanitization and token-purge regression harnesses.
550 1009
551 - $options = get_option('mlsimport_admin_options', []);
552 - if ( ! empty($_POST['mlsimport_username']) && ! empty($_POST['mlsimport_password']) ) {
553 - $options['mlsimport_username'] = sanitize_text_field($_POST['mlsimport_username']);
554 - $options['mlsimport_password'] = sanitize_text_field($_POST['mlsimport_password']);
555 - update_option('mlsimport_admin_options', $options);
556 - }
557 1010
558 - global $mlsimport;
559 1011
560 - // Refresh token
561 - $token = $mlsimport->admin->mlsimport_saas_get_mls_api_token_from_transient();
562 1012
563 - if (trim($token) === '') {
564 - ob_start();
565 -
566 - ?>
567 - <div class="mlsimport_warning">
568 - <?php esc_html_e('You are not connected to MlsImport - Please check your Username and Password.', 'mlsimport'); ?>
569 - </div>
570 - <?php
571 - $html = ob_get_clean();
572 1013
573 - wp_send_json_success([
574 - 'message' => __('You are not connected.', 'mlsimport'),
575 - 'html' => $html,
576 - 'connected' => false
577 - ]);
578 - } else {
579 - ob_start();
580 - ?>
581 - <div class="mlsimport_warning mlsimport_validated">
582 - <?php esc_html_e('You are connected to your MlsImport account!', 'mlsimport'); ?>
583 - </div>
584 - <?php
585 - $html = ob_get_clean();
586 1014
587 - wp_send_json_success([
588 - 'message' => __('Connected successfully!', 'mlsimport'),
589 - 'html' => $html,
590 - 'connected' => true
591 - ]);
592 - }
593 -}
594 -
595 -
596 -
597 -
598 -
599 -
600 -
601 -
602 1015 add_action('wp_ajax_mlsimport_save_mls_data', 'mlsimport_save_mls_data_callback');
603 1016 function mlsimport_save_mls_data_callback() {
604 1017 check_ajax_referer('mlsimport_onboarding_nonce', 'security');
1018 + if ( ! current_user_can( 'manage_options' ) ) {
1019 + wp_send_json_error( array( 'message' => 'Unauthorized' ), 403 );
1020 + }
605 1021
606 1022 $options = get_option('mlsimport_admin_options', []);
1023 + $options = is_array( $options ) ? $options : array();
1024 + $previous_mls_id = isset( $options['mlsimport_mls_name'] )
1025 + ? (string) $options['mlsimport_mls_name']
1026 + : '';
607 1027
608 1028 foreach ($_POST as $key => $value) {
609 1029 if (strpos($key, 'mlsimport_') === 0 && $key !== 'mlsimport_username' && $key !== 'mlsimport_password') {
610 1030 $options[$key] = sanitize_text_field($value);
@@ -610,20 +1030,34 @@
610 1030 $options[$key] = sanitize_text_field($value);
611 1031 }
612 1032 }
613 1033
1034 + // An MLS change invalidates only state owned by the old selection. Provider
1035 + // credentials remain saved so returning to that provider restores its fields.
1036 + $new_mls_id = isset( $options['mlsimport_mls_name'] )
1037 + ? (string) $options['mlsimport_mls_name']
1038 + : '';
1039 + if ( $previous_mls_id !== $new_mls_id ) {
1040 + Mlsimport_Provider_Family::clear_active_state();
1041 + } else {
1042 + Mlsimport_Provider_Family::clear_access_tokens();
1043 + delete_option( 'mlsimport_connection_test' );
1044 + }
1045 +
1046 + // Saving credentials always forces a fresh metadata gather for the SAVED
1047 + // MLS. The populated flag is per-connection (#275): only this connection's
1048 + // flag is cleared — other connections' gathered state stays isolated.
1049 + mlsimport_delete_connection_option( 'mlsimport_mls_metadata_populated', (int) $new_mls_id );
1050 +
614 1051 update_option('mlsimport_admin_options', $options);
615 1052
616 - // Run MLS connection check
1053 + // Always test the newly saved selection. Reusing a prior "yes" flag could
1054 + // incorrectly report that a different MLS or changed credentials succeeded.
617 1055 global $mlsimport;
1056 + $mlsimport->admin->mlsimport_saas_setting_up();
1057 + $mlsimport->admin->mlsimport_saas_check_mls_connection();
618 1058 $is_mls_connected = get_option('mlsimport_connection_test', '');
619 - $mlsimport->admin->mlsimport_saas_setting_up();
620 1059
621 - if ('yes' !== $is_mls_connected) {
622 - $mlsimport->admin->mlsimport_saas_check_mls_connection();
623 - $is_mls_connected = get_option('mlsimport_connection_test', '');
624 - }
625 -
626 1060 ob_start();
627 1061 if ('yes' === $is_mls_connected) {
628 1062 ?>
629 1063 <div class="mlsimport_warning mlsimport_validated">
@@ -644,6 +1078,4 @@
644 1078 'html' => $html,
645 1079 'connected' => $is_mls_connected === 'yes',
646 1080 ]);
647 1081 }
648 -
649 -