···44 type SourceFile,
55 VariableDeclarationKind,
66} from "ts-morph";
77-import { type LexiconDoc, Lexicons, type LexRecord } from "@atproto/lexicon";
77+import { type LexiconDoc, Lexicons, type LexRecord } from "@atp/lexicon";
88import { NSID } from "@atp/syntax";
99import type { GeneratedAPI } from "../types.ts";
1010import { gen, lexiconsTs, utilTs } from "./common.ts";
+4-4
lex-cli/codegen/common.ts
···33 type SourceFile,
44 VariableDeclarationKind,
55} from "ts-morph";
66-import type { LexiconDoc } from "@atproto/lexicon";
66+import type { LexiconDoc } from "@atp/lexicon";
77import type { GeneratedFile } from "../types.ts";
88import type { CodeGenOptions } from "./util.ts";
99import { format, type Options as PrettierOptions } from "prettier";
···2121) =>
2222 gen(project, "/util.ts", (file) => {
2323 file.replaceWithText(`
2424-import { type ValidationResult } from '@atproto/lexicon'
2424+import { type ValidationResult } from '@atp/lexicon'
25252626export type OmitKey<T, K extends keyof T> = {
2727 [K2 in keyof T as K2 extends K ? never : K2]: T[K2]
···152152 .join("");
153153 };
154154155155- //= import { type LexiconDoc, Lexicons } from '@atproto/lexicon'
155155+ //= import { type LexiconDoc, Lexicons } from '@atp/lexicon'
156156 file
157157 .addImportDeclaration({
158158- moduleSpecifier: "@atproto/lexicon",
158158+ moduleSpecifier: "@atp/lexicon",
159159 })
160160 .addNamedImports([
161161 { name: "LexiconDoc", isTypeOnly: true },
+4-5
lex-cli/codegen/lex-gen.ts
···1010 LexObject,
1111 LexPrimitive,
1212 LexToken,
1313-} from "@atproto/lexicon";
1313+} from "@atp/lexicon";
1414import {
1515 type CodeGenOptions,
1616 toCamelCase,
1717 toScreamingSnakeCase,
1818 toTitleCase,
1919} from "./util.ts";
2020-import type { LexiconDoc } from "@atproto/lexicon";
2121-import type { LexUserType } from "@atproto/lexicon";
2020+import type { LexiconDoc, LexUserType } from "@atp/lexicon";
22212322interface Commentable {
2423 addJsDoc: ({ description }: { description: string }) => JSDoc;
···191190 def.type === "object"
192191 );
193192194194- //= import {BlobRef} from '@atproto/lexicon'
193193+ //= import {BlobRef} from '@atp/lexicon'
195194 if (needsBlobRef) {
196195 file
197196 .addImportDeclaration({
198198- moduleSpecifier: "@atproto/lexicon",
197197+ moduleSpecifier: "@atp/lexicon",
199198 })
200199 .addNamedImports([{ name: "BlobRef" }]);
201200 }
+1-1
lex-cli/codegen/server.ts
···44 type SourceFile,
55 VariableDeclarationKind,
66} from "ts-morph";
77-import { type LexiconDoc, Lexicons } from "@atproto/lexicon";
77+import { type LexiconDoc, Lexicons } from "@atp/lexicon";
88import { NSID } from "@atp/syntax";
99import type { GeneratedAPI } from "../types.ts";
1010import { gen, lexiconsTs, utilTs } from "./common.ts";
+1-1
lex-cli/codegen/util.ts
···11-import type { LexiconDoc, LexUserType } from "@atproto/lexicon";
11+import type { LexiconDoc, LexUserType } from "@atp/lexicon";
22import { NSID } from "@atp/syntax";
3344export interface CodeGenOptions {
···11import { readFileSync } from "@std/fs/unstable-read-file";
22import { writeFileSync } from "@std/fs/unstable-write-file";
33-import type { LexiconDoc } from "@atproto/lexicon";
33+import type { LexiconDoc } from "@atp/lexicon";
4455const INSERT_START = [
66 "<!-- START lex generated content. Please keep comment here to allow auto update -->",
+1-1
lex-cli/util.ts
···88import { readDirSync } from "@std/fs/unstable-read-dir";
99import { colors } from "@cliffy/ansi/colors";
1010import { ZodError } from "zod";
1111-import { type LexiconDoc, parseLexiconDoc } from "@atproto/lexicon";
1111+import { type LexiconDoc, parseLexiconDoc } from "@atp/lexicon";
1212import type { FileDiff, GeneratedAPI } from "./types.ts";
13131414type RecursiveZodError = {
···11import { Hono } from "hono";
22-import { Lexicons } from "@atproto/lexicon";
22+import { type LexiconDoc, Lexicons } from "@atp/lexicon";
33import type { Context, Next } from "hono";
44-import type { LexiconDoc } from "@atproto/lexicon";
5465export function createServer(lexicons?: LexiconDoc[]) {
76 const routes = new Hono();
+1-1
xrpc-server/mod.ts
···2222 * @example Basic server setup with a simple endpoint
2323 * ```ts
2424 * import { createServer } from "jsr:@atp/xrpc-server";
2525- * import type { LexiconDoc } from "@atproto/lexicon";
2525+ * import type { LexiconDoc } from "@atp/lexicon";
2626 *
2727 * const lexicons: LexiconDoc[] = [{
2828 * lexicon: 1,
+1-1
xrpc-server/server.ts
···66 type LexXrpcProcedure,
77 type LexXrpcQuery,
88 type LexXrpcSubscription,
99-} from "@atproto/lexicon";
99+} from "@atp/lexicon";
1010import {
1111 excludeErrorResult,
1212 InternalServerError,
+6-6
xrpc-server/stream/types.ts
···3333 t?: string;
3434};
35353636-export const messageFrameHeader = z.object({
3636+export const messageFrameHeader = z.strictObject({
3737 op: z.literal(FrameType.Message), // Frame op
3838 t: z.string().optional(), // Message body type discriminator
3939-}).strict() as z.ZodType<MessageFrameHeader>;
3939+}) as z.ZodType<MessageFrameHeader>;
40404141/**
4242 * Header for error frames.
···4747 op: FrameType.Error;
4848};
49495050-export const errorFrameHeader = z.object({
5050+export const errorFrameHeader = z.strictObject({
5151 op: z.literal(FrameType.Error),
5252-}).strict() as z.ZodType<ErrorFrameHeader>;
5252+}) as z.ZodType<ErrorFrameHeader>;
53535454/**
5555 * Base type for error frame bodies.
···7474 message?: string;
7575};
76767777-export const errorFrameBody = z.object({
7777+export const errorFrameBody = z.strictObject({
7878 error: z.string(), // Error code
7979 message: z.string().optional(), // Error message
8080-}).strict() as z.ZodType<ErrorFrameBodyBase>;
8080+}) as z.ZodType<ErrorFrameBodyBase>;
81818282/**
8383 * Union type for all frame headers.
+1-1
xrpc-server/tests/auth_test.ts
···11import { MINUTE } from "@atp/common";
22import { Secp256k1Keypair } from "@atproto/crypto";
33-import type { LexiconDoc } from "@atproto/lexicon";
33+import type { LexiconDoc } from "@atp/lexicon";
44import { XrpcClient, XRPCError } from "@atp/xrpc";
55import * as xrpcServer from "../mod.ts";
66
+1-1
xrpc-server/tests/bodies_test.ts
···11import { cidForCbor } from "@atp/common";
22import { randomBytes } from "@atproto/crypto";
33-import type { LexiconDoc } from "@atproto/lexicon";
33+import type { LexiconDoc } from "@atp/lexicon";
44import { ResponseType, XrpcClient, XRPCError } from "@atp/xrpc";
55import * as xrpcServer from "../mod.ts";
66import { logger } from "../logger.ts";
+1-1
xrpc-server/tests/errors_test.ts
···11-import type { LexiconDoc } from "@atproto/lexicon";
11+import type { LexiconDoc } from "@atp/lexicon";
22import { XrpcClient, XRPCError, XRPCInvalidResponseError } from "@atp/xrpc";
33import * as xrpcServer from "../mod.ts";
44import { closeServer, createServer } from "./_util.ts";
+1-1
xrpc-server/tests/ipld_test.ts
···11import { CID } from "multiformats/cid";
22-import type { LexiconDoc } from "@atproto/lexicon";
22+import type { LexiconDoc } from "@atp/lexicon";
33import { XrpcClient } from "@atp/xrpc";
44import * as xrpcServer from "../mod.ts";
55import { closeServer, createServer } from "./_util.ts";
+1-1
xrpc-server/tests/parameters_test.ts
···11-import type { LexiconDoc } from "@atproto/lexicon";
11+import type { LexiconDoc } from "@atp/lexicon";
22import { XrpcClient } from "@atp/xrpc";
33import * as xrpcServer from "../mod.ts";
44import { closeServer, createServer } from "./_util.ts";
+1-1
xrpc-server/tests/procedures_test.ts
···11-import type { LexiconDoc } from "@atproto/lexicon";
11+import type { LexiconDoc } from "@atp/lexicon";
22import { XrpcClient } from "@atp/xrpc";
33import * as xrpcServer from "../mod.ts";
44import { closeServer, createServer } from "./_util.ts";
+1-1
xrpc-server/tests/queries_test.ts
···11-import type { LexiconDoc } from "@atproto/lexicon";
11+import type { LexiconDoc } from "@atp/lexicon";
22import { XrpcClient } from "@atp/xrpc";
33import * as xrpcServer from "../mod.ts";
44import { closeServer, createServer } from "./_util.ts";
+1-1
xrpc-server/tests/rate-limiter_test.ts
···11import { MINUTE } from "@atp/common";
22-import type { LexiconDoc } from "@atproto/lexicon";
22+import type { LexiconDoc } from "@atp/lexicon";
33import { XrpcClient } from "@atp/xrpc";
44import * as xrpcServer from "../mod.ts";
55import { closeServer, createServer } from "./_util.ts";
+1-1
xrpc-server/tests/responses_test.ts
···11import { byteIterableToStream } from "@atp/common";
22-import type { LexiconDoc } from "@atproto/lexicon";
22+import type { LexiconDoc } from "@atp/lexicon";
33import { XrpcClient } from "@atp/xrpc";
44import * as xrpcServer from "../mod.ts";
55import { closeServer, createServer } from "./_util.ts";
+1-1
xrpc-server/tests/subscriptions_test.ts
···11import { WebSocket, type WebSocketServer } from "ws";
22import { wait } from "@atp/common";
33-import type { LexiconDoc } from "@atproto/lexicon";
33+import type { LexiconDoc } from "@atp/lexicon";
44import {
55 byFrame,
66 ErrorFrame,
+8-8
xrpc-server/util.ts
···11-import type {
22- Lexicons,
33- LexXrpcProcedure,
44- LexXrpcQuery,
55- LexXrpcSubscription,
66-} from "@atproto/lexicon";
77-import { jsonToLex } from "@atproto/lexicon";
11+import {
22+ jsonToLex,
33+ type Lexicons,
44+ type LexXrpcBody,
55+ type LexXrpcProcedure,
66+ type LexXrpcQuery,
77+ type LexXrpcSubscription,
88+} from "@atp/lexicon";
89import {
910 InternalServerError,
1011 InvalidRequestError,
···2021 RouteOptions,
2122} from "./types.ts";
2223import type { Context, HonoRequest } from "hono";
2323-import type { LexXrpcBody } from "@atproto/lexicon";
2424import { createDecoders, MaxSizeChecker } from "@atp/common";
25252626function assert(condition: unknown, message?: string): asserts condition {
+1-1
xrpc/client.ts
···11-import { type LexiconDoc, Lexicons, ValidationError } from "@atproto/lexicon";
11+import { type LexiconDoc, Lexicons, ValidationError } from "@atp/lexicon";
22import {
33 buildFetchHandler,
44 type FetchHandler,
···11import { z } from "zod";
22-import type { ValidationError } from "@atproto/lexicon";
22+import type { ValidationError } from "@atp/lexicon";
3344export type QueryParams = Record<string, unknown>;
55export type HeadersMap = Record<string, string | undefined>;
+1-1
xrpc/util.ts
···33 type LexXrpcProcedure,
44 type LexXrpcQuery,
55 stringifyLex,
66-} from "@atproto/lexicon";
66+} from "@atp/lexicon";
77import {
88 type CallOptions,
99 type ErrorResponseBody,