antonioftamura

{
   "Resources":{
      "LambdaResolverDataSource":{
         "Type":"AWS::AppSync::DataSource",
         "Properties":{
            "ApiId":{
               "Ref":"AppSyncApiId"
            },
            "Name":"LambdaResolverFunction",
            "Type":"AWS_LAMBDA",

antonioftamura

exports.handler = async  (event, context, callback) => {
    switch(event.field) {
        case "getTodo":
            const todo = {"id": "1", "name": "My TODO", "description": "My first TODO"};
            callback(null, todo);
            break;
        // Add any methods that you want here.
        default:
            callback("Unknown field, unable to resolve" + event.field, null);
            break;

antonioftamura

$utils.toJson($context.result)

antonioftamura

{
    "version": "2017-02-28",
    "operation": "Invoke",
    "payload": {
        "field": "getTodo",
        "arguments":  $utils.toJson($context.arguments)
    }
}

antonioftamura

exports.handler = async  (event, context, callback) => {
  
    // Simple Postgres lib that supports async calls
    const { Pool } = require('pg');
    const pool = new Pool();

    switch(event.field) {
        case "getTodo":
            var id = event.arguments.id;
            const querySelect = 'SELECT * FROM todo WHERE id = $1';

antonioftamura

schema {
    query: Query
    mutation: Mutation
}

type Query {
  getTodo(id:ID!): Todo
  allTodos: [Todo]
}