带 FaunaDB 的 API 服务器

FaunaDB 自称为“现代应用程序的数据 API”。它是一个带有 GraphQL 接口的数据库，使您可以使用 GraphQL 与其交互。由于我们使用 HTTP 请求与其通信，因此我们不需要管理连接，这非常适合无服务器应用程序。

本教程假设您拥有 FaunaDB 和 Deno Deploy 帐户，已安装 Deno Deploy CLI，并了解一些 GraphQL 的基本知识。

概述
构建 API 端点
使用 FaunaDB 进行持久化
部署 API

概述跳转到标题

在本教程中，让我们构建一个小型报价 API，其中包含用于插入和检索报价的端点。稍后我们将使用 FaunaDB 持久保存这些报价。

让我们首先定义 API 端点。

# A POST request to the endpoint should insert the quote to the list.
POST /quotes/
# Body of the request.
{
  "quote": "Don't judge each day by the harvest you reap but by the seeds that you plant.",
  "author": "Robert Louis Stevenson"
}

# A GET request to the endpoint should return all the quotes from the database.
GET /quotes/
# Response of the request.
{
  "quotes": [
    {
      "quote": "Don't judge each day by the harvest you reap but by the seeds that you plant.",
      "author": "Robert Louis Stevenson"
    }
  ]
}

现在我们了解了端点的行为方式，让我们继续构建它。

构建 API 端点跳转到标题

首先，创建一个名为 quotes.ts 的文件，并将以下内容粘贴到其中。

仔细阅读代码中的注释以了解正在发生的事情。

import {
  json,
  serve,
  validateRequest,
} from "https://deno.land/x/[email protected]/mod.ts";

serve({
  "/quotes": handleQuotes,
});

// To get started, let's just use a global array of quotes.
const quotes = [
  {
    quote: "Those who can imagine anything, can create the impossible.",
    author: "Alan Turing",
  },
  {
    quote: "Any sufficiently advanced technology is equivalent to magic.",
    author: "Arthur C. Clarke",
  },
];

async function handleQuotes(request: Request) {
  // Make sure the request is a GET request.
  const { error } = await validateRequest(request, {
    GET: {},
  });
  // validateRequest populates the error if the request doesn't meet
  // the schema we defined.
  if (error) {
    return json({ error: error.message }, { status: error.status });
  }

  // Return all the quotes.
  return json({ quotes });
}

使用 Deno CLI 运行上述程序。

deno run --allow-net=:8000 ./path/to/quotes.ts
# Listening on http://0.0.0.0:8000/

并使用 curl 命令访问端点以查看一些报价。

curl http://127.0.0.1:8000/quotes
# {"quotes":[
# {"quote":"Those who can imagine anything, can create the impossible.", "author":"Alan Turing"},
# {"quote":"Any sufficiently advanced technology is equivalent to magic.","author":"Arthur C. Clarke"}
# ]}

让我们继续处理 POST 请求。

更新 validateRequest 函数以确保 POST 请求遵循提供的正文方案。

