- 
- 
-
- -
{" "}
-
+
+
+
+ +
+
+ {ratingCountPosition === "top" && (
+ <>
+
+ {(votesInfo?.totalVotes ?? 0) +
+ (votesInfo?.voteCounts?.length === 6 ? 1 : 0)}{" "}
+ {" RATINGS"}
+
+ {value?.toFixed(1)}
+
+ {(votesInfo?.totalVotes ?? 0) +
+ (votesInfo?.voteCounts?.length === 6 ? 1 : 0)}
+
+ )}
+
+
+
+ );
+};
diff --git a/src/components/Apps/AppViewer.tsx b/src/components/Apps/AppViewer.tsx
new file mode 100644
index 0000000..a2a5225
--- /dev/null
+++ b/src/components/Apps/AppViewer.tsx
@@ -0,0 +1,149 @@
+import React, { useContext, useEffect, useMemo, useState } from "react";
+
+import { Avatar, Box, } from "@mui/material";
+import { Add } from "@mui/icons-material";
+import { MyContext, getBaseApiReact, isMobile } from "../../App";
+
+import { executeEvent, subscribeToEvent, unsubscribeFromEvent } from "../../utils/events";
+import { useFrame } from "react-frame-component";
+import { useQortalMessageListener } from "./useQortalMessageListener";
+
+
+
+
+export const AppViewer = React.forwardRef(({ app , hide}, iframeRef) => {
+ const { rootHeight } = useContext(MyContext);
+ // const iframeRef = useRef(null);
+ const { document, window: frameWindow } = useFrame();
+ const {path, history, changeCurrentIndex} = useQortalMessageListener(frameWindow, iframeRef, app?.tabId)
+ const [url, setUrl] = useState('')
+ console.log('historyreact', history)
+
+ useEffect(()=> {
+ setUrl(`${getBaseApiReact()}/render/${app?.service}/${app?.name}${app?.path != null ? `/${app?.path}` : ''}?theme=dark&identifier=${(app?.identifier != null && app?.identifier != 'null') ? app?.identifier : ''}`)
+ }, [app?.service, app?.name, app?.identifier, app?.path])
+ const defaultUrl = useMemo(()=> {
+ return url
+ }, [url])
+
+
+
+ const refreshAppFunc = (e) => {
+ const {tabId} = e.detail
+ if(tabId === app?.tabId){
+ const constructUrl = `${getBaseApiReact()}/render/${app?.service}/${app?.name}${path != null ? path : ''}?theme=dark&identifier=${app?.identifier != null ? app?.identifier : ''}&time=${new Date().getMilliseconds()}`
+ setUrl(constructUrl)
+ }
+ };
+
+ useEffect(() => {
+ subscribeToEvent("refreshApp", refreshAppFunc);
+
+ return () => {
+ unsubscribeFromEvent("refreshApp", refreshAppFunc);
+ };
+ }, [app, path]);
+
+ // Function to navigate back in iframe
+ const navigateBackInIframe = async () => {
+ if (iframeRef.current && iframeRef.current.contentWindow && history?.currentIndex > 0) {
+ // Calculate the previous index and path
+ const previousPageIndex = history.currentIndex - 1;
+ const previousPath = history.customQDNHistoryPaths[previousPageIndex];
+
+ // Signal non-manual navigation
+ iframeRef.current.contentWindow.postMessage(
+ { action: 'PERFORMING_NON_MANUAL' }, '*'
+ );
+ console.log('previousPageIndex', previousPageIndex)
+ // Update the current index locally
+ changeCurrentIndex(previousPageIndex);
+
+ // Create a navigation promise with a 200ms timeout
+ const navigationPromise = new Promise((resolve, reject) => {
+ function handleNavigationSuccess(event) {
+ console.log('listeninghandlenav', event)
+ if (event.data?.action === 'NAVIGATION_SUCCESS' && event.data.path === previousPath) {
+ frameWindow.removeEventListener('message', handleNavigationSuccess);
+ resolve();
+ }
+ }
+
+ frameWindow.addEventListener('message', handleNavigationSuccess);
+
+ // Timeout after 200ms if no response
+ setTimeout(() => {
+ window.removeEventListener('message', handleNavigationSuccess);
+ reject(new Error("Navigation timeout"));
+ }, 200);
+
+ // Send the navigation command after setting up the listener and timeout
+ iframeRef.current.contentWindow.postMessage(
+ { action: 'NAVIGATE_TO_PATH', path: previousPath, requestedHandler: 'UI' }, '*'
+ );
+ });
+
+ // Execute navigation promise and handle timeout fallback
+ try {
+ await navigationPromise;
+ console.log('Navigation succeeded within 200ms.');
+ } catch (error) {
+ iframeRef.current.contentWindow.postMessage(
+ { action: 'PERFORMING_NON_MANUAL' }, '*'
+ );
+ setUrl(`${getBaseApiReact()}/render/${app?.service}/${app?.name}${app?.previousPath != null ? previousPath : ''}?theme=dark&identifier=${(app?.identifier != null && app?.identifier != 'null') ? app?.identifier : ''}&time=${new Date().getMilliseconds()}&isManualNavigation=false`)
+ // iframeRef.current.contentWindow.location.href = previousPath; // Fallback URL update
+ }
+ } else {
+ console.log('Iframe not accessible or does not have a content window.');
+ }
+};
+
+ const navigateBackAppFunc = (e) => {
+
+ navigateBackInIframe()
+ };
+
+ useEffect(() => {
+ if(!app?.tabId) return
+ subscribeToEvent(`navigateBackApp-${app?.tabId}`, navigateBackAppFunc);
+
+ return () => {
+ unsubscribeFromEvent(`navigateBackApp-${app?.tabId}`, navigateBackAppFunc);
+ };
+ }, [app, history]);
+
+
+ // Function to navigate back in iframe
+ const navigateForwardInIframe = async () => {
+
+
+ if (iframeRef.current && iframeRef.current.contentWindow) {
+ console.log('iframeRef.contentWindow', iframeRef.current.contentWindow);
+ iframeRef.current.contentWindow.postMessage(
+ { action: 'NAVIGATE_FORWARD'},
+ '*'
+ );
+ } else {
+ console.log('Iframe not accessible or does not have a content window.');
+ }
+};
+
+
+ return (
+ {
+ try {
+ if (hasInitialized.current) {
+ decryptMessages(data, true);
+ return;
+ }
+ hasInitialized.current = true;
+ const url = `${getBaseApiReact()}/chat/messages?involving=${selectedDirectAddress}&involving=${myAddress}&encoding=BASE64&limit=0&reverse=false`;
+ const response = await fetch(url, {
+ method: "GET",
+ headers: {
+ "Content-Type": "application/json",
+ },
+ });
+ const responseData = await response.json();
+ decryptMessages(responseData, false);
+ } catch (error) {
+ console.error(error);
+ }
+ }
- const decryptMessages = (encryptedMessages: any[])=> {
+ const decryptMessages = (encryptedMessages: any[], isInitiated: boolean)=> {
try {
return new Promise((res, rej)=> {
chrome?.runtime?.sendMessage({ action: "decryptDirect", payload: {
@@ -92,7 +111,7 @@ export const ChatDirect = ({ myAddress, isNewChat, selectedDirect, setSelectedDi
processWithNewMessages(response, selectedDirect?.address)
res(response)
- if(hasInitialized.current){
+ if(isInitiated){
const formatted = response.map((item: any)=> {
return {
@@ -127,7 +146,6 @@ export const ChatDirect = ({ myAddress, isNewChat, selectedDirect, setSelectedDi
const forceCloseWebSocket = () => {
if (socketRef.current) {
- console.log('Force closing the WebSocket');
clearTimeout(timeoutIdRef.current);
clearTimeout(groupSocketTimeoutRef.current);
socketRef.current.close(1000, 'forced');
@@ -161,7 +179,6 @@ export const ChatDirect = ({ myAddress, isNewChat, selectedDirect, setSelectedDi
socketRef.current = new WebSocket(socketLink);
socketRef.current.onopen = () => {
- console.log('WebSocket connection opened');
setTimeout(pingWebSocket, 50); // Initial ping
};
@@ -171,7 +188,8 @@ export const ChatDirect = ({ myAddress, isNewChat, selectedDirect, setSelectedDi
clearTimeout(timeoutIdRef.current);
groupSocketTimeoutRef.current = setTimeout(pingWebSocket, 45000); // Ping every 45 seconds
} else {
- decryptMessages(JSON.parse(e.data));
+ middletierFunc(JSON.parse(e.data), selectedDirect?.address, myAddress)
+
setIsLoading(false);
}
} catch (error) {
diff --git a/src/components/Chat/ChatGroup.tsx b/src/components/Chat/ChatGroup.tsx
index 9c9d736..0cf2cc6 100644
--- a/src/components/Chat/ChatGroup.tsx
+++ b/src/components/Chat/ChatGroup.tsx
@@ -97,27 +97,28 @@ export const ChatGroup = ({selectedGroup, secretKey, setSecretKey, getSecretKey,
}
const middletierFunc = async (data: any, groupId: string) => {
- try {
- if (hasInitialized.current) {
- decryptMessages(data, true);
- return;
- }
- hasInitialized.current = true;
- const url = `${getBaseApiReact()}/chat/messages?txGroupId=${groupId}&encoding=BASE64&limit=0&reverse=false`;
- const response = await fetch(url, {
- method: "GET",
- headers: {
- "Content-Type": "application/json",
- },
- });
- const responseData = await response.json();
- decryptMessages(responseData, false);
- } catch (error) {
- console.error(error);
+ try {
+ if (hasInitialized.current) {
+ decryptMessages(data, true);
+ return;
}
- }
+ hasInitialized.current = true;
+ const url = `${getBaseApiReact()}/chat/messages?txGroupId=${groupId}&encoding=BASE64&limit=0&reverse=false`;
+ const response = await fetch(url, {
+ method: "GET",
+ headers: {
+ "Content-Type": "application/json",
+ },
+ });
+ const responseData = await response.json();
+ decryptMessages(responseData, false);
+ } catch (error) {
+ console.error(error);
+ }
+ }
- const decryptMessages = ( encryptedMessages: any[], isInitiated: boolean )=> {
+
+ const decryptMessages = (encryptedMessages: any[], isInitiated: boolean )=> {
try {
if(!secretKeyRef.current){
checkForFirstSecretKeyNotification(encryptedMessages)
@@ -231,6 +232,7 @@ export const ChatGroup = ({selectedGroup, secretKey, setSecretKey, getSecretKey,
}
} )
setMessages(formatted)
+
setChatReferences((prev) => {
let organizedChatReferences = { ...prev };
diff --git a/src/components/Chat/ChatList.tsx b/src/components/Chat/ChatList.tsx
index 2b5edce..284fc6f 100644
--- a/src/components/Chat/ChatList.tsx
+++ b/src/components/Chat/ChatList.tsx
@@ -1,21 +1,33 @@
-import React, { useCallback, useState, useEffect, useRef } from 'react';
-import { Virtuoso } from 'react-virtuoso';
+import React, { useCallback, useState, useEffect, useRef, useMemo } from 'react';
+import { useVirtualizer } from '@tanstack/react-virtual';
import { MessageItem } from './MessageItem';
import { subscribeToEvent, unsubscribeFromEvent } from '../../utils/events';
+import { useInView } from 'react-intersection-observer'
export const ChatList = ({ initialMessages, myAddress, tempMessages, chatId, onReply, handleReaction, chatReferences, tempChatReferences }) => {
-
- const virtuosoRef = useRef();
+ const parentRef = useRef();
const [messages, setMessages] = useState(initialMessages);
const [showScrollButton, setShowScrollButton] = useState(false);
const hasLoadedInitialRef = useRef(false);
- const isAtBottomRef = useRef(true); //
+ const isAtBottomRef = useRef(true);
+ // const [ref, inView] = useInView({
+ // threshold: 0.7
+ // })
+
+ // useEffect(() => {
+ // if (inView) {
+
+ // }
+ // }, [inView])
// Update message list with unique signatures and tempMessages
useEffect(() => {
let uniqueInitialMessagesMap = new Map();
+ // Only add a message if it doesn't already exist in the Map
initialMessages.forEach((message) => {
- uniqueInitialMessagesMap.set(message.signature, message);
+ if (!uniqueInitialMessagesMap.has(message.signature)) {
+ uniqueInitialMessagesMap.set(message.signature, message);
+ }
});
const uniqueInitialMessages = Array.from(uniqueInitialMessagesMap.values()).sort(
@@ -29,22 +41,14 @@ export const ChatList = ({ initialMessages, myAddress, tempMessages, chatId, onR
setTimeout(() => {
const hasUnreadMessages = totalMessages.some((msg) => msg.unread && !msg?.chatReference);
-
- if (virtuosoRef.current) {
-
-
- if (virtuosoRef.current && !isAtBottomRef.current && hasUnreadMessages) {
-
-
-
-
- setShowScrollButton(hasUnreadMessages);
+ if (parentRef.current) {
+ const { scrollTop, scrollHeight, clientHeight } = parentRef.current;
+ const atBottom = scrollTop + clientHeight >= scrollHeight - 10; // Adjust threshold as needed
+ if (!atBottom && hasUnreadMessages) {
+ setShowScrollButton(hasUnreadMessages);
} else {
handleMessageSeen();
-
}
-
-
}
if (!hasLoadedInitialRef.current) {
scrollToBottom(totalMessages);
@@ -53,7 +57,14 @@ export const ChatList = ({ initialMessages, myAddress, tempMessages, chatId, onR
}, 500);
}, [initialMessages, tempMessages]);
-
+ const scrollToBottom = (initialMsgs) => {
+ const index = initialMsgs ? initialMsgs.length - 1 : messages.length - 1;
+ if (rowVirtualizer) {
+ rowVirtualizer.scrollToIndex(index, { align: 'end' });
+ }
+ handleMessageSeen()
+ };
+
const handleMessageSeen = useCallback(() => {
setMessages((prevMessages) =>
@@ -62,34 +73,16 @@ export const ChatList = ({ initialMessages, myAddress, tempMessages, chatId, onR
unread: false,
}))
);
+ setShowScrollButton(false)
}, []);
- const scrollToItem = useCallback((index) => {
- if (virtuosoRef.current) {
- virtuosoRef.current.scrollToIndex({ index, behavior: 'smooth' });
- }
- }, []);
+ // const scrollToBottom = (initialMsgs) => {
+ // const index = initialMsgs ? initialMsgs.length - 1 : messages.length - 1;
+ // if (parentRef.current) {
+ // parentRef.current.scrollToIndex(index);
+ // }
+ // };
- const scrollToBottom = (initialMsgs) => {
-
- const index = initialMsgs ? initialMsgs.length - 1 : messages.length - 1
- if (virtuosoRef.current) {
- virtuosoRef.current.scrollToIndex({ index});
- }
- };
-
-
- const handleScroll = (scrollState) => {
- const { scrollTop, scrollHeight, clientHeight } = scrollState;
- const isAtBottom = scrollTop + clientHeight >= scrollHeight - 50;
- const hasUnreadMessages = messages.some((msg) => msg.unread);
-
- if (isAtBottom) {
- handleMessageSeen();
- }
-
- setShowScrollButton(!isAtBottom && hasUnreadMessages);
- };
const sentNewMessageGroupFunc = useCallback(() => {
scrollToBottom();
@@ -102,96 +95,134 @@ export const ChatList = ({ initialMessages, myAddress, tempMessages, chatId, onR
};
}, [sentNewMessageGroupFunc]);
- const rowRenderer = (index) => {
- let message = messages[index];
- let replyIndex = messages.findIndex((msg)=> msg?.signature === message?.repliedTo)
- let reply
- let reactions = null
- if(message?.repliedTo && replyIndex !== -1){
- reply = messages[replyIndex]
- }
- if(message?.message && message?.groupDirectId){
- replyIndex = messages.findIndex((msg)=> msg?.signature === message?.message?.repliedTo)
- reply
- if(message?.message?.repliedTo && replyIndex !== -1){
- reply = messages[replyIndex]
- }
- message = {
- ...(message?.message || {}),
- isTemp: true,
- unread: false
+ const lastSignature = useMemo(()=> {
+ if(!messages || messages?.length === 0) return null
+ const lastIndex = messages.length - 1
+ return messages[lastIndex]?.signature
+ }, [messages])
+
+
+ // Initialize the virtualizer
+ const rowVirtualizer = useVirtualizer({
+ count: messages.length,
+ getScrollElement: () => parentRef.current,
+ estimateSize: () => 80, // Provide an estimated height of items, adjust this as needed
+ overscan: 10, // Number of items to render outside the visible area to improve smoothness
+ measureElement:
+ typeof window !== 'undefined' &&
+ navigator.userAgent.indexOf('Firefox') === -1
+ ? element => {
+ return element?.getBoundingClientRect().height
}
- }
-
- if(chatReferences && chatReferences[message?.signature]){
- if(chatReferences[message.signature]?.reactions){
- reactions = chatReferences[message.signature]?.reactions
- }
- }
- let isUpdating = false
- if(tempChatReferences && tempChatReferences?.find((item)=> item?.chatReference === message?.signature)){
- isUpdating = true
- }
-
- return (
-
-
- );
- };
-
- const handleAtBottomStateChange = (atBottom) => {
- isAtBottomRef.current = atBottom;
- if(atBottom){
- handleMessageSeen();
- setShowScrollButton(false)
- }
- };
+ : undefined,
+ });
return (
-
-
+
+ {showScrollButton && (
+
+ )}
+
+
);
};
diff --git a/src/components/Chat/MessageItem.tsx b/src/components/Chat/MessageItem.tsx
index a43170d..681130b 100644
--- a/src/components/Chat/MessageItem.tsx
+++ b/src/components/Chat/MessageItem.tsx
@@ -29,7 +29,8 @@ export const MessageItem = ({
scrollToItem,
handleReaction,
reactions,
- isUpdating
+ isUpdating,
+ lastSignature
}) => {
const { ref, inView } = useInView({
threshold: 0.7, // Fully visible
@@ -42,9 +43,10 @@ export const MessageItem = ({
}
}, [inView, message.id, message.unread, onSeen]);
+
return (
+ {rowVirtualizer.getVirtualItems().map((virtualRow) => {
+ const index = virtualRow.index;
+ let message = messages[index];
+ let replyIndex = messages.findIndex((msg) => msg?.signature === message?.repliedTo);
+ let reply;
+ let reactions = null;
- {showScrollButton && (
-
- )}
+ if (message?.repliedTo && replyIndex !== -1) {
+ reply = messages[replyIndex];
+ }
+
+ if (message?.message && message?.groupDirectId) {
+ replyIndex = messages.findIndex((msg) => msg?.signature === message?.message?.repliedTo);
+ if (message?.message?.repliedTo && replyIndex !== -1) {
+ reply = messages[replyIndex];
+ }
+ message = {
+ ...(message?.message || {}),
+ isTemp: true,
+ unread: false,
+ };
+ }
+
+ if (chatReferences && chatReferences[message?.signature]) {
+ if (chatReferences[message.signature]?.reactions) {
+ reactions = chatReferences[message.signature]?.reactions;
+ }
+ }
+
+ let isUpdating = false;
+ if (tempChatReferences && tempChatReferences?.find((item) => item?.chatReference === message?.signature)) {
+ isUpdating = true;
+ }
+
+ return (
+
+
+
rowVirtualizer.measureElement(node)} //measure dynamic row height
+ key={message.signature}
+ style={{
+ position: 'absolute',
+ top: 0,
+ left: '50%', // Move to the center horizontally
+ transform: `translateY(${virtualRow.start}px) translateX(-50%)`, // Adjust for centering
+ width: '100%', // Control width (90% of the parent)
+ padding: '10px 0',
+ display: 'flex',
+ justifyContent: 'center',
+ overscrollBehavior: 'none',
+ }}
+ >
+ rowVirtualizer.scrollToIndex(idx)}
+ handleReaction={handleReaction}
+ reactions={reactions}
+ isUpdating={isUpdating}
+ />
+
+ );
+ })}
+ ({
+ '& .MuiPaper-root': {
+ backgroundColor: '#f9f9f9',
+ borderRadius: '12px',
+ padding: theme.spacing(1),
+ boxShadow: '0 5px 15px rgba(0, 0, 0, 0.2)',
+ },
+ '& .MuiMenuItem-root': {
+ fontSize: '14px',
+ color: '#444',
+ transition: '0.3s background-color',
+ '&:hover': {
+ backgroundColor: '#f0f0f0',
+ },
+ },
+}));
+
+export const ContextMenuPinnedApps = ({ children, app, isMine }) => {
+ const [menuPosition, setMenuPosition] = useState(null);
+ const longPressTimeout = useRef(null);
+ const maxHoldTimeout = useRef(null);
+ const preventClick = useRef(false);
+ const startTouchPosition = useRef({ x: 0, y: 0 }); // Track initial touch position
+ const [sortablePinnedApps, setSortablePinnedApps] = useRecoilState(sortablePinnedAppsAtom);
+
+ const handleContextMenu = (event) => {
+ if(isMine) return
+ event.preventDefault();
+ event.stopPropagation();
+ preventClick.current = true;
+ setMenuPosition({
+ mouseX: event.clientX,
+ mouseY: event.clientY,
+ });
+ };
+
+ const handleTouchStart = (event) => {
+ if(isMine) return
+
+ const { clientX, clientY } = event.touches[0];
+ startTouchPosition.current = { x: clientX, y: clientY };
+
+ longPressTimeout.current = setTimeout(() => {
+ preventClick.current = true;
+
+ event.stopPropagation();
+ setMenuPosition({
+ mouseX: clientX,
+ mouseY: clientY,
+ });
+ }, 500);
+
+ // Set a maximum hold duration (e.g., 1.5 seconds)
+ maxHoldTimeout.current = setTimeout(() => {
+ clearTimeout(longPressTimeout.current);
+ }, 1500);
+ };
+
+ const handleTouchMove = (event) => {
+ if(isMine) return
+
+ const { clientX, clientY } = event.touches[0];
+ const { x, y } = startTouchPosition.current;
+
+ // Determine if the touch has moved beyond a small threshold (e.g., 10px)
+ const movedEnough = Math.abs(clientX - x) > 10 || Math.abs(clientY - y) > 10;
+
+ if (movedEnough) {
+ clearTimeout(longPressTimeout.current);
+ clearTimeout(maxHoldTimeout.current);
+ }
+ };
+
+ const handleTouchEnd = (event) => {
+ if(isMine) return
+
+ clearTimeout(longPressTimeout.current);
+ clearTimeout(maxHoldTimeout.current);
+ if (preventClick.current) {
+ event.preventDefault();
+ event.stopPropagation();
+ preventClick.current = false;
+ }
+ };
+
+ const handleClose = (e) => {
+ if(isMine) return
+
+ e.preventDefault();
+ e.stopPropagation();
+ setMenuPosition(null);
+ };
+
+ return (
+
{children}
@@ -69,9 +72,17 @@ export const DesktopFooter = ({
isHome,
isGroups,
isDirects,
- setDesktopSideView
+ setDesktopSideView,
+ isApps,
+ setDesktopViewMode,
+ desktopViewMode,
+ hide,
+ setIsOpenSideViewDirects,
+ setIsOpenSideViewGroups
+
}) => {
- const [value, setValue] = React.useState(0);
+
+ if(hide) return
return (
-
- {
- goToHome()
- }}>
-
-
-
- {
- setDesktopSideView('groups')
- }}>
-
-
-
- {
- setDesktopSideView('directs')
- }}>
-
-
-
-
-
-
+
+ {
+ goToHome();
+ }}
+ >
+
+
+
+ {
+ setDesktopViewMode('apps')
+ setIsOpenSideViewDirects(false)
+ setIsOpenSideViewGroups(false)
+ }}
+ >
+
+ 
+
+
+ {
+ setDesktopSideView("groups");
+ }}
+ >
+
+
+
+ {
+ setDesktopSideView("directs");
+ }}
+ >
+
+
+
+
+
);
};
diff --git a/src/components/Drawer/Drawer.tsx b/src/components/Drawer/Drawer.tsx
index 2e545cd..0296088 100644
--- a/src/components/Drawer/Drawer.tsx
+++ b/src/components/Drawer/Drawer.tsx
@@ -11,6 +11,7 @@ import ListItemText from '@mui/material/ListItemText';
import InboxIcon from '@mui/icons-material/MoveToInbox';
import MailIcon from '@mui/icons-material/Mail';
import CloseIcon from '@mui/icons-material/Close';
+import { isMobile } from '../../App';
export const DrawerComponent = ({open, setOpen, children}) => {
const toggleDrawer = (newOpen: boolean) => () => {
@@ -21,7 +22,7 @@ export const DrawerComponent = ({open, setOpen, children}) => {
return (
-
+
{children}
diff --git a/src/components/Group/Forum/GroupMail.tsx b/src/components/Group/Forum/GroupMail.tsx
index 05a1b3e..36fefad 100644
--- a/src/components/Group/Forum/GroupMail.tsx
+++ b/src/components/Group/Forum/GroupMail.tsx
@@ -536,10 +536,14 @@ export const GroupMail = ({
});
// Convert the map back to an array and sort by "created" timestamp in descending order
- const sortedList = Array.from(uniqueItems.values()).sort((a, b) => b.threadData?.createdAt - a.threadData?.createdAt);
+ const sortedList = Array.from(uniqueItems.values()).sort((a, b) =>
+ filterMode === 'Oldest'
+ ? a.threadData?.createdAt - b.threadData?.createdAt
+ : b.threadData?.createdAt - a.threadData?.createdAt
+);
return sortedList;
- }, [tempPublishedList, listOfThreadsToDisplay]);
+ }, [tempPublishedList, listOfThreadsToDisplay, filterMode]);
if (currentThread)
return (
diff --git a/src/components/Group/Forum/Mail-styles.ts b/src/components/Group/Forum/Mail-styles.ts
index 2d39cee..5308bf0 100644
--- a/src/components/Group/Forum/Mail-styles.ts
+++ b/src/components/Group/Forum/Mail-styles.ts
@@ -754,29 +754,7 @@ export const GroupContainer = styled(Box)`
position: relative;
overflow: auto;
width: 100%;
-&::-webkit-scrollbar-track {
- background-color: transparent;
-}
-&::-webkit-scrollbar-track:hover {
- background-color: transparent;
-}
-&::-webkit-scrollbar {
- width: 16px;
- height: 10px;
- background-color: white;
-}
-
-&::-webkit-scrollbar-thumb {
- background-color: #838eee;
- border-radius: 8px;
- background-clip: content-box;
- border: 4px solid transparent;
-}
-
-&::-webkit-scrollbar-thumb:hover {
- background-color: #6270f0;
-}
`
diff --git a/src/components/Group/Group.tsx b/src/components/Group/Group.tsx
index 45d9c57..9206914 100644
--- a/src/components/Group/Group.tsx
+++ b/src/components/Group/Group.tsx
@@ -88,6 +88,9 @@ import { ExitIcon } from "../../assets/Icons/ExitIcon";
import { HomeDesktop } from "./HomeDesktop";
import { DesktopFooter } from "../Desktop/DesktopFooter";
import { DesktopHeader } from "../Desktop/DesktopHeader";
+import { Apps } from "../Apps/Apps";
+import { AppsNavBar } from "../Apps/AppsNavBar";
+import { AppsDesktop } from "../Apps/AppsDesktop";
// let touchStartY = 0;
// let disablePullToRefresh = false;
@@ -373,7 +376,11 @@ export const Group = ({
isOpenDrawerProfile,
setIsOpenDrawerProfile,
logoutFunc,
+ setDesktopViewMode,
+ desktopViewMode
}: GroupProps) => {
+ const [desktopSideView, setDesktopSideView] = useState('groups')
+
const [secretKey, setSecretKey] = useState(null);
const [secretKeyPublishDate, setSecretKeyPublishDate] = useState(null);
const lastFetchedSecretKey = useRef(null);
@@ -418,7 +425,6 @@ export const Group = ({
const [mutedGroups, setMutedGroups] = useState([]);
const [mobileViewMode, setMobileViewMode] = useState("home");
const [mobileViewModeKeepOpen, setMobileViewModeKeepOpen] = useState("");
- const [desktopSideView, setDesktopSideView] = useState('groups')
const isFocusedRef = useRef(true);
const timestampEnterDataRef = useRef({});
const selectedGroupRef = useRef(null);
@@ -431,7 +437,22 @@ export const Group = ({
const { clearStatesMessageQueueProvider } = useMessageQueue();
const initiatedGetMembers = useRef(false);
const [groupChatTimestamps, setGroupChatTimestamps] = React.useState({});
+ const [appsMode, setAppsMode] = useState('home')
+ const [isOpenSideViewDirects, setIsOpenSideViewDirects] = useState(false)
+ const [isOpenSideViewGroups, setIsOpenSideViewGroups] = useState(false)
+ const toggleSideViewDirects = ()=> {
+ if(isOpenSideViewGroups){
+ setIsOpenSideViewGroups(false)
+ }
+ setIsOpenSideViewDirects((prev)=> !prev)
+ }
+ const toggleSideViewGroups = ()=> {
+ if(isOpenSideViewDirects){
+ setIsOpenSideViewDirects(false)
+ }
+ setIsOpenSideViewGroups((prev)=> !prev)
+ }
useEffect(()=> {
timestampEnterDataRef.current = timestampEnterData
}, [timestampEnterData])
@@ -821,98 +842,7 @@ export const Group = ({
}
}, [selectedGroup]);
- // const handleNotification = async (data)=> {
- // try {
- // if(isFocusedRef.current){
- // throw new Error('isFocused')
- // }
- // const newActiveChats= data
- // const oldActiveChats = await new Promise((res, rej) => {
- // chrome?.runtime?.sendMessage(
- // {
- // action: "getChatHeads",
- // },
- // (response) => {
- // console.log({ response });
- // if (!response?.error) {
- // res(response);
- // }
- // rej(response.error);
- // }
- // );
- // });
-
- // let results = []
- // newActiveChats?.groups?.forEach(newChat => {
- // let isNewer = true;
- // oldActiveChats?.data?.groups?.forEach(oldChat => {
- // if (newChat?.timestamp <= oldChat?.timestamp) {
- // isNewer = false;
- // }
- // });
- // if (isNewer) {
- // results.push(newChat)
- // console.log('This newChat is newer than all oldChats:', newChat);
- // }
- // });
-
- // if(results?.length > 0){
- // if (!lastGroupNotification.current || (Date.now() - lastGroupNotification.current >= 60000)) {
- // console.log((Date.now() - lastGroupNotification.current >= 60000), lastGroupNotification.current)
- // chrome?.runtime?.sendMessage(
- // {
- // action: "notification",
- // payload: {
- // },
- // },
- // (response) => {
- // console.log({ response });
- // if (!response?.error) {
-
- // }
-
- // }
- // );
- // audio.play();
- // lastGroupNotification.current = Date.now()
-
- // }
- // }
-
- // } catch (error) {
- // console.log('error not', error)
- // if(!isFocusedRef.current){
- // chrome?.runtime?.sendMessage(
- // {
- // action: "notification",
- // payload: {
- // },
- // },
- // (response) => {
- // console.log({ response });
- // if (!response?.error) {
-
- // }
-
- // }
- // );
- // audio.play();
- // lastGroupNotification.current = Date.now()
- // }
-
- // } finally {
-
- // chrome?.runtime?.sendMessage(
- // {
- // action: "setChatHeads",
- // payload: {
- // data,
- // },
- // }
- // );
-
- // }
- // }
+
const getAdmins = async (groupId) => {
try {
@@ -1176,6 +1106,7 @@ export const Group = ({
if (findDirect) {
if(!isMobile){
setDesktopSideView("directs");
+ setDesktopViewMode('home')
} else {
setMobileViewModeKeepOpen("messaging");
}
@@ -1213,6 +1144,7 @@ export const Group = ({
if (findDirect) {
if(!isMobile){
setDesktopSideView("directs");
+ setDesktopViewMode('home')
} else {
setMobileViewModeKeepOpen("messaging");
}
@@ -1236,6 +1168,7 @@ export const Group = ({
} else {
if(!isMobile){
setDesktopSideView("directs");
+ setDesktopViewMode('home')
} else {
setMobileViewModeKeepOpen("messaging");
}
@@ -1402,6 +1335,8 @@ export const Group = ({
setTimeout(() => {
setSelectedGroup(findGroup);
setMobileViewMode("group");
+ setDesktopSideView('groups')
+ setDesktopViewMode('home')
getTimestampEnterChat();
isLoadingOpenSectionFromNotification.current = false;
}, 200);
@@ -1449,7 +1384,8 @@ export const Group = ({
setTimeout(() => {
setSelectedGroup(findGroup);
setMobileViewMode("group");
-
+ setDesktopSideView('groups')
+ setDesktopViewMode('home')
getGroupAnnouncements();
}, 200);
}
@@ -1504,6 +1440,8 @@ export const Group = ({
setTimeout(() => {
setSelectedGroup(findGroup);
setMobileViewMode("group");
+ setDesktopSideView('groups')
+ setDesktopViewMode('home')
getGroupAnnouncements();
}, 200);
}
@@ -1527,6 +1465,8 @@ export const Group = ({
}
if (!isMobile) {
}
+ setDesktopViewMode('home')
+
setGroupSection("default");
clearAllQueues();
await new Promise((res) => {
@@ -1550,6 +1490,8 @@ export const Group = ({
setMemberCountFromSecretKeyData(null);
setTriedToFetchSecretKey(false);
setFirstSecretKeyInCreation(false);
+ setIsOpenSideViewDirects(false)
+ setIsOpenSideViewGroups(false)
};
const goToAnnouncements = async () => {
@@ -2025,6 +1967,8 @@ export const Group = ({
// }
onClick={() => {
setMobileViewMode("group");
+ setDesktopSideView('groups')
+ setDesktopViewMode('home')
initiatedGetMembers.current = false;
clearAllQueues();
setSelectedDirect(null);
@@ -2228,7 +2172,7 @@ export const Group = ({
isThin={
mobileViewMode === "groups" ||
mobileViewMode === "group" ||
- mobileViewModeKeepOpen === "messaging"
+ mobileViewModeKeepOpen === "messaging" || (mobileViewMode === "apps" && appsMode !== 'home')
}
logoutFunc={logoutFunc}
goToHome={goToHome}
@@ -2253,8 +2197,8 @@ export const Group = ({
alignItems: "flex-start",
}}
>
- {!isMobile && desktopSideView === 'groups' && renderGroups()}
- {!isMobile && desktopSideView === 'directs' && renderDirects()}
+ {!isMobile && ((desktopSideView === 'groups' && desktopViewMode !== 'apps') || isOpenSideViewGroups) && renderGroups()}
+ {!isMobile && ((desktopSideView === 'directs' && desktopViewMode !== 'apps') || isOpenSideViewDirects) && renderDirects()}
- {/*
-
- Home
-
-
- {selectedGroup && (
- <>
-
-
- Announcements
-
-
-
-
-
- Chat
-
-
-
- {
- setGroupSection("forum");
- setSelectedDirect(null);
- setNewChat(false);
- }}
- >
-
- Forum
-
-
- setOpenManageMembers(true)}
- sx={{
- display: "flex",
- gap: "3px",
- alignItems: "center",
- justifyContent: "flex-start",
- width: "100%",
- cursor: "pointer",
- }}
- >
-
- Members
-
-
-
- {isMobile && mobileViewMode === "home" && !mobileViewModeKeepOpen && (
+ {(isMobile && mobileViewMode === "home" || (isMobile && mobileViewMode === "apps" && appsMode === 'home')) && !mobileViewModeKeepOpen && (
<>
)}
+ {(isMobile && mobileViewMode === "apps" && appsMode !== 'home') && !mobileViewModeKeepOpen && (
+ <>
+
-//
-// {selectedGroup && (
-// <>
-//
-// }
-// sx={{
-// padding: "4px 6px",
-// color:
-// groupSection === "announcement" ? "black" : "white",
-// backgroundColor: isUnread
-// ? "red"
-// : groupSection === "announcement"
-// ? "white"
-// : "black",
-// "&:hover": {
-// backgroundColor: isUnread
-// ? "red"
-// : groupSection === "announcement"
-// ? "white"
-// : "black",
-// },
-// "&:active": {
-// backgroundColor: isUnread
-// ? "red"
-// : groupSection === "announcement"
-// ? "white"
-// : "black",
-// },
-// "&:focus": {
-// backgroundColor: isUnread
-// ? "red"
-// : groupSection === "announcement"
-// ? "white"
-// : "black",
-// },
-// }}
-// onClick={goToAnnouncements}
-// >
-// ANN
-//
-//
-//
-// }
-// sx={{
-// padding: "4px 6px",
-// color: groupSection === "chat" ? "black" : "white",
-// backgroundColor: isUnreadChat
-// ? "red"
-// : groupSection === "chat"
-// ? "white"
-// : "black",
-// "&:hover": {
-// backgroundColor: isUnreadChat
-// ? "red"
-// : groupSection === "chat"
-// ? "white"
-// : "black", // Same logic for hover
-// },
-// "&:active": {
-// backgroundColor: isUnreadChat
-// ? "red"
-// : groupSection === "chat"
-// ? "white"
-// : "black", // Same logic for active
-// },
-// "&:focus": {
-// backgroundColor: isUnreadChat
-// ? "red"
-// : groupSection === "chat"
-// ? "white"
-// : "black", // Same logic for focus
-// },
-// }}
-// onClick={goToChat}
-// >
-// Chat
-//
-//
-//
-// }
-// sx={{
-// padding: "4px 6px",
-// color: groupSection === "forum" ? "black" : "white",
-// backgroundColor:
-// groupSection === "forum" ? "white" : "black",
-// "&:hover": {
-// backgroundColor: groupSection === "forum" ? "white" : "black", // Hover state
-// },
-// "&:active": {
-// backgroundColor: groupSection === "forum" ? "white" : "black", // Active state
-// },
-// "&:focus": {
-// backgroundColor: groupSection === "forum" ? "white" : "black", // Focus state
-// },
-// }}
-// onClick={() => {
-// setSelectedDirect(null);
-// setNewChat(false)
-// setGroupSection("forum")
-// } }
-// >
-// Forum
-//
-//
-//
-// }
-// sx={{ padding: "4px 6px", backgroundColor: "black", "&:hover": {
-// backgroundColor: "black", // Hover state
-// },
-// "&:active": {
-// backgroundColor: "black", // Active state
-// },
-// "&:focus": {
-// backgroundColor: "black", // Focus state
-// }, }}
-// onClick={() => setOpenManageMembers(true)}
-// >
-// Members
-//
-//
-//
-// )}
-// {/* Second row: Groups, Home, Profile */}
-//
-// }
-// sx={{
-// padding: "2px 4px",
-// backgroundColor:
-// groupChatHasUnread ||
-// groupsAnnHasUnread ||
-// directChatHasUnread
-// ? "red"
-// : "black",
-// "&:hover": {
-// backgroundColor:
-// groupChatHasUnread || groupsAnnHasUnread || directChatHasUnread
-// ? "red"
-// : "black", // Hover state follows the same logic
-// },
-// "&:active": {
-// backgroundColor:
-// groupChatHasUnread || groupsAnnHasUnread || directChatHasUnread
-// ? "red"
-// : "black", // Active state follows the same logic
-// },
-// "&:focus": {
-// backgroundColor:
-// groupChatHasUnread || groupsAnnHasUnread || directChatHasUnread
-// ? "red"
-// : "black", // Focus state follows the same logic
-// },
-// }}
-// onClick={() => {
-// setIsOpenDrawer(true);
-// setDrawerMode("groups");
-// }}
-// >
-// {chatMode === "groups" ? "Groups" : "Direct"}
-//
-//
-//
-//
-//
-//
-//
-// setIsOpenDrawerProfile(true)}
-// >
-//
-//
-//
-//
-// )}
diff --git a/src/components/Group/GroupJoinRequests.tsx b/src/components/Group/GroupJoinRequests.tsx
index d373435..47fcb31 100644
--- a/src/components/Group/GroupJoinRequests.tsx
+++ b/src/components/Group/GroupJoinRequests.tsx
@@ -48,20 +48,7 @@ export const GroupJoinRequests = ({ myAddress, groups, setOpenManageMembers, get
return true
})
- // const getJoinGroupRequests = groupsAsAdmin.map(async (group)=> {
- // console.log('getJoinGroupRequests', group)
- // const joinRequestResponse = await requestQueueGroupJoinRequests.enqueue(()=> {
- // return fetch(
- // `${getBaseApiReact()}/groups/joinrequests/${group.groupId}`
- // );
- // })
-
- // const joinRequestData = await joinRequestResponse.json()
- // return {
- // group,
- // data: joinRequestData
- // }
- // })
+
await Promise.all(getAllGroupsAsAdmin)
const res = await Promise.all(groupsAsAdmin.map(async (group)=> {
diff --git a/src/components/Group/GroupMenu.tsx b/src/components/Group/GroupMenu.tsx
index 5aff12e..989c7de 100644
--- a/src/components/Group/GroupMenu.tsx
+++ b/src/components/Group/GroupMenu.tsx
@@ -134,6 +134,7 @@ export const GroupMenu = ({ setGroupSection, groupSection, setOpenManageMembers,
"& .MuiTypography-root": {
fontSize: "12px",
fontWeight: 600,
+ color: hasUnreadChat ? "var(--unread)" :"#fff"
},
}} primary="Chat" />
@@ -153,6 +154,7 @@ export const GroupMenu = ({ setGroupSection, groupSection, setOpenManageMembers,
"& .MuiTypography-root": {
fontSize: "12px",
fontWeight: 600,
+ color: hasUnreadAnnouncements ? "var(--unread)" :"#fff"
},
}} primary="Announcements" />
diff --git a/src/components/Mobile/MobileFooter.tsx b/src/components/Mobile/MobileFooter.tsx
index ca31331..7cb3a32 100644
--- a/src/components/Mobile/MobileFooter.tsx
+++ b/src/components/Mobile/MobileFooter.tsx
@@ -2,11 +2,14 @@ import * as React from "react";
import {
BottomNavigation,
BottomNavigationAction,
+ ButtonBase,
Typography,
} from "@mui/material";
import { Home, Groups, Message, ShowChart } from "@mui/icons-material";
import Box from "@mui/material/Box";
import BottomLogo from "../../assets/svgs/BottomLogo5.svg";
+import LogoSelected from "../../assets/svgs/LogoSelected.svg";
+
import { CustomSvg } from "../../common/CustomSvg";
import { WalletIcon } from "../../assets/Icons/WalletIcon";
import { HubsIcon } from "../../assets/Icons/HubsIcon";
@@ -132,6 +135,15 @@ export const MobileFooter = ({
zIndex: 3,
}}
>
+ {
+ if(mobileViewMode === 'home'){
+ setMobileViewMode('apps')
+
+ } else {
+ setMobileViewMode('home')
+
+ }
+ }}>
{/* Custom Center Icon */}
- 
+ 
+
{
const [anchorEl, setAnchorEl] = useState(null);
const open = Boolean(anchorEl);
-
+ const [fullScreen, setFullScreen] = useRecoilState(fullScreenAtom);
+ const {exitFullScreen} = useAppFullScreen(setFullScreen)
const handleClick = (event) => {
setAnchorEl(event.currentTarget);
};
@@ -76,10 +76,10 @@ const Header = ({
width: "75px",
}}
>
- {
setMobileViewModeKeepOpen("");
goToHome();
@@ -87,15 +87,24 @@ const Header = ({
// onClick={onHomeClick}
>
-
+
+
+ {fullScreen && (
+ {
+ exitFullScreen()
+ setFullScreen(false)
+ }}>
+
+ )}
+
{/* Center Title */}
@@ -121,34 +130,25 @@ const Header = ({
>
{/* Right Logout Icon */}
- {
setMobileViewModeKeepOpen("messaging");
}}
- edge="end"
- color="inherit"
- aria-label="logout"
-
- // onClick={onLogoutClick}
>
-
+
+
@@ -247,16 +247,32 @@ const Header = ({
}}
>
{/* Left Home Icon */}
-
+
-
+
+ {fullScreen && (
+ {
+ exitFullScreen()
+ setFullScreen(false)
+ }}>
+
+ )}
+
{/* Center Title */}
QORTAL
-
+
{/* Right Logout Icon */}
-
+
diff --git a/src/components/Save/Save.tsx b/src/components/Save/Save.tsx
new file mode 100644
index 0000000..e00bd08
--- /dev/null
+++ b/src/components/Save/Save.tsx
@@ -0,0 +1,161 @@
+import React, { useContext, useEffect, useMemo, useState } from 'react'
+import { useRecoilState, useSetRecoilState } from 'recoil';
+import isEqual from 'lodash/isEqual'; // Import deep comparison utility
+import { canSaveSettingToQdnAtom, hasSettingsChangedAtom, oldPinnedAppsAtom, settingsLocalLastUpdatedAtom, settingsQDNLastUpdatedAtom, sortablePinnedAppsAtom } from '../../atoms/global';
+import { ButtonBase } from '@mui/material';
+import { objectToBase64 } from '../../qdn/encryption/group-encryption';
+import { MyContext } from '../../App';
+import { getFee } from '../../background';
+import { CustomizedSnackbars } from '../Snackbar/Snackbar';
+import { SaveIcon } from '../../assets/svgs/SaveIcon';
+import { IconWrapper } from '../Desktop/DesktopFooter';
+export const Save = ({isDesktop}) => {
+ const [pinnedApps, setPinnedApps] = useRecoilState(sortablePinnedAppsAtom);
+ const [settingsQdnLastUpdated, setSettingsQdnLastUpdated] = useRecoilState(settingsQDNLastUpdatedAtom);
+ const [settingsLocalLastUpdated] = useRecoilState(settingsLocalLastUpdatedAtom);
+ const setHasSettingsChangedAtom = useSetRecoilState(hasSettingsChangedAtom);
+
+ const [canSave] = useRecoilState(canSaveSettingToQdnAtom);
+ const [openSnack, setOpenSnack] = useState(false);
+ const [isLoading, setIsLoading] = useState(false)
+ const [infoSnack, setInfoSnack] = useState(null);
+ const [oldPinnedApps, setOldPinnedApps] = useRecoilState(oldPinnedAppsAtom)
+
+ const { show } = useContext(MyContext);
+
+ const hasChanged = useMemo(()=> {
+ const newChanges = {
+ sortablePinnedApps: pinnedApps.map((item)=> {
+ return {
+ name: item?.name,
+ service: item?.service
+ }
+ })
+ }
+ const oldChanges = {
+ sortablePinnedApps: oldPinnedApps.map((item)=> {
+ return {
+ name: item?.name,
+ service: item?.service
+ }
+ })
+ }
+ if(settingsQdnLastUpdated === -100) return false
+ return !isEqual(oldChanges, newChanges) && settingsQdnLastUpdated < settingsLocalLastUpdated
+ }, [oldPinnedApps, pinnedApps, settingsQdnLastUpdated, settingsLocalLastUpdated])
+
+ useEffect(()=> {
+ setHasSettingsChangedAtom(hasChanged)
+ }, [hasChanged])
+
+ const saveToQdn = async ()=> {
+ try {
+ setIsLoading(true)
+ const data64 = await objectToBase64({
+ sortablePinnedApps: pinnedApps.map((item)=> {
+ return {
+ name: item?.name,
+ service: item?.service
+ }
+ })
+ })
+ const encryptData = await new Promise((res, rej) => {
+ chrome?.runtime?.sendMessage(
+ {
+ action: "ENCRYPT_DATA",
+ type: "qortalRequest",
+ payload: {
+ data64
+ },
+ },
+ (response) => {
+ if (response.error) {
+ rej(response?.message);
+ return;
+ } else {
+ res(response);
+
+ }
+ }
+ );
+ });
+ if(encryptData && !encryptData?.error){
+ const fee = await getFee('ARBITRARY')
+
+ await show({
+ message: "Would you like to publish your settings to QDN (encrypted) ?" ,
+ publishFee: fee.fee + ' QORT'
+ })
+ const response = await new Promise((res, rej) => {
+ chrome?.runtime?.sendMessage(
+ {
+ action: "publishOnQDN",
+ payload: {
+ data: encryptData,
+ identifier: "ext_saved_settings",
+ service: 'DOCUMENT_PRIVATE'
+ },
+ },
+ (response) => {
+
+ if (!response?.error) {
+ res(response);
+ return
+ }
+ rej(response.error);
+ }
+ );
+ });
+ if(response?.identifier){
+ setOldPinnedApps(pinnedApps)
+ setSettingsQdnLastUpdated(Date.now())
+ setInfoSnack({
+ type: "success",
+ message:
+ "Sucessfully published to QDN",
+ });
+ setOpenSnack(true);
+ }
+ }
+ } catch (error) {
+ setInfoSnack({
+ type: "error",
+ message:
+ error?.message || "Unable to save to QDN",
+ });
+ setOpenSnack(true);
+ } finally {
+ setIsLoading(false)
+ }
+ }
+ return (
+ <>
+
+ {isDesktop ? (
+
+
+ ) : (
+
+
+ {children}
+ {
+ e.stopPropagation();
+ }}
+ >
+
+
+
+ );
+};
diff --git a/src/components/Desktop/DesktopFooter.tsx b/src/components/Desktop/DesktopFooter.tsx
index 4eafe8b..f1cf754 100644
--- a/src/components/Desktop/DesktopFooter.tsx
+++ b/src/components/Desktop/DesktopFooter.tsx
@@ -13,21 +13,24 @@ import { WalletIcon } from "../../assets/Icons/WalletIcon";
import { HubsIcon } from "../../assets/Icons/HubsIcon";
import { TradingIcon } from "../../assets/Icons/TradingIcon";
import { MessagingIcon } from "../../assets/Icons/MessagingIcon";
-import { HomeIcon } from "../../assets/Icons/HomeIcon";
+import AppIcon from "../../assets/svgs/AppIcon.svg";
-const IconWrapper = ({ children, label, color, selected }) => {
+import { HomeIcon } from "../../assets/Icons/HomeIcon";
+import { Save } from "../Save/Save";
+
+export const IconWrapper = ({ children, label, color, selected }) => {
return (
-
+
+
,
diff --git a/src/qdn/encryption/group-encryption.ts b/src/qdn/encryption/group-encryption.ts
index 1905d4d..4f61dd8 100644
--- a/src/qdn/encryption/group-encryption.ts
+++ b/src/qdn/encryption/group-encryption.ts
@@ -67,7 +67,7 @@ export const createSymmetricKeyAndNonce = () => {
export const encryptDataGroup = ({ data64, publicKeys, privateKey, userPublicKey }: any) => {
- let combinedPublicKeys = publicKeys
+ let combinedPublicKeys = [...publicKeys, userPublicKey]
const decodedPrivateKey = Base58.decode(privateKey)
const publicKeysDuplicateFree = [...new Set(combinedPublicKeys)]
@@ -275,11 +275,61 @@ export const decodeBase64ForUIChatMessages = (messages)=> {
-
+ export function decryptGroupDataQortalRequest(data64EncryptedData, privateKey) {
+ const allCombined = base64ToUint8Array(data64EncryptedData)
+ const str = "qortalGroupEncryptedData"
+ const strEncoder = new TextEncoder()
+ const strUint8Array = strEncoder.encode(str)
+ // Extract the nonce
+ const nonceStartPosition = strUint8Array.length
+ const nonceEndPosition = nonceStartPosition + 24 // Nonce is 24 bytes
+ const nonce = allCombined.slice(nonceStartPosition, nonceEndPosition)
+ // Extract the shared keyNonce
+ const keyNonceStartPosition = nonceEndPosition
+ const keyNonceEndPosition = keyNonceStartPosition + 24 // Nonce is 24 bytes
+ const keyNonce = allCombined.slice(keyNonceStartPosition, keyNonceEndPosition)
+ // Extract the sender's public key
+ const senderPublicKeyStartPosition = keyNonceEndPosition
+ const senderPublicKeyEndPosition = senderPublicKeyStartPosition + 32 // Public keys are 32 bytes
+ const senderPublicKey = allCombined.slice(senderPublicKeyStartPosition, senderPublicKeyEndPosition)
+ // Calculate count first
+ const countStartPosition = allCombined.length - 4 // 4 bytes before the end, since count is stored in Uint32 (4 bytes)
+ const countArray = allCombined.slice(countStartPosition, countStartPosition + 4)
+ const count = new Uint32Array(countArray.buffer)[0]
+ // Then use count to calculate encryptedData
+ const encryptedDataStartPosition = senderPublicKeyEndPosition // start position of encryptedData
+ const encryptedDataEndPosition = allCombined.length - ((count * (32 + 16)) + 4)
+ const encryptedData = allCombined.slice(encryptedDataStartPosition, encryptedDataEndPosition)
+ // Extract the encrypted keys
+ // 32+16 = 48
+ const combinedKeys = allCombined.slice(encryptedDataEndPosition, encryptedDataEndPosition + (count * 48))
+ if (!privateKey) {
+ throw new Error("Unable to retrieve keys")
+ }
+ const decodedPrivateKey = Base58.decode(privateKey)
+ const convertedPrivateKey = ed2curve.convertSecretKey(decodedPrivateKey)
+ const convertedSenderPublicKey = ed2curve.convertPublicKey(senderPublicKey)
+ const sharedSecret = new Uint8Array(32)
+ nacl.lowlevel.crypto_scalarmult(sharedSecret, convertedPrivateKey, convertedSenderPublicKey)
+ for (let i = 0; i < count; i++) {
+ const encryptedKey = combinedKeys.slice(i * 48, (i + 1) * 48)
+ // Decrypt the symmetric key.
+ const decryptedKey = nacl.secretbox.open(encryptedKey, keyNonce, sharedSecret)
+ // If decryption was successful, decryptedKey will not be null.
+ if (decryptedKey) {
+ // Decrypt the data using the symmetric key.
+ const decryptedData = nacl.secretbox.open(encryptedData, nonce, decryptedKey)
+ // If decryption was successful, decryptedData will not be null.
+ if (decryptedData) {
+ return decryptedData
+ }
+ }
+ }
+ throw new Error("Unable to decrypt data")
+}
export function decryptGroupData(data64EncryptedData: string, privateKey: string) {
-
const allCombined = base64ToUint8Array(data64EncryptedData)
const str = "qortalGroupEncryptedData"
const strEncoder = new TextEncoder()
@@ -331,4 +381,43 @@ export function decryptGroupData(data64EncryptedData: string, privateKey: string
}
}
throw new Error("Unable to decrypt data")
+}
+
+export function uint8ArrayStartsWith(uint8Array, string) {
+ const stringEncoder = new TextEncoder()
+ const stringUint8Array = stringEncoder.encode(string)
+ if (uint8Array.length < stringUint8Array.length) {
+ return false
+ }
+ for (let i = 0; i < stringUint8Array.length; i++) {
+ if (uint8Array[i] !== stringUint8Array[i]) {
+ return false
+ }
+ }
+ return true
+}
+
+export function decryptDeprecatedSingle(uint8Array, publicKey, privateKey) {
+ const combinedData = uint8Array
+ const str = "qortalEncryptedData"
+ const strEncoder = new TextEncoder()
+ const strUint8Array = strEncoder.encode(str)
+ const strData = combinedData.slice(0, strUint8Array.length)
+ const nonce = combinedData.slice(strUint8Array.length, strUint8Array.length + 24)
+ const _encryptedData = combinedData.slice(strUint8Array.length + 24)
+
+ const _publicKey = window.parent.Base58.decode(publicKey)
+ if (!privateKey || !_publicKey) {
+ throw new Error("Unable to retrieve keys")
+ }
+ const convertedPrivateKey = ed2curve.convertSecretKey(privateKey)
+ const convertedPublicKey = ed2curve.convertPublicKey(_publicKey)
+ const sharedSecret = new Uint8Array(32)
+ nacl.lowlevel.crypto_scalarmult(sharedSecret, convertedPrivateKey, convertedPublicKey)
+ const _chatEncryptionSeed = new window.parent.Sha256().process(sharedSecret).finish().result
+ const _decryptedData = nacl.secretbox.open(_encryptedData, nonce, _chatEncryptionSeed)
+ if (!_decryptedData) {
+ throw new Error("Unable to decrypt")
+ }
+ return uint8ArrayToBase64(_decryptedData)
}
\ No newline at end of file
diff --git a/src/qdn/publish/pubish.ts b/src/qdn/publish/pubish.ts
index f359bba..a57fd1e 100644
--- a/src/qdn/publish/pubish.ts
+++ b/src/qdn/publish/pubish.ts
@@ -153,7 +153,6 @@ export const publishData = async ({
fee = feeAmount
} else if (withFee) {
const res = await getArbitraryFee()
-
if (res.fee) {
fee = res.fee
} else {
@@ -162,9 +161,8 @@ export const publishData = async ({
}
let transactionBytes = await uploadData(registeredName, file, fee)
-
- if (transactionBytes.error) {
- throw new Error(transactionBytes.message || 'Error when uploading')
+ if (!transactionBytes || transactionBytes.error) {
+ throw new Error(transactionBytes?.message || 'Error when uploading')
} else if (transactionBytes.includes('Error 500 Internal Server Error')) {
throw new Error('Error when uploading')
}
@@ -183,7 +181,7 @@ export const publishData = async ({
}
const uploadData = async (registeredName: string, file:any, fee: number) => {
- if (identifier != null && identifier.trim().length > 0) {
+
let postBody = ''
let urlSuffix = ''
@@ -211,8 +209,7 @@ export const publishData = async ({
}
let uploadDataUrl = `/arbitrary/${service}/${registeredName}${urlSuffix}`
-
- if (identifier.trim().length > 0) {
+ if (identifier?.trim().length > 0) {
uploadDataUrl = `/arbitrary/${service}/${registeredName}/${identifier}${urlSuffix}`
}
@@ -256,7 +253,7 @@ export const publishData = async ({
}
return await reusablePost(uploadDataUrl, postBody)
- }
+
}
try {
diff --git a/src/qortalRequests.ts b/src/qortalRequests.ts
new file mode 100644
index 0000000..3174148
--- /dev/null
+++ b/src/qortalRequests.ts
@@ -0,0 +1,428 @@
+import { addForeignServer, addListItems, createPoll, decryptData, deleteListItems, deployAt, encryptData, getCrossChainServerInfo, getDaySummary, getForeignFee, getListItems, getServerConnectionHistory, getTxActivitySummary, getUserAccount, getUserWallet, getUserWalletInfo, getWalletBalance, joinGroup, publishMultipleQDNResources, publishQDNResource, removeForeignServer, saveFile, sendChatMessage, sendCoin, setCurrentForeignServer, updateForeignFee, voteOnPoll } from "./qortalRequests/get";
+
+
+
+// Promisify chrome.storage.local.get
+function getLocalStorage(key) {
+ return new Promise((resolve, reject) => {
+ chrome.storage.local.get([key], function (result) {
+ if (chrome.runtime.lastError) {
+ return reject(chrome.runtime.lastError);
+ }
+ resolve(result[key]);
+ });
+ });
+ }
+
+ // Promisify chrome.storage.local.set
+ function setLocalStorage(data) {
+ return new Promise((resolve, reject) => {
+ chrome.storage.local.set(data, function () {
+ if (chrome.runtime.lastError) {
+ return reject(chrome.runtime.lastError);
+ }
+ resolve();
+ });
+ });
+ }
+
+
+ export async function setPermission(key, value) {
+ try {
+ // Get the existing qortalRequestPermissions object
+ const qortalRequestPermissions = (await getLocalStorage('qortalRequestPermissions')) || {};
+
+ // Update the permission
+ qortalRequestPermissions[key] = value;
+
+ // Save the updated object back to storage
+ await setLocalStorage({ qortalRequestPermissions });
+
+ console.log('Permission set for', key);
+ } catch (error) {
+ console.error('Error setting permission:', error);
+ }
+ }
+
+ export async function getPermission(key) {
+ try {
+ // Get the qortalRequestPermissions object from storage
+ const qortalRequestPermissions = (await getLocalStorage('qortalRequestPermissions')) || {};
+
+ // Return the value for the given key, or null if it doesn't exist
+ return qortalRequestPermissions[key] || null;
+ } catch (error) {
+ console.error('Error getting permission:', error);
+ return null;
+ }
+ }
+
+
+ // TODO: GET_FRIENDS_LIST
+ // NOT SURE IF TO IMPLEMENT: LINK_TO_QDN_RESOURCE, QDN_RESOURCE_DISPLAYED, SET_TAB_NOTIFICATIONS
+
+chrome?.runtime?.onMessage.addListener((request, sender, sendResponse) => {
+ if (request) {
+ const isFromExtension = request?.isExtension
+ switch (request.action) {
+ case "GET_USER_ACCOUNT": {
+ getUserAccount()
+ .then((res) => {
+ sendResponse(res);
+ })
+ .catch((error) => {
+ sendResponse({ error: "Unable to get user account" });
+ });
+
+ break;
+ }
+ case "ENCRYPT_DATA": {
+ const data = request.payload;
+
+ encryptData(data, sender)
+ .then((res) => {
+ sendResponse(res);
+ })
+ .catch((error) => {
+ sendResponse({ error: error.message });
+ });
+
+ break;
+ }
+ case "DECRYPT_DATA": {
+ const data = request.payload;
+
+ decryptData(data)
+ .then((res) => {
+ sendResponse(res);
+ })
+ .catch((error) => {
+ sendResponse({ error: error.message });
+ });
+
+ break;
+ }
+ case "GET_LIST_ITEMS": {
+ const data = request.payload;
+
+ getListItems(data, isFromExtension)
+ .then((res) => {
+ sendResponse(res);
+ })
+ .catch((error) => {
+ sendResponse({ error: error.message });
+ });
+
+ break;
+ }
+ case "ADD_LIST_ITEMS": {
+ const data = request.payload;
+
+ addListItems(data, isFromExtension)
+ .then((res) => {
+ sendResponse(res);
+ })
+ .catch((error) => {
+ sendResponse({ error: error.message });
+ });
+
+ break;
+ }
+ case "DELETE_LIST_ITEM": {
+ const data = request.payload;
+
+ deleteListItems(data, isFromExtension)
+ .then((res) => {
+ sendResponse(res);
+ })
+ .catch((error) => {
+ sendResponse({ error: error.message });
+ });
+
+ break;
+ }
+ case "PUBLISH_QDN_RESOURCE": {
+ const data = request.payload;
+
+ publishQDNResource(data, sender, isFromExtension)
+ .then((res) => {
+ sendResponse(res);
+ })
+ .catch((error) => {
+ sendResponse({ error: error.message });
+ });
+
+ break;
+ }
+ case "PUBLISH_MULTIPLE_QDN_RESOURCES": {
+ const data = request.payload;
+
+ publishMultipleQDNResources(data, sender, isFromExtension)
+ .then((res) => {
+ sendResponse(res);
+ })
+ .catch((error) => {
+ sendResponse({ error: error.message });
+ });
+
+ break;
+ }
+ case "VOTE_ON_POLL": {
+ const data = request.payload;
+
+ voteOnPoll(data, isFromExtension)
+ .then((res) => {
+ sendResponse(res);
+ })
+ .catch((error) => {
+ sendResponse({ error: error.message });
+ });
+
+ break;
+ }
+ case "CREATE_POLL": {
+ const data = request.payload;
+
+ createPoll(data, isFromExtension)
+ .then((res) => {
+ sendResponse(res);
+ })
+ .catch((error) => {
+ sendResponse({ error: error.message });
+ });
+
+ break;
+ }
+ case "SEND_CHAT_MESSAGE": {
+ const data = request.payload;
+ sendChatMessage(data, isFromExtension)
+ .then((res) => {
+ sendResponse(res);
+ })
+ .catch((error) => {
+ sendResponse({ error: error.message });
+ });
+
+ break;
+ }
+ case "JOIN_GROUP": {
+ const data = request.payload;
+
+ joinGroup(data, isFromExtension)
+ .then((res) => {
+ sendResponse(res);
+ })
+ .catch((error) => {
+ sendResponse({ error: error.message });
+ });
+
+ break;
+ }
+ case "SAVE_FILE": {
+ const data = request.payload;
+
+ saveFile(data, sender, isFromExtension)
+ .then((res) => {
+ sendResponse(res);
+ })
+ .catch((error) => {
+ sendResponse({ error: error.message });
+ });
+
+ break;
+ }
+ case "DEPLOY_AT": {
+ const data = request.payload;
+
+ deployAt(data, isFromExtension)
+ .then((res) => {
+ sendResponse(res);
+ })
+ .catch((error) => {
+ sendResponse({ error: error.message });
+ });
+
+ break;
+ }
+ case "GET_USER_WALLET": {
+ const data = request.payload;
+
+ getUserWallet(data, isFromExtension)
+ .then((res) => {
+ sendResponse(res);
+ })
+ .catch((error) => {
+ sendResponse({ error: error.message });
+ });
+
+ break;
+ }
+ case "GET_WALLET_BALANCE": {
+ const data = request.payload;
+
+ getWalletBalance(data, false, isFromExtension)
+ .then((res) => {
+ sendResponse(res);
+ })
+ .catch((error) => {
+ sendResponse({ error: error.message });
+ });
+
+ break;
+ }
+
+ case "GET_USER_WALLET_INFO": {
+ const data = request.payload;
+
+ getUserWalletInfo(data, isFromExtension)
+ .then((res) => {
+ sendResponse(res);
+ })
+ .catch((error) => {
+ sendResponse({ error: error.message });
+ });
+
+ break;
+ }
+ case "GET_CROSSCHAIN_SERVER_INFO": {
+ const data = request.payload;
+
+ getCrossChainServerInfo(data)
+ .then((res) => {
+ sendResponse(res);
+ })
+ .catch((error) => {
+ sendResponse({ error: error.message });
+ });
+
+ break;
+ }
+ case "GET_TX_ACTIVITY_SUMMARY": {
+ const data = request.payload;
+
+ getTxActivitySummary(data)
+ .then((res) => {
+ sendResponse(res);
+ })
+ .catch((error) => {
+ sendResponse({ error: error.message });
+ });
+
+ break;
+ }
+
+ case "GET_FOREIGN_FEE": {
+ const data = request.payload;
+
+ getForeignFee(data)
+ .then((res) => {
+ sendResponse(res);
+ })
+ .catch((error) => {
+ sendResponse({ error: error.message });
+ });
+
+ break;
+ }
+
+ case "UPDATE_FOREIGN_FEE": {
+ const data = request.payload;
+
+ updateForeignFee(data)
+ .then((res) => {
+ sendResponse(res);
+ })
+ .catch((error) => {
+ sendResponse({ error: error.message });
+ });
+
+ break;
+ }
+
+ case "GET_SERVER_CONNECTION_HISTORY": {
+ const data = request.payload;
+
+ getServerConnectionHistory(data)
+ .then((res) => {
+ sendResponse(res);
+ })
+ .catch((error) => {
+ sendResponse({ error: error.message });
+ });
+
+ break;
+ }
+
+ case "SET_CURRENT_FOREIGN_SERVER": {
+ const data = request.payload;
+
+ setCurrentForeignServer(data)
+ .then((res) => {
+ sendResponse(res);
+ })
+ .catch((error) => {
+ sendResponse({ error: error.message });
+ });
+
+ break;
+ }
+
+ case "ADD_FOREIGN_SERVER": {
+ const data = request.payload;
+
+ addForeignServer(data)
+ .then((res) => {
+ sendResponse(res);
+ })
+ .catch((error) => {
+ sendResponse({ error: error.message });
+ });
+
+ break;
+ }
+
+ case "REMOVE_FOREIGN_SERVER": {
+ const data = request.payload;
+
+ removeForeignServer(data)
+ .then((res) => {
+ sendResponse(res);
+ })
+ .catch((error) => {
+ sendResponse({ error: error.message });
+ });
+
+ break;
+ }
+
+ case "GET_DAY_SUMMARY": {
+ const data = request.payload;
+
+ getDaySummary(data)
+ .then((res) => {
+ sendResponse(res);
+ })
+ .catch((error) => {
+ sendResponse({ error: error.message });
+ });
+
+ break;
+ }
+
+ case "SEND_COIN": {
+ const data = request.payload;
+
+ sendCoin(data, isFromExtension)
+ .then((res) => {
+ sendResponse(res);
+ })
+ .catch((error) => {
+ sendResponse({ error: error.message });
+ });
+
+ break;
+ }
+ }
+ }
+ return true;
+});
diff --git a/src/qortalRequests/get.ts b/src/qortalRequests/get.ts
new file mode 100644
index 0000000..de91590
--- /dev/null
+++ b/src/qortalRequests/get.ts
@@ -0,0 +1,2463 @@
+import {
+ computePow,
+ createEndpoint,
+ getBalanceInfo,
+ getFee,
+ getKeyPair,
+ getLastRef,
+ getSaveWallet,
+ processTransactionVersion2,
+ removeDuplicateWindow,
+ signChatFunc,
+ joinGroup as joinGroupFunc,
+ sendQortFee,
+ sendCoin as sendCoinFunc,
+ isUsingLocal
+} from "../background";
+import { getNameInfo } from "../backgroundFunctions/encryption";
+import { QORT_DECIMALS } from "../constants/constants";
+import Base58 from "../deps/Base58";
+import {
+ base64ToUint8Array,
+ decryptDeprecatedSingle,
+ decryptGroupDataQortalRequest,
+ encryptDataGroup,
+ uint8ArrayStartsWith,
+ uint8ArrayToBase64,
+} from "../qdn/encryption/group-encryption";
+import { publishData } from "../qdn/publish/pubish";
+import { getPermission, setPermission } from "../qortalRequests";
+import { createTransaction } from "../transactions/transactions";
+import { mimeToExtensionMap } from "../utils/memeTypes";
+
+
+const btcFeePerByte = 0.00000100
+const ltcFeePerByte = 0.00000030
+const dogeFeePerByte = 0.00001000
+const dgbFeePerByte = 0.00000010
+const rvnFeePerByte = 0.00001125
+
+
+const _createPoll = async ({pollName, pollDescription, options}, isFromExtension) => {
+ const fee = await getFee("CREATE_POLL");
+
+ const resPermission = await getUserPermission({
+ text1: "You are requesting to create the poll below:",
+ text2: `Poll: ${pollName}`,
+ text3: `Description: ${pollDescription}`,
+ text4: `Options: ${options?.join(", ")}`,
+ fee: fee.fee,
+ }, isFromExtension);
+ const { accepted } = resPermission;
+
+ if (accepted) {
+ const wallet = await getSaveWallet();
+ const address = wallet.address0;
+ const resKeyPair = await getKeyPair();
+ const parsedData = JSON.parse(resKeyPair);
+ const uint8PrivateKey = Base58.decode(parsedData.privateKey);
+ const uint8PublicKey = Base58.decode(parsedData.publicKey);
+ const keyPair = {
+ privateKey: uint8PrivateKey,
+ publicKey: uint8PublicKey,
+ };
+ let lastRef = await getLastRef();
+
+ const tx = await createTransaction(8, keyPair, {
+ fee: fee.fee,
+ ownerAddress: address,
+ rPollName: pollName,
+ rPollDesc: pollDescription,
+ rOptions: options,
+ lastReference: lastRef,
+ });
+ const signedBytes = Base58.encode(tx.signedBytes);
+ const res = await processTransactionVersion2(signedBytes);
+ if (!res?.signature)
+ throw new Error(res?.message || "Transaction was not able to be processed");
+ return res;
+ } else {
+ throw new Error("User declined request");
+ }
+};
+
+const _deployAt = async (
+ {name,
+ description,
+ tags,
+ creationBytes,
+ amount,
+ assetId,
+ atType}, isFromExtension
+) => {
+ const fee = await getFee("DEPLOY_AT");
+
+ const resPermission = await getUserPermission({
+ text1: "Would you like to deploy this AT?",
+ text2: `Name: ${name}`,
+ text3: `Description: ${description}`,
+ fee: fee.fee,
+ }, isFromExtension);
+
+ const { accepted } = resPermission;
+
+ if (accepted) {
+ const wallet = await getSaveWallet();
+ const address = wallet.address0;
+ const lastReference = await getLastRef();
+ const resKeyPair = await getKeyPair();
+ const parsedData = JSON.parse(resKeyPair);
+ const uint8PrivateKey = Base58.decode(parsedData.privateKey);
+ const uint8PublicKey = Base58.decode(parsedData.publicKey);
+ const keyPair = {
+ privateKey: uint8PrivateKey,
+ publicKey: uint8PublicKey,
+ };
+
+ const tx = await createTransaction(16, keyPair, {
+ fee: fee.fee,
+ rName: name,
+ rDescription: description,
+ rTags: tags,
+ rAmount: amount,
+ rAssetId: assetId,
+ rCreationBytes: creationBytes,
+ atType: atType,
+ lastReference: lastReference,
+ });
+
+ const signedBytes = Base58.encode(tx.signedBytes);
+
+ const res = await processTransactionVersion2(signedBytes);
+ if (!res?.signature)
+ throw new Error(
+ res?.message || "Transaction was not able to be processed"
+ );
+ return res;
+ } else {
+ throw new Error("User declined transaction");
+ }
+};
+
+const _voteOnPoll = async ({pollName, optionIndex, optionName}, isFromExtension) => {
+ const fee = await getFee("VOTE_ON_POLL");
+
+ const resPermission = await getUserPermission({
+ text1: "You are being requested to vote on the poll below:",
+ text2: `Poll: ${pollName}`,
+ text3: `Option: ${optionName}`,
+ fee: fee.fee,
+ }, isFromExtension);
+ const { accepted } = resPermission;
+
+ if (accepted) {
+ const wallet = await getSaveWallet();
+ const address = wallet.address0;
+ const resKeyPair = await getKeyPair();
+ const parsedData = JSON.parse(resKeyPair);
+ const uint8PrivateKey = Base58.decode(parsedData.privateKey);
+ const uint8PublicKey = Base58.decode(parsedData.publicKey);
+ const keyPair = {
+ privateKey: uint8PrivateKey,
+ publicKey: uint8PublicKey,
+ };
+ let lastRef = await getLastRef();
+
+ const tx = await createTransaction(9, keyPair, {
+ fee: fee.fee,
+ voterAddress: address,
+ rPollName: pollName,
+ rOptionIndex: optionIndex,
+ lastReference: lastRef,
+ });
+ const signedBytes = Base58.encode(tx.signedBytes);
+ const res = await processTransactionVersion2(signedBytes);
+ if (!res?.signature)
+ throw new Error(res?.message || "Transaction was not able to be processed");
+ return res;
+ } else {
+ throw new Error("User declined request");
+ }
+};
+
+function getFileFromContentScript(fileId, sender) {
+ return new Promise((resolve, reject) => {
+ chrome.tabs.sendMessage(
+ sender.tab.id,
+ { action: "getFileFromIndexedDB", fileId: fileId },
+ (response) => {
+ if (response && response.result) {
+ resolve(response.result);
+ } else {
+ reject(response?.error || "Failed to retrieve file");
+ }
+ }
+ );
+ });
+}
+function sendToSaveFilePicker(data, sender) {
+
+ chrome.tabs.sendMessage(sender.tab.id, {
+ action: "SHOW_SAVE_FILE_PICKER",
+ data,
+ });
+}
+
+async function responseFromExtension() {
+ return new Promise((resolve) => {
+
+ // Send message to the content script to check focus
+ chrome.runtime.sendMessage({ action: "QORTAL_REQUEST_PERMISSION", payloa }, (response) => {
+
+ if (chrome.runtime.lastError) {
+ resolve(false); // Error occurred, assume not focused
+ } else {
+ resolve(response); // Resolve based on the response
+ }
+ });
+ });
+}
+
+async function getUserPermission(payload: any, isFromExtension?: boolean) {
+ function waitForWindowReady(windowId) {
+ return new Promise((resolve) => {
+ const checkInterval = setInterval(() => {
+ chrome.windows.get(windowId, (win) => {
+ if (chrome.runtime.lastError) {
+ clearInterval(checkInterval); // Stop polling if there's an error
+ resolve(false);
+ } else if (win.state === "normal" || win.state === "maximized") {
+ clearInterval(checkInterval); // Window is ready
+ resolve(true);
+ }
+ });
+ }, 100); // Check every 100ms
+ });
+ }
+
+ if(isFromExtension){
+
+
+ return new Promise((resolve) => {
+ // Set a timeout for 1 second
+ const timeout = setTimeout(() => {
+ resolve(false);
+ }, 30000);
+
+ // Send message to the content script to check focus
+ chrome.runtime.sendMessage(
+ { action: "QORTAL_REQUEST_PERMISSION", payload, isFromExtension },
+ (response) => {
+ if (response === undefined) return;
+ clearTimeout(timeout); // Clear the timeout if we get a response
+
+ if (chrome.runtime.lastError) {
+ resolve(false); // Error occurred, assume not focused
+ } else {
+ resolve(response); // Resolve based on the response
+ }
+ }
+ );
+ });
+ }
+ await new Promise((res) => {
+ const popupUrl = chrome.runtime.getURL("index.html?secondary=true");
+ chrome.windows.getAll(
+ { populate: true, windowTypes: ["popup"] },
+ (windows) => {
+ // Attempt to find an existing popup window that has a tab with the correct URL
+ const existingPopup = windows.find(
+ (w) =>
+ w.tabs &&
+ w.tabs.some((tab) => tab.url && tab.url.startsWith(popupUrl))
+ );
+ if (existingPopup) {
+ // If the popup exists but is minimized or not focused, focus it
+ chrome.windows.update(existingPopup.id, {
+ focused: true,
+ state: "normal",
+ });
+ res(null);
+ } else {
+ // No existing popup found, create a new one
+ chrome.system.display.getInfo((displays) => {
+ // Assuming the primary display is the first one (adjust logic as needed)
+ const primaryDisplay = displays[0];
+ const screenWidth = primaryDisplay.bounds.width;
+ const windowHeight = 500; // Your window height
+ const windowWidth = 400; // Your window width
+
+ // Calculate left position for the window to appear on the right of the screen
+ const leftPosition = screenWidth - windowWidth;
+
+ // Calculate top position for the window, adjust as desired
+ const topPosition =
+ (primaryDisplay.bounds.height - windowHeight) / 2;
+
+ chrome.windows.create(
+ {
+ url: popupUrl,
+ type: "popup",
+ width: windowWidth,
+ height: windowHeight,
+ left: leftPosition,
+ top: 0,
+ },
+ async (newWindow) => {
+ removeDuplicateWindow(popupUrl);
+ await waitForWindowReady(newWindow.id);
+
+ res(null);
+ }
+ );
+ });
+ }
+ }
+ );
+ });
+
+ await new Promise((res) => {
+ setTimeout(() => {
+ chrome.runtime.sendMessage({
+ action: "SET_COUNTDOWN",
+ payload: 30,
+ });
+ res(true);
+ }, 1000);
+ });
+ return new Promise((resolve) => {
+ // Set a timeout for 1 second
+ const timeout = setTimeout(() => {
+ resolve(false);
+ }, 30000);
+
+ // Send message to the content script to check focus
+ chrome.runtime.sendMessage(
+ { action: "QORTAL_REQUEST_PERMISSION", payload },
+ (response) => {
+ if (response === undefined) return;
+ clearTimeout(timeout); // Clear the timeout if we get a response
+
+ if (chrome.runtime.lastError) {
+ resolve(false); // Error occurred, assume not focused
+ } else {
+ resolve(response); // Resolve based on the response
+ }
+ }
+ );
+ });
+}
+
+export const getUserAccount = async () => {
+ try {
+ const wallet = await getSaveWallet();
+ const address = wallet.address0;
+ const publicKey = wallet.publicKey;
+ return {
+ address,
+ publicKey,
+ };
+ } catch (error) {
+ throw new Error("Unable to fetch user account");
+ }
+};
+
+export const encryptData = async (data, sender) => {
+ let data64 = data.data64;
+ let publicKeys = data.publicKeys || [];
+ if (data.fileId) {
+ data64 = await getFileFromContentScript(data.fileId, sender);
+ }
+ if (!data64) {
+ throw new Error("Please include data to encrypt");
+ }
+
+ const resKeyPair = await getKeyPair();
+ const parsedData = JSON.parse(resKeyPair);
+ const privateKey = parsedData.privateKey;
+ const userPublicKey = parsedData.publicKey;
+
+ const encryptDataResponse = encryptDataGroup({
+ data64,
+ publicKeys: publicKeys,
+ privateKey,
+ userPublicKey,
+ });
+ if (encryptDataResponse) {
+ return encryptDataResponse;
+ } else {
+ throw new Error("Unable to encrypt");
+ }
+};
+export const decryptData = async (data) => {
+ const { encryptedData, publicKey } = data;
+
+ if (!encryptedData) {
+ throw new Error(`Missing fields: encryptedData`);
+ }
+ const resKeyPair = await getKeyPair();
+ const parsedData = JSON.parse(resKeyPair);
+ const uint8PrivateKey = Base58.decode(parsedData.privateKey);
+ const uint8Array = base64ToUint8Array(encryptedData);
+ const startsWithQortalEncryptedData = uint8ArrayStartsWith(
+ uint8Array,
+ "qortalEncryptedData"
+ );
+ if (startsWithQortalEncryptedData) {
+ if (!publicKey) {
+ throw new Error(`Missing fields: publicKey`);
+ }
+
+ const decryptedDataToBase64 = decryptDeprecatedSingle(
+ uint8Array,
+ publicKey,
+ uint8PrivateKey
+ );
+ return decryptedDataToBase64;
+ }
+ const startsWithQortalGroupEncryptedData = uint8ArrayStartsWith(
+ uint8Array,
+ "qortalGroupEncryptedData"
+ );
+ if (startsWithQortalGroupEncryptedData) {
+ const decryptedData = decryptGroupDataQortalRequest(
+ encryptedData,
+ parsedData.privateKey
+ );
+ const decryptedDataToBase64 = uint8ArrayToBase64(decryptedData);
+ return decryptedDataToBase64;
+ }
+ throw new Error("Unable to decrypt");
+};
+
+export const getListItems = async (data, isFromExtension) => {
+ const localNodeAvailable = await isUsingLocal()
+ if(!localNodeAvailable) throw new Error('Please use your local node.')
+ const requiredFields = ["list_name"];
+ const missingFields: string[] = [];
+ requiredFields.forEach((field) => {
+ if (!data[field]) {
+ missingFields.push(field);
+ }
+ });
+ if (missingFields.length > 0) {
+ const missingFieldsString = missingFields.join(", ");
+ const errorMsg = `Missing fields: ${missingFieldsString}`;
+ throw new Error(errorMsg);
+ }
+ const value = (await getPermission("qAPPAutoLists")) || false;
+
+ let skip = false;
+ if (value) {
+ skip = true;
+ }
+ let resPermission;
+ let acceptedVar;
+ let checkbox1Var;
+ if (!skip) {
+ resPermission = await getUserPermission({
+ text1: "Do you give this application permission to",
+ text2: "Access the list",
+ highlightedText: data.list_name,
+ checkbox1: {
+ value: value,
+ label: "Always allow lists to be retrieved automatically",
+ },
+ }, isFromExtension);
+ const { accepted, checkbox1 } = resPermission;
+ acceptedVar = accepted;
+ checkbox1Var = checkbox1;
+ setPermission("qAPPAutoLists", checkbox1);
+ }
+
+ if (acceptedVar || skip) {
+ const url = await createEndpoint(`/lists/${data.list_name}`);
+ const response = await fetch(url);
+ if (!response.ok) throw new Error("Failed to fetch");
+
+ const list = await response.json();
+ return list;
+ } else {
+ throw new Error("User declined to share list");
+ }
+};
+
+export const addListItems = async (data, isFromExtension) => {
+ const localNodeAvailable = await isUsingLocal()
+ if(!localNodeAvailable) throw new Error('Please use your local node.')
+ const requiredFields = ["list_name", "items"];
+ const missingFields: string[] = [];
+ requiredFields.forEach((field) => {
+ if (!data[field]) {
+ missingFields.push(field);
+ }
+ });
+ if (missingFields.length > 0) {
+ const missingFieldsString = missingFields.join(", ");
+ const errorMsg = `Missing fields: ${missingFieldsString}`;
+ throw new Error(errorMsg);
+ }
+
+ const items = data.items;
+ const list_name = data.list_name;
+
+ const resPermission = await getUserPermission({
+ text1: "Do you give this application permission to",
+ text2: `Add the following to the list ${list_name}:`,
+ highlightedText: items.join(", "),
+ }, isFromExtension);
+ const { accepted } = resPermission;
+
+ if (accepted) {
+ const url = await createEndpoint(`/lists/${list_name}`);
+ const body = {
+ items: items,
+ };
+ const bodyToString = JSON.stringify(body);
+ const response = await fetch(url, {
+ method: "POST",
+ headers: {
+ "Content-Type": "application/json",
+ },
+ body: bodyToString,
+ });
+
+ if (!response.ok) throw new Error("Failed to add to list");
+ let res;
+ try {
+ res = await response.clone().json();
+ } catch (e) {
+ res = await response.text();
+ }
+ return res;
+ } else {
+ throw new Error("User declined add to list");
+ }
+};
+
+export const deleteListItems = async (data, isFromExtension) => {
+ const localNodeAvailable = await isUsingLocal()
+ if(!localNodeAvailable) throw new Error('Please use your local node.')
+ const requiredFields = ["list_name", "item"];
+ const missingFields: string[] = [];
+ requiredFields.forEach((field) => {
+ if (!data[field]) {
+ missingFields.push(field);
+ }
+ });
+ if (missingFields.length > 0) {
+ const missingFieldsString = missingFields.join(", ");
+ const errorMsg = `Missing fields: ${missingFieldsString}`;
+ throw new Error(errorMsg);
+ }
+
+ const item = data.item;
+ const list_name = data.list_name;
+
+ const resPermission = await getUserPermission({
+ text1: "Do you give this application permission to",
+ text2: `Remove the following from the list ${list_name}:`,
+ highlightedText: item,
+ }, isFromExtension);
+ const { accepted } = resPermission;
+
+ if (accepted) {
+ const url = await createEndpoint(`/lists/${list_name}`);
+ const body = {
+ items: [item],
+ };
+ const bodyToString = JSON.stringify(body);
+ const response = await fetch(url, {
+ method: "DELETE",
+ headers: {
+ "Content-Type": "application/json",
+ },
+ body: bodyToString,
+ });
+
+ if (!response.ok) throw new Error("Failed to add to list");
+ let res;
+ try {
+ res = await response.clone().json();
+ } catch (e) {
+ res = await response.text();
+ }
+ return res;
+ } else {
+ throw new Error("User declined delete from list");
+ }
+};
+
+export const publishQDNResource = async (data: any, sender, isFromExtension) => {
+ const requiredFields = ["service"];
+ const missingFields: string[] = [];
+ requiredFields.forEach((field) => {
+ if (!data[field]) {
+ missingFields.push(field);
+ }
+ });
+ if (missingFields.length > 0) {
+ const missingFieldsString = missingFields.join(", ");
+ const errorMsg = `Missing fields: ${missingFieldsString}`;
+ throw new Error(errorMsg);
+ }
+ if (!data.fileId && !data.data64) {
+ throw new Error("No data or file was submitted");
+ }
+ // Use "default" if user hasn't specified an identifer
+ const service = data.service;
+ const registeredName = await getNameInfo();
+ const name = registeredName;
+ let identifier = data.identifier;
+ let data64 = data.data64;
+ const filename = data.filename;
+ const title = data.title;
+ const description = data.description;
+ const category = data.category;
+ const tag1 = data.tag1;
+ const tag2 = data.tag2;
+ const tag3 = data.tag3;
+ const tag4 = data.tag4;
+ const tag5 = data.tag5;
+ if (data.identifier == null) {
+ identifier = "default";
+ }
+ if (
+ data.encrypt &&
+ (!data.publicKeys ||
+ (Array.isArray(data.publicKeys) && data.publicKeys.length === 0))
+ ) {
+ throw new Error("Encrypting data requires public keys");
+ }
+ if (!data.encrypt && data.service.endsWith("_PRIVATE")) {
+ throw new Error("Only encrypted data can go into private services");
+ }
+ if (data.fileId) {
+ data64 = await getFileFromContentScript(data.fileId, sender);
+ }
+ if (data.encrypt) {
+ try {
+ const resKeyPair = await getKeyPair()
+ const parsedData = JSON.parse(resKeyPair)
+ const privateKey = parsedData.privateKey
+ const userPublicKey = parsedData.publicKey
+ const encryptDataResponse = encryptDataGroup({
+ data64,
+ publicKeys: data.publicKeys,
+ privateKey,
+ userPublicKey
+ });
+ if (encryptDataResponse) {
+ data64 = encryptDataResponse;
+ }
+ } catch (error) {
+ throw new Error(
+ error.message || "Upload failed due to failed encryption"
+ );
+ }
+ }
+
+ const fee = await getFee("ARBITRARY");
+
+ const resPermission = await getUserPermission({
+ text1: "Do you give this application permission to publish to QDN?",
+ text2: `service: ${service}`,
+ text3: `identifier: ${identifier || null}`,
+ highlightedText: `isEncrypted: ${!!data.encrypt}`,
+ fee: fee.fee,
+ }, isFromExtension);
+ const { accepted } = resPermission;
+ if (accepted) {
+ if (data.fileId && !data.encrypt) {
+ data64 = await getFileFromContentScript(data.fileId, sender);
+ }
+ try {
+ const resPublish = await publishData({
+ registeredName: encodeURIComponent(name),
+ file: data64,
+ service: service,
+ identifier: encodeURIComponent(identifier),
+ uploadType: "file",
+ isBase64: true,
+ filename: filename,
+ title,
+ description,
+ category,
+ tag1,
+ tag2,
+ tag3,
+ tag4,
+ tag5,
+ apiVersion: 2,
+ withFee: true,
+ });
+ return resPublish;
+ } catch (error) {
+ throw new Error(error?.message || "Upload failed");
+ }
+ } else {
+ throw new Error("User declined request");
+ }
+};
+
+export const publishMultipleQDNResources = async (data: any, sender, isFromExtension) => {
+ const requiredFields = ["resources"];
+ const missingFields: string[] = [];
+ let feeAmount = null;
+ requiredFields.forEach((field) => {
+ if (!data[field]) {
+ missingFields.push(field);
+ }
+ });
+ if (missingFields.length > 0) {
+ const missingFieldsString = missingFields.join(", ");
+ const errorMsg = `Missing fields: ${missingFieldsString}`;
+ throw new Error(errorMsg);
+ }
+ const resources = data.resources;
+ if (!Array.isArray(resources)) {
+ throw new Error("Invalid data");
+ }
+ if (resources.length === 0) {
+ throw new Error("No resources to publish");
+ }
+ if (
+ data.encrypt &&
+ (!data.publicKeys ||
+ (Array.isArray(data.publicKeys) && data.publicKeys.length === 0))
+ ) {
+ throw new Error("Encrypting data requires public keys");
+ }
+ const fee = await getFee("ARBITRARY");
+ const registeredName = await getNameInfo();
+ const name = registeredName;
+ const resPermission = await getUserPermission({
+ text1: "Do you give this application permission to publish to QDN?",
+ html: `
+
+
+
+ ${data.resources
+ .map(
+ (resource) => `
+
+
+ `,
+ highlightedText: `isEncrypted: ${!!data.encrypt}`,
+ fee: fee.fee * resources.length,
+ }, isFromExtension);
+ const { accepted } = resPermission;
+ if (!accepted) {
+ throw new Error("User declined request");
+ }
+ let failedPublishesIdentifiers = [];
+ for (const resource of resources) {
+ try {
+ const requiredFields = ["service"];
+ const missingFields: string[] = [];
+ requiredFields.forEach((field) => {
+ if (!resource[field]) {
+ missingFields.push(field);
+ }
+ });
+ if (missingFields.length > 0) {
+ const missingFieldsString = missingFields.join(", ");
+ const errorMsg = `Missing fields: ${missingFieldsString}`;
+ failedPublishesIdentifiers.push({
+ reason: errorMsg,
+ identifier: resource.identifier,
+ });
+ continue;
+ }
+ if (!resource.fileId && !resource.data64) {
+ const errorMsg = "No data or file was submitted";
+ failedPublishesIdentifiers.push({
+ reason: errorMsg,
+ identifier: resource.identifier,
+ });
+ continue;
+ }
+ const service = resource.service;
+ let identifier = resource.identifier;
+ let data64 = resource.data64;
+ const filename = resource.filename;
+ const title = resource.title;
+ const description = resource.description;
+ const category = resource.category;
+ const tag1 = resource.tag1;
+ const tag2 = resource.tag2;
+ const tag3 = resource.tag3;
+ const tag4 = resource.tag4;
+ const tag5 = resource.tag5;
+ if (resource.identifier == null) {
+ identifier = "default";
+ }
+ if (!data.encrypt && service.endsWith("_PRIVATE")) {
+ const errorMsg = "Only encrypted data can go into private services";
+ failedPublishesIdentifiers.push({
+ reason: errorMsg,
+ identifier: resource.identifier,
+ });
+ continue;
+ }
+ if (resource.fileId) {
+ data64 = await getFileFromContentScript(resource.fileId, sender);
+ }
+ if (data.encrypt) {
+ try {
+ const resKeyPair = await getKeyPair()
+ const parsedData = JSON.parse(resKeyPair)
+ const privateKey = parsedData.privateKey
+ const userPublicKey = parsedData.publicKey
+ const encryptDataResponse = encryptDataGroup({
+ data64,
+ publicKeys: data.publicKeys,
+ privateKey,
+ userPublicKey
+ });
+ if (encryptDataResponse) {
+ data64 = encryptDataResponse;
+ }
+ } catch (error) {
+ const errorMsg =
+ error?.message || "Upload failed due to failed encryption";
+ failedPublishesIdentifiers.push({
+ reason: errorMsg,
+ identifier: resource.identifier,
+ });
+ continue;
+ }
+ }
+
+ try {
+ await publishData({
+ registeredName: encodeURIComponent(name),
+ file: data64,
+ service: service,
+ identifier: encodeURIComponent(identifier),
+ uploadType: "file",
+ isBase64: true,
+ filename: filename,
+ title,
+ description,
+ category,
+ tag1,
+ tag2,
+ tag3,
+ tag4,
+ tag5,
+ apiVersion: 2,
+ withFee: true,
+ });
+ await new Promise((res) => {
+ setTimeout(() => {
+ res();
+ }, 1000);
+ });
+ } catch (error) {
+ const errorMsg = error.message || "Upload failed";
+ failedPublishesIdentifiers.push({
+ reason: errorMsg,
+ identifier: resource.identifier,
+ });
+ }
+ } catch (error) {
+ failedPublishesIdentifiers.push({
+ reason: "Unknown error",
+ identifier: resource.identifier,
+ });
+ }
+ }
+ if (failedPublishesIdentifiers.length > 0) {
+ const obj = {};
+ obj["error"] = {
+ unsuccessfulPublishes: failedPublishesIdentifiers,
+ };
+ return obj;
+ }
+ return true;
+};
+
+export const voteOnPoll = async (data, isFromExtension) => {
+ const requiredFields = ["pollName", "optionIndex"];
+ const missingFields: string[] = [];
+ requiredFields.forEach((field) => {
+ if (!data[field] && data[field] !== 0) {
+ missingFields.push(field);
+ }
+ });
+ if (missingFields.length > 0) {
+ const missingFieldsString = missingFields.join(", ");
+ const errorMsg = `Missing fields: ${missingFieldsString}`;
+ throw new Error(errorMsg);
+ }
+ const pollName = data.pollName;
+ const optionIndex = data.optionIndex;
+ let pollInfo = null;
+ try {
+ const url = await createEndpoint(`/polls/${encodeURIComponent(pollName)}`);
+ const response = await fetch(url);
+ if (!response.ok) throw new Error("Failed to fetch poll");
+
+ pollInfo = await response.json();
+ } catch (error) {
+ const errorMsg = (error && error.message) || "Poll not found";
+ throw new Error(errorMsg);
+ }
+ if (!pollInfo || pollInfo.error) {
+ const errorMsg = (pollInfo && pollInfo.message) || "Poll not found";
+ throw new Error(errorMsg);
+ }
+ try {
+ const optionName = pollInfo.pollOptions[optionIndex].optionName;
+ const resVoteOnPoll = await _voteOnPoll({pollName, optionIndex, optionName}, isFromExtension);
+ return resVoteOnPoll;
+ } catch (error) {
+ throw new Error(error?.message || "Failed to vote on the poll.");
+ }
+};
+
+export const createPoll = async (data, isFromExtension) => {
+ const requiredFields = [
+ "pollName",
+ "pollDescription",
+ "pollOptions",
+ "pollOwnerAddress",
+ ];
+ const missingFields: string[] = [];
+ requiredFields.forEach((field) => {
+ if (!data[field]) {
+ missingFields.push(field);
+ }
+ });
+ if (missingFields.length > 0) {
+ const missingFieldsString = missingFields.join(", ");
+ const errorMsg = `Missing fields: ${missingFieldsString}`;
+ throw new Error(errorMsg);
+ }
+ const pollName = data.pollName;
+ const pollDescription = data.pollDescription;
+ const pollOptions = data.pollOptions;
+ const pollOwnerAddress = data.pollOwnerAddress;
+ try {
+ const resCreatePoll = await _createPoll(
+ {
+ pollName,
+ pollDescription,
+ options: pollOptions,
+ },
+ isFromExtension
+ );
+ return resCreatePoll;
+ } catch (error) {
+ throw new Error(error?.message || "Failed to created poll.");
+ }
+};
+
+export const sendChatMessage = async (data, isFromExtension) => {
+ const message = data.message;
+ const recipient = data.destinationAddress;
+ const groupId = data.groupId;
+ const isRecipient = !groupId;
+ const resPermission = await getUserPermission({
+ text1: "Do you give this application permission to send this chat message?",
+ text2: `To: ${isRecipient ? recipient : `group ${groupId}`}`,
+ text3: `${message?.slice(0, 25)}${message?.length > 25 ? "..." : ""}`,
+ }, isFromExtension);
+
+ const { accepted } = resPermission;
+ if (accepted) {
+ const tiptapJson = {
+ type: "doc",
+ content: [
+ {
+ type: "paragraph",
+ content: [
+ {
+ type: "text",
+ text: message,
+ },
+ ],
+ },
+ ],
+ };
+ const messageObject = {
+ messageText: tiptapJson,
+ images: [""],
+ repliedTo: "",
+ version: 3,
+ };
+
+ const stringifyMessageObject = JSON.stringify(messageObject);
+
+ const balance = await getBalanceInfo();
+ const hasEnoughBalance = +balance < 4 ? false : true;
+ if (!hasEnoughBalance) {
+ throw new Error("You need at least 4 QORT to send a message");
+ }
+ if (isRecipient && recipient) {
+ const url = await createEndpoint(`/addresses/publickey/${recipient}`);
+ const response = await fetch(url);
+ if (!response.ok)
+ throw new Error("Failed to fetch recipient's public key");
+
+ let key;
+ let hasPublicKey;
+ let res;
+ const contentType = response.headers.get("content-type");
+
+ // If the response is JSON, parse it as JSON
+ if (contentType && contentType.includes("application/json")) {
+ res = await response.json();
+ } else {
+ // Otherwise, treat it as plain text
+ res = await response.text();
+ }
+ if (res?.error === 102) {
+ key = "";
+ hasPublicKey = false;
+ } else if (res !== false) {
+ key = res;
+ hasPublicKey = true;
+ } else {
+ key = "";
+ hasPublicKey = false;
+ }
+
+ if (!hasPublicKey && isRecipient) {
+ throw new Error(
+ "Cannot send an encrypted message to this user since they do not have their publickey on chain."
+ );
+ }
+ let _reference = new Uint8Array(64);
+ self.crypto.getRandomValues(_reference);
+
+ let sendTimestamp = Date.now();
+
+ let reference = Base58.encode(_reference);
+ const resKeyPair = await getKeyPair();
+ const parsedData = JSON.parse(resKeyPair);
+ const uint8PrivateKey = Base58.decode(parsedData.privateKey);
+ const uint8PublicKey = Base58.decode(parsedData.publicKey);
+ const keyPair = {
+ privateKey: uint8PrivateKey,
+ publicKey: uint8PublicKey,
+ };
+
+ const difficulty = 8;
+ const tx = await createTransaction(18, keyPair, {
+ timestamp: sendTimestamp,
+ recipient: recipient,
+ recipientPublicKey: key,
+ hasChatReference: 0,
+ message: stringifyMessageObject,
+ lastReference: reference,
+ proofOfWorkNonce: 0,
+ isEncrypted: 1,
+ isText: 1,
+ });
+ const path = chrome.runtime.getURL("memory-pow.wasm.full");
+
+ const { nonce, chatBytesArray } = await computePow({
+ chatBytes: tx.chatBytes,
+ path,
+ difficulty,
+ });
+
+ let _response = await signChatFunc(chatBytesArray, nonce, null, keyPair);
+ if (_response?.error) {
+ throw new Error(_response?.message);
+ }
+ return _response;
+ } else if (!isRecipient && groupId) {
+ let _reference = new Uint8Array(64);
+ self.crypto.getRandomValues(_reference);
+
+ let reference = Base58.encode(_reference);
+ const resKeyPair = await getKeyPair();
+ const parsedData = JSON.parse(resKeyPair);
+ const uint8PrivateKey = Base58.decode(parsedData.privateKey);
+ const uint8PublicKey = Base58.decode(parsedData.publicKey);
+ const keyPair = {
+ privateKey: uint8PrivateKey,
+ publicKey: uint8PublicKey,
+ };
+
+ const difficulty = 8;
+
+ const txBody = {
+ timestamp: Date.now(),
+ groupID: Number(groupId),
+ hasReceipient: 0,
+ hasChatReference: 0,
+ message: stringifyMessageObject,
+ lastReference: reference,
+ proofOfWorkNonce: 0,
+ isEncrypted: 0, // Set default to not encrypted for groups
+ isText: 1,
+ };
+
+ const tx = await createTransaction(181, keyPair, txBody);
+
+ // if (!hasEnoughBalance) {
+ // throw new Error("Must have at least 4 QORT to send a chat message");
+ // }
+ const path = chrome.runtime.getURL("memory-pow.wasm.full");
+
+ const { nonce, chatBytesArray } = await computePow({
+ chatBytes: tx.chatBytes,
+ path,
+ difficulty,
+ });
+ let _response = await signChatFunc(chatBytesArray, nonce, null, keyPair);
+ if (_response?.error) {
+ throw new Error(_response?.message);
+ }
+ return _response;
+ } else {
+ throw new Error("Please enter a recipient or groupId");
+ }
+ } else {
+ throw new Error("User declined to send message");
+ }
+};
+
+export const joinGroup = async (data, isFromExtension) => {
+ const requiredFields = ["groupId"];
+ const missingFields: string[] = [];
+ requiredFields.forEach((field) => {
+ if (!data[field]) {
+ missingFields.push(field);
+ }
+ });
+ if (missingFields.length > 0) {
+ const missingFieldsString = missingFields.join(", ");
+ const errorMsg = `Missing fields: ${missingFieldsString}`;
+ throw new Error(errorMsg);
+ }
+ let groupInfo = null;
+ try {
+ const url = await createEndpoint(`/groups/${data.groupId}`);
+ const response = await fetch(url);
+ if (!response.ok) throw new Error("Failed to fetch group");
+
+ groupInfo = await response.json();
+ } catch (error) {
+ const errorMsg = (error && error.message) || "Group not found";
+ throw new Error(errorMsg);
+ }
+ const fee = await getFee("JOIN_GROUP");
+
+ const resPermission = await getUserPermission({
+ text1: "Confirm joining the group:",
+ highlightedText: `${groupInfo.groupName}`,
+ fee: fee.fee,
+ }, isFromExtension);
+ const { accepted } = resPermission;
+
+ if (accepted) {
+ const groupId = data.groupId;
+
+ if (!groupInfo || groupInfo.error) {
+ const errorMsg = (groupInfo && groupInfo.message) || "Group not found";
+ throw new Error(errorMsg);
+ }
+ try {
+ const resJoinGroup = await joinGroupFunc({ groupId });
+ return resJoinGroup;
+ } catch (error) {
+ throw new Error(error?.message || "Failed to join the group.");
+ }
+ } else {
+ throw new Error("User declined to join group");
+ }
+};
+
+export const saveFile = async (data, sender, isFromExtension) => {
+ try {
+ const requiredFields = ["filename", "fileId"];
+ const missingFields: string[] = [];
+ requiredFields.forEach((field) => {
+ if (!data[field]) {
+ missingFields.push(field);
+ }
+ });
+ if (missingFields.length > 0) {
+ const missingFieldsString = missingFields.join(", ");
+ const errorMsg = `Missing fields: ${missingFieldsString}`;
+ throw new Error(errorMsg);
+ }
+ const filename = data.filename;
+ const blob = data.blob;
+ const fileId = data.fileId;
+ const resPermission = await getUserPermission({
+ text1: "Would you like to download:",
+ highlightedText: `${filename}`,
+ }, isFromExtension);
+ const { accepted } = resPermission;
+
+ if (accepted) {
+ const mimeType = blob.type || data.mimeType;
+ let backupExention = filename.split(".").pop();
+ if (backupExention) {
+ backupExention = "." + backupExention;
+ }
+ const fileExtension = mimeToExtensionMap[mimeType] || backupExention;
+ let fileHandleOptions = {};
+ if (!mimeType) {
+ throw new Error("A mimeType could not be derived");
+ }
+ if (!fileExtension) {
+ const obj = {};
+ throw new Error("A file extension could not be derived");
+ }
+ if (fileExtension && mimeType) {
+ fileHandleOptions = {
+ accept: {
+ [mimeType]: [fileExtension],
+ },
+ };
+ }
+ sendToSaveFilePicker(
+ {
+ filename,
+ mimeType,
+ blob,
+ fileId,
+ fileHandleOptions,
+ },
+ sender
+ );
+ return true;
+ } else {
+ throw new Error("User declined to save file");
+ }
+ } catch (error) {
+ throw new Error(error?.message || "Failed to initiate download");
+ }
+};
+
+export const deployAt = async (data, isFromExtension) => {
+ const requiredFields = [
+ "name",
+ "description",
+ "tags",
+ "creationBytes",
+ "amount",
+ "assetId",
+ "type",
+ ];
+ const missingFields: string[] = [];
+ requiredFields.forEach((field) => {
+ if (!data[field] && data[field] !== 0) {
+ missingFields.push(field);
+ }
+ });
+ if (missingFields.length > 0) {
+ const missingFieldsString = missingFields.join(", ");
+ const errorMsg = `Missing fields: ${missingFieldsString}`;
+ throw new Error(errorMsg);
+ }
+ try {
+ const resDeployAt = await _deployAt(
+ {
+ name: data.name,
+ description: data.description,
+ tags: data.tags,
+ creationBytes: data.creationBytes,
+ amount: data.amount,
+ assetId: data.assetId,
+ atType: data.type
+ },
+ isFromExtension
+ );
+ return resDeployAt;
+ } catch (error) {
+ throw new Error(error?.message || "Failed to join the group.");
+ }
+};
+
+export const getUserWallet = async (data, isFromExtension) => {
+ const requiredFields = ["coin"];
+ const missingFields: string[] = [];
+ requiredFields.forEach((field) => {
+ if (!data[field]) {
+ missingFields.push(field);
+ }
+ });
+ if (missingFields.length > 0) {
+ const missingFieldsString = missingFields.join(", ");
+ const errorMsg = `Missing fields: ${missingFieldsString}`;
+ throw new Error(errorMsg);
+ }
+ const resPermission = await getUserPermission({
+ text1:
+ "Do you give this application permission to get your wallet information?",
+ }, isFromExtension);
+ const { accepted } = resPermission;
+
+ if (accepted) {
+ let coin = data.coin;
+ let userWallet = {};
+ let arrrAddress = "";
+ const wallet = await getSaveWallet();
+ const address = wallet.address0;
+ const resKeyPair = await getKeyPair();
+ const parsedData = JSON.parse(resKeyPair);
+ const arrrSeed58 = parsedData.arrrSeed58;
+ if (coin === "ARRR") {
+ const bodyToString = arrrSeed58;
+ const url = await createEndpoint(`/crosschain/arrr/walletaddress`);
+ const response = await fetch(url, {
+ method: "POST",
+ headers: {
+ "Content-Type": "application/json",
+ },
+ body: bodyToString,
+ });
+ let res;
+ try {
+ res = await response.clone().json();
+ } catch (e) {
+ res = await response.text();
+ }
+ if (res?.error && res?.message) {
+ throw new Error(res.message);
+ }
+ arrrAddress = res;
+ }
+ switch (coin) {
+ case "QORT":
+ userWallet["address"] = address;
+ userWallet["publickey"] = parsedData.publicKey;
+ break;
+ case "BTC":
+ userWallet["address"] = parsedData.btcAddress;
+ userWallet["publickey"] = parsedData.derivedMasterPublicKey;
+ break;
+ case "LTC":
+ userWallet["address"] = parsedData.ltcAddress;
+ userWallet["publickey"] = parsedData.ltcPublicKey;
+ break;
+ case "DOGE":
+ userWallet["address"] = parsedData.dogeAddress;
+ userWallet["publickey"] = parsedData.dogePublicKey;
+ break;
+ case "DGB":
+ userWallet["address"] = parsedData.dgbAddress;
+ userWallet["publickey"] = parsedData.dgbPublicKey;
+ break;
+ case "RVN":
+ userWallet["address"] = parsedData.rvnAddress;
+ userWallet["publickey"] = parsedData.rvnPublicKey;
+ break;
+ case "ARRR":
+ userWallet["address"] = arrrAddress;
+ break;
+ default:
+ break;
+ }
+ return userWallet;
+ } else {
+ throw new Error("User declined request");
+ }
+};
+
+export const getWalletBalance = async (data, bypassPermission?: boolean, isFromExtension) => {
+ const requiredFields = ["coin"];
+ const missingFields: string[] = [];
+ requiredFields.forEach((field) => {
+ if (!data[field]) {
+ missingFields.push(field);
+ }
+ });
+ if (missingFields.length > 0) {
+ const missingFieldsString = missingFields.join(", ");
+ const errorMsg = `Missing fields: ${missingFieldsString}`;
+ throw new Error(errorMsg);
+ }
+ let resPermission
+
+ if(!bypassPermission){
+ resPermission = await getUserPermission({
+ text1: "Do you give this application permission to fetch your",
+ highlightedText: `${data.coin} balance`,
+ }, isFromExtension);
+ } else {
+ resPermission = {
+ accepted: false
+ }
+ }
+
+ const { accepted } = resPermission;
+
+ if (accepted || bypassPermission) {
+ let coin = data.coin;
+ const wallet = await getSaveWallet();
+ const address = wallet.address0;
+ const resKeyPair = await getKeyPair();
+ const parsedData = JSON.parse(resKeyPair);
+ if (coin === "QORT") {
+ let qortAddress = address;
+ try {
+ const url = await createEndpoint(`/addresses/balance/${qortAddress}`);
+ const response = await fetch(url);
+ if (!response.ok) throw new Error("Failed to fetch");
+ let res;
+ try {
+ res = await response.clone().json();
+ } catch (e) {
+ res = await response.text();
+ }
+ return res;
+ } catch (error) {
+ throw new Error(
+ error?.message || "Fetch Wallet Failed. Please try again"
+ );
+ }
+ } else {
+ let _url = ``;
+ let _body = null;
+ switch (coin) {
+ case "BTC":
+ _url = await createEndpoint(`/crosschain/btc/walletbalance`);
+
+ _body = parsedData.derivedMasterPublicKey;
+ break;
+ case "LTC":
+ _url = await createEndpoint(`/crosschain/ltc/walletbalance`);
+ _body = parsedData.ltcPublicKey;
+ break;
+ case "DOGE":
+ _url = await createEndpoint(`/crosschain/doge/walletbalance`);
+ _body = parsedData.dogePublicKey;
+ break;
+ case "DGB":
+ _url = await createEndpoint(`/crosschain/dgb/walletbalance`);
+ _body = parsedData.dgbPublicKey;
+ break;
+ case "RVN":
+ _url = await createEndpoint(`/crosschain/rvn/walletbalance`);
+ _body = parsedData.rvnPublicKey;
+ break;
+ case "ARRR":
+ _url = await createEndpoint(`/crosschain/arrr/walletbalance`);
+ _body = parsedData.arrrSeed58;
+ break;
+ default:
+ break;
+ }
+ try {
+ const response = await fetch(_url, {
+ method: "POST",
+ headers: {
+ "Content-Type": "application/json",
+ },
+ body: _body,
+ });
+ let res;
+ try {
+ res = await response.clone().json();
+ } catch (e) {
+ res = await response.text();
+ }
+ if (res?.error && res?.message) {
+ throw new Error(res.message);
+ }
+ if (isNaN(Number(res))) {
+ throw new Error("Unable to fetch balance");
+ } else {
+ return (Number(res) / 1e8).toFixed(8);
+ }
+ } catch (error) {
+ throw new Error(error?.message || "Unable to fetch balance");
+ }
+ }
+ } else {
+ throw new Error("User declined request");
+ }
+};
+
+const getUserWalletFunc = async (coin) => {
+ let userWallet = {};
+ const wallet = await getSaveWallet();
+ const address = wallet.address0;
+ const resKeyPair = await getKeyPair();
+ const parsedData = JSON.parse(resKeyPair);
+ switch (coin) {
+ case "QORT":
+ userWallet["address"] = address;
+ userWallet["publickey"] = parsedData.publicKey;
+ break;
+ case "BTC":
+ userWallet["address"] = parsedData.btcAddress;
+ userWallet["publickey"] = parsedData.btcPublicKey;
+ break;
+ case "LTC":
+ userWallet["address"] = parsedData.ltcAddress;
+ userWallet["publickey"] = parsedData.ltcPublicKey;
+ break;
+ case "DOGE":
+ userWallet["address"] = parsedData.dogeAddress;
+ userWallet["publickey"] = parsedData.dogePublicKey;
+ break;
+ case "DGB":
+ userWallet["address"] = parsedData.dgbAddress;
+ userWallet["publickey"] = parsedData.dgbPublicKey;
+ break;
+ case "RVN":
+ userWallet["address"] = parsedData.rvnAddress;
+ userWallet["publickey"] = parsedData.rvnPublicKey;
+ break;
+ case "ARRR":
+ break;
+ default:
+ break;
+ }
+ return userWallet;
+};
+
+export const getUserWalletInfo = async (data, isFromExtension) => {
+ const requiredFields = ["coin"];
+ const missingFields: string[] = [];
+ requiredFields.forEach((field) => {
+ if (!data[field]) {
+ missingFields.push(field);
+ }
+ });
+ if (missingFields.length > 0) {
+ const missingFieldsString = missingFields.join(", ");
+ const errorMsg = `Missing fields: ${missingFieldsString}`;
+ throw new Error(errorMsg);
+ }
+ const resPermission = await getUserPermission({
+ text1: "Do you give this application permission to retrieve your wallet information",
+ }, isFromExtension);
+ const { accepted } = resPermission;
+
+ if (accepted) {
+ let coin = data.coin;
+ let walletKeys = await getUserWalletFunc(coin);
+ const _url = await createEndpoint(
+ `/crosschain/` + data.coin.toLowerCase() + `/addressinfos`
+ );
+ let _body = { xpub58: walletKeys["publickey"] };
+ try {
+ const response = await fetch(_url, {
+ method: "POST",
+ headers: {
+ Accept: "*/*",
+ "Content-Type": "application/json",
+ },
+ body: JSON.stringify(_body),
+ });
+ if(!response?.ok) throw new Error('Unable to fetch wallet information')
+ let res;
+ try {
+ res = await response.clone().json();
+ } catch (e) {
+ res = await response.text();
+ }
+ if (res?.error && res?.message) {
+ throw new Error(res.message);
+ }
+
+ return res;
+ } catch (error) {
+ throw new Error(error?.message || "Fetch Wallet Failed");
+ }
+ } else {
+ throw new Error("User declined request");
+ }
+};
+
+export const getCrossChainServerInfo = async (data)=> {
+ const requiredFields = ['coin']
+ const missingFields: string[] = []
+ requiredFields.forEach((field) => {
+ if (!data[field]) {
+ missingFields.push(field)
+ }
+ })
+ if (missingFields.length > 0) {
+ const missingFieldsString = missingFields.join(', ')
+ const errorMsg = `Missing fields: ${missingFieldsString}`
+ throw new Error(errorMsg)
+ }
+ let _url = `/crosschain/` + data.coin.toLowerCase() + `/serverinfos`
+ try {
+
+
+ const url = await createEndpoint(_url);
+ const response = await fetch(url);
+ if (!response.ok) throw new Error("Failed to fetch");
+ let res;
+ try {
+ res = await response.clone().json();
+ } catch (e) {
+ res = await response.text();
+ }
+ if (res?.error && res?.message) {
+ throw new Error(res.message);
+ }
+ return res.servers
+ } catch (error) {
+
+ throw new Error(error?.message || 'Error in retrieving server info')
+ }
+}
+
+export const getTxActivitySummary = async (data) => {
+ const requiredFields = ['coin'];
+ const missingFields: string[] = [];
+ requiredFields.forEach((field) => {
+ if (!data[field]) {
+ missingFields.push(field);
+ }
+ });
+
+ if (missingFields.length > 0) {
+ const missingFieldsString = missingFields.join(', ');
+ const errorMsg = `Missing fields: ${missingFieldsString}`;
+ throw new Error(errorMsg);
+ }
+
+ const coin = data.coin;
+ const url = `/crosschain/txactivity?foreignBlockchain=${coin}`; // No apiKey here
+
+ try {
+ const endpoint = await createEndpoint(url);
+ const response = await fetch(endpoint, {
+ method: 'POST',
+ headers: {
+ Accept: '*/*',
+ 'Content-Type': 'application/json',
+ },
+ });
+
+ if (!response.ok) throw new Error('Failed to fetch');
+ let res;
+ try {
+ res = await response.clone().json();
+ } catch (e) {
+ res = await response.text();
+ }
+ if (res?.error && res?.message) {
+ throw new Error(res.message);
+ }
+ return res; // Return full response here
+ } catch (error) {
+ throw new Error(error?.message || 'Error in tx activity summary');
+ }
+ };
+
+ export const getForeignFee = async (data) => {
+ const requiredFields = ['coin', 'type'];
+ const missingFields: string[] = [];
+
+ requiredFields.forEach((field) => {
+ if (!data[field]) {
+ missingFields.push(field);
+ }
+ });
+
+ if (missingFields.length > 0) {
+ const missingFieldsString = missingFields.join(', ');
+ const errorMsg = `Missing fields: ${missingFieldsString}`;
+ throw new Error(errorMsg);
+ }
+
+ const { coin, type } = data;
+ const url = `/crosschain/${coin}/${type}`;
+
+ try {
+ const endpoint = await createEndpoint(url);
+ const response = await fetch(endpoint, {
+ method: 'GET',
+ headers: {
+ Accept: '*/*',
+ 'Content-Type': 'application/json',
+ },
+ });
+
+ if (!response.ok) throw new Error('Failed to fetch');
+ let res;
+ try {
+ res = await response.clone().json();
+ } catch (e) {
+ res = await response.text();
+ }
+ if (res?.error && res?.message) {
+ throw new Error(res.message);
+ }
+ return res; // Return full response here
+ } catch (error) {
+ throw new Error(error?.message || 'Error in get foreign fee');
+ }
+ };
+
+ export const updateForeignFee = async (data) => {
+ const localNodeAvailable = await isUsingLocal()
+ if(!localNodeAvailable) throw new Error('Please use your local node.')
+ const requiredFields = ['coin', 'type', 'value'];
+ const missingFields: string[] = [];
+
+ requiredFields.forEach((field) => {
+ if (!data[field]) {
+ missingFields.push(field);
+ }
+ });
+
+ if (missingFields.length > 0) {
+ const missingFieldsString = missingFields.join(', ');
+ const errorMsg = `Missing fields: ${missingFieldsString}`;
+ throw new Error(errorMsg);
+ }
+
+ const { coin, type, value } = data;
+ const url = `/crosschain/${coin}/update${type}`;
+
+ try {
+ const endpoint = await createEndpoint(url);
+ const response = await fetch(endpoint, {
+ method: 'POST',
+ headers: {
+ Accept: '*/*',
+ 'Content-Type': 'application/json',
+ },
+ body: JSON.stringify({ value }),
+ });
+
+ if (!response.ok) throw new Error('Failed to update foreign fee');
+ let res;
+ try {
+ res = await response.clone().json();
+ } catch (e) {
+ res = await response.text();
+ }
+ if (res?.error && res?.message) {
+ throw new Error(res.message);
+ }
+ return res; // Return full response here
+ } catch (error) {
+ throw new Error(error?.message || 'Error in update foreign fee');
+ }
+ };
+
+ export const getServerConnectionHistory = async (data) => {
+ const requiredFields = ['coin'];
+ const missingFields: string[] = [];
+
+ // Validate required fields
+ requiredFields.forEach((field) => {
+ if (!data[field]) {
+ missingFields.push(field);
+ }
+ });
+
+ if (missingFields.length > 0) {
+ const missingFieldsString = missingFields.join(', ');
+ const errorMsg = `Missing fields: ${missingFieldsString}`;
+ throw new Error(errorMsg);
+ }
+
+ const coin = data.coin.toLowerCase();
+ const url = `/crosschain/${coin}/serverconnectionhistory`;
+
+ try {
+ const endpoint = await createEndpoint(url); // Assuming createEndpoint is available
+ const response = await fetch(endpoint, {
+ method: 'GET',
+ headers: {
+ Accept: '*/*',
+ 'Content-Type': 'application/json',
+ },
+ });
+
+ if (!response.ok) throw new Error('Failed to fetch server connection history');
+
+ let res;
+ try {
+ res = await response.clone().json();
+ } catch (e) {
+ res = await response.text();
+ }
+
+ if (res?.error && res?.message) {
+ throw new Error(res.message);
+ }
+
+ return res; // Return full response here
+ } catch (error) {
+ throw new Error(error?.message || 'Error in get server connection history');
+ }
+ };
+
+ export const setCurrentForeignServer = async (data) => {
+ const localNodeAvailable = await isUsingLocal()
+ if(!localNodeAvailable) throw new Error('Please use your local node.')
+ const requiredFields = ['coin'];
+ const missingFields: string[] = [];
+
+ // Validate required fields
+ requiredFields.forEach((field) => {
+ if (!data[field]) {
+ missingFields.push(field);
+ }
+ });
+
+ if (missingFields.length > 0) {
+ const missingFieldsString = missingFields.join(', ');
+ const errorMsg = `Missing fields: ${missingFieldsString}`;
+ throw new Error(errorMsg);
+ }
+
+ const { coin, host, port, type } = data;
+ const body = {
+ hostName: host,
+ port: port,
+ connectionType: type,
+ };
+
+ const url = `/crosschain/${coin}/setcurrentserver`;
+
+ try {
+ const endpoint = await createEndpoint(url); // Assuming createEndpoint is available
+ const response = await fetch(endpoint, {
+ method: 'POST',
+ headers: {
+ Accept: '*/*',
+ 'Content-Type': 'application/json',
+ },
+ body: JSON.stringify(body),
+ });
+
+ if (!response.ok) throw new Error('Failed to set current server');
+
+ let res;
+ try {
+ res = await response.clone().json();
+ } catch (e) {
+ res = await response.text();
+ }
+
+ if (res?.error && res?.message) {
+ throw new Error(res.message);
+ }
+
+ return res; // Return the full response
+ } catch (error) {
+ throw new Error(error?.message || 'Error in set current server');
+ }
+ };
+
+
+ export const addForeignServer = async (data) => {
+ const localNodeAvailable = await isUsingLocal()
+ if(!localNodeAvailable) throw new Error('Please use your local node.')
+ const requiredFields = ['coin'];
+ const missingFields: string[] = [];
+
+ // Validate required fields
+ requiredFields.forEach((field) => {
+ if (!data[field]) {
+ missingFields.push(field);
+ }
+ });
+
+ if (missingFields.length > 0) {
+ const missingFieldsString = missingFields.join(', ');
+ const errorMsg = `Missing fields: ${missingFieldsString}`;
+ throw new Error(errorMsg);
+ }
+
+ const { coin, host, port, type } = data;
+ const body = {
+ hostName: host,
+ port: port,
+ connectionType: type,
+ };
+
+ const url = `/crosschain/${coin}/addserver`;
+
+ try {
+ const endpoint = await createEndpoint(url); // Assuming createEndpoint is available
+ const response = await fetch(endpoint, {
+ method: 'POST',
+ headers: {
+ Accept: '*/*',
+ 'Content-Type': 'application/json',
+ },
+ body: JSON.stringify(body),
+ });
+
+ if (!response.ok) throw new Error('Failed to add server');
+
+ let res;
+ try {
+ res = await response.clone().json();
+ } catch (e) {
+ res = await response.text();
+ }
+
+ if (res?.error && res?.message) {
+ throw new Error(res.message);
+ }
+
+ return res; // Return the full response
+ } catch (error) {
+ throw new Error(error.message || 'Error in adding server');
+ }
+ };
+
+ export const removeForeignServer = async (data) => {
+ const localNodeAvailable = await isUsingLocal()
+ if(!localNodeAvailable) throw new Error('Please use your local node.')
+ const requiredFields = ['coin'];
+ const missingFields: string[] = [];
+
+ // Validate required fields
+ requiredFields.forEach((field) => {
+ if (!data[field]) {
+ missingFields.push(field);
+ }
+ });
+
+ if (missingFields.length > 0) {
+ const missingFieldsString = missingFields.join(', ');
+ const errorMsg = `Missing fields: ${missingFieldsString}`;
+ throw new Error(errorMsg);
+ }
+
+ const { coin, host, port, type } = data;
+ const body = {
+ hostName: host,
+ port: port,
+ connectionType: type,
+ };
+
+ const url = `/crosschain/${coin}/removeserver`;
+
+ try {
+ const endpoint = await createEndpoint(url); // Assuming createEndpoint is available
+ const response = await fetch(endpoint, {
+ method: 'POST',
+ headers: {
+ Accept: '*/*',
+ 'Content-Type': 'application/json',
+ },
+ body: JSON.stringify(body),
+ });
+
+ if (!response.ok) throw new Error('Failed to remove server');
+
+ let res;
+ try {
+ res = await response.clone().json();
+ } catch (e) {
+ res = await response.text();
+ }
+
+ if (res?.error && res?.message) {
+ throw new Error(res.message);
+ }
+
+ return res; // Return the full response
+ } catch (error) {
+ throw new Error(error?.message || 'Error in removing server');
+ }
+ };
+
+ export const getDaySummary = async () => {
+ const url = `/admin/summary`; // Simplified endpoint URL
+
+ try {
+ const endpoint = await createEndpoint(url); // Assuming createEndpoint is available for constructing the full URL
+ const response = await fetch(endpoint, {
+ method: 'GET',
+ headers: {
+ Accept: '*/*',
+ },
+ });
+
+ if (!response.ok) throw new Error('Failed to retrieve summary');
+
+ let res;
+ try {
+ res = await response.clone().json();
+ } catch (e) {
+ res = await response.text();
+ }
+
+ if (res?.error && res?.message) {
+ throw new Error(res.message);
+ }
+
+ return res; // Return the full response
+ } catch (error) {
+ throw new Error(error?.message || 'Error in retrieving summary');
+ }
+ };
+
+export const sendCoin = async (data, isFromExtension) => {
+ const requiredFields = ['coin', 'destinationAddress', 'amount']
+ const missingFields: string[] = []
+ requiredFields.forEach((field) => {
+ if (!data[field]) {
+ missingFields.push(field)
+ }
+ })
+ if (missingFields.length > 0) {
+ const missingFieldsString = missingFields.join(', ')
+ const errorMsg = `Missing fields: ${missingFieldsString}`
+ throw new Error(errorMsg)
+ }
+ let checkCoin = data.coin
+ const wallet = await getSaveWallet();
+ const address = wallet.address0;
+ const resKeyPair = await getKeyPair();
+ const parsedData = JSON.parse(resKeyPair);
+ const localNodeAvailable = await isUsingLocal()
+ if(checkCoin !== 'QORT' && !localNodeAvailable) throw new Error('Cannot send a non-QORT coin through the gateway. Please use your local node.')
+ if (checkCoin === "QORT") {
+ // Params: data.coin, data.destinationAddress, data.amount, data.fee
+ // TODO: prompt user to send. If they confirm, call `POST /crosschain/:coin/send`, or for QORT, broadcast a PAYMENT transaction
+ // then set the response string from the core to the `response` variable (defined above)
+ // If they decline, send back JSON that includes an `error` key, such as `{"error": "User declined request"}`
+ const amount = Number(data.amount)
+ const recipient = data.destinationAddress
+
+ const url = await createEndpoint(`/addresses/balance/${address}`);
+ const response = await fetch(url);
+ if (!response.ok) throw new Error("Failed to fetch");
+ let walletBalance;
+ try {
+ walletBalance = await response.clone().json();
+ } catch (e) {
+ walletBalance = await response.text();
+ }
+ if (isNaN(Number(walletBalance))) {
+ let errorMsg = "Failed to Fetch QORT Balance. Try again!"
+ throw new Error(errorMsg)
+ }
+
+ const transformDecimals = (Number(walletBalance) * QORT_DECIMALS).toFixed(0)
+ const walletBalanceDecimals = Number(transformDecimals)
+ const amountDecimals = Number(amount) * QORT_DECIMALS
+ const fee: number = await sendQortFee()
+ if (amountDecimals + (fee * QORT_DECIMALS) > walletBalanceDecimals) {
+ let errorMsg = "Insufficient Funds!"
+ throw new Error(errorMsg)
+ }
+ if (amount <= 0) {
+ let errorMsg = "Invalid Amount!"
+ throw new Error(errorMsg)
+ }
+ if (recipient.length === 0) {
+ let errorMsg = "Receiver cannot be empty!"
+ throw new Error(errorMsg)
+ }
+
+ const resPermission = await getUserPermission({
+ text1: "Do you give this application permission to send coins?",
+ text2: `To: ${recipient}`,
+ highlightedText: `${amount} ${checkCoin}`,
+ }, isFromExtension);
+ const { accepted } = resPermission;
+
+ if (accepted) {
+ const makePayment = await sendCoinFunc({amount, password: null, receiver: recipient }, true)
+ return makePayment.res
+ } else {
+ throw new Error("User declined request")
+ }
+
+ } else if (checkCoin === "BTC") {
+ const amount = Number(data.amount)
+ const recipient = data.destinationAddress
+ const xprv58 = parsedData.btcPrivateKey
+ const feePerByte = data.fee ? data.fee : btcFeePerByte
+
+ const btcWalletBalance = await getWalletBalance({coin: checkCoin}, true)
+
+ if (isNaN(Number(btcWalletBalance))) {
+ throw new Error('Unable to fetch BTC balance')
+ }
+ const btcWalletBalanceDecimals = Number(btcWalletBalance)
+ const btcAmountDecimals = Number(amount) * QORT_DECIMALS
+ const fee = feePerByte * 500 // default 0.00050000
+ if (btcAmountDecimals + (fee * QORT_DECIMALS) > btcWalletBalanceDecimals) {
+ throw new Error("INSUFFICIENT_FUNDS")
+ }
+
+ const resPermission = await getUserPermission({
+ text1: "Do you give this application permission to send coins?",
+ text2: `To: ${recipient}`,
+ highlightedText: `${amount} ${checkCoin}`,
+ fee: fee
+ }, isFromExtension);
+ const { accepted } = resPermission;
+
+ if (accepted) {
+ const opts = {
+ xprv58: xprv58,
+ receivingAddress: recipient,
+ bitcoinAmount: amount,
+ feePerByte: feePerByte * QORT_DECIMALS
+ }
+ const url = await createEndpoint(`/crosschain/btc/send`);
+
+ const response = await fetch(url, {
+ method: 'POST',
+ headers: {
+ 'Accept': 'application/json',
+ 'Content-Type': 'application/json'
+ },
+ body: JSON.stringify(opts)
+ })
+ if (!response.ok) throw new Error("Failed to send");
+ let res;
+ try {
+ res = await response.clone().json();
+ } catch (e) {
+ res = await response.text();
+ }
+ return res;
+
+ } else {
+ throw new Error("User declined request")
+ }
+
+ } else if (checkCoin === "LTC") {
+
+ const amount = Number(data.amount)
+ const recipient = data.destinationAddress
+ const xprv58 = parsedData.ltcPrivateKey
+ const feePerByte = data.fee ? data.fee : ltcFeePerByte
+ const ltcWalletBalance = await getWalletBalance({coin: checkCoin}, true)
+
+ if (isNaN(Number(ltcWalletBalance))) {
+ let errorMsg = "Failed to Fetch LTC Balance. Try again!"
+ throw new Error(errorMsg)
+ }
+ const ltcWalletBalanceDecimals = Number(ltcWalletBalance)
+ const ltcAmountDecimals = Number(amount) * QORT_DECIMALS
+ const balance = (Number(ltcWalletBalance) / 1e8).toFixed(8)
+ const fee = feePerByte * 1000 // default 0.00030000
+ if (ltcAmountDecimals + (fee * QORT_DECIMALS) > ltcWalletBalanceDecimals) {
+ throw new Error("Insufficient Funds!")
+ }
+ const resPermission = await getUserPermission({
+ text1: "Do you give this application permission to send coins?",
+ text2: `To: ${recipient}`,
+ highlightedText: `${amount} ${checkCoin}`,
+ fee: fee
+ }, isFromExtension);
+ const { accepted } = resPermission;
+
+ if (accepted) {
+ const url = await createEndpoint(`/crosschain/ltc/send`);
+ const opts = {
+ xprv58: xprv58,
+ receivingAddress: recipient,
+ litecoinAmount: amount,
+ feePerByte: feePerByte * QORT_DECIMALS
+ }
+ const response = await fetch(url, {
+ method: 'POST',
+ headers: {
+ 'Accept': 'application/json',
+ 'Content-Type': 'application/json'
+ },
+ body: JSON.stringify(opts)
+ })
+ if (!response.ok) throw new Error("Failed to send");
+ let res;
+ try {
+ res = await response.clone().json();
+ } catch (e) {
+ res = await response.text();
+ }
+ return res;
+ } else {
+ throw new Error("User declined request")
+ }
+
+ } else if (checkCoin === "DOGE") {
+
+ const amount = Number(data.amount)
+ const recipient = data.destinationAddress
+ const coin = data.coin
+ const xprv58 = parsedData.dogePrivateKey
+ const feePerByte = data.fee ? data.fee : dogeFeePerByte
+ const dogeWalletBalance = await getWalletBalance({coin: checkCoin}, true)
+ if (isNaN(Number(dogeWalletBalance))) {
+ let errorMsg = "Failed to Fetch DOGE Balance. Try again!"
+ throw new Error(errorMsg)
+ }
+ const dogeWalletBalanceDecimals = Number(dogeWalletBalance)
+ const dogeAmountDecimals = Number(amount) * QORT_DECIMALS
+ const balance = (Number(dogeWalletBalance) / 1e8).toFixed(8)
+ const fee = feePerByte * 5000 // default 0.05000000
+ if (dogeAmountDecimals + (fee * QORT_DECIMALS) > dogeWalletBalanceDecimals) {
+ let errorMsg = "Insufficient Funds!"
+ throw new Error(errorMsg)
+ }
+
+ const resPermission = await getUserPermission({
+ text1: "Do you give this application permission to send coins?",
+ text2: `To: ${recipient}`,
+ highlightedText: `${amount} ${checkCoin}`,
+ fee: fee
+ }, isFromExtension);
+ const { accepted } = resPermission;
+
+ if (accepted) {
+ const opts = {
+ xprv58: xprv58,
+ receivingAddress: recipient,
+ dogecoinAmount: amount,
+ feePerByte: feePerByte * QORT_DECIMALS
+ }
+ const url = await createEndpoint(`/crosschain/doge/send`);
+
+ const response = await fetch(url, {
+ method: 'POST',
+ headers: {
+ 'Accept': 'application/json',
+ 'Content-Type': 'application/json'
+ },
+ body: JSON.stringify(opts)
+ })
+ if (!response.ok) throw new Error("Failed to send");
+ let res;
+ try {
+ res = await response.clone().json();
+ } catch (e) {
+ res = await response.text();
+ }
+ return res;
+ } else {
+ throw new Error("User declined request")
+ }
+
+ } else if (checkCoin === "DGB") {
+ const amount = Number(data.amount)
+ const recipient = data.destinationAddress
+ const xprv58 = parsedData.dbgPrivateKey
+ const feePerByte = data.fee ? data.fee : dgbFeePerByte
+ const dgbWalletBalance = await getWalletBalance({coin: checkCoin}, true)
+ if (isNaN(Number(dgbWalletBalance))) {
+ let errorMsg = "Failed to Fetch DGB Balance. Try again!"
+ throw new Error(errorMsg)
+ }
+ const dgbWalletBalanceDecimals = Number(dgbWalletBalance)
+ const dgbAmountDecimals = Number(amount) * QORT_DECIMALS
+ const fee = feePerByte * 500 // default 0.00005000
+ if (dgbAmountDecimals + (fee * QORT_DECIMALS) > dgbWalletBalanceDecimals) {
+ let errorMsg = "Insufficient Funds!"
+ throw new Error(errorMsg)
+ }
+
+ const resPermission = await getUserPermission({
+ text1: "Do you give this application permission to send coins?",
+ text2: `To: ${recipient}`,
+ highlightedText: `${amount} ${checkCoin}`,
+ fee: fee
+ }, isFromExtension);
+ const { accepted } = resPermission;
+
+ if (accepted) {
+ const opts = {
+ xprv58: xprv58,
+ receivingAddress: recipient,
+ digibyteAmount: amount,
+ feePerByte: feePerByte * QORT_DECIMALS
+ }
+ const url = await createEndpoint(`/crosschain/dgb/send`);
+
+ const response = await fetch(url, {
+ method: 'POST',
+ headers: {
+ 'Accept': 'application/json',
+ 'Content-Type': 'application/json'
+ },
+ body: JSON.stringify(opts)
+ })
+ if (!response.ok) throw new Error("Failed to send");
+ let res;
+ try {
+ res = await response.clone().json();
+ } catch (e) {
+ res = await response.text();
+ }
+ return res;
+ } else {
+ throw new Error("User declined request")
+ }
+
+ } else if (checkCoin === "RVN") {
+ const amount = Number(data.amount)
+ const recipient = data.destinationAddress
+ const coin = data.coin
+ const xprv58 = parsedData.rvnPrivateKey
+ const feePerByte = data.fee ? data.fee : rvnFeePerByte
+ const rvnWalletBalance = await getWalletBalance({coin: checkCoin}, true)
+ if (isNaN(Number(rvnWalletBalance))) {
+ let errorMsg = "Failed to Fetch RVN Balance. Try again!"
+ throw new Error(errorMsg)
+ }
+ const rvnWalletBalanceDecimals = Number(rvnWalletBalance)
+ const rvnAmountDecimals = Number(amount) * QORT_DECIMALS
+ const balance = (Number(rvnWalletBalance) / 1e8).toFixed(8)
+ const fee = feePerByte * 500 // default 0.00562500
+ if (rvnAmountDecimals + (fee * QORT_DECIMALS) > rvnWalletBalanceDecimals) {
+
+ let errorMsg = "Insufficient Funds!"
+ throw new Error(errorMsg)
+ }
+
+ const resPermission = await getUserPermission({
+ text1: "Do you give this application permission to send coins?",
+ text2: `To: ${recipient}`,
+ highlightedText: `${amount} ${checkCoin}`,
+ fee: fee
+ }, isFromExtension);
+ const { accepted } = resPermission;
+
+ if (accepted) {
+ const opts = {
+ xprv58: xprv58,
+ receivingAddress: recipient,
+ ravencoinAmount: amount,
+ feePerByte: feePerByte * QORT_DECIMALS
+ }
+ const url = await createEndpoint(`/crosschain/rvn/send`);
+
+ const response = await fetch(url, {
+ method: 'POST',
+ headers: {
+ 'Accept': 'application/json',
+ 'Content-Type': 'application/json'
+ },
+ body: JSON.stringify(opts)
+ })
+ if (!response.ok) throw new Error("Failed to send");
+ let res;
+ try {
+ res = await response.clone().json();
+ } catch (e) {
+ res = await response.text();
+ }
+ return res;
+ } else {
+ throw new Error("User declined request")
+ }
+ } else if (checkCoin === "ARRR") {
+ const amount = Number(data.amount)
+ const recipient = data.destinationAddress
+ const memo = data.memo
+ const arrrWalletBalance = await getWalletBalance({coin: checkCoin}, true)
+
+ if (isNaN(Number(arrrWalletBalance))) {
+ let errorMsg = "Failed to Fetch ARRR Balance. Try again!"
+ throw new Error(errorMsg)
+ }
+ const arrrWalletBalanceDecimals = Number(arrrWalletBalance)
+ const arrrAmountDecimals = Number(amount) * QORT_DECIMALS
+ const fee = 0.00010000
+ if (arrrAmountDecimals + (fee * QORT_DECIMALS) > arrrWalletBalanceDecimals) {
+ let errorMsg = "Insufficient Funds!"
+ throw new Error(errorMsg)
+ }
+
+ const resPermission = await getUserPermission({
+ text1: "Do you give this application permission to send coins?",
+ text2: `To: ${recipient}`,
+ highlightedText: `${amount} ${checkCoin}`,
+ fee: fee
+ }, isFromExtension);
+ const { accepted } = resPermission;
+
+ if (accepted) {
+ const opts = {
+ entropy58: parsedData.arrrSeed58,
+ receivingAddress: recipient,
+ arrrAmount: amount,
+ memo: memo
+ }
+ const url = await createEndpoint(`/crosschain/btc/send`);
+
+ const response = await fetch(url, {
+ method: 'POST',
+ headers: {
+ 'Accept': 'application/json',
+ 'Content-Type': 'application/json'
+ },
+ body: JSON.stringify(opts)
+ })
+ if (!response.ok) throw new Error("Failed to send");
+ let res;
+ try {
+ res = await response.clone().json();
+ } catch (e) {
+ res = await response.text();
+ }
+ return res;
+ } else {
+ throw new Error("User declined request")
+ }
+ }
+};
diff --git a/src/transactions/CreatePollTransaction.ts b/src/transactions/CreatePollTransaction.ts
new file mode 100644
index 0000000..a2a9cc0
--- /dev/null
+++ b/src/transactions/CreatePollTransaction.ts
@@ -0,0 +1,73 @@
+// @ts-nocheck
+import { QORT_DECIMALS } from '../constants/constants'
+import TransactionBase from './TransactionBase'
+
+export default class CreatePollTransaction extends TransactionBase {
+ constructor() {
+ super()
+ this.type = 8
+ this._options = []
+ }
+
+ addOption(option) {
+ const optionBytes = this.constructor.utils.stringtoUTF8Array(option)
+ const optionLength = this.constructor.utils.int32ToBytes(optionBytes.length)
+ this._options.push({ length: optionLength, bytes: optionBytes })
+ }
+
+
+ set fee(fee) {
+ this._fee = fee * QORT_DECIMALS
+ this._feeBytes = this.constructor.utils.int64ToBytes(this._fee)
+ }
+
+ set ownerAddress(ownerAddress) {
+ this._ownerAddress = ownerAddress instanceof Uint8Array ? ownerAddress : this.constructor.Base58.decode(ownerAddress)
+ }
+
+ set rPollName(rPollName) {
+ this._rPollName = rPollName
+ this._rPollNameBytes = this.constructor.utils.stringtoUTF8Array(this._rPollName)
+ this._rPollNameLength = this.constructor.utils.int32ToBytes(this._rPollNameBytes.length)
+
+ }
+
+ set rPollDesc(rPollDesc) {
+ this._rPollDesc = rPollDesc
+ this._rPollDescBytes = this.constructor.utils.stringtoUTF8Array(this._rPollDesc)
+ this._rPollDescLength = this.constructor.utils.int32ToBytes(this._rPollDescBytes.length)
+ }
+
+ set rOptions(rOptions) {
+ const optionsArray = rOptions[0].split(', ').map(opt => opt.trim())
+ this._pollOptions = optionsArray
+
+ for (let i = 0; i < optionsArray.length; i++) {
+ this.addOption(optionsArray[i])
+ }
+
+ this._rNumberOfOptionsBytes = this.constructor.utils.int32ToBytes(optionsArray.length)
+ }
+
+
+ get params() {
+ const params = super.params
+ params.push(
+ this._ownerAddress,
+ this._rPollNameLength,
+ this._rPollNameBytes,
+ this._rPollDescLength,
+ this._rPollDescBytes,
+ this._rNumberOfOptionsBytes
+ )
+
+ // Push the dynamic options
+ for (let i = 0; i < this._options.length; i++) {
+ params.push(this._options[i].length, this._options[i].bytes)
+ }
+
+ params.push(this._feeBytes)
+
+ return params
+ }
+}
diff --git a/src/transactions/DeployAtTransaction.ts b/src/transactions/DeployAtTransaction.ts
new file mode 100644
index 0000000..8a20553
--- /dev/null
+++ b/src/transactions/DeployAtTransaction.ts
@@ -0,0 +1,78 @@
+// @ts-nocheck
+
+
+import TransactionBase from './TransactionBase'
+import { QORT_DECIMALS } from '../constants/constants'
+
+export default class DeployAtTransaction extends TransactionBase {
+ constructor() {
+ super()
+ this.type = 16
+ }
+
+
+
+ set fee(fee) {
+ this._fee = fee * QORT_DECIMALS
+ this._feeBytes = this.constructor.utils.int64ToBytes(this._fee)
+ }
+
+ set rAmount(rAmount) {
+ this._rAmount = Math.round(rAmount * QORT_DECIMALS)
+ this._rAmountBytes = this.constructor.utils.int64ToBytes(this._rAmount)
+ }
+
+ set rName(rName) {
+ this._rName = rName
+ this._rNameBytes = this.constructor.utils.stringtoUTF8Array(this._rName.toLocaleLowerCase())
+ this._rNameLength = this.constructor.utils.int32ToBytes(this._rNameBytes.length)
+ }
+
+ set rDescription(rDescription) {
+ this._rDescription = rDescription
+ this._rDescriptionBytes = this.constructor.utils.stringtoUTF8Array(this._rDescription.toLocaleLowerCase())
+ this._rDescriptionLength = this.constructor.utils.int32ToBytes(this._rDescriptionBytes.length)
+ }
+
+ set atType(atType) {
+ this._atType = atType
+ this._atTypeBytes = this.constructor.utils.stringtoUTF8Array(this._atType)
+ this._atTypeLength = this.constructor.utils.int32ToBytes(this._atTypeBytes.length)
+ }
+
+ set rTags(rTags) {
+ this._rTags = rTags
+ this._rTagsBytes = this.constructor.utils.stringtoUTF8Array(this._rTags.toLocaleLowerCase())
+ this._rTagsLength = this.constructor.utils.int32ToBytes(this._rTagsBytes.length)
+ }
+
+ set rCreationBytes(rCreationBytes) {
+ const decode = this.constructor.Base58.decode(rCreationBytes)
+ this._rCreationBytes = this.constructor.utils.stringtoUTF8Array(decode)
+ this._rCreationBytesLength = this.constructor.utils.int32ToBytes(this._rCreationBytes.length)
+ }
+
+ set rAssetId(rAssetId) {
+ this._rAssetId = this.constructor.utils.int64ToBytes(rAssetId)
+ }
+
+ get params() {
+ const params = super.params
+ params.push(
+ this._rNameLength,
+ this._rNameBytes,
+ this._rDescriptionLength,
+ this._rDescriptionBytes,
+ this._atTypeLength,
+ this._atTypeBytes,
+ this._rTagsLength,
+ this._rTagsBytes,
+ this._rCreationBytesLength,
+ this._rCreationBytes,
+ this._rAmountBytes,
+ this._rAssetId,
+ this._feeBytes
+ )
+ return params
+ }
+}
diff --git a/src/transactions/VoteOnPollTransaction.ts b/src/transactions/VoteOnPollTransaction.ts
new file mode 100644
index 0000000..327295e
--- /dev/null
+++ b/src/transactions/VoteOnPollTransaction.ts
@@ -0,0 +1,38 @@
+// @ts-nocheck
+import { QORT_DECIMALS } from '../constants/constants'
+import TransactionBase from './TransactionBase'
+
+export default class VoteOnPollTransaction extends TransactionBase {
+ constructor() {
+ super()
+ this.type = 9
+ }
+
+
+ set fee(fee) {
+ this._fee = fee * QORT_DECIMALS
+ this._feeBytes = this.constructor.utils.int64ToBytes(this._fee)
+ }
+
+ set rPollName(rPollName) {
+ this._rPollName = rPollName
+ this._rPollNameBytes = this.constructor.utils.stringtoUTF8Array(this._rPollName)
+ this._rPollNameLength = this.constructor.utils.int32ToBytes(this._rPollNameBytes.length)
+ }
+
+ set rOptionIndex(rOptionIndex) {
+ this._rOptionIndex = rOptionIndex
+ this._rOptionIndexBytes = this.constructor.utils.int32ToBytes(this._rOptionIndex)
+ }
+
+ get params() {
+ const params = super.params
+ params.push(
+ this._rPollNameLength,
+ this._rPollNameBytes,
+ this._rOptionIndexBytes,
+ this._feeBytes
+ )
+ return params
+ }
+}
diff --git a/src/transactions/transactions.ts b/src/transactions/transactions.ts
index 25ddbf5..400418c 100644
--- a/src/transactions/transactions.ts
+++ b/src/transactions/transactions.ts
@@ -14,11 +14,17 @@ import JoinGroupTransaction from './JoinGroupTransaction.js'
import AddGroupAdminTransaction from './AddGroupAdminTransaction.js'
import RemoveGroupAdminTransaction from './RemoveGroupAdminTransaction.js'
import RegisterNameTransaction from './RegisterNameTransaction.js'
+import VoteOnPollTransaction from './VoteOnPollTransaction.js'
+import CreatePollTransaction from './CreatePollTransaction.js'
+import DeployAtTransaction from './DeployAtTransaction.js'
export const transactionTypes = {
3: RegisterNameTransaction,
2: PaymentTransaction,
+ 8: CreatePollTransaction,
+ 9: VoteOnPollTransaction,
+ 16: DeployAtTransaction,
18: ChatTransaction,
181: GroupChatTransaction,
22: CreateGroupTransaction,
diff --git a/src/useAppFullscreen.tsx b/src/useAppFullscreen.tsx
new file mode 100644
index 0000000..3dbe4a1
--- /dev/null
+++ b/src/useAppFullscreen.tsx
@@ -0,0 +1,67 @@
+import { useCallback, useEffect } from 'react';
+import { isMobile } from './App';
+
+export const useAppFullScreen = (setFullScreen) => {
+ const enterFullScreen = useCallback(() => {
+ const element = document.documentElement; // Target the entire HTML document
+ if (element.requestFullscreen) {
+ element.requestFullscreen();
+ } else if (element.mozRequestFullScreen) { // Firefox
+ element.mozRequestFullScreen();
+ } else if (element.webkitRequestFullscreen) { // Chrome, Safari and Opera
+ element.webkitRequestFullscreen();
+ } else if (element.msRequestFullscreen) { // IE/Edge
+ element.msRequestFullscreen();
+ }
+ }, []);
+
+ const exitFullScreen = useCallback(() => {
+ if (document.fullscreenElement) {
+ document.exitFullscreen();
+ } else if (document.mozFullScreenElement) {
+ document.mozCancelFullScreen();
+ } else if (document.webkitFullscreenElement) {
+ document.webkitExitFullscreen();
+ } else if (document.msFullscreenElement) {
+ document.msExitFullscreen();
+ }
+ }, []);
+
+ const toggleFullScreen = useCallback(() => {
+ if(!isMobile || isMobile) return
+ if (document.fullscreenElement || document.mozFullScreenElement || document.webkitFullscreenElement || document.msFullscreenElement) {
+ exitFullScreen();
+ setFullScreen(false)
+ } else {
+ enterFullScreen();
+ setFullScreen(true)
+ }
+ }, [enterFullScreen, exitFullScreen]);
+
+ // Listen for changes to fullscreen state
+ useEffect(() => {
+ const handleFullScreenChange = () => {
+ if (document.fullscreenElement || document.mozFullScreenElement || document.webkitFullscreenElement || document.msFullscreenElement) {
+
+ } else {
+ setFullScreen(false);
+ }
+ };
+
+ document.addEventListener('fullscreenchange', handleFullScreenChange);
+ document.addEventListener('webkitfullscreenchange', handleFullScreenChange); // Safari
+ document.addEventListener('mozfullscreenchange', handleFullScreenChange); // Firefox
+ document.addEventListener('MSFullscreenChange', handleFullScreenChange); // IE/Edge
+
+ return () => {
+ document.removeEventListener('fullscreenchange', handleFullScreenChange);
+ document.removeEventListener('webkitfullscreenchange', handleFullScreenChange);
+ document.removeEventListener('mozfullscreenchange', handleFullScreenChange);
+ document.removeEventListener('MSFullscreenChange', handleFullScreenChange);
+ };
+ }, []);
+
+ return { enterFullScreen, exitFullScreen, toggleFullScreen };
+};
+
+
diff --git a/src/useQortalGetSaveSettings.tsx b/src/useQortalGetSaveSettings.tsx
new file mode 100644
index 0000000..0223f12
--- /dev/null
+++ b/src/useQortalGetSaveSettings.tsx
@@ -0,0 +1,94 @@
+import React, { useCallback, useEffect } from 'react'
+import { useRecoilState, useSetRecoilState } from 'recoil';
+import { canSaveSettingToQdnAtom, oldPinnedAppsAtom, settingsLocalLastUpdatedAtom, settingsQDNLastUpdatedAtom, sortablePinnedAppsAtom } from './atoms/global';
+import { getArbitraryEndpointReact, getBaseApiReact } from './App';
+import { decryptResource } from './components/Group/Group';
+import { base64ToUint8Array, uint8ArrayToObject } from './backgroundFunctions/encryption';
+
+function fetchFromLocalStorage(key) {
+ try {
+ const serializedValue = localStorage.getItem(key);
+ if (serializedValue === null) {
+ console.log(`No data found for key: ${key}`);
+ return null;
+ }
+ return JSON.parse(serializedValue);
+ } catch (error) {
+ console.error('Error fetching from localStorage:', error);
+ return null;
+ }
+}
+
+const getPublishRecord = async (myName) => {
+ // const validApi = await findUsableApi();
+ const url = `${getBaseApiReact()}${getArbitraryEndpointReact()}?mode=ALL&service=DOCUMENT_PRIVATE&identifier=ext_saved_settings&exactmatchnames=true&limit=1&prefix=true&name=${myName}`;
+ const response = await fetch(url);
+ if (!response.ok) {
+ throw new Error("network error");
+ }
+ const publishData = await response.json();
+
+ if(publishData?.length > 0) return {hasPublishRecord: true, timestamp: publishData[0]?.updated || publishData[0].created}
+
+ return {hasPublishRecord: false}
+ };
+ const getPublish = async (myName) => {
+ try {
+ let data
+ const res = await fetch(
+ `${getBaseApiReact()}/arbitrary/DOCUMENT_PRIVATE/${myName}/ext_saved_settings?encoding=base64`
+ );
+ data = await res.text();
+
+
+ if(!data) throw new Error('Unable to fetch publish')
+
+ const decryptedKey: any = await decryptResource(data);
+
+ const dataint8Array = base64ToUint8Array(decryptedKey.data);
+ const decryptedKeyToObject = uint8ArrayToObject(dataint8Array);
+ return decryptedKeyToObject
+ } catch (error) {
+ return null
+ }
+ };
+
+export const useQortalGetSaveSettings = (myName) => {
+ const setSortablePinnedApps = useSetRecoilState(sortablePinnedAppsAtom);
+ const setCanSave = useSetRecoilState(canSaveSettingToQdnAtom);
+ const setSettingsQDNLastUpdated = useSetRecoilState(settingsQDNLastUpdatedAtom);
+ const [settingsLocalLastUpdated] = useRecoilState(settingsLocalLastUpdatedAtom);
+ const [oldPinnedApps, setOldPinnedApps] = useRecoilState(oldPinnedAppsAtom)
+
+ const getSavedSettings = useCallback(async (myName, settingsLocalLastUpdated)=> {
+ try {
+ const {hasPublishRecord, timestamp} = await getPublishRecord(myName)
+ if(hasPublishRecord){
+ const settings = await getPublish(myName)
+ if(settings?.sortablePinnedApps && timestamp > settingsLocalLastUpdated){
+ setSortablePinnedApps(settings.sortablePinnedApps)
+
+ setSettingsQDNLastUpdated(timestamp || 0)
+ } else if(settings?.sortablePinnedApps){
+ setSettingsQDNLastUpdated(timestamp || 0)
+ setOldPinnedApps(settings.sortablePinnedApps)
+ }
+ if(!settings){
+ // set -100 to indicate that it couldn't fetch the publish
+ setSettingsQDNLastUpdated(-100)
+
+ }
+ } else {
+ setSettingsQDNLastUpdated( 0)
+ }
+ setCanSave(true)
+ } catch (error) {
+
+ }
+ }, [])
+ useEffect(()=> {
+ if(!myName || !settingsLocalLastUpdated) return
+ getSavedSettings(myName, settingsLocalLastUpdated)
+ }, [getSavedSettings, myName, settingsLocalLastUpdated])
+
+}
diff --git a/src/useRetrieveDataLocalStorage.tsx b/src/useRetrieveDataLocalStorage.tsx
new file mode 100644
index 0000000..6d7b05e
--- /dev/null
+++ b/src/useRetrieveDataLocalStorage.tsx
@@ -0,0 +1,35 @@
+import React, { useCallback, useEffect } from 'react'
+import { useSetRecoilState } from 'recoil';
+import { settingsLocalLastUpdatedAtom, sortablePinnedAppsAtom } from './atoms/global';
+
+function fetchFromLocalStorage(key) {
+ try {
+ const serializedValue = localStorage.getItem(key);
+ if (serializedValue === null) {
+ console.log(`No data found for key: ${key}`);
+ return null;
+ }
+ return JSON.parse(serializedValue);
+ } catch (error) {
+ console.error('Error fetching from localStorage:', error);
+ return null;
+ }
+}
+
+export const useRetrieveDataLocalStorage = () => {
+ const setSortablePinnedApps = useSetRecoilState(sortablePinnedAppsAtom);
+ const setSettingsLocalLastUpdated = useSetRecoilState(settingsLocalLastUpdatedAtom);
+
+ const getSortablePinnedApps = useCallback(()=> {
+ const pinnedAppsLocal = fetchFromLocalStorage('ext_saved_settings')
+ if(pinnedAppsLocal?.sortablePinnedApps){
+ setSortablePinnedApps(pinnedAppsLocal?.sortablePinnedApps)
+ }
+ setSettingsLocalLastUpdated(pinnedAppsLocal?.timestamp || -1)
+ }, [])
+ useEffect(()=> {
+
+ getSortablePinnedApps()
+ }, [getSortablePinnedApps])
+
+}
diff --git a/src/utils/memeTypes.ts b/src/utils/memeTypes.ts
new file mode 100644
index 0000000..2bc5873
--- /dev/null
+++ b/src/utils/memeTypes.ts
@@ -0,0 +1,56 @@
+export const mimeToExtensionMap = {
+ // Documents
+ "application/pdf": ".pdf",
+ "application/msword": ".doc",
+ "application/vnd.openxmlformats-officedocument.wordprocessingml.document": ".docx",
+ "application/vnd.ms-excel": ".xls",
+ "application/vnd.openxmlformats-officedocument.spreadsheetml.sheet": ".xlsx",
+ "application/vnd.ms-powerpoint": ".ppt",
+ "application/vnd.openxmlformats-officedocument.presentationml.presentation": ".pptx",
+ "application/vnd.oasis.opendocument.text": ".odt",
+ "application/vnd.oasis.opendocument.spreadsheet": ".ods",
+ "application/vnd.oasis.opendocument.presentation": ".odp",
+ "text/plain": ".txt",
+ "text/csv": ".csv",
+ "text/html": ".html",
+ "application/xhtml+xml": ".xhtml",
+ "application/xml": ".xml",
+ "application/json": ".json",
+
+ // Images
+ "image/jpeg": ".jpg",
+ "image/png": ".png",
+ "image/gif": ".gif",
+ "image/webp": ".webp",
+ "image/svg+xml": ".svg",
+ "image/tiff": ".tif",
+ "image/bmp": ".bmp",
+
+ // Audio
+ "audio/mpeg": ".mp3",
+ "audio/ogg": ".ogg",
+ "audio/wav": ".wav",
+ "audio/webm": ".weba",
+ "audio/aac": ".aac",
+
+ // Video
+ "video/mp4": ".mp4",
+ "video/webm": ".webm",
+ "video/ogg": ".ogv",
+ "video/x-msvideo": ".avi",
+ "video/quicktime": ".mov",
+ "video/x-ms-wmv": ".wmv",
+ "video/mpeg": ".mpeg",
+ "video/3gpp": ".3gp",
+ "video/3gpp2": ".3g2",
+ "video/x-matroska": ".mkv",
+ "video/x-flv": ".flv",
+
+ // Archives
+ "application/zip": ".zip",
+ "application/x-rar-compressed": ".rar",
+ "application/x-tar": ".tar",
+ "application/x-7z-compressed": ".7z",
+ "application/x-gzip": ".gz",
+ "application/x-bzip2": ".bz2",
+}
\ No newline at end of file
+
`
+ )
+ .join("")}
+ Service: ${
+ resource.service
+ }
+ Name: ${resource.name}
+ Identifier: ${
+ resource.identifier
+ }
+ ${
+ resource.filename
+ ? `Filename: ${resource.filename}
`
+ : ""
+ }
+