SukkaSurge/Build/build-domestic-direct-lan-ruleset-dns-mapping-module.ts

// @ts-check
import path from 'node:path';
import { DOMESTICS } from '../Source/non_ip/domestic';
import { DIRECTS, LANS } from '../Source/non_ip/direct';
import { readFileIntoProcessedArray } from './lib/fetch-text-by-line';
import { compareAndWriteFile, createRuleset } from './lib/create-file';
import { task } from './trace';
import { SHARED_DESCRIPTION } from './lib/constants';
import { createMemoizedPromise } from './lib/memo-promise';
import * as yaml from 'yaml';
import { appendArrayInPlace } from './lib/append-array-in-place';
import { output, writeFile } from './lib/misc';
import { OUTPUT_INTERNAL_DIR, OUTPUT_MODULES_DIR, SOURCE_DIR } from './constants/dir';

export const getDomesticAndDirectDomainsRulesetPromise = createMemoizedPromise(async () => {
  const domestics = await readFileIntoProcessedArray(path.join(SOURCE_DIR, 'non_ip/domestic.conf'));
  const directs = await readFileIntoProcessedArray(path.resolve(SOURCE_DIR, 'non_ip/direct.conf'));
  const lans: string[] = [];

  Object.entries(DOMESTICS).forEach(([, { domains }]) => {
    appendArrayInPlace(domestics, domains.map((domain) => `DOMAIN-SUFFIX,${domain}`));
  });
  Object.entries(DIRECTS).forEach(([, { domains }]) => {
    appendArrayInPlace(directs, domains.map((domain) => `DOMAIN-SUFFIX,${domain}`));
  });
  Object.entries(LANS).forEach(([, { domains }]) => {
    appendArrayInPlace(lans, domains.map((domain) => `DOMAIN-SUFFIX,${domain}`));
  });

  return [domestics, directs, lans] as const;
});

export const buildDomesticRuleset = task(require.main === module, __filename)(async (span) => {
  const res = await getDomesticAndDirectDomainsRulesetPromise();

  const dataset = Object.entries(DOMESTICS);
  appendArrayInPlace(dataset, Object.entries(DIRECTS));
  appendArrayInPlace(dataset, Object.entries(LANS));

  return Promise.all([
    createRuleset(
      span,
      'Sukka\'s Ruleset - Domestic Domains',
      [
        ...SHARED_DESCRIPTION,
        '',
        'This file contains known addresses that are avaliable in the Mainland China.'
      ],
      new Date(),
      res[0],
      'ruleset',
      output('domestic', 'non_ip')
    ),
    createRuleset(
      span,
      'Sukka\'s Ruleset - Direct Rules',
      [
        ...SHARED_DESCRIPTION,
        '',
        'This file contains domains and process that should not be proxied.'
      ],
      new Date(),
      res[1],
      'ruleset',
      output('direct', 'non_ip')
    ),
    createRuleset(
      span,
      'Sukka\'s Ruleset - LAN',
      [
        ...SHARED_DESCRIPTION,
        '',
        'This file includes rules for LAN DOMAIN and reserved TLDs.'
      ],
      new Date(),
      res[2],
      'ruleset',
      output('lan', 'non_ip')
    ),
    compareAndWriteFile(
      span,
      [
        '#!name=[Sukka] Local DNS Mapping',
        `#!desc=Last Updated: ${new Date().toISOString()}`,
        '',
        '[Host]',
        ...dataset.flatMap(([, { domains, dns, hosts }]) => [
          ...Object.entries(hosts).flatMap(([dns, ips]: [dns: string, ips: string[]]) => `${dns} = ${ips.join(', ')}`),
          ...domains.flatMap((domain) => [
            `${domain} = server:${dns}`,
            `*.${domain} = server:${dns}`
          ])
        ])
      ],
      path.resolve(OUTPUT_MODULES_DIR, 'sukka_local_dns_mapping.sgmodule')
    ),
    writeFile(
      path.join(OUTPUT_INTERNAL_DIR, 'clash_nameserver_policy.yaml'),
      yaml.stringify(
        {
          dns: {
            'nameserver-policy': dataset.reduce<Record<string, string | string[]>>(
              (acc, [, { domains, dns }]) => {
                domains.forEach((domain) => {
                  acc[`+.${domain}`] = dns === 'system'
                    ? [
                      'system://',
                      'system',
                      'dhcp://system'
                    ]
                    : dns;
                });

                return acc;
              },
              {}
            )
          },
          hosts: dataset.reduce<Record<string, string>>(
            (acc, [, { domains, dns, ...rest }]) => {
              if ('hosts' in rest) {
                Object.assign(acc, rest.hosts);
              }
              return acc;
            },
            {}
          )
        },
        { version: '1.1' }
      )
    )
  ]);
});