feat: Support capabilities in metadata api (#347)

* Support capabilities in metadata api

Signed-off-by: Deepanshu Agarwal <[email protected]>

* Add E2E test http/grpc

Signed-off-by: Deepanshu Agarwal <[email protected]>

* Correction

Signed-off-by: Deepanshu Agarwal <[email protected]>

* Fix error

Signed-off-by: Deepanshu Agarwal <[email protected]>

* Name correction

Signed-off-by: Deepanshu Agarwal <[email protected]>

* Comment out grpc E2E test

Signed-off-by: Deepanshu Agarwal <[email protected]>

* Fix issue

Signed-off-by: Deepanshu Agarwal <[email protected]>

Signed-off-by: Deepanshu Agarwal <[email protected]>

Author: DeepanshuA

src/implementation/Client/GRPCClient/metadata.ts

@@ -49,7 +49,8 @@ export default class GRPCClientMetadata implements IClientMetadata {
           components: res.getRegisteredComponentsList().map(c => ({
             name: c.getName(),
             type: c.getType(),
-            version: c.getVersion()
+            version: c.getVersion(),
+            capabilities: c.getCapabilitiesList()
           }))
         }
 

src/types/metadata/GetMetadataResponse.ts

@@ -29,4 +29,5 @@ type MetadataComponent = {
   name: string;
   type: string;
   version: string;
+  capabilities: Array<string>;
 }

test/e2e/grpc/client.test.ts

@@ -120,14 +120,26 @@ describe('grpc/client', () => {
       // expect(res.components.length).toBeGreaterThan(0);
     });
 
+    // Commenting out as it would need next version of Dapr to be used in E2E test.
+    // It would specifically require changes from https://github.com/dapr/dapr/pull/5052
+    // it('should be able to get the capabilities of components via metadata call', async () => {
+    //   const res = await client.metadata.get();
+    //   const redisStateComponent = res.components.filter( (component) => component.name == "state-redis" );
+    //   const expectedRedisStateCapabilities = [ 'ETAG', 'TRANSACTIONAL', 'QUERY_API', 'ACTOR' ];
+    //   expect(res.id.length).toBeGreaterThan(0);
+    //   expect(res.components.length).toBeGreaterThan(0);
+    //   expect(redisStateComponent.length).toEqual(1)
+    //   expect(redisStateComponent[0].capabilities).toEqual(expect.arrayContaining(expectedRedisStateCapabilities));
+    // });
+
+
     it('should be able to set a custom metadata value of the Dapr sidecar', async () => {
       await client.metadata.set("testKey", "Hello World");
 
       const res = await client.metadata.get();
 
       // app id is not set in grpc?
       // expect(res.id.length).toBeGreaterThan(0);
-      // expect(res.id.length).toBeGreaterThan(0);
       // expect(res.components.length).toBeGreaterThan(0);
       expect(res.extended["testKey"]).toEqual("Hello World");
     });

test/e2e/http/client.test.ts

@@ -52,6 +52,17 @@ describe('http/client', () => {
       expect(res.components.length).toBeGreaterThan(0);
     });
 
+    it('should be able to get the capabilities of components via metadata call', async () => {
+      const res = await client.metadata.get();
+      const redisStateComponent = res.components.filter( (component) => component.name == "state-redis" );
+      const expectedRedisStateCapabilities = [ 'ETAG', 'TRANSACTIONAL', 'QUERY_API', 'ACTOR' ];
+      expect(res.id.length).toBeGreaterThan(0);
+      expect(res.components.length).toBeGreaterThan(0);
+      expect(redisStateComponent.length).toEqual(1)
+      expect(redisStateComponent[0].capabilities).toEqual(expect.arrayContaining(expectedRedisStateCapabilities))
+    });
+
+
     it('should be able to set a custom metadata value of the Dapr sidecar', async () => {
       await client.metadata.set("testKey", "Hello World");