From b1fb9d7285a48e5a0f78e4d161d19d67d93de2e0 Mon Sep 17 00:00:00 2001
From: Ou <orongxing@gmail.com>
Date: Sat, 5 Oct 2024 01:22:41 +0800
Subject: [PATCH] feat: server routes

---
 public/icons/wallstreetcn.png  | Bin 0 -> 5238 bytes
 server/sources/36kr-quick.ts   |   4 +--
 server/sources/36kr.ts         |   5 ++++
 server/sources/index.ts        |   8 ++++--
 server/sources/wallstreetcn.ts |   3 +++
 server/utils/index.ts          |  44 +++++++++++++++++++++++++++++----
 shared/consts.ts               |   3 +++
 shared/data.ts                 |  24 +++++++++++-------
 shared/types.ts                |  15 +++++++++++
 9 files changed, 88 insertions(+), 18 deletions(-)
 create mode 100644 public/icons/wallstreetcn.png
 create mode 100644 server/sources/36kr.ts
 create mode 100644 server/sources/wallstreetcn.ts

diff --git a/public/icons/wallstreetcn.png b/public/icons/wallstreetcn.png
new file mode 100644
index 0000000000000000000000000000000000000000..01f050900b9be20d96b5890874bf39d39d5e8a66
GIT binary patch
literal 5238
zcmV-+6p8DJP)<h;3K|Lk000e1NJLTq0077U0077c1^@s6tyr#}00009a7bBm000XT
z000XT0n*)m`~UzHC`m*?RCt{2oll6})fLBYViO~!K3%*;1)H=>6=u*~6*AIpA}tvg
zLR{3$rnMU(T~rucIDwV{yXZtWjjK#u7-%6Akh-yS226L688BV8nFi`&7Uqf7#HuOh
zd44m$x%vG$zx(Ihf9C@aCz#CKdGCII=kGoDz@0mHl;D=};^YCP)T~nK7{01MEBt!K
z@CR-wrEcQaoA~v0d~NP5k8bw-dto3V5KG33lR4b{l^~7>UeZP-7!=KV;PoVp2xI``
z#R&*t4qvktmVlcr6by)EeP?-eJ&|<>M+DLVx=J91dHnCuXcs$-Z4}EI3PxPB7DON#
zXeH+H71~|mVgtppCe~#?B9J{xv4F2s+$LXuJ9YtHVp$3o$arxwkD@pk!E$2cG74p_
z)Hk3wfuIXjS&Lj^3g2wktV&TXSTO<_FHRuqbVez4I)de-%&JmqWoLP`S;8-yy+E)|
zu~bmN%>@MZOS#usvK5F3gN>|(lAS<A7{SO=DA@=EgYPAYF@m#-LdhbSPhKEc!+_xX
z)d-d&>~R)@`J`(pNecw)7%P&ljTT4`pGmonlB7V;ow^`#MlwKrvXG+NbufZ83}U=E
zIfI?4B93%`&uSAtyQE0Qf{4|~hNP@X5*7qw4Y3+|P+61t6n>kiEeK|)RwQ+sE$1*L
z9Brm6T7jTTwI=Q7*#qtM^Rc>IQMy<)mrBHuKQl4AT+s<+yf}es_$8&(D1zk(Jiupt
z2|xR&h|0wpFHSB<yiq)>JIkYmSl)yv1cJf%y0}yV0&&S)48ePF7Yl=N5r<F*_QE>u
zji3azAb84eUE&R)g$Y`cV5b*@Sr8G2KwyNHWH!{B6+|E+4q*U6MZzu+5r<$vFp;nd
zM8qLj5JV(w0ugZt4qz7vOBM^$b(<m%!4Z(%n&s%<@@_$}2)HKV5F7$~X$|+5S2$cO
zDFO;Un8Cf}6|Vxp-YOA?;ENgDW8Uy45bVs9#zVn3r+sz-dkNC9xBrs!Z!8GyJnLh;
zkaK}Z#!3i;m&}$^7fUi$LO{G^wp_;`OA?d|0hz%)=nQ8rmc$)GL^z8_oCrkXj_^G8
z-FwtCj~?=}jw}ECa{5XLXYt6l9R1E0L>yuH@T0G$uTxJPRxkhfUiI(;cHZ+Rx9+Id
z-n*?XUj0H%ZY4Lrd4zj%&h{HwTM(SL`g_}j2yS`fx%<?q#}6BQPY}n+H~%{oT;lv{
zXL+<@^D9^hL|m)5F%`+vuYa0@IFt)l%QlN8u2sam^rz3&yZ`v#pauT!ueWm%hpM?+
z#uy6(vsN-pI&xll=N5T^H*S8d&cA;<x3}Q9&D2ICfz*ad3z2i<<FD1l556ER5`yvs
z19A#0rUgV(3vx!TJxhlhANOy1upW@H%9NwHX9qJ_AQ+g-g_#NQ@Ph|>7Yo)Sb6zzW
zL}y|_q8l(Qbo1m7y31XV)_wQduwXt>2JhWL0>MlA<%~x{fH?Y!hUc#&SqwDcH11(C
zLo4Z7TaSkyJgA;|<dAytsl(QlXigxN`{74l@3w<{_@A$KH~gt5y4z2{dSsZn>SAd~
zg`Hd|MCJX>!-Av4Rm+A?pl0#*)i0)*swP12AH4jX&J{q03+g3>@$}B}h;*KP$fsXa
z>;V~_r_X(=-n<gu)Aia%Urnpsuf2DxRUE+cPxM#O&%d8-=Bf+wUM2|ytw(W1L2y%`
z(Du@w<9WhDI+ofe)#qOQ{a;_^R5c&MacV3=wID@juE3haB9a&W_!%jn1{bl<J$(CW
z5t*wtNPD_hAUNi+_?D6wL;~>w^@;yHAvn*tFi7DzWrQikf*4gGa|AY2$e4s0FF<hq
z!|!(|C<_-yMepA36bM!xrS4G!Vv=hC{C0>vsMZ6rZ+-mXiU<VjBAwOsJ_{1fZKE+U
zq(jyfUD>KSqaz2VwVW=XZbJQj1<<+2MIZ)1L5|uX>xzF9H}r`|52^c)boX9eEIT;Y
z>D=S3jw<%hOUG^t(A;Nwq}7B^KBpCQ``jyV)&4Tz5ETrA7~OYZ+Oh&^V_$_+NI64R
z4SK?u+g^^sUT>R%(iO>x_2{5FXTc?s#~!+;_wSJUt_BtctGEZOCKM*Yef!N%k2n*`
zCs=C=oHSU#frod|_*>%Pl9Q}UOc2f%amY;d(N`E$4zgEZeW1g@MWUh_4iP~{?PS}5
zs<wAstOtQ1r}b=sCw7-e;Q#emGgzw&_ho_`+g2oCIU=g$H|}{6h$Wl>Z`ZjF?!GG!
z$<N;UY-$BefO=A7wHTT}FfT0gb%}s)&Q%wA=8<-R^to5paIl<9z=EDPsHZ@pAi@)j
zGfg#-CJSOb0ism6if$(!In?N8QTncYtr5<W47DQAULWZJt-JQV2*d%9nlyDahVsiN
z?{=j^_Fch7A2PQW(zy}O`Rx`6M)JisCJtr7*!Tz5VpJ;x#?W^Krx~e4J{;n>p3TxN
zi1o1FQsHv5ph|wCHpM-LzALIlh}?Qq?9+fQ5OJ>zfq)e@00)&QD1BG3rdax}5;=de
zPXl5>9Kv;c6#{Zd`BM6>IMxL1D19U}n6BA^V2Vq6uPlHnGi(G7Ag$}V@5+?N9_p|1
zC)6N$w4Uy*M|Z)j$Fzs&L3k?OqrOLIsR#jd)53>bAF0y>{GDI_s6Q^Sh0+7YwJG}s
z)2XR@mDKr@xoRqW6auLNw~JT5d9&fk*q52%WXNb7s0(ligaXIBD@uc8g6B_m1ycXb
zde7%_0AhhYpVJm?3@(8R^pLqx)08jsS&=4O^<DMxVnba<C&BY4yIQCVB&zlj@SW#g
zchfa$gGt^#hFMb_n-bjO6Fpfpt~kgsyIPnEWazw7F2F3i=o&QzESSlM3q4OEg$+NO
zquxMikWBUTVx@`7f<)n7HQ}nY+60?T7IG*8*UzS$KS?Y&uQSy|^a4>1TB}VN(n6sF
zIsXtb6xUS-lm^MfhePZW$l!}bxPdqNg||M7eVO|RQ5XZ4kRv$nYmiiUtwO>~HBkv9
zi3UY*c{m5RQ74JC5yH*lXa=M-NJ4O)K;KmtQ%xK+z1%PqumQMS7bslX09J44HOw|}
z^<6c!-0S2pH6FBaF!uOEhqbl*@x!EH30-hzaX6X*p+WK#DSMU0<i^>9Da0Q-oURMy
zY1su=e->9WAZaiiQ<0K^V@V2x({<4gD4D?FZg5#D$^#>#$&FKiBo%{HaAipJ14<@v
zJlQ$w4bXS>XisZ<2Eloq^kR?-_z<{S%Wd5(-~Czey*Yw&N?|awE8S+(xyrQxt`7sA
znv|CAE_|+)!=;%9=cE?<yslM9*2PlH)oRMqvkPDSS-MLD8~L|CIpX~1kTO^K1m_h~
z7c1EzaTCL4LKEQWX&bEj$iC@?LD<N@c=BHB^t2A#9p6WW*DA~;?P4kBF)}YcWp@zD
zwZ&`dyQ(%arPG!Q42J0IyW;8~<|cW8a847kb+eS??3><qRX^S5VyzXF@0IJ7ZpjNo
zF^-dg&DS?(rw^CuSUvEsZ)8|2C2r`0awv+cgE$0P2n1Xg&S@exxGHjj)vOPrZpt!I
zI&S-*xN2M-#39H+Ac`?SY#Sgw1Q%|WZZ(^%1$5lnu9b4;JhR%zKC%%A#{`cG+rpu3
zk+W$Sbz7E+GMcmv5M5v2m5*x`Vj>%Xa846(;oI9hb#)8WHF^hPCe!pZ#YM~gzV&Pb
zq8Qz*`-v^zUD%|2^+3PN4KnQ|gK?sLhoW*0&MUGK2<L52F8Z@fik$j6Z%UTQWUZ9K
zV9vpLMOFe)j3yuYvnWHGyD)LHboYvqWg6N`MwuF~;=k*|3E2sRvp<XSl<fk7+aX2H
zrdD!l+IdKNnsO*ArfU^^lAS;lV@Iir{;VNIPTk^AT0km>td)}aO60B&YqAswXJ&;n
zSl5L=v}j4`C8G?Z_Ic-FY`{CQmD?}Hc_i1?%~Hg|q25YP3C?vWf};GLQp5q;0D;_$
zU?I-oI+DxPpQXE3Cf&MyYo#8F%Dwhc<7SpFmSR4V>$^XzsakFNGrRsB#RV%RIIjSK
zY{sz^_i*(H`R>ospV*YSxNUT;l{SpJjNlyE%+|$H%qd^n14?ZcuPGq5?b2;398xl3
zB?afm)Wy0U#Zo-Lc_f$8^{S&6@0u*0z9A`dar<b>ypblBloNYYT+dn{im}>j(x3Il
zbNB5NNt4CX-7DJ`7uB#<YDO&KyFN_0o^=eOn2+QRaeb<KL;cCETfC<GHC%KOD@|w=
z(ItM@hbfx}ca}%l#vm13fhD*;)c&l>CDSY1b&IEWCsWR6P^tHl(S}hM6`W52ZB$X&
zM&Px0h4V-*rEsXbH1!QyS-hspFI^m=)z?Z9U7{Cp+A`HdC6KJ+5XJZeq#RJvGhVu=
zz~bovyNlpl2dr0N!>ETa)kGzbtm6>HcqEq+tm_#gh(+{ZUC&;*2+o`68%C|l49-=h
ziDCr8c_g>X&1x(1>1pD6-xc-J8XpuIoU45T*;yW~2VV{YT&{v{5$d$X5nUB-%J~dm
z6zX2>YNGy$WY^WJ!+9jPsc_gAN3>PreYsbC6dIhXx)$mJ$==OUjGd@W7NPGTQd2b>
zQn8dc!3R0dyXs+A3-wR15H~AKe-`DOcT@Ju#d#A`3hTS7v#W*T1fn>P<kl<#C5~uv
zXKs8PW@<==cYO@uZh`D9k09^69s9~%z~yGu2S}UVEgmYxT550(8bB>f(bFbHSP{-6
zxsbJ@Tz;t!qpsjw>+a9Y>mtsf?9+fQkhN%+?HI1sZOB^LP6^>|GcPzeSGop@v>=N4
zNG@fBXIEUrxmHznaIQKn2zK^fW?xbuVtG<hECknD3lGjO>)q{5rQ4#iSzIaKE+~OG
z*HgXV;9NEB{U(7F6Nhjf$!&w$>%`GZR(No(n)d!(0>Knl_H8E>p$9Mzd1Cv1x|cAF
zx`VBHdbgr&jKxa8g|fnVBv)r>uanPUy@b0ydbrT^zuN>-jGLtb&U!Ms{=iePUcy};
zJ<tVGS~iRGNUr{KIsOfW!fPLQWv?o_CWSRBDp$C(H>T-SAHjO=7jY73-RrFa*;yW~
zmC~D~m~Y8dmQQTgVlHSHbrajT*Bj{@@LG%&;XIOS`^0v6@JoX8?maF7slnxDxp-o`
zdg@DXZXpoN3$Hp~QlxMk$#wO_hVS8`3!w1ee6^|eQHL@^znGecV(`Zy3+3X8?V<~y
zt;N0|diQp(Kz5c#o4HS3tmC^s%cTHqpZ<m2^`WzYd%F|rEi6kcOO6CzwFcL>Gr`l}
z)FmwNt`8m3o+b$dX9N{vMSQtgKAza7Yb{(H8`N2FL+<e^#)|kj<_eX1ADhxNSTDTx
zLEg(`fs|%NTpx4wl|nWN)=RsHQ-f?h)IbZOO0puZJ7;}PCmGtNUU+amXb%q(2r93b
zx`?Y90aWOHKCy?i>=z!KuMV9<ZE}}zF;>J?%9o=;Pqhk?xf;e`fneqFtoyachl^qy
z*D+SAm<tZh&-PW#n=rloex;O7U)y7-oUI&v)}i3LKDJFeLW~50hfB_w{M*#9Ig-om
z@Ap}Uf+v=oF}<wT)Phv!MT$6eXqxrm?v(8kbHR6gY;>LX=)+hb2w0Jc<@bml(<8Yd
zI%V6$T&VScy}4lX4Xgx$K~E7`t)Uw%RHtlPuwLjzoJ%Hwc^z8|0wP%{p~61&NN&ht
zoF4ZS8k}$7-n7D6Ajo{~uGWwvxuJ`3daz!gdu8ofRUEi;$4wA9UYvkPE;;#TkplO8
zto{7ky^DME%5C+^JGXLvD`Mwao4~w|D+^L(wa!KU##uo<l3RGEY-rB85{Ggr5M(L$
zxxRgyzu;nA3~aeh8aWjR7GtuGNBUYi3co%eB(Ue^O$&l;xV9iw>eoqt6f123c)`WE
z7+A1P={Dh9AZjlj$+n@f&CM!&gic7#x{N#OcoB&DMkGtQo*ijBl3REyc_>zKuX(|n
zK-4!PS;#eL*N@~Dez#vJws4Pmqx<?*H_YMPZ!<Z4GLZ5eFJ|9{7BgG8x4h!4P}s$I
zadJ#41w*<<d3{DgAmGU~>mw-F@#<n#;4d;)Lg%mG9oR#29O6)10#SP-OhqJu4V5^0
zM~1qBO(04{BG|z$4#h1HB_a{b2qF#@LLf>+A`By#I8-QsC=rQ3Bd9o3NP(z5k<8}a
z0W27?g{j<N;!s?5kUqwXlLvAvCJM%Eq2+MenQKB60;w1;PT)et({Zdu2*j%I_K_h3
zb+L5tjVWTRsnE#Tn8cxCvmh0CzWsu<rWC^j&vSTbS+^ldfvCOytu={DvS$lV0<yG@
z3?(WTt4^(dE9*fJg>#OxugZjIEl3@4xw0c#mr5rIfvCMyFubA1BUp}L&W5k^<3316
zAQj`q$r&8&BGx1=CO9kCdK@Sx$q7X51@Q1jpNwERLO)4ajXFsRqyl3T5X#XwRwQU_
z<K;Ec#~N)!o5iAlZ~Uwj7o+4X_EIG)4wbqEse^9UlC-J>XVt~M9I=p%Kq|(IlQ|TM
zWV?9TKw%8Jhdg$&6G(*!g^etQQIV}cDnuyW$XXZ`*$bp%yf~S~OGhO}u>)d^mCy&7
zxF|*-6&TDf;7iiOG`6wT=Rz*QH<jW9QU~iO3sP`w<uZyQ=~S%^MGK??`@H7S1uMP1
zeye6Jf**MejR-^oU9fp<wJ*i8Y+xhkT4^p+A0m(r(6Y?c1d~h5vW-JBKosj@DcTW%
z3;?am9KL1~a>urCy8b!}LaYQ45r`#NXPL#<u?Xrd;4WQ9L2Tw;r|^vk!~^J>Rf2(6
w^=E}&n_3>Q1eH6qiC<r@1R<`HW0X?=2Ronxk&%v(r2qf`07*qoM6N<$f>2PwfdBvi

literal 0
HcmV?d00001

diff --git a/server/sources/36kr-quick.ts b/server/sources/36kr-quick.ts
index 9e4d3a9..7ad63ca 100644
--- a/server/sources/36kr-quick.ts
+++ b/server/sources/36kr-quick.ts
@@ -1,3 +1,3 @@
-import { defineRSSSource } from "#/utils"
+import { defineRSSHubSource } from "#/utils"
 
-export default defineRSSSource("https://rsshub.rssforever.com/36kr/newsflashes")
+export default defineRSSHubSource("/36kr/newsflashes")
diff --git a/server/sources/36kr.ts b/server/sources/36kr.ts
new file mode 100644
index 0000000..782ad10
--- /dev/null
+++ b/server/sources/36kr.ts
@@ -0,0 +1,5 @@
+import { defineRSSHubSource } from "#/utils"
+
+export default defineRSSHubSource("/36kr/hot-list", {
+  sorted: false,
+})
diff --git a/server/sources/index.ts b/server/sources/index.ts
index 555d7ca..37b493d 100644
--- a/server/sources/index.ts
+++ b/server/sources/index.ts
@@ -2,7 +2,9 @@ import type { SourceID, SourceInfo } from "@shared/types"
 import peopledaily from "./peopledaily"
 import weibo from "./weibo"
 import zaobao from "./zaobao"
-import kr from "./36kr-quick"
+import krQ from "./36kr-quick"
+import wallstreetcn from "./wallstreetcn"
+// import kr from "./36kr"
 
 export { fallback } from "./fallback"
 
@@ -10,5 +12,7 @@ export const sources = {
   peopledaily,
   weibo,
   zaobao,
-  "36kr-quick": kr,
+  wallstreetcn,
+  "36kr-quick": krQ,
+  // "36kr": kr,
 } as Record<SourceID, () => Promise<SourceInfo>>
diff --git a/server/sources/wallstreetcn.ts b/server/sources/wallstreetcn.ts
new file mode 100644
index 0000000..da04998
--- /dev/null
+++ b/server/sources/wallstreetcn.ts
@@ -0,0 +1,3 @@
+import { defineRSSHubSource } from "#/utils"
+
+export default defineRSSHubSource("/wallstreetcn/live")
diff --git a/server/utils/index.ts b/server/utils/index.ts
index 5bbcda3..ac34503 100644
--- a/server/utils/index.ts
+++ b/server/utils/index.ts
@@ -1,4 +1,5 @@
-import type { NewsItem, SourceInfo } from "@shared/types"
+import { RSSHubBase } from "@shared/consts"
+import type { NewsItem, RSSHubInfo, SourceInfo } from "@shared/types"
 
 export function defineSource(source: () => Promise<NewsItem[]>): () => Promise<SourceInfo> {
   return async () => ({
@@ -9,11 +10,11 @@ export function defineSource(source: () => Promise<NewsItem[]>): () => Promise<S
 
 export function defineRSSSource(url: string): () => Promise<SourceInfo> {
   return async () => {
-    const source = await rss2json(url)
-    if (!source?.items.length) throw new Error("Cannot fetch data")
+    const data = await rss2json(url)
+    if (!data?.items.length) throw new Error("Cannot fetch data")
     return {
-      updatedTime: source.updatedTime ?? Date.now(),
-      items: source.items.slice(0, 20).map(item => ({
+      updatedTime: data.updatedTime ?? Date.now(),
+      items: data.items.slice(0, 20).map(item => ({
         title: item.title,
         url: item.link,
         id: item.link,
@@ -24,3 +25,36 @@ export function defineRSSSource(url: string): () => Promise<SourceInfo> {
     }
   }
 }
+
+interface Option {
+  // default: true
+  sorted?: boolean
+  // default: 20
+  limit?: number
+}
+export function defineRSSHubSource(route: string, option?: Option): () => Promise<SourceInfo> {
+  return async () => {
+    const url = new URL(route, RSSHubBase)
+    url.searchParams.set("format", "json")
+    const defaultOption: Option = {
+      sorted: true,
+      limit: 20,
+    }
+    Object.assign(defaultOption, option)
+    Object.entries(defaultOption).forEach(([key, value]) => {
+      url.searchParams.set(key, value.toString())
+    })
+    const data: RSSHubInfo = await $fetch(url)
+    return {
+      updatedTime: Date.now(),
+      items: data.items.slice(0, 20).map(item => ({
+        title: item.title,
+        url: item.url,
+        id: item.id ?? item.url,
+        extra: {
+          date: item.date_published,
+        },
+      })),
+    }
+  }
+}
diff --git a/shared/consts.ts b/shared/consts.ts
index 88b3ac5..9e1c384 100644
--- a/shared/consts.ts
+++ b/shared/consts.ts
@@ -3,3 +3,6 @@ export const TTL = 15 * 60 * 1000
  * 默认刷新间隔，否则复用缓存
  */
 export const Interval = 30 * 60 * 1000
+
+export const RSSHubBase = "https://rsshub.rssforever.com"
+// export const RSSHubBase = "https://rsshub.pseudoyu.com"
diff --git a/shared/data.ts b/shared/data.ts
index cb239c1..6bdd5ef 100644
--- a/shared/data.ts
+++ b/shared/data.ts
@@ -3,12 +3,18 @@ import type { Metadata } from "./types"
 export const sectionIds = ["focus", "social", "china", "world", "digital"] as const
 
 export const sources = {
-  "36kr": {
-    name: "36氪",
-    type: "人气榜",
+  "wallstreetcn": {
+    name: "华尔街见闻",
     interval: 10,
-    home: "https://36kr.com",
+    home: "https://wallstreetcn.com/",
+    type: "快讯",
   },
+  // "36kr": {
+  //   name: "36氪",
+  //   type: "人气榜",
+  //   interval: 10,
+  //   home: "https://36kr.com",
+  // },
   "36kr-quick": {
     name: "36氪",
     type: "快讯",
@@ -83,19 +89,19 @@ export const metadata: Metadata = {
     sourceList: [],
   },
   social: {
-    name: "社交媒体",
-    sourceList: ["douyin", "hupu", "tieba", "weibo"],
+    name: "实时",
+    sourceList: ["douyin", "weibo", "36kr-quick", "wallstreetcn", "zaobao"],
   },
   china: {
     name: "国内",
-    sourceList: ["peopledaily", "36kr", "toutiao", "36kr-quick"],
+    sourceList: ["peopledaily", "toutiao"],
   },
   world: {
     name: "国外",
-    sourceList: ["zaobao"],
+    sourceList: [],
   },
   digital: {
     name: "数码",
-    sourceList: ["36kr"],
+    sourceList: [],
   },
 }
diff --git a/shared/types.ts b/shared/types.ts
index cafb985..1c5973f 100644
--- a/shared/types.ts
+++ b/shared/types.ts
@@ -52,3 +52,18 @@ export interface CacheInfo {
   updated: number
   expires: number
 }
+
+export interface RSSHubInfo {
+  title: string
+  home_page_url: string
+  description: string
+  items: RSSHubItem[]
+}
+
+export interface RSSHubItem {
+  id: string
+  url: string
+  title: string
+  content_html: string
+  date_published: string
+}