✨ Add NASA Node (#1232)

* ✨ NASA node

* Test up to asteroidNeoLookup

* Add earth imagery

* ⚡ Small improvement

* ⚡ Improvements to NASA node

* ⚡ Small Improvements

* ⚡ Some minor fixes for NASA Node

Co-authored-by: Iván Ovejero <ivov.src@gmail.com>
Co-authored-by: Jan Oberhauser <jan.oberhauser@gmail.com>

packages/nodes-base/credentials/NasaApi.credentials.ts

@@ -0,0 +1,17 @@
+import {
+	ICredentialType,
+	NodePropertyTypes,
+} from 'n8n-workflow';
+
+export class NasaApi implements ICredentialType {
+	name = 'nasaApi';
+	displayName = 'NASA API';
+	properties = [
+		{
+			displayName: 'API Key',
+			name: 'api_key',
+			type: 'string' as NodePropertyTypes,
+			default: '',
+		},
+	];
+}

packages/nodes-base/nodes/Nasa/GenericFunctions.ts

@@ -0,0 +1,71 @@
+import {
+	OptionsWithUri,
+} from 'request';
+
+import {
+	IExecuteFunctions,
+	IHookFunctions,
+} from 'n8n-core';
+
+import {
+	IDataObject,
+} from 'n8n-workflow';
+
+export async function nasaApiRequest(this: IHookFunctions | IExecuteFunctions, method: string, endpoint: string, qs: IDataObject, option: IDataObject = {}, uri?: string | undefined): Promise<any> { // tslint:disable-line:no-any
+
+	const credentials = this.getCredentials('nasaApi') as IDataObject;
+
+	qs.api_key = credentials['api_key'] as string;
+
+	const options: OptionsWithUri = {
+		method,
+		qs,
+		uri: uri || `https://api.nasa.gov${endpoint}`,
+		json: true,
+	};
+
+	if (Object.keys(option)) {
+		Object.assign(options, option);
+	}
+
+	try {
+		return await this.helpers.request(options);
+
+	} catch (error) {
+		if (error.statusCode === 401) {
+			// Return a clear error
+			throw new Error('The NASA credentials are not valid!');
+		}
+
+		if (error.response && error.response.body && error.response.body.msg) {
+			// Try to return the error prettier
+			throw new Error(`NASA error response [${error.statusCode}]: ${error.response.body.msg}`);
+		}
+
+		// If that data does not exist for some reason return the actual error
+		throw error;
+	}
+}
+
+export async function nasaApiRequestAllItems(this: IHookFunctions | IExecuteFunctions, propertyName: string, method: string, resource: string, query: IDataObject = {}): Promise<any> { // tslint:disable-line:no-any
+
+	const returnData: IDataObject[] = [];
+
+	let responseData;
+
+	query.size = 20;
+
+	let uri: string | undefined = undefined;
+
+	do {
+		responseData = await nasaApiRequest.call(this, method, resource, query, {}, uri);
+		uri = responseData.links.next;
+		returnData.push.apply(returnData, responseData[propertyName]);
+	} while (
+		responseData.links.next !== undefined
+	);
+
+	return returnData;
+}
+
+

packages/nodes-base/package.json

@@ -147,6 +147,7 @@
       "dist/credentials/Mqtt.credentials.js",
       "dist/credentials/Msg91Api.credentials.js",
       "dist/credentials/MySql.credentials.js",
+      "dist/credentials/NasaApi.credentials.js",
       "dist/credentials/NextCloudApi.credentials.js",
       "dist/credentials/NextCloudOAuth2Api.credentials.js",
       "dist/credentials/OAuth1Api.credentials.js",
@@ -376,6 +377,7 @@
       "dist/nodes/MoveBinaryData.node.js",
       "dist/nodes/Msg91/Msg91.node.js",
       "dist/nodes/MySql/MySql.node.js",
+      "dist/nodes/Nasa/Nasa.node.js",
       "dist/nodes/NextCloud/NextCloud.node.js",
       "dist/nodes/NoOp.node.js",
       "dist/nodes/OpenThesaurus/OpenThesaurus.node.js",