Skip to content

Commit

Permalink
added tests for metricsCounterStore
Browse files Browse the repository at this point in the history 
Signed-off-by: munishchouhan <[email protected]>
  • Loading branch information
@munishchouhan
munishchouhan committed Feb 5, 2025
1 parent ab62cd6 commit 8ef38ab
Show file tree
Hide file tree
Showing 2 changed files with 57 additions and 14 deletions.
35 changes: 28 additions & 7 deletions src/test/groovy/io/seqera/wave/service/metric/MetricsCounterStoreLocalTest.groovy
View file
Original file line number Diff line number Diff line change
Expand Up @@ -57,13 +57,27 @@ class MetricsCounterStoreLocalTest extends Specification {
metricsCounterStore.inc('builds/o/bar.org/d/2024-05-30')
metricsCounterStore.inc('fusion/o/bar.in/d/2024-05-30')
metricsCounterStore.inc('pulls/o/bar.in/d/2024-05-31')
metricsCounterStore.inc('builds/a/arm64')
metricsCounterStore.inc('builds/a/amd64')
metricsCounterStore.inc('builds/a/arm64/d/2024-05-30')
metricsCounterStore.inc('pulls/o/bar.in/a/amd64')
metricsCounterStore.inc('pulls/o/foo.com/a/arm64')
metricsCounterStore.inc('pulls/o/foo.com/a/amd64/d/2024-05-29')
metricsCounterStore.inc('builds/o/bar.org/a/arm64/d/2024-05-30')
metricsCounterStore.inc('fusion/o/bar.in/a/amd64/d/2024-05-30')
metricsCounterStore.inc('pulls/o/bar.in/a/arm64/d/2024-05-31')

then:
metricsCounterStore.getAllMatchingEntries('builds/o/*') == ['builds/o/foo.com':1, 'builds/o/bar.org':1, 'builds/o/bar.org/d/2024-05-30':1]
metricsCounterStore.getAllMatchingEntries('pulls/o/*') == ['pulls/o/bar.in':1, 'pulls/o/foo.com/d/2024-05-29':1, 'pulls/o/bar.in/d/2024-05-31':1]
metricsCounterStore.getAllMatchingEntries('fusion/o/*') == ['fusion/o/bar.in/d/2024-05-30':1]
metricsCounterStore.getAllMatchingEntries('builds/o/*/d/2024-05-30') == ['builds/o/bar.org/d/2024-05-30':1]
metricsCounterStore.getAllMatchingEntries('builds/o/*') == ['builds/o/foo.com':1, 'builds/o/bar.org':1, 'builds/o/bar.org/d/2024-05-30':1, 'builds/o/bar.org/a/arm64/d/2024-05-30':1]
metricsCounterStore.getAllMatchingEntries('pulls/o/*') == ['pulls/o/bar.in/a/amd64':1, 'pulls/o/bar.in':1, 'pulls/o/bar.in/a/arm64/d/2024-05-31':1, 'pulls/o/foo.com/a/arm64':1,
'pulls/o/foo.com/d/2024-05-29':1, 'pulls/o/bar.in/d/2024-05-31':1, 'pulls/o/foo.com/a/amd64/d/2024-05-29':1]
metricsCounterStore.getAllMatchingEntries('fusion/o/*') == ['fusion/o/bar.in/a/amd64/d/2024-05-30':1, 'fusion/o/bar.in/d/2024-05-30':1]
metricsCounterStore.getAllMatchingEntries('builds/o/*/d/2024-05-30') == ['builds/o/bar.org/d/2024-05-30':1, 'builds/o/bar.org/a/arm64/d/2024-05-30':1]
metricsCounterStore.getAllMatchingEntries('pulls/o/bar.in/d/2024-05-31') == ['pulls/o/bar.in/d/2024-05-31':1]
metricsCounterStore.getAllMatchingEntries('builds/a/arm64') == ['builds/a/arm64':1]
metricsCounterStore.getAllMatchingEntries('builds/a/arm64*') == ['builds/a/arm64':1, 'builds/a/arm64/d/2024-05-30':1]
metricsCounterStore.getAllMatchingEntries('pulls/o/*/a/amd64') == ['pulls/o/bar.in/a/amd64':1]
metricsCounterStore.getAllMatchingEntries('fusion/o/*/a/amd64/d/2024-05-30') == ['fusion/o/bar.in/a/amd64/d/2024-05-30':1]
}

