import type { INodeTypeDescription } from 'n8n-workflow';

import { paginatedRequest, type StrapiFilters } from '@/utils/strapi-utils';

export type StrapiCommunityNodeType = {
	id: number;
	authorGithubUrl: string;
	authorName: string;
	checksum: string;
	description: string;
	displayName: string;
	name: string;
	numberOfStars: number;
	numberOfDownloads: number;
	packageName: string;
	createdAt: string;
	updatedAt: string;
	npmVersion: string;
	isOfficialNode: boolean;
	companyName?: string;
	nodeDescription: INodeTypeDescription;
	nodeVersions?: Array<{ npmVersion: string; checksum: string }>;
	aiNodeSdkVersion?: number;
};

export type CommunityNodesMetadata = Pick<
	StrapiCommunityNodeType,
	'id' | 'name' | 'npmVersion' | 'updatedAt'
>;

const N8N_VETTED_NODE_TYPES_STAGING_URL = 'https://api-staging.n8n.io/api/community-nodes';
const N8N_VETTED_NODE_TYPES_PRODUCTION_URL = 'https://api.n8n.io/api/community-nodes';

function getUrl(environment: 'staging' | 'production'): string {
	return environment === 'production'
		? N8N_VETTED_NODE_TYPES_PRODUCTION_URL
		: N8N_VETTED_NODE_TYPES_STAGING_URL;
}

export async function getCommunityNodeTypes(
	environment: 'staging' | 'production',
	qs: { filters?: StrapiFilters; fields?: string[] } = {},
	maxAiNodeSdk: number,
): Promise<StrapiCommunityNodeType[]> {
	const url = getUrl(environment);
	const params = {
		...qs,
		maxAiNodeSdk,
		pagination: {
			page: 1,
			pageSize: 25,
		},
	};
	return await paginatedRequest<StrapiCommunityNodeType>(url, params);
}

export async function getCommunityNodesMetadata(
	environment: 'staging' | 'production',
	maxAiNodeSdk: number,
): Promise<CommunityNodesMetadata[]> {
	const url = getUrl(environment);
	const params = {
		fields: ['npmVersion', 'name', 'updatedAt'],
		maxAiNodeSdk,
		pagination: {
			page: 1,
			pageSize: 500,
		},
	};
	// we want to make sure this throws on error
	return await paginatedRequest<CommunityNodesMetadata>(url, params, {
		throwOnError: true,
	});
}