added inteceptor to include diff headers in diff env

This commit is contained in:
heyethereum
2024-08-03 13:47:24 +08:00
parent 1fdfd94baf
commit 804eb6f024
6 changed files with 67 additions and 19 deletions

View File

@@ -1,2 +1,2 @@
NODE_ENV=development
BASE_URL=http://localhost:8080
BASE_URL=http://192.168.1.30:8080

View File

@@ -1,3 +1,3 @@
NODE_ENV=production
BASE_URL=https://bk5wiynzsi.execute-api.ap-southeast-1.amazonaws.com/api/
BASE_URL=https://bk5wiynzsi.execute-api.ap-southeast-1.amazonaws.com/api
ENV=production

View File

@@ -1,6 +1,7 @@
import axios from 'axios';
import Constants from 'expo-constants';
const { API_BASE_URL } = Constants.expoConfig.extra;
const { API_BASE_URL, ENVIRONMENT } = Constants.expoConfig.extra;
import { fetchAuthSession, getCurrentUser } from 'aws-amplify/auth';
//const API_BASE_URL = 'https://localhost:8443';
const API_URL_DETECT = "/v1/qrcodetypes/detect";
@@ -12,15 +13,46 @@ const API_URL_DELETE_SCANNED_HISTORY = "/v1/user/deleteScannedHistories"
const API_URL_GET_BOOKMARKS = "/v1/user/getBookmarks"
const API_URL_SET_BOOKMARK = "/v1/user/setBookmark"
const API_URL_DELETE_BOOKMARK = "/v1/user/deleteBookmark"
const API_URL_GET_SCANNED_GMAILS = "/v1/gmail/getEmails"
// Create an Axios instance
const apiClient = axios.create({
baseURL: API_BASE_URL,
});
// Request interceptor to set headers based on env
apiClient.interceptors.request.use(
async (config) => {
const token = await fetchIdToken();
const userId = await fetchUserId();
if (ENVIRONMENT === 'production') {
if (!config.headers.Authorization) {
config.headers.Authorization = `Bearer ${token}`;
}
} else {
if (!config.headers['X-USER-ID']) {
config.headers['X-USER-ID'] = userId;
}
}
return config;
},
(error) => {
return Promise.reject(error);
}
);
// Define a generic function to handle all types of requests
export const apiRequest = async (config) => {
try {
console.log("ENVIRONMENT:", ENVIRONMENT);
console.log(`API Call - ${config.method.toUpperCase()}:`, config.url, config.data || '');
console.log(config);
const response = await axios(config);
const response = await apiClient(config);
console.log('API Response:', response.data);
return response.data;
} catch (error) {
if (error.response) {
@@ -37,6 +69,18 @@ export const apiRequest = async (config) => {
}
};
// Function to get the token
const fetchIdToken = async () => {
const { tokens } = await fetchAuthSession();
return tokens.idToken.toString();
};
// Function to get the user ID
const fetchUserId = async () => {
const currentUser = await getCurrentUser();
return currentUser.userId;
};
export const detectQRCodeType = async (data) => {
return apiRequest({
method: 'post',
@@ -69,48 +113,51 @@ export const checkRedirects = async (data) => {
});
};
// GET User's Scanned Histories
export const getScannedHistories = async (userId: string) => {
export const getScannedHistories = async () => {
return apiRequest({
method: 'get',
url: `${API_BASE_URL}${API_URL_GET_HISTORIES}`,
headers: { "X-USER-ID": userId },
url: `${API_BASE_URL}${API_URL_GET_HISTORIES}`
});
};
// GET All User's Bookmark
export const getAllUserBookmarks = async (userId: string) => {
export const getAllUserBookmarks = async () => {
return apiRequest({
method: 'get',
url: `${API_BASE_URL}${API_URL_GET_BOOKMARKS}`,
headers: { "X-USER-ID": userId },
});
};
// Create Bookmark on QR Code
export const setBookmark = async (userId: string, qrCodeId: string) => {
export const setBookmark = async (qrCodeId: string) => {
return apiRequest({
method: 'post',
url: `${API_BASE_URL}${API_URL_SET_BOOKMARK}`,
headers: { "X-USER-ID": userId},
data: { "qrCodeId": qrCodeId }
});
};
// Delete single bookmark
export const deleteBookmark = async (userId: string, qrCodeId: string) => {
export const deleteBookmark = async (qrCodeId: string) => {
return apiRequest({
method: 'put',
url: `${API_BASE_URL}${API_URL_DELETE_BOOKMARK}`,
headers: { "X-USER-ID": userId},
data: { "qrCodeId": qrCodeId }
});
};
// Delete Single Scanned History
export const deleteScannedHistory = async (userId: string, qrCodeId: string) => {
export const deleteScannedHistory = async (qrCodeId: string) => {
return apiRequest({
method: 'put',
url: `${API_BASE_URL}${API_URL_DELETE_SCANNED_HISTORY}`,
headers: { "X-USER-ID": userId},
data: { "qrCodeId": qrCodeId }
});
};
// GET Scan user's GMAILS
export const getScannedGmails = async () => {
return apiRequest({
method: 'get',
url: `${API_BASE_URL}${API_URL_GET_SCANNED_GMAILS}`
});
};

View File

@@ -9,6 +9,7 @@ export default ({ config }) => {
...config,
extra: {
API_BASE_URL: process.env.BASE_URL,
ENVIRONMENT: process.env.NODE_ENV
},
};
};

View File

@@ -18,7 +18,7 @@ export const toggleBookmark = createAsyncThunk(
'qrCodes/toggleBookmark',
async ({ userId, qrCode }: { userId: string, qrCode: QRCodeType }, { dispatch, rejectWithValue }) => {
try {
await (qrCode.bookmarked ? deleteBookmark(userId, qrCode.data.id) : setBookmark(userId, qrCode.data.id));
await (qrCode.bookmarked ? deleteBookmark(qrCode.data.id) : setBookmark(qrCode.data.id));
// Dispatch the action to update local state
dispatch(toggleBookmarkInState(qrCode));
return qrCode;
@@ -33,7 +33,7 @@ export const deleteQRCode = createAsyncThunk(
'qrCodes/deleteQRCode',
async ({ userId, qrCodeId }: { userId: string, qrCodeId: string }, { dispatch, rejectWithValue }) => {
try {
await deleteScannedHistory(userId, qrCodeId);
await deleteScannedHistory(qrCodeId);
dispatch(deleteQRCodeInState(qrCodeId));
return qrCodeId;
} catch (error) {

View File

@@ -25,7 +25,7 @@ const HistoryScreen: React.FC = () => {
try {
setHistoriesLoading(true);
const historiesData = await getScannedHistories(userAttributes.sub);
const historiesData = await getScannedHistories();
dispatch(setScannedHistories(historiesData));
setHistoriesLoading(false);