Conectori

Doi conectori se livrează cu platforma: unul consumă de pe un broker de mesaje prin STOMP, celălalt urmărește un director. Amândoi sunt binare separate, cu proces propriu și configurare proprie. Niciunul nu rulează înăuntrul platformei: fiecare prezintă o credențială la ușa de coadă și postează mesajul acolo, exact ca orice alt apelant.

Consecința e utilă când se scrie un caiet de sarcini: tot ce spune pagina de poartă despre autentificare, plafon de debit și refuz se aplică și unui conector, fără nimic în plus și fără nimic special pentru el.

Un refuz de credențială oprește procesul în loc să-l lase să se învârtă. Credențiala e a conectorului, nu a mesajului: dacă e greșită, următoarele mii de mesaje vor primi același refuz, iar un proces care reîncearcă la infinit umple jurnalul și ascunde cauza. Platforma nu răspunde niciodată 401 când poarta n-a putut decide — acolo răspunde 503, care e tranzitoriu și chiar se reîncearcă.

Ce nu e terminal, deliberat: 400, 404 și 422 se reîncearcă în continuare. Un conector pornit înaintea fluxului pe care-l alimentează primește un 404 legitim, iar oprirea lui ar fi un fals defect. De luat în calcul la planificare: un corp pe care fluxul îl refuză se reîncearcă până e scos din sursă, deci mesajul acela ține coada pe loc.

Un conector raportează în același jurnal ca restul platformei: fiecare mesaj preluat lasă un eveniment, cu o corelare proprie care se regăsește în urma livrării. Raportarea aia nu consumă din plafonul de debit al credențialei. Plafonul e per credențială, deci un conector care împarte cheia cu apelanții sincroni ar plăti de două ori pe mesaj și ar coborî tăcut plafonul celorlalți.

Conectorul de mesaje ia identitatea din identificatorul pe care-l dă brokerul; cel de fișiere o compune din cale, oră de modificare și dimensiune. Contractul cozii rămâne livrare cel puțin o dată, în ambele cazuri.

Apărarea împotriva unui duplicat se scrie în flux, nu în conector: o cheie de deduplicare declarată în frontmatter, iar a doua livrare a aceleiași chei nu mai rulează fluxul — răspunde din înregistrare sau se oprește, după cum cere fluxul. E mecanismul pe care se sprijină un proces de business care nu are voie să se execute de două ori.

Consecință practică pentru identitatea compusă din cale, oră și dimensiune: rezoluția e de o secundă. Un fișier înlocuit în aceeași secundă, la aceeași cale și cu aceeași dimensiune, nu se mai citește a doua oară.

Plafonul unui mesaj se rezolvă per punct de acces, iar un corp anunțat peste plafon e refuzat fără să se citească un octet. Conectorii citesc același plafon din frontmatter-ul fluxului pe care-l alimentează, deci nu există un al doilea plafon care să se învechească separat de primul.

Peste plafon nu există conținut opac și nici referință la depozitul adresat prin conținut: corpul se materializează în memorie și se parsează. De aici regula pe care o spunem înaintea oricărei discuții de arhitectură — fișierele mari nu trec printr-un flux. Un nor de puncte, o înregistrare video, o ridicare fotogrammetrică se transferă direct între sisteme; prin platformă trece metadata: unde e fișierul, ce acoperă, ce amprentă are, ce s-a schimbat.

Și în celălalt sens: nimic din platformă nu scrie un fișier pentru un flux. Conectorul de fișiere citește un director și postează; nu există pas care să depună un fișier undeva.

Un flux are două garduri, cu două înțelesuri, iar alegerea între ele e a autorului: unul filtrează tăcut mesajele care nu-l interesează, celălalt refuză explicit, la prima regulă falsă, cu mesajul scris de autor. Un set incomplet, insuficient agregat sau neanonimizat se respinge pe al doilea, nu se aruncă pe primul.

Un flux poate avea și o secvență de tratare a erorii. Un handler care reușește nu răspunde 200: statusul rămâne cel natural al erorii, deci un refuz nu se citește niciodată ca acceptare.

Ce nu există: validare de schemă. Nu se încarcă un XSD sau un JSON Schema și nu se verifică mesajul contra lui. Regulile sunt expresii scrise în flux, peste mesajul sosit.

Conectorul de fișiere scanează directorul la un interval configurat, în ordinea vechimii. Nu se abonează la notificările sistemului de fișiere și nu coboară în subdirectoare. Conectorul de mesaje stă pe o coadă de broker și consumă de acolo.

Separat de conectori, un flux poate purta un orar cu șase câmpuri, iar un tic lasă în jurnal aceeași pereche de evenimente ca o cerere, pe canalul de cron.

Ce nu există: un abonament push către un produs terț. Dacă sursa trebuie să anunțe platforma, o face chemând ușa — și atunci nu mai e nevoie de conector.

• Un mesaj acceptat pe ușa de coadă se scrie în jurnalul propriu al cozii și supraviețuiește unei căderi; o reîncercare programată supraviețuiește unei reporniri.
• Corpul mesajului stă în acel jurnal în clar. Mascarea se aplică la ieșirea de jurnal, e numai pe JSON și numai pe chei de obiect — cadrul de pe coadă n-o primește.
• Confirmarea unui mesaj nu șterge octeții. Nu există nici limită de timp, nici de dimensiune pentru cât stă un corp pe coadă: octeții pleacă la drenajul complet al cozii sau la compactarea unei cozi abandonate.
• Fereastra de retenție guvernează ambele ieșiri de jurnal — rânduri și fișiere — într-o singură trecere. Nu atinge cozile, registrul, lanțul de audit sau starea de flux.

• Conectorul de fișiere citește un director local. Nu vorbește SFTP, FTP sau SMB și nu citește un depozit de obiecte.
• Conectorul de mesaje vorbește STOMP peste TCP în clar, pe cozi. Fără TLS către broker, fără credențiale de broker, fără topicuri, iar anteturile brokerului nu ajung în flux.
• Nu există extensie prin cod propriu: nu se rulează JavaScript într-un flux și nu se încarcă module. Punctul de extensie e fluxul însuși — scris în FlowMarkdown, desenat în editorul vizual din VS Code și verificat de extensia de server de limbaj în timp ce se scrie.
• Nu există magazie de serii de timp și nici de indicatori. O serie se stochează în sistemul care o deține, iar fluxul o duce acolo.
• Nu se consumă un WSDL străin, iar WSDL-ul generat pentru un serviciu expus e slab tipizat.

• ObservabilitateCe rămâne scris după o livrare și cât timp rămâne.
• OperareCine pornește conectorul, cu ce configurare, și ce se vede când se oprește.