refactor: update

Author: fecommunity

client/pages/install/index.tsx

@@ -0,0 +1,89 @@
+import React, { useState } from 'react';
+import { Form, Input, Button, Checkbox } from 'antd';
+import { UserOutlined, LockOutlined, MailOutlined } from '@ant-design/icons';
+import { useRouter } from 'next/router';
+ 
+const InstallPage = () => {
+  const [form] = Form.useForm();
+  const router = useRouter();
+  const [loading, setLoading] = useState(false);
+  const [error, setError] = useState(null);
+ 
+  const onFinish = async (values) => {
+    setLoading(true);
+    setError(null);
+ 
+    try {
+      // 发送POST请求到你的后端API进行数据库配置验证和初始化
+    //   const response = await axios.post('/api/install', values);
+ 
+    //   if (response.data.success) {
+    //     // 安装成功，重定向到登录页面或其他页面
+    //     router.push('/login');
+    //   } else {
+    //     // 处理错误
+    //     setError(response.data.message);
+    //   }
+    } catch (err) {
+      setError('安装过程中发生错误，请重试。');
+    } finally {
+      setLoading(false);
+    }
+  };
+ 
+  return (
+    <div className="install-container">
+      <h1>安装向导</h1>
+      {error && <div className="error-message">{error}</div>}
+      <Form form={form} onFinish={onFinish} layout="vertical">
+        <Form.Item
+          name="site_title"
+          label="站点标题"
+          rules={[{ required: true, message: '请输入站点标题！' }]}
+        >
+          <Input prefix={<UserOutlined />} placeholder="请输入站点标题" />
+        </Form.Item>
+        <Form.Item
+          name="username"
+          label="用户名"
+          rules={[{ required: true, message: '请输入用户名！' }]}
+        >
+          <Input prefix={<UserOutlined />} placeholder="请输入用户名" />
+        </Form.Item>
+        <Form.Item
+          name="password"
+          label="密码"
+          rules={[{ required: true, message: '请输入密码！' }]}
+          hasFeedback
+        >
+          <Input.Password prefix={<LockOutlined />} placeholder="请输入密码" />
+        </Form.Item>
+        <Form.Item
+          name="email"
+          label="电子邮箱"
+          rules={[
+            { type: 'email', message: '请输入有效的电子邮箱！' },
+            { required: true, message: '请输入电子邮箱！' },
+          ]}
+        >
+          <Input prefix={<MailOutlined />} placeholder="请输入电子邮箱" />
+        </Form.Item>
+        <Form.Item>
+          <Form.Item name="agree" valuePropName="checked" noStyle>
+            <Checkbox>我同意以上条款和条件</Checkbox>
+          </Form.Item>
+          <div className="form-item-error" style={{ color: 'red' }}>
+            {form.getFieldError('agree')?.message}
+          </div>
+        </Form.Item>
+        <Form.Item>
+          <Button type="primary" htmlType="submit" loading={loading}>
+            安装
+          </Button>
+        </Form.Item>
+      </Form>
+    </div>
+  );
+};
+ 
+export default InstallPage;

server/src/modules/install/install.controller.ts

@@ -0,0 +1,20 @@
+import { Controller, Post, Body, Get, Res, UseGuards } from '@nestjs/common';
+import { InstallService } from './install.service';
+import { Response } from 'express';
+import { ApiBearerAuth, ApiOkResponse, ApiTags } from '@nestjs/swagger';
+
+@ApiTags('install')
+@Controller('install')
+export class InstallController {
+  constructor(private readonly installService: InstallService) {}
+
+  @Post('check')
+  async checkEnvFileExists(): Promise<string> {
+    return this.installService.checkEnvFileExists() ? 'Environment file exists.' : 'Please configure your database.';
+  }
+
+  @Post('configure')
+  async configureDatabase(@Body() body: { username: string, password: string, database: string }): Promise<string> {
+    return this.installService.configureDatabase(body).then(() => 'Database configured successfully.');
+  }
+}

server/src/modules/install/install.module.ts

@@ -0,0 +1,14 @@
+import { Module } from '@nestjs/common';
+import { TypeOrmModule } from '@nestjs/typeorm';
+
+import { AuthModule } from '../auth/auth.module';
+import { SettingModule } from '../setting/setting.module';
+import { InstallController } from './install.controller';
+import { InstallService } from './install.service';
+
+@Module({
+  imports: [TypeOrmModule.forFeature([File]), AuthModule, SettingModule],
+  controllers: [InstallController],
+  providers: [InstallService],
+})
+export class InstallModule {}

server/src/modules/install/install.service.ts

@@ -0,0 +1,53 @@
+import { Injectable } from '@nestjs/common';
+import * as fs from 'fs';
+import * as path from 'path';
+import { createConnection } from 'typeorm';
+import { ConfigService } from '@nestjs/config';
+
+@Injectable()
+export class InstallService {
+  private envConfigPath = path.resolve(__dirname, '..', '..', '.env');
+  private configService: ConfigService;
+
+  constructor(configService: ConfigService) {
+    this.configService = configService;
+  }
+
+  checkEnvFileExists(): boolean {
+    return fs.existsSync(this.envConfigPath);
+  }
+
+  async configureDatabase(config: { username: string, password: string, database: string }): Promise<void> {
+    const connection = await createConnection({
+      type: 'mysql',
+      host: 'localhost', // 这里可以改为从body中获取，但为了简化我们固定为localhost
+      port: 3306,        // 同样，可以改为动态获取
+      username: config.username,
+      password: config.password,
+      database: config.database,
+      synchronize: true, // 注意：在生产中不要启用synchronize
+      logging: false,    // 控制台不输出orm日志
+      entities: [__dirname + '/../**/*.entity{.ts,.js}'], // 扫描实体位置
+    });
+
+    try {
+      await connection.connect();
+      console.log('Connected to the database');
+
+      // 写入.env文件
+      const envConfigLines = [
+        `DB_HOST=localhost`, // 也可以动态写入
+        `DB_PORT=3306`,      // 同上
+        `DB_USERNAME=${config.username}`,
+        `DB_PASSWORD=${config.password}`,
+        `DB_NAME=${config.database}`,
+      ];
+
+      fs.writeFileSync(this.envConfigPath, envConfigLines.join('\n'), { encoding: 'utf8' });
+    } catch (error) {
+      throw new Error('Failed to connect to the database: ' + error.message);
+    } finally {
+      await connection.close();
+    }
+  }
+}