feat: add hook and parameter to inverse operations (#27)

README.md

@@ -96,6 +96,7 @@ components:
 
 |Name|Description|Required|Default|
 |---|---|---|---|
+|inverseOperations|Generate an application that will publish messages to `publish` operation of channels and read messages from `subscribe` operation of channels. Literally this flag will simply swap `publish` and `subscribe` operations in the channels. <br> This flag will be useful when you want to generate a code of mock for your main application. Be aware, generation could be incomplete and manual changes will be required e.g. if bindings are defined only for case of main application.|No|`false`|
 |listenerPollTimeout|Only for Kafka. Timeout in ms to use when polling the consumer.|No|`3000`|
 |listenerConcurrency|Only for Kafka. Number of threads to run in the listener containers.|No|`3`|
 |asyncapiFileDir| Path where original AsyncAPI file will be stored.|No|`src/main/resources/api/`|
@@ -143,7 +144,7 @@ See the list of features that are still missing in the component:
 - [ ] [`security schemas`](https://github.com/asyncapi/asyncapi/blob/master/versions/2.0.0/asyncapi.md#securitySchemeObject) are not supported
 - [ ] [`traits`](https://github.com/asyncapi/asyncapi/blob/master/versions/2.0.0/asyncapi.md#operationTraitObject) are not supported
 - [ ] Json serializer/desirializer is used always, without taking into account real [`content type`](https://github.com/asyncapi/asyncapi/blob/master/versions/2.0.0/asyncapi.md#default-content-type)
-- [ ] client side generation mode (in general just flip subscribe and publish channels)
+- [x] client side generation mode (in general just flip subscribe and publish channels)
 - [ ] template generation of docker-compose depending on protocol of server, now the rabbitmq is hardcoded
 
 If you want to help us develop them, feel free to contribute.

hooks/inverseOperations.js

@@ -0,0 +1,19 @@
+module.exports = {
+    'generate:before': generator => {
+        if (generator.templateParams && generator.templateParams['inverseOperations'] === 'true') {
+            console.log("Operations are inverted!");
+            const asyncapi = generator.asyncapi;
+            for (let [key, value] of Object.entries(asyncapi.channels())) {
+                let publish = value._json.publish;
+                value._json.publish = value._json.subscribe;
+                value._json.subscribe = publish;
+                if (!value._json.subscribe) {
+                    delete value._json.subscribe;
+                }
+                if (!value._json.publish) {
+                    delete value._json.publish;
+                }
+            }
+        }
+    }
+};

package.json

@@ -71,6 +71,11 @@
       "**/*.jar"
     ],
     "parameters": {
+      "inverseOperations": {
+        "description": "Generate application that will publish messages to `publish` operation of channels and read messages from `subscribe` operation of channels. Literally this flag just swap `publish` and `subscribe` operations in channels.",
+        "default": false,
+        "required": false
+      },
       "listenerPollTimeout": {
         "description": "Only for Kafka. Timeout to use when polling the consumer.",
         "default": 3000,