Release/v1.0.0 beta

connectors/local.js

@@ -1,24 +1,5 @@
-let comments = [
-  {
-    id: "0",
-    content: "Hello world",
-    author: "Louis Bertrand"
-  },
-  {
-    id: "1",
-    content: "Lymeo",
-    author: "Cortney Knorr"
-  },
-  {
-    id: "2",
-    content: "brhibhribir",
-    author: "vebiveivhei"
-  }
-];
-
 module.exports = async function() {
-
   return {
-    comments
+
   };
 };

directives/trigger.js

@@ -0,0 +1,42 @@
+/**
+ * 
+ * the name of the file is the name of the directive
+ * 
+ */
+
+let {
+    SchemaDirectiveVisitor
+} = require("graphql-tools");
+let {
+    defaultFieldResolver
+} = require("graphql");
+
+class TriggerDirective extends SchemaDirectiveVisitor {
+
+    visitFieldDefinition(field, {objectType}) {
+
+        let subName = this.args.name
+
+        const { resolve = defaultFieldResolver } = field;
+
+        field.resolve = async function(root, params, context) {
+
+            let resolverResult = await this::resolve(root, params, context); 
+
+            if (subName && subName != '') {
+                const {pubsub} = context
+
+                pubsub.publish(subName, {
+                    [subName]: resolverResult
+                });
+            }
+
+            return resolverResult;
+        };
+
+    }
+
+}
+
+
+module.exports = TriggerDirective;

other/authentication.js

@@ -5,9 +5,10 @@
  * @returns {async function} Asynchronous authentication middleware
  */
 function authenticator(context) {
-  return async function authenticate(request, accept, reject) {
-    return accept();
-  };
+	return async function authenticate(request, accept, reject) {
+		context.logger.debug('Authentication challenge');
+		return accept();
+	};
 }
 
 module.exports = authenticator;