Compare commits

..

No commits in common. "74ae167e3cfeb9805bc92eff8155d07a34e2d005" and "1e6065ec7c42b0ba2e21c6022888cd1e9809f479" have entirely different histories.

3 changed files with 9 additions and 94 deletions

View File

@ -23,16 +23,11 @@ function App() {
const [showAuthModal, setShowAuthModal] = useState(false)
const [showFolderModal, setShowFolderModal] = useState(false)
const [processes, setProcesses] = useState<any>(null)
const [userPairingId, setUserPairingId] = useState<string | null>(null)
useEffect(() => {
setIsConnected(UserStore.getInstance().isConnected());
});
useEffect(() => {
setUserPairingId(UserStore.getInstance().getUserPairingId());
});
useEffect(() => {
if (isConnected) {
const messageBus = MessageBus.getInstance(iframeUrl);
@ -56,23 +51,15 @@ function App() {
console.error('Failed to retrieve data:', error);
}
}
messageBus.getData('467b005278cf516a42a54ba777fcbab29748072b52c01a988a596662e7b7844a:0', 'ada06b5c6e5add8a281b284a31a258355b33a9f0dbc4a5dcfe77dfd4eb904011').then((data: any) => {
console.log(data);
});
});
});
}
}, [isConnected, iframeUrl]);
useEffect(() => {
if (isConnected && userPairingId === null) {
const messageBus = MessageBus.getInstance(iframeUrl);
messageBus.isReady().then(() => {
messageBus.getUserPairingId().then((userPairingId: string) => {
UserStore.getInstance().pair(userPairingId);
setUserPairingId(UserStore.getInstance().getUserPairingId());
})
});
}
}, [isConnected, userPairingId]);
// Gestionnaire pour afficher la modale de connexion
const handleLogin = useCallback(() => {
// Afficher la modale de connexion

View File

@ -10,8 +10,6 @@ export default class MessageBus {
private readonly origin: string;
private messageListener: ((event: MessageEvent) => void) | null = null;
private errors: { [key: string]: string } = {};
private readyPromise: Promise<void> | null = null;
private isReadyFlag = false;
private constructor(origin: string) {
this.origin = origin;
@ -25,28 +23,19 @@ export default class MessageBus {
}
public isReady(): Promise<void> {
if (this.isReadyFlag) {
return Promise.resolve();
}
if (this.readyPromise) {
return this.readyPromise;
}
this.readyPromise = new Promise<void>((resolve) => {
return new Promise<void>((resolve: () => void) => {
const correlationId = uuidv4();
this.initMessageListener(correlationId);
const unsubscribe = EventBus.getInstance().on('IS_READY', (responseId: string) => {
if (responseId !== correlationId) return;
if (responseId !== correlationId) {
return;
}
unsubscribe();
this.destroyMessageListener();
this.isReadyFlag = true;
resolve();
});
});
return this.readyPromise;
}
public requestLink(): Promise<void> {
@ -79,41 +68,6 @@ export default class MessageBus {
});
}
public getUserPairingId(): Promise<string> {
return new Promise<string>((resolve: (userPairingId: string) => void, reject: (error: string) => void) => {
this.checkToken().then(() => {
const userStore = UserStore.getInstance();
const accessToken = userStore.getAccessToken()!;
const correlationId = uuidv4();
this.initMessageListener(correlationId);
const unsubscribe = EventBus.getInstance().on('PAIRING_ID', (responseId: string, userPairingId: string) => {
if (responseId !== correlationId) {
return;
}
unsubscribe();
this.destroyMessageListener();
resolve(userPairingId);
});
const unsubscribeError = EventBus.getInstance().on('ERROR_PAIRING_ID', (responseId: string, error: string) => {
if (responseId !== correlationId) {
return;
}
unsubscribeError();
this.destroyMessageListener();
reject(error);
});
this.sendMessage({
type: 'GET_PAIRING_ID',
accessToken,
});
}).catch(console.error);
});
}
public validateToken(): Promise<boolean> {
return new Promise<boolean>((resolve: (isValid: boolean) => void, reject: (error: string) => void) => {
const userStore = UserStore.getInstance();
@ -194,15 +148,10 @@ export default class MessageBus {
public getProcesses(): Promise<any> {
return new Promise<any>((resolve: (processes: any) => void, reject: (error: string) => void) => {
this.checkToken().then(() => {
const userStore = UserStore.getInstance();
const accessToken = userStore.getAccessToken()!;
const correlationId = uuidv4();
console.log(correlationId);
this.initMessageListener(correlationId);
const unsubscribe = EventBus.getInstance().on('PROCESSES_RETRIEVED', (responseId: string, processes: any) => {
console.log(responseId);
if (responseId !== correlationId) {
return;
}
@ -221,8 +170,7 @@ export default class MessageBus {
});
this.sendMessage({
type: 'GET_PROCESSES',
accessToken,
type: 'GET_PROCESSES'
});
}).catch(console.error);
});
@ -423,17 +371,6 @@ export default class MessageBus {
EventBus.getInstance().emit('TOKEN_RENEWED', correlationId, message.accessToken, message.refreshToken);
break;
case 'GET_PAIRING_ID':
if (this.errors[correlationId]) {
const error = this.errors[correlationId];
delete this.errors[correlationId];
EventBus.getInstance().emit('ERROR_PAIRING_ID', correlationId, error);
return;
}
EventBus.getInstance().emit('MESSAGE_RECEIVED', message);
EventBus.getInstance().emit('PAIRING_ID', correlationId, message.userPairingId);
break;
case 'PROCESSES_RETRIEVED': // GET_PROCESSES
if (this.errors[correlationId]) {
const error = this.errors[correlationId];

View File

@ -22,7 +22,6 @@ export default class UserStore {
public disconnect(): void {
sessionStorage.removeItem('accessToken');
sessionStorage.removeItem('refreshToken');
sessionStorage.removeItem('userPairingId');
}
public getAccessToken(): string | null {
@ -32,12 +31,4 @@ export default class UserStore {
public getRefreshToken(): string | null {
return sessionStorage.getItem('refreshToken');
}
public pair(userPairingId: string): void {
sessionStorage.setItem('userPairingId', userPairingId);
}
public getUserPairingId(): string | null {
return sessionStorage.getItem('userPairingId');
}
}