Skip to content

Commit 3748456

Browse files
GozalaGozala
committed
chore: format code
1 parent a2ed4bd commit 3748456

File tree

4 files changed

+74
-31
lines changed

4 files changed

+74
-31
lines changed

‎typescript/packages/toolshed/routes/ai/spell/behavior/effects.ts‎

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
import { hc } from "hono/client";
22
import { AppType } from "@/app.ts";
3-
import { Principal, Consumer } from "@commontools/memory";
4-
import { memory, Memory } from "@/routes/storage/memory.ts";
3+
import { Consumer, Principal } from "@commontools/memory";
4+
import { Memory, memory } from "@/routes/storage/memory.ts";
55

66
// Create a spellbook consumer.
77
const spellbook = Consumer.open({
@@ -41,7 +41,9 @@ function handleErrorResponse(data: any) {
4141
}
4242
}
4343

44-
export async function getAllMemories(replica: string): Promise<Record<string, any>> {
44+
export async function getAllMemories(
45+
replica: string,
46+
): Promise<Record<string, any>> {
4547
const result = await spellbook.mount(replica as Memory.DID).query({
4648
select: {
4749
_: {

‎typescript/packages/toolshed/routes/storage/memory/memory.handlers.ts‎

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
import type { AppRouteHandler } from "@/lib/types.ts";
22
import type * as Routes from "./memory.routes.ts";
3-
import { memory, Memory } from "../memory.ts";
3+
import { Memory, memory } from "../memory.ts";
44

55
export const transact: AppRouteHandler<typeof Routes.transact> = async (c) => {
66
try {
@@ -23,7 +23,8 @@ export const transact: AppRouteHandler<typeof Routes.transact> = async (c) => {
2323
}
2424
}
2525
} catch (cause) {
26-
const { message, stack, name } = (cause ?? new Error(cause as any)) as Error;
26+
const { message, stack, name } =
27+
(cause ?? new Error(cause as any)) as Error;
2728
return c.json({ error: { message, name, stack } }, 500);
2829
}
2930
};
@@ -43,7 +44,8 @@ export const query: AppRouteHandler<typeof Routes.query> = async (c) => {
4344
return c.json({ error }, 503);
4445
}
4546
} catch (cause) {
46-
const { message, stack, name } = (cause ?? new Error(cause as any)) as Error;
47+
const { message, stack, name } =
48+
(cause ?? new Error(cause as any)) as Error;
4749
return c.json({ error: { message, name, stack } }, 500);
4850
}
4951
};

‎typescript/packages/toolshed/routes/storage/memory/memory.routes.ts‎

Lines changed: 47 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -8,9 +8,15 @@ export const tags = ["Memory Storage"];
88

99
export const Null = z.literal(null);
1010
export const Unit = z.object({});
11-
export const Meta = z.record(z.string(), z.string()).describe("Arbitrary metadata");
12-
export const The = z.string().describe("Type of the fact usually formatted as media type");
13-
export const Of = z.string().describe("Unique identifier for the mutable entity");
11+
export const Meta = z.record(z.string(), z.string()).describe(
12+
"Arbitrary metadata",
13+
);
14+
export const The = z.string().describe(
15+
"Type of the fact usually formatted as media type",
16+
);
17+
export const Of = z.string().describe(
18+
"Unique identifier for the mutable entity",
19+
);
1420

1521
export const UTCUnixTimestampInSeconds = z.number().int();
1622

@@ -34,10 +40,14 @@ export const Principal = z
3440
.union([z.string(), DID])
3541
.describe("Unique DID identifier of the issuing principal");
3642

37-
export const Cause = z.string().describe("Merkle reference to the previous state of the entity");
43+
export const Cause = z.string().describe(
44+
"Merkle reference to the previous state of the entity",
45+
);
3846
export const Retract = z
3947
.object({
40-
is: z.literal(undefined).optional().describe("Retraction has no 'is' field"),
48+
is: z.literal(undefined).optional().describe(
49+
"Retraction has no 'is' field",
50+
),
4151
})
4252
.describe("Retracts fact");
4353
export const Claim = z.literal(true).describe("Expects fact");
@@ -67,23 +77,29 @@ export const Fact = z.object({
6777
});
6878

6979
export const Delegation = z.never().describe("UCAN delegation");
70-
export const Since = z.number().int().describe("Sequence number of the transaction");
80+
export const Since = z.number().int().describe(
81+
"Sequence number of the transaction",
82+
);
7183
export const Selector = z.record(
7284
Of,
7385
z.record(
7486
The,
7587
z.record(
7688
Cause,
7789
z.object({
78-
is: Unit.optional().describe("If omitted will includes retracted facts"),
90+
is: Unit.optional().describe(
91+
"If omitted will includes retracted facts",
92+
),
7993
}),
8094
),
8195
),
8296
);
8397

8498
const Access = z
8599
.record(
86-
z.string().describe("Merkle reference to the invocation / delegation being authorized"),
100+
z.string().describe(
101+
"Merkle reference to the invocation / delegation being authorized",
102+
),
87103
Unit,
88104
)
89105
.describe("Access that was authorized");
@@ -94,7 +110,9 @@ const Bytes = z
94110
bytes: z.string().describe("Base64 encoded binary"),
95111
}),
96112
})
97-
.transform<Uint8Array>((source) => JSON.decode<Uint8Array>(JSON.encode(source) as Uint8Array))
113+
.transform<Uint8Array>((source) =>
114+
JSON.decode<Uint8Array>(JSON.encode(source) as Uint8Array)
115+
)
98116
.describe("Bytes in DAG-JSON format");
99117

