From 9e68be72255bbb0ac1e52bdfe2f63c957ff6d022 Mon Sep 17 00:00:00 2001
From: Darren Clarke <darren@redaranj.com>
Date: Fri, 8 Sep 2023 16:34:13 +0200
Subject: [PATCH] Whatsapp send and Zammad autologin fixes

---
 .../app/(login)/login/_components/Login.tsx   |   4 +-
 apps/link/app/(main)/_components/Home.tsx     |   2 +-
 .../app/(main)/_components/ZammadWrapper.tsx  | 158 ++++++++++++------
 apps/link/middleware.ts                       |   9 +-
 docker/zammad/Dockerfile                      |  22 +--
 package.json                                  |   2 +-
 .../app/models/channel/driver/cdr_whatsapp.rb |   8 +-
 .../enqueue_communicate_cdr_signal_job.rb     |   1 +
 .../enqueue_communicate_cdr_whatsapp_job.rb   |   3 +-
 .../src/config/initializers/cdr_signal.rb     |   7 +-
 .../src/config/initializers/cdr_whatsapp.rb   |   7 +-
 .../src/lib/cdr_signal.rb                     |   4 +-
 .../src/lib/cdr_signal_api.rb                 |  13 +-
 .../src/lib/cdr_whatsapp.rb                   |   4 +-
 .../src/lib/cdr_whatsapp_api.rb               |   9 +-
 15 files changed, 153 insertions(+), 100 deletions(-)

