mcgill-a

io.on("connection", async (socket: Socket) => {
    socket.on("position", (user: string) => {
        userService.position(JSON.parse(user) as User)
    });
});

userService.change.subscribe((change: UserChange) => {
    io.sockets.emit(SocketChannel.user, JSON.stringify(change))
});

mcgill-a

// when a user connects to the WebSocket server
io.on("connection", async (socket: Socket) => {
    
    // listen for users with new location data
    socket.on("position", (user: string) => {
        // update our reference of the user and trigger a change event
        userService.position(JSON.parse(user) as User);
    });
    
    // listen for those change events

mcgill-a

// https://github.com/capacitor-community/background-geolocation
this.BackgroundGeolocation.addWatcher(
    {
        requestPermissions: true,
        stale: false,
        distanceFilter: 10
    },
    (current, error) => {
        if (!current || error) return;
        const { latitude, longitude, time } = current;

mcgill-a

@Injectable({ providedIn: 'root' })
constructor(private socketService: SocketService) {
    this.subs.add(
        this.socketService.userChange.subscribe((change: UserChange) => {
            const {user, action} = change;

            switch (change.action) {
                case UserAction.join:
                case TeamAction.position:
                    this._users.set(user.email, user);

mcgill-a

@Injectable({ providedIn: 'root' })
export class SocketService {
    
    constructor(private socket: Socket) {}
    
    public readonly userChange = this.socket
        .fromEvent<string>(SocketChannel.user)
        .pipe(map((x) => JSON.parse(x) as UserChange));
}

mcgill-a

export class UserService {
    private _change = new Subject<UserChange>();
    private _users = new Map<string, User>();

    public readonly change = this._change.asObservable();
    
    public get users(): User[] {
        return Array.from(this._users.values());
    }

mcgill-a

userService.change.subscribe((change) =>
    io.sockets.emit(SocketChannel.user, JSON.stringify(change))
);

app.post("/users/join", (req, res) => {
    try {
        res.json(userService.join(<User>req.body));
    } catch (error) {
        res.status(400).send(error);
    }

mcgill-a

import sys, csv, requests, io, re, argparse, os
from tqdm import tqdm
from pathlib import Path


def load_data(filename):
    arr = []
    with open(filename, 'r', encoding='UTF-8') as file:
        reader = csv.reader(file)
        for row in reader:

mcgill-a

import sys
import csv
import argparse
import re
import io
import os
import os.path
from tqdm import tqdm
from pathlib import Path
from pdfminer.converter import TextConverter

mcgill-a

import sys, csv, requests, zipfile, io, re
from tqdm import tqdm
from pathlib import Path


def load_data(filename):
    arr = []
    with open(filename, 'r', encoding='UTF-8') as file:
        reader = csv.reader(file)
        for row in reader: