ake/paperclip
1
0
Fork 0
mirror of https://github.com/alkimake/paperclip.git synced 2026-06-14 01:50:39 +09:00
Code Issues Projects Releases Packages Wiki Activity

Remove unsupported job company scope patch

Browse source
This commit is contained in:
Paperclip Bot 2026-06-05 10:42:01 +00:00
parent 0a56b88fa7
commit ce18c1a9e2
2 changed files with 1 additions and 94 deletions
Download patch file Download diff file Expand all files Collapse all files

5
packages/plugins/sdk/src/worker-rpc-host.ts
View file

@ -1502,10 +1502,7 @@ export function startWorkerRpcHost(options: WorkerRpcHostOptions): WorkerRpcHost
if (!handler) { if (!handler) {
throw new Error(`No handler registered for job "${params.job.jobKey}"`); throw new Error(`No handler registered for job "${params.job.jobKey}"`);
} }
await runtimeCompanyContext.run( await handler(params.job);
{ companyId: params.job.companyId ?? null },
() => handler(params.job),
);
} }
async function handleWebhook(params: PluginWebhookInput): Promise<void> { async function handleWebhook(params: PluginWebhookInput): Promise<void> {

90
packages/plugins/sdk/tests/worker-rpc-host.test.ts
View file

@ -515,94 +515,4 @@ describe("startWorkerRpcHost runtime company context", () => {
} }
}); });
it("passes runJob company context into config host calls", async () => {
const stdin = new PassThrough();
const stdout = new PassThrough();
const nextMessage = collectJsonLines(stdout);
const plugin = definePlugin({
async setup(ctx) {
ctx.jobs.register("check-job-context", async () => {
const config = await ctx.config.get();
await ctx.state.set(
{
scopeKind: "instance",
namespace: "job-context",
stateKey: "mode",
},
config.mode,
);
});
},
});
const host = startWorkerRpcHost({ plugin, stdin, stdout });
try {
writeMessage(stdin, {
jsonrpc: "2.0",
id: 1,
method: "initialize",
params: {
manifest: { id: "test-plugin", name: "test-plugin", version: "1.0.0" },
config: {},
instanceInfo: { instanceId: "inst-1", hostVersion: "0.0.0-test" },
apiVersion: 1,
},
});
await expect(nextMessage()).resolves.toMatchObject({ id: 1, result: { ok: true } });
writeMessage(stdin, {
jsonrpc: "2.0",
id: 2,
method: "runJob",
params: {
job: {
id: "job-1",
jobKey: "check-job-context",
companyId: "company-1",
payload: {},
createdAt: new Date().toISOString(),
updatedAt: new Date().toISOString(),
},
},
});
const configRequest = await nextMessage();
expect(configRequest).toMatchObject({
method: "config.get",
params: { companyId: "company-1" },
});
writeMessage(stdin, {
jsonrpc: "2.0",
id: configRequest.id,
result: { mode: "company-config" },
});
const stateRequest = await nextMessage();
expect(stateRequest).toMatchObject({
method: "state.set",
params: {
scopeKind: "instance",
namespace: "job-context",
stateKey: "mode",
value: "company-config",
},
});
writeMessage(stdin, {
jsonrpc: "2.0",
id: stateRequest.id,
result: null,
});
await expect(nextMessage()).resolves.toMatchObject({
id: 2,
result: null,
});
} finally {
host.stop();
stdin.destroy();
stdout.destroy();
}
});
}); });