/**
 * This file is part of the NocoBase (R) project.
 * Copyright (c) 2020-2024 NocoBase Co., Ltd.
 * Authors: NocoBase Team.
 *
 * This project is dual-licensed under AGPL-3.0 and NocoBase Commercial License.
 * For more information, please refer to: https://www.nocobase.com/agreement.
 */

import { Context, Next, DEFAULT_PAGE, DEFAULT_PER_PAGE } from '@nocobase/actions';
import { Cache } from '@nocobase/cache';
import { Database, Model, Op } from '@nocobase/database';
import { PluginManager } from '@nocobase/server';
import { EXTEND_MODULES } from '../constans';

const appendTranslations = async (db: Database, rows: Model[], locale: string): Promise<any[]> => {
  const texts = rows || [];
  const textIds = texts.map((text: any) => text.id);
  const textMp = texts.reduce((memo: any, text: any) => {
    memo[text.id] = text;
    return memo;
  }, {});
  const repo = db.getRepository('localizationTranslations');
  const translations = await repo.find({
    filter: {
      locale,
      textId: textIds,
    },
  });
  translations.forEach((translation: Model) => {
    const text = textMp[translation.textId];
    if (text) {
      text.set('translation', translation.translation, { raw: true });
      text.set('translationId', translation.id, { raw: true });
      textMp[translation.textId] = text;
    }
  });
  return Object.values(textMp);
};

const listText = async (db: Database, params: any): Promise<[any[], number]> => {
  const { module, keyword, hasTranslation, locale, options } = params;
  if (module) {
    options['filter'] = { module: `resources.${module}` };
  }
  if (keyword || !hasTranslation) {
    options['include'] = [{ association: 'translations', where: { locale }, required: false }];
    if (!hasTranslation) {
      if (keyword) {
        options['filter'] = {
          ...options['filter'],
          text: {
            $includes: keyword,
          },
        };
      }
      options['where'] = {
        '$translations.id$': null,
      };
    } else {
      options['where'] = {
        [Op.or]: [
          { text: { [Op.like]: `%${keyword}%` } },
          { '$translations.translation$': { [Op.like]: `%${keyword}%` } },
        ],
      };
    }
  }
  const [rows, count] = await db.getRepository('localizationTexts').findAndCount(options);
  if (!hasTranslation) {
    return [rows, count];
  }
  return [await appendTranslations(db, rows, locale), count];
};

const list = async (ctx: Context, next: Next) => {
  const locale = ctx.get('X-Locale') || 'en-US';
  let { page = DEFAULT_PAGE, pageSize = DEFAULT_PER_PAGE, hasTranslation } = ctx.action.params;
  page = parseInt(String(page));
  pageSize = parseInt(String(pageSize));
  hasTranslation = hasTranslation === 'true' || hasTranslation === undefined;
  const { keyword, module } = ctx.action.params;
  const options = {
    context: ctx,
    offset: (page - 1) * pageSize,
    limit: pageSize,
  };
  const [rows, count] = await listText(ctx.db, { module, keyword, hasTranslation, locale, options });

  // append plugin displayName
  const cache = ctx.app.cache as Cache;
  const pm = ctx.app.pm as PluginManager;
  const plugins = await cache.wrap(`lm-plugins:${locale}`, () => pm.list({ locale }));
  const modules = [
    ...EXTEND_MODULES,
    ...plugins.map((plugin) => ({
      value: plugin.alias || plugin.name,
      label: plugin.displayName,
    })),
  ];
  for (const row of rows) {
    const moduleName = (row.get('module') as string).replace('resources.', '');
    const module = modules.find((module) => module.value === moduleName);
    if (module) {
      row.set('moduleTitle', module.label, { raw: true });
    }
  }
  ctx.body = {
    count,
    rows,
    page,
    pageSize,
    totalPage: Math.ceil(count / pageSize),
    modules: [
      ...EXTEND_MODULES,
      ...plugins.map((plugin) => ({
        value: plugin.alias || plugin.name,
        label: plugin.displayName,
      })),
    ],
  };
  await next();
};

export default { list };