resolver de recipients

db/migrations/20180413024152_new_group_message_relations.js

+
+exports.up = async function(knex, Promise) {
+    let relations = await knex.select().from('group_message_relationships');
+    await knex('group_message_relationships').del();    
+    await knex.schema.table('group_message_relationships', table => {
+        table.dropColumn('status');
+    });
+    await knex.schema.table('group_message_relationships', table => {
+        table.enum('status', ['join', 'host', 'publish', 'recieve', 'internal']);
+    });
+    return knex('group_message_relationships').insert(relations);
+};
+
+exports.down = async function(knex, Promise) {
+    let relations = await knex.select().from('group_message_relationships')
+        .whereIn('status', ['join', 'host', 'publish']);
+    await knex('group_message_relationships').del();    
+    await knex.schema.table('group_message_relationships', table => {
+        table.dropColumn('status');
+    });
+    await knex.schema.table('group_message_relationships', table => {
+        table.enum('status', ['join', 'host', 'publish']);
+    });
+    return knex('group_message_relationships').insert(relations);
+};

db/seeds/07_make_event.js

@@ -2,6 +2,7 @@
 exports.seed = async function(knex, Promise) {
   // Deletes ALL existing entries
   await knex('events').del()
+  await knex('group_message_relationships').del()
       // Inserts seed entries
   await knex('events').insert([
     {
@@ -20,7 +21,13 @@ exports.seed = async function(knex, Promise) {
       message : 42,
       group : 'br',
       status : 'host'
+    },
+    {
+      message : 42,
+      group : 'kes',
+      status : 'recieve'
     }
+    
   ]);
     
 };

src/graphql/connectors/connectors.js

@@ -400,7 +400,17 @@ export async function getMessageAuthor(user, messageID){
 }
 
 export async function getMessageRecipient(user, messageID){
+    let GroupReciepients = await getGroupsFromCallbacks(user, qb  => {
+        return qb.select({uid: 'group'}).from('group_message_relationships')
+          .where('message', messageID).where('status', 'recieve')
+        })
+    let recipientObject = Object()
+    if(GroupReciepients.length == 1)
+        recipientObject.singleGroup = GroupReciepients[0]
+    else
+        authorObject.multipleGroups = GroupReciepients
 
+    return recipientObject
 }
 
 /**

src/graphql/resolvers.js

@@ -113,7 +113,7 @@ export const resolvers = {
         },
 
         test: async function(obj, args, context){
-            return connectors.getSimpleGroup(context.user, "br")
+            return connectors.getSimpleGroup(context.user, "br");
         }
     },
 
@@ -219,11 +219,11 @@ export const resolvers = {
         },
 
         authors: async function (obj, args, context){
-            return connectors.getMessageAuthor(context.user, obj.id)
+            return connectors.getMessageAuthor(context.user, obj.id);
         },
 
         recipient: async function (obj, args, context){
-            return connectors.getMessageRecipient(context.user, obj.id)
+            return connectors.getMessageRecipient(context.user, obj.id);
         }
     },
 
@@ -247,11 +247,11 @@ export const resolvers = {
         },
 
         authors: async function (obj, args, context){
-            return connectors.getMessageAuthor(context.user, obj.id)
+            return connectors.getMessageAuthor(context.user, obj.id);
         },
 
         recipient: async function (obj, args, context){
-            return connectors.getMessageRecipient(context.user, obj.id)
+            return connectors.getMessageRecipient(context.user, obj.id);
         }
     },