🔧 修改配置文件

.gitattributes

@@ -0,0 +1,2 @@
+# Auto detect text files and perform LF normalization
+* text=auto

.github/ISSUE_TEMPLATE/bug_report.yml

@@ -1,39 +0,0 @@
-name: "Bug report"
-description: Bug report
-labels: [pending triage]
-body:
-  - type: markdown
-    attributes:
-      value: |
-        Thanks for taking the time to fill out this bug report!
-  - type: input
-    id: version
-    attributes:
-      label: Alist Version / Alist 版本
-      description: What version of our software are you running?
-      placeholder: v2.0.0
-    validations:
-      required: true
-  - type: textarea
-    id: bug-description
-    attributes:
-      label: Describe the bug / 问题描述
-    validations:
-      required: true
-  - type: textarea
-    id: reproduction
-    attributes:
-      label: Reproduction / 复现链接
-      description: |
-        Please provide a link to a repo that can reproduce the problem you ran into.
-        请提供能复现此问题的链接
-    validations:
-      required: false
-  - type: textarea
-    id: logs
-    attributes:
-      label: 日志 / Logs
-      description: |
-        Please copy and paste any relevant log output.
-        请复制粘贴错误日志，或者截图
-      render: shell

.github/ISSUE_TEMPLATE/config.yml

@@ -1,5 +0,0 @@
-blank_issues_enabled: false
-contact_links:
-  - name: Questions & Discussions & Feature request
-    url: https://github.com/Xhofe/alist/discussions
-    about: Use GitHub discussions for message-board style questions and discussions or feature request.

.github/workflows/build.yml

@@ -2,87 +2,70 @@ name: build
 
 on:
   push:
-    branches: [ v2 ]
+    branches: [ main ]
   pull_request:
-    branches: [ v2 ]
+    branches: [ main ]
 
 jobs:
+
   build:
     strategy:
       matrix:
         platform: [ubuntu-latest]
-        go-version: [1.17]
+        go-version: [1.15]
     name: Build
     runs-on: ${{ matrix.platform }}
     steps:
-      - name: Setup Go
+
+      - name: Set up Go
         uses: actions/setup-go@v2
         with:
           go-version: ${{ matrix.go-version }}
 
-      - name: Set up Node
-        uses: actions/setup-node@v2
-        with:
-          node-version: '16'
-
-      - name: Checkout
+      - name: Check out code into the Go module directory
         uses: actions/checkout@v2
-        with:
-          ref: v2
-          path: alist
 
-      - name: Set up xgo
+      - name: Get dependencies
         run: |
-          docker pull techknowlogick/xgo:latest
-          go install src.techknowlogick.com/xgo@latest
-          sudo apt install upx
-
-      - name: Build
+          sudo apt-get update
+          sudo apt-get -y install gcc-mingw-w64-x86-64
+          sudo apt-get -y install gcc-arm-linux-gnueabihf libc6-dev-armhf-cross
+          sudo apt-get -y install gcc-aarch64-linux-gnu libc6-dev-arm64-cross
+          go get -v -t -d ./...
+          if [ -f Gopkg.toml ]; then
+              curl https://raw.githubusercontent.com/golang/dep/master/install.sh | sh
+              dep ensure
+          fi
+      - name: Build linux
         run: |
