mudhorn/n8n
1
0
Fork 0
mirror of https://github.com/n8n-io/n8n.git synced 2025-03-05 20:50:17 -08:00
Code Issues Actions Packages Projects Releases Wiki Activity

⚡ Normalize FTP-Data

Browse source
This commit is contained in:
Jan Oberhauser 2020-09-02 10:50:55 +02:00
parent 89ed3c4a6d
commit 0e1a4e5309
1 changed files with 42 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

47
packages/nodes-base/nodes/Ftp.node.ts
View file

@ -17,6 +17,24 @@ import {
import * as ftpClient from 'promise-ftp'; import * as ftpClient from 'promise-ftp';
import * as sftpClient from 'ssh2-sftp-client'; import * as sftpClient from 'ssh2-sftp-client';
interface ReturnFtpItem {
type: string;
name: string;
size: number;
accessTime: Date;
modifyTime: Date;
rights: {
user: string;
group: string;
other: string;
};
owner: string | number;
group: string | number;
target: string;
sticky?: boolean;
path: string;
}
export class Ftp implements INodeType { export class Ftp implements INodeType {
description: INodeTypeDescription = { description: INodeTypeDescription = {
displayName: 'FTP', displayName: 'FTP',
@ -304,10 +322,11 @@ export class Ftp implements INodeType {
const recursive = this.getNodeParameter('recursive', i) as boolean; const recursive = this.getNodeParameter('recursive', i) as boolean;
if (recursive) { if (recursive) {
responseData = await callRecursiveList(path, sftp); responseData = await callRecursiveList(path, sftp!, normalizeSFtpItem);
returnItems.push.apply(returnItems, this.helpers.returnJsonArray(responseData as unknown as IDataObject[])); returnItems.push.apply(returnItems, this.helpers.returnJsonArray(responseData as unknown as IDataObject[]));
} else { } else {
responseData = await sftp!.list(path); responseData = await sftp!.list(path);
responseData.forEach(item => normalizeSFtpItem(item as sftpClient.FileInfo, path));
returnItems.push.apply(returnItems, this.helpers.returnJsonArray(responseData as unknown as IDataObject[])); returnItems.push.apply(returnItems, this.helpers.returnJsonArray(responseData as unknown as IDataObject[]));
} }
} }
@ -372,10 +391,11 @@ export class Ftp implements INodeType {
const recursive = this.getNodeParameter('recursive', i) as boolean; const recursive = this.getNodeParameter('recursive', i) as boolean;
if (recursive) { if (recursive) {
responseData = await callRecursiveList(path, ftp); responseData = await callRecursiveList(path, ftp!, normalizeFtpItem);
returnItems.push.apply(returnItems, this.helpers.returnJsonArray(responseData as unknown as IDataObject[])); returnItems.push.apply(returnItems, this.helpers.returnJsonArray(responseData as unknown as IDataObject[]));
} else { } else {
responseData = await ftp!.list(path); responseData = await ftp!.list(path);
responseData.forEach(item => normalizeFtpItem(item as ftpClient.ListingElement, path));
returnItems.push.apply(returnItems, this.helpers.returnJsonArray(responseData as unknown as IDataObject[])); returnItems.push.apply(returnItems, this.helpers.returnJsonArray(responseData as unknown as IDataObject[]));
} }
} }
@ -461,7 +481,25 @@ export class Ftp implements INodeType {
return [returnItems]; return [returnItems];
} }
} }
async function callRecursiveList(path: string, client : sftpClient | ftpClient) {
function normalizeFtpItem(input: ftpClient.ListingElement, path: string) {
const item = input as unknown as ReturnFtpItem;
item.modifyTime = input.date;
item.path = `${path}${path.endsWith('/') ? '' : '/'}${item.name}`;
// @ts-ignore
item.date = undefined;
}
function normalizeSFtpItem(input: sftpClient.FileInfo, path: string) {
const item = input as unknown as ReturnFtpItem;
item.accessTime = new Date(input.accessTime);
item.modifyTime = new Date(input.modifyTime);
item.path = `${path}${path.endsWith('/') ? '' : '/'}${item.name}`;
}
async function callRecursiveList(path: string, client: sftpClient | ftpClient, normalizeFunction: (input: ftpClient.ListingElement & sftpClient.FileInfo, path: string) => void) {
const pathArray : string[] = [path]; const pathArray : string[] = [path];
let currentPath = path; let currentPath = path;
const directoryItems : sftpClient.FileInfo[] = []; const directoryItems : sftpClient.FileInfo[] = [];
@ -484,8 +522,7 @@ async function callRecursiveList(path: string, client : sftpClient | ftpClient)
pathArray.push(currentPath); pathArray.push(currentPath);
} }
//@ts-ignore normalizeFunction(item as ftpClient.ListingElement & sftpClient.FileInfo, currentPath);
item.path = currentPath;
directoryItems.push(item); directoryItems.push(item);
}); });
index++; index++;