diff --git a/apps/link/app/(login)/login/_components/Login.tsx b/apps/link/app/(login)/login/_components/Login.tsx
index bfbe6b2..16331e3 100644
--- a/apps/link/app/(login)/login/_components/Login.tsx
+++ b/apps/link/app/(login)/login/_components/Login.tsx
@@ -146,7 +146,7 @@ export const Login: FC<LoginProps> = ({ session }) => {
                       sx={buttonStyles}
                       onClick={() =>
                         signIn("google", {
-                          callbackUrl: `${origin}/setup`,
+                          callbackUrl: `${origin}`,
                         })
                       }
                     >
@@ -160,7 +160,7 @@ export const Login: FC<LoginProps> = ({ session }) => {
                       sx={buttonStyles}
                       onClick={() =>
                         signIn("apple", {
-                          callbackUrl: `${window.location.origin}/setup`,
+                          callbackUrl: `${window.location.origin}`,
                         })
                       }
                     >
diff --git a/apps/link/app/(main)/_components/Home.tsx b/apps/link/app/(main)/_components/Home.tsx
index 082069e..3196091 100644
--- a/apps/link/app/(main)/_components/Home.tsx
+++ b/apps/link/app/(main)/_components/Home.tsx
@@ -3,4 +3,4 @@
 import { FC } from "react";
 import { ZammadWrapper } from "./ZammadWrapper";
 
-export const Home: FC = () => <ZammadWrapper path="/#dashboard" hideSidebar />;
+export const Home: FC = () => <ZammadWrapper path="#dashboard" hideSidebar />;
diff --git a/apps/link/app/(main)/_components/ZammadWrapper.tsx b/apps/link/app/(main)/_components/ZammadWrapper.tsx
index 2515ae9..43892e7 100644
--- a/apps/link/app/(main)/_components/ZammadWrapper.tsx
+++ b/apps/link/app/(main)/_components/ZammadWrapper.tsx
@@ -1,8 +1,10 @@
 "use client";
 
-import { FC, useState } from "react";
+import { FC, useState, useEffect } from "react";
 import { useRouter } from "next/navigation";
 import Iframe from "react-iframe";
+import { useSession } from "next-auth/react";
+import { Box, Grid, CircularProgress } from "@mui/material";
 
 type ZammadWrapperProps = {
   path: string;
@@ -14,69 +16,117 @@ export const ZammadWrapper: FC<ZammadWrapperProps> = ({
   hideSidebar = true,
 }) => {
   const router = useRouter();
+  const { data: session } = useSession();
+  const [authenticated, setAuthenticated] = useState(false);
   const [display, setDisplay] = useState("none");
   const url = `/zammad${path}`;
+  const id = url.replace(/[^a-zA-Z0-9]/g, "");
 
-  return (
-    // @ts-ignore
-    <Iframe
-      id="zammad"
-      url={url}
-      width="100%"
-      height="100%"
-      frameBorder={0}
-      styles={{ display }}
-      onLoad={() => {
-        const linkElement = document.querySelector("iframe");
-        if (
-          linkElement.contentDocument &&
-          linkElement.contentDocument?.querySelector &&
-          linkElement.contentDocument.querySelector("#navigation") &&
-          linkElement.contentDocument.querySelector("body")
-        ) {
-          // @ts-ignore
-          linkElement.contentDocument.querySelector("#navigation").style =
-            "display: none";
-          // @ts-ignore
-          linkElement.contentDocument.querySelector("body").style =
-            "font-family: Arial";
+  useEffect(() => {
+    const checkAuthenticated = async () => {
+      const res = await fetch("/zammad/auth/sso", {
+        method: "GET",
+        redirect: "manual",
+      });
 
+      if (res.type === "opaqueredirect") {
+        setAuthenticated(true);
+      } else {
+        setAuthenticated(false);
+      }
+    };
+
+    checkAuthenticated();
+  }, [path]);
+
+  if (!session) {
+    console.log("No session");
+    return (
+      <Box sx={{ width: "100%" }}>
+        <Grid
+          container
+          direction="column"
+          sx={{ height: 500 }}
+          justifyContent="center"
+          alignContent="center"
+          alignItems="center"
+        >
+          <Grid item>
+            <CircularProgress size={80} color="success" />
+          </Grid>
+        </Grid>
+      </Box>
+    );
+  }
+
+  if (session && authenticated) {
+    console.log("Session and authenticated");
+    return (
+      <Iframe
+        id={id}
+        url={url}
+        width="100%"
+        height="100%"
+        frameBorder={0}
+        styles={{ display }}
+        onLoad={() => {
+          const linkElement = document.querySelector(
+            `#${id}`,
+          ) as HTMLIFrameElement;
+
+          console.log({ path });
+          console.log({ id });
+          console.log({ linkElement });
           if (
-            hideSidebar &&
-            linkElement.contentDocument.querySelector(".sidebar")
+            linkElement.contentDocument &&
+            linkElement.contentDocument?.querySelector &&
+            linkElement.contentDocument.querySelector("#navigation") &&
+            linkElement.contentDocument.querySelector("body")
           ) {
             // @ts-ignore
-            linkElement.contentDocument.querySelector(".sidebar").style =
+            linkElement.contentDocument.querySelector("#navigation").style =
               "display: none";
-          }
-
-          // @ts-ignore
-          if (linkElement.contentDocument.querySelector(".overview-header")) {
             // @ts-ignore
-            (
-              linkElement.contentDocument.querySelector(
-                ".overview-header",
-              ) as any
-            ).style = "display: none";
-          }
+            linkElement.contentDocument.querySelector("body").style =
+              "font-family: Arial";
 
-          setDisplay("inherit");
+            if (
+              hideSidebar &&
+              linkElement.contentDocument.querySelector(".sidebar")
+            ) {
+              // @ts-ignore
+              linkElement.contentDocument.querySelector(".sidebar").style =
+                "display: none";
+            }
 
-          if (linkElement.contentWindow) {
-            linkElement.contentWindow.addEventListener("hashchange", () => {
-              const hash = linkElement.contentWindow?.location?.hash ?? "";
-              if (hash.startsWith("#ticket/zoom/")) {
-                setDisplay("none");
-                const ticketID = hash.split("/").pop();
-                router.push(`/tickets/${ticketID}`);
-                setTimeout(() => {
-                  setDisplay("inherit");
-                }, 1000);
-              }
-            });
+            // @ts-ignore
+            if (linkElement.contentDocument.querySelector(".overview-header")) {
+              // @ts-ignore
+              (
+                linkElement.contentDocument.querySelector(
+                  ".overview-header",
+                ) as any
+              ).style = "display: none";
+            }
+
+            setDisplay("inherit");
+
+            if (linkElement.contentWindow) {
+              linkElement.contentWindow.addEventListener("hashchange", () => {
+                const hash = linkElement.contentWindow?.location?.hash ?? "";
+                if (hash.startsWith("#ticket/zoom/")) {
+                  setDisplay("none");
+                  const ticketID = hash.split("/").pop();
+                  router.push(`/tickets/${ticketID}`);
+                  setTimeout(() => {
+                    setDisplay("inherit");
+                  }, 1000);
+                }
+              });
+            }
           }
-        }
-      }}
-    />
-  );
+        }}
+      />
+    );
+  }
 };
diff --git a/apps/link/middleware.ts b/apps/link/middleware.ts
index b1bdb4f..0f40ec9 100644
--- a/apps/link/middleware.ts
+++ b/apps/link/middleware.ts
@@ -22,20 +22,21 @@ const checkRewrites = async (request: NextRequestWithAuth) => {
   const metamigoURL = process.env.METAMIGO_URL ?? "http://metamigo-api:3000";
   const labelStudioURL = process.env.LABEL_STUDIO_URL ?? "http://label-studio:8080";
   const { token } = request.nextauth;
+  const headers = { 'X-Forwarded-User': token?.email?.toLowerCase() };
 
+  console.log(request.nextUrl);
   if (request.nextUrl.pathname.startsWith('/metamigo')) {
     return rewriteURL(request, `${linkBaseURL}/metamigo`, metamigoURL);
   } else if (request.nextUrl.pathname.startsWith('/label-studio')) {
     return rewriteURL(request, `${linkBaseURL}/label-studio`, labelStudioURL);
   } else if (request.nextUrl.pathname.startsWith('/zammad')) {
-    return rewriteURL(request, `${linkBaseURL}/zammad`, zammadURL);
+    return rewriteURL(request, `${linkBaseURL}/zammad`, zammadURL, headers);
   } else if (request.nextUrl.pathname.startsWith('/auth/sso') || request.nextUrl.pathname.startsWith('/assets')) {
-    const headers = { 'X-Forwarded-User': token.email.toLowerCase() };
     return rewriteURL(request, linkBaseURL, zammadURL, headers);
   } else if (request.nextUrl.pathname.startsWith('/proxy/api') || request.nextUrl.pathname.startsWith('/proxy/assets')) {
     return rewriteURL(request, `${linkBaseURL}/proxy`, zammadURL);
   } else if (request.nextUrl.pathname.startsWith('/api/v1') || request.nextUrl.pathname.startsWith('/auth/sso')) {
-    return rewriteURL(request, linkBaseURL, zammadURL);
+    return rewriteURL(request, linkBaseURL, zammadURL, headers);
   }
 
   return NextResponse.next();
@@ -75,7 +76,7 @@ export default withAuth(
 
 export const config = {
   matcher: [
-    '/((?!ws|_next/static|_next/image|favicon.ico).*)',
+    '/((?!ws|wss|_next/static|_next/image|favicon.ico).*)',
   ],
 };
 
diff --git a/docker/zammad/Dockerfile b/docker/zammad/Dockerfile
index 434879f..748291d 100644
--- a/docker/zammad/Dockerfile
+++ b/docker/zammad/Dockerfile
@@ -10,17 +10,17 @@ USER root
 RUN set -ex; \
   apt-get update; \
   apt-get install -y --no-install-recommends nodejs git libclang-dev clang llvm pkg-config nettle-dev;
-RUN curl --proto '=https' --tlsv1.2 -sSf https://sh.rustup.rs | sh -s -- -y
-ARG SEQUOIA_PROJECT_URL=https://gitlab.com/sequoia-pgp/sequoia-ffi.git
-ARG SEQUOIA_GIT_TAG=main
-ENV SEQUOIA_DIR=/usr/lib/sequoia
-ENV LD_LIBRARY_PATH=${SEQUOIA_DIR}/target/debug
-RUN git clone -b "${SEQUOIA_GIT_TAG}" --single-branch --depth 1 "${SEQUOIA_PROJECT_URL}" "${SEQUOIA_DIR}";
-WORKDIR ${SEQUOIA_DIR}
-RUN export PATH=~/.cargo/bin:$PATH && cargo build -p sequoia-openpgp-ffi;
+# RUN curl --proto '=https' --tlsv1.2 -sSf https://sh.rustup.rs | sh -s -- -y
+# ARG SEQUOIA_PROJECT_URL=https://gitlab.com/sequoia-pgp/sequoia-ffi.git
+# ARG SEQUOIA_GIT_TAG=main
+# ENV SEQUOIA_DIR=/usr/lib/sequoia
+# ENV LD_LIBRARY_PATH=${SEQUOIA_DIR}/target/debug
+# RUN git clone -b "${SEQUOIA_GIT_TAG}" --single-branch --depth 1 "${SEQUOIA_PROJECT_URL}" "${SEQUOIA_DIR}";
+# WORKDIR ${SEQUOIA_DIR}
+# RUN export PATH=~/.cargo/bin:$PATH && cargo build -p sequoia-openpgp-ffi;
 
 WORKDIR ${ZAMMAD_DIR}
-RUN  echo "gem 'ruby_openpgp', git: 'https://github.com/throneless-tech/ruby_openpgp', branch: 'signing-and-userids'" >> Gemfile.local
+# RUN  echo "gem 'ruby_openpgp', git: 'https://github.com/throneless-tech/ruby_openpgp', branch: 'signing-and-userids'" >> Gemfile.local
 RUN bundle install --without test development mysql
 RUN sed -i '/^[[:space:]]*# create install ready file/ i\
   echo "about to reinstall..."\n\
@@ -34,8 +34,8 @@ FROM node:16.18.0-slim as node
 
 FROM zammad/zammad-docker-compose:${ZAMMAD_VERSION}
 USER ${ZAMMAD_USER}
-ENV SEQUOIA_DIR=/usr/lib/sequoia
-ENV LD_LIBRARY_PATH=${SEQUOIA_DIR}/target/debug
+# ENV SEQUOIA_DIR=/usr/lib/sequoia
+# ENV LD_LIBRARY_PATH=${SEQUOIA_DIR}/target/debug
 ENV ZAMMAD_READY_FILE=${ZAMMAD_DIR}/var/zammad.ready
 COPY --from=node /opt /opt
 COPY --from=node /usr/local/bin /usr/local/bin
diff --git a/package.json b/package.json
index fb8dc41..70c28b0 100644
--- a/package.json
+++ b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "link-stack",
-  "version": "2.0.0b2",
+  "version": "2.0.0b3",
   "description": "",
   "main": "index.js",
   "scripts": {
diff --git a/packages/zammad-addon-metamigo/src/app/models/channel/driver/cdr_whatsapp.rb b/packages/zammad-addon-metamigo/src/app/models/channel/driver/cdr_whatsapp.rb
index 7462eb3..d97d0ae 100644
--- a/packages/zammad-addon-metamigo/src/app/models/channel/driver/cdr_whatsapp.rb
+++ b/packages/zammad-addon-metamigo/src/app/models/channel/driver/cdr_whatsapp.rb
@@ -1,8 +1,6 @@
 # frozen_string_literal: true
 
-class Channel
-  class Driver
-    class CdrWhatsapp
+class Channel::Driver::CdrWhatsapp
       def fetchable?(_channel)
         false
       end
@@ -24,7 +22,7 @@ class Channel
       #
 
       def send(options, article, _notification = false)
-        # return if we run import mode
+        # return if we run import mode   
         return if Setting.get('import_mode')
 
         options = check_external_credential(options)
@@ -50,6 +48,4 @@ class Channel
         end
         options
       end
-    end
-  end
 end
diff --git a/packages/zammad-addon-metamigo/src/app/models/ticket/article/enqueue_communicate_cdr_signal_job.rb b/packages/zammad-addon-metamigo/src/app/models/ticket/article/enqueue_communicate_cdr_signal_job.rb
index 52813e2..1a8d4fa 100644
--- a/packages/zammad-addon-metamigo/src/app/models/ticket/article/enqueue_communicate_cdr_signal_job.rb
+++ b/packages/zammad-addon-metamigo/src/app/models/ticket/article/enqueue_communicate_cdr_signal_job.rb
@@ -29,3 +29,4 @@ module Ticket::Article::EnqueueCommunicateCdrSignalJob
     CommunicateCdrSignalJob.perform_later(id)
   end
 end
+
diff --git a/packages/zammad-addon-metamigo/src/app/models/ticket/article/enqueue_communicate_cdr_whatsapp_job.rb b/packages/zammad-addon-metamigo/src/app/models/ticket/article/enqueue_communicate_cdr_whatsapp_job.rb
index ee32a86..304c2c5 100644
--- a/packages/zammad-addon-metamigo/src/app/models/ticket/article/enqueue_communicate_cdr_whatsapp_job.rb
+++ b/packages/zammad-addon-metamigo/src/app/models/ticket/article/enqueue_communicate_cdr_whatsapp_job.rb
@@ -24,8 +24,9 @@ module Ticket::Article::EnqueueCommunicateCdrWhatsappJob
     return true unless type_id
 
     type = Ticket::Article::Type.lookup(id: type_id)
-    return true unless type.name.match?(/\Acdr_whatspp/i)
+    return true unless type.name.match?(/\Acdr_whatsapp/i)
 
     CommunicateCdrWhatsappJob.perform_later(id)
   end
 end
+
diff --git a/packages/zammad-addon-metamigo/src/config/initializers/cdr_signal.rb b/packages/zammad-addon-metamigo/src/config/initializers/cdr_signal.rb
index 4519fa5..f00feca 100644
--- a/packages/zammad-addon-metamigo/src/config/initializers/cdr_signal.rb
+++ b/packages/zammad-addon-metamigo/src/config/initializers/cdr_signal.rb
@@ -1,7 +1,9 @@
 # frozen_string_literal: true
 
-Rails.application.config.after_initialize do
-  # Ticket::Article.add_observer Observer::Ticket::Article::CommunicateCdrSignal.instance
+Rails.application.config.after_initialize do  
+  class Ticket::Article
+    include Ticket::Article::EnqueueCommunicateCdrSignalJob
+  end
 
   icon = File.read('public/assets/images/icons/cdr_signal.svg')
   doc = File.open('public/assets/images/icons.svg') { |f| Nokogiri::XML(f) }
@@ -13,3 +15,4 @@ Rails.application.config.after_initialize do
   end
   File.write('public/assets/images/icons.svg', doc.to_xml)
 end
+ 
\ No newline at end of file
diff --git a/packages/zammad-addon-metamigo/src/config/initializers/cdr_whatsapp.rb b/packages/zammad-addon-metamigo/src/config/initializers/cdr_whatsapp.rb
index f1480e6..ece32dc 100644
--- a/packages/zammad-addon-metamigo/src/config/initializers/cdr_whatsapp.rb
+++ b/packages/zammad-addon-metamigo/src/config/initializers/cdr_whatsapp.rb
@@ -1,8 +1,11 @@
 # frozen_string_literal: true
 
 Rails.application.config.after_initialize do
-  # Ticket::Article.add_observer Observer::Ticket::Article::CommunicateCdrWhatsapp.instance
-
+    
+  class Ticket::Article
+    include Ticket::Article::EnqueueCommunicateCdrWhatsappJob
+  end
+  
   icon = File.read('public/assets/images/icons/cdr_whatsapp.svg')
   doc = File.open('public/assets/images/icons.svg') { |f| Nokogiri::XML(f) }
   if !doc.at_css('#icon-cdr-whatsapp')
diff --git a/packages/zammad-addon-metamigo/src/lib/cdr_signal.rb b/packages/zammad-addon-metamigo/src/lib/cdr_signal.rb
index 4484efe..82247b3 100644
--- a/packages/zammad-addon-metamigo/src/lib/cdr_signal.rb
+++ b/packages/zammad-addon-metamigo/src/lib/cdr_signal.rb
@@ -12,7 +12,7 @@ class CdrSignal
   #
 
   def self.check_token(api_url, token)
-    api = CdrSignalAPI.new(api_url, token)
+    api = CdrSignalApi.new(api_url, token)
     begin
       bot = api.fetch_self
     rescue StandardError => e
@@ -128,7 +128,7 @@ class CdrSignal
   def initialize(api_url, token)
     @token = token
     @api_url = api_url
-    @api = CdrSignalAPI.new(api_url, token)
+    @api = CdrSignalApi.new(api_url, token)
   end
 
   #
diff --git a/packages/zammad-addon-metamigo/src/lib/cdr_signal_api.rb b/packages/zammad-addon-metamigo/src/lib/cdr_signal_api.rb
index cc6935b..e800cff 100644
--- a/packages/zammad-addon-metamigo/src/lib/cdr_signal_api.rb
+++ b/packages/zammad-addon-metamigo/src/lib/cdr_signal_api.rb
@@ -4,13 +4,12 @@ require 'json'
 require 'net/http'
 require 'net/https'
 require 'uri'
-require 'rest-client'
 
-class CdrSignalAPI
+class CdrSignalApi
   def initialize(api_url, token)
     @token = token
     @last_update = 0
-    @api = api_url
+    @api_url = api_url
   end
 
   def parse_hash(hash)
@@ -22,13 +21,13 @@ class CdrSignalAPI
   end
 
   def get(api)
-    url = "#{@api}/bots/#{@token}/#{api}"
-    JSON.parse(RestClient.get(url, { accept: :json }).body)
+    url = "#{@api_url}/bots/#{@token}/#{api}"
+    JSON.parse(Faraday.get(url, { Accept: "application/json" }).body)
   end
 
   def post(api, params = {})
-    url = "#{@api}/bots/#{@token}/#{api}"
-    JSON.parse(RestClient.post(url, params, { accept: :json }).body)
+    url = "#{@api_url}/bots/#{@token}/#{api}"
+    JSON.parse(Faraday.post(url, params.to_json, { "Content-Type": "application/json", Accept: "application/json" }).body)
   end
 
   def fetch_self
diff --git a/packages/zammad-addon-metamigo/src/lib/cdr_whatsapp.rb b/packages/zammad-addon-metamigo/src/lib/cdr_whatsapp.rb
index dc81e92..83a5d15 100644
--- a/packages/zammad-addon-metamigo/src/lib/cdr_whatsapp.rb
+++ b/packages/zammad-addon-metamigo/src/lib/cdr_whatsapp.rb
@@ -12,7 +12,7 @@ class CdrWhatsapp
   #
 
   def self.check_token(api_url, token)
-    api = CdrWhatsappAPI.new(api_url, token)
+    api = CdrWhatsappApi.new(api_url, token)
     begin
       bot = api.fetch_self
     rescue StandardError => e
@@ -128,7 +128,7 @@ class CdrWhatsapp
   def initialize(api_url, token)
     @token = token
     @api_url = api_url
-    @api = CdrWhatsappAPI.new(api_url, token)
+    @api = CdrWhatsappApi.new(api_url, token)
   end
 
   #
diff --git a/packages/zammad-addon-metamigo/src/lib/cdr_whatsapp_api.rb b/packages/zammad-addon-metamigo/src/lib/cdr_whatsapp_api.rb
index 2ea0c7f..19aab61 100644
--- a/packages/zammad-addon-metamigo/src/lib/cdr_whatsapp_api.rb
+++ b/packages/zammad-addon-metamigo/src/lib/cdr_whatsapp_api.rb
@@ -4,9 +4,8 @@ require 'json'
 require 'net/http'
 require 'net/https'
 require 'uri'
-require 'rest-client'
 
-class CdrWhatsappAPI
+class CdrWhatsappApi
   def initialize(api_url, token)
     @token = token
     @last_update = 0
@@ -20,15 +19,15 @@ class CdrWhatsappAPI
     end
     ret
   end
-
+  
   def get(api)
     url = "#{@api_url}/bots/#{@token}/#{api}"
-    JSON.parse(RestClient.get(url, { accept: :json }).body)
+    JSON.parse(Faraday.get(url, { Accept: "application/json" }).body)
   end
 
   def post(api, params = {})
     url = "#{@api_url}/bots/#{@token}/#{api}"
-    JSON.parse(RestClient.post(url, params, { accept: :json }).body)
+    JSON.parse(Faraday.post(url, params.to_json, { "Content-Type": "application/json", Accept: "application/json" }).body)
   end
 
   def fetch_self