17 Commits

Author SHA1 Message Date
keven1024
3001ea3250 fix(front): enhance error handling in file download components by refining error message extraction 2025-07-07 15:55:08 +08:00
keven1024
1b12703b90 refactor(front): update file sharing logic to use downloadFileByShareId for improved error handling and token management 2025-07-07 15:49:01 +08:00
keven1024
e4bb9781f7 fix(front): improve type safety in GlobalDrawer and PasswallShareDrawer components by refining computed properties and prop handling 2025-07-07 15:37:22 +08:00
keven1024
943a5a76d2 feat(backend): enhance password handling in share and download controllers for improved security and error management 2025-07-07 15:30:37 +08:00
keven1024
71147451bb feat: add PasswallShareDrawer component for password-protected file sharing and enhance getShareToken function to accept password 2025-07-07 15:29:05 +08:00
keven1024
3d88c68ed5 fix: refactor InputField component to improve attribute binding and remove unused props 2025-07-07 15:23:20 +08:00
keven1024
338e22dfca fix: improve drawer management by adding onClose handler and refactoring GlobalDrawer component 2025-07-07 14:55:26 +08:00
keven1024
464dba2546 feat: add password hashing utility using argon2 for secure password storage 2025-07-07 12:24:59 +08:00
keven1024
a3dd28dd92 fix: update useStore to set key value to null instead of undefined for better state management 2025-07-07 11:21:03 +08:00
keven1024
9fd4943bb6 fix: update GlobalDrawer component to use direct drawer reference for improved state management 2025-07-07 11:20:42 +08:00
keven1024
668a2dd4d8 fix: adjust alreadyUploadSize computation to prevent exceeding total file size 2025-07-02 10:38:59 +08:00
keven1024
695395ba6a feat: set staleTime to Infinity in TextShareResult component for persistent query data 2025-07-01 14:26:24 +08:00
keven1024
a0cff53901 feat: enhance TextShareView component with copy functionality for preview text and update share data structure 2025-07-01 12:53:18 +08:00
keven1024
7d8075277d feat: enhance TextShareResult component with download count, expiration time, and pickup code display 2025-07-01 12:45:05 +08:00
keven1024
862b381e65 feat: update .env.example to include frontend configuration options for site title, description, and URL 2025-07-01 11:38:13 +08:00
keven1024
745ae94c49 feat: add .env.example file with configuration options for download secret, upload path, Redis URL, and admin information 2025-07-01 11:22:23 +08:00
keven
8c60d32ac0 feat: 更新 README 和新增中文文档,详细介绍 015 文件分享平台的功能、技术架构及快速开始指南 2025-06-30 08:28:51 +08:00
24 changed files with 1137 additions and 563 deletions

16
.env.example Normal file
View File

@@ -0,0 +1,16 @@
# 你的下载secret每一次下载次数减1的时候都会根据这里的secret生成一个下载jwt token 有效期一小时使用该下载token有效期内可以多线程下载该文件而不会被多次扣除次数
DOWNLOAD_SECRET="your-secret-token"
UPLOAD_PATH="/upload" # 上传路径
REDIS_URL="redis://127.0.0.1:6379/0" # redis 地址
NODE_ENV="production" # 指定系统环境 production 或者 dev
MAX_LOCALSTORAGE_SIZE="100GB" # 指定实例最大上传容量支持填写人类可读的值比如1TB500GB等
# (可选): 系统状态页面显示站长信息的 头像会使用email的gravatar头像点击是触发mailto:your-email不填写不显示站长信息
ADMIN_EMAIL="keven@fudaoyuan.icu"
ADMIN_NAME="keven"
# 下面的env是前端渲染用到的SITE_URL必填对应你的公网域名
SITE_TITLE="015"
SITE_DESC="015 是一个开源的临时内容分享平台项目, 支持文件和文本上传, 下载, 分享"
SITE_URL="http://localhost:5000"

232
README.md
View File

