algovoi-keystone-amqp 0.1.2

Bind AMQP / RabbitMQ publishes to the AlgoVoi keystone -- wrap any pika channel and every publish gets a content-addressed execution_ref (keystone-only edition, Apache-2.0)

algovoi-keystone-amqp

Bind AMQP / RabbitMQ publishes to the AlgoVoi keystone -- every publish on a wrapped pika channel gets a content-addressed execution_ref. Open, keystone-only edition, Apache-2.0. Byte-compatible with algovoi-execution-ref. Available on request -- see https://docs.algovoi.co.uk/keystone-connectors

from algovoi_keystone_amqp import keystone_channel

ch = keystone_channel(channel, decision_ref="sha256:...")
ch.basic_publish(exchange="orders", routing_key="created", body=payload)
ch.execution_ref   # binds that publish (scope = exchange/routing_key) to the keystone decision

Wraps basic_publish; everything else (queue_declare, basic_consume, ...) passes through. A failed publish is recorded FAILED. No pika dependency -- wraps any channel exposing basic_publish. Or compute standalone with amqp_execution_ref(...).

A failed operation is recorded with outcome FAILED; tamper_detected(...) recomputes any binding offline.

Keystone-only edition

The open edition binds and verifies each operation. The signed, hash-linked chain of operations (PQC + CCC ingest) is the commercial tier.

License

Apache-2.0. Copyright AlgoVoi.