"validator": "^10.2.0"
},
"devDependencies": {
+ "awesome-typescript-loader": "^5.2.0",
"babel-core": "^6.24.0",
"babel-eslint": "^8.2.1",
"babel-jest": "^22.1.0",
"react-test-renderer": "^16.4.1",
"sass-loader": "^6.0.6",
"source-map-loader": "^0.1.5",
+ "typescript": "^2.9.2",
"uglifyjs-webpack-plugin": "^1.1.6",
"webpack": "^4.5.0",
"webpack-api-mocker": "^1.4.3",
* See the License for the specific language governing permissions and
* limitations under the License.
*/
+
import { hot } from 'react-hot-loader';
import React, { Component } from 'react';
import { Route } from 'react-router-dom';
+import { PluginPubSub } from 'shared/pubsub/plugin-pubsub';
import 'resources/scss/style.scss';
import 'bpmn-js-properties-panel/styles/properties.less';
import { routes } from './routes';
);
class App extends Component {
- constructor(props) {
- super(props);
+ componentDidMount() {
+ const searchParams = new URLSearchParams(location.search);
+ const eventsClientId = searchParams.get('eventsClientId');
+ const parentUrl = searchParams.get('parentUrl');
+
+ if (eventsClientId && parentUrl) {
+ const client = new PluginPubSub(eventsClientId, parentUrl);
+
+ client.notify('READY');
+ }
}
render() {
import React from 'react';
import ReactDOM from 'react-dom';
import { Provider } from 'react-redux';
-import { HashRouter } from 'react-router-dom';
+import { BrowserRouter } from 'react-router-dom';
import Notifications from 'shared/notifications/Notifications';
import Loader from 'shared/loader/Loader';
<React.Fragment>
<Notifications />
<Loader />
- <HashRouter>
+ <BrowserRouter>
<React.Fragment>
<div className="workflow-app">
<App />
</div>
<ModalWrapper />
</React.Fragment>
- </HashRouter>
+ </BrowserRouter>
</React.Fragment>
</Provider>,
document.getElementById('root')
--- /dev/null
+declare const window: Window;
+
+export class BasePubSub {
+
+ subscribers: Map<string, ISubscriber>;
+ eventsCallbacks: Array<Function>;
+ clientId: string;
+ eventsToWait: Map<string, Array<string>>;
+ lastEventNotified: string;
+
+ constructor(pluginId: string) {
+ this.subscribers = new Map<string, ISubscriber>();
+ this.eventsCallbacks = [];
+ this.eventsToWait = new Map<string, Array<string>>();
+ this.clientId = pluginId;
+ this.lastEventNotified = "";
+ this.onMessage = this.onMessage.bind(this);
+
+ window.addEventListener("message", this.onMessage);
+ }
+
+ public register(subscriberId: string, subscriberWindow: Window, subscriberUrl: string) {
+ const subscriber = {
+ window: subscriberWindow,
+ locationUrl: subscriberUrl || subscriberWindow.location.href
+ } as ISubscriber;
+
+ this.subscribers.set(subscriberId, subscriber);
+ }
+
+ public unregister(subscriberId: string) {
+ this.subscribers.delete(subscriberId);
+ }
+
+ public on(callback: Function) {
+ let functionExists = this.eventsCallbacks.find((func: Function) => {
+ return callback.toString() == func.toString()
+ });
+
+ if (!functionExists) {
+ this.eventsCallbacks.push(callback);
+ }
+ }
+
+ public off(callback: Function) {
+ let index = this.eventsCallbacks.indexOf(callback);
+ this.eventsCallbacks.splice(index, 1)
+ }
+
+ public notify(eventType:string, eventData?:any) {
+ let eventObj = {
+ type: eventType,
+ data: eventData,
+ originId: this.clientId
+ } as IPubSubEvent;
+
+ this.subscribers.forEach( (subscriber: ISubscriber, subscriberId: string) => {
+ subscriber.window.postMessage(eventObj, subscriber.locationUrl);
+ });
+
+ this.lastEventNotified = eventType;
+
+ return {
+ subscribe: function(callbackFn) {
+
+ if(this.subscribers.size !== 0) {
+ let subscribersToNotify = Array.from(this.subscribers.keys());
+
+ const checkNotifyComplete = (subscriberId: string) => {
+
+ let index = subscribersToNotify.indexOf(subscriberId);
+ subscribersToNotify.splice(index, 1);
+
+ if (subscribersToNotify.length === 0) {
+ callbackFn();
+ }
+ };
+
+ this.subscribers.forEach((subscriber: ISubscriber, subscriberId: string) => {
+ if (this.eventsToWait.has(subscriberId) && this.eventsToWait.get(subscriberId).indexOf(eventType) !== -1) {
+
+ const actionCompletedFunction = (eventData, subId = subscriberId) => {
+ if (eventData.type == "ACTION_COMPLETED") {
+ checkNotifyComplete(subId);
+ }
+ this.off(actionCompletedFunction);
+
+ };
+ this.on(actionCompletedFunction);
+ }
+ else {
+ checkNotifyComplete(subscriberId);
+ }
+ });
+ }
+ else {
+ callbackFn();
+ }
+ }.bind(this)
+ }
+ }
+
+ public isWaitingForEvent(eventName: string) : boolean {
+ return Array.from(this.eventsToWait.values()).some((eventsList: Array<string>) =>
+ eventsList.indexOf(eventName) !== -1
+ );
+ }
+
+ protected onMessage(event: any) {
+ if (this.subscribers.has(event.data.originId)) {
+ this.eventsCallbacks.forEach((callback: Function) => {
+ callback(event.data, event);
+ })
+ }
+ }
+}
+
+export interface IPubSubEvent {
+ type: string;
+ originId: string;
+ data: any;
+}
+
+export interface ISubscriber {
+ window: Window;
+ locationUrl: string;
+}
--- /dev/null
+import {BasePubSub} from 'shared/pubsub/base-pubsub';
+
+declare const window: Window;
+
+export class PluginPubSub extends BasePubSub {
+
+
+ constructor(pluginId: string, parentUrl: string, eventsToWait?: Array<string>) {
+ super(pluginId);
+ this.register('sdc-hub', window.parent, parentUrl);
+ this.subscribe(eventsToWait);
+ }
+
+ public subscribe(eventsToWait?: Array<string>) {
+ const registerData = {
+ pluginId: this.clientId,
+ eventsToWait: eventsToWait || []
+ };
+
+ this.notify('PLUGIN_REGISTER', registerData);
+ }
+
+ public unsubscribe() {
+ const unregisterData = {
+ pluginId: this.clientId
+ };
+
+ this.notify('PLUGIN_UNREGISTER', unregisterData);
+ }
+}
--- /dev/null
+{
+ "compilerOptions": {
+ "strict" : false,
+ "noImplicitAny": false,
+ "outDir": "./dist/",
+ "module": "es6",
+ "target": "es5",
+ "jsx": "react",
+ "lib": ["es5", "es6", "dom"],
+ "allowJs": true
+ }
+}
devtool: DEV ? 'eval-source-map' : 'none',
resolve: {
modules: modulePath,
- extensions: ['.js', '.json', '.css', '.scss', '.jsx'],
+ extensions: ['.js', '.json', '.css', '.scss', '.jsx', '.ts'],
alias: {
wfapp: path.resolve(__dirname, 'src/'),
features: path.resolve(__dirname, 'src/features'),
{
test: /\.(bpmn|xml)$/,
loader: 'raw-loader'
+ },
+ {
+ test: /\.ts|\.tsx$/,
+ loader: ['babel-loader', 'awesome-typescript-loader'],
+ include: srcPath
}
]
},
postcss "^6.0.17"
postcss-value-parser "^3.2.3"
+awesome-typescript-loader@^5.2.0:
+ version "5.2.0"
+ resolved "https://registry.yarnpkg.com/awesome-typescript-loader/-/awesome-typescript-loader-5.2.0.tgz#d7bccf4823c45096ec24da4c12a1507d276ba15a"
+ dependencies:
+ chalk "^2.4.1"
+ enhanced-resolve "^4.0.0"
+ loader-utils "^1.1.0"
+ lodash "^4.17.5"
+ micromatch "^3.1.9"
+ mkdirp "^0.5.1"
+ source-map-support "^0.5.3"
+ webpack-log "^1.2.0"
+
aws-sign2@~0.6.0:
version "0.6.0"
resolved "https://registry.yarnpkg.com/aws-sign2/-/aws-sign2-0.6.0.tgz#14342dd38dbcc94d0e5b87d763cd63612c0e794f"
dependencies:
source-map "^0.5.6"
-source-map-support@^0.5.0:
+source-map-support@^0.5.0, source-map-support@^0.5.3:
version "0.5.6"
resolved "https://registry.yarnpkg.com/source-map-support/-/source-map-support-0.5.6.tgz#4435cee46b1aab62b8e8610ce60f788091c51c13"
dependencies:
version "0.0.6"
resolved "https://registry.yarnpkg.com/typedarray/-/typedarray-0.0.6.tgz#867ac74e3864187b1d3d47d996a78ec5c8830777"
+typescript@^2.9.2:
+ version "2.9.2"
+ resolved "https://registry.yarnpkg.com/typescript/-/typescript-2.9.2.tgz#1cbf61d05d6b96269244eb6a3bce4bd914e0f00c"
+
ua-parser-js@^0.7.18:
version "0.7.18"
resolved "https://registry.yarnpkg.com/ua-parser-js/-/ua-parser-js-0.7.18.tgz#a7bfd92f56edfb117083b69e31d2aa8882d4b1ed"
querystring "^0.2.0"
strip-ansi "^3.0.0"
-webpack-log@^1.0.1, webpack-log@^1.1.2:
+webpack-log@^1.0.1, webpack-log@^1.1.2, webpack-log@^1.2.0:
version "1.2.0"
resolved "https://registry.yarnpkg.com/webpack-log/-/webpack-log-1.2.0.tgz#a4b34cda6b22b518dbb0ab32e567962d5c72a43d"
dependencies:
Code Review / sdc / sdc-workflow-designer.git / commitdiff