如何使用 POST 响应的一部分作为另一个 post 请求的参数？ （GraphQL 的分页）

Question

我想使用“endCursor”通过分页向 Github GraphQL API 发出多个 POST 请求。

var unirest = require ('unirest');
var async = require('async');
const endpoint="https://api.github.com/graphql"
const token = "sometoken";

var search_query={
  "query": 'query($name: String!, $after: String){\
          search(query:$name, type: USER, first: 2, after: $after){\
                userCount\
                pageInfo{endCursor}\
                nodes{\
                   ...on User{\
                          id \
                          bio \
                          html_url:url \
                         }\
                       }\
                     }\
                   }',
     "variable": {"name":"somename", "after":null}
    };
unirest.post(endpoint)
.headers({"Content-Type": "text/html" , "Authorization": "bearer "+token, 'user-agent': 'node.js'})
.send(JSON.stringify(search_query)) //creating requests
.end(function(response, request){
    console.log(response.body.data.search.pageInfo.endCursor);
  });

我想多次迭代这个 POST 请求。每次使用 $after 作为最后一个请求的 endCursor。我该怎么做？谢谢！

Answer 1

首先，我建议您也从 pageInfo 获取 hasNextPage 这样您就可以知道何时到达终点。

之后你只需要更好地构建你的代码

将 search_query 改为这样的函数：

function searchQuery(after = null) {
  return {
    "query": `query($name: String!, $after: String){
          search(query:$name, type: USER, first: 2, after: $after){
                userCount
                pageInfo {
                    hasNextPage
                    endCursor
                }
                nodes{
                   ...on User{
                          id 
                          bio 
                          html_url:url 
                         }
                       }
                     }
                 }`,
    "variable": {
      "name": "somename",
      "after": after
    }
  };
};

现在searchQuery 返回一个基于参数after 的查询
所以你需要做的是创建一个逻辑"while"，当响应hasNextPage为假时完成：

function queryServer(after) {
  unirest.post(endpoint)
    .headers({
      "Content-Type": "text/html",
      "Authorization": "bearer " + token,
      'user-agent': 'node.js'
    })
    .send(JSON.stringify(searchQuery(after))) //creating requests
    .end(function(response, request) {
      // do stuff with the result
      console.log(response.body.data.search.pageInfo.endCursor);
      
      // if there are more pages get them
      if (response.body.data.search.pageInfo.hasNextPage) {
        return queryServer(response.body.data.search.pageInfo.endCursor);
      }
    });
}

queryServer(null);

注意：我还没有测试过代码，而且 IMO 使用支持 promises 的不同请求包（如 axios），代码可能会更干净，然后您甚至可以合并 async/await，这样会很多更易于使用和理解 而不是当前需要的那种丑陋的递归......