import { api } from '@rocket.chat/core-services';
import type { IWebdavAccount, IWebdavAccountIntegration } from '@rocket.chat/core-typings';
import { WebdavAccounts } from '@rocket.chat/models';
import { ajv, validateUnauthorizedErrorResponse, validateBadRequestErrorResponse } from '@rocket.chat/rest-typings';
import type { DeleteResult } from 'mongodb';

import type { ExtractRoutesFromAPI } from '../ApiClass';
import { API } from '../api';
import { findWebdavAccountsByUserId } from '../lib/webdav';

const webdavGetMyAccountsEndpoints = API.v1.get(
	'webdav.getMyAccounts',
	{
		authRequired: true,
		response: {
			200: ajv.compile<{
				accounts: IWebdavAccountIntegration[];
			}>({
				type: 'object',
				properties: {
					accounts: {
						type: 'array',
						items: {
							type: 'object',
							properties: {
								_id: {
									type: 'string',
								},
								serverURL: {
									type: 'string',
								},
								username: {
									type: 'string',
								},
								name: {
									type: 'string',
								},
							},
							required: ['_id', 'serverURL', 'username', 'name'],
							additionalProperties: false,
						},
					},
					success: {
						type: 'boolean',
						description: 'Indicates if the request was successful.',
					},
				},
				required: ['success', 'accounts'],
				additionalProperties: false,
			}),
			401: validateUnauthorizedErrorResponse,
		},
	},
	async function action() {
		return API.v1.success({
			accounts: await findWebdavAccountsByUserId({ uid: this.userId }),
		});
	},
);

type POSTRemoveWebdavAccount = {
	accountId: IWebdavAccount['_id'];
};

const POSTRemoveWebdavAccountSchema = {
	type: 'object',
	properties: {
		accountId: {
			type: 'string',
		},
	},
	required: ['accountId'],
	additionalProperties: false,
};

const isPOSTRemoveWebdavAccount = ajv.compile<POSTRemoveWebdavAccount>(POSTRemoveWebdavAccountSchema);

const webdavRemoveAccountEndpoints = API.v1.post(
	'webdav.removeWebdavAccount',
	{
		authRequired: true,
		validateParams: isPOSTRemoveWebdavAccount,
		body: isPOSTRemoveWebdavAccount,
		response: {
			200: ajv.compile<{
				result: DeleteResult;
			}>({
				type: 'object',
				properties: {
					result: {
						type: 'object',
						properties: {
							acknowledged: {
								type: 'boolean',
							},
							deletedCount: {
								type: 'integer',
							},
						},
						required: ['acknowledged', 'deletedCount'],
						additionalProperties: false,
					},
					success: {
						type: 'boolean',
						description: 'Indicates if the request was successful.',
					},
				},
				required: ['result', 'success'],
				additionalProperties: false,
			}),
			400: validateBadRequestErrorResponse,
			401: validateUnauthorizedErrorResponse,
		},
	},
	async function action() {
		const { accountId } = this.bodyParams;

		const removed = await WebdavAccounts.removeByUserAndId(accountId, this.userId);
		if (removed) {
			void api.broadcast('notify.webdav', this.userId, {
				type: 'removed',
				account: { _id: accountId },
			});
		}

		return API.v1.success({ result: removed });
	},
);

type WebdavGetMyAccountsEndpoints = ExtractRoutesFromAPI<typeof webdavGetMyAccountsEndpoints>;

type WebdavRemoveAccountEndpoints = ExtractRoutesFromAPI<typeof webdavRemoveAccountEndpoints>;

export type WebdavEndpoints = WebdavGetMyAccountsEndpoints | WebdavRemoveAccountEndpoints;

declare module '@rocket.chat/rest-typings' {
	// eslint-disable-next-line @typescript-eslint/naming-convention, @typescript-eslint/no-empty-interface
	interface Endpoints extends WebdavGetMyAccountsEndpoints {}
	// eslint-disable-next-line @typescript-eslint/naming-convention, @typescript-eslint/no-empty-interface
	interface Endpoints extends WebdavRemoveAccountEndpoints {}
}