-
Notifications
You must be signed in to change notification settings - Fork 6
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
feat(keyAutoAdd): support key auto-add for Chimoney (#749)
- Loading branch information
1 parent
1553e3c
commit 0c4a818
Showing
12 changed files
with
504 additions
and
12 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
|
|
@@ -2,6 +2,7 @@ | |
| Interledger | ||
| Fynbos | ||
| Rafiki | ||
| Chimoney | ||
|
|
||
| SPSP | ||
| webextension | ||
|
|
||
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,113 @@ | ||
| // cSpell:ignore nextjs | ||
| import { errorWithKey, ErrorWithKey, sleep } from '@/shared/helpers'; | ||
| import { | ||
| KeyAutoAdd, | ||
| LOGIN_WAIT_TIMEOUT, | ||
| type StepRun as Run, | ||
| } from './lib/keyAutoAdd'; | ||
| import { isTimedOut, waitForElement, waitForURL } from './lib/helpers'; | ||
| import { getAuthToken, getWalletAddressId } from './lib/helpers/chimoney'; | ||
|
|
||
| // #region: Steps | ||
|
|
||
| const waitForLogin: Run<void> = async ( | ||
| { keyAddUrl }, | ||
| { skip, setNotificationSize }, | ||
| ) => { | ||
| await sleep(2000); | ||
| let alreadyLoggedIn = window.location.href.startsWith(keyAddUrl); | ||
| if (!alreadyLoggedIn) setNotificationSize('notification'); | ||
| try { | ||
| alreadyLoggedIn = await waitForURL( | ||
| (url) => (url.origin + url.pathname).startsWith(keyAddUrl), | ||
| { timeout: LOGIN_WAIT_TIMEOUT }, | ||
| ); | ||
|
|
||
| setNotificationSize('fullscreen'); | ||
| } catch (error) { | ||
| if (isTimedOut(error)) { | ||
| throw new ErrorWithKey('connectWalletKeyService_error_timeoutLogin'); | ||
| } | ||
| throw new Error(error); | ||
| } | ||
|
|
||
| if (alreadyLoggedIn) { | ||
| skip(errorWithKey('connectWalletKeyService_error_skipAlreadyLoggedIn')); | ||
| } | ||
| }; | ||
|
|
||
| const findWallet: Run<{ walletAddressId: string }> = async ( | ||
| { walletAddressUrl }, | ||
| { setNotificationSize }, | ||
| ) => { | ||
| const walletAddress = new URL(walletAddressUrl); | ||
| setNotificationSize('fullscreen'); | ||
|
|
||
| await waitForElement('h5', { | ||
| match: (el) => el.textContent?.trim() === 'Interledger Wallet Address Info', | ||
| }).catch(() => { | ||
| throw new Error('Are you on the correct page?'); | ||
| }); | ||
|
|
||
| const walletAddressElem = await waitForElement('h6', { | ||
| match(el) { | ||
| const prefix = walletAddress.hostname; | ||
| const text = el.textContent?.trim() ?? ''; | ||
| return text.startsWith(`Wallet Address:`) && text.includes(prefix); | ||
| }, | ||
| }).catch(() => { | ||
| throw new Error( | ||
| 'Failed to find wallet address. Are you on the correct page?', | ||
| ); | ||
| }); | ||
|
|
||
| // To match both payment pointer and wallet address URL format | ||
| const walletAddressText = walletAddress.hostname + walletAddress.pathname; | ||
| if (walletAddressElem.textContent?.includes(walletAddressText)) { | ||
| throw new ErrorWithKey('connectWalletKeyService_error_accountNotFound'); | ||
| } | ||
|
|
||
| const walletAddressId = await getWalletAddressId(); | ||
| return { walletAddressId }; | ||
| }; | ||
|
|
||
| const addKey: Run<void> = async ({ publicKey }, { output }) => { | ||
| const { walletAddressId } = output(findWallet); | ||
|
|
||
| const res = await fetch('/api/interledger/create-user-wallet-address-key', { | ||
| method: 'POST', | ||
| headers: { | ||
| authorization: `Bearer ${getAuthToken()}`, | ||
| 'content-type': 'application/json', | ||
| }, | ||
| credentials: 'include', | ||
| body: JSON.stringify({ | ||
| key: publicKey, | ||
| walletAddressId, | ||
| // Chimoney doesn't have a nickName field supported yet | ||
| }), | ||
| }).catch((error) => { | ||
| return Response.json(null, { status: 599, statusText: error.message }); | ||
| }); | ||
|
|
||
| if (!res.ok) { | ||
| throw new Error(`Failed to upload public key (${res.statusText})`); | ||
| } | ||
| const data = await res.json().catch(() => null); | ||
| if (data?.status !== 'success') { | ||
| throw new Error(`Failed to upload public key (${await res.text()})`); | ||
| } | ||
| }; | ||
| // #endregion | ||
|
|
||
| // #region: Main | ||
| new KeyAutoAdd([ | ||
| { | ||
| name: 'Waiting for you to login', | ||
| run: waitForLogin, | ||
| maxDuration: LOGIN_WAIT_TIMEOUT, | ||
| }, | ||
| { name: 'Finding wallet', run: findWallet }, | ||
| { name: 'Adding key', run: addKey }, | ||
| ]).init(); | ||
| // #endregion |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,49 @@ | ||
| import { sleep } from '@/shared/helpers'; | ||
|
|
||
| export const getAuthToken = (): string => { | ||
| const getFirebaseAuthKey = () => { | ||
| for (let i = 0; i < sessionStorage.length; i++) { | ||
| const key = sessionStorage.key(i); | ||
| if (key?.startsWith('firebase:authUser:')) { | ||
| return key; | ||
| } | ||
| } | ||
| }; | ||
|
|
||
| const key = getFirebaseAuthKey(); | ||
| if (!key) { | ||
| throw new Error('No Firebase auth key found'); | ||
| } | ||
| const firebaseDataStr = sessionStorage.getItem(key); | ||
| if (!firebaseDataStr) { | ||
| throw new Error('No Firebase auth data found'); | ||
| } | ||
| const firebaseData: { | ||
| stsTokenManager: { | ||
| accessToken: string; | ||
| refreshToken: string; | ||
| expirationTime: number; | ||
| }; | ||
| } = JSON.parse(firebaseDataStr); | ||
| const token = firebaseData?.stsTokenManager?.accessToken; | ||
| if (!token) { | ||
| throw new Error('No Firebase auth token found'); | ||
| } | ||
| const JWT_REGEX = | ||
| /^([A-Za-z0-9-_=]{2,})\.([A-Za-z0-9-_=]{2,})\.([A-Za-z0-9-_=]{2,})$/; | ||
| if (!JWT_REGEX.test(token)) { | ||
| throw new Error('Invalid Firebase auth token'); | ||
| } | ||
| return token; | ||
| }; | ||
|
|
||
| export const getWalletAddressId = async (): Promise<string> => { | ||
| // A Firebase request will set this field eventually. We wait max 6s for that. | ||
| let attemptToFindWalletAddressId = 0; | ||
| while (++attemptToFindWalletAddressId < 12) { | ||
| const walletAddressId = sessionStorage.getItem('walletAddressId'); | ||
| if (walletAddressId) return walletAddressId; | ||
| await sleep(500); | ||
| } | ||
| throw new Error('No walletAddressId found in sessionStorage'); | ||
| }; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.