feat: GQL query to get latest service messages

packages/daf-cli/src/graphql.ts

@@ -36,6 +36,7 @@ program
       context: () => ({ dataStore, core }),
       introspection: true,
     })
+    await core.setupServices()
     const info = await server.listen({ port: cmd.port })
     console.log(`🚀  Server ready at ${info.url}`)
 

packages/daf-core/src/graphql/graphql-base-type-defs.ts

@@ -22,7 +22,6 @@ export const baseTypeDefs = `
   }
 
   type MessageMetaData {
-    rowId: String!
     type: String!
     id: String
     data: String

packages/daf-core/src/graphql/graphql-core.ts

@@ -1,4 +1,6 @@
 import { Core } from '../core'
+import { LastMessageTimestampForInstance } from '../service/service-manager'
+
 import { Message } from '../message/message'
 
 interface Context {
@@ -21,13 +23,53 @@ const newMessage = async (
   )
 }
 
+const serviceMessagesSince = async (
+  _: any,
+  args: { ts: LastMessageTimestampForInstance[] },
+  ctx: Context,
+) => {
+  const res = await ctx.core.getMessagesSince(args.ts)
+  return res.map(msg => ({
+    ...msg,
+    data: JSON.stringify(msg.data),
+    raw: msg.raw,
+    metaData: msg.allMeta,
+  }))
+}
+
 export const resolvers = {
+  Query: {
+    serviceMessagesSince,
+  },
   Mutation: {
     newMessage,
   },
 }
 
 export const typeDefs = `
+  input LastMessageTimestampForInstance {
+    timestamp: Int!
+    did: String!
+    type: String!
+    id: String!
+  }
+
+  type ServiceMessage {
+    id: String!
+    threadId: String,
+    timestamp: Int,
+    sender: String,
+    receiver: String,
+    type: String,
+    raw: String,
+    data: String,
+    metaData: [MessageMetaData]
+  }
+
+  extend type Query {
+    serviceMessagesSince(ts: [LastMessageTimestampForInstance]!): [ServiceMessage]
+  }
+
   extend type Mutation {
     newMessage(raw: String!, sourceType: String!, sourceId: String): Message
   }