Extract out processor and spy variables to reduce repetition.
This commit is contained in:
parent
4887ca261e
commit
7505d60888
|
@ -16,6 +16,9 @@ const newIdentity = () => {
|
||||||
}
|
}
|
||||||
|
|
||||||
describe("PosthogProcessor", () => {
|
describe("PosthogProcessor", () => {
|
||||||
|
let processor: PosthogProcessor
|
||||||
|
let spy: jest.SpyInstance
|
||||||
|
|
||||||
beforeAll(() => {
|
beforeAll(() => {
|
||||||
testEnv.singleTenant()
|
testEnv.singleTenant()
|
||||||
})
|
})
|
||||||
|
@ -25,25 +28,21 @@ describe("PosthogProcessor", () => {
|
||||||
await cache.bustCache(
|
await cache.bustCache(
|
||||||
`${CacheKey.EVENTS_RATE_LIMIT}:${Event.SERVED_BUILDER}`
|
`${CacheKey.EVENTS_RATE_LIMIT}:${Event.SERVED_BUILDER}`
|
||||||
)
|
)
|
||||||
|
|
||||||
|
processor = new PosthogProcessor("test")
|
||||||
|
spy = jest.spyOn(processor.posthog, "capture")
|
||||||
})
|
})
|
||||||
|
|
||||||
describe("processEvent", () => {
|
describe("processEvent", () => {
|
||||||
it("processes event", async () => {
|
it("processes event", async () => {
|
||||||
const processor = new PosthogProcessor("test")
|
|
||||||
const spy = jest.spyOn(processor.posthog, "capture")
|
|
||||||
|
|
||||||
const identity = newIdentity()
|
const identity = newIdentity()
|
||||||
const properties = {}
|
const properties = {}
|
||||||
|
|
||||||
await processor.processEvent(Event.APP_CREATED, identity, properties)
|
await processor.processEvent(Event.APP_CREATED, identity, properties)
|
||||||
|
|
||||||
expect(spy).toHaveBeenCalledTimes(1)
|
expect(spy).toHaveBeenCalledTimes(1)
|
||||||
})
|
})
|
||||||
|
|
||||||
it("honours exclusions", async () => {
|
it("honours exclusions", async () => {
|
||||||
const processor = new PosthogProcessor("test")
|
|
||||||
const spy = jest.spyOn(processor.posthog, "capture")
|
|
||||||
|
|
||||||
const identity = newIdentity()
|
const identity = newIdentity()
|
||||||
const properties = {}
|
const properties = {}
|
||||||
|
|
||||||
|
@ -52,9 +51,6 @@ describe("PosthogProcessor", () => {
|
||||||
})
|
})
|
||||||
|
|
||||||
it("removes audited information", async () => {
|
it("removes audited information", async () => {
|
||||||
const processor = new PosthogProcessor("test")
|
|
||||||
const spy = jest.spyOn(processor.posthog, "capture")
|
|
||||||
|
|
||||||
const identity = newIdentity()
|
const identity = newIdentity()
|
||||||
const properties = {
|
const properties = {
|
||||||
email: "test",
|
email: "test",
|
||||||
|
@ -65,6 +61,7 @@ describe("PosthogProcessor", () => {
|
||||||
|
|
||||||
await processor.processEvent(Event.USER_CREATED, identity, properties)
|
await processor.processEvent(Event.USER_CREATED, identity, properties)
|
||||||
expect(spy).toHaveBeenCalled()
|
expect(spy).toHaveBeenCalled()
|
||||||
|
|
||||||
// @ts-ignore
|
// @ts-ignore
|
||||||
const call = processor.posthog.capture.mock.calls[0][0]
|
const call = processor.posthog.capture.mock.calls[0][0]
|
||||||
expect(call.properties.audited).toBeUndefined()
|
expect(call.properties.audited).toBeUndefined()
|
||||||
|
@ -73,9 +70,6 @@ describe("PosthogProcessor", () => {
|
||||||
|
|
||||||
describe("rate limiting", () => {
|
describe("rate limiting", () => {
|
||||||
it("sends daily event once in same day", async () => {
|
it("sends daily event once in same day", async () => {
|
||||||
const processor = new PosthogProcessor("test")
|
|
||||||
const spy = jest.spyOn(processor.posthog, "capture")
|
|
||||||
|
|
||||||
const identity = newIdentity()
|
const identity = newIdentity()
|
||||||
const properties = {}
|
const properties = {}
|
||||||
|
|
||||||
|
@ -89,8 +83,6 @@ describe("PosthogProcessor", () => {
|
||||||
})
|
})
|
||||||
|
|
||||||
it("sends daily event once per unique day", async () => {
|
it("sends daily event once per unique day", async () => {
|
||||||
const processor = new PosthogProcessor("test")
|
|
||||||
const spy = jest.spyOn(processor.posthog, "capture")
|
|
||||||
const identity = newIdentity()
|
const identity = newIdentity()
|
||||||
const properties = {}
|
const properties = {}
|
||||||
|
|
||||||
|
@ -110,9 +102,6 @@ describe("PosthogProcessor", () => {
|
||||||
})
|
})
|
||||||
|
|
||||||
it("sends event again after cache expires", async () => {
|
it("sends event again after cache expires", async () => {
|
||||||
const processor = new PosthogProcessor("test")
|
|
||||||
const spy = jest.spyOn(processor.posthog, "capture")
|
|
||||||
|
|
||||||
const identity = newIdentity()
|
const identity = newIdentity()
|
||||||
const properties = {}
|
const properties = {}
|
||||||
|
|
||||||
|
@ -130,8 +119,6 @@ describe("PosthogProcessor", () => {
|
||||||
})
|
})
|
||||||
|
|
||||||
it("sends per app events once per day per app", async () => {
|
it("sends per app events once per day per app", async () => {
|
||||||
const processor = new PosthogProcessor("test")
|
|
||||||
const spy = jest.spyOn(processor.posthog, "capture")
|
|
||||||
const identity = newIdentity()
|
const identity = newIdentity()
|
||||||
const properties = {}
|
const properties = {}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue