Method buildCommandMessages

app/src/API/GRPC/ProtoGenerator.cpp:108–142

* @brief Builds per-command request messages plus the matching RPC lines from CommandRegistry. */

 * @brief Builds per-command request messages plus the matching RPC lines from CommandRegistry.
 */
void API::GRPC::ProtoGenerator::buildCommandMessages(QStringList& message_defs,
                                                     QStringList& rpc_lines)
{
  const auto& commands = API::CommandRegistry::instance().commands();

  for (auto it = commands.begin(); it != commands.end(); ++it) {
    const auto& def     = it.value();
    const auto msg_name = sanitizeName(def.name) + "Request";

    QString msg;
    QTextStream msg_out(&msg);
    msg_out << "message " << msg_name << " {\n"
            << "  string id = 1;\n";

    if (!def.inputSchema.isEmpty()) {
      const auto props = def.inputSchema.value("properties").toObject();
      int field_num    = 2;

      for (auto pit = props.begin(); pit != props.end(); ++pit) {
        const auto field_schema = pit.value().toObject();
        const auto field_type   = jsonTypeToProtoType(field_schema.value("type").toString());
        const auto field_name   = pit.key();

        msg_out << "  " << field_type << " " << field_name << " = " << field_num++ << ";\n";
      }
    }

    msg_out << "}\n";
    message_defs.append(msg);

    const auto rpc_name = sanitizeName(def.name);
    rpc_lines.append(QStringLiteral("  // %1\n  rpc %2(%3) returns (CommandResponse);")
                       .arg(def.description, rpc_name, msg_name));
  }
}

/**
 * @brief Writes per-command request messages and the typed service block with streaming RPCs.