fix: support resolve plugin path from framework (#161)

.gitignore

@@ -114,4 +114,6 @@ pnpm-lock.yaml
 lib
 
 # OSX
-.DS_Store
+.DS_Store
+
+!test/fixtures/frameworks/layer/foo/foo2/node_modules

jest.config.js

@@ -12,4 +12,5 @@ module.exports = {
   ],
   coverageReporters: ['json', 'json-summary', 'lcov', 'text', 'clover', 'text-summary', 'cobertura'],
   collectCoverageFrom: ['<rootDir>/src/**/*.ts'],
+  transformIgnorePatterns: ["/node_modules/(?!(artus_plugin_hbase)/)", "\\.pnp\\.[^\\\/]+$"]
 };

src/loader/impl/plugin_config.ts

@@ -29,7 +29,8 @@ class PluginConfigLoader extends ConfigLoader implements Loader {
           );
         }
         if (pluginConfigItem.enable) {
-          pluginConfigItem.path = ArtusPlugin.getPath(pluginConfigItem.package);
+          const loaderState = item._loaderState as { baseDir: string };
+          pluginConfigItem.path = ArtusPlugin.getPath(pluginConfigItem.package, [loaderState.baseDir]);
         }
         delete pluginConfigItem.package;
         configObj[pluginName] = pluginConfigItem;

src/plugin/base.ts

@@ -3,8 +3,9 @@ import path from 'path';
 type PluginMap = Map<string, BasePlugin>;
 
 export class BasePlugin implements Plugin {
-  static getPath(packageName: string): string {
-    return path.resolve(require.resolve(packageName), '..');
+  static getPath(packageName: string, paths?: string[]): string {
+    const opts = paths ? { paths } : undefined;
+    return path.resolve(require.resolve(packageName, opts), '..');
   }
 
   public name: string;

src/scanner/scan.ts

@@ -177,6 +177,9 @@ export class Scanner {
         filename,
         loader,
         source: 'config',
+        _loaderState: {
+          baseDir,
+        },
       };
     }));
     await loaderFactory.loadItemList(configItemList.filter(v => v) as ManifestItem[]);

test/fixtures/artus_application/src/controller/plugin.ts

@@ -7,6 +7,8 @@ import { Context } from '@artus/pipeline';
 export default class Hello {
   @Inject('ARTUS_MYSQL')
   private client: any;
+  @Inject('ARTUS_HBASE')
+  private client2: any;
 
   @HttpMethod({
     method: HTTPMethodEnum.GET,
@@ -36,4 +38,14 @@ export default class Hello {
     } : { message: 'plugin redis not enabled' };
     return result;
   }
+
+  @HttpMethod({
+    method: HTTPMethodEnum.GET,
+    path: '/plugin-hbase',
+  })
+  async getHbaseClient() {
+    return {
+      client: await this.client2.getClient(),
+    };
+  }
 }

test/fixtures/frameworks/layer/foo/foo2/src/config/plugin.ts

@@ -0,0 +1,6 @@
+export default {
+  hbase: {
+    enable: true,
+    package: 'artus_plugin_hbase',
+  },
+};

test/framework.test.ts

@@ -51,6 +51,8 @@ describe('test/framework.test.ts', () => {
     assert(testResponseName4.data.client === 'mysql-ob');
     const testResponseName5 = await axios.get(`http://127.0.0.1:${port}/plugin-redis`);
     assert(testResponseName5.data.message === 'plugin redis not enabled');
+    const testResponseName6 = await axios.get(`http://127.0.0.1:${port}/plugin-hbase`);
+    assert(testResponseName6.data.client === 'foo2-hbase');
 
     await app.artus.close();
     assert(!app.isListening());