As well as slightly reworking it to make them easier to work with and more "dependent". Fixes #298.
**/
export interface TxMonitorClient {
context: InteractionContext
awaitAcquire: (args?: {}) => Promise<Slot>
hasTx: (id: TxId) => Promise<boolean>
nextTx: (args?: { fields?: 'all' }) => Promise<TxId | TxAlonzo | null>
sizeAndCapacity: (args?: {}) => Promise<MempoolSizeAndCapacity>
release: (args?: {}) => Promise<void>
shutdown: () => Promise<void>
awaitAcquire(args?: {}): Promise<Slot>
hasTx(id: TxId): Promise<boolean>
nextTx(): Promise<TxId | null>
nextTx(args: { fields: 'all' }): Promise<TxAlonzo | null>
sizeAndCapacity(args?: {}): Promise<MempoolSizeAndCapacity>
release(args?: {}): Promise<void>
shutdown(): Promise<void>
}
/**
return handleHasTxResponse((await response.next()).value)
}, context)
},
nextTx: (args?: {fields?: 'all'}) => {
nextTx: (args?: {fields: 'all'}) => {
ensureSocketIsOpen(socket)
return send<TxId | TxAlonzo | null>(async (socket) => {
socket.send(safeJSON.stringify({
...baseRequest,
methodname: 'NextTx',
args: args
args: args || {}
} as unknown as Ogmios['NextTx']))
return handleNextTxResponse((await response.next()).value, args)
*
* @category TxMonitor
*/
export function nextTx (context: InteractionContext, args?: { fields: 'all' }) : Promise<TxAlonzo|null>
export function nextTx (context: InteractionContext, args?: {}) : Promise<TxId|null>
export function nextTx (context: InteractionContext, args?: { fields: 'all' }) : Promise<TxId|TxAlonzo|null> {
export function nextTx (context: InteractionContext, args: { fields: 'all' }) : Promise<TxAlonzo|null>
export function nextTx (context: InteractionContext) : Promise<TxId|null>
export function nextTx (context: InteractionContext, args?: { fields: 'all' }) : Promise<TxAlonzo|TxId|null> {
return Query<
Ogmios['NextTx'],
Ogmios['NextTxResponse'],
TxAlonzo | null
TxAlonzo | TxId | null
>({
methodName: 'NextTx',
args: args
/**
* @internal
*/
export function handleNextTxResponse (response: Ogmios['NextTxResponse'], args?: { fields: 'all' }): (TxAlonzo | null)
export function handleNextTxResponse (response: Ogmios['NextTxResponse'], args?: {}): (TxId | null)
export function handleNextTxResponse (response: Ogmios['NextTxResponse'], args: { fields: 'all' }): (TxAlonzo | null)
export function handleNextTxResponse (response: Ogmios['NextTxResponse']): (TxId | null)
export function handleNextTxResponse (response: Ogmios['NextTxResponse'], args?: { fields: 'all' }): (TxId | TxAlonzo | null) {
const { result } = response
if (args.fields === 'all') {
if (args?.fields === 'all') {
if (isNextTxResultAll(result)) {
return result
}
63806154.0756fc9a9e9ce0fb8502ed0c1e26f43dfba32f4ea2cfbb667fe4c08759ebd423 => [{"witness":{"signatures":{"b0e76e8978f20ee4ac658cc79b821723dc596961e4962c713e5f67e67cc5223b":"zc1vAHAiP+NQI0qTTLyRHz5oDayCFKV0rb4rIRA18D9YsPEsjFvJ583Pwjg2EwN3yoZNQuE3hkpHU5ksAxUTBQ=="},"scripts":{"51936f3c98a04b6609aa9b5c832ba1182cf43a58e534fcc05db09d69":{"plutus:v2":"46010000222601"}},"datums":{"15461aa490b224fe541f3568e5d7704e0d88460cde9f418f700e2b6864d8d3c9":"19077a"},"redeemers":{"spend:0":{"redeemer":"187b","executionUnits":{"memory":10,"steps":10}}},"bootstrap":[]},"raw":"hKcAgYJYIFS05ONKAiQk5EGwDYpz6arvcbPGMITnYkbTJgdMXTdWAQ2BglggFvIAkM3+SxFdNdJc4WbuYQsI/QbJ5Vuy+k5siCmeiHMAAYGiAFg5AGePzU3GukREQFLPnJNFruOhB+JEc5It0FT4krXDMUhMUQ+fjMyxMnrEZaHAj4N98wcpH6I9b3FvARoC3GwAEKIAWDkAZ4/NTca6RERAUs+ck0Wu46EH4kRzki3QVPiStcMxSExRD5+MzLEyesRlocCPg33zBykfoj1vcW8BGgBqz8ARGgAtxsACGgAehIALWCDH4f/GOnBFDGb3Fym0FuggXLjae9p2diOV8xOsrZmIw6QAgYJYILDnbol48g7krGWMx5uCFyPcWWlh5JYscT5fZ+Z8xSI7WEDNzW8AcCI/41AjSpNMvJEfPmgNrIIUpXStvishEDXwP1iw8SyMW8nnzc/CODYTA3fKhk1C4TeGSkdTmSwDFRMFBoFHRgEAACImAQSBGQd6BYGEAAAYe4IKCvT2","id":"26d6c82e535507470dd0defe3a10597241d13c43d6b5a88068d9515c38c86969","body":{"inputs":[{"txId":"54b4e4e34a022424e441b00d8a73e9aaef71b3c63084e76246d326074c5d3756","index":1}],"collaterals":[{"txId":"16f20090cdfe4b115d35d25ce166ee610b08fd06c9e55bb2fa4e6c88299e8873","index":0}],"references":[],"collateralReturn":{"address":"addr_test1qpncln2dc6ayg3zq2t8eey694m36zplzg3eeytws2nuf9dwrx9yyc5g0n7xvevfj0tzxtgwq37phmuc89y06y0t0w9hscrzesh","value":{"coins":7000000,"assets":{}},"datumHash":null,"datum":null,"script":null},"totalCollateral":3000000,"outputs":[{"address":"addr_test1qpncln2dc6ayg3zq2t8eey694m36zplzg3eeytws2nuf9dwrx9yyc5g0n7xvevfj0tzxtgwq37phmuc89y06y0t0w9hscrzesh","value":{"coins":48000000,"assets":{}},"datumHash":null,"datum":null,"script":null}],"certificates":[],"withdrawals":{},"fee":2000000,"validityInterval":{"invalidBefore":null,"invalidHereafter":null},"update":null,"mint":{"coins":0,"assets":{}},"network":null,"scriptIntegrityHash":"c7e1ffc63a70450c66f71729b416e8205cb8da7bda76762395f313acad9988c3","requiredExtraSignatures":[]},"metadata":null,"inputSource":"collaterals"}]
const WebSocket = require('ws');
const client = new WebSocket("ws://localhost:1337");
function wsp(methodname, args = {}, mirror) {
client.send(JSON.stringify({
type: "jsonwsp/request",
version: "1.0",
servicename: "ogmios",
methodname,
args,
mirror
}));
}
client.on('message', function(msg) {
const response = JSON.parse(msg);
if (!response.result.RollForward) {
return wsp("RequestNext");
}
const block = response.result.RollForward.block;
const era = Object.keys(block)[0];
if (era === "byron") {
return wsp("RequestNext");
}
block[era]
.body
.forEach((tx, ix) => {
if (tx.inputSource == 'collaterals' && tx.body.collateralReturn != null) {
const tx_ix = ('0000' + ix.toString(16)).slice(-4);
const out_ix = ('0000' + tx.body.outputs.length.toString(16)).slice(-4);
console.log(`INSERT INTO inputs(ext_output_reference, address, value, datum_info, script_hash, created_at, spent_at) SELECT x'${tx.id}${out_ix}${tx_ix}', address, value, datum_info, script_hash, created_at, spent_at FROM inputs WHERE output_reference = x'${tx.id}0000';`);
console.log(`DELETE FROM inputs WHERE output_reference = x'${tx.id}0000';`);
console.log("");
}
});
const tip = response.result.RollForward.tip.blockNo;
const current = block[era].header.blockHeight;
if (tip - current < 100) {
console.error(`${block[era].header.slot}.${block[era].headerHash}`);
client.close();
} else {
wsp("RequestNext");
}
});
client.once('open', () => {
wsp("FindIntersect", { points: [ { "slot": 72316796, "hash": "c58a24ba8203e7629422a24d9dc68ce2ed495420bf40d9dab124373655161a20" } ] });
for (let i = 0; i < 100; i += 1) {
wsp("RequestNext");
}
});
weight = 5
+++
As described in the [Local Tx Monitor](/mini-protocols/local-tx-monitor/) user guide, Ogmios gives ways to inspect the attached node's mempool. A new `TxMonitorClient` can be created using an interaction context and be used to run many queries.
As described in the [Local Tx Monitor](/mini-protocols/local-tx-monitor/) user guide, Ogmios gives ways to inspect the attached node's mempool. A new `TxMonitorClient` can be created using an interaction context and be used to run many queries.
Note that all queries are blocking on this client and in particular, the `awaitAcquire` query. The latter will only return once a new snapshot (that is, different from the one currently acquired, if any) can be acquired. It can therefore be used as a notification mechanism to automatically 'wake up' when something has changed in the mempool.
Note that all queries are blocking on this client and in particular, the `awaitAcquire` query. The latter will only return once a new snapshot (that is, different from the one currently acquired, if any) can be acquired. It can therefore be used as a notification mechanism to automatically 'wake up' when something has changed in the mempool.
A typical usage of the mempool consist of acquiring a snapshot, get all the transactions in the mempool, and then wait for a new snapshot to become available. The complete API reference can be found [here](/typescript/api/modules/_cardano_ogmios_client.TxMonitor.html).
```ts
import { createTxMonitorClient, TxMonitor } from '@cardano-ogmios/client'
import { TxId } from '@cardano-ogmios/schema'
const client = await createTxMonitorClient(context)
await client.release()
// A recursive function to fetch the 'nextTx' until there's no more to fetch.
async function fetchAllTxs(client) {
async function fetchAllTxs(client: TxMonitor.TxMonitorClient): Promise<TxId[]> {
const tx = await client.nextTx()
if (tx === null) {
return []
}
return [tx].concat(await fetchAllTxs(client))
}
```
![github-actions[bot]](https://avatars.githubusercontent.com/in/15368?v=4&s=80)
Adding Milkomeda Open Oracle dev guide
![iohk-bors[bot]](https://avatars.githubusercontent.com/in/17473?v=4&s=80)
3815: Cleanup nix setup: remove unused cabal shell r=Unisay a=Unisay ### Overview This pull request cleans up our `flake.nix` configuration by * removing the unused `cabal-shell.nix` * making explicit which shell is created when doing `nix develop` (it's `….devShells.default`). ### Issue Number ADP-2447 Co-authored-by: Yura Lazarev <[email protected]>
fix CI not running on bors branches
5023: fix CI not running on bors branches r=disassembler a=dermetfan Looks like this was broken in #4930 as `prAndBorsIo` was added but not used. Also removed `nix` from the task name. I do not see what purpose it has and it makes the names unnecessarily long. Also we happen to need the old names in #5018. Co-authored-by: Robin Stumm <[email protected]>
I don't trust it. Compare these two runs: 1. https://github.com/input-output-hk/cardano-haskell-packages/actions/runs/4532746158/jobs/7984714895 2. https://github.com/input-output-hk/cardano-haskell-packages/actions/runs/4516172089/jobs/7954255360 The second is on the parent commit of the first, the commit itself is a no-op, and yet the derivations they build are not the same! Doing the same locally, I get a) a different derivation, but b) the same derivation for both. I conclude that what the CI is doing is questionable, the cache seems like the most likely source of pollution. I suspect whatever is causing this was also responsible for the no-op PR spending a lot of time building tons of stuff.
* Update readme (cli flags, comment dsl, new format) * Document the comment DSL * Document CLI flags * Mention new split rust/wasm output structure * Remove unsupported section (to handle in issues instead as this tends to get very outdated) * respond to comments + add supported.cddl * minor fixes for comment placement in supported.cddl + remove unsupported optional fixed value from example
There's an issue with the `deriving via` clause for OneEraHeader: * `show`ing a `NS Header (CardanoEras StandardCrypto BatchCompatibleCrypto)` works fine * `show`ing a `OneEraHeader (CardanoEras ...)` yields the annoying error message about not being able to handle 2 different cryptos Using forAllBlind in the property removes the QC requirement to be able to `Show` the generated values which makes it work.
