mirror of
https://github.com/grafana/grafana.git
synced 2024-12-24 16:10:22 -06:00
f45eb309ef
* Fix: make webpack pickup workers written in TS * Add comlink to dependencies * Temporary fix: copy paste `toDataQueryError` from @grafana/runtime to avoid web dependencies * Implemented comlink-based centrifuge worker & worker proxy * Temporary fix: implement comlink transferHandlers for subscriptions and streamingdataframes * Move liveTimer filtering from CentrifugeService into GrafanaLiveService * Switch from CentrifugeService to CentrifugeServiceWorkerProxy in GrafanaLive * Naming fix * Refactor: move liveTimer-based data filtering from GrafanaLiveService to CentrifugeServiceWorker * observe dataStream on an async scheduler * Fix: - Unsubscribe is now propagated from the main thread to the worker, - improve worker&workerProxy types * Fix: Prettify types * Fix: Add error & complete observers * Docs: Add comment explaining the `subscriberTransferHandler` * Fix: Replace `StreamingDataFrameHandler` with explicitly converting StreamingDataFrame to a DataFrameDTO * Refactor: move liveTimer filtering to service.ts to make it easy to implement a `live-service-web-worker` feature flag * Feat: add `live-service-web-worker` feature flag * Fix: extract toDataQueryError.ts to a separate file within `@grafana-runtime` to avoid having a dependency from webworker to the whole package (@grafana-runtime/index.ts) * Update public/app/features/dashboard/dashgrid/liveTimer.ts Co-authored-by: Leon Sorokin <leeoniya@gmail.com> * Fix: fixed default import class in worker file * Fix: cast worker as Endpoint * Migrate from worker-loader to webpack native worker support v1 - broken prod build * Fix: Use custom path in HtmlWebpackPlugin * Fix: Loading workers from CDNs * Fix: Avoid issues with jest ESM support by mocking `createWorker` files * Fix: move the custom mockWorker rendering layout to `test/mocks` Co-authored-by: Leon Sorokin <leeoniya@gmail.com>
65 lines
2.0 KiB
JavaScript
65 lines
2.0 KiB
JavaScript
const { RuntimeGlobals, RuntimeModule } = require('webpack');
|
|
|
|
class CorsWorkerPublicPathRuntimeModule extends RuntimeModule {
|
|
constructor(publicPath) {
|
|
super('publicPath', RuntimeModule.STAGE_BASIC);
|
|
this.publicPath = publicPath;
|
|
}
|
|
|
|
/**
|
|
* @returns {string} runtime code
|
|
*/
|
|
generate() {
|
|
const { compilation, publicPath } = this;
|
|
|
|
const publicPathValue = compilation.getPath(publicPath || '', {
|
|
hash: compilation.hash || 'XXXX',
|
|
});
|
|
return `${RuntimeGlobals.publicPath} = __webpack_worker_public_path__ || '${publicPathValue}';`;
|
|
}
|
|
}
|
|
|
|
// https://github.com/webpack/webpack/discussions/14648#discussioncomment-1604202
|
|
// by @ https://github.com/piotr-oles
|
|
class CorsWorkerPlugin {
|
|
/**
|
|
* @param {import('webpack').Compiler} compiler
|
|
*/
|
|
apply(compiler) {
|
|
compiler.hooks.compilation.tap(
|
|
'CorsWorkerPlugin',
|
|
/**
|
|
* @param {import('webpack').Compilation} compilation
|
|
*/
|
|
(compilation) => {
|
|
const getChunkLoading = (chunk) => {
|
|
const entryOptions = chunk.getEntryOptions();
|
|
return entryOptions && entryOptions.chunkLoading !== undefined
|
|
? entryOptions.chunkLoading
|
|
: compilation.outputOptions.chunkLoading;
|
|
};
|
|
const getChunkPublicPath = (chunk) => {
|
|
const entryOptions = chunk.getEntryOptions();
|
|
return entryOptions && entryOptions.publicPath !== undefined
|
|
? entryOptions.publicPath
|
|
: compilation.outputOptions.publicPath;
|
|
};
|
|
|
|
compilation.hooks.runtimeRequirementInTree.for(RuntimeGlobals.publicPath).tap('CorsWorkerPlugin', (chunk) => {
|
|
if (getChunkLoading(chunk) === 'import-scripts') {
|
|
const publicPath = getChunkPublicPath(chunk);
|
|
|
|
if (publicPath !== 'auto') {
|
|
const module = new CorsWorkerPublicPathRuntimeModule(publicPath);
|
|
compilation.addRuntimeModule(chunk, module);
|
|
return true;
|
|
}
|
|
}
|
|
});
|
|
}
|
|
);
|
|
}
|
|
}
|
|
|
|
module.exports = CorsWorkerPlugin;
|