fix: NewMessage mutation

decentralized-identity · Nov 14, 2019 · 3c9428e · 3c9428e
1 parent 628780a
commit 3c9428e
Showing 1 changed file with 9 additions and 3 deletions.
diff --git a/packages/daf-core/src/graphql-core.ts b/packages/daf-core/src/graphql-core.ts
@@ -4,8 +4,14 @@ interface Context {
   core: Core
 }
 
-const newMessage = async (_: any, args: { raw: string }, ctx: Context) => {
-  return await ctx.core.onRawMessage({ raw: args.raw })
+const newMessage = async (_: any, args: { raw: string, sourceType: string, sourceId?: string }, ctx: Context) => {
+  return await ctx.core.onRawMessage({ 
+    raw: args.raw,
+    meta: [{
+      sourceType: args.sourceType,
+      sourceId: args.sourceId
+    }]
+  })
 }
 
 export const resolvers = {
@@ -16,6 +22,6 @@ export const resolvers = {
 
 export const typeDefs = `
   extend type Mutation {
-    newMessage(raw: String): Message
+    newMessage(raw: String!, sourceType: String!, sourceId: String): Message
   }
 `