update

README.md

@@ -1,12 +1,141 @@
----
-title: Wx Rss
-emoji: 🔥
-colorFrom: red
-colorTo: indigo
-sdk: docker
-pinned: false
-license: mit
-app_port: 4000
----
-
-Check out the configuration reference at https://huggingface.co/docs/hub/spaces-config-reference
+<div align="center">
+<img src="https://raw.githubusercontent.com/cooderl/wewe-rss/main/assets/logo.png" width="80" alt="预览"/>
+
+<h1 align="center"><a href="https://github.com/cooderl/wewe-rss">WeWe RSS</a></h1>
+
+更优雅的微信公众号订阅方式。
+
+![主界面](https://raw.githubusercontent.com/cooderl/wewe-rss/main/assets/preview1.png)
+
+</div>
+
+## 功能
+
+- [x]  支持微信公众号订阅（基于微信读书）
+- [x]  后台自动定时更新内容
+- [x]  微信公众号RSS生成（支持`.atom`\.`rss`\.`json`格式)
+- [x]  支持全文内容输出，让阅读无障碍
+- [x]  所有订阅源导出OPML
+
+## 部署
+
+### 一键部署（待完善添加模板）
+
+你可以通过以下平台一键部署，只需填写本项目的URL即可。
+
+[Zeabur](https://zeabur.com/)
+
+[Railway](https://railway.app/)
+
+[Hugging Face部署参考](https://github.com/cooderl/wewe-rss/issues/32)
+
+### Docker Compose 部署
+
+可参考 [docker-compose.yml](https://github.com/cooderl/wewe-rss/blob/main/docker-compose.yml) 和 [docker-compose.sqlite.yml](https://github.com/cooderl/wewe-rss/blob/main/docker-compose.sqlite.yml)
+
+### Docker 命令启动
+
+#### Sqlite
+
+```sh
+docker run -d \
+  --name wewe-rss \
+  -p 4000:4000 \
+  -e DATABASE_TYPE=sqlite \
+  -e AUTH_CODE=123567 \
+  -v $(pwd)/data:/app/data \
+  cooderl/wewe-rss-sqlite:latest
+```
+
+#### Mysql
+
+1. 创建docker网络
+
+```sh
+docker network create wewe-rss
+```
+
+2. 启动 MySQL 数据库
+
+```sh
+docker run -d \
+  --name db \
+  -e MYSQL_ROOT_PASSWORD=123456 \
+  -e TZ='Asia/Shanghai' \
+  -e MYSQL_DATABASE='wewe-rss' \
+  -v db_data:/var/lib/mysql \
+  --network wewe-rss \
+  mysql:latest --default-authentication-plugin=mysql_native_password
+```
+
+3. 启动 Server
+
+```sh
+docker run -d \
+  --name wewe-rss \
+  -p 4000:4000 \
+  -e DATABASE_URL='mysql://root:123456@db:3306/wewe-rss?schema=public&connect_timeout=30&pool_timeout=30&socket_timeout=30' \
+  -e AUTH_CODE=123567 \
+  --network wewe-rss \
+  cooderl/wewe-rss:latest
+
+```
+
+[Nginx配置参考](https://raw.githubusercontent.com/cooderl/wewe-rss/main/assets/nginx.example.conf)
+
+### 本地部署
+
+如果你想本地部署，请使用 `pnpm install &&  pnpm run -r build && pnpm run start:server` 命令(可以配合 pm2 来守护进程，防止被杀死)。
+
+## 环境变量
+
+- `DATABASE_URL` （**必填项**）数据库地址，例如 `mysql://root:123456@127.0.0.1:3306/wewe-rss`。
+
+- `DATABASE_TYPE` 数据库类型，使用 `sqlite` 时需要填写 `sqlite`。
+
+- `AUTH_CODE` 服务端接口请求授权码，(`/feeds`路径不需要)。
+
+- `SERVER_ORIGIN_URL` 服务端访问地址，用于生成RSS的完整路径（外网访问时，设置为服务器的公网 IP 或者域名地址）。
+
+- `MAX_REQUEST_PER_MINUTE` 每分钟最大请求次数，默认 60。
+
+- `FEED_MODE` 输出模式，可选值 `fulltext`（RSS全文模式会使接口响应会变慢，占用更多内存）。
+
+- `CRON_EXPRESSION` 定时更新订阅源Cron表达式，默认为 `35 5,17 * * *`。
+
+
+## 使用方式
+
+1. 进入账号管理，点击添加账号，微信扫码登录微信读书账号。
+<img width="400" src="./assets/preview2.png"/>
+
+1. 进入公众号源，点击添加，通过提交微信公众号分享链接，订阅微信公众号。
+  **（添加频率过高容易被封控，等24小时解封）**
+<img width="400" src="./assets/preview3.png"/>
+
+
+## 本地开发
+
+1. 安装 nodejs 18 和 pnpm；
+2. 修改环境变量`cp ./apps/web/.env.local.example ./apps/web/.env`和`cp ./apps/server/.env.local.example ./apps/server/.env`
+3. 执行 `pnpm install && pnpm dev` 即可。⚠️ 注意：此命令仅用于本地开发，不要用于部署！
+4. 前端访问 `http://localhost:5173` ，后端访问 `http://localhost:4000`
+
+## 风险声明
+
+为了确保本项目的持久运行，某些接口请求将通过`weread.111965.xyz`进行转发。请放心，该转发服务不会保存任何数据。
+
+## 打赏
+
+如果您觉得我们的项目有价值，并希望帮助我们继续发展，可以用以下几种加密货币打赏:
+
+BTC(Bitcoin): `1DGU9zRC8cvexq3W92Kzxqg5sNnbWPz9fE`
+
+ETH(Ethereum, ERC20): `0x6bb8cef666c346ac3926fd32edd27d8246dcece0`
+
+USDT(Tron, TRC20): `TLsukYHcXN34RXABZwppRE5AuPp8AWY7Wv`
+
+
+## License
+
+[MIT](https://raw.githubusercontent.com/cooderl/wewe-rss/main/LICENSE) @cooderl

apps/server/package.json

@@ -1,6 +1,6 @@
 {
   "name": "server",
-  "version": "1.7.1",
+  "version": "1.8.0",
   "description": "",
   "author": "",
   "private": true,

apps/server/src/app.controller.ts

@@ -1,9 +1,14 @@
 import { Controller, Get, Redirect, Render } from '@nestjs/common';
 import { AppService } from './app.service';
+import { ConfigService } from '@nestjs/config';
+import { ConfigurationType } from './configuration';
 
 @Controller()
 export class AppController {
-  constructor(private readonly appService: AppService) {}
+  constructor(
+    private readonly appService: AppService,
+    private readonly configService: ConfigService,
+  ) {}
 
   @Get()
   getHello(): string {
@@ -23,9 +28,12 @@ export class AppController {
   @Render('index.hbs')
   dashRender() {
     const { originUrl: weweRssServerOriginUrl } =
-      this.appService.getFeedConfig();
+      this.configService.get<ConfigurationType['feed']>('feed')!;
+    const { code } = this.configService.get<ConfigurationType['auth']>('auth')!;
+
     return {
       weweRssServerOriginUrl,
+      enabledAuthCode: !!code,
     };
   }
 }

apps/server/src/app.service.ts

@@ -1,6 +1,5 @@
 import { Injectable } from '@nestjs/common';
 import { ConfigService } from '@nestjs/config';
-import { ConfigurationType } from './configuration';
 
 @Injectable()
 export class AppService {
@@ -12,8 +11,4 @@ export class AppService {
     </div>
     `;
   }
-
-  getFeedConfig() {
-    return this.configService.get<ConfigurationType['feed']>('feed')!;
-  }
 }

apps/server/src/trpc/trpc.router.ts

@@ -22,12 +22,12 @@ export class TrpcRouter {
     list: this.trpcService.protectedProcedure
       .input(
         z.object({
-          limit: z.number().min(1).max(100).nullish(),
+          limit: z.number().min(1).max(500).nullish(),
           cursor: z.string().nullish(),
         }),
       )
       .query(async ({ input }) => {
-        const limit = input.limit ?? 50;
+        const limit = input.limit ?? 500;
         const { cursor } = input;
 
         const items = await this.prismaService.account.findMany({
@@ -132,12 +132,12 @@ export class TrpcRouter {
     list: this.trpcService.protectedProcedure
       .input(
         z.object({
-          limit: z.number().min(1).max(100).nullish(),
+          limit: z.number().min(1).max(500).nullish(),
           cursor: z.string().nullish(),
         }),
       )
       .query(async ({ input }) => {
-        const limit = input.limit ?? 50;
+        const limit = input.limit ?? 500;
         const { cursor } = input;
 
         const items = await this.prismaService.feed.findMany({
@@ -247,13 +247,13 @@ export class TrpcRouter {
     list: this.trpcService.protectedProcedure
       .input(
         z.object({
-          limit: z.number().min(1).max(100).nullish(),
+          limit: z.number().min(1).max(500).nullish(),
           cursor: z.string().nullish(),
           mpId: z.string().nullish(),
         }),
       )
       .query(async ({ input }) => {
-        const limit = input.limit ?? 50;
+        const limit = input.limit ?? 500;
         const { cursor, mpId } = input;
 
         const items = await this.prismaService.article.findMany({
@@ -401,7 +401,7 @@ export class TrpcRouter {
           const authCode =
             this.configService.get<ConfigurationType['auth']>('auth')!.code;
 
-          if (req.headers.authorization !== authCode) {
+          if (authCode && req.headers.authorization !== authCode) {
             return {
               errorMsg: 'authCode不正确！',
             };

apps/web/index.html

@@ -11,6 +11,7 @@
     <div id="root"></div>
     <script>
       window.__WEWE_RSS_SERVER_ORIGIN_URL__ = '{{ weweRssServerOriginUrl }}';
+      window.__WEWE_RSS_ENABLED_AUTH_CODE__ = {{ enabledAuthCode }};
     </script>
     <script type="module" src="/src/main.tsx"></script>
   </body>

apps/web/package.json

@@ -1,7 +1,7 @@
 {
   "name": "web",
   "private": true,
-  "version": "1.7.1",
+  "version": "1.8.0",
   "type": "module",
   "scripts": {
     "dev": "vite",

apps/web/src/pages/accounts/index.tsx

@@ -25,9 +25,7 @@ import { statusMap } from '@web/constants';
 const AccountPage = () => {
   const { isOpen, onOpen, onClose, onOpenChange } = useDisclosure();
 
-  const { refetch, data, isFetching } = trpc.account.list.useQuery({
-    limit: 100,
-  });
+  const { refetch, data, isFetching } = trpc.account.list.useQuery({});
 
   const { mutateAsync: updateAccount } = trpc.account.edit.useMutation({});
 

apps/web/src/pages/feeds/index.tsx

@@ -30,9 +30,7 @@ const Feeds = () => {
 
   const { isOpen, onOpen, onOpenChange, onClose } = useDisclosure();
   const { refetch: refetchFeedList, data: feedData } = trpc.feed.list.useQuery(
-    {
-      limit: 100,
-    },
+    {},
     {
       refetchOnWindowFocus: true,
     },
@@ -93,6 +91,38 @@ const Feeds = () => {
     return feedData?.items.find((item) => item.id === currentMpId);
   }, [currentMpId, feedData?.items]);
 
+  const handleExportOpml = async (ev) => {
+    ev.preventDefault();
+    ev.stopPropagation();
+    if (!feedData?.items?.length) {
+      console.warn('没有订阅源');
+      return;
+    }
+
+    let opmlContent = `<?xml version="1.0" encoding="UTF-8"?>
+    <opml version="2.0">
+      <head>
+        <title>WeWeRSS 所有订阅源</title>
+      </head>
+      <body>
+    `;
+
+    feedData?.items.forEach((sub) => {
+      opmlContent += `    <outline text="${sub.mpName}" type="rss" xmlUrl="${window.location.origin}/feeds/${sub.id}.atom" htmlUrl="${window.location.origin}/feeds/${sub.id}.atom"/>\n`;
+    });
+
+    opmlContent += `    </body>
+    </opml>`;
+
+    const blob = new Blob([opmlContent], { type: 'text/xml;charset=utf-8;' });
+    const link = document.createElement('a');
+    link.href = URL.createObjectURL(blob);
+    link.download = 'WeWeRSS-All.opml';
+    document.body.appendChild(link);
+    link.click();
+    document.body.removeChild(link);
+  };
+
   return (
     <>
       <div className="h-full flex justify-between">
@@ -238,15 +268,26 @@ const Feeds = () => {
                 </Tooltip>
               </div>
             ) : (
-              <Link
-                size="sm"
-                showAnchorIcon
-                target="_blank"
-                href={`${serverOriginUrl}/feeds/all.atom`}
-                color="foreground"
-              >
-                RSS
-              </Link>
+              <div className="flex gap-2">
+                <Link
+                  href="#"
+                  color="foreground"
+                  onClick={handleExportOpml}
+                  size="sm"
+                >
+                  导出OPML
+                </Link>
+                <Divider orientation="vertical" />
+                <Link
+                  size="sm"
+                  showAnchorIcon
+                  target="_blank"
+                  href={`${serverOriginUrl}/feeds/all.atom`}
+                  color="foreground"
+                >
+                  RSS
+                </Link>
+              </div>
             )}
           </div>
           <div className="p-2 overflow-y-auto">

apps/web/src/provider/trpc.tsx

@@ -5,13 +5,19 @@ import { useState } from 'react';
 import { toast } from 'sonner';
 import { isTRPCClientError, trpc } from '../utils/trpc';
 import { getAuthCode, setAuthCode } from '../utils/auth';
-import { serverOriginUrl } from '../utils/env';
+import { enabledAuthCode, serverOriginUrl } from '../utils/env';
 
 export const TrpcProvider: React.FC<{ children: React.ReactNode }> = ({
   children,
 }) => {
   const navigate = useNavigate();
 
+  const handleNoAuth = () => {
+    if (enabledAuthCode) {
+      setAuthCode('');
+      navigate('/login');
+    }
+  };
   const [queryClient] = useState(
     () =>
       new QueryClient({
@@ -38,8 +44,7 @@ export const TrpcProvider: React.FC<{ children: React.ReactNode }> = ({
                     description: error.message,
                   });
 
-                  setAuthCode('');
-                  navigate('/login');
+                  handleNoAuth();
                 } else {
                   toast.error('请求失败!', {
                     description: error.message,
@@ -56,8 +61,7 @@ export const TrpcProvider: React.FC<{ children: React.ReactNode }> = ({
                   toast.error('无权限', {
                     description: error.message,
                   });
-                  setAuthCode(null);
-                  navigate('/login');
+                  handleNoAuth();
                 } else {
                   toast.error('请求失败!', {
                     description: error.message,
@@ -82,9 +86,10 @@ export const TrpcProvider: React.FC<{ children: React.ReactNode }> = ({
             const token = getAuthCode();
 
             if (!token) {
-              navigate('/login');
+              handleNoAuth();
               return {};
             }
+
             return token
               ? {
                   Authorization: `${token}`,

apps/web/src/utils/env.ts

@@ -5,3 +5,6 @@ export const serverOriginUrl = isProd
   : import.meta.env.VITE_SERVER_ORIGIN_URL;
 
 export const appVersion = __APP_VERSION__;
+
+export const enabledAuthCode =
+  window.__WEWE_RSS_ENABLED_AUTH_CODE__ === false ? false : true;

apps/web/src/vite-env.d.ts

@@ -7,6 +7,7 @@ interface ImportMetaEnv {
 
 interface Window {
   __WEWE_RSS_SERVER_ORIGIN_URL__?: string;
+  __WEWE_RSS_ENABLED_AUTH_CODE__?: boolean;
 }
 
 declare const __APP_VERSION__: string;

package.json

@@ -1,6 +1,6 @@
 {
   "name": "wewe-rss",
-  "version": "1.7.1",
+  "version": "1.8.0",
   "private": true,
   "author": "cooderl <cooder@111965.xyz>",
   "description": "",