feature/IO-3096-GlobalNotifications - Checkpoint - Splits are now in place

client/src/App/App.jsx

@@ -48,6 +48,8 @@ export function App({ bodyshop, checkUserSession, currentUser, online, setOnline
   const { t } = useTranslation();
   const navigate = useNavigate();
 
+  const scenarioNotificationsOn = client?.getTreatment("Realtime_Notifications_UI") === "on";
+
   useEffect(() => {
     if (!navigator.onLine) {
       setOnline(false);
@@ -201,7 +203,12 @@ export function App({ bodyshop, checkUserSession, currentUser, online, setOnline
             path="/manage/*"
             element={
               <ErrorBoundary>
-                <SocketProvider bodyshop={bodyshop} navigate={navigate} currentUser={currentUser}>
+                <SocketProvider
+                  bodyshop={bodyshop}
+                  navigate={navigate}
+                  currentUser={currentUser}
+                  scenarioNotificationsOn={scenarioNotificationsOn}
+                >
                   <PrivateRoute isAuthorized={currentUser.authorized} />
                 </SocketProvider>
               </ErrorBoundary>
@@ -213,7 +220,12 @@ export function App({ bodyshop, checkUserSession, currentUser, online, setOnline
             path="/tech/*"
             element={
               <ErrorBoundary>
-                <SocketProvider bodyshop={bodyshop} navigate={navigate} currentUser={currentUser}>
+                <SocketProvider
+                  bodyshop={bodyshop}
+                  navigate={navigate}
+                  currentUser={currentUser}
+                  scenarioNotificationsOn={scenarioNotificationsOn}
+                >
                   <PrivateRoute isAuthorized={currentUser.authorized} />
                 </SocketProvider>
               </ErrorBoundary>

client/src/components/header/header.component.jsx

@@ -93,10 +93,11 @@ function Header({
   });
 
   const { t } = useTranslation();
-  const { isConnected } = useSocket();
+  const { isConnected, scenarioNotificationsOn } = useSocket();
   const [notificationVisible, setNotificationVisible] = useState(false);
 
   const userAssociationId = bodyshop?.associations?.[0]?.id;
+
   const {
     data: unreadData,
     refetch: refetchUnread,
@@ -105,7 +106,7 @@ function Header({
     variables: { associationid: userAssociationId },
     fetchPolicy: "network-only",
     pollInterval: isConnected ? 0 : day.duration(60, "seconds").asMilliseconds(),
-    skip: !userAssociationId
+    skip: !userAssociationId || !scenarioNotificationsOn
   });
 
   const unreadCount = unreadData?.notifications_aggregate?.aggregate?.count ?? 0;
@@ -647,20 +648,22 @@ function Header({
   ];
 
   // Notifications item (always on the right)
-  const notificationItem = [
-    {
-      key: "notifications",
-      id: "header-notifications",
-      icon: unreadLoading ? (
-        <Spin size="small" />
-      ) : (
-        <Badge count={unreadCount}>
-          <BellFilled />
-        </Badge>
-      ),
-      onClick: handleNotificationClick
-    }
-  ];
+  const notificationItem = scenarioNotificationsOn
+    ? [
+        {
+          key: "notifications",
+          id: "header-notifications",
+          icon: unreadLoading ? (
+            <Spin size="small" />
+          ) : (
+            <Badge count={unreadCount}>
+              <BellFilled />
+            </Badge>
+          ),
+          onClick: handleNotificationClick
+        }
+      ]
+    : [];
 
   return (
     <Layout.Header style={{ padding: 0, background: "#001529" }}>
@@ -688,17 +691,21 @@ function Header({
             background: "transparent"
           }}
         />
-        <Menu
-          mode="horizontal"
-          theme="dark"
-          selectedKeys={[selectedHeader]}
-          onClick={handleMenuClick}
-          subMenuCloseDelay={0.3}
-          items={notificationItem}
-          style={{ flex: "0 0 auto", minWidth: 0, borderBottom: "none", background: "transparent" }}
-        />
+        {scenarioNotificationsOn && (
+          <Menu
+            mode="horizontal"
+            theme="dark"
+            selectedKeys={[selectedHeader]}
+            onClick={handleMenuClick}
+            subMenuCloseDelay={0.3}
+            items={notificationItem}
+            style={{ flex: "0 0 auto", minWidth: 0, borderBottom: "none", background: "transparent" }}
+          />
+        )}
       </div>
-      <NotificationCenterContainer visible={notificationVisible} onClose={() => setNotificationVisible(false)} />
+      {scenarioNotificationsOn && (
+        <NotificationCenterContainer visible={notificationVisible} onClose={() => setNotificationVisible(false)} />
+      )}
     </Layout.Header>
   );
 }

client/src/components/profile-my/profile-my.component.jsx

@@ -9,6 +9,7 @@ import { logImEXEvent, updateCurrentPassword } from "../../firebase/firebase.uti
 import LayoutFormRow from "../layout-form-row/layout-form-row.component";
 import { useNotification } from "../../contexts/Notifications/notificationContext.jsx";
 import NotificationSettingsForm from "./notification-settings.component.jsx";
+import { useSocket } from "../../contexts/SocketIO/socketContext.jsx";
 
 const mapStateToProps = createStructuredSelector({
   currentUser: selectCurrentUser
@@ -22,6 +23,7 @@ export default connect(
 )(function ProfileMyComponent({ currentUser, updateUserDetails }) {
   const { t } = useTranslation();
   const notification = useNotification();
+  const { scenarioNotificationsOn } = useSocket();
 
   const handleFinish = (values) => {
     logImEXEvent("profile_update");
@@ -117,9 +119,11 @@ export default connect(
           </Card>
         </Form>
       </Col>
-      <Col span={24}>
-        <NotificationSettingsForm />
-      </Col>
+      {scenarioNotificationsOn && (
+        <Col span={24}>
+          <NotificationSettingsForm />
+        </Col>
+      )}
     </>
   );
 });

client/src/contexts/SocketIO/socketContext.jsx

@@ -17,7 +17,17 @@ const SocketContext = createContext(null);
 
 const INITIAL_NOTIFICATIONS = 10;
 
-const SocketProvider = ({ children, bodyshop, navigate, currentUser }) => {
+/**
+ * Socket Provider - Scenario Notifications / Web Socket related items.
+ * @param children
+ * @param bodyshop
+ * @param navigate
+ * @param currentUser
+ * @param scenarioNotificationsOn
+ * @returns {JSX.Element}
+ * @constructor
+ */
+const SocketProvider = ({ children, bodyshop, navigate, currentUser, scenarioNotificationsOn }) => {
   const socketRef = useRef(null);
   const [clientId, setClientId] = useState(null);
   const [isConnected, setIsConnected] = useState(false);
@@ -191,6 +201,11 @@ const SocketProvider = ({ children, bodyshop, navigate, currentUser }) => {
       };
 
       const handleNotification = (data) => {
+        // Scenario Notifications have been disabled, bail.
+        if (!scenarioNotificationsOn) {
+          return;
+        }
+
         const { jobId, jobRoNumber, notificationId, associationId, notifications } = data;
         if (associationId !== userAssociationId) return;
 
@@ -295,6 +310,11 @@ const SocketProvider = ({ children, bodyshop, navigate, currentUser }) => {
       };
 
       const handleSyncNotificationRead = ({ notificationId, timestamp }) => {
+        // Scenario Notifications have been disabled, bail.
+        if (!scenarioNotificationsOn) {
+          return;
+        }
+
         try {
           const notificationRef = client.cache.identify({
             __typename: "notifications",
@@ -336,6 +356,11 @@ const SocketProvider = ({ children, bodyshop, navigate, currentUser }) => {
       };
 
       const handleSyncAllNotificationsRead = ({ timestamp }) => {
+        // Scenario Notifications have been disabled, bail.
+        if (!scenarioNotificationsOn) {
+          return;
+        }
+
         try {
           const queryVars = {
             limit: INITIAL_NOTIFICATIONS,
@@ -436,7 +461,8 @@ const SocketProvider = ({ children, bodyshop, navigate, currentUser }) => {
         clientId,
         isConnected,
         markNotificationRead,
-        markAllNotificationsRead
+        markAllNotificationsRead,
+        scenarioNotificationsOn
       }}
     >
       {children}

client/src/pages/jobs-detail/jobs-detail.page.component.jsx

@@ -57,6 +57,7 @@ import dayjs from "../../utils/day";
 import UndefinedToNull from "../../utils/undefinedtonull";
 import { useNotification } from "../../contexts/Notifications/notificationContext.jsx";
 import JobWatcherToggle from "./job-watcher-toggle.component.jsx";
+import { useSocket } from "../../contexts/SocketIO/socketContext.jsx";
 
 const mapStateToProps = createStructuredSelector({
   bodyshop: selectBodyshop,
@@ -103,6 +104,7 @@ export function JobsDetailPage({
     nextFetchPolicy: "network-only"
   });
   const notification = useNotification();
+  const { scenarioNotificationsOn } = useSocket();
 
   useEffect(() => {
     //form.setFieldsValue(transormJobToForm(job));
@@ -323,7 +325,7 @@ export function JobsDetailPage({
 
           title={
             <Space>
-              <JobWatcherToggle job={job} />
+              {scenarioNotificationsOn && <JobWatcherToggle job={job} />}
               {job.ro_number || t("general.labels.na")}
             </Space>
           }