Add ve consumer

.devcontainer/devcontainer.json

@@ -1,12 +1,22 @@
 {
-    "name": "arca",
-    "build": {
-        "dockerfile": "Dockerfile",
-        "context": "..",
-        "args": { "RUBY_VERSION": "3.4.7" }
-    },
-    "features": {
-        "ghcr.io/devcontainers/features/github-cli:1": {}
-    },
-    "postCreateCommand": "bundle install && rake"
+  "name": "arca.rb",
+  "runArgs": [
+    "--name",
+    "arca.rb"
+  ],
+  "image": "ghcr.io/rails/devcontainer/images/ruby:4.0.0",
+  "workspaceFolder": "/workspaces/arca.rb",
+  "workspaceMount": "source=${localWorkspaceFolder},target=/workspaces/arca.rb,type=bind,consistency=cached",
+  "remoteEnv": {
+    "ANTHROPIC_API_KEY": "${localEnv:ANTHROPIC_API_KEY}"
+  },
+  "postCreateCommand": "bin/devcontainer",
+  "customizations": {
+    "vscode": {
+      "extensions": [
+        "Shopify.ruby-lsp",
+        "anthropic.claude-code"
+      ]
+    }
+  }
 }

.mise.toml

@@ -1,2 +1,5 @@
 [settings]
-idiomatic_version_file_enable_tools = ["ruby"]
+idiomatic_version_file_enable_tools = ["ruby"]
+
+[tools]
+ruby = "4.0.0"

.ruby-version

@@ -1 +1 @@
-3.4.7
+4.0.0

CHANGELOG.md

@@ -1,10 +1,19 @@
 # Arca Changelog
 
+## [1.1.2] 2025-03-02
+
+- **VEConsumer** — Nuevo servicio: Ventanilla Electrónica - Consumir Comunicaciones (`veconsumerws`). Permite consultar y leer comunicaciones enviadas a un contribuyente vía SOAP 1.2.
+  - `consultar_comunicaciones(filter = {})` — consulta paginada con filtros opcionales (estado, fechas, sistema publicador, referencias, etc.).
+  - `consumir_comunicacion(id, incluir_adjuntos: false)` — recupera una comunicación y la marca como leída; con `incluir_adjuntos: true` extrae el contenido binario vía MTOM en `adjunto[:content]`.
+  - `consultar_sistemas_publicadores(id_sistema_publicador: nil)` — lista sistemas publicadores habilitados.
+  - `consultar_estados` — lista los posibles estados (1=No leída, 2=Leída).
+  - Los errores SOAP Fault del servicio se traducen a `ResponseError` con soporte para `e.code?`.
+
 ## [1.1.1] - 2025-02-20
 
-- **WSFE:** Added `tipos_condicion_iva_receptor(clase_cmp: nil)` to query IVA receptor conditions with optional invoice class filter.
-- **WSFE:** Added `actividades` to retrieve list of economic activities.
-- **WSFE:** Added `consultar_caea_sin_movimientos(caea, pto_vta)` to query CAEA without movements.
+- **WSFE:** Agregado `tipos_condicion_iva_receptor(clase_cmp: nil)` para consultar condiciones de IVA del receptor con filtro opcional por clase de comprobante.
+- **WSFE:** Agregado `actividades` para obtener el listado de actividades económicas.
+- **WSFE:** Agregado `consultar_caea_sin_movimientos(caea, pto_vta)` para consultar CAEA sin movimientos.
 
 ## [1.1.0]
 

README.md

@@ -13,6 +13,7 @@ Cliente Ruby para integrar webservices SOAP de AFIP y ARCA en Argentina. Soporta
 - **Autenticación WSAA** - Manejo automático de tokens y certificados
 - **Producción y homologación** - Ambientes configurables
 - **Padrón AFIP** - Consulta de contribuyentes (A4, A5, A100)
+- **Ventanilla Electrónica (VEConsumer)** - Consulta y lectura de comunicaciones de AFIP
 
 ## Requisitos
 
