feat: query/site/users

Author: dragon-fish

api/query.ts

@@ -411,19 +411,62 @@ export default async (req: VercelRequest, res: VercelResponse) => {
         ctx.status = 400
         ctx.message = 'Missing siteUrl'
         return false
-      } else if (isValidUrl(ctx.req.query.siteUrl as string)) {
+      } else if (!isValidUrl(ctx.req.query.siteUrl as string)) {
         ctx.status = 400
         ctx.message = 'Invalid siteUrl'
         return false
       }
     })
-    .action((ctx) => {
+    .action(async (ctx) => {
       const { siteUrl } = ctx.req.query
       const aggregate: Document[] = [
         {
           $match: { siteUrl },
         },
+        {
+          $group: {
+            _id: {
+              userName: '$userName',
+              siteUrl: '$siteUrl',
+              siteName: '$siteName',
+            },
+            count: { $sum: 1 },
+          },
+        },
+        {
+          $group: {
+            _id: {
+              userName: '$_id.userName',
+            },
+            count: { $sum: '$count' },
+            userName: { $first: '$_id.userName' },
+            siteUrl: { $first: '$_id.siteUrl' },
+            siteName: { $first: '$_id.siteName' },
+          },
+        },
+        {
+          $project: {
+            _id: false,
+          },
+        },
+        { $sort: ctx.sort },
+        { $limit: ctx.limit + 1 },
+        { $skip: ctx.offset },
       ]
+      const users = await ctx.col.aggregate(aggregate).toArray()
+
+      let hasNext = false
+      if (users.length > ctx.limit) {
+        hasNext = true
+        users.pop()
+      }
+
+      ctx.body = {
+        query: users,
+        hasNext,
+        offset: ctx.offset,
+        limit: ctx.limit,
+      }
     })
 
   return router.init(req, res)

docs/api-collections.http

@@ -35,6 +35,18 @@ GET {{ENDPOINT}}/query/site
     &project=*
     &sort=!_total
 
+### Query site users
+GET {{ENDPOINT}}/query/site/users
+    # required {string}
+    ?siteUrl=https://zh.moegirl.org.cn/
+    # {number}
+    &offset=0
+    # {number}
+    &limit=5
+    # {'*' | string}
+    &project=*
+    &sort=!count
+
 ### Search users
 GET {{ENDPOINT}}/search/user
     # required {string}

src/view/site.vue

@@ -39,7 +39,7 @@ h1(v-else) {{ site.siteName }}
         .key User
         .val Count
       .list-item.card(
-        v-for='(user, index) in site.users.sort((a, b) => b.count - a.count)'
+        v-for='(user, index) in users.sort((a, b) => b.count - a.count)'
       )
         .val(style='flex: 0; padding: 0 1rem') {{ index + 1 }}
         .key
@@ -68,15 +68,13 @@ const site = ref<{
   siteUrl: string
   _total: number
   features: any[]
-  users: { userName: string; count: number }[]
 }>({
   siteName: '',
   siteUrl: '',
   _total: 0,
   features: [],
-  users: [],
 })
-const users = ref<{ userName: string; count: number }[]>()
+const users = ref<{ userName: string; count: number }[]>([])
 const loading = ref<boolean>(true)
 const route = useRoute()
 
@@ -93,14 +91,29 @@ function initSite() {
       loading.value = false
       const [query] = data.body.query
       site.value = query
-      users.value = (query.users as { userName: string; count: number }[]).sort(
-        (a, b) => b.count - a.count
-      )
-      setTitle(query.siteName, 'wiki data')
+      setTitle(query.siteName, 'wiki')
+      initUsers()
     })
     .finally(() => {})
 }
 
+function initUsers() {
+  axios
+    .get(`${API_BASE}/query/site/users`, {
+      params: {
+        siteUrl: route.query.siteUrl,
+        limit: 100,
+        sort: '!count',
+        prop: 'userName|count',
+      },
+    })
+    .then(({ data }) => {
+      const { query } = data.body
+      users.value = query
+    })
+    .finally(() => {})
+
+
 onMounted(() => {
   setTitle('wiki data')
   initSite()