admin/n8n-enterprise-unlocked
1
0
Fork 0
mirror of https://github.com/Abdulazizzn/n8n-enterprise-unlocked.git synced 2025-12-19 11:01:15 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix(core): Copy metadata information for binary data when data is migrated using filesystem (no-changelog) (#16003)

Browse Source
This commit is contained in:
Andreas Fitzek
2025-06-04 14:52:15 +02:00
committed by GitHub
parent 9abb333507
commit 40de4ed91c
2 changed files with 7 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
packages/core/src/binary-data/__tests__/file-system.manager.test.ts
View File

@@ -99,6 +99,7 @@ describe('getMetadata()', () => {
describe('copyByFileId()', () => { describe('copyByFileId()', () => {
it('should copy by file ID and return the file ID', async () => { it('should copy by file ID and return the file ID', async () => {
fsp.copyFile = jest.fn().mockResolvedValue(undefined); fsp.copyFile = jest.fn().mockResolvedValue(undefined);
fsp.writeFile = jest.fn().mockResolvedValue(undefined);
// @ts-expect-error - private method // @ts-expect-error - private method
jest.spyOn(fsManager, 'toFileId').mockReturnValue(otherFileId); jest.spyOn(fsManager, 'toFileId').mockReturnValue(otherFileId);
@@ -109,6 +110,9 @@ describe('copyByFileId()', () => {
const targetPath = toFullFilePath(targetFileId); const targetPath = toFullFilePath(targetFileId);
expect(fsp.copyFile).toHaveBeenCalledWith(sourcePath, targetPath); expect(fsp.copyFile).toHaveBeenCalledWith(sourcePath, targetPath);
// Make sure metadata file was written
expect(fsp.writeFile).toBeCalledTimes(1);
}); });
}); });

3
packages/core/src/binary-data/file-system.manager.ts
View File

@@ -127,11 +127,14 @@ export class FileSystemManager implements BinaryData.Manager {
const targetFileId = this.toFileId(workflowId, executionId); const targetFileId = this.toFileId(workflowId, executionId);
const sourcePath = this.resolvePath(sourceFileId); const sourcePath = this.resolvePath(sourceFileId);
const targetPath = this.resolvePath(targetFileId); const targetPath = this.resolvePath(targetFileId);
const sourceMetadata = await this.getMetadata(sourceFileId);
await assertDir(path.dirname(targetPath)); await assertDir(path.dirname(targetPath));
await fs.copyFile(sourcePath, targetPath); await fs.copyFile(sourcePath, targetPath);
await this.storeMetadata(targetFileId, sourceMetadata);
return targetFileId; return targetFileId;
} }