Потоки й автоматизація

Потік — це орієнтований граф: вузли, зʼєднані дротами, які проходять від однієї точки початку. Це навмисне не сценарій із циклом. Форму задають чотири правила, і редактор відмовляється публікувати креслення, яке порушує бодай одне з них, називаючи хибний вузол.

• Рівно один тригер. Вузол тригера — єдиний вхід, і саме він вирішує, які змінні існують у решті креслення.
• Жодних циклів. Дріт, який веде назад до вузла, звідки він вийшов, відхиляється, бо потік не вміє чекати: цикл просто ніколи б не завершився.
• Кожен вузол має бути досяжним від тригера. Вузол, що завис окремо, — це помилка, якої не видно на знімку екрана, тож це помилка під час публікації.
• Гілки проходять одна за одною, ніколи поруч. Дві гілки водночас писали б у state одночасно, і результат залежав би від випадковості годинника.

Редактор — це полотно, і другого немає. Новий потік відкривається просто на ньому, а потік, який був прямим списком кроків, відкривається як прямий ланцюг вузлів.

• Палітра містить дванадцять видів вузлів. Клацніть на одному, щоб покласти його на полотно, або перетягніть у потрібне місце.
• Вузол пересувається перетягуванням за його заголовок. Усе інше на вузлі — це елемент керування, тож перетягування воно не починає.
• Дріт іде від точки виходу до точки входу. Перетягніть від однієї до іншої або клацніть спершу вихід, а потім вхід. Обидва способи роблять те саме, і другий — це шлях із клавіатури.
• Якщо відпустити дріт у порожнечі, нічого не станеться. Щоб прибрати дріт, виберіть його й натисніть Delete або скористайтеся хрестиком на ньому.
• Масштаб від 50 до 200 відсотків, Вмістити показує все креслення, а перетягування тла зміщує огляд. Мінікарти немає.

Дванадцять видів, і цей перелік навмисне короткий. Кожен вид — це панель, девʼять перекладів, гілка у виконавці та рядок у таблиці істинності, тож вид, який виправдовує своє місце, вартий більше за той, що майже виправдовує.

Пʼять моментів, і обраний каже не лише, коли потік виконується. Він каже також, які змінні існують, які пропонує вибирач і які платформа відмовляється зберігати. Шлях, який у той момент існувати не може, — це помилка під час збереження, а не порожній рядок посеред виконання.

Кожне значення, яке потік може прочитати, походить із однієї з цих груп. Вибирач у редакторі показує групи, що існують для обраного тригера, і більше нічого. Читати невідомий шлях — це помилка, а не порожнє значення: хибне припущення має бути гучним.

Вузол set пише у state. Його значення — дослівний текст, якщо тільки ви не позначите поле виразу; тоді воно читається як шаблон, зі вже підставленими змінними цього виконання.

• Ця позначка — свідомий вибір. Значення, у якому випадково стоять дві фігурні дужки, шматок Ansible або уривок Helm, і далі означає те, що там написано. Ніщо не змінює сенсу через зміну, якої ніхто не просив.
• Мова — це лише вивід. Дві дужки й шлях, і більше нічого: жодного assign, жодного capture, жодного циклу, жодного include. Що стоїть на полотні, те й виходить, із підставленими значеннями.
• Є 46 фільтрів: текст, числа, дати, ті кілька спискових фільтрів, що дають текст, і власні quote, ini та ipoctet. Вибирач у редакторі їх перелічує. Двох родин навмисне немає — тих, що кидають жереб, і тих, що повертають обʼєкт там, де ви хотіли слово.
• Таємниці тут недоступні, як і повторно вживані уривки. Те, що пише вузол set, потрапляє до запису виконання, а таємниці там робити нічого.

Потік може зупинитися й чекати на людину, а також може проходити ті самі вузли не один раз. Ані те, ані інше не було можливе, доки запуск не можна було відкласти й пізніше розбудити; ця черга тепер є.

• Вузол погодження зупиняє запуск, створює запит і сповіщає обліковий запис. Відповідь потребує окремого права, тож той, хто написав потік, не є автоматично тим, хто його затверджує.
• Кожен запит несе термін і те, що станеться без відповіді: продовжити як погоджено, продовжити як відхилено або завершити запуск як такий, що не стосується. Четвертого варіанта немає, бо запуск, який чекає вічно, це запуск, про який більше ніхто не почує.
• Для кожного проходить свій вихід циклу один раз на елемент списку. У циклі state.loop містить поточний елемент, його позицію та загальну кількість.
• Ніщо ззовні циклу не може приєднуватися до вузлів усередині нього. Ці вузли виконуються щообертом, і сповіщення, приєднане до обох, писало б по одному повідомленню на оберт.
• Крок погодження може також надсилати пошту. Вона надходить лише учасникам, які можуть вирішувати щодо погоджень, а не всім, хто бачить потоки; сповіщення в панелі записується в будь-якому разі.

Запуск, що стоїть, — це не запуск, який зазнав невдачі. Відкласти його можуть три речі, і всі три користуються однією чергою: погодження, довга пауза та підпотік, дочірній запуск якого сам чекає.

