Skip to content

Commit

Permalink
remove unused messages
Browse files Browse the repository at this point in the history
  • Loading branch information
nicktrn committed Jun 11, 2024
1 parent 5a27e9c commit 9bae64b
Show file tree
Hide file tree
Showing 2 changed files with 0 additions and 39 deletions.
15 changes: 0 additions & 15 deletions packages/core-apps/src/provider.ts
Original file line number Diff line number Diff line change
Expand Up @@ -168,21 +168,6 @@ export class ProviderShell implements Provider {
"x-trigger-provider-type": this.options.type,
},
handlers: {
DELETE: async (message) => {
this.tasks.delete({ runId: message.name });

return {
message: "delete request received",
};
},
GET: async (message) => {
this.tasks.get({ runId: message.name });
},
HEALTH: async (message) => {
return {
status: "ok",
};
},
INDEX: async (message) => {
try {
await this.tasks.index({
Expand Down
24 changes: 0 additions & 24 deletions packages/core/src/v3/schemas/messages.ts
Original file line number Diff line number Diff line change
Expand Up @@ -347,14 +347,6 @@ export const ProviderToPlatformMessages = {
};

export const PlatformToProviderMessages = {
HEALTH: {
message: z.object({
version: z.literal("v1").default("v1"),
}),
callback: z.object({
status: z.literal("ok"),
}),
},
INDEX: {
message: z.object({
version: z.literal("v1").default("v1"),
Expand Down Expand Up @@ -383,7 +375,6 @@ export const PlatformToProviderMessages = {
}),
]),
},
// TODO: this should be a shared queue message instead
RESTORE: {
message: z.object({
version: z.literal("v1").default("v1"),
Expand All @@ -401,21 +392,6 @@ export const PlatformToProviderMessages = {
runId: z.string(),
}),
},
DELETE: {
message: z.object({
version: z.literal("v1").default("v1"),
name: z.string(),
}),
callback: z.object({
message: z.string(),
}),
},
GET: {
message: z.object({
version: z.literal("v1").default("v1"),
name: z.string(),
}),
},
};

const CreateWorkerMessage = z.object({
Expand Down

0 comments on commit 9bae64b

Please sign in to comment.