Revert "Port method and path fixes - can overwrite autogenerated routes - sticks to its http methods (#6)" (#9)

This reverts commit 9a73dc9.

Author: quesurifn

src/adapters/controllers/post-invoke-port.js

@@ -13,9 +13,6 @@ export default function anyInvokePortFactory (invokePort) {
       const result = await invokePort({
         port: httpRequest.params.port,
         args: httpRequest.body,
-        method: httpRequest.method,
-        headers: httpRequest.headers,
-        path: httpRequest.path,
         id: httpRequest.params.id || null
       })
 

src/aegis.js

@@ -96,13 +96,11 @@ const router = {
           if (ctrl.ports) {
             for (const portName in ctrl.ports) {
               const port = ctrl.ports[portName]
-              const specPortMethods = (port?.methods || "").join('|')
-
               if (port.path) {
                 routeOverrides.set(port.path, portName)
               }
 
-              if (checkAllowedMethods(ctrl, method) && (!port.methods || (specPortMethods.includes(method.toLowerCase()))) ) {
+              if (checkAllowedMethods(ctrl, method)) {
                 routes.set(port.path || path(ctrl.endpoint), {
                   [method]: adapter(ctrl.fn)
                 })
@@ -133,8 +131,6 @@ const router = {
 }
 
 function makeRoutes () {
-  router.adminRoute(getConfig, http)
-  router.userRoutes(getRoutes)
   router.autoRoutes(endpoint, 'get', liveUpdate, http)
   router.autoRoutes(endpoint, 'get', getModels, http)
   router.autoRoutes(endpoint, 'post', postModels, http)
@@ -150,6 +146,8 @@ function makeRoutes () {
   router.autoRoutes(endpointPortId, 'patch', anyInvokePorts, http, true)
   router.autoRoutes(endpointPortId, 'delete', anyInvokePorts, http, true)
   router.autoRoutes(endpointPortId, 'get', anyInvokePorts, http, true)
+  router.adminRoute(getConfig, http)
+  router.userRoutes(getRoutes)
   console.log(routes)
 }
 

src/domain/use-cases/invoke-port.js

@@ -33,22 +33,23 @@ export default function makeInvokePort ({
   }
   /**
    *
-   * @param {{id:String,model:import('..').Model,args:String[],port:String,method:String,headers:Array}} input
+   * @param {{id:string,model:import('..').Model,args:string[],port:string}} input
    * @returns
    */
   return async function invokePort (input) {
     if (isMainThread) {
       return threadpool.runJob(invokePort.name, input, modelName)
     } else {
       try {
-        let { id = null, port = null, method, path } = input;
+        let { id = null, port = null} = input;
         const service = await findModelService(id)
         if (!service) {
           throw new Error('could not find a service associated with given id')
         } 
 
-        const specPorts = service.getPorts();
         if(!port) {
+          const specPorts = service.getPorts();
+          const path = context['requestContext'].getStore().get('path');
           for(const p of Object.entries(specPorts)) {
             if(!p[1].path) {
               continue;
@@ -67,14 +68,6 @@ export default function makeInvokePort ({
           throw new Error('the port or record ID is invalid')
         }
 
-        const specPortMethods = specPorts[port]?.methods.join('|').toLowerCase();
-        if (specPortMethods && !(specPortMethods.includes(method.toLowerCase()))) {
-          throw new Error('invalid method for given port');
-        }
-        if (specPorts[port]?.path && !pathsMatch(specPorts[port].path, path)) {
-          throw new Error('invalid path for given port');
-        }
-
         return await service[port](input)
       } catch (error) {
         return AppError(error)