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 +547 -114 6.3.77.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.7
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.7');
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,14 +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';
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';
144 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';
145 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';
146 280 require_once plugin_dir_path( __FILE__ ) . 'includes/class-mlsimport.php';
147 281 require_once plugin_dir_path( __FILE__ ) . 'includes/ThemeImport.php';
282 +require_once plugin_dir_path( __FILE__ ) . 'enviroment/StandaloneClass.php';
148 283 require_once plugin_dir_path( __FILE__ ) . 'enviroment/ResidenceClass.php';
149 284 require_once plugin_dir_path( __FILE__ ) . 'enviroment/EstateClass.php';
150 285 require_once plugin_dir_path( __FILE__ ) . 'enviroment/HouzezClass.php';
151 286 require_once plugin_dir_path( __FILE__ ) . 'enviroment/RealHomesClass.php';
@@ -153,17 +288,161 @@
153 288 require_once plugin_dir_path( __FILE__ ) . 'enviroment/SparkResoClass.php';
154 289 require_once plugin_dir_path( __FILE__ ) . 'enviroment/BridgeResoClass.php';
155 290 require_once plugin_dir_path( __FILE__ ) . 'enviroment/TresleResoClass.php';
156 291 require_once plugin_dir_path( __FILE__ ) . 'enviroment/MlsgridResoClass.php';
157 -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';
158 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';
159 300 require_once plugin_dir_path( __FILE__ ) . 'includes/mlsimport-onboarding.php';
160 301
302 +require_once plugin_dir_path( __FILE__ ) . 'includes/class-mlsimport-field-configuration.php';
161 303 require_once plugin_dir_path( __FILE__ ) . 'includes/mlsimport-field-selector-functions.php';
162 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';
163 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';
164 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';
165 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 +
166 445 if ( ! wp_next_scheduled( 'event_mls_import_auto' ) ) {
167 446 wp_schedule_event( time(), 'hourly', 'event_mls_import_auto' );
168 447 }
169 448
@@ -179,9 +458,11 @@
179 458 * Optimizations:
180 459 * - Uses 'fields' => 'ids' so only post IDs are loaded (saves memory)
181 460 * - Batches with posts_per_page/paged, so memory does not spike for large data sets
182 461 * - Calls gc_collect_cycles() periodically to further reduce memory leaks
183 - * - 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
184 465 *
185 466 * @return void
186 467 */
187 468 add_action('event_mls_import_auto', 'mlsimport_saas_event_mls_import_auto_function');
@@ -193,34 +474,89 @@
193 474 global $mlsimport;
194 475
195 476 //error_log('[AutoCron] Start: ' . (memory_get_usage(true) / 1024 / 1024) . ' MB');
196 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 +
197 513 // 1. Get the API token from transient - exit if not set
198 514 $token = $mlsimport->admin->mlsimport_saas_get_mls_api_token_from_transient();
199 515 //error_log('[AutoCron] After token fetch: ' . (memory_get_usage(true) / 1024 / 1024) . ' MB');
200 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' );
201 521 //error_log('[AutoCron] No token, exiting.');
202 522 return;
203 523 }
204 524
205 - // 2. Check if MLS connection is valid - exit if not
206 - $is_mls_connected = get_option('mlsimport_connection_test', '');
207 - //error_log('[AutoCron] After connection check: ' . (memory_get_usage(true) / 1024 / 1024) . ' MB');
208 - if ('yes' !== $is_mls_connected) {
209 - //error_log('[AutoCron] No valid connection, exiting.');
210 - return;
211 - }
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.
212 529
213 - // Record sync attempt in telemetry
214 - 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.
215 548 mlsimport_telemetry_set( 'last_sync_attempt', time() );
216 549
217 - // 3. Set batch size for processing and initialize loop variables
550 + // 3. Set batch size for gathering and initialize loop variables
218 551 $batch_size = 100;
219 552 $paged = 1;
220 553 $total_processed = 0;
221 554
222 - // 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();
223 559 do {
224 560 // Prepare query: only IDs, filter by meta key, batch, paged, no_found_rows speeds up query
225 561 $args = array(
226 562 'post_type' => 'mlsimport_item',
@@ -239,43 +575,101 @@
239 575 );
240 576
241 577 // Get post IDs for this batch
242 578 $post_ids = get_posts($args);
243 - //error_log("[AutoCron] Batch {$paged} fetched " . count($post_ids) . " items, memory: " . (memory_get_usage(true) / 1024 / 1024) . ' MB');
244 579
245 - // If nothing is returned, break the loop
580 + // If nothing is returned, the gather is complete
246 581 if (empty($post_ids)) {
247 582 break;
248 583 }
249 584
250 - // 5. Loop through each post ID in this batch
251 585 foreach ($post_ids as $prop_id) {
252 - $logs = 'Loop custom post: ' . $prop_id . PHP_EOL;
253 - mlsimport_debuglogs_per_plugin($logs);
586 + $cron_task_ids[] = (int) $prop_id;
587 + }
254 588
255 - // Call processing function for this item. The feed count it pulls
256 - // is recorded inside mlsimport_make_listing_requests() (last_feed_found).
257 - $mlsimport->admin->mlsimport_saas_start_cron_links_per_item($prop_id);
589 + // Prepare next batch
590 + $paged++;
591 + unset($post_ids); // Free memory
258 592
259 - $total_processed++;
593 + } while (true);
260 594
261 - // Free memory every 100 processed items
262 - if ($total_processed % 100 === 0) {
263 - gc_collect_cycles();
264 - //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'] );
265 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;
266 640 }
267 641
268 - // 6. Prepare next batch
269 - $paged++;
270 - unset($post_ids); // Free memory
271 - gc_collect_cycles(); // Trigger garbage collection
272 - //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);
273 645
274 - } while (true);
646 + $total_processed++;
275 647
276 - mlsimport_telemetry_set( 'last_sync_success', time() );
648 + // Heartbeat (#208): measurable progress for the stuck-run check.
649 + mlsimport_cron_heartbeat_progress( $total_processed );
277 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 +
278 672 //error_log('[AutoCron] Done, total processed: ' . $total_processed . ', end memory: ' . (memory_get_usage(true) / 1024 / 1024) . ' MB');
279 673 }
280 674
281 675
@@ -291,8 +685,9 @@
291 685 wp_schedule_event( time(), 'daily', 'mlsimport_reconciliation_event' );
292 686 }
293 687
294 688 add_action( 'mlsimport_reconciliation_event', 'mlsimport_saas_reconciliation_event_function' );
689 +add_action( 'mlsimport_reconciliation_retry_event', 'mlsimport_saas_reconciliation_event_function' );
295 690
296 691 if ( ! wp_next_scheduled( 'mlsimport_daily_telemetry_event' ) ) {
297 692 wp_schedule_event( time(), 'daily', 'mlsimport_daily_telemetry_event' );
298 693 }
@@ -306,8 +701,17 @@
306 701 *
307 702 *
308 703 **/
309 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 + */
310 714 function mlsimport_force_use_transient( $value ) {
311 715 return $value;
312 716 // return false;
313 717 }
@@ -314,8 +718,9 @@
314 718
315 719
316 720
317 721
722 +// Instantiate the core orchestrator and register all admin/public hooks.
318 723 global $mlsimport;
319 724 $mlsimport = new Mlsimport();
320 725 $mlsimport->run();
321 726
@@ -322,9 +727,12 @@
322 727
323 728
324 729
325 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.
326 733 $supported_theme = array(
734 + 990 => 'Standalone (any theme)',
327 735 991 => 'WpResidence',
328 736 992 => 'Houzez',
329 737 993 => 'Real Homes',
330 738 994 => 'Wpestate',
@@ -330,11 +738,18 @@
330 738 994 => 'Wpestate',
331 739
332 740 );
333 741
742 +// Expose the theme map as a constant for use across the plugin.
334 743 define( 'MLSIMPORT_THEME', $supported_theme );
335 744
336 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 + */
337 752 function mlsimport_saas_filter_timelimit( $time_limit ) {
338 753 return 3000;
339 754 }
340 755
@@ -345,19 +760,29 @@
345 760 * Write logs
346 761 *
347 762 **/
348 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 + */
349 771 function mlsimport_saas_single_write_import_custom_logs( $message, $tip_import = 'normal' ) {
350 772 // Check if logging is enabled
351 773 $enable_logs = intval( get_option( 'mlsimport_disable_logs' ) );
774 + // Bail unless the "logs enabled" option equals exactly 1.
352 775 if ( 1 !== $enable_logs) {
353 776 return;
354 777 }
355 778
779 + // Encode array payloads to JSON so they can be written as text.
356 780 if ( is_array( $message ) ) {
357 781 $message = wp_json_encode( $message );
358 782 }
359 783
784 + // Prefix the message with a UTC timestamp.
360 785 $formatted_message = gmdate( 'F j, Y, g:i a' ) . ' -> ' . $message;
361 786
362 787 // Determine the log file path based on the import type
363 788 $log_file_name = 'cron' === $tip_import ? 'cron_logs' :
@@ -393,10 +818,20 @@
393 818 **/
394 819
395 820
396 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 + */
397 831 function mlsimport_debuglogs_per_plugin_old( $message ) {
398 832
833 + // Encode array payloads to JSON.
399 834 if ( is_array( $message ) ) {
400 835 $message = wp_json_encode( $message );
401 836 }
402 837
@@ -408,18 +843,27 @@
408 843
409 844 $path_status = WP_PLUGIN_DIR . '/mlsimport/logs/status_logs.log';
410 845 file_put_contents( $path_status, $message, LOCK_EX );
411 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 + */
412 853 function mlsimport_debuglogs_per_plugin( $message ) {
413 854
855 + // Encode array payloads to JSON.
414 856 if ( is_array( $message ) ) {
415 857 $message = wp_json_encode( $message );
416 858 }
417 859
860 + // Nothing to write for an empty message.
418 861 if ( empty( $message ) ) {
419 862 return; // Exit the function if there's nothing to log
420 863 }
421 864
865 + // Target log file inside the plugin's logs/ directory.
422 866 $log_file_path = WP_PLUGIN_DIR . '/mlsimport/logs/status_logs.log';
423 867
424 868 // Check and create the directory for logs if it does not exist
425 869 $log_dir = dirname( $log_file_path );
@@ -449,18 +893,32 @@
449 893
450 894
451 895 // */5 * * * * wget http://example.com/check */2
452 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 + */
453 905 function mlsimport_trigger_cron_job() {
454 906 // ?mlsimport_cron=yes
907 + // Only proceed when the request carries mlsimport_cron=yes.
455 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).
456 910 $last_run = intval( get_option( 'mlsimport_last_server_cron' ) );
911 + // Current time.
457 912 $now = time();
913 + // First-ever call: seed the last-run timestamp.
458 914 if ( 0 === intval($last_run) ) {
459 915 update_option( 'mlsimport_last_server_cron', $now );
460 916 }
461 917
918 + // Only run if at least 2 hours have elapsed since the last run.
462 919 if ( $last_run < $now - ( 60 * 60 * 2 ) ) {
920 + // Build the "triggered" log line and record the new run time.
463 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;
464 922 // mlsimport_saas_event_mls_import_auto_function();
465 923 update_option( 'mlsimport_last_server_cron', $now );
466 924 } else {
@@ -472,13 +930,23 @@
472 930 }
473 931
474 932
475 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 + */
476 941 function mlsimport_show_signup() {
942 + // Default sign-up URL.
477 943 $affiliate_url = 'https://mlsimport.com';
944 + // Swap in the WpResidence affiliate/campaign link when that theme is active.
478 945 if ( function_exists( 'wp_estate_init' ) ) {
479 946 $affiliate_url = 'https://mlsimport.com/ref/1/?campaign=wpresidence';
480 947 }
948 + // Output the promo markup.
481 949 ?>
482 950 <div class="mlsimport_signup">
483 951 <h3><?php esc_html_e('Import MLS Listings into your Real Estate website', 'mlsimport'); ?></h3>
484 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>
@@ -488,8 +956,16 @@
488 956 }
489 957
490 958
491 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 + */
492 968 function force_recount_all_terms() {
493 969 global $wpdb;
494 970
495 971 // Get all taxonomies
@@ -494,8 +970,9 @@
494 970
495 971 // Get all taxonomies
496 972 $taxonomies = get_taxonomies([], 'names');
497 973
974 + // Recount terms for each registered taxonomy.
498 975 foreach ($taxonomies as $taxonomy) {
499 976 // Get all terms for the taxonomy
500 977 $terms = get_terms([
501 978 'taxonomy' => $taxonomy,
@@ -519,91 +996,35 @@
519 996 echo "Term counts have been recalculated for all taxonomies.";
520 997 }
521 998
522 999
523 -/*
524 - *
525 - * create dropdown list
526 - *
527 - *
528 - */
529 -function mlsiport_mls_select_list( $key, $value, $data_array ) {
530 - $select = '<select class="mlsimport-2025-select" id="' . esc_attr( $key ) . '" name="mlsimport_admin_options[' . $key . ']">';
531 - if ( is_array( $data_array ) ) :
532 - foreach ( $data_array as $key => $mls_item ) {
533 - $select .= '<option value="' .esc_attr( $key ). '"';
534 - if ( intval( $value ) === intval( $key ) ) {
535 - $select .= ' selected ';
536 - }
537 - $select .= '>' .esc_html( $mls_item ). '</option>';
538 - }
539 - endif;
540 - $select .= '</select>';
541 - return $select;
542 -}
1000 +// The theme <select> builder lives in includes/mlsimport-theme-detection.php,
1001 +// next to mlsimport_resolve_theme_id() whose answer it renders (#242).
543 1002
544 1003
545 1004
546 -add_action('wp_ajax_mlsimport_save_account', 'mlsimport_save_account_callback');
547 -function mlsimport_save_account_callback() {
548 - 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.
549 1009
550 - $options = get_option('mlsimport_admin_options', []);
551 - if ( ! empty($_POST['mlsimport_username']) && ! empty($_POST['mlsimport_password']) ) {
552 - $options['mlsimport_username'] = sanitize_text_field($_POST['mlsimport_username']);
553 - $options['mlsimport_password'] = sanitize_text_field($_POST['mlsimport_password']);
554 - update_option('mlsimport_admin_options', $options);
555 - }
556 1010
557 - global $mlsimport;
558 1011
559 - // Refresh token
560 - $token = $mlsimport->admin->mlsimport_saas_get_mls_api_token_from_transient();
561 1012
562 - if (trim($token) === '') {
563 - ob_start();
564 -
565 - ?>
566 - <div class="mlsimport_warning">
567 - <?php esc_html_e('You are not connected to MlsImport - Please check your Username and Password.', 'mlsimport'); ?>
568 - </div>
569 - <?php
570 - $html = ob_get_clean();
571 1013
572 - wp_send_json_success([
573 - 'message' => __('You are not connected.', 'mlsimport'),
574 - 'html' => $html,
575 - 'connected' => false
576 - ]);
577 - } else {
578 - ob_start();
579 - ?>
580 - <div class="mlsimport_warning mlsimport_validated">
581 - <?php esc_html_e('You are connected to your MlsImport account!', 'mlsimport'); ?>
582 - </div>
583 - <?php
584 - $html = ob_get_clean();
585 1014
586 - wp_send_json_success([
587 - 'message' => __('Connected successfully!', 'mlsimport'),
588 - 'html' => $html,
589 - 'connected' => true
590 - ]);
591 - }
592 -}
593 -
594 -
595 -
596 -
597 -
598 -
599 -
600 -
601 1015 add_action('wp_ajax_mlsimport_save_mls_data', 'mlsimport_save_mls_data_callback');
602 1016 function mlsimport_save_mls_data_callback() {
603 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 + }
604 1021
605 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 + : '';
606 1027
607 1028 foreach ($_POST as $key => $value) {
608 1029 if (strpos($key, 'mlsimport_') === 0 && $key !== 'mlsimport_username' && $key !== 'mlsimport_password') {
609 1030 $options[$key] = sanitize_text_field($value);
@@ -609,20 +1030,34 @@
609 1030 $options[$key] = sanitize_text_field($value);
610 1031 }
611 1032 }
612 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 +
613 1051 update_option('mlsimport_admin_options', $options);
614 1052
615 - // 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.
616 1055 global $mlsimport;
1056 + $mlsimport->admin->mlsimport_saas_setting_up();
1057 + $mlsimport->admin->mlsimport_saas_check_mls_connection();
617 1058 $is_mls_connected = get_option('mlsimport_connection_test', '');
618 - $mlsimport->admin->mlsimport_saas_setting_up();
619 1059
620 - if ('yes' !== $is_mls_connected) {
621 - $mlsimport->admin->mlsimport_saas_check_mls_connection();
622 - $is_mls_connected = get_option('mlsimport_connection_test', '');
623 - }
624 -
625 1060 ob_start();
626 1061 if ('yes' === $is_mls_connected) {
627 1062 ?>
628 1063 <div class="mlsimport_warning mlsimport_validated">
@@ -643,6 +1078,4 @@
643 1078 'html' => $html,
644 1079 'connected' => $is_mls_connected === 'yes',
645 1080 ]);
646 1081 }
647 -
648 -