Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
28 commits
Select commit Hold shift + click to select a range
277787c
llo/channeldefinitions: support for multiple channel definition sources
brunotm Nov 12, 2025
b6ae047
llo/channeldefinitions: improve comments
brunotm Nov 15, 2025
64e05c5
llo/channeldefinitions: add channel adder limits
brunotm Nov 17, 2025
6494eb9
llo/channeldefinitions: remove errAdderAdditionsLimitExceeded check t…
brunotm Nov 20, 2025
fef2ecf
llo/channeldefinitions: don't merge logs and avoid re-sorting them
brunotm Nov 21, 2025
fc089d4
llo/channeldefinitions: reconcile source with previous outcome channe…
brunotm Nov 21, 2025
897f168
llo/channeldefinitions: process definitions deterministically
brunotm Nov 25, 2025
25f8128
llo/channeldefinitions: persist source definitions
brunotm Nov 25, 2025
ac740a4
llo/channeldefinitions: owner can tombstone its own channels.
brunotm Nov 25, 2025
c1ca5ea
llo/channeldefinitions: cache format migration
brunotm Nov 26, 2025
802666e
llo/channeldefinitions: channel definitions reconciliation integratio…
brunotm Dec 2, 2025
00e8fb0
llo/channeldefinitions: check adder limits against previous definitio…
brunotm Dec 4, 2025
f9663f3
llo/channeldefinitions: owner tombstones integration tests
brunotm Dec 4, 2025
f94ef49
llo/channeldefinitions: check for feedID collisions in proposed chann…
brunotm Dec 5, 2025
db58330
llo/channeldefinitions: LLO merging integration test
brunotm Dec 5, 2025
5f84bbd
llo/channeldefinitions: fix mergeDefinitions behaviour when adder lim…
brunotm Dec 10, 2025
8bd18a4
llo/channeldefinitions: ensure a default timeout when the context has…
brunotm Dec 10, 2025
d4fc2cf
llo/channeldefinitions: ensure processLogs termination on close
brunotm Dec 10, 2025
f02675a
llo/channeldefinitions: don't immediatelly free updated owner feed id…
brunotm Dec 10, 2025
e8f3b0f
llo/channeldefinitions: update comments and ensure we close response …
brunotm Dec 10, 2025
cff86e7
llo/channeldefinitions: ensure multiple triggers at the same block nu…
brunotm Dec 10, 2025
ef3c005
llo/channeldefinitions: update tests to latest contract constraints
brunotm Dec 10, 2025
af4f8dd
llo/cre: report codec can accept parsed ops
brunotm Dec 11, 2025
3c4c50d
llo/channeldefinitions: bump chainlink-evm/chainlink-common/chainlink…
brunotm Dec 11, 2025
7dc31f8
linting fixes
brunotm Dec 11, 2025
d1c74ad
llo/channeldefinitions: orm allows same block version persist
brunotm Dec 11, 2025
a16bbd6
llo/channeldefinitions: allow for concurrent fetch operations up to d…
brunotm Dec 12, 2025
fb9c227
changeset
brunotm Dec 11, 2025
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
5 changes: 5 additions & 0 deletions .changeset/nervous-shrimps-refuse.md
Original file line number Diff line number Diff line change
@@ -0,0 +1,5 @@
---
"chainlink": minor
---

#added LLO plugin channel adder support
Original file line number Diff line number Diff line change
Expand Up @@ -128,7 +128,7 @@ func MakeOCRTriggerEvent(lggr logger.Logger, reports *datastreams.LLOStreamsTrig
}

