Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
13 changes: 13 additions & 0 deletions rivetkit-typescript/packages/rivetkit/src/manager-api/actors.ts
Original file line number Diff line number Diff line change
Expand Up @@ -15,6 +15,11 @@ export const ActorSchema = z.object({
});
export type Actor = z.infer<typeof ActorSchema>;

export const ActorNameSchema = z.object({
metadata: z.record(z.string(), z.unknown()),
});
export type ActorName = z.infer<typeof ActorNameSchema>;

// MARK: GET /actors
export const ActorsListResponseSchema = z.object({
actors: z.array(ActorSchema),
Expand Down Expand Up @@ -61,3 +66,11 @@ export type ActorsGetOrCreateResponse = z.infer<
// MARK: DELETE /actors/{}
export const ActorsDeleteResponseSchema = z.object({});
export type ActorsDeleteResponse = z.infer<typeof ActorsDeleteResponseSchema>;

// MARK: GET /actors/names
export const ActorsListNamesResponseSchema = z.object({
names: z.record(z.string(), ActorNameSchema),
});
export type ActorsListNamesResponse = z.infer<
typeof ActorsListNamesResponseSchema
>;
25 changes: 24 additions & 1 deletion rivetkit-typescript/packages/rivetkit/src/manager/router.ts
Original file line number Diff line number Diff line change
Expand Up @@ -46,12 +46,14 @@ import {
ActorsGetOrCreateRequestSchema,
type ActorsGetOrCreateResponse,
ActorsGetOrCreateResponseSchema,
type ActorsListNamesResponse,
ActorsListNamesResponseSchema,
type ActorsListResponse,
ActorsListResponseSchema,
type Actor as ApiActor,
} from "@/manager-api/actors";
import type { AnyClient } from "@/mod";
import type { RegistryConfig } from "@/registry/config";
import { buildActorNames, type RegistryConfig } from "@/registry/config";
import type { DriverConfig, RunnerConfig } from "@/registry/run-config";
import type { ActorOutput, ManagerDriver } from "./driver";
import { actorGateway, createTestWebSocketProxy } from "./gateway";
Expand Down Expand Up @@ -369,6 +371,27 @@ function addManagerRoutes(
});
}

// GET /actors/names
{
const route = createRoute({
method: "get",
path: "/actors/names",
request: {
query: z.object({
namespace: z.string(),
}),
},
responses: buildOpenApiResponses(ActorsListNamesResponseSchema),
});

router.openapi(route, async (c) => {
const names = buildActorNames(registryConfig);
return c.json<ActorsListNamesResponse>({
names,
});
});
}

// PUT /actors
{
const route = createRoute({
Expand Down
Loading