streamflow 0.1.1

Solana program for streamflow.finance
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43

#!/usr/bin/env python3
import asyncio
import json
import websockets

connected = set()
prog_addr = "3ujtFXCGGRoWpJ1rKeeKBase18qoaCXDX7MCTKaMj89g"
ws_uri = "wss://api.mainnet-beta.solana.com/"
# ws_uri = "ws://localhost:8900/"


def parse_msg(msg):
    if not msg.get("jsonrpc") or not msg.get("params"):
        print(msg)
        return

    print(msg["params"]["result"]["value"]["logs"][7].split()[-1])


async def main():
    connected.add(ws_uri)
    try:
        async with websockets.connect(ws_uri, ssl=True) as ws:  # pylint: disable=E1101
            sub = {
                "jsonrpc": "2.0",
                "id": 42,
                "method": "logsSubscribe",
                "params": [  # ["all"],
                    {
                        "mentions": [prog_addr]
                    }
                ],
            }
            await ws.send(json.dumps(sub))
            while True:
                parse_msg(json.loads(await ws.recv()))
    finally:
        connected.remove(ws_uri)


if __name__ == "__main__":
    while True:
        asyncio.get_event_loop().run_until_complete(main())