hasura / hasura-actions-examples Goto Github PK

const fetch = require("node-fetch");
const bcrypt = require("bcryptjs");
const jwt = require("jsonwebtoken");

const HASURA_OPERATION = `
mutation ($username: String!, $password: String!) {
  insert_user_one(object: {
    username: $username,
    password: $password,
  }) {
    id
  }
}
`;

// execute the parent mutation in Hasura
const execute = async (variables, reqHeaders) => {
  const fetchResponse = await fetch("http://localhost:8080/v1/graphql", {
    method: "POST",
    headers: reqHeaders || {},
    body: JSON.stringify({
      query: HASURA_OPERATION,
      variables,
    }),
  });
  return await fetchResponse.json();
};

// Request Handler
const handler = async (req, res) => {
  // get request input
  const { username, password } = req.body.input;

  // run some business logic
  const salt = bcrypt.genSaltSync();
  let hashedPassword = await bcrypt.hash(password, salt);

  // execute the Hasura operation
  const { data, errors } = await execute(
    { username, password: hashedPassword },
    req.headers
  );

  // if Hasura operation errors, then throw error
  if (errors) {
    return res.status(400).json({
      message: errors.message,
    });
  }

  const tokenContents = {
    sub: data.insert_user_one.id.toString(),
    name: username,
    iat: Date.now() / 1000,
    "https://hasura.io/jwt/claims": {
      "x-hasura-allowed-roles": ["user", "anonymous"],
      "x-hasura-user-id": data.insert_user_one.id.toString(),
      "x-hasura-default-role": "user",
      "x-hasura-role": "user",
    },
    exp: Math.floor(Date.now() / 1000) + 24 * 60 * 60,
  };

  const token = jwt.sign(tokenContents, process.env.AUTH_PUBLIC_KEY);

  // success
  return res.json({
    ...data.insert_user_one,
    token: token,
  });
};

module.exports = handler;

mutation {
  signup(name: "Seb", home: "UK", email: "[email protected]", password: "test123") {
    id
  }
}

{
  "errors": [
    {
      "extensions": {
        "internal": {
          "error": {
            "type": "http_exception",
            "message": "ConnectionFailure Network.Socket.getAddrInfo (called with preferred socket type/protocol: AddrInfo {addrFlags = [AI_ADDRCONFIG], addrFamily = AF_UNSPEC, addrSocketType = Stream, addrProtocol = 0, addrAddress = <assumed to be undefined>, addrCanonName = <assumed to be undefined>}, host name: Just \"host.docker.internal\", service name: Just \"3000\"): does not exist (Name or service not known)"
          },
          "response": null,
          "request": {
            "body": {
              "session_variables": {
                "x-hasura-role": "admin"
              },
              "input": {
                "email": "[email protected]",
                "home": "UK",
                "name": "seb",
                "password": "test"
              },
              "action": {
                "name": "signup"
              }
            },
            "url": "http://host.docker.internal:3000/signup",
            "headers": []
          }
        },
        "path": "$",
        "code": "unexpected"
      },
      "message": "http exception when calling webhook"
    }
  ]
}

mutation {
  signup(name: "Seb", username: "[email protected]", password: "test123"){
    id
    name
  }
}