-  const { error } = await validateRequest(request, {
+  const { error, body } = await validateRequest(request, {
    GET: {},
+   POST: {
+      body: ["quote", "author"]
+   }
  });

通过使用以下代码更新 handleQuotes 函数来处理 POST 请求。

async function handleQuotes(request: Request) {
  const { error, body } = await validateRequest(request, {
    GET: {},
    POST: {
      body: ["quote", "author"],
    },
  });
  if (error) {
    return json({ error: error.message }, { status: error.status });
  }

+  // Handle POST requests.
+  if (request.method === "POST") {
+    const { quote, author } = body as { quote: string; author: string };
+    quotes.push({ quote, author });
+    return json({ quote, author }, { status: 201 });
+  }

  return json({ quotes });
}

让我们通过插入一些数据来测试它。

curl --dump-header - --request POST --data '{"quote": "A program that has not been tested does not work.", "author": "Bjarne Stroustrup"}' http://127.0.0.1:8000/quotes

输出可能类似于以下内容。

HTTP/1.1 201 Created
transfer-encoding: chunked
content-type: application/json; charset=utf-8

{"quote":"A program that has not been tested does not work.","author":"Bjarne Stroustrup"}

太棒了！我们构建了我们的 API 端点，它按预期工作。由于数据存储在内存中，因此在重新启动后它将丢失。让我们使用 FaunaDB 持久保存我们的报价。

使用 FaunaDB 进行持久化跳转到标题

让我们使用 GraphQL Schema 定义数据库模式。

# We're creating a new type named `Quote` to represent a quote and its author.
type Quote {
  quote: String!
  author: String!
}

type Query {
  # A new field in the Query operation to retrieve all quotes.
  allQuotes: [Quote!]
}

Fauna 为其数据库提供了一个 graphql 端点，它会生成必要的变异，例如为在模式中定义的数据类型创建、更新、删除。例如，fauna 将生成一个名为 createQuote 的变异，以在数据库中为数据类型 Quote 创建新的报价。我们还另外定义了一个名为 allQuotes 的查询字段，它返回数据库中的所有报价。

让我们开始编写代码，以便从 Deno Deploy 应用程序与 fauna 进行交互。

为了与 fauna 进行交互，我们需要向其 graphql 端点发送 POST 请求，并提供适当的查询和参数以获取返回值。因此，让我们构建一个通用函数来处理这些事情。

async function queryFauna(
  query: string,
  variables: { [key: string]: unknown },
): Promise<{
  data?: any;
  error?: any;
}> {
  // Grab the secret from the environment.
  const token = Deno.env.get("FAUNA_SECRET");
  if (!token) {
    throw new Error("environment variable FAUNA_SECRET not set");
  }

  try {
    // Make a POST request to fauna's graphql endpoint with body being
    // the query and its variables.
    const res = await fetch("https://graphql.fauna.com/graphql", {
      method: "POST",
      headers: {
        authorization: `Bearer ${token}`,
        "content-type": "application/json",
      },
      body: JSON.stringify({
        query,
        variables,
      }),
    });

    const { data, errors } = await res.json();
    if (errors) {
      // Return the first error if there are any.
      return { data, error: errors[0] };
    }

    return { data };
  } catch (error) {
    return { error };
  }
}

将此代码添加到 quotes.ts 文件中。现在，让我们继续更新端点以使用 fauna。

async function handleQuotes(request: Request) {
  const { error, body } = await validateRequest(request, {
    GET: {},
    POST: {
      body: ["quote", "author"],
    },
  });
  if (error) {
    return json({ error: error.message }, { status: error.status });
  }

  if (request.method === "POST") {
+    const { quote, author, error } = await createQuote(
+      body as { quote: string; author: string }
+    );
+    if (error) {
+      return json({ error: "couldn't create the quote" }, { status: 500 });
+    }

    return json({ quote, author }, { status: 201 });
  }

  return json({ quotes });
}

+async function createQuote({
+  quote,
+  author,
+}: {
+  quote: string;
+  author: string;
+}): Promise<{ quote?: string; author?: string; error?: string }> {
+  const query = `
+    mutation($quote: String!, $author: String!) {
+      createQuote(data: { quote: $quote, author: $author }) {
+        quote
+        author
+      }
+    }
+  `;
+
+  const { data, error } = await queryFauna(query, { quote, author });
+  if (error) {
+    return { error };
+  }
+
+  return data;
+}

现在我们已经更新了代码以插入新的报价，让我们在继续测试代码之前设置一个 fauna 数据库。

创建新数据库

访问 https://dashboard.fauna.com（如果需要，请登录），然后点击**新建数据库**
填写**数据库名称**字段，然后点击**保存**。
点击左侧边栏上可见的**GraphQL**部分。
创建一个以 .gql 扩展名结尾的文件，其内容是我们上面定义的模式。

生成访问数据库的密钥

点击**安全**部分，然后点击**新建密钥**。
选择**服务器**角色，然后点击**保存**。复制密钥。

现在让我们使用密钥运行应用程序。

FAUNA_SECRET=<the_secret_you_just_obtained> deno run --allow-net=:8000 --watch quotes.ts
# Listening on http://0.0.0.0:8000

curl --dump-header - --request POST --data '{"quote": "A program that has not been tested does not work.", "author": "Bjarne Stroustrup"}' http://127.0.0.1:8000/quotes

注意报价是如何添加到 FaunaDB 中的集合中的。

让我们编写一个新函数来获取所有报价。

async function getAllQuotes() {
  const query = `
    query {
      allQuotes {
        data {
          quote
          author
        }
      }
    }
  `;

  const {
    data: {
      allQuotes: { data: quotes },
    },
    error,
  } = await queryFauna(query, {});
  if (error) {
    return { error };
  }

  return { quotes };
}

并使用以下代码更新 handleQuotes 函数。

-// To get started, let's just use a global array of quotes.
-const quotes = [
-  {
-    quote: "Those who can imagine anything, can create the impossible.",
-    author: "Alan Turing",
-  },
-  {
-    quote: "Any sufficiently advanced technology is equivalent to magic.",
-    author: "Arthur C. Clarke",
-  },
-];

async function handleQuotes(request: Request) {
  const { error, body } = await validateRequest(request, {
    GET: {},
    POST: {
      body: ["quote", "author"],
    },
  });
  if (error) {
    return json({ error: error.message }, { status: error.status });
  }

  if (request.method === "POST") {
    const { quote, author, error } = await createQuote(
      body as { quote: string; author: string },
    );
    if (error) {
      return json({ error: "couldn't create the quote" }, { status: 500 });
    }

    return json({ quote, author }, { status: 201 });
  }

+  // It's assumed that the request method is "GET".
+  {
+    const { quotes, error } = await getAllQuotes();
+    if (error) {
+      return json({ error: "couldn't fetch the quotes" }, { status: 500 });
+    }
+
+    return json({ quotes });
+  }
}

curl http://127.0.0.1:8000/quotes

您应该看到我们插入到数据库中的所有报价。API 的最终代码位于 https://deno.org.cn/examples/fauna.ts。

部署 API 跳转到标题

现在我们已经准备就绪，让我们部署您的新 API！

在浏览器中访问 Deno Deploy 并链接您的 GitHub 帐户。
选择包含新 API 的仓库。
您可以为项目命名，也可以让 Deno 为您生成一个名称。
在入口点下拉菜单中选择 index.ts
点击**部署项目**

为了使您的应用程序能够正常工作，我们需要配置其环境变量。

在您的项目成功页面或项目仪表板中，点击**添加环境变量**。在环境变量下，点击**+ 添加变量**。创建一个名为 FAUNA_SECRET 的新变量 - 该值应该是我们之前创建的密钥。

在您的项目概览中，点击查看在浏览器中查看项目，在URL末尾添加/quotes以查看您的FaunaDB内容。

带 FaunaDB 的 API 服务器

概述 跳转到标题#

构建 API 端点 跳转到标题#

使用 FaunaDB 进行持久化 跳转到标题#

部署 API 跳转到标题#

概述跳转到标题

构建 API 端点跳转到标题

使用 FaunaDB 进行持久化跳转到标题

部署 API 跳转到标题