Calling AppSync from Lambda

index.js

const https = require('https');
const AWS = require("aws-sdk");
const urlParse = require("url").URL;
const appsyncUrl = process.env.API_BACKENDGRAPHQL_GRAPHQLAPIENDPOINTOUTPUT;
const region = process.env.REGION;
const endpoint = new urlParse(appsyncUrl).hostname.toString();
const graphqlQuery = require('./query.js').mutation;
const apiKey = process.env.API_KEY;

exports.handler = async (event) => {
    const req = new AWS.HttpRequest(appsyncUrl, region);

    const item = {
        input: {
            title: "Lambda Item",
            Content: "Item Generated from Lambda"
        }
    };

    req.method = "POST";
    req.headers.host = endpoint;
    req.headers["Content-Type"] = "application/json";
    req.body = JSON.stringify({
        query: graphqlQuery,
        operationName: "createLambdaGraphQL",
        variables: item
    });

    if (apiKey) {
        req.headers["x-api-key"] = apiKey;
    } else {
        const signer = new AWS.Signers.V4(req, "appsync", true);
        signer.addAuthorization(AWS.config.credentials, AWS.util.date.getDate());
    }

    const data = await new Promise((resolve, reject) => {
        const httpRequest = https.request({ ...req, host: endpoint }, (result) => {
            result.on('data', (data) => {
                resolve(JSON.parse(data.toString()));
            });
        });

        httpRequest.write(req.body);
        httpRequest.end();
    });

    return {
        statusCode: 200,
        body: data
    };
};

query.js

module.exports = {
    mutation: `mutation createLambdaGraphQL($input: CreateLambdaGraphQLInput!) {
      createLambdaGraphQL(input: $input) {
        id
        title
        Content
      }
    }
    `
}

@janhesters I made a few updates above. Remember this was a gist as a quick sample, so yes most likely the credentials aren't needed I just need to double check the default Lambda SDK import is setting credentials. The host endpoint is needed as a signer param but I moved it to use a spread operator for readability. I'm not sure why you're seeing the error on line 40, maybe it was a typo or something copied/pasted wrong? It also might be that you didn't have the environment variables set for the region or graphql endpoint.

Confirmed - The latest code above works. BTW I also verified I think the reason you were getting that "Data must be string or buffer" was because you didn't have the env vars in your lambda for the endpoint and region. If you didn't use the CLI to create your function after creating an AppSync backend, you would need to manually create them.

the line #5:
const region = process.env.REGION;

should be:
const region = process.env.AWS_REGION;

Thanks for this gist.

Thanks a lot for this gist!

Just FYI, this was taken from the official AWS Amplify docs here: https://docs.amplify.aws/cli/function#signing-a-request-from-lambda