update service

src/appmixer/hubspot/crm/CreateContact/component.json

@@ -120,6 +120,6 @@
     ],
     "version": "1.0.1",
     "dependencies": {
-        "service": "1.0.1"
+        "service": "2.0.1"
     }
 }

src/appmixer/hubspot/crm/CreateDeal/component.json

@@ -5,7 +5,7 @@
     "description": "Create a new deal.",
     "version": "1.0.3",
     "dependencies": {
-        "service": "1.0.1"
+        "service": "2.0.1"
     },
     "private": false,
     "auth": {

src/appmixer/hubspot/crm/CreateLineItem/component.json

@@ -104,6 +104,6 @@
     ],
     "version": "1.0.1",
     "dependencies": {
-        "service": "1.0.1"
+        "service": "2.0.1"
     }
 }

src/appmixer/hubspot/crm/DeleteContact/component.json

@@ -53,6 +53,6 @@
     ],
     "version": "1.0.1",
     "dependencies": {
-        "service": "1.0.1"
+        "service": "2.0.1"
     }
 }

src/appmixer/hubspot/crm/DeleteDeal/component.json

@@ -53,6 +53,6 @@
     ],
     "version": "1.0.1",
     "dependencies": {
-        "service": "1.0.1"
+        "service": "2.0.1"
     }
 }

src/appmixer/hubspot/crm/DeletedContact/component.json

@@ -18,6 +18,6 @@
         }
     ],
     "dependencies": {
-        "service": "1.0.1"
+        "service": "2.0.1"
     }
 }

src/appmixer/hubspot/crm/FindContacts/component.json

@@ -90,6 +90,6 @@
     ],
     "version": "2.0.0",
     "dependencies": {
-        "service": "1.0.1"
+        "service": "2.0.1"
     }
 }

src/appmixer/hubspot/crm/GetContact/component.json

@@ -86,6 +86,6 @@
         }
     ],
     "dependencies": {
-        "service": "1.0.1"
+        "service": "2.0.1"
     }
 }

src/appmixer/hubspot/crm/GetContactsProperties/component.json

@@ -18,6 +18,6 @@
     "outPorts": [ "out" ],
     "version": "1.1.0",
     "dependencies": {
-        "service": "1.0.1"
+        "service": "2.0.1"
     }
 }

src/appmixer/hubspot/crm/GetDeal/component.json

@@ -57,6 +57,6 @@
     ],
     "version": "1.0.1",
     "dependencies": {
-        "service": "1.0.1"
+        "service": "2.0.1"
     }
 }

src/appmixer/hubspot/crm/GetDealsProperties/component.json

@@ -18,6 +18,6 @@
     "outPorts": [ "out" ],
     "version": "1.0.1",
     "dependencies": {
-        "service": "1.0.1"
+        "service": "2.0.1"
     }
 }

src/appmixer/hubspot/crm/ListContacts/component.json

@@ -87,6 +87,6 @@
     ],
     "version": "2.0.0",
     "dependencies": {
-        "service": "1.0.1"
+        "service": "2.0.1"
     }
 }

src/appmixer/hubspot/crm/ListDeals/component.json

@@ -76,6 +76,6 @@
     ],
     "version": "1.0.1",
     "dependencies": {
-        "service": "1.0.1"
+        "service": "2.0.1"
     }
 }

src/appmixer/hubspot/crm/ListOwners/component.json

@@ -22,6 +22,6 @@
     ],
     "version": "1.0.1",
     "dependencies": {
-        "service": "1.0.1"
+        "service": "2.0.1"
     }
 }

src/appmixer/hubspot/crm/ListPipelineStages/component.json

@@ -36,7 +36,7 @@
     "outPorts": ["out"],
     "version": "1.0.0",
     "dependencies": {
-        "service": "1.0.1"
+        "service": "2.0.1"
     }
 }
 

src/appmixer/hubspot/crm/ListPipelines/component.json

@@ -46,7 +46,7 @@
     "outPorts": ["out"],
     "version": "1.0.2",
     "dependencies": {
-        "service": "1.0.1"
+        "service": "2.0.1"
     }
 }
 

src/appmixer/hubspot/crm/ListProducts/component.json

@@ -22,6 +22,6 @@
     ],
     "version": "1.0.1",
     "dependencies": {
-        "service": "1.0.1"
+        "service": "2.0.1"
     }
 }

src/appmixer/hubspot/crm/NewContact/component.json

@@ -20,6 +20,6 @@
         }
     ],
     "dependencies": {
-        "service": "1.0.1"
+        "service": "2.0.1"
     }
 }

src/appmixer/hubspot/crm/NewDeal/component.json

@@ -20,6 +20,6 @@
         }
     ],
     "dependencies": {
-        "service": "1.0.1"
+        "service": "2.0.1"
     }
 }

