decentralised sync engine

refactor: rename function, loosen function signature

serenity 2b18a611 022ad99d

Changed files
+14 -8
src
+2 -2
src/index.ts
···
import { connectToShards, performHandshakes } from "@/lib/setup";
import { handshakeTokens, setRegistrationState } from "@/lib/state";
import type { AtUri } from "@/lib/types/atproto";
-
import { getRecordFromAtUri } from "@/lib/utils/atproto";
import { newErrorResponse } from "@/lib/utils/http/responses";
import { connectToPrism } from "@/lib/utils/prism";
import {
···
rKey: latticeUrlOrigin,
};
-
const latticeRecord = await getRecordFromAtUri(latticeAtUri);
if (latticeRecord.ok) {
setRegistrationState(true);
···
import { connectToShards, performHandshakes } from "@/lib/setup";
import { handshakeTokens, setRegistrationState } from "@/lib/state";
import type { AtUri } from "@/lib/types/atproto";
+
import { getRecordFromFullAtUri } from "@/lib/utils/atproto";
import { newErrorResponse } from "@/lib/utils/http/responses";
import { connectToPrism } from "@/lib/utils/prism";
import {
···
rKey: latticeUrlOrigin,
};
+
const latticeRecord = await getRecordFromFullAtUri(latticeAtUri);
if (latticeRecord.ok) {
setRegistrationState(true);
+2 -2
src/lib/setup.ts
···
import { systemsGmstnDevelopmentChannelRecordSchema } from "@/lib/types/lexicon/systems.gmstn.development.channel";
import {
atUriToString,
-
getRecordFromAtUri,
stringToAtUri,
} from "@/lib/utils/atproto";
import { getConstellationBacklink } from "@/lib/utils/constellation";
···
const channelRecordsPromises = channelBacklinks.map(
async ({ did, collection, rkey }) =>
-
await getRecordFromAtUri({
// @ts-expect-error seriously i gotta do something about the template literals not converting properly SIGH
authority: did,
collection,
···
import { systemsGmstnDevelopmentChannelRecordSchema } from "@/lib/types/lexicon/systems.gmstn.development.channel";
import {
atUriToString,
+
getRecordFromFullAtUri,
stringToAtUri,
} from "@/lib/utils/atproto";
import { getConstellationBacklink } from "@/lib/utils/constellation";
···
const channelRecordsPromises = channelBacklinks.map(
async ({ did, collection, rkey }) =>
+
await getRecordFromFullAtUri({
// @ts-expect-error seriously i gotta do something about the template literals not converting properly SIGH
authority: did,
collection,
+8 -2
src/lib/utils/atproto.ts
···
} from "@atcute/identity-resolver";
import { z } from "zod";
-
export const getRecordFromAtUri = async ({
authority,
collection,
rKey,
-
}: Required<AtUri>): Promise<Result<unknown, unknown>> => {
const didDocResult = await resolveDidDoc(authority);
if (!didDocResult.ok) return { ok: false, error: didDocResult.error };
const { service: services } = didDocResult.data;
if (!services)
···
} from "@atcute/identity-resolver";
import { z } from "zod";
+
export const getRecordFromFullAtUri = async ({
authority,
collection,
rKey,
+
}: AtUri): Promise<Result<unknown, unknown>> => {
const didDocResult = await resolveDidDoc(authority);
if (!didDocResult.ok) return { ok: false, error: didDocResult.error };
+
+
if (!collection || !rKey)
+
return {
+
ok: false,
+
error: "No rkey or collection found in provided AtUri object",
+
};
const { service: services } = didDocResult.data;
if (!services)
+2 -2
src/lib/utils/constellation.ts
···
ConstellationBacklinkResponse,
} from "@/lib/types/constellation";
import { constellationBacklinkResponseSchema } from "@/lib/types/constellation";
-
import { getRecordFromAtUri } from "@/lib/utils/atproto";
import type { Result } from "@/lib/utils/result";
import type { ZodError } from "zod";
···
backlink: ConstellationBacklink,
): Promise<Result<unknown, unknown>> => {
const atUri = createAtUriFromBacklink(backlink);
-
const atUriRecordResult = await getRecordFromAtUri(atUri);
if (!atUriRecordResult.ok)
return { ok: false, error: atUriRecordResult.error };
return { ok: true, data: atUriRecordResult.data };
···
ConstellationBacklinkResponse,
} from "@/lib/types/constellation";
import { constellationBacklinkResponseSchema } from "@/lib/types/constellation";
+
import { getRecordFromFullAtUri } from "@/lib/utils/atproto";
import type { Result } from "@/lib/utils/result";
import type { ZodError } from "zod";
···
backlink: ConstellationBacklink,
): Promise<Result<unknown, unknown>> => {
const atUri = createAtUriFromBacklink(backlink);
+
const atUriRecordResult = await getRecordFromFullAtUri(atUri);
if (!atUriRecordResult.ok)
return { ok: false, error: atUriRecordResult.error };
return { ok: true, data: atUriRecordResult.data };