test: add an example of custom mutation resolver with tag adding to existed record via script

Related #37

Author: nodkz

README.md

@@ -3,10 +3,9 @@ graphql-compose-elasticsearch
 
 [![](https://img.shields.io/npm/v/graphql-compose-elasticsearch.svg)](https://www.npmjs.com/package/graphql-compose-elasticsearch)
 [![npm](https://img.shields.io/npm/dt/graphql-compose-elasticsearch.svg)](http://www.npmtrends.com/graphql-compose-elasticsearch)
-[![Travis](https://img.shields.io/travis/nodkz/graphql-compose-elasticsearch.svg?maxAge=2592000)](https://travis-ci.org/nodkz/graphql-compose-elasticsearch)
+[![Travis](https://img.shields.io/travis/graphql-compose/graphql-compose-elasticsearch.svg?maxAge=2592000)](https://travis-ci.org/graphql-compose/graphql-compose-elasticsearch)
 [![Commitizen friendly](https://img.shields.io/badge/commitizen-friendly-brightgreen.svg)](http://commitizen.github.io/cz-cli/)
 [![semantic-release](https://img.shields.io/badge/%20%20%F0%9F%93%A6%F0%9F%9A%80-semantic--release-e10079.svg)](https://github.com/semantic-release/semantic-release)
-[![Greenkeeper badge](https://badges.greenkeeper.io/nodkz/graphql-compose-elasticsearch.svg)](https://greenkeeper.io/)
 
 This module expose Elastic Search REST API via GraphQL.
 
@@ -46,7 +45,7 @@ const schema = new GraphQLSchema({
 });
 ```
 
-Full [code example](https://github.com/nodkz/graphql-compose-elasticsearch/tree/master/examples/differentVersions)
+Full [code example](https://github.com/graphql-compose/graphql-compose-elasticsearch/tree/master/examples/differentVersions)
 
 Live demo of [Introspection of Elasticsearch API via Graphiql](https://graphql-compose.herokuapp.com/elasticsearch/)
 
@@ -126,7 +125,7 @@ const Schema = new GraphQLSchema({
 });
 ```
 
-Full [code example](https://github.com/nodkz/graphql-compose-elasticsearch/blob/master/examples/elastic50/index.js)
+Full [code example](https://github.com/graphql-compose/graphql-compose-elasticsearch/blob/master/examples/elastic50/index.js)
 
 ## Installation
 ```
@@ -150,6 +149,36 @@ Modules `graphql`, `graphql-compose`, `elasticsearch` are in `peerDependencies`,
 ### Mapping: Generated GraphQL Types and Documentation
 <img width="1703" alt="screen shot 2017-03-22 at 19 33 24" src="https://cloud.githubusercontent.com/assets/1946920/24200220/a05944b6-0f36-11e7-9919-39b7001af203.png">
 
+## FAQ
+
+### Creating custom Resolvers
+
+If you need create something special, you may create a custom Resolver. For example, if you need to add a new tag for existing record, do it in the following manner ([see full test-case](https://github.com/graphql-compose/graphql-compose-elasticsearch/blob/master/src/__tests__/github_issues/37-test.js)):
+
+```js
+ActivitiesEsTC.addResolver({
+  name: 'addTag',
+  kind: 'mutation',
+  type: 'JSON',
+  args: {
+    id: 'String!',
+    tag: 'String!',
+  },
+  resolve: ({ args }) => {
+    return elasticClient.update({
+      index: elasticIndex,
+      type: elasticType,
+      id: args.id,
+      body: {
+        script: {
+          inline: 'ctx._source.tags.add(params.tag)',
+          params: { tag: args.tag },
+        },
+      },
+    });
+  },
+});
+```
 
 ## License
-[MIT](https://github.com/nodkz/graphql-compose-elasticsearch/blob/master/LICENSE.md)
+[MIT](https://github.com/graphql-compose/graphql-compose-elasticsearch/blob/master/LICENSE.md)

scripts/docker/es2/Dockerfile

@@ -1,3 +1,4 @@
-from elasticsearch:2-alpine
+FROM elasticsearch:2-alpine
 
-copy elasticsearch.yml /usr/share/elasticsearch/config/elasticsearch.yml
+COPY elasticsearch.yml /usr/share/elasticsearch/config/elasticsearch.yml
+ENV ES_JAVA_OPTS="-Xms750m -Xmx750m"

scripts/docker/es5/Dockerfile

@@ -1,3 +1,4 @@
-from elasticsearch:5-alpine
+FROM docker.elastic.co/elasticsearch/elasticsearch:5.2.1
 
-copy elasticsearch.yml /usr/share/elasticsearch/config/elasticsearch.yml
+COPY elasticsearch.yml /usr/share/elasticsearch/config/elasticsearch.yml
+ENV ES_JAVA_OPTS="-Xms750m -Xmx750m"

scripts/docker/es5/elasticsearch.yml

@@ -3,3 +3,4 @@ network.host: 0.0.0.0
 http.cors.enabled: true
 http.cors.allow-origin: "*"
 cluster.name: elasticsearch_nodkz
+xpack.security.enabled: false

src/__tests__/github_issues/32-test.js

@@ -33,7 +33,7 @@ const ActivitiesEsTC = composeWithElastic({
   }),
 });
 
-describe('github issue #72 - hits returns me the found id, score, type...', () => {
+describe('github issue #32 - hits returns me the found id, score, type...', () => {
   it('test `search` resolver', () => {
     expect(ActivitiesEsTC).toBeInstanceOf(TypeComposer);
 

src/__tests__/github_issues/37-test.js

@@ -0,0 +1,134 @@
+/* @flow */
+
+import elasticsearch from 'elasticsearch';
+import { TypeComposer, schemaComposer } from 'graphql-compose';
+import { graphql } from 'graphql';
+import { composeWithElastic } from '../..';
+
+const ELASTICSEARCH_HOST = '';
+const ELASTICSEARCH_API_VERSION = '5.2';
+const mapping = {
+  properties: {
+    id: {
+      type: 'keyword',
+    },
+    title: {
+      type: 'text',
+    },
+    tags: {
+      type: 'text',
+    },
+  },
+};
+
+const elasticClient = new elasticsearch.Client({
+  host: ELASTICSEARCH_HOST,
+  apiVersion: ELASTICSEARCH_API_VERSION,
+  log: 'info', // FOR DETAILED DEBUG USE - 'trace'
+});
+const elasticIndex = 'github37';
+const elasticType = 'activities';
+
+const ActivitiesEsTC = composeWithElastic({
+  graphqlTypeName: 'SearchActivities',
+  elasticMapping: mapping,
+  pluralFields: ['tags'],
+  elasticIndex,
+  elasticType,
+  elasticClient,
+});
+
+beforeAll(async () => {
+  const indexExists = await elasticClient.indices.exists({ index: elasticIndex });
+  if (indexExists) {
+    await elasticClient.indices.delete({ index: elasticIndex });
+  }
+
+  // create demo record directly in elastic
+  await elasticClient.create({
+    index: elasticIndex,
+    type: elasticType,
+    id: '333',
+    body: {
+      title: 'Test 1',
+      tags: ['y', 'z'],
+    },
+  });
+});
+
+describe('github issue #37 - Mutations via updateById overwrite arrays instead of appending to them', () => {
+  it('create custom resolver', async () => {
+    expect(ActivitiesEsTC).toBeInstanceOf(TypeComposer);
+
+    ActivitiesEsTC.addResolver({
+      name: 'addTag',
+      kind: 'mutation',
+      type: 'JSON',
+      args: {
+        id: 'String!',
+        tag: 'String!',
+      },
+      resolve: ({ args }) => {
+        return elasticClient.update({
+          index: elasticIndex,
+          type: elasticType,
+          id: args.id,
+          body: {
+            script: {
+              inline: 'ctx._source.tags.add(params.tag)',
+              params: { tag: args.tag },
+            },
+          },
+        });
+      },
+    });
+
+    // create simple Schema for EE test
+    schemaComposer.Query.addFields({ noop: 'String' }); // by spec query MUST be always present
+    schemaComposer.Mutation.addFields({
+      activitiesAddTag: ActivitiesEsTC.getResolver('addTag'),
+    });
+    const schema = schemaComposer.buildSchema();
+
+    // update record via graphql
+    const graphqlResponse = await graphql({
+      schema,
+      source: `
+        mutation {
+          activitiesAddTag(id: "333", tag: "x")
+        }
+      `,
+    });
+
+    // check graphql response
+    expect(graphqlResponse).toEqual({
+      data: {
+        activitiesAddTag: {
+          _id: '333',
+          _index: 'github37',
+          _shards: { failed: 0, successful: 1, total: 2 },
+          _type: 'activities',
+          _version: 2,
+          result: 'updated',
+        },
+      },
+    });
+
+    // check demo record directly in elastic
+    const elasticData = await elasticClient.get({
+      index: elasticIndex,
+      type: elasticType,
+      id: '333',
+      _source: true,
+    });
+
+    expect(elasticData).toEqual({
+      _id: '333',
+      _index: 'github37',
+      _source: { tags: ['y', 'z', 'x'], title: 'Test 1' },
+      _type: 'activities',
+      _version: 2,
+      found: true,
+    });
+  });
+});