src/appmixer/hubspot/crm/UpdateContact/component.json

@@ -129,6 +129,6 @@
         }
     ],
     "dependencies": {
-        "service": "1.0.1"
+        "service": "2.0.1"
     }
 }

src/appmixer/hubspot/crm/UpdateDeal/component.json

@@ -124,6 +124,6 @@
         }
     ],
     "dependencies": {
-        "service": "1.0.1"
+        "service": "2.0.1"
     }
 }

src/appmixer/hubspot/crm/UpdatedContact/component.json

@@ -20,6 +20,6 @@
         }
     ],
     "dependencies": {
-        "service": "1.0.1"
+        "service": "2.0.1"
     }
 }

src/appmixer/hubspot/crm/UpdatedDeal/component.json

@@ -20,6 +20,6 @@
         }
     ],
     "dependencies": {
-        "service": "1.0.1"
+        "service": "2.0.1"
     }
 }

src/appmixer/hubspot/engagements/CreateEmail/component.json

@@ -190,6 +190,6 @@
     ],
     "version": "2.2.0",
     "dependencies": {
-        "service": "1.0.1"
+        "service": "2.0.1"
     }
 }

src/appmixer/hubspot/engagements/CreateNote/CreateNote.js

@@ -0,0 +1,48 @@
+'use strict';
+const Hubspot = require('../../Hubspot');
+
+module.exports = {
+
+    /**
+     * This component requires a contact to be associated to the newly created note.
+     * TODO: Future versions should allow for other objects, like deals, companies etc to be associated with the note
+     * NOTE: A note can also be without associations, but it seems useless as it cannot be found easily.
+     */
+    async receive(context) {
+
+        const {
+            body,
+            contactId,
+            hubSpotOwnerId,
+            attachmentIds
+        } = context.messages.in.content;
+
+        const { auth } = context;
+        const hs = new Hubspot(auth.accessToken, context.config);
+
+        const payload = {
+            properties: {
+                hs_timestamp: (new Date()).toISOString(),
+                hs_note_body: body,
+                hubspot_owner_id: hubSpotOwnerId || '', // Optional
+                hs_attachment_ids: attachmentIds || '' // If multiple the ids must be separated by semi-colons
+            },
+            associations: [  //TODO: In the future extend to accept other object types than contacts
+                {
+                    to: {
+                        id: contactId
+                    },
+                    types: [
+                        {
+                            associationCategory: 'HUBSPOT_DEFINED',
+                            associationTypeId: 202
+                        }]
+                }
+            ]
+        };
+
+        const { data } = await hs.call('post', 'crm/v3/objects/notes', payload);
+
+        return context.sendJson(data, 'out');
+    }
+};

src/appmixer/hubspot/engagements/GetEmails/component.json

@@ -51,6 +51,6 @@
     ],
     "version": "2.0.0",
     "dependencies": {
-        "service": "1.0.1"
+        "service": "2.0.1"
     }
 }

src/appmixer/hubspot/files/UploadFile/UploadFile.js

@@ -0,0 +1,64 @@
+'use strict';
+const Hubspot = require('../../Hubspot');
+const FormData = require('form-data');
+
+module.exports = {
+
+    async receive(context) {
+
+        const { fileId, fileName } = context.messages.in.content;
+
+        const { auth } = context;
+        const hs = new Hubspot(auth.accessToken, context.config);
+
+        const filestream = await context.getFileReadStream(fileId);
+
+        const options = {
+            access: 'PUBLIC_NOT_INDEXABLE',
+            overwrite: false,
+            duplicateValidationStrategy: 'NONE',
+            duplicateValidationScope: 'EXACT_FOLDER'
+        };
+
+        let form = new FormData();
+        form.append('file', filestream, fileName);
+        form.append('options', JSON.stringify(options));
+        form.append('fileName', fileName);
+        form.append('folderPath', '/');
+
+        // Had to craft an http call instead of hs.call, due to the form data/headers
+        try {
+            const {data} = await hs.call('POST',
+                'files/v3/files',
+                {
+                    fileName,
+                    options,
+                    filestream,
+                    folderPath: '/',
+                    file: filestream
+                });
+
+            // context.log({ stage: 'rq', form});
+            // const { data } = await context.httpRequest({
+            //     url: 'https://api.hubapi.com/files/v3/files',
+            //     method: 'POST',
+            //     headers: {
+            //         Authorization: 'Bearer ' + auth.accessToken
+            //     },
+            //     data: form
+            // });
+
+            context.log({ stage: 'rs', data });
+            return context.sendJson(data, 'out');
+
+        } catch (e) {
+            if (e.response && e.response.data && e.response.data.message) {
+                const error = new Error(e.response.data.message);
+                error.status = e.response.status;
+                error.data = e.response.data;
+                throw error;
+            }
+            throw e;
+        }
+    }
+};