ELSTER: Bescheide aus dem Posteingang abholen, ohne daran zu denken

{
  "title": "Mein ELSTER: neue Bescheide aus dem Posteingang einsammeln",
  "parameters": [
    {
      "key": "ab_datum",
      "description": "Nur Posteingänge ab diesem Tag berücksichtigen (JJJJ-MM-TT)",
      "required": true
    },
    {
      "key": "ziel_webhook",
      "description": "Dein Endpunkt, der die Liste der Bescheide entgegennimmt",
      "required": true
    }
  ],
  "runSequentially": true,
  "sequentialKey": "mein-elster",
  "blocks": [
    {
      "blockType": "navigation",
      "label": "Startseite",
      "url": "https://www.elster.de/eportal/start"
    },
    {
      "blockType": "validation",
      "label": "Angemeldet",
      "criterion": "Die Startseite von Mein ELSTER ist im angemeldeten Zustand zu sehen, der Posteingang ist aus der Navigation erreichbar, und es steht weder ein Anmeldeformular noch eine Zertifikatsabfrage auf der Seite"
    },
    {
      "blockType": "action",
      "label": "Posteingang_oeffnen",
      "instruction": "Öffne Mein Posteingang aus der Navigation von Mein ELSTER"
    },
    {
      "blockType": "extraction",
      "label": "Posteingang_lesen",
      "instruction": "Jeder Eintrag im Posteingang ab dem {{ ab_datum }}: Datum, Absender (das Finanzamt), Betreff, ob es sich um einen Bescheid oder eine Mitteilung handelt, und ob ein PDF hinterlegt ist",
      "schema": {
        "type": "object",
        "properties": {
          "eintraege": {
            "type": "array",
            "items": {
              "type": "object",
              "properties": {
                "datum": {
                  "type": "string"
                },
                "absender": {
                  "type": "string"
                },
                "betreff": {
                  "type": "string"
                },
                "art": {
                  "type": "string",
                  "enum": [
                    "bescheid",
                    "mitteilung"
                  ]
                },
                "hatPdf": {
                  "type": "boolean"
                }
              },
              "required": [
                "datum",
                "betreff",
                "art",
                "hatPdf"
              ]
            }
          }
        },
        "required": [
          "eintraege"
        ]
      }
    },
    {
      "blockType": "loop",
      "label": "Je_Eintrag",
      "over": "{{ Posteingang_lesen_output.eintraege }}",
      "maxIterations": 50,
      "blocks": [
        {
          "blockType": "action",
          "label": "PDF_laden",
          "nextLoopOnFailure": true,
          "instruction": "Öffne den Eintrag vom {{ loopValue.datum }} mit dem Betreff {{ loopValue.betreff }} und lade das hinterlegte PDF herunter"
        }
      ]
    },
    {
      "blockType": "http_request",
      "label": "Liste_senden",
      "method": "POST",
      "url": "{{ ziel_webhook }}",
      "headers": {
        "content-type": "application/json"
      },
      "body": "{{ Posteingang_lesen_output }}"
    }
  ]
}

import { Browserberg } from '@browserberg/sdk';
import vorlage from './elster-bescheide.json' with { type: 'json' };

const bb = new Browserberg({
  apiKey: process.env.BROWSERBERG_API_KEY,
  baseUrl: 'https://browserberg.com',
});

const wf = await bb.workflows.publish(vorlage);

// Der Zertifikatsschritt gehört einer Person: Watch-Link öffnen, übernehmen, anmelden.
await using session = await bb.sessions.create();
const { url } = await bb.sessions.watchLink(session.id, { allowTakeover: true });
console.log('Hier bei Mein ELSTER anmelden, danach den Lauf starten:', url);

const lauf = await bb.workflows.run(wf.workflowId, {
  sessionId: session.id,
  inputs: {
    ab_datum: '2026-08-01',
    ziel_webhook: 'https://erp.intern.example/hooks/elster',
  },
});
console.log(lauf.status, lauf.endedBy, lauf.outputs.Posteingang_lesen_output);