import { Users } from '@rocket.chat/models';

import { API } from '../../../api/server';
import { normalizers } from '../normalizers';
import { serverLogger } from '../lib/logger';
import { isFederationEnabled } from '../lib/isFederationEnabled';

const userFields = { _id: 1, username: 1, type: 1, emails: 1, name: 1 };

API.v1.addRoute(
	'federation.users.search',
	{ authRequired: false },
	{
		async get() {
			if (!isFederationEnabled()) {
				return API.v1.failure('Federation not enabled');
			}

			const { username, domain } = this.queryParams;

			serverLogger.debug(`federation.users.search => username=${username} domain=${domain}`);

			const query = {
				type: 'user',
				$or: [{ name: username }, { username }, { 'emails.address': `${username}@${domain}` }],
			};

			let users = await Users.find(query, { projection: userFields }).toArray();

			users = await normalizers.normalizeAllUsers(users);

			return API.v1.success({ users });
		},
	},
);

API.v1.addRoute(
	'federation.users.getByUsername',
	{ authRequired: false },
	{
		async get() {
			if (!isFederationEnabled()) {
				return API.v1.failure('Federation not enabled');
			}

			const { username } = this.queryParams;

			serverLogger.debug(`federation.users.getByUsername => username=${username}`);

			const query = {
				type: 'user',
				username,
			};

			let user = await Users.findOne(query, { projection: userFields });

			user = await normalizers.normalizeUser(user);

			return API.v1.success({ user });
		},
	},
);