Merge pull request #150 from frmscoe/event-director

Event director

.env.template

@@ -1,5 +1,5 @@
 # SPDX-License-Identifier: Apache-2.0
-FUNCTION_NAME="channel-router-setup-processor"
+FUNCTION_NAME="event-director"
 NODE_ENV="dev"
 REST_PORT=3000
 CACHETTL=300

.github/workflows/node.js.yml

@@ -93,7 +93,7 @@ jobs:
         run: npm run start &
 
       - name: Test Processor
-        run: newman run https://raw.githubusercontent.com/frmscoe/postman/main/micro_processors/ChannelRouterSetupProcessor_Proxy_Test.postman_collection.json --iteration-count ${{ env.ITERATION_COUNT }} -e ${{ env.ENV_NEWMAN }} --timeout-request 10200 -r json --reporter-json-export fullReport.json
+        run: newman run https://raw.githubusercontent.com/frmscoe/postman/main/micro_processors/EventDirectorSetupProcessor_Proxy_Test.postman_collection.json --iteration-count ${{ env.ITERATION_COUNT }} -e ${{ env.ENV_NEWMAN }} --timeout-request 10200 -r json --reporter-json-export fullReport.json
 
       - name: Extract Specific Field
         id: newman_test

__tests__/postman/3.1. CRSP Quick-Check.postman_collection.json

@@ -1,7 +1,7 @@
 {
 	"info": {
 		"_postman_id": "0c0a8fb4-1cbe-4f86-8eb8-50bce0da9026",
-		"name": "3.1. CRSP Quick-Check",
+		"name": "3.1. Event Director Quick-Check",
 		"schema": "https://schema.getpostman.com/json/collection/v2.1.0/collection.json",
 		"_exporter_id": "29185806"
 	},
@@ -14,12 +14,12 @@
 					"script": {
 						"exec": [
 							"responseJSON = pm.response.json();\r",
-							"let outgoingCRSPResult = responseJSON.data;\r",
-							"let transaction = outgoingCRSPResult.transaction\r",
-							"let networkMap = outgoingCRSPResult.networkMap\r",
-							"let dataCache = outgoingCRSPResult.DataCache\r",
-							"let metaData = outgoingCRSPResult.metaData;\r",
-							"let prcgTm = outgoingCRSPResult.metaData.prcgTmCRSP;\r",
+							"let outgoingEventDirectorResult = responseJSON.data;\r",
+							"let transaction = outgoingEventDirectorResult.transaction\r",
+							"let networkMap = outgoingEventDirectorResult.networkMap\r",
+							"let dataCache = outgoingEventDirectorResult.DataCache\r",
+							"let metaData = outgoingEventDirectorResult.metaData;\r",
+							"let prcgTm = outgoingEventDirectorResult.metaData.prcgTmED;\r",
 							"let msg = networkMap.messages;\r",
 							"\r",
 							"console.log(`Networkmap message: ${JSON.stringify(msg)}`);\r",
@@ -29,19 +29,19 @@
 							"});\r",
 							"\r",
 							"pm.test('Has a transaction object', function() {\r",
-							"  pm.expect(outgoingCRSPResult).to.have.property('transaction');\r",
+							"  pm.expect(outgoingEventDirectorResult).to.have.property('transaction');\r",
 							"});\r",
 							"\r",
 							"pm.test('Has a networkMap object', function() {\r",
-							"  pm.expect(outgoingCRSPResult).to.have.property('networkMap');\r",
+							"  pm.expect(outgoingEventDirectorResult).to.have.property('networkMap');\r",
 							"});\r",
 							"\r",
 							"pm.test('Has a dataCache object', function() {\r",
-							"  pm.expect(outgoingCRSPResult).to.have.property('DataCache');\r",
+							"  pm.expect(outgoingEventDirectorResult).to.have.property('DataCache');\r",
 							"});\r",
 							"\r",
 							"pm.test('Has a metaData object', function() {\r",
-							"  pm.expect(outgoingCRSPResult).to.have.property('metaData');\r",
+							"  pm.expect(outgoingEventDirectorResult).to.have.property('metaData');\r",
 							"});\r",
 							"\r",
 							"pm.test('Networkmap message array contains typologies', function() {\r",
@@ -68,10 +68,10 @@
 							"let moment = require('moment');\r",
 							"// ## Set up rule config\r",
 							"\r",
-							"const requestDestination = `CRSP`;\r",
+							"const requestDestination = `event-director`;\r",
 							"const responseDestination = `[email protected]`;\r",
 							"\r",
-							"console.log(`CRSP - Full Network Map`);\r",
+							"console.log(`Event-Director - Full Network Map`);\r",
 							"\r",
 							"// ## Set up transaction eco-system\r",
 							"\r",
@@ -117,12 +117,12 @@
 					}
 				},
 				"url": {
-					"raw": "{{natsUrl}}/{{path-channel-router-setup-processor}}",
+					"raw": "{{natsUrl}}/{{path-event-director}}",
 					"host": [
 						"{{natsUrl}}"
 					],
 					"path": [
-						"{{path-channel-router-setup-processor}}"
+						"{{path-event-director}}"
 					]
 				}
 			},

deployment.yaml

@@ -28,7 +28,7 @@ spec:
               protocol: TCP
           resources: {}
           imagePullPolicy: Always
-        - name: crsp-sidecar-rel-1-0-0
+        - name: ed-sidecar-rel-1-0-0
           image: example.io/sidecar-rel-1-0-0:1.0.0
           ports:
             - name: http

docker-compose.yml

@@ -2,7 +2,7 @@
 
 services:
   node:
-    container_name: crsp
+    container_name: event-director
     build:
       dockerfile: Dockerfile
       context: .