A comprehensive Substreams package that captures all Polymarket trading data and P&L calculations, perfectly matching the Dune Analytics query structure.
python3 examples/test_scripts/test_proper_endpoint.py
python3 scripts/stream_7days_proper.py
The script will create a comprehensive Dune-style dashboard with:
src/
├── lib.rs # Main processing logic
├── abi.rs # ABI decoding functions
└── ...
proto/
└── contract.proto # Protobuf message definitions
scripts/
├── stream_7days_proper.py # Main 7-day streaming
├── stream_7days_simple.py # Simplified streaming
└── stream_recent_data.py # Recent data streaming
examples/
├── old_dashboards/ # Dashboard implementations
└── test_scripts/ # Testing utilities
The package uses the official Polygon endpoint:
polygon.streamingfast.io:443
Perfect match with Dune query structure:
{
"userPnls": [...], // User P&L data
"marketData": [...], // Market information
"tokenTransfers": [...], // ERC1155 transfers
"orderFills": [...], // Trading orders
"rewardClaims": [...] // Liquidity rewards
}
This Substreams package provides 100% data structure compatibility with:
Ready to build your Polymarket leaderboard! 🎉
substreams gui polymarket-dune-pure@v0.4.1 map_ctf_exchange_token_registered
substreams gui polymarket-dune-pure@v0.4.1 map_neg_risk_ctf_exchange_token_registered
substreams gui polymarket-dune-pure@v0.4.1 map_fpmm_factory_creation
substreams gui polymarket-dune-pure@v0.4.1 map_ctf_exchange_order_filled
substreams gui polymarket-dune-pure@v0.4.1 map_neg_risk_ctf_exchange_order_filled
substreams gui polymarket-dune-pure@v0.4.1 map_erc1155_transfer_single
substreams gui polymarket-dune-pure@v0.4.1 map_erc1155_transfer_batch
substreams gui polymarket-dune-pure@v0.4.1 map_erc20_transfer
substreams gui polymarket-dune-pure@v0.4.1 map_uma_merkle_distributor
substreams gui polymarket-dune-pure@v0.4.1 map_usdc_merkle_distributor
substreams gui polymarket-dune-pure@v0.4.1 map_ctf_events
substreams gui polymarket-dune-pure@v0.4.1 map_usdc_events
substreams gui polymarket-dune-pure@v0.4.1 map_pure_dune_pnl
all_events
gives you all the events in a block (from successful transactions), with basic block hash/number/timestamp and transaction hash
substreams gui polymarket-dune-pure@v0.4.1 ethcommon:all_events
index_events
sets the following keys on the block:
substreams gui polymarket-dune-pure@v0.4.1 ethcommon:index_events
message
DeployRequest
message
Parameter
message
DeployResponse
message
UpdateRequest
message
UpdateResponse
message
InfoRequest
message
InfoResponse
message
SinkProgress
message
PackageInfo
message
ListRequest
message
ListResponse
message
DeploymentWithStatus
message
RemoveRequest
message
RemoveResponse
message
PauseRequest
message
PauseResponse
message
StopRequest
message
StopResponse
message
ResumeRequest
message
ResumeResponse
enum
DeploymentStatus
message
Calls
message
Call
message
Events
message
Event
message
EventsAndCalls
message
Transactions
message
Transaction
enum
DetailLevel
message
Modules
message
Binary
message
Module
message
Package
message
PackageMetadata
message
ModuleMetadata
message
Clock
message
BlockRef
message
FileDescriptorSet
message
FileDescriptorProto
message
DescriptorProto
message
ExtensionRangeOptions
message
FieldDescriptorProto
message
OneofDescriptorProto
message
EnumDescriptorProto
message
EnumValueDescriptorProto
message
ServiceDescriptorProto
message
MethodDescriptorProto
message
FileOptions
message
MessageOptions
message
FieldOptions
message
OneofOptions
message
EnumOptions
message
EnumValueOptions
message
ServiceOptions
message
MethodOptions
message
UninterpretedOption
message
SourceCodeInfo
message
GeneratedCodeInfo
message
Any
message
Timestamp
message
Duration
message
Request
message
Response
message
BlockUndoSignal
message
BlockScopedData
message
SessionInit
message
InitialSnapshotComplete
message
InitialSnapshotData
message
MapModuleOutput
message
StoreModuleOutput
message
OutputDebugInfo
message
ModulesProgress
message
ModuleProgress
message
BlockRange
message
StoreDelta
message
Block
message
BlockHeader
message
Uint64NestedArray
message
Uint64Array
message
BigInt
message
TransactionTrace
message
AccessTuple
message
TransactionReceipt
message
Log
message
Call
message
StorageChange
message
BalanceChange
message
NonceChange
message
AccountCreation
message
CodeChange
message
GasChange
message
HeaderOnlyBlock
message
BlockWithRefs
message
TransactionTraceWithBlockRef
message
TransactionRefs
message
BlockRef
enum
TransactionTraceStatus
enum
CallType
message
RpcCalls
message
RpcCall
message
RpcResponses
message
RpcResponse
message
PureDunePnL
message
DuneUserPnL
message
DuneMarketData
message
DuneTokenTransfer
message
DuneOrderFill
message
DuneRewardClaim
message
DunePriceData
message
DuneTokenHolding
message
TokenRegisteredEvents
message
TokenRegistered
message
NegRiskTokenRegisteredEvents
message
NegRiskTokenRegistered
message
OrderFilledEvents
message
OrderFilled
message
FpmmFactoryEvents
message
FpmmFactoryCreation
message
Erc1155TransferSingleEvents
message
Erc1155TransferSingle
message
Erc1155TransferBatchEvents
message
Erc1155TransferBatch
message
Erc20TransferEvents
message
Erc20Transfer
message
MerkleDistributorEvents
message
MerkleDistributorClaimed
message
CtfEvents
message
UsdcEvents
message
Ctf_ConditionPreparation
message
Ctf_ConditionResolution
message
Ctf_PositionSplit
message
Ctf_PositionMerge
message
Ctf_PositionRedeem
message
Ctf_TransferSingle
message
Ctf_TransferBatch
message
Usdc_Transfer
message
Usdc_Approval