@@ -72,6 +73,7 @@ Opción del constructor: `env: :development` o `env: :production` (symbol o stri
 | WS Constancia Inscripción | `Arca::WSConstanciaInscripcion` | Constancia de inscripción |
 | Padrón A4 / A5 / A100 | `Arca::PersonaServiceA4`, `PersonaServiceA5`, `PersonaServiceA100` | Consulta padrón de contribuyentes |
 | WConsDeclaracion | `Arca::WConsDeclaracion` | Declaraciones aduaneras |
+| VEConsumer | `Arca::VEConsumer` | Ventanilla Electrónica — comunicaciones del contribuyente |
 
 ## Uso
 
@@ -173,6 +175,33 @@ ws = Arca::WSConstanciaInscripcion.new(env: :development, cuit: '20123456789', k
 ws.get_persona('20123456789')
 ```
 
+### VEConsumer (Ventanilla Electrónica)
+```ruby
+ws = Arca::VEConsumer.new(env: :development, cuit: '20123456789', key: key, cert: cert)
+
+# Consultar comunicaciones (paginado, con filtros opcionales)
+r = ws.consultar_comunicaciones(estado: 1, pagina: 1)
+r[:items]          # Array de ComunicacionSimplificada
+r[:total_paginas]  # total de páginas
+
+# Leer una comunicación (la marca como leída)
+com = ws.consumir_comunicacion(12_061_068)
+com[:estado]       # "2" (leída)
+com[:adjuntos]     # [] si no tiene adjuntos
+
+# Leer con adjuntos binarios vía MTOM
+com = ws.consumir_comunicacion(12_061_068, incluir_adjuntos: true)
+com[:adjuntos][0][:filename]  # "informe.pdf"
+com[:adjuntos][0][:content]   # contenido binario (String)
+
+# Sistemas publicadores habilitados
+ws.consultar_sistemas_publicadores
+ws.consultar_sistemas_publicadores(id_sistema_publicador: 88)
+
+# Estados posibles (1=No leída, 2=Leída)
+ws.consultar_estados
+```
+
 ### WConsDeclaracion (Declaraciones aduaneras)
 ```ruby
 ws = Arca::WConsDeclaracion.new(cuit: '20123456789', key: key, cert: cert, env: :development)

bin/devcontainer

@@ -0,0 +1,28 @@
+#!/usr/bin/env bash
+set -euo pipefail
+
+export DEBIAN_FRONTEND=noninteractive
+
+# Add Charm apt repo for gum and gitleaks
+sudo mkdir -p /etc/apt/keyrings
+curl -fsSL https://repo.charm.sh/apt/gpg.key | gpg --dearmor | sudo tee /etc/apt/keyrings/charm.gpg > /dev/null
+echo "deb [signed-by=/etc/apt/keyrings/charm.gpg] https://repo.charm.sh/apt/ * *" | sudo tee /etc/apt/sources.list.d/charm.list > /dev/null
+
+sudo apt-get update
+sudo apt-get install -y --no-install-recommends \
+  ca-certificates \
+  curl \
+  gh \
+  gum \
+  zlib1g-dev
+
+sudo rm -rf /var/lib/apt/lists/*
+
+if ! command -v mise >/dev/null 2>&1; then
+  curl -fsSL https://mise.jdx.dev/install.sh | sh
+  ln -sfn "$HOME/.local/bin/mise" /usr/local/bin/mise
+  mise trust
+fi
+
+# Claude Code CLI
+curl -fsSL https://claude.ai/install.sh | bash

lib/arca.rb

@@ -28,4 +28,5 @@ module Arca
 require "arca/w_cons_declaracion"
 require "arca/wsrgiva"
 require "arca/wscdc"
+require "arca/ve_consumer"
 require "arca/wsfecred"

lib/arca/ve_consumer.rb

@@ -0,0 +1,131 @@
+# frozen_string_literal: true
+
+# VEConsumer: Web Service de Ventanilla Electrónica - Consumir Comunicaciones (AFIP).
+# Permite consultar y leer comunicaciones enviadas a un contribuyente.
+# Documentación: VE-CU-WS-Consumir-Comunicaciones v1.3.0.
+# Id del servicio WSAA: "veconsumerws".
+module Arca
+  class VEConsumer
+    WSDL = {
+      development: "https://stable-middleware-tecno-ext.afip.gob.ar/ve-ws/services/veconsumer?wsdl",
+      production:  "https://infraestructura.afip.gob.ar/ve-ws/services/veconsumer?wsdl",
+      test:        "#{Root}/test/fixtures/ve_consumer/ve_consumer.wsdl"
+    }.freeze
+
+    attr_reader :wsaa, :cuit
+
+    def initialize(options = {})
+      @cuit = normalize_cuit(options[:cuit])
+      @wsaa = WSAA.new options.merge(service: "veconsumerws")
+      @client = Client.new Hash(options[:savon]).reverse_merge(
+        wsdl: WSDL[@wsaa.env],
+        soap_version: 2,
+        convert_request_keys_to: :camelcase
+      )
+    end
+
+    # Consulta comunicaciones del contribuyente con filtros opcionales.
+    # Claves opcionales del filter: estado, fecha_desde, fecha_hasta,
+    #   comunicacion_id_desde, comunicacion_id_hasta, tiene_adjunto,
+    #   sistema_publicador_id, pagina, resultados_por_pagina,
+    #   referencia1, referencia2.
+    # Retorna un hash con :pagina, :total_paginas, :items_por_pagina,
+    #   :total_items e :items (Array de ComunicacionSimplificada).
+    def consultar_comunicaciones(filter = {})
+      r = raw_request(:consultar_comunicaciones, auth_request.merge(filter: filter))
+      paginada = r[:respuesta_paginada]
+      paginada.merge(items: get_array(paginada[:items], :comunicacion_simplificada))
+    end
+
+    # Recupera una comunicación por id y la marca como leída.
+    # Con incluir_adjuntos: true se incluyen los adjuntos vía MTOM en la respuesta;
+    # el contenido binario de cada adjunto queda en :content como String.
+    # Retorna la Comunicacion con :adjuntos como Array.
+    def consumir_comunicacion(id_comunicacion, incluir_adjuntos: false)
+      response = client_request(:consumir_comunicacion, auth_request.merge(
+        id_comunicacion: id_comunicacion,
+        incluir_adjuntos: incluir_adjuntos
+      ))
+      resp = response.to_hash[:consumir_comunicacion_response]
+      raise ServerError, "Unexpected response structure" unless resp
+
+      comunicacion = resp[:comunicacion]
+      comunicacion.merge(adjuntos: build_adjuntos(comunicacion[:adjuntos], response.attachments))
+    end
+
+    # Lista los sistemas publicadores habilitados en Ventanilla Electrónica.
+    # Con id_sistema_publicador filtra por sistema específico.
+    def consultar_sistemas_publicadores(id_sistema_publicador: nil)
+      params = auth_request
+      params = params.merge(id_sistema_publicador: id_sistema_publicador) if id_sistema_publicador
+      r = raw_request(:consultar_sistemas_publicadores, params)
+      Array.wrap(r.dig(:sistemas, :sistema))
+    end
+
+    # Lista los posibles estados de una comunicación. 1=No leída, 2=Leída.
+    def consultar_estados
+      r = raw_request(:consultar_estados, auth_request)
+      Array.wrap(r.dig(:estados, :estado))
+    end
+
+    private
+
+    def auth_request
+      { auth_request: @wsaa.auth.merge(cuit_representada: cuit) }
+    end
+
+    def client_request(action, body)
+      @client.request(action, body)
+    rescue ServerError => e
+      raise parse_fault(e)
+    end
+
+    def raw_request(action, body)
+      resp = client_request(action, body).to_hash[:"#{action}_response"]
+      raise ServerError, "Unexpected response structure" unless resp
+
+      resp
+    end
+
+    def parse_fault(error)
+      match = error.message.match(/Error (\d+): (.+)/)
+      return error unless match
+
+      ResponseError.new([ { code: match[1], msg: match[2].strip } ])
+    end
+
+    def build_adjuntos(adjuntos_element, mtom_parts)
+      return [] unless adjuntos_element && adjuntos_element[:adjunto]
+
+      items = Array.wrap(adjuntos_element[:adjunto])
+      return items if mtom_parts.empty?
+
+      by_cid = mtom_parts.each_with_object({}) do |part, h|
+        cid = part.header[:content_id].to_s.tr("<>", "")
+        h[cid] = part.body.decoded
+      end
+
+      items.map do |adj|
+        href = adj.dig(:content, :include, :"@href").to_s
+        next adj unless href.start_with?("cid:")
+
+        cid = href.delete_prefix("cid:")
+        adj.merge(content: by_cid.fetch(cid, adj[:content]))
+      end
+    end
+
+    def get_array(container, element)
+      return [] unless container && container[element]
+
+      Array.wrap(container[element])
+    end
+
+    def normalize_cuit(value)
+      if value.nil? || value == ""
+        0
+      else
+        value.to_s.gsub(/\D/, "").to_i
+      end
+    end
+  end
+end