mudhorn/n8n
1
0
Fork 0
mirror of https://github.com/n8n-io/n8n.git synced 2025-01-22 18:11:29 -08:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

fix(Email Trigger (IMAP) Node): Fix connection issue with unexpected spaces in host (#6886)

Browse source
This commit is contained in:
Jon 2023-08-10 08:58:51 +01:00 committed by GitHub
parent 718e61354d
commit f3248e46e4
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 16 additions and 16 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
packages/nodes-base/nodes/EmailReadImap/v1/EmailReadImapV1.node.ts
View file

@ -241,7 +241,7 @@ export class EmailReadImapV1 implements INodeType {
imap: {
user: credentials.user as string,
password: credentials.password as string,
host: credentials.host as string,
host: (credentials.host as string).trim(),
port: credentials.port as number,
tls: credentials.secure as boolean,
authTimeout: 20000,
@ -250,7 +250,7 @@ export class EmailReadImapV1 implements INodeType {
const tlsOptions: IDataObject = {};
if (credentials.secure) {
tlsOptions.servername = credentials.host as string;
tlsOptions.servername = (credentials.host as string).trim();
}
if (!isEmpty(tlsOptions)) {
config.imap.tlsOptions = tlsOptions;
@ -527,7 +527,7 @@ export class EmailReadImapV1 implements INodeType {
imap: {
user: credentials.user as string,
password: credentials.password as string,
host: credentials.host as string,
host: (credentials.host as string).trim(),
port: credentials.port as number,
tls: credentials.secure as boolean,
authTimeout: 20000,
@ -579,7 +579,7 @@ export class EmailReadImapV1 implements INodeType {
}
if (credentials.secure) {
tlsOptions.servername = credentials.host as string;
tlsOptions.servername = (credentials.host as string).trim();
}
if (!isEmpty(tlsOptions)) {

24
packages/nodes-base/nodes/EmailReadImap/v2/EmailReadImapV2.node.ts
View file

@ -34,14 +34,14 @@ export async function parseRawEmail(
): Promise<INodeExecutionData> {
const responseData = await simpleParser(messageEncoded);
const headers: IDataObject = {};
const addidtionalData: IDataObject = {};
const additionalData: IDataObject = {};
for (const header of responseData.headerLines) {
headers[header.key] = header.line;
}
addidtionalData.headers = headers;
addidtionalData.headerLines = undefined;
additionalData.headers = headers;
additionalData.headerLines = undefined;
const binaryData: IBinaryKeyData = {};
if (responseData.attachments) {
@ -54,11 +54,11 @@ export async function parseRawEmail(
);
}
addidtionalData.attachments = undefined;
additionalData.attachments = undefined;
}
return {
json: { ...responseData, ...addidtionalData },
json: { ...responseData, ...additionalData },
binary: Object.keys(binaryData).length ? binaryData : undefined,
} as INodeExecutionData;
}
@ -238,7 +238,7 @@ export class EmailReadImapV2 implements INodeType {
imap: {
user: credentials.user,
password: credentials.password,
host: credentials.host,
host: credentials.host.trim(),
port: credentials.port,
tls: credentials.secure,
authTimeout: 20000,
@ -251,7 +251,7 @@ export class EmailReadImapV2 implements INodeType {
}
if (credentials.secure) {
tlsOptions.servername = credentials.host;
tlsOptions.servername = credentials.host.trim();
}
if (!isEmpty(tlsOptions)) {
config.imap.tlsOptions = tlsOptions;
@ -554,7 +554,7 @@ export class EmailReadImapV2 implements INodeType {
imap: {
user: credentials.user,
password: credentials.password,
host: credentials.host,
host: credentials.host.trim(),
port: credentials.port,
tls: credentials.secure,
authTimeout: 20000,
@ -609,7 +609,7 @@ export class EmailReadImapV2 implements INodeType {
}
if (credentials.secure) {
tlsOptions.servername = credentials.host;
tlsOptions.servername = credentials.host.trim();
}
if (!isEmpty(tlsOptions)) {
@ -648,7 +648,7 @@ export class EmailReadImapV2 implements INodeType {
let reconnectionInterval: NodeJS.Timeout | undefined;
const handleReconect = async () => {
const handleReconnect = async () => {
this.logger.verbose('Forcing reconnect to IMAP server');
try {
isCurrentlyReconnecting = true;
@ -665,12 +665,12 @@ export class EmailReadImapV2 implements INodeType {
if (options.forceReconnect !== undefined) {
reconnectionInterval = setInterval(
handleReconect,
handleReconnect,
(options.forceReconnect as number) * 1000 * 60,
);
}
// When workflow and so node gets set to inactive close the connectoin
// When workflow and so node gets set to inactive close the connection
async function closeFunction() {
closeFunctionWasCalled = true;
if (reconnectionInterval) {