• Пауза до півхвилини просто чекає всередині запиту, який її розпочав, і саме цього ви хочете, коли даєте агентові трохи часу. Усе довше відкладає запуск, тож замовлення, яке його розпочало, завершується одразу, а решта потоку йде пізніше.
• Підпотік виконує інший потік цього облікового запису як один крок. Його результат визначає вихід: дочірній запуск, який удався або не знайшов роботи, продовжує через OK, а невдалий — через «Помилка». Стан, запуск і назва потоку є в state.subflow.
• Потік ніколи не має досягати сам себе — ні напряму, ні через інший потік. Це перевіряють під час розгортання, і повідомлення називає знайдений ланцюг.
• Потоки можуть викликати один одного щонайбільше на три рівні. Оскільки потоки редагують окремо, цю межу перевіряють двічі: під час розгортання і поки запуск справді триває.

Точка входу вебхука дає зовнішній системі власну URL. Та система надсилає JSON, потік за URL виконується, а відповідь — голий код стану. Точки входу живуть у розділі Скрипти, на вкладці вебхуків, і є окремими обʼєктами: та сама точка входу може вказувати на інший потік, а відправник цього й не помітить.

1. 01Створіть точку входу й дайте їй назву, яку впізнаєте згодом. URL створюється сама й вибору не підлягає: 32 випадкові символи, тобто 160 бітів, тож вгадування — не стратегія.
2. 02Оберіть, як відправник підтверджує себе, і скопіюйте таємницю. Її показують один раз і більше ніколи; якщо вона загубилася, ви створюєте нову, а разом із нею отримуєте й нову URL.
3. 03Спрямуйте точку входу на потік, тригером якого є вебхук. Точка входу може існувати раніше за потік, і доти запит приймається й отримує 202, який нічого не запускає. Саме в такому порядку люди це й будують насправді, тож помилкою це не вважають.

Підпис — це слово sha256, знак рівності й HMAC-SHA256 саме над байтами позначки часу, крапки й тіла, малими шістнадцятковими цифрами. Він іде в X-Provibr-Signature, а сама позначка часу йде в X-Provibr-Timestamp, цілими секундами від епохи.

Запит, чия позначка часу старша за 300 секунд або лежить у майбутньому, відхиляється з 401. Це вікно — справжнє правило, а не оздоба, бо позначка часу міститься всередині підписаного матеріалу: перехоплений запит не вийде надіслати завтра, наліпивши поверх свіжу позначку.

Підписати запит — це один рядок openssl. Цей приклад надсилає невеликий обʼєкт; текст для термінала навмисне лишається англійським, щоб збігатися з тим, що показує ваш термінал.

# Sign the raw body together with the timestamp, then post it.
SECRET="$PROVIBR_WEBHOOK_SECRET"
BODY='{"reason":"maintenance","attempt":1}'
TS=$(date +%s)
SIG=$(printf '%s.%s' "$TS" "$BODY" | openssl dgst -sha256 -hmac "$SECRET" -r | cut -d' ' -f1)

curl -sS -X POST 'https://app.provibr.com/api/hooks/flows/<your-slug>' \
  -H 'Content-Type: application/json' \
  -H "X-Provibr-Timestamp: $TS" \
  -H "X-Provibr-Signature: sha256=$SIG" \
  --data "$BODY"

Кожен запит лишає квитанцію, прийнятий він чи ні: наслідок, повернутий стан, адресу джерела повністю й скільки байтів справді прочитано. Тіло не зберігається ніколи. Квитанції зникають за 90 днів, раніше за самі виконання, бо адреса джерела — це персональні дані того, хто нашим клієнтом не є.

Два схожі питання мають тут дві різні відповіді. Хто що і коли змінив — це редакція. Що саме пройшло це конкретне виконання — це копія, збережена на самому виконанні. Знімок не може відповісти на перше питання, а редакція — на друге, тож існують обидва.

• Кожна публікація пише редакцію, зокрема й публікація, яка нічого не змінила. Номер зростає для кожного потоку й ніколи не використовується вдруге.
• Різниця між двома редакціями — це читабельний список, а не сирий JSON: доданий, прибраний або змінений вузол із названими полями, доданий чи прибраний дріт. Те, де вузол стоїть на полотні, зміною не є.
• Відновлення нічого не відмотує. Воно записує старе креслення як нову редакцію поверх історії, з приміткою, звідки воно взялося.
• Кожне виконання зберігає креслення, яке воно пройшло. Зміна потоку згодом ніколи не переписує того, що зробило давніше виконання.
• Виконання містить рядок на кожен відвіданий вузол, із наслідком і виходом, через який воно пішло, і рядок на кожен невідвіданий вузол із причиною. Невідвіданий — це факт, який варто записати, а не порожнє місце.
• Список виконань фільтрується за тригером, станом і редакцією та вивантажується у CSV. Вивантаження спиняється на 5000 рядках і каже про це всередині файлу, а не обривається мовчки.

Шаблони скриптів тримають поряд власну історію: кожну збережену версію вмісту й порядкову різницю між будь-якими двома з них.