mirror/lowdefy
2
0
Fork 0
mirror of https://github.com/lowdefy/lowdefy.git synced 2025-04-06 15:30:30 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix(api): Fix api context tests.

Browse Source
This commit is contained in:
Sam Tolmay 2021-10-27 13:42:51 +02:00
parent 320c4a10a1
commit 8aa2642437
No known key found for this signature in database
GPG Key ID: D004126FCD1A6DF0
2 changed files with 31 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
packages/api/src/context/createContext.test.js
View File

@ -29,7 +29,10 @@ getSecrets.mockImplementation(() => ({ secret: true }));
createAuthorize.mockImplementation(({ authenticated, roles = [] }) => ({ authenticated, roles }));
createReadConfigFile.mockImplementation(({ configDirectory }) => () => ({ configDirectory }));
createReadConfigFile.mockImplementation(({ configDirectory }) => (path) => ({
configDirectory,
path,
}));
verifyAuthorizationHeader.mockImplementation(() => ({
authenticated: true,
@ -42,6 +45,7 @@ test('createContext', async () => {
const context = contextFn({
headers: { header: 'header' },
host: 'host',
logger: 'logger',
protocol: 'https',
setHeader: 'setHeaderFunction',
});
@ -56,11 +60,17 @@ test('createContext', async () => {
},
"config": Object {
"configDirectory": "configDirectory",
"path": "config.json",
},
"connectionTypes": Object {
"configDirectory": "configDirectory",
"path": "connectionTypes.json",
},
"headers": Object {
"header": "header",
},
"host": "host",
"logger": "logger",
"protocol": "https",
"readConfigFile": [Function],
"secrets": Object {
@ -85,11 +95,17 @@ test('createContext', async () => {
},
"config": Object {
"configDirectory": "configDirectory",
"path": "config.json",
},
"connectionTypes": Object {
"configDirectory": "configDirectory",
"path": "connectionTypes.json",
},
"headers": Object {
"header": "header",
},
"host": "host",
"logger": "logger",
"protocol": "https",
"readConfigFile": [Function],
"secrets": Object {

30
packages/api/src/routes/request/getConnectionPackage.js
View File

@ -13,28 +13,26 @@
See the License for the specific language governing permissions and
limitations under the License.
*/
import { createRequire } from 'module';
import { ConfigurationError } from '../../context/errors';
async function getConnectionPackage({ connectionTypes, logger }, { connection, request }) {
const connectionTypeDefinition = connectionTypes[connection.type];
if (!connectionTypeDefinition) {
throw new ConfigurationError(
`Request "${request.requestId}" has undefined connection type "${connection.type}".`
);
}
// const connectionTypeDefinition = connectionTypes[connection.type];
// if (!connectionTypeDefinition) {
// throw new ConfigurationError(
// `Request "${request.requestId}" has undefined connection type "${connection.type}".`
// );
// }
const require = createRequire(import.meta.url);
const connectionPackage = require(connectionTypeDefinition.package);
// const connectionPackage = await import(connectionTypeDefinition.package);
logger.info(connectionPackage);
// logger.info(connectionPackage);
if (!connectionPackage) {
throw new ConfigurationError(
`Connection package "${connectionTypeDefinition.package}" could not be imported.`
);
}
return connectionPackage;
// if (!connectionPackage) {
// throw new ConfigurationError(
// `Connection package "${connectionTypeDefinition.package}" could not be imported.`
// );
// }
return null;
}
export default getConnectionPackage;