Implementing identities claim command

Fix naming of `identityId` field of `Provider` proto message
Sigchain `addClaim()` method returns generated claim
"Reset" functionality for Test Provider
Replacing identities rpc exceptions with domain+client exceptions

src/PolykeyAgent.ts

@@ -449,6 +449,7 @@ class PolykeyAgent {
       notificationsManager: this.notificationsManager,
       sessionManager: this.sessionManager,
       vaultManager: this.vaultManager,
+      sigchain: this.sigchain,
       grpcServerClient: this.grpcServerClient,
       grpcServerAgent: this.grpcServerAgent,
       fwdProxy: this.fwdProxy,

src/bin/identities/CommandAllow.ts

@@ -72,7 +72,7 @@ class CommandAllow extends CommandPolykey {
           // Setting By Identity
           const providerMessage = new identitiesPB.Provider();
           providerMessage.setProviderId(gestaltId.providerId);
-          providerMessage.setMessage(gestaltId.identityId);
+          providerMessage.setIdentityId(gestaltId.identityId);
           setActionMessage.setIdentity(providerMessage);
           await binUtils.retryAuthentication(
             (auth) =>

src/bin/identities/CommandAuthenticate.ts

@@ -45,7 +45,7 @@ class CommandAuthenticate extends CommandPolykey {
         });
         const providerMessage = new identitiesPB.Provider();
         providerMessage.setProviderId(providerId);
-        providerMessage.setMessage(identityId);
+        providerMessage.setIdentityId(identityId);
         const successMessage = await binUtils.retryAuthentication(
           async (auth) => {
             const stream = pkClient.grpcClient.identitiesAuthenticate(
@@ -56,7 +56,7 @@ class CommandAuthenticate extends CommandPolykey {
             process.stdout.write(
               binUtils.outputFormatter({
                 type: options.format === 'json' ? 'json' : 'list',
-                data: [`Your device code is: ${codeMessage!.getMessage()}`],
+                data: [`Your device code is: ${codeMessage!.getIdentityId()}`],
               }),
             );
             return (await stream.next()).value;
@@ -67,7 +67,7 @@ class CommandAuthenticate extends CommandPolykey {
           binUtils.outputFormatter({
             type: options.format === 'json' ? 'json' : 'list',
             data: [
-              `Successfully authenticated user: ${successMessage!.getMessage()}`,
+              `Successfully authenticated user: ${successMessage!.getIdentityId()}`,
             ],
           }),
         );

src/bin/identities/CommandClaim.ts

@@ -45,11 +45,24 @@ class CommandClaim extends CommandPolykey {
         });
         const providerMessage = new identitiesPB.Provider();
         providerMessage.setProviderId(providerId);
-        providerMessage.setMessage(identityId);
-        await binUtils.retryAuthentication(
+        providerMessage.setIdentityId(identityId);
+        const response = await binUtils.retryAuthentication(
           (auth) => pkClient.grpcClient.identitiesClaim(providerMessage, auth),
           meta,
         );
+        const output = [
+          `Published identity claim with id: ${response.getClaimId()}
+        on provider: ${providerId}`,
+        ];
+        if (response.getUrl()) {
+          output.push(`See claim at: ${response.getUrl()}`);
+        }
+        process.stdout.write(
+          binUtils.outputFormatter({
+            type: options.format === 'json' ? 'json' : 'list',
+            data: output,
+          }),
+        );
       } finally {
         if (pkClient! != null) await pkClient.stop();
       }

src/bin/identities/CommandDisallow.ts

@@ -72,7 +72,7 @@ class CommandDisallow extends CommandPolykey {
           //  Setting by Identity
           const providerMessage = new identitiesPB.Provider();
           providerMessage.setProviderId(gestaltId.providerId);
-          providerMessage.setMessage(gestaltId.identityId);
+          providerMessage.setIdentityId(gestaltId.identityId);
           setActionMessage.setIdentity(providerMessage);
           // Trusting.
           await binUtils.retryAuthentication(

src/bin/identities/CommandDiscover.ts

@@ -63,7 +63,7 @@ class CommandDiscover extends CommandPolykey {
           //  Discovery by Identity
           const providerMessage = new identitiesPB.Provider();
           providerMessage.setProviderId(gestaltId.providerId);
-          providerMessage.setMessage(gestaltId.identityId);
+          providerMessage.setIdentityId(gestaltId.identityId);
           await binUtils.retryAuthentication(
             (auth) =>
               pkClient.grpcClient.gestaltsDiscoveryByIdentity(

src/bin/identities/CommandGet.ts

@@ -65,7 +65,7 @@ class CommandGet extends CommandPolykey {
           // Getting from identity.
           const providerMessage = new identitiesPB.Provider();
           providerMessage.setProviderId(gestaltId.providerId);
-          providerMessage.setMessage(gestaltId.identityId);
+          providerMessage.setIdentityId(gestaltId.identityId);
           res = await binUtils.retryAuthentication(
             (auth) =>
               pkClient.grpcClient.gestaltsGestaltGetByIdentity(

src/bin/identities/CommandPermissions.ts

@@ -63,7 +63,7 @@ class CommandPermissions extends CommandPolykey {
           // Getting by Identity
           const providerMessage = new identitiesPB.Provider();
           providerMessage.setProviderId(gestaltId.providerId);
-          providerMessage.setMessage(gestaltId.identityId);
+          providerMessage.setIdentityId(gestaltId.identityId);
           const res = await binUtils.retryAuthentication(
             (auth) =>
               pkClient.grpcClient.gestaltsActionsGetByIdentity(

src/bin/identities/CommandSearch.ts

@@ -54,15 +54,21 @@ class CommandSearch extends CommandPolykey {
             pkClient.grpcClient.identitiesInfoGet(providerMessage, auth),
           meta,
         );
+        let output;
+        if (res.getIdentityId()) {
+          output = [
+            parsers.formatIdentityString(
+              res.getProviderId() as ProviderId,
+              res.getIdentityId() as IdentityId,
+            ),
+          ];
+        } else {
+          output = [`No identities found for provider ${providerId}`];
+        }
         process.stdout.write(
           binUtils.outputFormatter({
             type: options.format === 'json' ? 'json' : 'list',
-            data: [
-              parsers.formatIdentityString(
-                res.getProviderId() as ProviderId,
-                res.getMessage() as IdentityId,
-              ),
-            ],
+            data: output,
           }),
         );
       } finally {

src/bin/identities/CommandTrust.ts

@@ -71,7 +71,7 @@ class CommandTrust extends CommandPolykey {
           //  Setting by Identity
           const providerMessage = new identitiesPB.Provider();
           providerMessage.setProviderId(gestaltId.providerId!);
-          providerMessage.setMessage(gestaltId.identityId!);
+          providerMessage.setIdentityId(gestaltId.identityId!);
           setActionMessage.setIdentity(providerMessage);
           await binUtils.retryAuthentication(
             (auth) =>

src/bin/identities/CommandUntrust.ts

@@ -71,7 +71,7 @@ class CommandUntrust extends CommandPolykey {
           //  Setting by Identity
           const providerMessage = new identitiesPB.Provider();
           providerMessage.setProviderId(gestaltId.providerId!);
-          providerMessage.setMessage(gestaltId.identityId!);
+          providerMessage.setIdentityId(gestaltId.identityId!);
           setActionMessage.setIdentity(providerMessage);
           await binUtils.retryAuthentication(
             (auth) =>

src/client/GRPCClientClient.ts

@@ -544,7 +544,7 @@ class GRPCClientClient extends GRPCClient<ClientServiceClient> {
 
   @ready(new clientErrors.ErrorClientClientDestroyed())
   public identitiesClaim(...args) {
-    return grpcUtils.promisifyUnaryCall<utilsPB.EmptyMessage>(
+    return grpcUtils.promisifyUnaryCall<identitiesPB.Claim>(
       this.client,
       this.client.identitiesClaim,
     )(...args);

src/client/clientService.ts

@@ -7,6 +7,7 @@ import type { GestaltGraph } from '../gestalts';
 import type { SessionManager } from '../sessions';
 import type { NotificationsManager } from '../notifications';
 import type { Discovery } from '../discovery';
+import type { Sigchain } from '../sigchain';
 import type { GRPCServer } from '../grpc';
 import type { ForwardProxy, ReverseProxy } from '../network';
 import type { FileSystem } from '../types';
@@ -43,6 +44,7 @@ function createClientService({
   sessionManager,
   notificationsManager,
   discovery,
+  sigchain,
   grpcServerClient,
   grpcServerAgent,
   fwdProxy,
@@ -58,6 +60,7 @@ function createClientService({
   sessionManager: SessionManager;
   notificationsManager: NotificationsManager;
   discovery: Discovery;
+  sigchain: Sigchain;
   grpcServerClient: GRPCServer;
   grpcServerAgent: GRPCServer;
   fwdProxy: ForwardProxy;
@@ -93,7 +96,7 @@ function createClientService({
     }),
     ...createIdentitiesRPC({
       identitiesManager,
-      gestaltGraph,
+      sigchain,
       nodeManager,
       authenticate,
     }),

src/client/errors.ts

@@ -26,11 +26,17 @@ class ErrorClientInvalidNode extends ErrorClient {
   exitCode: number = 70;
 }
 
+class ErrorClientInvalidProvider extends ErrorClient {
+  description = 'Provider Id is invalid or does not exist';
+  exitCode = 70;
+}
+
 export {
   ErrorClient,
   ErrorClientClientDestroyed,
   ErrorClientAuthMissing,
   ErrorClientAuthFormat,
   ErrorClientAuthDenied,
   ErrorClientInvalidNode,
+  ErrorClientInvalidProvider,
 };

src/client/rpcGestalts.ts

@@ -60,7 +60,7 @@ const createGestaltsRPC = ({
 
         const gestalt = await gestaltGraph.getGestaltByIdentity(
           call.request.getProviderId() as ProviderId,
-          call.request.getMessage() as IdentityId,
+          call.request.getIdentityId() as IdentityId,
         );
         if (gestalt != null) {
           response.setGestaltGraph(JSON.stringify(gestalt));
@@ -129,7 +129,7 @@ const createGestaltsRPC = ({
         // Constructing identity info.
         const gen = discovery.discoverGestaltByIdentity(
           info.getProviderId() as ProviderId,
-          info.getMessage() as IdentityId,
+          info.getIdentityId() as IdentityId,
         );
         for await (const _ of gen) {
           // Empty
@@ -180,7 +180,7 @@ const createGestaltsRPC = ({
         call.sendMetadata(metadata);
 
         const providerId = info.getProviderId() as ProviderId;
-        const identityId = info.getMessage() as IdentityId;
+        const identityId = info.getIdentityId() as IdentityId;
         const result = await gestaltGraph.getGestaltActionsByIdentity(
           providerId,
           identityId,
@@ -258,7 +258,7 @@ const createGestaltsRPC = ({
         // Setting the action.
         const action = makeGestaltAction(info.getAction());
         const providerId = info.getIdentity()?.getProviderId() as ProviderId;
-        const identityId = info.getIdentity()?.getMessage() as IdentityId;
+        const identityId = info.getIdentity()?.getIdentityId() as IdentityId;
         await gestaltGraph.setGestaltActionByIdentity(
           providerId,
           identityId,
@@ -329,7 +329,7 @@ const createGestaltsRPC = ({
         // Setting the action.
         const action = makeGestaltAction(info.getAction());
         const providerId = info.getIdentity()?.getProviderId() as ProviderId;
-        const identityId = info.getIdentity()?.getMessage() as IdentityId;
+        const identityId = info.getIdentity()?.getIdentityId() as IdentityId;
         await gestaltGraph.unsetGestaltActionByIdentity(
           providerId,
           identityId,