// Encode the report to bytes
reportBytes, err := reportCodec.Encode(report, channelDef)
reportBytes, err := reportCodec.Encode(report, channelDef, nil)
if err != nil {
return nil, "", fmt.Errorf("failed to encode report: %w", err)
}
Expand Down
12 changes: 11 additions & 1 deletion core/internal/testutils/testutils.go
Original file line number Diff line number Diff line change
Expand Up @@ -167,7 +167,17 @@ func WaitForLogMessage(t *testing.T, observedLogs *observer.ObservedLogs, msg st
func WaitForLogMessageWithField(t *testing.T, observedLogs *observer.ObservedLogs, msg, field, value string) (le observer.LoggedEntry) {
RequireEventually(t, func() bool {
for _, l := range observedLogs.All() {
if strings.Contains(l.Message, msg) && strings.Contains(l.ContextMap()[field].(string), value) {
if !strings.Contains(l.Message, msg) {
continue
}
ctxMap := l.ContextMap()
fieldValue, exists := ctxMap[field]
if !exists {
continue
}
// Convert field value to string for comparison, handling all types
fieldValueStr := fmt.Sprintf("%v", fieldValue)
if strings.Contains(fieldValueStr, value) {
le = l
return true
}
Expand Down
6 changes: 3 additions & 3 deletions core/scripts/go.mod
Original file line number Diff line number Diff line change
Expand Up @@ -47,11 +47,11 @@ require (
github.com/shopspring/decimal v1.4.0
github.com/smartcontractkit/chainlink-automation v0.8.1
github.com/smartcontractkit/chainlink-ccip v0.1.1-solana.0.20251128020529-88d93b01d749
github.com/smartcontractkit/chainlink-common v0.9.6-0.20251210225051-4659b78ac2a8
github.com/smartcontractkit/chainlink-data-streams v0.1.7-0.20251209111830-ccd12a5b2a19
github.com/smartcontractkit/chainlink-common v0.9.6-0.20251211140724-319861e514c4
github.com/smartcontractkit/chainlink-data-streams v0.1.7
github.com/smartcontractkit/chainlink-deployments-framework v0.70.0
github.com/smartcontractkit/chainlink-evm v0.3.4-0.20251210110629-10c56e8d2cec
github.com/smartcontractkit/chainlink-evm/gethwrappers v0.0.0-20251022075638-49d961001d1b
github.com/smartcontractkit/chainlink-evm/gethwrappers v0.0.0-20251211123524-f0c4fe7cfc0a
github.com/smartcontractkit/chainlink-protos/cre/go v0.0.0-20251124151448-0448aefdaab9
github.com/smartcontractkit/chainlink-protos/job-distributor v0.17.0
github.com/smartcontractkit/chainlink-testing-framework/framework v0.12.1
Expand Down
12 changes: 6 additions & 6 deletions core/scripts/go.sum
Original file line number Diff line number Diff line change
Expand Up @@ -1634,20 +1634,20 @@ github.com/smartcontractkit/chainlink-ccip/deployment v0.0.0-20251027185542-babb
github.com/smartcontractkit/chainlink-ccip/deployment v0.0.0-20251027185542-babb09e5363e/go.mod h1:IaoLCQE1miX3iUlQNxOPcVrXrshcO/YsFpxnFuhG9DM=
github.com/smartcontractkit/chainlink-ccv v0.0.0-20251210114515-e8434089d599 h1:0IMjHpzI9mgvGGtmsr1NdRhoXp++gU805f/f9oN94ls=
github.com/smartcontractkit/chainlink-ccv v0.0.0-20251210114515-e8434089d599/go.mod h1:Ysd/qkofD0bepk29RS7Q4ZlVDd4yAHXucYsp5gAy6AE=
github.com/smartcontractkit/chainlink-common v0.9.6-0.20251210225051-4659b78ac2a8 h1:b8aHhus/+bikhHlR5+Ll4Z0hsczJPA0hEj68/8+xyXs=
github.com/smartcontractkit/chainlink-common v0.9.6-0.20251210225051-4659b78ac2a8/go.mod h1:uRnGLHKo56QYaPk93z0NRAIgv115lh72rzG40CiE1Mk=
github.com/smartcontractkit/chainlink-common v0.9.6-0.20251211140724-319861e514c4 h1:i1Vi+c3Zptqgpvj99IOJZcux6OdYl/2X1QM/fudALP8=
github.com/smartcontractkit/chainlink-common v0.9.6-0.20251211140724-319861e514c4/go.mod h1:uRnGLHKo56QYaPk93z0NRAIgv115lh72rzG40CiE1Mk=
github.com/smartcontractkit/chainlink-common/pkg/chipingress v0.0.10 h1:FJAFgXS9oqASnkS03RE1HQwYQQxrO4l46O5JSzxqLgg=
github.com/smartcontractkit/chainlink-common/pkg/chipingress v0.0.10/go.mod h1:oiDa54M0FwxevWwyAX773lwdWvFYYlYHHQV1LQ5HpWY=
github.com/smartcontractkit/chainlink-common/pkg/monitoring v0.0.0-20250415235644-8703639403c7 h1:9wh1G+WbXwPVqf0cfSRSgwIcaXTQgvYezylEAfwmrbw=
github.com/smartcontractkit/chainlink-common/pkg/monitoring v0.0.0-20250415235644-8703639403c7/go.mod h1:yaDOAZF6MNB+NGYpxGCUc+owIdKrjvFW0JODdTcQ3V0=
github.com/smartcontractkit/chainlink-data-streams v0.1.7-0.20251209111830-ccd12a5b2a19 h1:gU4suSMid2uQVSxdtPhqGR9s9w3ViclcGtwkQaNbrtM=
github.com/smartcontractkit/chainlink-data-streams v0.1.7-0.20251209111830-ccd12a5b2a19/go.mod h1:GPsn6PKJvPe1UfRYyVxsDzOWq6NILzBstiiLq/w+kG0=
github.com/smartcontractkit/chainlink-data-streams v0.1.7 h1:Mwb69azs8hsKyxw93zmLMLDK0QpkF7mZa9PK9eGsG3g=
github.com/smartcontractkit/chainlink-data-streams v0.1.7/go.mod h1:8rUcGhjeXBoTFx2MynWgXiBWzVSB+LXd9JR6m8y2FfQ=
github.com/smartcontractkit/chainlink-deployments-framework v0.70.0 h1:wo2KL2viGZK/LhHLM8F88sRyhZF9wwWh+YDzW8hS00g=
github.com/smartcontractkit/chainlink-deployments-framework v0.70.0/go.mod h1:Cp7PuO7HUDugp7bWGP/TcDAvvvkFLdKOVrSm0zXlnhg=
github.com/smartcontractkit/chainlink-evm v0.3.4-0.20251210110629-10c56e8d2cec h1:K8sLjgwPgozQb86LH+aWXqBUJak6VGwSt5YiKbCI/uY=
github.com/smartcontractkit/chainlink-evm v0.3.4-0.20251210110629-10c56e8d2cec/go.mod h1:9VcrUs+H/f9ekkqAdfUd70Pk2dA1Zc3KykJVFBfJNHs=
github.com/smartcontractkit/chainlink-evm/gethwrappers v0.0.0-20251022075638-49d961001d1b h1:Dqhm/67Sb1ohgce8FW6tnK1CRXo2zoLCbV+EGyew5sg=
github.com/smartcontractkit/chainlink-evm/gethwrappers v0.0.0-20251022075638-49d961001d1b/go.mod h1:oyfOm4k0uqmgZIfxk1elI/59B02shbbJQiiUdPdbMgI=
github.com/smartcontractkit/chainlink-evm/gethwrappers v0.0.0-20251211123524-f0c4fe7cfc0a h1:kVKWRGrSCioMY2lEVIEblerv/KkINIQS2hLUOw2wKOg=
github.com/smartcontractkit/chainlink-evm/gethwrappers v0.0.0-20251211123524-f0c4fe7cfc0a/go.mod h1:oyfOm4k0uqmgZIfxk1elI/59B02shbbJQiiUdPdbMgI=
github.com/smartcontractkit/chainlink-feeds v0.1.2-0.20250227211209-7cd000095135 h1:8u9xUrC+yHrTDexOKDd+jrA6LCzFFHeX1G82oj2fsSI=
github.com/smartcontractkit/chainlink-feeds v0.1.2-0.20250227211209-7cd000095135/go.mod h1:NkvE4iQgiT7dMCP6U3xPELHhWhN5Xr6rHC0axRebyMU=
github.com/smartcontractkit/chainlink-framework/capabilities v0.0.0-20250818175541-3389ac08a563 h1:ACpDbAxG4fa4sA83dbtYcrnlpE/y7thNIZfHxTv2ZLs=
Expand Down
Loading
Loading