-          mv alist/build.sh .
-          bash build.sh web
-          mv dist/* alist/public
-          bash build.sh build
+          CC=gcc CGO_ENABLED=1 GOOS=linux GOARCH=amd64 go build -o alist_linux_amd64 alist.go
+          CC=aarch64-linux-gnu-gcc CGO_ENABLED=1 GOOS=linux GOARCH=arm64 go build -o alist_linux_arm64 alist.go
+          CC=arm-linux-gnueabihf-gcc CGO_ENABLED=1 GOOS=linux GOARCH=arm go build -o alist_linux_arm alist.go
 
-      - name: Upload artifact
+      - name: Build windows
+        run: |
+          CC=x86_64-w64-mingw32-gcc CGO_ENABLED=1 GOOS=windows GOARCH=amd64 go build -o alist_windows_amd64.exe alist.go
+
+      - name: Upload artifacts linux_amd64
         uses: actions/upload-artifact@v2
         with:
-          name: artifact
-          path: alist/build
-  docker:
-    name: Docker
-    runs-on: ubuntu-latest
-    steps:
-      - name: Checkout
-        uses: actions/checkout@v2
-      - name: Docker meta
-        id: meta
-        uses: docker/metadata-action@v3
+          name: alist_linux_amd64
+          path: alist_linux_amd64
+
+      - name: Upload artifacts linux_arm64
+        uses: actions/upload-artifact@v2
         with:
-          images: xhofe/alist
-      - name: Set up Node
-        uses: actions/setup-node@v2
+          name: alist_linux_arm64
+          path: alist_linux_arm64
+
+      - name: Upload artifacts linux_arm
+        uses: actions/upload-artifact@v2
         with:
-          node-version: '16'
-      - name: Build web
-        run: |
-          bash build.sh web
-          mv dist/* public
-      - name: Set up QEMU
-        uses: docker/setup-qemu-action@v1
-      - name: Set up Docker Buildx
-        uses: docker/setup-buildx-action@v1
-      - name: Login to DockerHub
-        uses: docker/login-action@v1
+          name: alist_linux_arm
+          path: alist_linux_arm
+
+      - name: Upload artifacts windows_amd64
+        uses: actions/upload-artifact@v2
         with:
-          username: xhofe
-          password: ${{ secrets.DOCKERHUB_TOKEN }}
-      - name: Build and push
-        id: docker_build
-        uses: docker/build-push-action@v2
-        with:
-          context: .
-          push: true
-          tags: ${{ steps.meta.outputs.tags }}
-          labels: ${{ steps.meta.outputs.labels }}
-          platforms: linux/amd64,linux/arm64,linux/arm/v7,linux/386,linux/arm/v6,linux/s390x
+          name: alist_windows_amd64
+          path: alist_windows_amd64.exe

.github/workflows/release.yml

@@ -1,83 +1,28 @@
 name: release
-
 on:
   push:
     tags:
       - '*'
 
 jobs:
-  release:
-    strategy:
-      matrix:
-        platform: [ubuntu-latest]
-        go-version: [1.17]
-    name: Release
-    runs-on: ${{ matrix.platform }}
-    steps:
-      - name: Setup Go
-        uses: actions/setup-go@v2
-        with:
-          go-version: ${{ matrix.go-version }}
-
-      - name: Checkout
-        uses: actions/checkout@v2
-        with:
-          ref: v2
-          path: alist
-          persist-credentials: false
-          fetch-depth: 0
-
-      - name: Set up xgo
-        run: |
-          docker pull techknowlogick/xgo:latest
-          go install src.techknowlogick.com/xgo@latest
-          sudo apt install upx
-
-      - name: Build
-        run: |
-          mv alist/build.sh .
-          bash build.sh cdn
-          mv dist/* alist/public
-          bash build.sh release
-
-      - name: Release
-        uses: softprops/action-gh-release@v1
-        with:
-          files: alist/build/compress/*
-  docker:
-    name: Docker
+  goreleaser:
     runs-on: ubuntu-latest
     steps:
-      - name: Checkout
+      -
+        name: Checkout
         uses: actions/checkout@v2
-      - name: Docker meta
-        id: meta
-        uses: docker/metadata-action@v3
         with:
-          images: xhofe/alist
-      - name: Set up Node
-        uses: actions/setup-node@v2
+          fetch-depth: 0
+      -
+        name: Set up Go
+        uses: actions/setup-go@v2
         with:
-          node-version: '16'
-      - name: Build web
-        run: |
-          bash build.sh cdn
-          mv dist/* public
-      - name: Set up QEMU
-        uses: docker/setup-qemu-action@v1
-      - name: Set up Docker Buildx
-        uses: docker/setup-buildx-action@v1
-      - name: Login to DockerHub
-        uses: docker/login-action@v1
+          go-version: 1.15
+      -
+        name: Run GoReleaser
+        uses: goreleaser/goreleaser-action@v2
         with:
-          username: xhofe
-          password: ${{ secrets.DOCKERHUB_TOKEN }}
-      - name: Build and push
-        id: docker_build
-        uses: docker/build-push-action@v2
-        with:
-          context: .
-          push: true
-          tags: ${{ steps.meta.outputs.tags }}
-          labels: ${{ steps.meta.outputs.labels }}
-          platforms: linux/amd64,linux/arm64,linux/arm/v7,linux/386,linux/arm/v6,linux/s390x
+          version: latest
+          args: release --rm-dist
+        env:
+          GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}

.gitignore

@@ -20,10 +20,6 @@ dist/
 
 # Dependency directories (remove the comment below to include it)
 # vendor/
+*.yml
 bin/*
-/alist
-*.json
-public/index.html
-public/assets/
-public/public/
-data/
+alist

Dockerfile

@@ -1,14 +0,0 @@
-FROM alpine:edge as builder
-LABEL stage=go-builder
-WORKDIR /app/
-COPY ./ ./
-RUN apk add --no-cache bash git go gcc musl-dev; \
-    sh build.sh docker
-
-FROM alpine:edge
-LABEL MAINTAINER="i@nn.ci"
-VOLUME /opt/alist/data/
-WORKDIR /opt/alist/
-COPY --from=builder /app/bin/alist ./
-EXPOSE 5244
-CMD [ "./alist" ]

README.md

@@ -1,75 +1,62 @@
-<div align="center">
-  <h3><a href="https://alist.nn.ci">Alist</a></h3>
-  <p><em>🗂️Another file list program that supports multiple storage, powered by Gin and React.</em></p>
-  <a href="https://github.com/Xhofe/alist/releases"><img src="https://img.shields.io/github/release/Xhofe/alist?style=flat-square" alt="latest version"></a>
-  <a href="https://github.com/Xhofe/alist/discussions"><img src="https://img.shields.io/github/discussions/Xhofe/alist?color=%23ED8936&style=flat-square" alt="discussions"></a>
-  <a href="https://github.com/Xhofe/alist/actions?query=workflow%3ABuild"><img src="https://img.shields.io/github/workflow/status/Xhofe/alist/build?style=flat-square" alt="Build status"></a>
-  <a href="https://github.com/Xhofe/alist/releases"><img src="https://img.shields.io/github/downloads/Xhofe/alist/total?style=flat-square&color=%239F7AEA" alt="Downloads"></a>
-  <a href="https://github.com/Xhofe/alist/blob/v2/LICENSE"><img src="https://img.shields.io/github/license/Xhofe/alist?style=flat-square" alt="License"></a>
+<p align="center">
+    <img src="https://img.oez.cc/2020/12/24/1fb16bc25a4f6.png" alt="AList Logo" width=200/>
+</p>
+<p align="center">
+  <a href="https://github.com/Xhofe/alist/releases"><img src="https://img.shields.io/github/release/Xhofe/alist" alt="Release version"></a>
+  <a href="https://github.com/Xhofe/alist/actions?query=workflow%3ABuild"><img src="https://github.com/Xhofe/alist/workflows/build/badge.svg" alt="Build status"></a>
+  <a href="https://github.com/Xhofe/alist/releases"><img src="https://img.shields.io/github/downloads/Xhofe/alist/latest/total" alt="Downloads"></a>
+  <a href="https://github.com/Xhofe/alist/blob/main/LICENSE"><img src="https://img.shields.io/github/license/Xhofe/alist" alt="License"></a>
   <a href="https://pay.xhofe.top">
-    <img src="https://img.shields.io/badge/%24-donate-ff69b4.svg?style=flat-square" alt="donate">
+    <img src="https://img.shields.io/badge/%24-donate-ff69b4.svg" alt="donate">
   </a>
-</div>
-
+</p>
 
 ---
 
-English | [中文](./README_cn.md)
+### 这是什么？
 
-## Features
+一款阿里云盘的目录文件列表程序，后端基于`golang`最好的`http`框架`gin`，前端使用`vue`和`ant design`。
 
-- [x] Multiple storage
-  - [x] Local storage
-  - [x] [Aliyundrive](https://www.aliyundrive.com/)
-  - [x] OneDrive / Sharepoint ([global](https://www.office.com/), [cn](https://portal.partner.microsoftonline.cn),de,us)
-  - [x] [189cloud](https://cloud.189.cn)
-  - [x] [GoogleDrive](https://drive.google.com/)
-  - [x] [123pan](https://www.123pan.com/)
-  - [x] [Lanzou](https://pc.woozooo.com/)
-  - [x] [Alist](https://github.com/Xhofe/alist)
-  - [x] FTP
-  - [x] [PikPak](https://www.mypikpak.com/)
-  - [x] [ShandianPan](https://shandianpan.com/)
-  - [x] [S3](https://aws.amazon.com/s3/)
-  - [x] WebDav
-  - [x] Teambition([China](https://www.teambition.com/ ),[International](https://us.teambition.com/ ))
-  - [x] [Mediatrack](https://www.mediatrack.cn/)
-  - [x] [139yun](https://yun.139.com/) (Personal, Family)
-- [x] Easy to deploy and out-of-the-box
-- [x] File preview (PDF, markdown, code, plain text, ...)
-- [x] Image preview in gallery mode
-- [x] Video and audio preview (mp4, mp3, ...)
-- [x] Office documents preview (docx, pptx, xlsx, ...)
-- [x] `README.md` preview rendering
-- [x] File permalink copy and direct file download
-- [x] Dark mode
-- [x] I18n
-- [x] Protected routes (password protection and authentication) 
-- [x] WebDav (see https://alist-doc.nn.ci/en/docs/webdav for details)
-- [x] [Docker Deploy](https://hub.docker.com/r/xhofe/alist)
-- [x] Cloudflare workers proxy
-- [x] File/Folder package download
-- [x] Support video list playback and subtitles(ass,srt,vtt)
-- [x] Web upload(Can allow visitors to upload) and delete
+### 前端项目地址
 
-## Discussion
+- https://github.com/Xhofe/alist-web
 
-Please go to our [discussion forum](https://github.com/Xhofe/alist/discussions) for general questions, **issues are for bug reports  only.**
+### 演示地址
 
-## Demo
+- https://alist.nn.ci
 
-Available at: <https://alist.nn.ci>.
+### 预览
 
-![demo](https://inews.gtimg.com/newsapp_ls/0/14256614096/0)
+<a href="https://alist.nn.ci/"><img src="https://img.oez.cc/2020/12/24/d81d2dab3e5f0.png"></a>
 
-## Document
+### 支持的功能
 
-<https://alist-doc.nn.ci/en/>
+- 自动刷新`token`，`refresh_token`自动更新，失效时间未知，本人使用过程中没有失效过。
+- 图片、视频、音频预览
+- 目录加密
+- `Readme`渲染
+- 自定义根目录
+- 文件直链下载
+- …
 
-## License
+#### TODO
 
-The `AList` is open-source software licensed under the AGPL-3.0 license.
+- [x] 排序
+- [x] 文件预览
+  - [x] 图片
+  - [x] 视频 
+  - [x] 音频
+- [x] `Readme`渲染
+- [x] 密码加密
+- [ ] 搜索与翻页
+- [x] 文件直链
+- [ ] 路径优化
+- [x] 缓存
 
----
+### 如何使用
 
-> [@Blog](https://www.nn.ci/) · [@GitHub](https://github.com/Xhofe)
+- https://www.nn.ci/archives/alist.html
+
+### License
+
+The `AList` is open-source software licensed under the MIT license.

README_cn.md

@@ -1,74 +0,0 @@
-<div align="center">
-  <h3><a href="https://alist.nn.ci">Alist</a></h3>
-  <p><em>🗂️一个支持多存储的文件列表程序，使用 Gin 和 React 。</em></p>
-  <a href="https://github.com/Xhofe/alist/releases"><img src="https://img.shields.io/github/release/Xhofe/alist?style=flat-square" alt="latest version"></a>
-  <a href="https://github.com/Xhofe/alist/discussions"><img src="https://img.shields.io/github/discussions/Xhofe/alist?color=%23ED8936&style=flat-square" alt="discussions"></a>
-  <a href="https://github.com/Xhofe/alist/actions?query=workflow%3ABuild"><img src="https://img.shields.io/github/workflow/status/Xhofe/alist/build?style=flat-square" alt="Build status"></a>
-  <a href="https://github.com/Xhofe/alist/releases"><img src="https://img.shields.io/github/downloads/Xhofe/alist/total?style=flat-square&color=%239F7AEA" alt="Downloads"></a>
-  <a href="https://github.com/Xhofe/alist/blob/v2/LICENSE"><img src="https://img.shields.io/github/license/Xhofe/alist?style=flat-square" alt="License"></a>
-  <a href="https://pay.xhofe.top">
-    <img src="https://img.shields.io/badge/%24-donate-ff69b4.svg?style=flat-square" alt="donate">
-  </a>
-</div>
-
----
-
-[English](./README.md) | 中文
-
-## 支持
-
-- [x] 多种存储
-  - [x] 本地存储
-  - [x] [阿里云盘](https://www.aliyundrive.com/)
-  - [x] OneDrive / Sharepoint（[国际版](https://www.office.com/), [世纪互联](https://portal.partner.microsoftonline.cn),de,us）
-  - [x] [天翼云盘](https://cloud.189.cn)
-  - [x] [GoogleDrive](https://drive.google.com/)
-  - [x] [123云盘](https://www.123pan.com/)
-  - [x] [蓝奏云](https://pc.woozooo.com/)
-  - [x] [Alist](https://github.com/Xhofe/alist)
-  - [x] FTP
-  - [x] [PikPak](https://www.mypikpak.com/)
-  - [x] [闪电盘](https://shandianpan.com/)
-  - [x] [S3](https://aws.amazon.com/cn/s3/)
-  - [x] WebDav
-  - [x] Teambition（[中国](https://www.teambition.com/ )，[国际](https://us.teambition.com/ )）
-  - [x] [分秒帧](https://www.mediatrack.cn/)
-  - [x] [和彩云](https://yun.139.com/) (个人云, 家庭云)
-- [x] 部署方便，开箱即用
-- [x] 文件预览（PDF、markdown、代码、纯文本……）
-- [x] 画廊模式下的图像预览
-- [x] 视频和音频预览（mp4、mp3 等）
-- [x] Office 文档预览（docx、pptx、xlsx、...）
-- [x] `README.md` 预览渲染
-- [x] 文件永久链接复制和直接文件下载
-- [x] 黑暗模式
-- [x] 国际化
-- [x] 受保护的路由（密码保护和身份验证）
-- [x] WebDav（具体见https://alist-doc.nn.ci/docs/webdav ）
-- [x] [Docker 部署](https://hub.docker.com/r/xhofe/alist)
-- [x] Cloudflare workers 中转
-- [x] 文件/文件夹打包下载
-- [x] 支持视频列表播放和字幕(ass,srt,vtt)
-- [x] 网页上传(可以允许访客上传)，删除
-
-## 讨论
-
-一般问题请到[讨论论坛](https://github.com/Xhofe/alist/discussions) ，**issue仅针对错误报告。**
-
-## 演示
-
-<https://alist.nn.ci>。
-
-![演示](https://inews.gtimg.com/newsapp_ls/0/14256614096/0)
-
-## 文档
-
-<https://alist-doc.nn.ci/>
-
-##  许可
-
-`AList` 是在 AGPL-3.0 许可下许可的开源软件。
-
----
-
-> [@Blog](https://www.nn.ci/) · [@GitHub](https://github.com/Xhofe)

alidrive/auth.go

@@ -0,0 +1,75 @@
+package alidrive
+
+import (
+	"encoding/json"
+	"fmt"
+	"github.com/Xhofe/alist/conf"
+	"github.com/Xhofe/alist/utils"
+	log "github.com/sirupsen/logrus"
+)
+
+func TokenLogin() (*TokenLoginResp, error) {
+	log.Infof("尝试使用token登录...")
+	url:="https://auth.aliyundrive.com/v2/oauth/token_login"
+	req:=TokenLoginReq{Token:conf.Conf.AliDrive.LoginToken}
+	log.Debugf("token_login_req:%+v",req)
+	var tokenLogin TokenLoginResp
+	if body, err := DoPost(url, req,false); err != nil {
+		log.Errorf("tokenLogin-doPost出错:%s",err.Error())
+		return nil,err
+	}else {
+		if err = json.Unmarshal(body,&tokenLogin);err!=nil {
+			log.Errorf("解析json[%s]出错:%s",string(body),err.Error())
+			return nil,err
+		}
+	}
+	if tokenLogin.IsAvailable() {
+		return &tokenLogin,nil
+	}
+	return nil,fmt.Errorf("登录token失效,请更换:%s",tokenLogin.Message)
+}
+
+func GetToken(tokenLogin *TokenLoginResp) (*TokenResp,error) {
+	log.Infof("获取API token...")
+	url:="https://websv.aliyundrive.com/token/get"
+	code:=utils.GetCode(tokenLogin.Goto)
+	if code == "" {
+		return nil,fmt.Errorf("获取code出错")
+	}
+	req:=GetTokenReq{Code:code}
+	var token TokenResp
+	if body, err := DoPost(url, req,false); err != nil {
+		log.Errorf("tokenLogin-doPost出错:%s",err.Error())
+		return nil,err
+	}else {
+		if err = json.Unmarshal(body,&token);err!=nil {
+			log.Errorf("解析json[%s]出错:%s",string(body),err.Error())
+			log.Errorf("此处json解析失败应该是code失效")
+			return nil,fmt.Errorf("code失效")
+		}
+	}
+	return &token,nil
+}
+
+func RefreshToken() bool {
+	log.Infof("刷新token...")
+	url:="https://websv.aliyundrive.com/token/refresh"
+	req:=RefreshTokenReq{RefreshToken:conf.Conf.AliDrive.RefreshToken}
+	var token TokenResp
+	if body, err := DoPost(url, req,false); err != nil {
+		log.Errorf("tokenLogin-doPost出错:%s",err.Error())
+		return false
+	}else {
+		if err = json.Unmarshal(body,&token);err!=nil {
+			log.Errorf("解析json[%s]出错:%s",string(body),err.Error())
+			log.Errorf("此处json解析失败应该是refresh_token失效")
+			return false
+		}
+	}
+	//刷新成功 更新token并写入文件
+	conf.Conf.AliDrive.AccessToken=token.AccessToken
+	conf.Conf.AliDrive.RefreshToken=token.RefreshToken
+	conf.Authorization=token.TokenType+"\t"+token.AccessToken
+	utils.WriteToYml(conf.Con,conf.Conf)
+	return true
+}

alidrive/const.go

@@ -0,0 +1,5 @@
+package alidrive
+
+var (
+	User	*UserInfo
+)

alidrive/req_bean.go

@@ -0,0 +1,52 @@
+package alidrive
+
+type ListReq struct {
+	DriveId               string `json:"drive_id"`
+	Fields                string `json:"fields"`
+	ImageThumbnailProcess string `json:"image_thumbnail_process"`
+	ImageUrlProcess       string `json:"image_url_process"`
+	Limit                 int    `json:"limit"`
+	Marker                string `json:"marker"`
+	OrderBy               string `json:"order_by"`
+	OrderDirection        string `json:"order_direction"`
+	ParentFileId          string `json:"parent_file_id"`
+	VideoThumbnailProcess string `json:"video_thumbnail_process"`
+}
+
+type GetReq struct {
+	DriveId               string `json:"drive_id"`
+	FileId                string `json:"file_id"`
+	ImageThumbnailProcess string `json:"image_thumbnail_process"`
+	VideoThumbnailProcess string `json:"video_thumbnail_process"`
+}
+
+type SearchReq struct {
+	DriveId               string `json:"drive_id"`
+	ImageThumbnailProcess string `json:"image_thumbnail_process"`
+	ImageUrlProcess       string `json:"image_url_process"`
+	Limit                 int    `json:"limit"`
+	Marker                string `json:"marker"`
+	OrderBy               string `json:"order_by"` //"type ASC,updated_at DESC"
+
+	Query string `json:"query"` // "name match '测试文件'"
+
+	VideoThumbnailProcess string `json:"video_thumbnail_process"`
+}
+
+type TokenLoginReq struct {
+	Token string `json:"token"`
+}
+
+type GetTokenReq struct {
+	Code string `json:"code"`
+}
+
+type RefreshTokenReq struct {
+	RefreshToken string `json:"refresh_token"`
+}
+
+type OfficePreviewUrlReq struct {
+	AccessToken string `json:"access_token"`
+	DriveId     string `json:"drive_id"`
+	FileId      string `json:"file_id"`
+}

alidrive/request.go

@@ -0,0 +1,181 @@
+package alidrive
+
+import (
+	"bytes"
+	"encoding/json"
+	"fmt"
+	"github.com/Xhofe/alist/conf"
+	log "github.com/sirupsen/logrus"
+	"io/ioutil"
+	"net/http"
+	"strings"
+	"time"
+)
+
+func GetFile(fileId string) (*File, error) {
+	url:=conf.Conf.AliDrive.ApiUrl+"/file/get"
+	req:=GetReq{
+		DriveId:               User.DefaultDriveId,
+		FileId:                fileId,
+		ImageThumbnailProcess: conf.ImageThumbnailProcess,
+		VideoThumbnailProcess: conf.VideoThumbnailProcess,
+	}
+	var resp File
+	if err := BodyToJson(url, req, &resp, true); err!=nil {
+		return nil,err
+	}
+	return &resp,nil
+}
+
+func Search(key string,limit int, marker string) (*Files, error) {
+	url:=conf.Conf.AliDrive.ApiUrl+"/file/search"
+	req:=SearchReq{
+		DriveId:               User.DefaultDriveId,
+		ImageThumbnailProcess: conf.ImageThumbnailProcess,
+		ImageUrlProcess:       conf.ImageUrlProcess,
+		Limit:                 limit,
+		Marker:                marker,
+		OrderBy:               conf.OrderSearch,
+		Query:                 fmt.Sprintf("name match '%s'",key),
+		VideoThumbnailProcess: conf.VideoThumbnailProcess,
+	}
+	var resp Files
+	if err := BodyToJson(url, req, &resp, true); err!=nil {
+		return nil,err
+	}
+	return &resp,nil
+}
+
+func GetRoot(limit int,marker string,orderBy string,orderDirection string) (*Files,error) {
+	return GetList(conf.Conf.AliDrive.RootFolder,limit,marker,orderBy,orderDirection)
+}
+
+func GetList(parent string,limit int,marker string,orderBy string,orderDirection string) (*Files,error) {
+	url:=conf.Conf.AliDrive.ApiUrl+"/file/list"
+	req:=ListReq{
+		DriveId:               User.DefaultDriveId,
+		Fields:                "*",
+		ImageThumbnailProcess: conf.ImageThumbnailProcess,
+		ImageUrlProcess:       conf.ImageUrlProcess,
+		Limit:                 limit,
+		Marker:                marker,
+		OrderBy:               orderBy,
+		OrderDirection:        orderDirection,
+		ParentFileId:          parent,
+		VideoThumbnailProcess: conf.VideoThumbnailProcess,
+	}
+	var resp Files
+	if err := BodyToJson(url, req, &resp, true); err!=nil {
+		return nil,err
+	}
+	return &resp,nil
+}
+
+func GetUserInfo() (*UserInfo,error) {
+	url:=conf.Conf.AliDrive.ApiUrl+"/user/get"
+	var resp UserInfo
+	if err := BodyToJson(url, map[string]interface{}{}, &resp, true); err!=nil {
+		return nil,err
+	}
+	return &resp,nil
+}
+
+func GetOfficePreviewUrl(fileId string) (*OfficePreviewUrlResp,error) {
+	url:=conf.Conf.AliDrive.ApiUrl+"/file/get_office_preview_url"
+	req:=OfficePreviewUrlReq{
+		AccessToken: conf.Conf.AliDrive.AccessToken,
+		DriveId:     User.DefaultDriveId,
+		FileId:      fileId,
+	}
+	var resp OfficePreviewUrlResp
+	if err := BodyToJson(url, req, &resp, true); err!=nil {
+		return nil,err
+	}
+	return &resp,nil
+}
+
+func BodyToJson(url string, req interface{}, resp RespHandle,auth bool) error {
+	if body,err := DoPost(url,req,auth);err!=nil {
+		log.Errorf("doPost出错:%s",err.Error())
+		return err
+	}else {
+		if err = json.Unmarshal(body,&resp);err!=nil {
+			log.Errorf("解析json[%s]出错:%s",string(body),err.Error())
+			return err
+		}
+	}
+	if resp.IsAvailable() {
+		return nil
+	}
+	if resp.GetCode() == conf.AccessTokenInvalid {
+		resp.SetCode("")
+		if RefreshToken() {
+			return BodyToJson(url,req,resp,auth)
+		}
+	}
+	return fmt.Errorf(resp.GetMessage())
+}
+
+func DoPost(url string,request interface{},auth bool) (body []byte, err error) {
+	var(
+		resp *http.Response
+	)
+	requestBody := new(bytes.Buffer)
+	err = json.NewEncoder(requestBody).Encode(request)
+	if err !=nil {
+		log.Errorf("创建requestBody出错:%s",err.Error())
+	}
+	req,err:=http.NewRequest("POST",url,requestBody)
+	log.Debugf("do_post_req:%+v",req)
+	if err != nil {
+		log.Errorf("创建request出错:%s",err.Error())
+		return
+	}
+	if auth {
+		req.Header.Set("authorization",conf.Authorization)
+	}
+	req.Header.Add("content-type","application/json")
+	req.Header.Add("user-agent","Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/87.0.4280.88 Safari/537.36")
+	req.Header.Add("origin","https://aliyundrive.com")
+	req.Header.Add("accept","*/*")
+	req.Header.Add("Accept-Language", "zh-CN,zh;q=0.8,en-US;q=0.5,en;q=0.3")
+	req.Header.Add("Connection", "keep-alive")
+
+	for retryCount := 3; retryCount >= 0; retryCount-- {
+		if resp,err=conf.Client.Do(req);err!=nil&&strings.Contains(err.Error(),"timeout") {
+			<- time.After(time.Second)
+		}else {
+			break
+		}
+	}
+	if err!=nil {
+		log.Errorf("请求阿里云盘api时出错:%s",err.Error())
+		return
+	}
+	if body, err = ioutil.ReadAll(resp.Body); err != nil {
+		log.Errorf("读取api返回内容失败")
+	}
+	log.Debugf("请求返回信息:%s",string(body))
+	return
+}
+
+func GetPaths(fileId string) (*[]Path,error) {
+	paths:=make([]Path,0)
+	for fileId != conf.Conf.AliDrive.RootFolder && fileId != "root" {
+		file,err:=GetFile(fileId)
+		if err !=nil {
+			log.Errorf("获取path出错:%s",err.Error())
+			return nil,err
+		}
+		paths=append(paths,Path{
+			Name:   file.Name,
+			FileId: file.FileId,
+		})
+		fileId=file.ParentFileId
+	}
+	paths=append(paths, Path{
+		Name:   "Root",
+		FileId: "root",
+	})
+	return &paths,nil
+}

