19214aff18
1. "What Goes Up Must Come Down" – if you subscribe to message bus, make sure you also unsubscribe 2. When you unsubscribe - remove only your subscription, not **all** subscriptions on given channel Attempt #2. The first attempt tried to extend a core `@bound` method in new-user-narrative plugin which did not work. I reworked that plugin in the meantime. This new PR also cleans up message bus subscriptions in now core-merged chat plugin.
89 lines
2.8 KiB
JavaScript
89 lines
2.8 KiB
JavaScript
import DiscourseURL from "discourse/lib/url";
|
|
import { isDevelopment } from "discourse-common/config/environment";
|
|
import discourseLater from "discourse-common/lib/later";
|
|
import { bind } from "discourse-common/utils/decorators";
|
|
|
|
// Use the message bus for live reloading of components for faster development.
|
|
export default {
|
|
name: "live-development",
|
|
|
|
initialize(container) {
|
|
this.messageBus = container.lookup("service:message-bus");
|
|
const session = container.lookup("service:session");
|
|
|
|
// Preserve preview_theme_id=## and pp=async-flamegraph parameters across pages
|
|
const params = new URLSearchParams(window.location.search);
|
|
const previewThemeId = params.get("preview_theme_id");
|
|
const flamegraph = params.get("pp") === "async-flamegraph";
|
|
if (flamegraph || previewThemeId !== null) {
|
|
["replaceState", "pushState"].forEach((funcName) => {
|
|
const originalFunc = window.history[funcName];
|
|
|
|
window.history[funcName] = (stateObj, name, rawUrl) => {
|
|
const url = new URL(rawUrl, window.location);
|
|
if (previewThemeId !== null) {
|
|
url.searchParams.set("preview_theme_id", previewThemeId);
|
|
}
|
|
if (flamegraph) {
|
|
url.searchParams.set("pp", "async-flamegraph");
|
|
}
|
|
|
|
return originalFunc.call(window.history, stateObj, name, url.href);
|
|
};
|
|
});
|
|
}
|
|
|
|
// Useful to export this for debugging purposes
|
|
if (isDevelopment()) {
|
|
window.DiscourseURL = DiscourseURL;
|
|
}
|
|
|
|
// Observe file changes
|
|
this.messageBus.subscribe(
|
|
"/file-change",
|
|
this.onFileChange,
|
|
session.mbLastFileChangeId
|
|
);
|
|
},
|
|
|
|
teardown() {
|
|
this.messageBus.unsubscribe("/file-change", this.onFileChange);
|
|
},
|
|
|
|
@bind
|
|
onFileChange(data) {
|
|
data.forEach((me) => {
|
|
if (me === "refresh") {
|
|
// Refresh if necessary
|
|
document.location.reload(true);
|
|
} else if (me.new_href && me.target) {
|
|
let query = `link[data-target='${me.target}']`;
|
|
|
|
if (me.theme_id) {
|
|
query += `[data-theme-id='${me.theme_id}']`;
|
|
}
|
|
|
|
const links = document.querySelectorAll(query);
|
|
|
|
if (links.length > 0) {
|
|
const lastLink = links[links.length - 1];
|
|
|
|
// this check is useful when message-bus has multiple file updates
|
|
// it avoids the browser doing a lot of work for nothing
|
|
// should the filenames be unchanged
|
|
if (lastLink.href.split("/").pop() !== me.new_href.split("/").pop()) {
|
|
this.refreshCSS(lastLink, me.new_href);
|
|
}
|
|
}
|
|
}
|
|
});
|
|
},
|
|
|
|
refreshCSS(node, newHref) {
|
|
const reloaded = node.cloneNode(true);
|
|
reloaded.href = newHref;
|
|
node.insertAdjacentElement("afterend", reloaded);
|
|
discourseLater(() => node?.parentNode?.removeChild(node), 500);
|
|
},
|
|
};
|