v1.2.0-beta/fix file structure

2020-05-21 10:48:37 -04:00
parent c5dc4d756f
commit 9e61fe15ef
38 changed files with 19531 additions and 0 deletions
@@ -0,0 +1,131 @@
+/* global chrome */
+/*global firebase*/
+
+const firebaseConfig = {
+  apiKey: 'AIzaSyCJLuYpzXLDRmu2ttzFuSGmYcpFxqToWFU',
+  authDomain: 'watch-party-crx.firebaseapp.com',
+  databaseURL: 'https://watch-party-crx.firebaseio.com',
+  projectId: 'watch-party-crx',
+  storageBucket: 'watch-party-crx.appspot.com',
+  messagingSenderId: '712242707190',
+  appId: '1:712242707190:web:65fa7f772e30da364b0ad7',
+  measurementId: 'G-EZS4PEVG4T',
+};
+
+firebase.initializeApp(firebaseConfig);
+firebase.auth().setPersistence(firebase.auth.Auth.Persistence.LOCAL);
+
+const isAuthed = () => true && firebase.auth().currentUser;
+const doAuth = () => firebase.auth().signInAnonymously();
+
+const fetcher = async (request, sendResponse) => {
+  if (!isAuthed()) await doAuth();
+  const { url, method } = request;
+  delete request.type;
+  delete request.url;
+  delete request.method;
+  const idToken = await firebase.auth().currentUser.getIdToken();
+  let resStatus = {};
+  fetch(url, {
+    method,
+    headers: {
+      Authorization: `Token ${idToken}:${firebase.auth().currentUser.uid}`,
+      'Access-Control-Allow-Origin': '*',
+    },
+    ...request,
+  })
+    .then((res) => {
+      resStatus = {
+        status: res.status,
+        statusText: res.statusText,
+      };
+      return res.json();
+    })
+    .then((res) => sendResponse({ ...res, ...resStatus }))
+    .catch((err) => sendResponse({ ...err, status: 503, statusText: "Couldn't talk to server" }));
+};
+
+const sendAuth = async (sendResponse) => {
+  if (!isAuthed()) await doAuth();
+  sendResponse(firebase.auth().currentUser);
+};
+
+chrome.runtime.onMessage.addListener((request, sender, sendResponse) => {
+  const { type } = request;
+  switch (type) {
+    case 'API_CALL':
+      fetcher(request, sendResponse);
+      break;
+    case 'GET_AUTH':
+      sendAuth(sendResponse);
+      break;
+    default:
+      console.warn('Unknown message type: <', type, '>');
+      break;
+  }
+  return true;
+});
+
+chrome.runtime.onConnect.addListener((port) => {
+  port.onDisconnect.addListener(() => {
+    port.roomListener && port.roomListener();
+    port.userListener && port.userListener();
+    port.messageListener && port.messageListener();
+  });
+  port.onMessage.addListener((request) => {
+    const { type, roomId } = request;
+    if (type === 'INIT') {
+      port.roomListener = firebase
+        .firestore()
+        .collection('rooms')
+        .doc(roomId)
+        .onSnapshot(
+          (snap) => {
+            if (snap) {
+              port.postMessage(snap.data());
+            }
+          },
+          (err) => {
+            port.postMessage({ isError: true, ...err });
+          }
+        );
+      port.userListener = firebase
+        .firestore()
+        .collection('rooms')
+        .doc(roomId)
+        .collection('users')
+        .onSnapshot(
+          (snap) => {
+            if (snap) {
+              const isAdmin = snap.docs
+                .filter((user) => user.id === firebase.auth().currentUser.uid)[0]
+                .data().admin;
+              port.postMessage({ admin: isAdmin });
+            }
+          },
+          (err) => {
+            port.postMessage({ isError: true, ...err });
+          }
+        );
+      port.messageListener = firebase
+        .firestore()
+        .collection('rooms')
+        .doc(roomId)
+        .collection('messages')
+        .orderBy('time')
+        .onSnapshot(
+          (snap) => {
+            if (snap) {
+              let messages = snap.docs.map((v) => ({ ...v.data(), id: v.id }));
+              port.postMessage({
+                messages,
+              });
+            }
+          },
+          (err) => {
+            port.postMessage({ isError: true, ...err });
+          }
+        );
+    }
+  });
+});