Function generateSessionEvents

scripts/codegen/go.ts:3677–3773

(schemaPath?: string, apiSchema?: ApiSchema)

}

async function generateSessionEvents(schemaPath?: string, apiSchema?: ApiSchema): Promise<void> {
    console.log("Go: generating session-events...");

    const resolvedPath = schemaPath ?? (await getSessionEventsSchemaPath());
    const schema = cloneSchemaForCodegen((await loadSchemaJson(resolvedPath)) as JSONSchema7);
    const processed = propagateInternalVisibility(postProcessSchema(schema));
    const processedApiSchema = apiSchema
        ? propagateInternalVisibility(postProcessSchema(cloneSchemaForCodegen(apiSchema as JSONSchema7)) as JSONSchema7)
        : undefined;
    const sharedDefinitions = processedApiSchema
        ? findSharedSchemaDefinitions(
            processed as unknown as Record<string, unknown>,
            processedApiSchema as unknown as Record<string, unknown>
        )
        : new Set<string>();
    const reachableDefinitions = collectReachableDefinitionNames(processed as unknown as Record<string, unknown>);
    const sharedSessionEventDefinitions = new Set([...sharedDefinitions].filter((name) => reachableDefinitions.has(name)));
    const sessionSchema = rewriteSharedDefinitionReferences(processed, sharedDefinitions, "api.schema.json", true);

    const generatedSessionCode = generateGoSessionEventsCode(
        sessionSchema,
        "rpc",
        processedApiSchema ? { "api.schema.json": processedApiSchema } : undefined
    );
    let generatedTypeCode = stripTrailingGoWhitespace(generatedSessionCode.typeCode);
    // Annotate internal session-event types (driven by the JSON Schema definition's
    // `visibility: "internal"` flag). Matches what the RPC generator does below;
    // the session-events emit path doesn't pass through that code so we apply it here.
    {
        const sessionDefs = collectDefinitionCollections(sessionSchema as Record<string, unknown>);
        const allSessionDefs = { ...sessionDefs.$defs, ...sessionDefs.definitions };
        const internalSessionTypeNames = new Set<string>();
        for (const [name, def] of Object.entries(allSessionDefs)) {
            if (def && typeof def === "object" && (def as Record<string, unknown>).visibility === "internal") {
                internalSessionTypeNames.add(name);
            }
        }
        for (const typeName of internalSessionTypeNames) {
            generatedTypeCode = generatedTypeCode.replace(
                new RegExp(`^(type ${typeName} struct)`, "m"),
                `// Internal: ${typeName} is an internal SDK API and is not part of the public surface.\n$1`
            );
        }
    }
    const generatedEncodingCode = stripTrailingGoWhitespace(generatedSessionCode.encodingCode);
    rpcSessionEventTopLevelNames = {
        types: new Set(collectGoTopLevelNames(generatedTypeCode, "type")),
        consts: new Set(collectGoTopLevelNames(generatedTypeCode, "const")),
    };

    const rpcOutPath = await writeGeneratedFile("go/rpc/zsession_events.go", generatedTypeCode);
    console.log(`  ✓ ${rpcOutPath}`);

    await formatGoFile(rpcOutPath);

    const rpcEncodingOutPath = await writeGeneratedFile("go/rpc/zsession_encoding.go", goGeneratedEncodingFileCode("session-events.schema.json", "rpc", generatedEncodingCode, true));
    console.log(`  ✓ ${rpcEncodingOutPath}`);