dql is now dql.query and dql.mutate

Author: gja

script.js

@@ -12,7 +12,7 @@ self.addGraphQLResolvers({
 
 async function reallyComplexDql({ parents, dql }) {
   const ids = parents.map(p => p.id);
-  const someComplexResults = await dql(`really-complex-query-here with ${ids}`);
+  const someComplexResults = await dql.query(`really-complex-query-here with ${ids}`);
   return parents.map(parent => someComplexResults[parent.id])
 }
 

slash-graphql-lambda-types/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@slash-graphql/lambda-types",
-  "version": "1.0.0",
+  "version": "1.1.0",
   "description": "Types for building out a Dgraph Lambda",
   "main": "index.js",
   "types": "types.d.ts",

slash-graphql-lambda-types/types.d.ts

@@ -21,7 +21,10 @@ module "@slash-graphql/lambda-types" {
   type GraphQLEvent = GraphQLEventFields & {
     respondWith: (r: ResolverResponse) => void,
     graphql: (s: string, vars: Record<string, any> | undefined) => Promise<GraphQLResponse>,
-    dql: (s: string, vars: Record<string, any> | undefined) => Promise<GraphQLResponse>,
+    dql: {
+      query: (s: string, vars: Record<string, any> | undefined) => Promise<GraphQLResponse>
+      mutate: (s: string) => Promise<GraphQLResponse>
+    },
   }
 
   type GraphQLEventWithParent = GraphQLEvent & {

src/dgraph.ts

@@ -17,7 +17,7 @@ export async function graphql(query: string, variables: Record<string, any> = {}
   return response.json();
 }
 
-export async function dql(query: string, variables: Record<string, any> = {}): Promise<GraphQLResponse> {
+async function dqlQuery(query: string, variables: Record<string, any> = {}): Promise<GraphQLResponse> {
   const response = await fetch(`${process.env.DGRAPH_URL}/query`, {
     method: "POST",
     headers: {
@@ -31,3 +31,23 @@ export async function dql(query: string, variables: Record<string, any> = {}): P
   }
   return response.json();
 }
+
+async function dqlMutate(mutate: string): Promise<GraphQLResponse> {
+  const response = await fetch(`${process.env.DGRAPH_URL}/mutate?commitNow=true`, {
+    method: "POST",
+    headers: {
+      "Content-Type": "pplication/rdf",
+      "X-Auth-Token": process.env.DGRAPH_TOKEN || ""
+    },
+    body: mutate
+  })
+  if (response.status !== 200) {
+    throw new Error("Failed to execute DQL Mutate")
+  }
+  return response.json();
+}
+
+export const dql = {
+  query: dqlQuery,
+  mutate: dqlMutate,
+}

src/evaluate-script.test.ts

@@ -60,7 +60,7 @@ describe(evaluateScript, () => {
     it("works with dgraph dql", async () => {
       const runScript = evaluateScript(`
         async function todoTitles({dql}) {
-          const results = await dql('{ queryTitles(func: type(Todo)){ Todo.title } }')
+          const results = await dql.query('{ queryTitles(func: type(Todo)){ Todo.title } }')
           return results.data.queryTitles.map(t => t["Todo.title"])
         }
         addGraphQLResolvers({ "Query.todoTitles": todoTitles })`)