use upsert for create

eisbilir · eisbilir · commit a0e4254cfd8b · 2023-05-24T10:50:14.000+03:00
diff --git a/src/services/ProcessorService.js b/src/services/ProcessorService.js
@@ -35,12 +35,12 @@ function * create (message) {
     }
   }
 
-  yield client.create({
+  yield client.update({
     index: config.get('esConfig.ES_INDEX'),
     type: config.get('esConfig.ES_TYPE'),
     id: message.payload.id,
-    body: message.payload,
-    refresh: 'wait_for'
+    refresh: 'wait_for',
+    body: { doc: message.payload, doc_as_upsert: true }
   })
 
   // Add review / reviewSummation to submission

Original file line number	Diff line number	Diff line change
`@@ -35,12 +35,12 @@ function * create (message) {`
`35`	`35`	`}`
`36`	`36`	`}`
`37`	`37`
`38`		`- yield client.create({`
	`38`	`+ yield client.update({`
`39`	`39`	`index: config.get('esConfig.ES_INDEX'),`
`40`	`40`	`type: config.get('esConfig.ES_TYPE'),`
`41`	`41`	`id: message.payload.id,`
`42`		`- body: message.payload,`
`43`		`- refresh: 'wait_for'`
	`42`	`+ refresh: 'wait_for',`
	`43`	`+ body: { doc: message.payload, doc_as_upsert: true }`
`44`	`44`	`})`
`45`	`45`
`46`	`46`	`// Add review / reviewSummation to submission`