Add operations and tests for Thng commissioning and state (#25)

evrythng · Sep 6, 2019 · 233b151 · 233b151
1 parent a1d697e
commit 233b151
Show file tree

Hide file tree

Showing 2 changed files with 53 additions and 0 deletions.
diff --git a/src/commands/thng.js b/src/commands/thng.js
@@ -107,6 +107,29 @@ module.exports = {
       pattern: '$id actions $id read',
     },
 
+    // Thng commissions
+    createThngCommissionsAction: {
+      execute: async ([identifier, , , , json]) => {
+        const payload = JSON.parse(json);
+        return http.post(`/thngs/${identifier}/actions/commissions`, payload);
+      },
+      pattern: '$identifier actions commissions create $payload',
+      helpPattern: '$identifier|$id actions commissions create $payload',
+    },
+    readThngCommissionState: {
+      execute: async ([identifier]) => http.get(`/thngs/${identifier}/commissionState`),
+      pattern: '$identifier commission-state read',
+      helpPattern: '$identifier|$id commission-state read',
+    },
+    createThngDecommissionsAction: {
+      execute: async ([identifier, , , , json]) => {
+        const payload = JSON.parse(json);
+        return http.post(`/thngs/${identifier}/actions/decommissions`, payload);
+      },
+      pattern: '$identifier actions decommissions create $payload',
+      helpPattern: '$identifier|$id actions decommissions create $payload',
+    },
+
     // Thng redirection
     createThngRedirection: {
       execute: async ([id, , shortDomain, , json]) => {

diff --git a/tests/commands/thng.js b/tests/commands/thng.js
@@ -124,6 +124,36 @@ describe('thngs', () => {
     await cli(`thngs ${ID} actions ${ID} read`);
   });
 
+  // Thng commissions actions
+  it('should make correct request for \'thngs $identifier actions commissions create $payload\'', async () => {
+    const identifier = 'gs1:01:43876';
+    const payload = JSON.stringify({});
+    mockApi()
+      .post(`/thngs/${identifier}/actions/commissions`, payload)
+      .reply(201);
+
+    await cli(`thngs ${identifier} actions commissions create ${payload}`);
+  });
+
+  it('should make correct request for \'thngs $identifier actions decommissions create $payload\'', async () => {
+    const identifier = 'gs1:01:43876';
+    const payload = JSON.stringify({});
+    mockApi()
+      .post(`/thngs/${identifier}/actions/decommissions`, payload)
+      .reply(201);
+
+    await cli(`thngs ${identifier} actions decommissions create ${payload}`);
+  });
+
+  it('should make correct request for \'thngs $identifier commission-state read\'', async () => {
+    const identifier = 'gs1:01:43876';
+    mockApi()
+      .get(`/thngs/${identifier}/commissionState?perPage=30`)
+      .reply(200);
+
+    await cli(`thngs ${identifier} commission-state read`);
+  });
+
   // Thng redirection
   it('should make correct request for \'thngs $id redirections $shortDomain create $payload\'',
     async () => {