alidrive/resp_bean.go

@@ -0,0 +1,161 @@
+package alidrive
+
+import (
+	log "github.com/sirupsen/logrus"
+	"io/ioutil"
+	"net/http"
+	"strings"
+	"time"
+)
+
+type RespHandle interface {
+	IsAvailable() bool
+	GetCode() string
+	GetMessage() string
+	SetCode(code string)
+}
+
+type RespError struct {
+	Code    string `json:"code"`
+	Message string `json:"message"`
+}
+
+func (resp *RespError) IsAvailable() bool {
+	return resp.Code == ""
+}
+
+func (resp *RespError)GetCode() string {
+	return resp.Code
+}
+
+func (resp *RespError)GetMessage() string {
+	return resp.Message
+}
+
+func (resp *RespError)SetCode(code string) {
+	resp.Code=code
+}
+
+type UserInfo struct {
+	RespError
+	DomainId       string                 `json:"domain_id"`
+	UserId         string                 `json:"user_id"`
+	Avatar         string                 `json:"avatar"`
+	CreatedAt      int64                  `json:"created_at"`
+	UpdatedAt      int64                  `json:"updated_at"`
+	Email          string                 `json:"email"`
+	NickName       string                 `json:"nick_name"`
+	Phone          string                 `json:"phone"`
+	Role           string                 `json:"role"`
+	Status         string                 `json:"status"`
+	UserName       string                 `json:"user_name"`
+	Description    string                 `json:"description"`
+	DefaultDriveId string                 `json:"default_drive_id"`
+	UserData       map[string]interface{} `json:"user_data"`
+}
+
+type Files struct {
+	RespError
+	Items      []File `json:"items"`
+	NextMarker string `json:"next_marker"`
+	Readme     string `json:"readme"`
+	Paths      []Path `json:"paths"`
+}
+
+type Path struct {
+	Name   string `json:"name"`
+	FileId string `json:"file_id"`
+}
+
+type File struct {
+	RespError
+	DriveId       string     `json:"drive_id"`
+	CreatedAt     *time.Time `json:"created_at"`
+	DomainId      string     `json:"domain_id"`
+	EncryptMode   string     `json:"encrypt_mode"`
+	FileExtension string     `json:"file_extension"`
+	FileId        string     `json:"file_id"`
+	Hidden        bool       `json:"hidden"`
+	Name          string     `json:"name"`
+	ParentFileId  string     `json:"parent_file_id"`
+	Starred       bool       `json:"starred"`
+	Status        string     `json:"status"`
+	Type          string     `json:"type"`
+	UpdatedAt     *time.Time `json:"updated_at"`
+	// 文件多出部分
+	Category           string                 `json:"category"`
+	ContentHash        string                 `json:"content_hash"`
+	ContentHashName    string                 `json:"content_hash_name"`
+	ContentType        string                 `json:"content_type"`
+	Crc64Hash          string                 `json:"crc_64_hash"`
+	DownloadUrl        string                 `json:"download_url"`
+	PunishFlag         int64                  `json:"punish_flag"`
+	Size               int64                  `json:"size"`
+	Thumbnail          string                 `json:"thumbnail"`
+	Url                string                 `json:"url"`
+	ImageMediaMetadata map[string]interface{} `json:"image_media_metadata"`
+
+	Paths []Path `json:"paths"`
+}
+
+type TokenLoginResp struct {
+	RespError
+	Goto string `json:"goto"`
+}
+
+type TokenResp struct {
+	RespError
+	AccessToken  string `json:"access_token"`
+	RefreshToken string `json:"refresh_token"`
+	ExpiresIn    int    `json:"expires_in"`
+	TokenType    string `json:"token_type"`
+
+	UserInfo
+
+	DefaultSboxDriveId string        `json:"default_sbox_drive_id"`
+	ExpireTime         *time.Time    `json:"expire_time"`
+	State              string        `json:"state"`
+	ExistLink          []interface{} `json:"exist_link"`
+	NeedLink           bool          `json:"need_link"`
+	PinSetup           bool          `json:"pin_setup"`
+	IsFirstLogin       bool          `json:"is_first_login"`
+	NeedRpVerify       bool          `json:"need_rp_verify"`
+	DeviceId           string        `json:"device_id"`
+}
+
+type OfficePreviewUrlResp struct {
+	RespError
+	PreviewUrl  string `json:"preview_url"`
+	AccessToken string `json:"access_token"`
+}
+
+func HasPassword(files *Files) string {
+	fileList := files.Items
+	for i, file := range fileList {
+		if strings.HasPrefix(file.Name, ".password-") {
+			files.Items = fileList[:i+copy(fileList[i:], fileList[i+1:])]
+			return file.Name[10:]
+		}
+	}
+	return ""
+}
+
+func HasReadme(files *Files) string {
+	fileList := files.Items
+	for _, file := range fileList {
+		if file.Name == "Readme.md" {
+			resp, err := http.Get(file.Url)
+			if err != nil {
+				log.Errorf("Get Readme出错:%s", err.Error())
+				return ""
+			}
+			data, err := ioutil.ReadAll(resp.Body)
+			if err != nil {
+				log.Errorf("读取 Readme出错:%s", err.Error())
+				return ""
+			}
+			return string(data)
+		}
+	}
+	return ""
+}

