feat: add mercure to vue.js template (#313)

Author: Shywim

.github/workflows/ci.yml

@@ -27,6 +27,7 @@ jobs:
     - run: yarn test-gen
     - run: yarn test-next-app
     - run: yarn test-react-app
+    - run: yarn test-vue-app
     - run: yarn test-gen-env
     - run: yarn test-gen-openapi3
     - run: yarn check

package.json

@@ -65,7 +65,8 @@
     "test-gen-custom": "rm -rf ./tmp && yarn build && babel src/generators/ReactGenerator.js src/generators/BaseGenerator.js -d ./tmp/gens && cp -r ./templates/react ./templates/react-common ./templates/entrypoint.js ./tmp/gens && ./lib/index.js https://demo.api-platform.com ./tmp/react-custom -g \"$(pwd)/tmp/gens/ReactGenerator.js\" -t ./tmp/gens",
     "test-gen-env": "rm -rf ./tmp && yarn build && API_PLATFORM_CLIENT_GENERATOR_ENTRYPOINT=https://demo.api-platform.com API_PLATFORM_CLIENT_GENERATOR_OUTPUT=./tmp ./lib/index.js",
     "test-react-app": "rm -rf ./tmp/app && mkdir -p ./tmp/app && yarn create react-app ./tmp/app/reactapp && yarn --cwd ./tmp/app/reactapp add react-router-dom@5 redux redux-thunk react-redux redux-form connected-react-router && cp -R ./tmp/react/* ./tmp/app/reactapp/src && cp ./templates/react/index.js ./tmp/app/reactapp/src && start-server-and-test 'BROWSER=none yarn --cwd ./tmp/app/reactapp start' http://127.0.0.1:3000/books/ 'yarn playwright test'",
-    "test-next-app": "rm -rf ./tmp/app && mkdir -p ./tmp/app && yarn create next-app --typescript ./tmp/app/next && yarn --cwd ./tmp/app/next add isomorphic-unfetch formik react-query && cp -R ./tmp/next/* ./tmp/app/next && rm ./tmp/app/next/pages/index.tsx && rm -rf ./tmp/app/next/pages/api && yarn --cwd ./tmp/app/next build && start-server-and-test 'yarn --cwd ./tmp/app/next start' http://127.0.0.1:3000/books/ 'yarn playwright test'"
+    "test-next-app": "rm -rf ./tmp/app && mkdir -p ./tmp/app && yarn create next-app --typescript ./tmp/app/next && yarn --cwd ./tmp/app/next add isomorphic-unfetch formik react-query && cp -R ./tmp/next/* ./tmp/app/next && rm ./tmp/app/next/pages/index.tsx && rm -rf ./tmp/app/next/pages/api && yarn --cwd ./tmp/app/next build && start-server-and-test 'yarn --cwd ./tmp/app/next start' http://127.0.0.1:3000/books/ 'yarn playwright test'",
+    "test-vue-app": "rm -rf ./tmp/app && mkdir -p ./tmp/app && cd ./tmp/app && npm init -y vue@2 -- --router vue && cd ../.. && yarn --cwd ./tmp/app/vue add vuex@3 vuex-map-fields lodash && cp -R ./tmp/vue/* ./tmp/app/vue/src && cp ./templates/vue/main.js ./tmp/app/vue/src && yarn --cwd ./tmp/app/vue build && start-server-and-test 'yarn --cwd ./tmp/app/vue vite preview --host 127.0.0.1 --port 3000' http://127.0.0.1:3000/books/ 'yarn playwright test'"
   },
   "lint-staged": {
     "src/**/*.js": "yarn lint --fix"

src/generators/ReactGenerator.js

@@ -5,6 +5,11 @@ export default class extends BaseGenerator {
   constructor(params) {
     super(params);
 
+    this.registerTemplates("common/", [
+      // utils
+      "utils/mercure.js",
+    ]);
+
     this.registerTemplates("react-common/", [
       // actions
       "actions/foo/create.js",
@@ -130,6 +135,7 @@ combineReducers({ ${titleLc},/* ... */ }),
       context,
       false
     );
+    this.createFile("utils/mercure.js", `${dir}/utils/mercure.js`);
 
     this.createEntrypoint(api.entrypoint, `${dir}/config/entrypoint.js`);
   }

src/generators/ReactNativeGenerator.js

@@ -13,6 +13,11 @@ export default class extends BaseGenerator {
       return options.inverse(this);
     });
 
+    this.registerTemplates("common/", [
+      // utils
+      "utils/mercure.js",
+    ]);
+
     this.registerTemplates(`react-common/`, [
       // actions
       "actions/foo/create.js",
@@ -133,6 +138,7 @@ combineReducers({ ${titleLc}, /* ... */ }),
 
     [
       "utils/dataAccess.js",
+      "utils/mercure.js",
       "utils/helpers.js",
       "components/Spinner.js",
       "components/Confirm.js",

src/generators/VueGenerator.js

@@ -5,6 +5,11 @@ export default class extends BaseGenerator {
   constructor(params) {
     super(params);
 
+    this.registerTemplates("common/", [
+      // utils
+      "utils/mercure.js",
+    ]);
+
     this.registerTemplates(`vue/`, [
       // modules
       "store/modules/foo/index.js",
@@ -36,6 +41,10 @@ export default class extends BaseGenerator {
       "components/foo/Update.vue",
       "components/foo/Show.vue",
 
+      // mixins
+      "mixins/ItemWatcher.js",
+      "mixins/ListWatcher.js",
+
       // routes
       "router/foo.js",
 
@@ -102,9 +111,13 @@ export const store = new Vuex.Store({
 
     // Create directories
     // These directories may already exist
-    [`${dir}/config`, `${dir}/error`, `${dir}/router`, `${dir}/utils`].forEach(
-      (dir) => this.createDir(dir, false)
-    );
+    [
+      `${dir}/config`,
+      `${dir}/error`,
+      `${dir}/mixins`,
+      `${dir}/router`,
+      `${dir}/utils`,
+    ].forEach((dir) => this.createDir(dir, false));
 
     [
       `${dir}/store/modules/${lc}`,
@@ -153,6 +166,10 @@ export const store = new Vuex.Store({
       this.createFileFromPattern(pattern, dir, lc, context)
     );
 
+    for (const file of ["mixins/ItemWatcher.js", "mixins/ListWatcher.js"]) {
+      this.createFile(file, `${dir}/${file}`);
+    }
+
     // error
     this.createFile(
       "error/SubmissionError.js",
@@ -174,5 +191,6 @@ export const store = new Vuex.Store({
       { hydraPrefix: this.hydraPrefix },
       false
     );
+    this.createFile("utils/mercure.js", `${dir}/utils/mercure.js`);
   }
 }

templates/common/utils/mercure.js

@@ -0,0 +1,23 @@
+import { ENTRYPOINT } from "../config/entrypoint";
+
+export const mercureSubscribe = (hubURL, topics, setData) => {
+  const url = new URL(hubURL, ENTRYPOINT);
+  topics.forEach(topic =>
+    url.searchParams.append("topic", (new URL(topic, ENTRYPOINT)).toString())
+  );
+  const eventSource = new EventSource(url.toString());
+  eventSource.addEventListener("message", (event) => setData(JSON.parse(event.data)));
+
+  return eventSource;
+}
+
+export const extractHubURL = (response) => {
+  const linkHeader = response.headers.get('Link');
+  if (!linkHeader) return null;
+
+  const matches = linkHeader.match(
+    /<([^>]+)>;\s+rel=(?:mercure|"[^"]*mercure[^"]*")/
+  );
+
+  return matches && matches[1] ? new URL(matches[1], ENTRYPOINT) : null;
+}

templates/react-common/actions/foo/list.js

@@ -1,9 +1,5 @@
-import {
-  fetch,
-  normalize,
-  extractHubURL,
-  mercureSubscribe as subscribe
-} from '../../utils/dataAccess';
+import { fetch, normalize } from '../../utils/dataAccess';
+import { extractHubURL, mercureSubscribe as subscribe } from "../../utils/mercure";
 import { success as deleteSuccess } from './delete';
 
 export function error(error) {
@@ -61,11 +57,9 @@ export function reset(eventSource) {
 
 export function mercureSubscribe(hubURL, topics) {
   return dispatch => {
-    const eventSource = subscribe(hubURL, topics);
+    const eventSource = subscribe(hubURL, topics, data =>
+      dispatch(mercureMessage(normalize(data))));
     dispatch(mercureOpen(eventSource));
-    eventSource.addEventListener('message', event =>
-      dispatch(mercureMessage(normalize(JSON.parse(event.data))))
-    );
   };
 }
 

templates/react-common/actions/foo/show.js

@@ -1,9 +1,5 @@
-import {
-  fetch,
-  extractHubURL,
-  normalize,
-  mercureSubscribe as subscribe
-} from '../../utils/dataAccess';
+import { fetch, normalize } from '../../utils/dataAccess';
+import { extractHubURL, mercureSubscribe as subscribe } from "../../utils/mercure";
 
 export function error(error) {
   return { type: '{{{uc}}}_SHOW_ERROR', error };
@@ -54,11 +50,9 @@ export function reset(eventSource) {
 
 export function mercureSubscribe(hubURL, topic) {
   return dispatch => {
-    const eventSource = subscribe(hubURL, [topic]);
+    const eventSource = subscribe(hubURL, [topic], data =>
+      dispatch(mercureMessage(normalize(data))));
     dispatch(mercureOpen(eventSource));
-    eventSource.addEventListener('message', event =>
-      dispatch(mercureMessage(normalize(JSON.parse(event.data))))
-    );
   };
 }
 

templates/react-common/actions/foo/update.js

@@ -1,10 +1,6 @@
 import { SubmissionError } from 'redux-form';
-import {
-  fetch,
-  extractHubURL,
-  normalize,
-  mercureSubscribe as subscribe
-} from '../../utils/dataAccess';
+import { fetch, normalize } from '../../utils/dataAccess';
+import { extractHubURL, mercureSubscribe as subscribe } from "../../utils/mercure";
 import { success as createSuccess } from './create';
 import { loading, error } from './delete';
 
@@ -107,11 +103,9 @@ export function reset(eventSource) {
 
 export function mercureSubscribe(hubURL, topic) {
   return dispatch => {
-    const eventSource = subscribe(hubURL, [topic]);
+    const eventSource = subscribe(hubURL, [topic], data =>
+      dispatch(mercureMessage(normalize(data))));
     dispatch(mercureOpen(eventSource));
-    eventSource.addEventListener('message', event =>
-      dispatch(mercureMessage(normalize(JSON.parse(event.data))))
-    );
   };
 }
 

templates/react-common/utils/dataAccess.js

@@ -46,14 +46,6 @@ export function fetch(id, options = {}) {
   });
 }
 
-export function mercureSubscribe(url, topics) {
-  topics.forEach(topic =>
-    url.searchParams.append('topic', new URL(topic, ENTRYPOINT))
-  );
-
-  return new EventSource(url.toString());
-}
-
 export function normalize(data) {
   if (has(data, 'hydra:member')) {
     // Normalize items in collections
@@ -70,14 +62,3 @@ export function normalize(data) {
       : get(value, '@id', value)
   );
 }
-
-export function extractHubURL(response) {
-  const linkHeader = response.headers.get('Link');
-  if (!linkHeader) return null;
-
-  const matches = linkHeader.match(
-    /<([^>]+)>;\s+rel=(?:mercure|"[^"]*mercure[^"]*")/
-  );
-
-  return matches && matches[1] ? new URL(matches[1], ENTRYPOINT) : null;
-}