Skip to content

Commit bc50c89

Browse files
authored
Schema Refactor Fixes (#101)
* 👀 * fix all tests
1 parent b62a2be commit bc50c89

5 files changed

Lines changed: 13 additions & 5 deletions

File tree

src/integrations/postgres/shared.ts

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,15 @@ import { TransformerTree, parseRowsWithTransformers } from "./transformer"
55

66
const logger = new Logger("POSTGRES")
77

8-
export const TABLE_SCHEMAS = ["raw", "public"]
8+
export const TABLE_SCHEMAS = [
9+
"core",
10+
"definitions",
11+
"clan",
12+
"flagging",
13+
"leaderboard",
14+
"extended",
15+
"raw"
16+
]
917

1018
export type QueryParams = unknown[]
1119

src/services/atlas/atlas.test.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -112,6 +112,6 @@ describe("getAtlasStatus no mock", () => {
112112
const result = await getAtlasStatus()
113113

114114
expect(result.isCrawling).toBeTrue()
115-
expect(result.lag).toBeWithin(15, 80)
115+
expect(result.lag).toBeWithin(10, 120)
116116
})
117117
})

src/services/atlas/index.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,7 @@ export const getAtlasStatus = async (): Promise<
1616
> => {
1717
const now = Date.now()
1818
const queryRangeResponse = await promQueryRange({
19-
query: "histogram_quantile(0.50, sum(rate(pgcr_crawl_summary_lag_bucket[2m])) by (le))",
19+
query: "histogram_quantile(0.50, sum(rate(pgcr_crawl_summary_lag_seconds_bucket[2m])) by (le))",
2020
start: new Date(now - intervalMins * 60000),
2121
end: new Date(now),
2222
step

src/services/clans/clan-stats.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,7 @@ export const getClanStats = async (
2828
'displayName', player."display_name",
2929
'bungieGlobalDisplayName', player."bungie_global_display_name",
3030
'bungieGlobalDisplayNameCode', player."bungie_global_display_name_code",
31-
'lastSeen', player."last_seen"::text,
31+
'lastSeen', player."last_seen",
3232
'isPrivate', player."is_private",
3333
'cheatLevel', player."cheat_level"
3434
) END,

src/services/player-instances/teammates.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,7 @@ export const getTeammates = async (membershipId: bigint | string, { count }: { c
3333
'displayName', "display_name",
3434
'bungieGlobalDisplayName', "bungie_global_display_name",
3535
'bungieGlobalDisplayNameCode', "bungie_global_display_name_code",
36-
'lastSeen', "last_seen"::text,
36+
'lastSeen', "last_seen",
3737
'isPrivate', "is_private",
3838
'cheatLevel', cheat_level
3939
) AS "playerInfo"

0 commit comments

Comments
 (0)