Function postEnvelope

src/gep/cliContracts.js:593–614

(endpointPath, message, deps)

}

async function postEnvelope(endpointPath, message, deps) {
  const hubUrl = getHubUrl(deps);
  if (!hubUrl) throw new ContractError('auth_required', 'Hub URL is required');
  const a2a = deps.a2a || require('./a2aProtocol');
  const headers = buildEnvelopeHeaders(endpointPath, deps, a2a);
  if (!hasAuthorizationHeader(headers)) throw new ContractError('auth_required', 'Hub authentication required');
  const fetchImpl = deps.hubFetch || require('./hubFetch').hubFetch;
  const timeoutMs = deps.timeoutMs || 30000;
  const endpoint = hubUrl.replace(/\/+$/, '') + endpointPath;
  try {
    const res = await fetchImpl(endpoint, {
      method: 'POST',
      headers,
      body: JSON.stringify(message),
      signal: AbortSignal.timeout(timeoutMs),
    });
    const body = await safeJson(res);
    return { ok: Boolean(res && res.ok), status: res && res.status || 0, body };
  } catch (e) {
    return { ok: false, status: 0, body: { error: 'network_error' } };
  }
}

async function safeJson(res) {
  if (!res) return {};