def 'should get correct org count value for mirror and scan' () {
Expand All @@ -74,11 +88,18 @@ class MetricsCounterStoreLocalTest extends Specification {
metricsCounterStore.inc('scans/o/foo.com/d/2024-05-29')
metricsCounterStore.inc('mirrors/o/bar.org/d/2024-05-30')
metricsCounterStore.inc('scans/o/bar.in/d/2024-05-31')
metricsCounterStore.inc('scans/a/arm64')
metricsCounterStore.inc('mirrors/o/foo.com/a/arm64')
metricsCounterStore.inc('scans/o/foo.com/a/arm64/d/2024-05-29')
metricsCounterStore.inc('mirrors/o/bar.org/a/arm64/d/2024-05-30')

then:
metricsCounterStore.getAllMatchingEntries('mirrors/o/*') == ['mirrors/o/foo.com':1, 'mirrors/o/bar.org':1, 'mirrors/o/bar.org/d/2024-05-30':1]
metricsCounterStore.getAllMatchingEntries('scans/o/*') == ['scans/o/bar.in':1, 'scans/o/foo.com/d/2024-05-29':1, 'scans/o/bar.in/d/2024-05-31':1]
metricsCounterStore.getAllMatchingEntries('mirrors/o/*/d/2024-05-30') == ['mirrors/o/bar.org/d/2024-05-30':1]
metricsCounterStore.getAllMatchingEntries('mirrors/o/*') == ['mirrors/o/foo.com':1, 'mirrors/o/bar.org':1, 'mirrors/o/foo.com/a/arm64':1, 'mirrors/o/bar.org/d/2024-05-30':1, 'mirrors/o/bar.org/a/arm64/d/2024-05-30':1]
metricsCounterStore.getAllMatchingEntries('scans/o/*') == ['scans/o/bar.in':1, 'scans/o/foo.com/d/2024-05-29':1, 'scans/o/foo.com/a/arm64/d/2024-05-29':1, 'scans/o/bar.in/d/2024-05-31':1]
metricsCounterStore.getAllMatchingEntries('mirrors/o/*/d/2024-05-30') == ['mirrors/o/bar.org/d/2024-05-30':1, 'mirrors/o/bar.org/a/arm64/d/2024-05-30':1]
metricsCounterStore.getAllMatchingEntries('scans/o/bar.in/d/2024-05-31') == ['scans/o/bar.in/d/2024-05-31':1]
metricsCounterStore.getAllMatchingEntries('scans/a/arm64') == ['scans/a/arm64':1]
metricsCounterStore.getAllMatchingEntries('mirrors/o/bar.org/a/arm64/d/2024-05-30') == ['mirrors/o/bar.org/a/arm64/d/2024-05-30':1]
metricsCounterStore.getAllMatchingEntries('mirrors/o/foo.com/a/arm64*') == ['mirrors/o/foo.com/a/arm64':1]
}
}
36 changes: 29 additions & 7 deletions src/test/groovy/io/seqera/wave/service/metric/MetricsCounterStoreRedisTest.groovy
View file
Original file line number Diff line number Diff line change
Expand Up @@ -70,6 +70,7 @@ class MetricsCounterStoreRedisTest extends Specification implements RedisTestCo
given:
def metricsCounterStore = applicationContext.getBean(MetricsCounterStore)

when:
when:
metricsCounterStore.inc('builds/o/foo.com')
metricsCounterStore.inc('builds/o/bar.org')
Expand All @@ -78,13 +79,27 @@ class MetricsCounterStoreRedisTest extends Specification implements RedisTestCo
metricsCounterStore.inc('builds/o/bar.org/d/2024-05-30')
metricsCounterStore.inc('fusion/o/bar.in/d/2024-05-30')
metricsCounterStore.inc('pulls/o/bar.in/d/2024-05-31')
metricsCounterStore.inc('builds/a/arm64')
metricsCounterStore.inc('builds/a/amd64')
metricsCounterStore.inc('builds/a/arm64/d/2024-05-30')
metricsCounterStore.inc('pulls/o/bar.in/a/amd64')
metricsCounterStore.inc('pulls/o/foo.com/a/arm64')
metricsCounterStore.inc('pulls/o/foo.com/a/amd64/d/2024-05-29')
metricsCounterStore.inc('builds/o/bar.org/a/arm64/d/2024-05-30')
metricsCounterStore.inc('fusion/o/bar.in/a/amd64/d/2024-05-30')
metricsCounterStore.inc('pulls/o/bar.in/a/arm64/d/2024-05-31')

