Prepare OnCall for Unified Slack App

engine/apps/chatops_proxy/urls.py

@@ -0,0 +1,7 @@
+from common.api_helpers.optional_slash_router import optional_slash_path
+
+from .views import ReceiveBroadcast
+
+urlpatterns = [
+    optional_slash_path("broadcast", ReceiveBroadcast.as_view()),
+]

engine/apps/chatops_proxy/views.py

@@ -0,0 +1,8 @@
+from rest_framework.response import Response
+from rest_framework.views import APIView
+
+
+class ReceiveBroadcast(APIView):
+    def post(self, request):
+        print(request.data)
+        return Response(status=200)

engine/apps/slack/oauth.py

@@ -0,0 +1,19 @@
+from django.conf import settings
+from django.shortcuts import redirect
+from rest_framework.response import Response
+from rest_framework.views import APIView
+
+from common.oncall_gateway.client import ChatopsProxyAPIClient
+
+
+class OauthStartView(APIView):
+    def get(self, request):
+        client = ChatopsProxyAPIClient(settings.ONCALL_GATEWAY_URL, settings.ONCALL_GATEWAY_API_TOKEN)
+
+        try:
+            link, _ = client.get_slack_oauth_link(
+                request.auth.organization.stack_id, request.auth.user.user_id, request.auth.organization.web_link
+            )
+            return redirect(link)
+        except Exception as e:
+            return Response({"error": str(e)}, status=500)

engine/apps/social_auth/backends.py

@@ -91,7 +91,10 @@ class SlackOAuth2V2(SlackOAuth2):
 
     @handle_http_errors
     def auth_complete(self, *args, **kwargs):
-        """Completes login process, must return user instance"""
+        """
+        Override original method to include auth token in redirect uri and adjust response shape to slack Oauth2.0 V2.
+        Access token is in the ["authed_user"]["access_token"] field, not in the root of the response.
+        """
         self.process_error(self.data)
         state = self.validate_state()
         # add auth token to redirect uri, because it must be the same in all slack auth requests
@@ -113,6 +116,7 @@ def auth_complete(self, *args, **kwargs):
             method=self.ACCESS_TOKEN_METHOD,
         )
         self.process_error(response)
+        # Take access token from the authed_user field, not from the root
         access_token = response["authed_user"]["access_token"]
         kwargs.update(response=response)
         return self.do_auth(access_token, *args, **kwargs)

engine/common/oncall_gateway/client.py

@@ -131,6 +131,15 @@ def unlink_slack_team(
         self._check_response(response)
         return response.json()["removed"], response
 
+    def get_slack_oauth_link(
+        self, stack_id: int, grafana_user_id: int, app_redirect: str
+    ) -> tuple[str, requests.models.Response]:
+        url = f"{self.api_base_url}/api/v3/oauth2/start"
+        d = {"stack_id": stack_id, "grafana_user_id": grafana_user_id, "app_redirect": app_redirect}
+        response = requests.post(url=url, json=d, headers=self._headers)
+        self._check_response(response)
+        return response.json()["install_link"], response
+
     def _check_response(self, response: requests.models.Response):
         """
         Wraps an exceptional response to ChatopsProxyAPIException

engine/engine/urls.py

@@ -88,3 +88,8 @@
         path("internal/schema/", SpectacularYAMLAPIView.as_view(api_version="internal/v1"), name="schema"),
         path("internal/schema/swagger-ui/", SpectacularSwaggerView.as_view(url_name="schema"), name="swagger-ui"),
     ]
+
+if settings.FEATURE_MULTIREGION_ENABLED:
+    urlpatterns += [
+        path("api/chatops/", include("apps.chatops_proxy.urls")),
+    ]

engine/settings/base.py

@@ -281,6 +281,7 @@ class DatabaseTypes:
     "apps.phone_notifications",
     "drf_spectacular",
     "apps.google",
+    "apps.chatops_proxy",
 ]
 
 REST_FRAMEWORK = {