alist.go

@@ -1,59 +1,7 @@
 package main
 
-import (
-	"fmt"
-	"github.com/Xhofe/alist/bootstrap"
-	"github.com/Xhofe/alist/conf"
-	_ "github.com/Xhofe/alist/drivers"
-	"github.com/Xhofe/alist/model"
-	"github.com/Xhofe/alist/server"
-	"github.com/gin-gonic/gin"
-	log "github.com/sirupsen/logrus"
-)
-
-func Init() bool {
-	//bootstrap.InitLog()
-	bootstrap.InitConf()
-	bootstrap.InitCron()
-	bootstrap.InitModel()
-	if conf.Password {
-		pass, err := model.GetSettingByKey("password")
-		if err != nil {
-			log.Errorf(err.Error())
-			return false
-		}
-		log.Infof("current password: %s", pass.Value)
-		return false
-	}
-	server.InitIndex()
-	bootstrap.InitSettings()
-	bootstrap.InitAccounts()
-	bootstrap.InitCache()
-	return true
-}
+import "github.com/Xhofe/alist/bootstrap"
 
 func main() {
-	if conf.Version {
-		fmt.Printf("Built At: %s\nGo Version: %s\nAuthor: %s\nCommit ID: %s\nVersion: %s\n", conf.BuiltAt, conf.GoVersion, conf.GitAuthor, conf.GitCommit, conf.GitTag)
-		return
-	}
-	if !Init() {
-		return
-	}
-	if !conf.Debug {
-		gin.SetMode(gin.ReleaseMode)
-	}
-	r := gin.Default()
-	server.InitApiRouter(r)
-	base := fmt.Sprintf("%s:%d", conf.Conf.Address, conf.Conf.Port)
-	log.Infof("start server @ %s", base)
-	var err error
-	if conf.Conf.Scheme.Https {
-		err = r.RunTLS(base, conf.Conf.Scheme.CertFile, conf.Conf.Scheme.KeyFile)
-	} else {
-		err = r.Run(base)
-	}
-	if err != nil {
-		log.Errorf("failed to start: %s", err.Error())
-	}
-}
+	bootstrap.Run()
+}

