aevgarik/paperclip
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Inject PAPERCLIP_* env vars into all adapter process runs

Browse Source 
Agents spawned via process, claude_local, and codex_local adapters now
automatically receive PAPERCLIP_AGENT_ID, PAPERCLIP_COMPANY_ID, and
PAPERCLIP_API_URL in their environment, eliminating the need to manually
configure these in adapter_config.env.

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
This commit is contained in:
Forgotten
2026-02-17 20:07:19 -06:00
parent 04f708c32e
commit b13c5f4b34
1 changed files with 15 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
server/src/services/heartbeat.ts
View File

@@ -250,6 +250,16 @@ async function runChildProcess(
}); });
} }
function buildPaperclipEnv(agent: { id: string; companyId: string }): Record<string, string> {
const vars: Record<string, string> = {
PAPERCLIP_AGENT_ID: agent.id,
PAPERCLIP_COMPANY_ID: agent.companyId,
};
const apiUrl = process.env.PAPERCLIP_API_URL ?? `http://localhost:${process.env.PORT ?? 3100}`;
vars.PAPERCLIP_API_URL = apiUrl;
return vars;
}
export function heartbeatService(db: Db) { export function heartbeatService(db: Db) {
const runLogStore = getRunLogStore(); const runLogStore = getRunLogStore();
@@ -530,6 +540,7 @@ export function heartbeatService(db: Db) {
async function executeProcessRun( async function executeProcessRun(
runId: string, runId: string,
agent: typeof agents.$inferSelect,
config: Record<string, unknown>, config: Record<string, unknown>,
onLog: (stream: "stdout" | "stderr", chunk: string) => Promise<void>, onLog: (stream: "stdout" | "stderr", chunk: string) => Promise<void>,
): Promise<AdapterExecutionResult> { ): Promise<AdapterExecutionResult> {
@@ -539,7 +550,7 @@ export function heartbeatService(db: Db) {
const args = asStringArray(config.args); const args = asStringArray(config.args);
const cwd = asString(config.cwd, process.cwd()); const cwd = asString(config.cwd, process.cwd());
const envConfig = parseObject(config.env); const envConfig = parseObject(config.env);
const env: Record<string, string> = {}; const env: Record<string, string> = { ...buildPaperclipEnv(agent) };
for (const [k, v] of Object.entries(envConfig)) { for (const [k, v] of Object.entries(envConfig)) {
if (typeof v === "string") env[k] = v; if (typeof v === "string") env[k] = v;
} }
@@ -607,7 +618,7 @@ export function heartbeatService(db: Db) {
const cwd = asString(config.cwd, process.cwd()); const cwd = asString(config.cwd, process.cwd());
const envConfig = parseObject(config.env); const envConfig = parseObject(config.env);
const env: Record<string, string> = {}; const env: Record<string, string> = { ...buildPaperclipEnv(agent) };
for (const [k, v] of Object.entries(envConfig)) { for (const [k, v] of Object.entries(envConfig)) {
if (typeof v === "string") env[k] = v; if (typeof v === "string") env[k] = v;
} }
@@ -707,7 +718,7 @@ export function heartbeatService(db: Db) {
const cwd = asString(config.cwd, process.cwd()); const cwd = asString(config.cwd, process.cwd());
const envConfig = parseObject(config.env); const envConfig = parseObject(config.env);
const env: Record<string, string> = {}; const env: Record<string, string> = { ...buildPaperclipEnv(agent) };
for (const [k, v] of Object.entries(envConfig)) { for (const [k, v] of Object.entries(envConfig)) {
if (typeof v === "string") env[k] = v; if (typeof v === "string") env[k] = v;
} }
@@ -886,7 +897,7 @@ export function heartbeatService(db: Db) {
} else if (agent.adapterType === "codex_local") { } else if (agent.adapterType === "codex_local") {
adapterResult = await executeCodexLocalRun(run.id, agent, runtime, config, context, onLog); adapterResult = await executeCodexLocalRun(run.id, agent, runtime, config, context, onLog);
} else { } else {
adapterResult = await executeProcessRun(run.id, config, onLog); adapterResult = await executeProcessRun(run.id, agent, config, onLog);
} }
let outcome: "succeeded" | "failed" | "cancelled" | "timed_out"; let outcome: "succeeded" | "failed" | "cancelled" | "timed_out";