commit fb6301d7567b3496f946ea815fb4dd89b48515a6 · gmstn.systems/lattice

+14

src/lib/types/lexicon/com.atproto.repo.getRecord.ts

···

       1
       +
       import { z } from "zod";

     

       2
       +
       

     

       3
       +
       export const comAtprotoRepoGetRecordResponseSchema = z.object({

     

       4
       +
           uri: z.string(),

     

       5
       +
           cid: z.optional(z.string()),

     

       6
       +
           value: z

     

       7
       +
               .object({

     

       8
       +
                   $type: z.string(),

     

       9
       +
               })

     

       10
       +
               .catchall(z.unknown()),

     

       11
       +
       });

     

       12
       +
       export type ComAtprotoRepoGetRecordResponse = z.infer<

     

       13
       +
           typeof comAtprotoRepoGetRecordResponseSchema

     

       14
       +
       >;

+57

src/lib/utils/atproto.ts

···

       5
        
           DidDocument,

     

       6
        
       } from "@/lib/types/atproto";

     

       7
        
       import { atprotoHandleSchema } from "@/lib/types/atproto";

     

       0
        
       
     

       8
        
       import type { Result } from "@/lib/utils/result";

     

       9
        
       import type { DidDocumentResolver } from "@atcute/identity-resolver";

     

       10
        
       import {

     
···

       15
        
           WebDidDocumentResolver,

     

       16
        
           WellKnownHandleResolver,

     

       17
        
       } from "@atcute/identity-resolver";

     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       0
        
       
     

       18
        
       

     

       19
        
       export const didDocResolver: DidDocumentResolver =

     

       20
        
           new CompositeDidDocumentResolver({

···

       5
        
           DidDocument,

     

       6
        
       } from "@/lib/types/atproto";

     

       7
        
       import { atprotoHandleSchema } from "@/lib/types/atproto";

     

       8
       +
       import { comAtprotoRepoGetRecordResponseSchema } from "@/lib/types/lexicon/com.atproto.repo.getRecord";

     

       9
        
       import type { Result } from "@/lib/utils/result";

     

       10
        
       import type { DidDocumentResolver } from "@atcute/identity-resolver";

     

       11
        
       import {

     
···

       16
        
           WebDidDocumentResolver,

     

       17
        
           WellKnownHandleResolver,

     

       18
        
       } from "@atcute/identity-resolver";

     

       19
       +
       

     

       20
       +
       export const getRecordFromAtUri = async ({

     

       21
       +
           authority,

     

       22
       +
           collection,

     

       23
       +
           rKey,

     

       24
       +
       }: Required<AtUri>): Promise<Result<unknown, unknown>> => {

     

       25
       +
           const didDocResult = await resolveDidDoc(authority);

     

       26
       +
           if (!didDocResult.ok) return { ok: false, error: didDocResult.error };

     

       27
       +
       

     

       28
       +
           const { service: services } = didDocResult.data;

     

       29
       +
           if (!services)

     

       30
       +
               return {

     

       31
       +
                   ok: false,

     

       32
       +
                   error: { message: "Resolved DID document has no service field." },

     

       33
       +
               };

     

       34
       +
       

     

       35
       +
           const pdsService = services.find(

     

       36
       +
               (service) =>

     

       37
       +
                   service.id === "#atproto_pds" &&

     

       38
       +
                   service.type === "AtprotoPersonalDataServer",

     

       39
       +
           );

     

       40
       +
       

     

       41
       +
           if (!pdsService)

     

       42
       +
               return {

     

       43
       +
                   ok: false,

     

       44
       +
                   error: {

     

       45
       +
                       message:

     

       46
       +
                           "Resolved DID document has no PDS service listed in the document.",

     

       47
       +
                   },

     

       48
       +
               };

     

       49
       +
       

     

       50
       +
           const pdsEndpointRecord = pdsService.serviceEndpoint;

     

       51
       +
           let pdsEndpointUrl;

     

       52
       +
           try {

     

       53
       +
               // @ts-expect-error yes, we are coercing something that is explicitly not a string into a string, but in this case we want to be specific. only serviceEndpoints with valid atproto pds URLs should be allowed.

     

       54
       +
               pdsEndpointUrl = new URL(pdsEndpointRecord).origin;

     

       55
       +
           } catch (err) {

     

       56
       +
               return { ok: false, error: err };

     

       57
       +
           }

     

       58
       +
           const req = new Request(

     

       59
       +
               `${pdsEndpointUrl}/xrpc/com.atproto.repo.getRecord?repo=${didDocResult.data.id}&collection=${collection}&rkey=${rKey}`,

     

       60
       +
           );

     

       61
       +
       

     

       62
       +
           const res = await fetch(req);

     

       63
       +
           const data: unknown = await res.json();

     

       64
       +
       

     

       65
       +
           const {

     

       66
       +
               success: responseParseSuccess,

     

       67
       +
               error: responseParseError,

     

       68
       +
               data: record,

     

       69
       +
           } = comAtprotoRepoGetRecordResponseSchema.safeParse(data);

     

       70
       +
           if (!responseParseSuccess) {

     

       71
       +
               return { ok: false, error: responseParseError };

     

       72
       +
           }

     

       73
       +
           return { ok: true, data: record.value };

     

       74
       +
       };

     

       75
        
       

     

       76
        
       export const didDocResolver: DidDocumentResolver =

     

       77
        
           new CompositeDidDocumentResolver({