alist_test.go

@@ -1,12 +0,0 @@
-package main
-
-import (
-	"fmt"
-	"net/url"
-	"testing"
-)
-
-func TestUrl(t *testing.T) {
-	s,_ := url.QueryUnescape("/ali/%E7%8C%AA%E5%A4%B4%E7%9A%84%E6%96%87%E4%BB%B6%5B%E5%98%BF%E5%98%BF%5D/%E9%82%B9%E9%82%B9%E7%9A%84%E6%96%87%E4%BB%B6/%E6%A1%8C%E9%9D%A2%E5%A3%81%E7%BA%B8/v2-e8f266ba17ae387eefed1cb22b2b5e4e_r.jpg")
-	fmt.Print(s)
-}

bootstrap/account.go

@@ -1,30 +0,0 @@
-package bootstrap
-
-import (
-	"github.com/Xhofe/alist/conf"
-	"github.com/Xhofe/alist/drivers/base"
-	"github.com/Xhofe/alist/model"
-	log "github.com/sirupsen/logrus"
-)
-
-func InitAccounts() {
-	log.Infof("init accounts...")
-	var accounts []model.Account
-	if err := conf.DB.Find(&accounts).Error; err != nil {
-		log.Fatalf("failed sync init accounts")
-	}
-	for i, account := range accounts {
-		model.RegisterAccount(account)
-		driver, ok := base.GetDriver(account.Type)
-		if !ok {
-			log.Errorf("no [%s] driver", account.Type)
-		} else {
-			err := driver.Save(&accounts[i], nil)
-			if err != nil {
-				log.Errorf("init account [%s] error:[%s]", account.Name, err.Error())
-			} else {
-				log.Infof("success init account: %s, type: %s", account.Name, account.Type)
-			}
-		}
-	}
-}

