fix(points): add required request headers for trackPointsEvent call

src/points/saga.test.ts

@@ -4,8 +4,9 @@ import { FetchMock } from 'jest-fetch-mock/types'
 import { expectSaga } from 'redux-saga-test-plan'
 import * as matchers from 'redux-saga-test-plan/matchers'
 import { throwError } from 'redux-saga-test-plan/providers'
-import { select } from 'redux-saga/effects'
+import { call, select } from 'redux-saga/effects'
 import { Actions as AppActions } from 'src/app/actions'
+import { retrieveSignedMessage } from 'src/pincode/authentication'
 import * as pointsSaga from 'src/points/saga'
 import {
   fetchHistory,
@@ -33,10 +34,11 @@ import pointsReducer, {
   sendPointsEventStarted,
   trackPointsEvent,
 } from 'src/points/slice'
-import { ClaimHistory, GetHistoryResponse } from 'src/points/types'
+import { ClaimHistory, GetHistoryResponse, PointsEvent } from 'src/points/types'
 import Logger from 'src/utils/Logger'
 import * as fetchWithTimeout from 'src/utils/fetchWithTimeout'
 import networkConfig from 'src/web3/networkConfig'
+import { walletAddressSelector } from 'src/web3/selectors'
 import { createMockStore } from 'test/utils'
 import { mockAccount } from 'test/values'
 import { v4 as uuidv4 } from 'uuid'
@@ -45,6 +47,7 @@ jest.mock('src/statsig')
 
 jest.mock('uuid')
 jest.mock('src/utils/Logger')
+jest.unmock('src/pincode/authentication')
 
 const MOCK_HISTORY_RESPONSE: GetHistoryResponse = {
   data: [
@@ -567,3 +570,26 @@ describe('watchAppMounted', () => {
     expect(mockSendPendingPointsEvents).toHaveBeenCalledTimes(1)
   })
 })
+
+describe('fetchTrackPointsEventsEndpoint', () => {
+  it('should call fetch with correct params', async () => {
+    const mockEvent: PointsEvent = { activityId: 'create-wallet' }
+    mockFetch.mockResponseOnce(JSON.stringify({ ok: true }))
+
+    await expectSaga(fetchTrackPointsEventsEndpoint, mockEvent)
+      .provide([
+        [select(walletAddressSelector), mockAccount],
+        [call(retrieveSignedMessage), 'someSignedMessage'],
+      ])
+      .run()
+
+    expect(fetchWithTimeoutSpy).toHaveBeenCalledWith(networkConfig.trackPointsEventUrl, {
+      method: 'POST',
+      headers: {
+        'Content-Type': 'application/json',
+        authorization: `Valora ${mockAccount}:someSignedMessage`,
+      },
+      body: JSON.stringify(mockEvent),
+    })
+  })
+})

src/points/saga.ts

@@ -1,6 +1,7 @@
 import { differenceInDays } from 'date-fns'
 import { Actions as AppActions } from 'src/app/actions'
 import { Actions as HomeActions } from 'src/home/actions'
+import { retrieveSignedMessage } from 'src/pincode/authentication'
 import {
   nextPageUrlSelector,
   pendingPointsEvents,
@@ -51,8 +52,8 @@
 
   const address = yield* select(walletAddressSelector)
   if (!address) {
     Logger.error(TAG, 'No wallet address found when fetching points balance')
     return
   }
 
   try {
@@ -171,9 +172,16 @@
   }
 }
 
-export async function fetchTrackPointsEventsEndpoint(event: PointsEvent) {
-  return fetchWithTimeout(networkConfig.trackPointsEventUrl, {
+export function* fetchTrackPointsEventsEndpoint(event: PointsEvent) {
+  const address = yield* select(walletAddressSelector)
+  const signedMessage = yield* call(retrieveSignedMessage)
+
+  return yield* call(fetchWithTimeout, networkConfig.trackPointsEventUrl, {
     method: 'POST',
+    headers: {
+      'Content-Type': 'application/json',
+      authorization: `Valora ${address}:${signedMessage}`,
+    },
     body: JSON.stringify(event),
   })
 }
@@ -243,7 +251,7 @@
 
 function* watchGetHistory() {
   yield* takeLeading(getHistoryStarted.type, safely(getHistory))
   yield* takeLeading(getHistoryStarted.type, safely(getPointsBalance))
 }
 
 function* watchGetConfig() {
@@ -260,10 +268,10 @@
 }
 
 export function* pointsSaga() {
   const showPoints = getFeatureGate(StatsigFeatureGates.SHOW_POINTS)
   if (!showPoints) {
     Logger.info(TAG, 'Points feature is disabled, not spawning points sagas')
     return
   }
 
   yield* spawn(watchGetHistory)