Serverless FrameworkでAWS AppSync上にGraphQL APIを構築したい（HTTPデータソース）

service: appsync-serverless-poc
frameworkVersion: "3"
configValidationMode: error

plugins:
  - serverless-appsync-plugin

provider:
  name: aws
  region: ap-northeast-1

appSync:
  name: AppSync Playground(serverless)
  schema: schema.graphql

  authentication:
    type: API_KEY

  dataSources:
    catstronautsRestApi:
      type: HTTP
      config:
        endpoint: https://odyssey-lift-off-rest-api.herokuapp.com

  pipelineFunctions:
    getTracksForHome:
      dataSource: catstronautsRestApi
      code: functions/getTracksForHome.js

    getAuthor:
      dataSource: catstronautsRestApi
      code: functions/getAuthor.js

  resolvers:
    Query.tracksForHome:
      code: resolvers/Query.tracksForHome.js
      functions:
        - getTracksForHome

    Track.author:
      code: resolvers/Track.author.js
      functions:
        - getAuthor

type Author {
  id: ID!
  name: String!
  photo: String
}

type Query {
  tracksForHome: [Track!]!
}

type Track {
  id: ID!
  title: String!
  author: Author!
  thumbnail: String
  length: Int
  modulesCount: Int
}

import { util } from "@aws-appsync/utils";

export function request(ctx) {
  return {
    method: "GET",
    params: {
      headers: { "Content-Type": "application/json" },
    },
    resourcePath: "/tracks",
  };
}

export function response(ctx) {
  const { error, result } = ctx;
  if (error) {
    ctx.stash.errors = ctx.stash.errors ?? [];
    ctx.stash.errors.push(ctx.error);
    return util.appendError(error.message, error.type, result);
  }

  if (result.statusCode === 200) {
    return JSON.parse(result.body);
  } else {
    return util.appendError(result.body, result.statusCode);
  }
}

import { util } from "@aws-appsync/utils";

export function request(ctx) {
  return {
    method: "GET",
    params: {
      headers: { "Content-Type": "application/json" },
    },
    resourcePath: `/author/${ctx.source.authorId}`,
  };
}

export function response(ctx) {
  const { error, result } = ctx;
  if (error) {
    ctx.stash.errors = ctx.stash.errors ?? [];
    ctx.stash.errors.push(ctx.error);
    return util.appendError(error.message, error.type, result);
  }

  if (result.statusCode === 200) {
    return JSON.parse(result.body);
  } else {
    return util.appendError(result.body, result.statusCode);
  }
}

export function request(ctx) {
  return {};
}

export function response(ctx) {
  return ctx.prev.result;
}

pnpm serverless config credentials --provider aws --key xxx --secret yyy

pnpm serverless deploy