then:
metricsCounterStore.getAllMatchingEntries('builds/o/*') == ['builds/o/foo.com':1, 'builds/o/bar.org':1, 'builds/o/bar.org/d/2024-05-30':1]
metricsCounterStore.getAllMatchingEntries('pulls/o/*') == ['pulls/o/bar.in':1, 'pulls/o/foo.com/d/2024-05-29':1, 'pulls/o/bar.in/d/2024-05-31':1]
metricsCounterStore.getAllMatchingEntries('fusion/o/*') == ['fusion/o/bar.in/d/2024-05-30':1]
metricsCounterStore.getAllMatchingEntries('builds/o/*/d/2024-05-30') == ['builds/o/bar.org/d/2024-05-30':1]
metricsCounterStore.getAllMatchingEntries('builds/o/*') == ['builds/o/foo.com':1, 'builds/o/bar.org':1, 'builds/o/bar.org/d/2024-05-30':1, 'builds/o/bar.org/a/arm64/d/2024-05-30':1]
metricsCounterStore.getAllMatchingEntries('pulls/o/*') == ['pulls/o/bar.in/a/amd64':1, 'pulls/o/bar.in':1, 'pulls/o/bar.in/a/arm64/d/2024-05-31':1, 'pulls/o/foo.com/a/arm64':1,
'pulls/o/foo.com/d/2024-05-29':1, 'pulls/o/bar.in/d/2024-05-31':1, 'pulls/o/foo.com/a/amd64/d/2024-05-29':1]
metricsCounterStore.getAllMatchingEntries('fusion/o/*') == ['fusion/o/bar.in/a/amd64/d/2024-05-30':1, 'fusion/o/bar.in/d/2024-05-30':1]
metricsCounterStore.getAllMatchingEntries('builds/o/*/d/2024-05-30') == ['builds/o/bar.org/d/2024-05-30':1, 'builds/o/bar.org/a/arm64/d/2024-05-30':1]
metricsCounterStore.getAllMatchingEntries('pulls/o/bar.in/d/2024-05-31') == ['pulls/o/bar.in/d/2024-05-31':1]
metricsCounterStore.getAllMatchingEntries('builds/a/arm64') == ['builds/a/arm64':1]
metricsCounterStore.getAllMatchingEntries('builds/a/arm64*') == ['builds/a/arm64':1, 'builds/a/arm64/d/2024-05-30':1]
metricsCounterStore.getAllMatchingEntries('pulls/o/*/a/amd64') == ['pulls/o/bar.in/a/amd64':1]
metricsCounterStore.getAllMatchingEntries('fusion/o/*/a/amd64/d/2024-05-30') == ['fusion/o/bar.in/a/amd64/d/2024-05-30':1]
}

def 'should get correct org count value for mirror and scan' () {
Expand All @@ -98,11 +113,18 @@ class MetricsCounterStoreRedisTest extends Specification implements RedisTestCo
metricsCounterStore.inc('scans/o/foo.com/d/2024-05-29')
metricsCounterStore.inc('mirrors/o/bar.org/d/2024-05-30')
metricsCounterStore.inc('scans/o/bar.in/d/2024-05-31')
metricsCounterStore.inc('scans/a/arm64')
metricsCounterStore.inc('mirrors/o/foo.com/a/arm64')
metricsCounterStore.inc('scans/o/foo.com/a/arm64/d/2024-05-29')
metricsCounterStore.inc('mirrors/o/bar.org/a/arm64/d/2024-05-30')

then:
metricsCounterStore.getAllMatchingEntries('mirrors/o/*') == ['mirrors/o/foo.com':1, 'mirrors/o/bar.org':1, 'mirrors/o/bar.org/d/2024-05-30':1]
metricsCounterStore.getAllMatchingEntries('scans/o/*') == ['scans/o/bar.in':1, 'scans/o/foo.com/d/2024-05-29':1, 'scans/o/bar.in/d/2024-05-31':1]
metricsCounterStore.getAllMatchingEntries('mirrors/o/*/d/2024-05-30') == ['mirrors/o/bar.org/d/2024-05-30':1]
metricsCounterStore.getAllMatchingEntries('mirrors/o/*') == ['mirrors/o/foo.com':1, 'mirrors/o/bar.org':1, 'mirrors/o/foo.com/a/arm64':1, 'mirrors/o/bar.org/d/2024-05-30':1, 'mirrors/o/bar.org/a/arm64/d/2024-05-30':1]
metricsCounterStore.getAllMatchingEntries('scans/o/*') == ['scans/o/bar.in':1, 'scans/o/foo.com/d/2024-05-29':1, 'scans/o/foo.com/a/arm64/d/2024-05-29':1, 'scans/o/bar.in/d/2024-05-31':1]
metricsCounterStore.getAllMatchingEntries('mirrors/o/*/d/2024-05-30') == ['mirrors/o/bar.org/d/2024-05-30':1, 'mirrors/o/bar.org/a/arm64/d/2024-05-30':1]
metricsCounterStore.getAllMatchingEntries('scans/o/bar.in/d/2024-05-31') == ['scans/o/bar.in/d/2024-05-31':1]
metricsCounterStore.getAllMatchingEntries('scans/a/arm64') == ['scans/a/arm64':1]
metricsCounterStore.getAllMatchingEntries('mirrors/o/bar.org/a/arm64/d/2024-05-30') == ['mirrors/o/bar.org/a/arm64/d/2024-05-30':1]
metricsCounterStore.getAllMatchingEntries('mirrors/o/foo.com/a/arm64*') == ['mirrors/o/foo.com/a/arm64':1]
}
}

0 comments on commit 8ef38ab

Please sign in to comment.