bootstrap/alidrive.go

@@ -0,0 +1,36 @@
+package bootstrap
+
+import (
+	"github.com/Xhofe/alist/alidrive"
+	"github.com/Xhofe/alist/conf"
+	log "github.com/sirupsen/logrus"
+)
+
+func InitAliDrive() bool {
+	log.Infof("初始化阿里云盘...")
+	//首先token_login
+	if conf.Conf.AliDrive.RefreshToken == "" {
+		tokenLogin,err:=alidrive.TokenLogin()
+		if err!=nil {
+			log.Errorf("登录失败:%s",err.Error())
+			return false
+		}
+		//然后get_token
+		token,err:=alidrive.GetToken(tokenLogin)
+		if err!=nil {
+			return false
+		}
+		conf.Authorization=token.TokenType+"\t"+token.AccessToken
+	}else {
+		conf.Authorization=conf.Bearer+conf.Conf.AliDrive.AccessToken
+	}
+	log.Debugf("token:%s",conf.Authorization)
+	user,err:=alidrive.GetUserInfo()
+	if err != nil {
+		log.Errorf("初始化用户失败:%s",err.Error())
+		return false
+	}
+	log.Infof("当前用户信息:%+v",user)
+	alidrive.User=user
+	return true
+}

bootstrap/cache.go

@@ -2,21 +2,14 @@ package bootstrap
 
 import (
 	"github.com/Xhofe/alist/conf"
-	"github.com/eko/gocache/v2/cache"
-	"github.com/eko/gocache/v2/store"
-	goCache "github.com/patrickmn/go-cache"
+	"github.com/patrickmn/go-cache"
 	log "github.com/sirupsen/logrus"
 	"time"
 )
 
-// InitCache init cache
 func InitCache() {
-	log.Infof("init cache...")
-	c := conf.Conf.Cache
-	if c.Expiration == 0 {
-		c.Expiration, c.CleanupInterval = 60, 120
+	if conf.Conf.Cache.Enable {
+		log.Infof("初始化缓存...")
+		conf.Cache=cache.New(time.Duration(conf.Conf.Cache.Expiration)*time.Minute,time.Duration(conf.Conf.Cache.CleanupInterval)*time.Minute)
 	}
-	goCacheClient := goCache.New(time.Duration(c.Expiration)*time.Minute, time.Duration(c.CleanupInterval)*time.Minute)
-	goCacheStore := store.NewGoCache(goCacheClient, nil)
-	conf.Cache = cache.New(goCacheStore)
 }