Skip to content

Commit

Permalink
[api] Fix manual import
Browse files Browse the repository at this point in the history
  • Loading branch information
Samuel Hassine committed Apr 15, 2021
1 parent 7d3f88e commit ed56dbe
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions opencti-platform/opencti-graphql/src/domain/file.js
Original file line number Diff line number Diff line change
Expand Up @@ -8,14 +8,14 @@ import { internalLoadById } from '../database/middleware';
import { isStixDomainObjectContainer } from '../schema/stixDomainObject';
import { UnsupportedError } from '../config/errors';

export const uploadJobImport = async (user, fileId, fileMime, entityId) => {
export const uploadJobImport = async (user, fileId, fileMime, entityId, manual = false) => {
let isImportInContainer = false;
if (entityId) {
const entity = await internalLoadById(user, entityId);
isImportInContainer = isStixDomainObjectContainer(entity.entity_type);
if (!isImportInContainer) throw UnsupportedError('Cant importing on none container entity');
}
const connectors = await connectorsForImport(user, fileMime, true, true);
const connectors = await connectorsForImport(user, fileMime, true, !manual);
if (connectors.length > 0) {
// Create job and send ask to broker
const createConnectorWork = async (connector) => {
Expand Down Expand Up @@ -51,7 +51,7 @@ export const uploadJobImport = async (user, fileId, fileMime, entityId) => {
export const askJobImport = async (user, filename) => {
logApp.debug(`[JOBS] ask import for file ${filename} by ${user.user_email}`);
const file = await loadFile(user, filename);
await uploadJobImport(user, file.id, file.metaData.mimetype, file.metaData.entity_id);
await uploadJobImport(user, file.id, file.metaData.mimetype, file.metaData.entity_id, true);
return file;
};

Expand Down

0 comments on commit ed56dbe

Please sign in to comment.