test reject-attestation (#1348)

src/backend/endpoints/paths.ts

@@ -33,6 +33,7 @@ export const paths = {
   verifier: {
     requestCredential: '/api/request-credential',
     verify: '/api/verify',
+    rejectAttestation: '/api/reject-attestation',
   },
 
   staticFiles: '/{param*}',

src/backend/server.ts

@@ -32,6 +32,7 @@ import { confirmTelegram } from './telegram/confirmTelegram';
 
 import { requestCredential } from './verifier/requestCredential';
 import { verify } from './verifier/verify';
+import { rejectAttestation } from './verifier/rejectAttestation';
 
 import { session } from './endpoints/session';
 import { authHtml } from './endpoints/authHtml';
@@ -149,6 +150,7 @@ const logger = {
 
   server.route(requestCredential);
   server.route(verify);
+  server.route(rejectAttestation);
 
   server.route(home);
 

src/backend/verifier/rejectAttestation.ts

@@ -0,0 +1,58 @@
+import type {
+  Request,
+  ResponseObject,
+  ResponseToolkit,
+  ServerRoute,
+} from '@hapi/hapi';
+import type { IEncryptedMessage } from '@kiltprotocol/sdk-js';
+import type { HexString } from '@polkadot/util/types';
+
+import { z } from 'zod';
+
+import { encryptMessageBody } from '../utilities/encryptMessage';
+import { paths } from '../endpoints/paths';
+import { getSession } from '../utilities/sessionStorage';
+
+const zodPayload = z.object({
+  rootHash: z
+    .string()
+    .trim()
+    .refine((input: string): input is HexString => input.startsWith('0x')),
+});
+
+export type Input = z.infer<typeof zodPayload>;
+
+export type Output = IEncryptedMessage;
+
+async function handler(
+  request: Request<{ Payload: Input }>,
+  h: ResponseToolkit,
+): Promise<ResponseObject> {
+  const { logger } = request;
+  logger.debug('Reject attestation started');
+
+  const { rootHash } = request.payload;
+  const session = getSession(request.headers);
+  const { encryptionKeyUri } = session;
+
+  logger.debug('Reject attestation rootHash found');
+
+  const output = await encryptMessageBody(encryptionKeyUri, {
+    content: rootHash,
+    type: 'reject-attestation',
+  });
+
+  logger.debug('Reject attestation completed');
+  return h.response(output as Output);
+}
+
+export const rejectAttestation = {
+  method: 'POST',
+  path: paths.verifier.rejectAttestation,
+  handler,
+  options: {
+    validate: {
+      payload: async (payload) => zodPayload.parse(payload),
+    },
+  },
+} as ServerRoute;

src/backend/verifier/rejectAttestationApi.ts

@@ -0,0 +1,14 @@
+import ky from 'ky';
+
+import { paths } from '../endpoints/paths';
+import { sessionHeader } from '../endpoints/sessionHeader';
+
+import { Input, Output } from './rejectAttestation';
+
+export async function rejectAttestation(
+  json: Input,
+  sessionId: string,
+): Promise<Output> {
+  const headers = { [sessionHeader]: sessionId };
+  return ky.post(paths.verifier.rejectAttestation, { json, headers }).json();
+}

src/frontend/verifier.html

@@ -75,6 +75,12 @@ <h1>Verifier Test Page</h1>
         </details>
       </section>
     </form>
+
+    <form id="rejectForm">
+      <label>rootHash: <input name="rootHash" size="60"></label>
+      <button>Reject attestation</button>
+    </form>
+
     <footer class="footer">
       <div class="content">
 

src/frontend/verifier.ts

@@ -1,13 +1,16 @@
+import type { HexString } from '@polkadot/util/types';
 import type { SupportedCType } from '../backend/utilities/supportedCType';
 
 import { requestCredential } from '../backend/verifier/requestCredentialApi';
 import { verifyCredential } from '../backend/verifier/verifyApi';
+import { rejectAttestation } from '../backend/verifier/rejectAttestationApi';
 
 import { apiWindow, getSession } from './utilities/session';
 
 const credentialForm = document.getElementById(
   'credentialForm',
 ) as HTMLFormElement;
+const rejectForm = document.getElementById('rejectForm') as HTMLFormElement;
 const shared = document.getElementById('shared') as HTMLElement;
 
 const claimerDid = document.getElementById('claimer-did') as HTMLOutputElement;
@@ -40,7 +43,7 @@ function handleBeforeUnload(event: Event) {
   event.returnValue = false;
 }
 
-async function handleSubmit(event: Event) {
+async function handleRequestSubmit(event: Event) {
   event.preventDefault();
 
   window.addEventListener('beforeunload', handleBeforeUnload);
@@ -114,4 +117,18 @@ async function handleSubmit(event: Event) {
   }
 }
 
-credentialForm.addEventListener('submit', handleSubmit);
+async function handleRejectSubmit(event: SubmitEvent) {
+  event.preventDefault();
+
+  const form = event.currentTarget as HTMLFormElement;
+  const rootHash = new FormData(form).get('rootHash') as HexString;
+
+  const session = await getSession(apiWindow.kilt.sporran, 'sporran');
+  const { sessionId } = session;
+
+  const message = await rejectAttestation({ rootHash }, sessionId);
+  await session.send(message);
+}
+
+credentialForm.addEventListener('submit', handleRequestSubmit);
+rejectForm.addEventListener('submit', handleRejectSubmit);