@@ -1,20 +1,220 @@
# 015 # 015
这里是send企划 015 (/ˈzɪərəʊ wʌn faɪv/, "zero-one-five") is a self-hosted temporary file sharing platform. Focused on providing one-time, temporary file and text upload, processing, and sharing services. The project name originates from [Ichigo](https://darling-in-the-franxx.fandom.com/wiki/Ichigo) from DARLING in the FRANXX.
功能: A modern file sharing website built with Vue 3 + Nuxt 3 + Go, supporting file upload, text sharing, image compression, concurrent processing, instant transfer functionality, and more, featuring a complete sharing management and access control system.
- ✅ 前端计算hash和秒传
- ✅ 并发切片上传 (使用webWorker计算)
- ✅ 文件上传/文本上传和分享
- ✅ 上传统计页面
- ✅ 多语言支持
- ✅ 最大上传限制
- ✅ 后端有队列系统和worker处理文件
todo: ![015 Platform Overview](/docs/image/0.png)
- 断点续传(后端计算已上传部分并返回)
- 图片格式转换 压缩 ## 🌟 Features
- 图片ocr 复制
- xx转markdown ### Core Functionality
- 文本翻译/总结
- 支持上传多文件 🖼️ **High-Performance File Upload** - Supports large file chunked uploads with frontend file hash calculation for instant transfer
📱 **Responsive Design** - Modern UI based on Tailwind V4 + Reka UI, adapts to various devices
**Concurrent Processing** - Uses Web Worker for frontend hash calculation, backend queue system for task processing
🌐 **Multi-language Support** - Complete Chinese and English internationalization support
🔗 **Share Management** - Flexible sharing link generation and management system
### File Processing
🔄 **Smart Instant Transfer** - Frontend instant transfer detection based on file hash + file size, avoiding duplicate uploads
📷 **Image Compression** - Automatic image compression functionality supporting multiple formats
🖼️ **File Preview** - Supports preview of images, videos, audio, documents, and various file types
📊 **Upload Statistics** - Real-time display of upload progress and file information
🌈 **Resume Upload** - Supports resuming uploads after interruption
### Advanced Features
🎛️ **Share Control** - Supports password protection, download count limits, and expiration time settings
🔍 **Pickup Code System** - Supports pickup code sharing, simplifying sharing difficulty
**Queue Processing** - Asynchronous task processing system based on Redis + Asynq
🗂️ **File Management** - Complete file lifecycle management
📷 **Image Processing** - Image compression, format conversion, and other processing features
🏷️ **Download Control** - Download token management system based on JWT
## 📸 Screenshots
![](/docs/image/1.webp)
![](/docs/image/2.webp)
![](/docs/image/3.png)
![](/docs/image/4.png)
## 🏗️ Technical Architecture
### Frontend Tech Stack
- **Vue 3** - Progressive JavaScript framework
- **Nuxt 3** - Vue.js full-stack framework
- **TypeScript** - Complete type safety
- **Tailwind CSS** - Atomic CSS framework
- **Reka UI** - Modern component library
- **Pinia** - State management
- **TanStack Query** - Data fetching and caching
- **Vue Router** - Routing management
- **i18next** - Internationalization support
### Backend Tech Stack
- **Go 1.23** - High-performance server-side language
- **Echo** - High-performance HTTP framework
- **Redis** - Caching and session storage
- **Asynq** - Asynchronous task queue
- **JWT** - Authentication
- **Zap** - Structured logging
### Build System
- **Node.js** - Server-side runtime
- **pnpm** - Fast package manager
- **Husky** - Git hooks management
- **Prettier** - Code formatting
- **Lint-staged** - Staged file checking
### Storage Architecture
- **File Storage** - Local file system storage
- **Redis Cache** - Share information and file metadata caching
- **Queue System** - Asynchronous task processing queue
## 🚀 Quick Start
### Requirements
- Node.js 18+
- Go 1.23+
- Redis 6+
- pnpm 9+
### Install Dependencies
```bash
# Install root dependencies
pnpm install
# Install frontend dependencies
cd front && pnpm install
# Install backend dependencies
cd backend && go mod download
# Install Worker dependencies
cd worker && go mod download
```
### Environment Configuration
```bash
# Copy environment variables file
cp .env.example .env
# Configure necessary environment variables
REDIS_URL=redis://localhost:6379
UPLOAD_PATH=./uploads
download_secret=your_download_secret
```
### Start Services
```bash
# Start all services in development mode
pnpm run dev
# Or start separately
pnpm run dev:front # Frontend service (port 5000)
pnpm run dev:backend # Backend service (port 1323)
pnpm run dev:worker # Worker service
```
## 📁 Project Structure
```
015/
├── front/ # Frontend application (Vue 3 + Nuxt 3)
│ ├── components/ # Vue components
│ │ ├── pages/ # Page routes
│ │ ├── composables/ # Composable functions
│ │ ├── i18n/ # Internationalization files
│ │ └── assets/ # Static assets
│ ├── backend/ # Backend service (Go + Echo)
│ │ ├── internal/ # Internal packages
│ │ │ ├── controllers/ # Controllers
│ │ │ ├── models/ # Data models
│ │ │ ├── services/ # Business logic
│ │ │ └── utils/ # Utility functions
│ │ └── middleware/ # Middleware
│ ├── worker/ # Asynchronous task processing (Go + Asynq)
│ │ ├── internal/ # Internal packages
│ │ │ ├── tasks/ # Task processors
│ │ │ └── utils/ # Utility functions
│ │ └── middleware/ # Middleware
│ └── tmp/ # Temporary files
```
## 🔧 Development Guide
### Code Standards
- Use Prettier for code formatting
- Use Husky + lint-staged for pre-commit checking
- Follow TypeScript type safety standards
### Commit Standards
```bash
# Code formatting will run automatically before commit
git add .
git commit -m "feat: add new feature"
```
### Build and Deploy
```bash
# Build frontend
cd front && pnpm run build
# Build backend (requires Go environment)
cd backend && go build -o main .
# Build Worker
cd worker && go build -o worker .
```
## 📝 Development Roadmap
### Completed Features ✅
- Frontend hash calculation and instant transfer
- Concurrent chunked upload (using Web Worker)
- File upload/text upload and sharing
- Upload statistics page
- Multi-language support
- Maximum upload limits
- Backend queue system and Worker file processing
### Planned Features 🚧
- Resume upload (backend calculates uploaded parts and returns)
- Image format conversion and compression
- Image OCR copy
- Document to Markdown conversion
- Text translation/summarization
- Support for multiple file uploads
## 🤝 Contributing
Welcome to submit Issues and Pull Requests to improve this project.
## 📄 License
This project is licensed under AGPLV3.
## 🔗 Related Links
- [Vue 3 Documentation](https://vuejs.org/)
- [Nuxt 3 Documentation](https://nuxt.com/)
- [Echo Framework Documentation](https://echo.labstack.com/)
- [Asynq Documentation](https://github.com/hibiken/asynq)

View File

@@ -13,8 +13,10 @@ require (
github.com/matoous/go-nanoid/v2 v2.1.0 github.com/matoous/go-nanoid/v2 v2.1.0
github.com/redis/go-redis/v9 v9.7.3 github.com/redis/go-redis/v9 v9.7.3
github.com/samber/lo v1.50.0 github.com/samber/lo v1.50.0
github.com/spf13/cast v1.7.1
github.com/spf13/viper v1.20.1 github.com/spf13/viper v1.20.1
go.uber.org/zap v1.27.0 go.uber.org/zap v1.27.0
golang.org/x/crypto v0.39.0
golang.org/x/time v0.11.0 golang.org/x/time v0.11.0
) )
@@ -35,16 +37,14 @@ require (
github.com/sagikazarmark/locafero v0.7.0 // indirect github.com/sagikazarmark/locafero v0.7.0 // indirect
github.com/sourcegraph/conc v0.3.0 // indirect github.com/sourcegraph/conc v0.3.0 // indirect
github.com/spf13/afero v1.12.0 // indirect github.com/spf13/afero v1.12.0 // indirect
github.com/spf13/cast v1.7.1 // indirect
github.com/spf13/pflag v1.0.6 // indirect github.com/spf13/pflag v1.0.6 // indirect
github.com/subosito/gotenv v1.6.0 // indirect github.com/subosito/gotenv v1.6.0 // indirect
github.com/valyala/bytebufferpool v1.0.0 // indirect github.com/valyala/bytebufferpool v1.0.0 // indirect
github.com/valyala/fasttemplate v1.2.2 // indirect github.com/valyala/fasttemplate v1.2.2 // indirect
go.uber.org/multierr v1.11.0 // indirect go.uber.org/multierr v1.11.0 // indirect
golang.org/x/crypto v0.36.0 // indirect
golang.org/x/net v0.37.0 // indirect golang.org/x/net v0.37.0 // indirect
golang.org/x/sys v0.31.0 // indirect golang.org/x/sys v0.33.0 // indirect
golang.org/x/text v0.23.0 // indirect golang.org/x/text v0.26.0 // indirect
google.golang.org/protobuf v1.36.5 // indirect google.golang.org/protobuf v1.36.5 // indirect
gopkg.in/yaml.v3 v3.0.1 // indirect gopkg.in/yaml.v3 v3.0.1 // indirect
) )

View File

@@ -90,15 +90,15 @@ go.uber.org/multierr v1.11.0 h1:blXXJkSxSSfBVBlC76pxqeO+LN3aDfLQo+309xJstO0=
go.uber.org/multierr v1.11.0/go.mod h1:20+QtiLqy0Nd6FdQB9TLXag12DsQkrbs3htMFfDN80Y= go.uber.org/multierr v1.11.0/go.mod h1:20+QtiLqy0Nd6FdQB9TLXag12DsQkrbs3htMFfDN80Y=
go.uber.org/zap v1.27.0 h1:aJMhYGrd5QSmlpLMr2MftRKl7t8J8PTZPA732ud/XR8= go.uber.org/zap v1.27.0 h1:aJMhYGrd5QSmlpLMr2MftRKl7t8J8PTZPA732ud/XR8=
go.uber.org/zap v1.27.0/go.mod h1:GB2qFLM7cTU87MWRP2mPIjqfIDnGu+VIO4V/SdhGo2E= go.uber.org/zap v1.27.0/go.mod h1:GB2qFLM7cTU87MWRP2mPIjqfIDnGu+VIO4V/SdhGo2E=
golang.org/x/crypto v0.36.0 h1:AnAEvhDddvBdpY+uR+MyHmuZzzNqXSe/GvuDeob5L34= golang.org/x/crypto v0.39.0 h1:SHs+kF4LP+f+p14esP5jAoDpHU8Gu/v9lFRK6IT5imM=
golang.org/x/crypto v0.36.0/go.mod h1:Y4J0ReaxCR1IMaabaSMugxJES1EpwhBHhv2bDHklZvc= golang.org/x/crypto v0.39.0/go.mod h1:L+Xg3Wf6HoL4Bn4238Z6ft6KfEpN0tJGo53AAPC632U=
golang.org/x/net v0.37.0 h1:1zLorHbz+LYj7MQlSf1+2tPIIgibq2eL5xkrGk6f+2c= golang.org/x/net v0.37.0 h1:1zLorHbz+LYj7MQlSf1+2tPIIgibq2eL5xkrGk6f+2c=
golang.org/x/net v0.37.0/go.mod h1:ivrbrMbzFq5J41QOQh0siUuly180yBYtLp+CKbEaFx8= golang.org/x/net v0.37.0/go.mod h1:ivrbrMbzFq5J41QOQh0siUuly180yBYtLp+CKbEaFx8=
golang.org/x/sys v0.6.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg= golang.org/x/sys v0.6.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
golang.org/x/sys v0.31.0 h1:ioabZlmFYtWhL+TRYpcnNlLwhyxaM9kWTDEmfnprqik= golang.org/x/sys v0.33.0 h1:q3i8TbbEz+JRD9ywIRlyRAQbM0qF7hu24q3teo2hbuw=
golang.org/x/sys v0.31.0/go.mod h1:BJP2sWEmIv4KK5OTEluFJCKSidICx8ciO85XgH3Ak8k= golang.org/x/sys v0.33.0/go.mod h1:BJP2sWEmIv4KK5OTEluFJCKSidICx8ciO85XgH3Ak8k=
golang.org/x/text v0.23.0 h1:D71I7dUrlY+VX0gQShAThNGHFxZ13dGLBHQLVl1mJlY= golang.org/x/text v0.26.0 h1:P42AVeLghgTYr4+xUnTRKDMqpar+PtX7KWuNQL21L8M=
golang.org/x/text v0.23.0/go.mod h1:/BLNzu4aZCJ1+kcD0DNRotWKage4q2rGVAg4o22unh4= golang.org/x/text v0.26.0/go.mod h1:QK15LZJUUQVJxhz7wXgxSy/CJaTFjd0G+YLonydOVQA=
golang.org/x/time v0.11.0 h1:/bpjEDfN9tkoN/ryeYHnv5hcMlc8ncjMcM4XBk5NWV0= golang.org/x/time v0.11.0 h1:/bpjEDfN9tkoN/ryeYHnv5hcMlc8ncjMcM4XBk5NWV0=
golang.org/x/time v0.11.0/go.mod h1:CDIdPxbZBQxdj6cxyCIdrNogrJKMJ7pr37NYpMcMDSg= golang.org/x/time v0.11.0/go.mod h1:CDIdPxbZBQxdj6cxyCIdrNogrJKMJ7pr37NYpMcMDSg=
google.golang.org/protobuf v1.36.5 h1:tPhr+woSbjfYvY6/GPufUoYizxw1cF/yFoxJ2fmpwlM= google.golang.org/protobuf v1.36.5 h1:tPhr+woSbjfYvY6/GPufUoYizxw1cF/yFoxJ2fmpwlM=

View File

@@ -72,8 +72,17 @@ func VaildateShare(c echo.Context) error {
if shareInfo == nil { if shareInfo == nil {
return utils.HTTPErrorHandler(c, errors.New("分享不存在")) return utils.HTTPErrorHandler(c, errors.New("分享不存在"))
} }
if shareInfo.Password != "" && shareInfo.Password != r.Password { if shareInfo.Password != "" {
return utils.HTTPErrorHandler(c, errors.New("分享密码错误")) if r.Password == "" {
return utils.HTTPErrorHandler(c, errors.New("缺少分享密码"))
}
hash, err := utils.GeneratePasswordHash(r.Password)
if err != nil {
return utils.HTTPErrorHandler(c, err)
}
if hash != shareInfo.Password {
return utils.HTTPErrorHandler(c, errors.New("分享密码错误"))
}
} }
// 如果下载次数为0则设置为-1 防止空值问题 // 如果下载次数为0则设置为-1 防止空值问题
if shareInfo.ViewNum < 1 { if shareInfo.ViewNum < 1 {

View File

@@ -64,17 +64,25 @@ func CreateShareInfo(c echo.Context) error {
return utils.HTTPErrorHandler(c, errors.New("分享文件状态错误")) return utils.HTTPErrorHandler(c, errors.New("分享文件状态错误"))
} }
} }
password := ""
if r.Config.Password != "" {
hash, err := utils.GeneratePasswordHash(r.Config.Password)
if err != nil {
return utils.HTTPErrorHandler(c, err)
}
password = hash
}
models.SetRedisShareInfo(id, models.RedisShareInfo{ models.SetRedisShareInfo(id, models.RedisShareInfo{
Data: r.Data, Data: r.Data,
Type: r.Type, Type: r.Type,
CreatedAt: time.Now().Unix(), CreatedAt: time.Now().Unix(),
Owner: cc.Auth.(string), Owner: cc.Auth.(string),
ViewNum: r.Config.ViewNum, ViewNum: r.Config.ViewNum,
Password: r.Config.Password, Password: password,
NotifyEmail: r.Config.NotifyEmail, // NotifyEmail: r.Config.NotifyEmail,
FileName: r.FileName, FileName: r.FileName,
ExpireAt: ExpireTime.Unix(), ExpireAt: ExpireTime.Unix(),
}) })
var pickupCode string var pickupCode string
if r.Config.HasPickupCode { if r.Config.HasPickupCode {
@@ -153,6 +161,7 @@ func GetShareInfo(c echo.Context) error {
"type": shareInfo.Type, "type": shareInfo.Type,
"name": shareInfo.FileName, "name": shareInfo.FileName,
"download_nums": shareInfo.ViewNum, "download_nums": shareInfo.ViewNum,
"has_password": shareInfo.Password != "",
"expire_at": shareInfo.ExpireAt, "expire_at": shareInfo.ExpireAt,
"owner": shareInfo.Owner, "owner": shareInfo.Owner,
"size": fileInfo.FileSize, "size": fileInfo.FileSize,
@@ -165,6 +174,7 @@ func GetShareInfo(c echo.Context) error {
"type": shareInfo.Type, "type": shareInfo.Type,
"name": shareInfo.FileName, "name": shareInfo.FileName,
"download_nums": shareInfo.ViewNum, "download_nums": shareInfo.ViewNum,
"has_password": shareInfo.Password != "",
"expire_at": shareInfo.ExpireAt, "expire_at": shareInfo.ExpireAt,
"owner": shareInfo.Owner, "owner": shareInfo.Owner,
}) })

View File

@@ -0,0 +1,17 @@
package utils
import (
"errors"
"fmt"
"golang.org/x/crypto/argon2"
)
func GeneratePasswordHash(password string) (string, error) {
salt := GetEnv("PASSWORD_SALT")
if salt == "" {
return "", errors.New("请配置PASSWORD_SALT")
}
hash := argon2.IDKey([]byte(password), []byte(salt), 1, 64*1024, 4, 32)
return fmt.Sprintf("%x", hash), nil
}

221
docs/README-zh.md Normal file
View File

@@ -0,0 +1,221 @@
# 015
015 (/ˈzɪərəʊ wʌn faɪv/, "zero-one-five") 是一个支持selfhosted的临时文件分享平台。专注于提供一次性临时的文件和文本上传处理分享服务。项目名称来源于DARLING in the FRANXX的 [](https://darling-in-the-franxx.fandom.com/wiki/Ichigo)
一个基于 Vue 3 + Nuxt 3 + Go 构建的现代文件分享网站,支持文件上传、文本分享、图片压缩、并发处理、秒传功能等,具备完整的分享管理和访问控制体系。
![015 Platform Overview](./image/0.png)
## 🌟 功能特性
### 核心功能
🖼️ **高性能文件上传** - 支持大文件切片上传,前端计算文件哈希实现秒传
📱 **响应式设计** - 基于 Tailwind V4 + Reka UI 的现代化 UI适配各种设备
**并发处理** - 使用 Web Worker 进行前端Hash计算后端队列系统处理任务
🌐 **多语言支持** - 完整的中英文国际化支持
🔗 **分享管理** - 灵活的分享链接生成和管理系统
### 文件处理
🔄 **智能秒传** - 基于文件哈希+文件大小的前端秒传检测,避免重复上传
📷 **图片压缩** - 自动图片压缩功能,支持多种格式
🖼️ **文件预览** - 支持图片、视频、音频、文档等多种文件类型预览
📊 **上传统计** - 实时显示上传进度和文件信息
🌈 **断点续传** - 支持上传中断后的续传功能
### 高级功能
🎛️ **分享控制** - 支持密码保护、下载次数限制、过期时间设置
🔍 **取件码系统** - 支持取件码分享,简化分享难度
**队列处理** - 基于 Redis + Asynq 的异步任务处理系统
🗂️ **文件管理** - 完整的文件生命周期管理
📷 **图片处理** - 图片压缩、格式转换等处理功能
🏷️ **下载控制** - 基于 JWT 的下载令牌管理系统
## 截图
![](./image/1.webp)
![](./image/2.webp)
![](./image/3.png)
![](./image/4.png)
## 🏗️ 技术架构
### 前端技术栈
- **Vue 3** - 渐进式 JavaScript 框架
- **Nuxt 3** - Vue.js 全栈框架
- **TypeScript** - 完整的类型安全
- **Tailwind CSS** - 原子化 CSS 框架
- **Reka UI** - 现代化组件库
- **Pinia** - 状态管理
- **TanStack Query** - 数据获取和缓存
- **Vue Router** - 路由管理
- **i18next** - 国际化支持
### 后端技术栈
- **Go 1.23** - 高性能服务器端语言
- **Echo** - 高性能 HTTP 框架
- **Redis** - 缓存和会话存储
- **Asynq** - 异步任务队列
- **JWT** - 身份验证
- **Zap** - 结构化日志
### 构建系统
- **Node.js** - 服务器端运行时
- **pnpm** - 快速包管理器
- **Husky** - Git hooks 管理
- **Prettier** - 代码格式化
- **Lint-staged** - 暂存文件检查
### 存储架构
- **文件存储** - 本地文件系统存储
- **Redis 缓存** - 分享信息、文件元数据缓存
- **队列系统** - 异步任务处理队列
## 🚀 快速开始
### 环境要求
- Node.js 18+
- Go 1.23+
- Redis 6+
- pnpm 9+
### 安装依赖
```bash
# 安装根目录依赖
pnpm install
# 安装前端依赖
cd front && pnpm install
# 安装后端依赖
cd backend && go mod download
# 安装 Worker 依赖
cd worker && go mod download
```
### 环境配置
```bash
# 复制环境变量文件
cp .env.example .env
# 配置必要的环境变量
REDIS_URL=redis://localhost:6379
UPLOAD_PATH=./uploads
download_secret=your_download_secret
```
### 启动服务
```bash
# 开发模式启动所有服务
pnpm run dev
# 或分别启动
pnpm run dev:front # 前端服务 (端口 5000)
pnpm run dev:backend # 后端服务 (端口 1323)
pnpm run dev:worker # Worker 服务
```
## 📁 项目结构
```
015/
├── front/ # 前端应用 (Vue 3 + Nuxt 3)
│ ├── components/ # Vue 组件
│ │ ├── pages/ # 页面路由
│ │ ├── composables/ # 组合式函数
│ │ ├── i18n/ # 国际化文件
│ │ └── assets/ # 静态资源
│ └── middleware/ # 中间件
├── backend/ # 后端服务 (Go + Echo)
│ ├── internal/ # 内部包
│ │ ├── controllers/ # 控制器
│ │ ├── models/ # 数据模型
│ │ ├── services/ # 业务逻辑
│ │ └── utils/ # 工具函数
│ └── middleware/ # 中间件
├── worker/ # 异步任务处理 (Go + Asynq)
│ ├── internal/ # 内部包
│ │ ├── tasks/ # 任务处理器
│ │ └── utils/ # 工具函数
│ └── middleware/ # 中间件
└── tmp/ # 临时文件
```
## 🔧 开发指南
### 代码规范
- 使用 Prettier 进行代码格式化
- 使用 Husky + lint-staged 进行提交前检查
- 遵循 TypeScript 类型安全规范
### 提交规范
```bash
# 提交前会自动运行代码格式化
git add .
git commit -m "feat: add new feature"
```
### 构建部署
```bash
# 构建前端
cd front && pnpm run build
# 构建后端 (需要 Go 环境)
cd backend && go build -o main .
# 构建 Worker
cd worker && go build -o worker .
```
## 📝 开发计划
### 已完成功能 ✅
- 前端计算哈希和秒传
- 并发切片上传 (使用 Web Worker)
- 文件上传/文本上传和分享
- 上传统计页面
- 多语言支持
- 最大上传限制
- 后端队列系统和 Worker 处理文件
### 计划功能 🚧
- 断点续传 (后端计算已上传部分并返回)
- 图片格式转换和压缩
- 图片 OCR 复制
- 文档转 Markdown
- 文本翻译/总结
- 支持上传多文件
## 🤝 贡献指南
欢迎提交 Issue 和 Pull Request 来改进这个项目。
## 📄 许可证
本项目采用 AGPLV3 许可证。
## 🔗 相关链接
- [Vue 3 文档](https://vuejs.org/)
- [Nuxt 3 文档](https://nuxt.com/)
- [Echo 框架文档](https://echo.labstack.com/)
- [Asynq 文档](https://github.com/hibiken/asynq)

BIN
docs/image/0.png Normal file

Binary file not shown.

After

Width:  |  Height:  |  Size: 1.8 MiB

BIN
docs/image/1.webp Normal file

Binary file not shown.

After

Width:  |  Height:  |  Size: 1.0 MiB

BIN
docs/image/2.webp Normal file

Binary file not shown.

After

Width:  |  Height:  |  Size: 654 KiB

BIN
docs/image/3.png Normal file

Binary file not shown.

After

Width:  |  Height:  |  Size: 1.0 MiB

BIN
docs/image/4.png Normal file

Binary file not shown.

After

Width:  |  Height:  |  Size: 1.0 MiB

View File

@@ -0,0 +1,39 @@
<script setup lang="ts">
import VeeForm from '@/components/VeeForm.vue'
import FormButton from '@/components/Field/FormButton.vue'
import InputField from '@/components/Field/InputField.vue'
import type { FormContext, GenericObject } from 'vee-validate'
import { toast } from 'vue-sonner'
const props = defineProps<{
share_id: string
hide: any
}>()
const { getShareToken } = useMyAppShare()
const handleSubmit = async (form: FormContext<GenericObject, GenericObject>) => {
try {
const password = form.values.password
const token = await getShareToken(props.share_id, { password })
if (!token) {
toast.error('密码错误')
form.resetForm()
return
}
props?.hide(token)
return
} catch (error) {
toast.error('密码错误')
form.resetForm()
}
}
</script>
<template>
<VeeForm>
<div class="flex flex-col gap-5">
<div class="text-xl font-bold">输入密码</div>
<InputField name="password" type="password" rules="required" placeholder="请输入密码" />
<FormButton @click="handleSubmit">提交</FormButton>
</div>
</VeeForm>
</template>

View File

@@ -1,17 +1,15 @@
<template> <template>
<Field :name="props.name" v-slot="{ field }"> <Field :name="props.name" v-slot="{ field }">
<div class="flex flex-col gap-2"> <div class="flex flex-col gap-2">
<Label v-if="props.label">{{ props.label }}</Label> <Label v-if="props.label">{{ props.label }}</Label>
<Input v-bind="field" :placeholder="props.placeholder" :class="props.class" /> <Input v-bind="{ ...field, ...$attrs }" />
</div> </div>
</Field> </Field>
</template> </template>
<script setup lang="ts"> <script setup lang="ts">
import { Input } from '@/components/ui/input' import { Input } from '@/components/ui/input'
const props = defineProps<{ const props = defineProps<{
name: string name: string
label?: string label?: string
placeholder?: string
class?: string
}>() }>()
</script> </script>

View File

@@ -1,8 +1,5 @@
<script setup lang="ts"> <script setup lang="ts">
import { import { Drawer, DrawerContent } from '@/components/ui/drawer'
Drawer,
DrawerContent,
} from '@/components/ui/drawer'
import { createVNode } from 'vue' import { createVNode } from 'vue'
import useStore from '@/composables/useStore' import useStore from '@/composables/useStore'
@@ -10,24 +7,29 @@ const store = useStore('drawer')
const drawer = computed(() => store?._get('drawer')) const drawer = computed(() => store?._get('drawer'))
const currentDrawer = computed(() => drawer?.value?.[drawer?.value?.length - 1]) const currentDrawer = computed(() => drawer?.value?.[drawer?.value?.length - 1])
const render = computed(() => currentDrawer?.value?.render) const render = computed<() => Component>(() => currentDrawer?.value?.render)
const hide = computed<() => void>(() => currentDrawer?.value?.onClose)
const Children = () => const Children = () =>
createVNode(render.value, { createVNode(render.value, {
hide: () => store?._set('drawer', drawer?.value?.slice(0, -1)), hide: hide?.value,
}) })
</script> </script>
<template> <template>
<Drawer :open="!!store?._get('drawer')?.[store?._get('drawer')?.length - 1]" @update:open="(open) => { <Drawer
if (!open && drawer?.length > 0) { :open="!!drawer?.[drawer?.length - 1]"
store?._set('drawer', drawer?.slice(0, -1)) @update:open="
} (open) => {
}"> if (!open && drawer?.length > 0) {
<DrawerContent> hide()
<div class="mx-auto w-full max-w-sm pb-10"> }
<Children /> }
</div> "
</DrawerContent> >
</Drawer> <DrawerContent>
</template> <div class="mx-auto w-full max-w-sm pb-10">
<Children />
</div>
</DrawerContent>
</Drawer>
</template>

View File

@@ -27,7 +27,7 @@ const fileSliceUploadStatusList = ref<
>([]) >([])
const successCount = computed(() => fileSliceUploadStatusList.value.filter((item) => item.status === 'success').length) const successCount = computed(() => fileSliceUploadStatusList.value.filter((item) => item.status === 'success').length)
const alreadyUploadSize = computed(() => successCount.value * chunkSize.value) const alreadyUploadSize = computed(() => Math.min(successCount.value * chunkSize.value, props?.data?.file?.size))
const uploadProgress = computed(() => Math.round((alreadyUploadSize.value / (props?.data?.file?.size || 0)) * 100)) const uploadProgress = computed(() => Math.round((alreadyUploadSize.value / (props?.data?.file?.size || 0)) * 100))
const { error } = useAsyncState(async () => { const { error } = useAsyncState(async () => {

View File

@@ -1,193 +1,166 @@
<script setup lang="ts"> <script setup lang="ts">
import { useQuery } from "@tanstack/vue-query"; import { useQuery } from '@tanstack/vue-query'
import { AsyncButton, Button } from "@/components/ui/button"; import { AsyncButton, Button } from '@/components/ui/button'
import { Skeleton } from "@/components/ui/skeleton"; import { Skeleton } from '@/components/ui/skeleton'
import { filesize } from "filesize"; import { filesize } from 'filesize'
import useMyAppShare from "@/composables/useMyAppShare"; import useMyAppShare from '@/composables/useMyAppShare'
import { toast } from "vue-sonner"; import { toast } from 'vue-sonner'
const emit = defineEmits<{ const emit = defineEmits<{
(e: "change", key: string): void; (e: 'change', key: string): void
}>(); }>()
const props = defineProps<{ const props = defineProps<{
data: { file: File; config: any; handle_type: string; file_id: string }; data: { file: File; config: any; handle_type: string; file_id: string }
}>(); }>()
const { data } = useQuery({ const { data } = useQuery({
queryKey: ["create-image-compress", props?.data?.file_id], queryKey: ['create-image-compress', props?.data?.file_id],
queryFn: async () => { queryFn: async () => {
const { file_id } = props?.data || {}; const { file_id } = props?.data || {}
const data = await $fetch<{ const data = await $fetch<{
code: number; code: number
data: { data: {
id?: string; id?: string
}; }
}>(`/api/image/compress`, { }>(`/api/image/compress`, {
method: "POST", method: 'POST',
body: { body: {
file_id, file_id,
}, },
}); })
return data?.data; return data?.data
}, },
staleTime: Infinity, staleTime: Infinity,
}); })
const taskId = computed(() => data?.value?.id); const taskId = computed(() => data?.value?.id)
const { data: taskData, refetch } = useQuery({ const { data: taskData, refetch } = useQuery({
queryKey: ["image-compress-task", taskId], queryKey: ['image-compress-task', taskId],
queryFn: async () => { queryFn: async () => {
const data = await $fetch<{ const data = await $fetch<{
code: number; code: number
data: { data: {
result: { result: {
old_file: { old_file: {
id: string; id: string
size: number; size: number
}; }
new_file: { new_file: {
id: string; id: string
size: number; size: number
}; }
}[]; }[]
status: "success" | "retry" | "archived"; status: 'success' | 'retry' | 'archived'
err?: { err?: {
message?: string; message?: string
retry?: number; retry?: number
max_retry?: number; max_retry?: number
}; }
}; }
}>(`/api/image/compress/${taskId.value}`); }>(`/api/image/compress/${taskId.value}`)
return data?.data; return data?.data
}, },
enabled: !!taskId.value, enabled: !!taskId.value,
}); })
const { downloadFile, createFileShare } = useMyAppShare(); const { downloadFileByShareId, createFileShare } = useMyAppShare()
const { counter, pause } = useInterval(2000, { controls: true }); const { counter, pause } = useInterval(2000, { controls: true })
watch( watch(
() => counter.value, () => counter.value,
() => { () => {
if (["success", "archived"].includes(taskData.value?.status ?? "")) { if (['success', 'archived'].includes(taskData.value?.status ?? '')) {
pause(); pause()
return; return
}
refetch()
} }
refetch(); )
},
);
watch( watch(
() => taskData.value?.err?.retry, () => taskData.value?.err?.retry,
(newVal, oldVal) => { (newVal, oldVal) => {
if (!oldVal || !newVal || !taskData.value?.err?.max_retry) { if (!oldVal || !newVal || !taskData.value?.err?.max_retry) {
return; return
}
if (newVal <= taskData.value?.err?.max_retry) {
toast.error(`处理错误: ${taskData.value?.err?.message}, 将再次重试`)
}
} }
if (newVal <= taskData.value?.err?.max_retry) { )
toast.error(`处理错误: ${taskData.value?.err?.message}, 将再次重试`);
}
},
);
</script> </script>
<template> <template>
<div class="flex flex-col gap-3"> <div class="flex flex-col gap-3">
<h2 class="text-lg">上传成功</h2> <h2 class="text-lg">上传成功</h2>
<div class="flex flex-col gap-1 items-center"> <div class="flex flex-col gap-1 items-center">
<div class="flex flex-col h-30 items-center justify-center"> <div class="flex flex-col h-30 items-center justify-center">
<FilePreviewView :value="props?.data?.file" /> <FilePreviewView :value="props?.data?.file" />
</div> </div>
</div>
<div
v-if="taskData?.status === 'success'"
class="flex flex-col gap-2"
v-for="item in taskData?.result"
>
<div
class="bg-white/80 p-2 rounded-md w-full flex flex-row items-center justify-between gap-2"
>
<div class="flex flex-row gap-2 items-center max-w-2/3">
<div
class="flex flex-row items-center justify-center rounded-md bg-black/5 p-2"
>
<LucideImage />
</div>
<div class="truncate w-auto">{{ props?.data?.file?.name }}</div>
<div class="flex flex-row gap-2 items-center text-sm shrink-0">
<span class="opacity-75">{{
filesize(item.new_file.size ?? 0)
}}</span>
<span
class="bg-green-200 text-green-600 rounded-md px-1 py-0.5 flex flex-row gap-1 items-center text-xs"
>
<LucideChevronDown class="size-4" />
{{
((1 - item.new_file.size / item.old_file.size) * 100).toFixed(
2,
)
}}%
</span>
</div>
</div> </div>
<AsyncButton <div v-if="taskData?.status === 'success'" class="flex flex-col gap-2" v-for="item in taskData?.result">
variant="outline" <div class="bg-white/80 p-2 rounded-md w-full flex flex-row items-center justify-between gap-2">
class="bg-black/5" <div class="flex flex-row gap-2 items-center max-w-2/3">
size="icon" <div class="flex flex-row items-center justify-center rounded-md bg-black/5 p-2">
@click=" <LucideImage />
async () => { </div>
const data = await createFileShare({ <div class="truncate w-auto">{{ props?.data?.file?.name }}</div>
file_id: item.new_file.id, <div class="flex flex-row gap-2 items-center text-sm shrink-0">
config: { <span class="opacity-75">{{ filesize(item.new_file.size ?? 0) }}</span>
download_nums: 1, <span class="bg-green-200 text-green-600 rounded-md px-1 py-0.5 flex flex-row gap-1 items-center text-xs">
expire_time: 60, <LucideChevronDown class="size-4" />
has_pickup_code: false, {{ ((1 - item.new_file.size / item.old_file.size) * 100).toFixed(2) }}%
has_password: false, </span>
}, </div>
file_name: props?.data?.file?.name, </div>
}); <AsyncButton
const { id } = data?.data || {}; variant="outline"
if (!id) { class="bg-black/5"
return; size="icon"
} @click="
await downloadFile(id); async () => {
} const data = await createFileShare({
" file_id: item.new_file.id,
> config: {
<LucideDownload /> download_nums: 1,
</AsyncButton> expire_time: 60,
</div> has_pickup_code: false,
</div> has_password: false,
<div },
v-else-if="taskData?.status !== 'retry' && !!taskData?.err?.message" file_name: props?.data?.file?.name,
class="flex flex-col gap-2" })
> const { id } = data?.data || {}
<div if (!id) {
class="w-full h-16 flex flex-row items-center gap-3 bg-white/80 rounded-md p-2" return
> }
<div try {
class="size-10 flex items-center justify-center rounded-md bg-red-200" await downloadFileByShareId(id)
> } catch (error: any) {
<LucideAlertTriangle class="size-5 text-red-600" /> toast.error(error?.data?.message || error?.message || error)
}
}
"
>
<LucideDownload />
</AsyncButton>
</div>
</div> </div>
<div class="text-sm"> <div v-else-if="taskData?.status !== 'retry' && !!taskData?.err?.message" class="flex flex-col gap-2">
{{ <div class="w-full h-16 flex flex-row items-center gap-3 bg-white/80 rounded-md p-2">
`经过 ${taskData?.err?.retry} 次重试后任务处理失败: ${taskData?.err?.message}` <div class="size-10 flex items-center justify-center rounded-md bg-red-200">
}} <LucideAlertTriangle class="size-5 text-red-600" />
</div>
<div class="text-sm">
{{ `经过 ${taskData?.err?.retry} 次重试后任务处理失败: ${taskData?.err?.message}` }}
</div>
</div>
<div class="flex flex-row justify-center">
<Button @click="emit('change', 'input')"> 返回首页 </Button>
</div>
</div> </div>
</div>
<div class="flex flex-row justify-center">
<Button @click="emit('change', 'input')"> 返回首页 </Button>
</div>
</div>
<div <div v-else="taskData?.status !== 'retry' && !!taskData?.err?.message" class="flex flex-col gap-2">
v-else="taskData?.status !== 'retry' && !!taskData?.err?.message" <Skeleton class="w-full h-16 flex flex-row items-center justify-between" v-for="i in 3" />
class="flex flex-col gap-2" </div>
>
<Skeleton
class="w-full h-16 flex flex-row items-center justify-between"
v-for="i in 3"
/>
</div> </div>
</div>
</template> </template>

View File

@@ -1,99 +1,143 @@
<script setup lang="ts"> <script setup lang="ts">
import { Button } from "@/components/ui/button"; import { Button } from '@/components/ui/button'
import { Input } from "@/components/ui/input"; import { Input } from '@/components/ui/input'
import { useClipboard } from "@vueuse/core"; import { useClipboard } from '@vueuse/core'
import { toast } from "vue-sonner"; import { toast } from 'vue-sonner'
import { useQuery } from "@tanstack/vue-query"; import { useQuery } from '@tanstack/vue-query'
import useMyAppShare from "@/composables/useMyAppShare"; import useMyAppShare from '@/composables/useMyAppShare'
import useMyAppConfig from "@/composables/useMyAppConfig"; import useMyAppConfig from '@/composables/useMyAppConfig'
import showDrawer from "@/lib/showDrawer"; import showDrawer from '@/lib/showDrawer'
import QrCoreDrawer from "@/components/Drawer/QrCoreDrawer.vue"; import QrCoreDrawer from '@/components/Drawer/QrCoreDrawer.vue'
import dayjs from 'dayjs'
const props = defineProps<{ const props = defineProps<{
data: { text: string; config: any; handle_type: string }; data: { text: string; config: any; handle_type: string }
}>(); }>()
const emit = defineEmits<{ const emit = defineEmits<{
(e: "change", key: string): void; (e: 'change', key: string): void
}>(); }>()
const { createTextShare } = useMyAppShare(); const { createTextShare } = useMyAppShare()
const { data } = useQuery({ const { data } = useQuery({
queryKey: ["create-share", props?.data?.text], queryKey: ['create-share', props?.data?.text],
queryFn: async () => { staleTime: Infinity,
const { config, text } = props?.data || {}; queryFn: async () => {
const data = await createTextShare({ const { config, text } = props?.data || {}
text, const data = await createTextShare({
config, text,
}); config,
return data?.data; })
}, return data?.data
}); },
const appConfig = useMyAppConfig(); })
const appConfig = useMyAppConfig()
const url = computed(() => { const url = computed(() => {
const { id } = data?.value || {}; const { id } = data?.value || {}
return `${appConfig?.value?.site_url}/s/${id}`; return `${appConfig?.value?.site_url}/s/${id}`
}); })
const { copy } = useClipboard(); const { copy } = useClipboard()
</script> </script>
<template> <template>
<div class="flex flex-col gap-3"> <div class="flex flex-col gap-3">
<div class="flex flex-col md:flex-row gap-2"> <div class="flex flex-row gap-2">
<div class="flex flex-row justify-between md:basis-1/2"> <div class="flex flex-row justify-between w-full">
<h2 class="text-lg">分享成功</h2> <h2 class="text-lg">分享成功</h2>
<Button <Button
variant="outline" variant="outline"
class="bg-white/70" class="bg-white/70"
size="icon" size="icon"
@click=" @click="
() => { () => {
emit('change', 'input'); emit('change', 'input')
} }
" "
> >
<LucideHome /> <LucideHome />
</Button> </Button>
</div> </div>
<div class="flex flex-row gap-2 flex-1"> </div>
<Input v-model="url" class="bg-white/70" readonly /> <div class="flex flex-col md:flex-row gap-5 rounded-md p-5 bg-white/20 backdrop-blur-xl w-full">
<Button <div class="flex flex-col gap-2 flex-1">
variant="outline" <div class="text-sm font-semibold">信息</div>
class="bg-white/70" <div class="grid grid-cols-2 gap-2">
size="icon" <div class="rounded-xl flex flex-col bg-black/10 px-3 py-2 gap-1">
@click=" <div class="text-xs font-semibold">下载次数</div>
() => { <div class="text-3xl font-light">{{ data?.download_nums }}</div>
copy(url); </div>
toast.success('复制成功'); <div class="rounded-xl flex flex-col bg-black/5 px-3 py-2 gap-1">
} <div class="text-xs font-semibold">过期时间</div>
" <div class="text-md font-light">
> {{ dayjs((data?.expire_at ?? 0) * 1000).format('YYYY-MM-DD HH:mm:ss') }}
<LucideCopy /> </div>
</Button> </div>
<Button <div class="rounded-xl flex flex-col bg-black/10 px-3 py-2 gap-1" v-if="data?.pickup_code">
variant="outline" <div class="flex flex-row justify-between w-full items-center">
class="bg-white/70" <div class="text-xs font-semibold">提取码</div>
size="icon" <Button
@click=" variant="outline"
() => { class="bg-white/70 p-0 size-6"
showDrawer({ size="icon"
render: ({ ...rest }) => @click="
h(QrCoreDrawer, { () => {
...rest, copy(data?.pickup_code as string)
data: url, toast.success('复制成功')
}), }
}); "
} >
" <LucideCopy class="size-3" />
> </Button>
<LucideQrCode /> </div>
</Button> <div class="flex flex-row gap-2">
</div> <div v-for="s in data?.pickup_code" class="text-2xl font-light">
{{ s }}
</div>
</div>
</div>
</div>
</div>
<div class="flex flex-col gap-5 flex-1">
<div class="text-sm font-semibold">链接</div>
<div class="flex flex-row gap-2">
<Input v-model="url" class="bg-white/70" readonly />
<Button
variant="outline"
class="bg-white/70"
size="icon"
@click="
() => {
copy(url)
toast.success('复制成功')
}
"
>
<LucideCopy />
</Button>
<Button
variant="outline"
class="bg-white/70"
size="icon"
@click="
() => {
showDrawer({
render: ({ ...rest }) =>
h(QrCoreDrawer, {
...rest,
data: url,
}),
})
}
"
>
<LucideQrCode />
</Button>
</div>
</div>
</div>
<h2 class="text-md">内容</h2>
<MarkdownRender class="prose rounded-md bg-white/70 p-3 w-full max-w-full min-h-[30vh]" :markdown="props?.data?.text" />
</div> </div>
<div
class="prose rounded-md bg-white/70 p-3 w-full max-w-full min-h-[30vh]"
v-html="props?.data?.text"
/>
</div>
</template> </template>

View File

@@ -1,69 +1,81 @@
<script setup lang="ts"> <script setup lang="ts">
import AsyncButton from "@/components/ui/button/AsyncButton.vue"; import AsyncButton from '@/components/ui/button/AsyncButton.vue'
import dayjs from "dayjs"; import dayjs from 'dayjs'
import duration from "dayjs/plugin/duration"; import duration from 'dayjs/plugin/duration'
import relativeTime from "dayjs/plugin/relativeTime"; import relativeTime from 'dayjs/plugin/relativeTime'
import { isBoolean } from "lodash-es"; import { isBoolean } from 'lodash-es'
import { LucideCheck, LucideX } from "lucide-vue-next"; import { LucideCheck, LucideX } from 'lucide-vue-next'
import { useQueryClient } from "@tanstack/vue-query"; import { useQueryClient } from '@tanstack/vue-query'
dayjs.extend(duration); import showDrawer from '~/lib/showDrawer'
dayjs.extend(relativeTime); import { toast } from 'vue-sonner'
import PasswallShareDrawer from '~/components/Drawer/PasswallShareDrawer.vue'
dayjs.extend(duration)
dayjs.extend(relativeTime)
const props = defineProps<{ const props = defineProps<{
data: any; data: any
}>(); }>()
const queryClient = useQueryClient(); const queryClient = useQueryClient()
const { downloadFile } = useMyAppShare(); const { downloadFile, getShareToken } = useMyAppShare()
const handleDownload = async () => { const handleDownload = async () => {
const { id } = props?.data || {}; const { id } = props?.data || {}
await downloadFile(id); try {
queryClient.invalidateQueries({ queryKey: ["share", id] }); let token = null
}; if (props?.data?.has_password) {
token = await showDrawer({
render: ({ ...rest }) => h(PasswallShareDrawer, { ...rest, share_id: id }),
})
} else {
token = await getShareToken(id)
}
if (!token) {
throw new Error('获取token失败')
}
downloadFile(token)
} catch (error: any) {
toast.error(error?.data?.message || error?.message || error)
} finally {
queryClient.invalidateQueries({ queryKey: ['share', id] })
}
}
const expireSeconds = computed(() => { const expireSeconds = computed(() => {
return dayjs(props?.data?.expire_at * 10e2).unix() - dayjs().unix(); return dayjs(props?.data?.expire_at * 10e2).unix() - dayjs().unix()
}); })
const { remaining, start } = useCountdown(expireSeconds.value); const { remaining, start } = useCountdown(expireSeconds.value)
onMounted(() => { onMounted(() => {
start(); start()
}); })
const fileShareInfo = computed(() => { const fileShareInfo = computed(() => {
return [ return [
{ label: "需要密码", value: props?.data?.has_password ?? false }, { label: '需要密码', value: props?.data?.has_password ?? false },
{ {
label: "过期时间", label: '过期时间',
value: dayjs.duration(remaining.value, "seconds").format(`D天 HH:mm:ss`), value: dayjs.duration(remaining.value, 'seconds').format(`D天 HH:mm:ss`),
}, },
{ label: "剩余下载次数", value: props?.data?.download_nums ?? 0 }, { label: '剩余下载次数', value: props?.data?.download_nums ?? 0 },
]; ]
}); })
</script> </script>
<template> <template>
<div class="flex flex-col gap-5 items-center"> <div class="flex flex-col gap-5 items-center">
<h1 class="text-xl font-bold">下载文件</h1> <h1 class="text-xl font-bold">下载文件</h1>
<FilePreviewView :value="props?.data" /> <FilePreviewView :value="props?.data" />
<div class="flex flex-col gap-2 md:flex-row w-full"> <div class="flex flex-col gap-2 md:flex-row w-full">
<div <div class="flex flex-row md:flex-col md:gap-1 justify-between items-center md:flex-1" v-for="item in fileShareInfo">
class="flex flex-row md:flex-col md:gap-1 justify-between items-center md:flex-1" <div class="text-xs opacity-75">{{ item?.label }}</div>
v-for="item in fileShareInfo" <component v-if="isBoolean(item?.value)" :is="item?.value ? LucideCheck : LucideX" class="size-6" />
> <div v-else class="md:text-xl">{{ item?.value }}</div>
<div class="text-xs opacity-75">{{ item?.label }}</div> </div>
<component </div>
v-if="isBoolean(item?.value)" <div class="w-full">
:is="item?.value ? LucideCheck : LucideX" <AsyncButton @click="handleDownload" class="w-full">下载</AsyncButton>
class="size-6" </div>
/>
<div v-else class="md:text-xl">{{ item?.value }}</div>
</div>
</div> </div>
<div class="w-full">
<AsyncButton @click="handleDownload" class="w-full">下载</AsyncButton>
</div>
</div>
</template> </template>

View File

@@ -1,93 +1,106 @@
<script setup lang="ts"> <script setup lang="ts">
import dayjs from "dayjs"; import dayjs from 'dayjs'
import AsyncButton from "@/components/ui/button/AsyncButton.vue"; import AsyncButton from '@/components/ui/button/AsyncButton.vue'
import duration from "dayjs/plugin/duration"; import duration from 'dayjs/plugin/duration'
import relativeTime from "dayjs/plugin/relativeTime"; import relativeTime from 'dayjs/plugin/relativeTime'
import { isBoolean } from "lodash-es"; import { isBoolean } from 'lodash-es'
import { LucideCheck, LucideX } from "lucide-vue-next"; import { LucideCheck, LucideX } from 'lucide-vue-next'
import { cx } from "class-variance-authority"; import { cx } from 'class-variance-authority'
import { toast } from "vue-sonner"; import { toast } from 'vue-sonner'
import MarkdownRender from "@/components/MarkdownRender.vue"; import MarkdownRender from '@/components/MarkdownRender.vue'
dayjs.extend(duration); import { Button } from '@/components/ui/button'
dayjs.extend(relativeTime); import { LucideCopy } from 'lucide-vue-next'
import { useClipboard } from '@vueuse/core'
import showDrawer from '~/lib/showDrawer'
import PasswallShareDrawer from '~/components/Drawer/PasswallShareDrawer.vue'
dayjs.extend(duration)
dayjs.extend(relativeTime)
const props = defineProps<{ const props = defineProps<{
data: any; data: any
}>(); }>()
const { getShareToken } = useMyAppShare(); const { getShareToken } = useMyAppShare()
const expireSeconds = computed(() => { const expireSeconds = computed(() => {
return dayjs(props?.data?.expire_at * 10e2).unix() - dayjs().unix(); return dayjs(props?.data?.expire_at * 10e2).unix() - dayjs().unix()
}); })
const { remaining, start } = useCountdown(expireSeconds.value); const { remaining, start } = useCountdown(expireSeconds.value)
const { copy } = useClipboard()
onMounted(() => { onMounted(() => {
start(); start()
}); })
const fileShareInfo = computed(() => { const fileShareInfo = computed(() => {
return [ return [
{ label: "需要密码", value: props?.data?.has_password ?? false }, { label: '需要密码', value: props?.data?.has_password ?? false },
{ {
label: "过期时间", label: '过期时间',
value: dayjs.duration(remaining.value, "seconds").format(`D天 HH:mm:ss`), value: dayjs.duration(remaining.value, 'seconds').format(`D天 HH:mm:ss`),
}, },
{ label: "剩余浏览次数", value: props?.data?.download_nums ?? 0 }, { label: '剩余浏览次数', value: props?.data?.download_nums ?? 0 },
]; ]
}); })
const previewText = ref<string | null>(null); const previewText = ref<string | null>(null)
const handlePreview = async () => { const handlePreview = async () => {
try { try {
const token = await getShareToken(props?.data?.id); let token = null
const r = await $fetch<{ if (props?.data?.has_password) {
code: number; token = await showDrawer({
data: { render: ({ ...rest }) => h(PasswallShareDrawer, { ...rest, share_id: props?.data?.id }),
data: string; })
}; } else {
}>(`/api/download?token=${token}`); token = await getShareToken(props?.data?.id)
previewText.value = r?.data?.data; }
} catch (error) { const r = await $fetch<{
toast.error((error as any)?.data?.message || error); code: number
} data: {
}; data: string
}
}>(`/api/download?token=${token}`)
previewText.value = r?.data?.data
} catch (error: any) {
toast.error(error?.data?.message || error?.message || error)
}
}
</script> </script>
<template> <template>
<div <div :class="cx('flex flex-col max-h-full', !!previewText ? 'gap-3' : 'gap-16 items-center')">
:class=" <div :class="cx('flex flex-row w-full', !!previewText ? 'justify-between' : 'justify-center')">
cx( <h1 class="text-xl">查看文本</h1>
'flex flex-col max-h-full', <Button
!!previewText ? 'gap-3' : 'gap-16 items-center', v-if="!!previewText"
) variant="outline"
" size="icon"
> @click="
<h1 class="text-xl">查看文本</h1> () => {
<template v-if="!previewText"> copy(previewText as string)
<div class="flex flex-col gap-2 md:flex-row w-full"> toast.success('复制成功')
<div }
class="flex flex-row md:flex-col md:gap-1 justify-between items-center md:flex-1" "
v-for="item in fileShareInfo" >
> <LucideCopy />
<div class="text-xs opacity-75">{{ item?.label }}</div> </Button>
<component
v-if="isBoolean(item?.value)"
:is="item?.value ? LucideCheck : LucideX"
class="size-6"
/>
<div v-else class="md:text-xl">{{ item?.value }}</div>
</div> </div>
</div> <template v-if="!previewText">
<div class="w-full"> <div class="flex flex-col gap-2 md:flex-row w-full">
<AsyncButton @click="handlePreview" class="w-full">浏览</AsyncButton> <div class="flex flex-row md:flex-col md:gap-1 justify-between items-center md:flex-1" v-for="item in fileShareInfo">
</div> <div class="text-xs opacity-75">{{ item?.label }}</div>
</template> <component v-if="isBoolean(item?.value)" :is="item?.value ? LucideCheck : LucideX" class="size-6" />
<template v-else> <div v-else class="md:text-xl">{{ item?.value }}</div>
<MarkdownRender </div>
:markdown="previewText" </div>
class="rounded-md bg-white/70 p-3 w-full max-w-full min-h-80 overflow-y-auto" <div class="w-full">
/> <AsyncButton @click="handlePreview" class="w-full">浏览</AsyncButton>
</template> </div>
</div> </template>
<template v-else>
<MarkdownRender :markdown="previewText" class="rounded-md bg-white/70 p-3 w-full max-w-full min-h-80 overflow-y-auto" />
</template>
</div>
</template> </template>

View File

@@ -1,98 +1,109 @@
import { toast } from "vue-sonner"; import { toast } from 'vue-sonner'
declare const window: any
let shareIdTokenMap: WeakMap<{ share_id: string }, string>
let shareIdTokenMap: WeakMap<{ share_id: string }, string>; const getShareToken = async (
share_id: string,
const getShareToken = async (share_id: string): Promise<string | undefined> => { options?: {
if (!shareIdTokenMap) { password?: string
shareIdTokenMap = new WeakMap();
}
let token = shareIdTokenMap.get({ share_id });
if (!token) {
const data = await $fetch<{
code: number;
message: string;
data: {
token?: string;
};
}>(`/api/download`, {
method: "POST",
body: {
share_id,
},
});
if (!data?.data?.token) {
throw new Error(data?.message || "获取token失败");
} }
token = data.data.token; ): Promise<string | undefined> => {
shareIdTokenMap.set({ share_id }, token); if (!shareIdTokenMap) {
} shareIdTokenMap = new WeakMap()
return token; }
}; let token = shareIdTokenMap.get({ share_id })
const { password } = options || {}
const downloadFile = async (share_id: string) => {
try {
const token = await getShareToken(share_id);
if (!token) { if (!token) {
throw new Error("获取token失败"); const data = await $fetch<{
return; code: number
message: string
data: {
token?: string
}
}>(`/api/download`, {
method: 'POST',
body: {
share_id,
password,
},
})
if (!data?.data?.token) {
throw new Error(data?.message || '获取token失败')
}
token = data.data.token
shareIdTokenMap.set({ share_id }, token)
} }
(window as any)?.open(`/api/download?token=${token}`); return token
} catch (e) { }
toast.error((e as any)?.data?.message || e);
} const downloadFile = (token: string) => {
}; window?.open(`/api/download?token=${token}`)
}
const downloadFileByShareId = async (share_id: string) => {
const token = await getShareToken(share_id)
if (!token) {
throw new Error('获取token失败')
}
return downloadFile(token)
}
const createShare = async (data: any) => { const createShare = async (data: any) => {
return await $fetch<{ return await $fetch<{
code: number; code: number
data: { data: {
id?: string; id?: string
}; download_nums?: number
}>(`/api/share`, { expire_at?: number
method: "POST", file_name?: string
body: data, pickup_code?: string
}); }
}; }>(`/api/share`, {
method: 'POST',
body: data,
})
}
const createFileShare = async (data: { const createFileShare = async (data: {
file_id: string; file_id: string
config: { config: {
download_nums: number; download_nums: number
expire_time: number; expire_time: number
has_pickup_code?: boolean; has_pickup_code?: boolean
has_password?: boolean; has_password?: boolean
pickup_code?: string; pickup_code?: string
password?: string; password?: string
notify_email?: string; notify_email?: string
}; }
file_name: string; file_name: string
}) => { }) => {
const { file_id, config, file_name } = data || {}; const { file_id, config, file_name } = data || {}
return await createShare({ return await createShare({
type: "file", type: 'file',
data: file_id, data: file_id,
config, config,
file_name, file_name,
}); })
}; }
const createTextShare = async (data: { text: string; config: any }) => { const createTextShare = async (data: { text: string; config: any }) => {
const { text, config } = data || {}; const { text, config } = data || {}
return await createShare({ return await createShare({
type: "text", type: 'text',
data: text, data: text,
config, config,
}); })
}; }
const useMyAppShare = () => { const useMyAppShare = () => {
return { return {
downloadFile, downloadFile,
createShare, downloadFileByShareId,
createFileShare, createShare,
createTextShare, createFileShare,
getShareToken, createTextShare,
}; getShareToken,
}; }
}
export default useMyAppShare; export default useMyAppShare

View File

@@ -1,35 +1,34 @@
import { defineStore } from 'pinia' import { defineStore } from 'pinia'
import { cloneDeep, get, isEmpty, isUndefined, set,isString } from 'lodash-es' import { cloneDeep, get, isEmpty, isUndefined, set, isString } from 'lodash-es'
type StoreType = Record<string, any> type StoreType = Record<string, any>
const initState: StoreType = {} const initState: StoreType = {}
// 做了一点小小的改进可以传入key会自动初始化如果不初始化的话容易导致不存在值而丢失响应式 // 做了一点小小的改进可以传入key会自动初始化如果不初始化的话容易导致不存在值而丢失响应式
const useStore = (key?: string) => { const useStore = (key?: string) => {
const store = defineStore('store', { const store = defineStore('store', {
state: () => ({ state: () => ({
...initState, ...initState,
}), }),
actions: { actions: {
_get(path?: string) { _get(path?: string) {
if (isEmpty(path) || isUndefined(path)) { if (isEmpty(path) || isUndefined(path)) {
return this.$state return this.$state
} }
return get(this.$state, path) return get(this.$state, path)
}, },
_set(path: string, value: any) { _set(path: string, value: any) {
const newState = cloneDeep(this.$state) const newState = cloneDeep(this.$state)
set(newState, path, value) set(newState, path, value)
this.$patch(newState) this.$patch(newState)
}, },
}, },
persist: true, })()
})() if (!isEmpty(key) && isString(key) && isUndefined(store?._get(key))) {
if (!isEmpty(key) && isString(key) && isUndefined(store?._get(key))) { // console.log('reset', key, store?._get(key))
console.log('reset', key, store?._get(key)) store?._set(key, null)
store?._set(key, undefined) }
} return store
return store
} }
export default useStore export default useStore

View File

@@ -1,11 +1,21 @@
interface DrawerProps { interface DrawerProps {
render: (props: { hide: () => void }) => Component render: (props: { hide: () => void }) => Component
} }
const showDrawer = (props: DrawerProps) => { const showDrawer = (props: DrawerProps) => {
const { render } = props || {} const key = Math.random().toString(36).slice(2, 8)
const store = useStore() return new Promise<void>((res) => {
store?._set('drawer', [...(store?._get('drawer')?.value || []), { render }]) const { render } = props || {}
const onClose = (data?: any) => {
store._set(
'drawer',
(store._get('drawer')?.value ?? [])?.filter((item: any) => item.key !== key)
)
res(data)
}
const store = useStore()
store._set('drawer', [...(store._get('drawer')?.value || []), { render, onClose, key }])
})
} }
export default showDrawer export default showDrawer