100118
const Signature = Bytes.describe("Signature");
@@ -110,7 +128,10 @@ export const ucan = <T extends z.ZodTypeAny>(invocation: T) =>
110128
authorization: Authorization,
111129
});
112130

113-
const invocation = <Ability extends string, Args extends z.ZodTypeAny>(cmd: Ability, args: Args) =>
131+
const invocation = <Ability extends string, Args extends z.ZodTypeAny>(
132+
cmd: Ability,
133+
args: Args,
134+
) =>
114135
z.object({
115136
cmd: z.literal(cmd),
116137
iss: Principal,
@@ -122,7 +143,10 @@ const invocation = <Ability extends string, Args extends z.ZodTypeAny>(cmd: Abil
122143
prf: Delegation.array().describe("UCAN delegation chain"),
123144
});
124145

125-
export const Transaction = invocation("/memory/transact", z.object({ changes: Changes }));
146+
export const Transaction = invocation(
147+
"/memory/transact",
148+
z.object({ changes: Changes }),
149+
);
126150

127151
export const Query = invocation(
128152
"/memory/query",
@@ -216,8 +240,14 @@ export const transact = createRoute({
216240
},
217241
responses: {
218242
[HttpStatusCodes.OK]: jsonContent(ok(Commit), "Successful transaction"),
219-
[HttpStatusCodes.CONFLICT]: jsonContent(error(ConflictError), "Conflict occurred"),
220-
[HttpStatusCodes.UNAUTHORIZED]: jsonContent(error(AuthorizationError), "Unauthorized"),
243+
[HttpStatusCodes.CONFLICT]: jsonContent(
244+
error(ConflictError),
245+
"Conflict occurred",
246+
),
247+
[HttpStatusCodes.UNAUTHORIZED]: jsonContent(
248+
error(AuthorizationError),
249+
"Unauthorized",
250+
),
221251
[HttpStatusCodes.SERVICE_UNAVAILABLE]: jsonContent(
222252
error(ConnectionError.or(TransactionError)),
223253
"Memory service is unable to process transaction",
@@ -269,7 +299,10 @@ export const query = createRoute({
269299
error(QueryError.or(ConnectionError)),
270300
"Memory service unable to process query",
271301
),
272-
[HttpStatusCodes.UNAUTHORIZED]: jsonContent(error(AuthorizationError), "Unauthorized"),
302+
[HttpStatusCodes.UNAUTHORIZED]: jsonContent(
303+
error(AuthorizationError),
304+
"Unauthorized",
305+
),
273306
[HttpStatusCodes.INTERNAL_SERVER_ERROR]: jsonContent(
274307
error(SystemError),
275308
"Memory service error",

‎typescript/packages/toolshed/routes/storage/memory/memory.test.ts‎

Lines changed: 17 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -7,8 +7,8 @@ import {
77
CommitBuilder,
88
Consumer,
99
Fact,
10-
TransactionBuilder,
1110
Principal,
11+
TransactionBuilder,
1212
} from "@commontools/memory";
1313
import * as FS from "@std/fs";
1414

@@ -19,21 +19,25 @@ if (env.ENV !== "test") {
1919
const the = "application/json";
2020
const doc = `of:${refer({ hello: "world" })}` as const;
2121

22-
export const alice =
23-
Principal.ED25519Signer.fromString<"did:key:z6Mkk89bC3JrVqKie71YEcc5M1SMVxuCgNx6zLZ8SYJsxALi">(
24-
"MgCZT5vOnYZoVAeyjnzuJIVY9J4LNtJ+f8Js0cTPuKUpFne0BVEDJjEu6quFIU8yp91/TY/+MYK8GvlKoTDnqOCovCVM=",
25-
);
22+
export const alice = Principal.ED25519Signer.fromString<
23+
"did:key:z6Mkk89bC3JrVqKie71YEcc5M1SMVxuCgNx6zLZ8SYJsxALi"
24+
>(
25+
"MgCZT5vOnYZoVAeyjnzuJIVY9J4LNtJ+f8Js0cTPuKUpFne0BVEDJjEu6quFIU8yp91/TY/+MYK8GvlKoTDnqOCovCVM=",
26+
);
2627

27-
export const space =
28-
Principal.ED25519Signer.fromString<"did:key:z6MkrZ1r5XBFZjBU34qyD8fueMbMRkKw17BZaq2ivKFjnz2z">(
29-
"MgCYKXoHVy7Vk4/QjcEGi+MCqjntUiasxXJ8uJKY0qh11e+0Bs8WsdqGK7xothgrDzzWD0ME7ynPjz2okXDh8537lId8=",
30-
);
28+
export const space = Principal.ED25519Signer.fromString<
29+
"did:key:z6MkrZ1r5XBFZjBU34qyD8fueMbMRkKw17BZaq2ivKFjnz2z"
30+
>(
31+
"MgCYKXoHVy7Vk4/QjcEGi+MCqjntUiasxXJ8uJKY0qh11e+0Bs8WsdqGK7xothgrDzzWD0ME7ynPjz2okXDh8537lId8=",
32+
);
3133

3234
const toJSON = <T>(source: T) => JSON.parse(JSON.stringify(source));
3335

3436
Deno.test("test transaction", async (t) => {
3537
const server = Deno.serve({ port: 9000 }, app.fetch);
36-
const address = new URL(`http://${server.addr.hostname}:${server.addr.port}/api/storage/memory`);
38+
const address = new URL(
39+
`http://${server.addr.hostname}:${server.addr.port}/api/storage/memory`,
40+
);
3741

3842
try {
3943
const memory = Consumer.connect({
@@ -80,7 +84,9 @@ Deno.test("test transaction", async (t) => {
8084

8185
Deno.test("test consumer", async (t) => {
8286
const server = Deno.serve({ port: 9000 }, app.fetch);
83-
const address = new URL(`http://${server.addr.hostname}:${server.addr.port}/api/storage/memory`);
87+
const address = new URL(
88+
`http://${server.addr.hostname}:${server.addr.port}/api/storage/memory`,
89+
);
8490
try {
8591
const session = Consumer.connect({ address, as: alice });
8692
const memory = session.mount(alice.did());

0 commit comments

Comments
 (0)