Abort search requests when clearing search box
Also adds abort support for Photon queries
This commit is contained in:
@@ -12,6 +12,7 @@ import { eq, or } from 'ember-truth-helpers';
|
|||||||
|
|
||||||
export default class SearchBoxComponent extends Component {
|
export default class SearchBoxComponent extends Component {
|
||||||
@service photon;
|
@service photon;
|
||||||
|
@service osm;
|
||||||
@service router;
|
@service router;
|
||||||
@service mapUi;
|
@service mapUi;
|
||||||
@service map; // Assuming we might need map context, but mostly we use router
|
@service map; // Assuming we might need map context, but mostly we use router
|
||||||
@@ -178,6 +179,11 @@ export default class SearchBoxComponent extends Component {
|
|||||||
|
|
||||||
@action
|
@action
|
||||||
clear() {
|
clear() {
|
||||||
|
this.searchTask.cancelAll();
|
||||||
|
this.mapUi.stopLoading();
|
||||||
|
this.osm.cancelAll();
|
||||||
|
this.photon.cancelAll();
|
||||||
|
|
||||||
this.query = '';
|
this.query = '';
|
||||||
this.results = [];
|
this.results = [];
|
||||||
if (this.args.onQueryChange) {
|
if (this.args.onQueryChange) {
|
||||||
|
|||||||
@@ -9,6 +9,13 @@ export default class OsmService extends Service {
|
|||||||
cachedResults = null;
|
cachedResults = null;
|
||||||
lastQueryKey = null;
|
lastQueryKey = null;
|
||||||
|
|
||||||
|
cancelAll() {
|
||||||
|
if (this.controller) {
|
||||||
|
this.controller.abort();
|
||||||
|
this.controller = null;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
async getNearbyPois(lat, lon, radius = 50) {
|
async getNearbyPois(lat, lon, radius = 50) {
|
||||||
const queryKey = `${lat},${lon},${radius}`;
|
const queryKey = `${lat},${lon},${radius}`;
|
||||||
|
|
||||||
|
|||||||
@@ -5,6 +5,15 @@ import { humanizeOsmTag } from '../utils/format-text';
|
|||||||
export default class PhotonService extends Service {
|
export default class PhotonService extends Service {
|
||||||
@service settings;
|
@service settings;
|
||||||
|
|
||||||
|
controller = null;
|
||||||
|
|
||||||
|
cancelAll() {
|
||||||
|
if (this.controller) {
|
||||||
|
this.controller.abort();
|
||||||
|
this.controller = null;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
get baseUrl() {
|
get baseUrl() {
|
||||||
return this.settings.photonApi;
|
return this.settings.photonApi;
|
||||||
}
|
}
|
||||||
@@ -12,6 +21,12 @@ export default class PhotonService extends Service {
|
|||||||
async search(query, lat, lon, limit = 10) {
|
async search(query, lat, lon, limit = 10) {
|
||||||
if (!query || query.length < 2) return [];
|
if (!query || query.length < 2) return [];
|
||||||
|
|
||||||
|
if (this.controller) {
|
||||||
|
this.controller.abort();
|
||||||
|
}
|
||||||
|
this.controller = new AbortController();
|
||||||
|
const signal = this.controller.signal;
|
||||||
|
|
||||||
const params = new URLSearchParams({
|
const params = new URLSearchParams({
|
||||||
q: query,
|
q: query,
|
||||||
limit: String(limit),
|
limit: String(limit),
|
||||||
@@ -25,7 +40,7 @@ export default class PhotonService extends Service {
|
|||||||
const url = `${this.baseUrl}?${params.toString()}`;
|
const url = `${this.baseUrl}?${params.toString()}`;
|
||||||
|
|
||||||
try {
|
try {
|
||||||
const res = await this.fetchWithRetry(url);
|
const res = await this.fetchWithRetry(url, { signal });
|
||||||
if (!res.ok) {
|
if (!res.ok) {
|
||||||
throw new Error(`Photon request failed with status ${res.status}`);
|
throw new Error(`Photon request failed with status ${res.status}`);
|
||||||
}
|
}
|
||||||
@@ -35,6 +50,9 @@ export default class PhotonService extends Service {
|
|||||||
|
|
||||||
return data.features.map((f) => this.normalizeFeature(f));
|
return data.features.map((f) => this.normalizeFeature(f));
|
||||||
} catch (e) {
|
} catch (e) {
|
||||||
|
if (e.name === 'AbortError') {
|
||||||
|
return [];
|
||||||
|
}
|
||||||
console.error('Photon search error:', e);
|
console.error('Photon search error:', e);
|
||||||
// Return empty array on error so UI doesn't break
|
// Return empty array on error so UI doesn't break
|
||||||
return [];
|
return [];
|
||||||
|
|||||||
@@ -1,10 +1,18 @@
|
|||||||
import { module, test } from 'qunit';
|
import { module, test } from 'qunit';
|
||||||
import { visit } from '@ember/test-helpers';
|
import {
|
||||||
|
visit,
|
||||||
|
click,
|
||||||
|
fillIn,
|
||||||
|
triggerEvent,
|
||||||
|
currentURL,
|
||||||
|
} from '@ember/test-helpers';
|
||||||
import { setupApplicationTest } from 'marco/tests/helpers';
|
import { setupApplicationTest } from 'marco/tests/helpers';
|
||||||
import Service from '@ember/service';
|
import Service from '@ember/service';
|
||||||
import { Promise } from 'rsvp';
|
import { Promise } from 'rsvp';
|
||||||
|
|
||||||
class MockPhotonService extends Service {
|
class MockPhotonService extends Service {
|
||||||
|
cancelAll() {}
|
||||||
|
|
||||||
async search(query) {
|
async search(query) {
|
||||||
// Simulate network delay
|
// Simulate network delay
|
||||||
await new Promise((resolve) => setTimeout(resolve, 50));
|
await new Promise((resolve) => setTimeout(resolve, 50));
|
||||||
@@ -24,6 +32,8 @@ class MockPhotonService extends Service {
|
|||||||
}
|
}
|
||||||
|
|
||||||
class MockOsmService extends Service {
|
class MockOsmService extends Service {
|
||||||
|
cancelAll() {}
|
||||||
|
|
||||||
async getCategoryPois(bounds, category) {
|
async getCategoryPois(bounds, category) {
|
||||||
await new Promise((resolve) => setTimeout(resolve, 50));
|
await new Promise((resolve) => setTimeout(resolve, 50));
|
||||||
if (category === 'slow_category') {
|
if (category === 'slow_category') {
|
||||||
@@ -94,4 +104,39 @@ module('Acceptance | search loading', function (hooks) {
|
|||||||
'Loading state is NOT set for nearby search'
|
'Loading state is NOT set for nearby search'
|
||||||
);
|
);
|
||||||
});
|
});
|
||||||
|
|
||||||
|
test('clearing search stops loading indicator', async function (assert) {
|
||||||
|
const mapUi = this.owner.lookup('service:map-ui');
|
||||||
|
|
||||||
|
// 1. Start from index
|
||||||
|
await visit('/');
|
||||||
|
|
||||||
|
// 2. Type "slow" to trigger autocomplete (which is async)
|
||||||
|
await fillIn('.search-input', 'slow');
|
||||||
|
|
||||||
|
// 3. Submit search to trigger route loading
|
||||||
|
click('.search-submit-btn'); // Intentionally no await to not block on transition
|
||||||
|
|
||||||
|
// Wait for loading state to activate
|
||||||
|
await new Promise((r) => setTimeout(r, 100));
|
||||||
|
|
||||||
|
assert.deepEqual(
|
||||||
|
mapUi.loadingState,
|
||||||
|
{ type: 'text', value: 'slow' },
|
||||||
|
'Loading state is set'
|
||||||
|
);
|
||||||
|
|
||||||
|
// 4. Click the clear button (should be visible since input has value)
|
||||||
|
await click('.search-clear-btn');
|
||||||
|
|
||||||
|
// Verify loading state is cleared immediately
|
||||||
|
assert.strictEqual(
|
||||||
|
mapUi.loadingState,
|
||||||
|
null,
|
||||||
|
'Loading state is cleared immediately after clicking clear'
|
||||||
|
);
|
||||||
|
|
||||||
|
// Verify we are back on index (or at least query is gone)
|
||||||
|
assert.strictEqual(currentURL(), '/', 'Navigated to index');
|
||||||
|
});
|
||||||
});
|
});
|
||||||
|
|||||||
Reference in New Issue
Block a user