merged luke's branch into mine, he fixed all the fetches to catch stuff, need to test

This commit is contained in:
Me
2023-01-16 19:23:32 +01:00
23 changed files with 677 additions and 665 deletions

3
package-lock.json generated
View File

@@ -1,3 +0,0 @@
{
"lockfileVersion": 1
}

View File

@@ -52,8 +52,22 @@ export class ChatController {
let fields = ["name", "type", "users", "protection", "allowed_users"]; let fields = ["name", "type", "users", "protection", "allowed_users"];
const rooms = await this.chatService.getMyRooms(req.user.username, fields); const rooms = await this.chatService.getMyRooms(req.user.username, fields);
const blocked = await this.chatService.getListBlockUser(req.user.username);
const ret_rooms = rooms.map(room => let filtered_rooms = rooms.filter(room =>
{
if (room.type === 'direct')
{
let roomname = room.users[0];
if (roomname === req.user.username)
roomname = room.users[1];
if (blocked.includes(roomname))
return false;
}
return true;
});
const ret_rooms = filtered_rooms.map(room =>
{ {
let new_room = this.format_room(room); let new_room = this.format_room(room);
if (room.protection) if (room.protection)
@@ -78,8 +92,19 @@ export class ChatController {
printCaller("- in "); printCaller("- in ");
const rooms: roomDto[] = await this.chatService.getAllOtherRoomsAndUsers(req.user.username) const rooms: roomDto[] = await this.chatService.getAllOtherRoomsAndUsers(req.user.username)
const blocked = await this.chatService.getListBlockUser(req.user.username);
const ret_rooms = rooms.map(room => this.format_room(room)); let filtered_rooms = rooms.filter(room =>
{
if (room.type === 'user')
{
if (blocked.includes(room.name))
return false;
}
return true;
});
const ret_rooms = filtered_rooms.map(room => this.format_room(room));
res.status(HttpStatus.OK).json({ rooms: ret_rooms }); res.status(HttpStatus.OK).json({ rooms: ret_rooms });
printCaller("- out "); printCaller("- out ");
} }
@@ -200,6 +225,19 @@ export class ChatController {
let response = ""; let response = "";
if (room.type === 'user') if (room.type === 'user')
{ {
const blocked = await this.chatService.getListBlockUser(req.user.username);
if (blocked.includes(room.name))
{
console.log("throw error: error: true, code: 'BLOCKED_USER', message: 'you cannot enter this room, you blocked this user'");
throw new HttpException({ error: true, code: 'BLOCKED_USER', message: `you cannot enter this room, you blocked this user` }, HttpStatus.UNAUTHORIZED);
}
const find_room = await this.chatService.getRoomByName(`${req.user.username} + ${room.name}`);
if (find_room)
{
console.log("throw error: error: true, code: 'ROOM_CONFLICT', message: 'This room name already exist'");
throw new HttpException({ error: true, code: 'ROOM_CONFLICT', message: `This room name already exist` }, HttpStatus.CONFLICT);
}
room.type = 'direct'; room.type = 'direct';
room.users = [room.name, req.user.username]; room.users = [room.name, req.user.username];
room.name += ` + ${req.user.username}`; room.name += ` + ${req.user.username}`;
@@ -243,7 +281,7 @@ export class ChatController {
{ {
printCaller("- in "); printCaller("- in ");
let fields = ["protection", "allowed_users"]; let fields = ["protection", "allowed_users", "type", "users"];
const room_db = await this.chatService.getRoomByName(room.name, fields); const room_db = await this.chatService.getRoomByName(room.name, fields);
if (room_db.protection === true) if (room_db.protection === true)
@@ -255,6 +293,19 @@ export class ChatController {
} }
} }
const blocked = await this.chatService.getListBlockUser(req.user.username);
if (room_db.type === 'direct')
{
let roomname = room_db.users[0];
if (roomname === req.user.username)
roomname = room.users[1];
if (blocked.includes(roomname))
{
console.log("throw error: error: true, code: 'BLOCKED_USER', message: 'you cannot enter this room, you blocked this user'");
throw new HttpException({ error: true, code: 'BLOCKED_USER', message: `you cannot enter this room, you blocked this user` }, HttpStatus.UNAUTHORIZED);
}
}
await this.chatService.setCurrentRoom(req.user.username, room.name); await this.chatService.setCurrentRoom(req.user.username, room.name);
let socket: socketDto = this.chatGateway.sockets.get(req.user.username); let socket: socketDto = this.chatGateway.sockets.get(req.user.username);
await this.chatService.socketChangeRoom(socket, room.name); await this.chatService.socketChangeRoom(socket, room.name);
@@ -361,6 +412,14 @@ export class ChatController {
{ {
printCaller("- in "); printCaller("- in ");
const blocked = await this.chatService.getListBlockUser(req.user.username);
if (blocked.includes(username))
{
console.log("throw error: error: true, code: 'BLOCKED_USER', message: 'you cannot invite this user, you have blocked it'");
throw new HttpException({ error: true, code: 'BLOCKED_USER', message: `you cannot invite this user, you have blocked it` }, HttpStatus.UNAUTHORIZED);
}
let current_room_name = await this.chatService.getCurrentRoomName(req.user.username); let current_room_name = await this.chatService.getCurrentRoomName(req.user.username);
let room = await this.chatService.addUserToRoom(username, current_room_name); let room = await this.chatService.addUserToRoom(username, current_room_name);
let message = `${username} joined the room`; let message = `${username} joined the room`;
@@ -403,7 +462,17 @@ export class ChatController {
printCaller("- in "); printCaller("- in ");
const messages = await this.chatService.getMessagesFromCurrentRoom(req.user.username); const messages = await this.chatService.getMessagesFromCurrentRoom(req.user.username);
res.status(HttpStatus.OK).json({ messages: messages });
console.log("messages:", messages);
const blocked = await this.chatService.getListBlockUser(req.user.username);
let filtered_messages = messages.filter(message =>
{
if (blocked.includes(message.name))
return false;
return true;
});
res.status(HttpStatus.OK).json({ messages: filtered_messages });
printCaller("- out "); printCaller("- out ");
} }
@@ -456,7 +525,15 @@ export class ChatController {
const room_name = await this.chatService.getCurrentRoomName(req.user.username); const room_name = await this.chatService.getCurrentRoomName(req.user.username);
const users = await this.chatService.getAllUsersNotInRoom(room_name); const users = await this.chatService.getAllUsersNotInRoom(room_name);
res.status(HttpStatus.OK).json({ users: users }); const blocked = await this.chatService.getListBlockUser(req.user.username);
let filtered_users = users.filter(user =>
{
if (blocked.includes(user.username))
return false;
return true;
});
res.status(HttpStatus.OK).json({ users: filtered_users });
printCaller("- out "); printCaller("- out ");
} }

View File

@@ -28,7 +28,7 @@ implements OnGatewayConnection, OnGatewayDisconnect
socket.username = socket.handshake.query.username.toString(); socket.username = socket.handshake.query.username.toString();
this.sockets.set(socket.username, socket); this.sockets.set(socket.username, socket);
printCaller("socket.username:", socket.username); printCaller("--- socket.username:", socket.username);
let not_emit: string = `${socket.username}_not_emit`; let not_emit: string = `${socket.username}_not_emit`;
socket.join(not_emit); socket.join(not_emit);

View File

@@ -306,26 +306,22 @@ export class ChatService {
async findOneRelationshipByUsername(friendUsername : string, username : string) async findOneRelationshipByUsername(friendUsername : string, username : string)
{ {
printCaller("-- in ");
const friendship = await this.friendshipRepository const friendship = await this.friendshipRepository
.createQueryBuilder('friendship') .createQueryBuilder('friendship')
.leftJoinAndSelect('friendship.sender', 'sender') .leftJoinAndSelect('friendship.sender', 'sender')
.leftJoinAndSelect('friendship.receiver', 'receiver') .leftJoinAndSelect('friendship.receiver', 'receiver')
.where .where (
( new Brackets((qb) => {
new Brackets((qb) => qb.where (
{ new Brackets((subAQb) => {
qb.where
(
new Brackets((subAQb) =>
{
subAQb.where('sender.username = :username', {username : username}) subAQb.where('sender.username = :username', {username : username})
.andWhere('receiver.username = :friendUsername', {friendUsername : friendUsername}) .andWhere('receiver.username = :friendUsername', {friendUsername : friendUsername})
}) })
) )
.orWhere .orWhere (
( new Brackets((subBQb) => {
new Brackets((subBQb) =>
{
subBQb.where('sender.username = :friendUsername2', {friendUsername2 : friendUsername}) subBQb.where('sender.username = :friendUsername2', {friendUsername2 : friendUsername})
.andWhere('receiver.username = :username2', {username2 : username}) .andWhere('receiver.username = :username2', {username2 : username})
.andWhere('friendship.status != :status', {status : FriendshipStatus.BLOCKED}) .andWhere('friendship.status != :status', {status : FriendshipStatus.BLOCKED})
@@ -333,11 +329,14 @@ export class ChatService {
) )
}), }),
) )
.getOne() .getOne();
console.log("friendship:", friendship);
if (!friendship) if (!friendship)
return null; return null;
return new SendableFriendship(friendship); return new SendableFriendship(friendship);
printCaller("-- out ");
} }
async addBlockUser(username: string, to_block_username: string): Promise<void> async addBlockUser(username: string, to_block_username: string): Promise<void>

View File

@@ -1,18 +1,13 @@
<script lang="ts"> <script lang="ts">
import Canvas from "../pieces/Canvas.svelte";
import { push } from "svelte-spa-router"; import { push } from "svelte-spa-router";
import { onMount } from 'svelte'; import { onMount } from 'svelte';
import { fetchUser } from "../pieces/utils";
let user; let user;
onMount(async () => { onMount(async () => {
user = await fetch(`http://${process.env.WEBSITE_HOST}:${process.env.WEBSITE_PORT}/api/v2/user`) user = await fetchUser();
.then((resp) => resp.json())
if (user && user.statusCode && user.statusCode === 403) {
console.log('on mount no user, returned status code 403 so logging out of userStore')
}
}); });
const login = async() => { const login = async() => {
@@ -21,10 +16,21 @@
} }
const logout = async() => { const logout = async() => {
await fetch(`http://${process.env.WEBSITE_HOST}:${process.env.WEBSITE_PORT}/api/v2/auth/logout`, { await fetch(`http://${process.env.WEBSITE_HOST}:${process.env.WEBSITE_PORT}/api/v2/auth/logout`,
method: 'POST', {
method: 'POST'
}
)
.then((response) => {
if (!response.ok) {
throw new Error("HTTP " + response.status);
}
})
.catch((error) => {
console.log("catch logout: ", error);
}); });
user = undefined;
user = null;
}; };
</script> </script>

View File

@@ -2,42 +2,57 @@
import { onMount } from "svelte"; import { onMount } from "svelte";
import { push } from "svelte-spa-router"; import { push } from "svelte-spa-router";
let qrCodeImg; let qrCodeImg;
let qrCode = ""; let qrCode = "";
let wrongCode = ""; let wrongCode = "";
const fetchQrCodeImg = (async () => { const fetchQrCodeImg = (async () => {
await fetch(`http://${process.env.WEBSITE_HOST}:${process.env.WEBSITE_PORT}/api/v2/auth/2fa/generate`, qrCodeImg = await fetch(`http://${process.env.WEBSITE_HOST}:${process.env.WEBSITE_PORT}/api/v2/auth/2fa/generate`,
{ {
method: 'POST', method: "POST",
}
)
.then((response) => {
if (!response.ok) {
throw new Error("HTTP " + response.status);
}
return response.blob();
}) })
.then(response => {return response.blob()}) .then((blob) => {
.then(blob => { return URL.createObjectURL(blob);
const url = URL.createObjectURL(blob); })
qrCodeImg = url; .catch((error) => {
console.log("catch fetchQrCodeImg: ", error);
}); });
})()
})();
const submitCode = async () => { const submitCode = async () => {
const response = await fetch(`http://${process.env.WEBSITE_HOST}:${process.env.WEBSITE_PORT}/api/v2/auth/2fa/check`, await fetch(`http://${process.env.WEBSITE_HOST}:${process.env.WEBSITE_PORT}/api/v2/auth/2fa/check`,
{ {
method : 'POST', method: "POST",
headers: { headers: {
"Content-Type": "application/json", "Content-Type": "application/json",
}, },
body: JSON.stringify({ body: JSON.stringify({
"twoFaCode" : qrCode, twoFaCode: qrCode,
}), }),
}); }
)
.then((response) => {
if (!response.ok) {
if (response.status === 401) { if (response.status === 401) {
qrCode = ""; qrCode = "";
wrongCode = `Wrong code`; wrongCode = `Wrong code`;
} }
if (response.status === 200) { throw new Error("HTTP " + response.status);
push('/profile');
console.log('valid Code for 2FA')
} }
push("/profile");
console.log("valid Code for 2FA");
})
.catch((error) => {
console.log("catch submitCode: ", error);
});
}; };
</script> </script>

View File

@@ -14,8 +14,8 @@
let user; let user;
let allUsers; let allUsers;
let playerOneAvatar; let playerOneAvatar = "";
let playerTwoAvatar; let playerTwoAvatar = "";
//Game's stuff //Game's stuff
const options = new pong.InitOptions(); const options = new pong.InitOptions();

View File

@@ -5,13 +5,13 @@
import MatchListElem from "../../pieces/MatchListElem.svelte"; import MatchListElem from "../../pieces/MatchListElem.svelte";
import type { Match } from "../../pieces/Match"; import type { Match } from "../../pieces/Match";
import { fetchUser, fetchAllUsers, fetchAvatar } from "../../pieces/utils"; import { fetchAvatar } from "../../pieces/utils";
import * as pongSpectator from "./client/pongSpectator"; import * as pongSpectator from "./client/pongSpectator";
import { gameState } from "./client/ws"; import { gameState } from "./client/ws";
let playerOneAvatar; let playerOneAvatar = "";
let playerTwoAvatar; let playerTwoAvatar = "";
//Game's stuff //Game's stuff
const gameAreaId = "game_area"; const gameAreaId = "game_area";
@@ -190,6 +190,7 @@
position: relative; position: relative;
width: 100%; width: 100%;
height: 100%; height: 100%;
box-sizing: border-box;
} }
#canvas_container { #canvas_container {
margin-top: 20px; margin-top: 20px;

View File

@@ -1,28 +1,37 @@
<script lang="ts"> <script lang="ts">
import { onMount, onDestroy } from "svelte"; import { onMount, onDestroy } from "svelte";
import { fetchUser } from "../../pieces/utils";
let user;
let allUsersRanking = [];
let fetchScoresInterval;
//user's stuff
let currentUser;
let allUsers = [];
let idInterval;
onMount( async() => { onMount( async() => {
currentUser = await fetch(`http://${process.env.WEBSITE_HOST}:${process.env.WEBSITE_PORT}/api/v2/user`) user = await fetchUser();
.then( x => x.json() ); allUsersRanking = await fetchScores();
allUsers = await fetch(`http://${process.env.WEBSITE_HOST}:${process.env.WEBSITE_PORT}/api/v2/game/ranking`)
.then( x => x.json() ); fetchScoresInterval = setInterval(fetchScores, 10000);
idInterval = setInterval(fetchScores, 10000);
}) })
onDestroy( async() => { onDestroy( async() => {
clearInterval(idInterval); clearInterval(fetchScoresInterval);
}) })
function fetchScores() { async function fetchScores()
fetch(`http://${process.env.WEBSITE_HOST}:${process.env.WEBSITE_PORT}/api/v2/game/ranking`) {
.then( x => x.json() ) return fetch(`http://${process.env.WEBSITE_HOST}:${process.env.WEBSITE_PORT}/api/v2/game/ranking`)
.then( x => allUsers = x ); .then((response) => {
if (!response.ok) {
throw new Error("HTTP " + response.status);
}
return response.json();
})
.catch((error) => {
console.log("catch fetchScores: ", error);
return [];
});
} }
</script> </script>
@@ -41,18 +50,18 @@
</tr> </tr>
</thead> </thead>
<tbody> <tbody>
{#each allUsers as user, i} {#each allUsersRanking as userRanking, i}
<tr> <tr>
<th>{i + 1}</th> <th>{i + 1}</th>
{#if user.username === currentUser.username} {#if userRanking.username === user.username}
<td><b>{user.username} [You]</b></td> <td><b>{userRanking.username} [You]</b></td>
{:else} {:else}
<td>{user.username}</td> <td>{userRanking.username}</td>
{/if} {/if}
<td>{user.stats.winGame}</td> <td>{userRanking.stats.winGame}</td>
<td>{user.stats.loseGame}</td> <td>{userRanking.stats.loseGame}</td>
<td>{user.stats.drawGame}</td> <td>{userRanking.stats.drawGame}</td>
<td>{user.stats.totalGame}</td> <td>{userRanking.stats.totalGame}</td>
</tr> </tr>
{/each} {/each}
</tbody> </tbody>

View File

@@ -4,15 +4,15 @@
import GenerateUserDisplay from '../../pieces/GenerateUserDisplay.svelte'; import GenerateUserDisplay from '../../pieces/GenerateUserDisplay.svelte';
import { push } from 'svelte-spa-router'; import { push } from 'svelte-spa-router';
import Chat from '../../pieces/chat/Chat.svelte';
import { fetchUser } from "../../pieces/utils";
let user; let user;
onMount( async() => { onMount( async() => {
// console.log('mounting profile display') user = await fetchUser();
user = await fetch(`http://${process.env.WEBSITE_HOST}:${process.env.WEBSITE_PORT}/api/v2/user`)
.then( (x) => x.json() );
}) })
</script> </script>
<div class="background-pages"> <div class="background-pages">

View File

@@ -4,35 +4,22 @@
from a regular var. But yea it's functionally identical, seemed easier to just have a duplicate rather than figuring from a regular var. But yea it's functionally identical, seemed easier to just have a duplicate rather than figuring
out how to get a more complicated things to do 2 jobs.*/ out how to get a more complicated things to do 2 jobs.*/
import { onMount } from 'svelte'; import { onMount } from 'svelte';
import GenerateUserDisplay from '../../pieces/GenerateUserDisplay.svelte'; import GenerateUserDisplay from '../../pieces/GenerateUserDisplay.svelte';
import { fetchUser } from "../../pieces/utils";
export let params; export let params;
let user; let oneUser;
onMount( async() => { onMount( async() => {
oneUser = await fetchUser(params.username);
// console.log('Display One User username: '+ params.username)
user = await fetch(`http://${process.env.WEBSITE_HOST}:${process.env.WEBSITE_PORT}/api/v2/user?username=${params.username}`)
.then( (x) => x.json() );
console.log('in display ONE user')
console.log({...user})
}) })
export const updateUser = async() => {
user = await fetch(`http://${process.env.WEBSITE_HOST}:${process.env.WEBSITE_PORT}/api/v2/user?username=${params.username}`)
.then( (x) => x.json() );
};
$: params.username, updateUser();
</script> </script>
<div class="background-pages"> <div class="background-pages">
{#if user !== undefined} {#if oneUser}
<GenerateUserDisplay user={user}/> <GenerateUserDisplay user={oneUser}/>
{:else} {:else}
<h2>Sorry</h2> <h2>Sorry</h2>
<div>Failed to load user {params.username}</div> <div>Failed to load user {params.username}</div>

View File

@@ -5,7 +5,7 @@
import { push } from 'svelte-spa-router'; import { push } from 'svelte-spa-router';
import Button from '../../pieces/Button.svelte'; import Button from '../../pieces/Button.svelte';
import { fetchAvatar } from "../../pieces/utils"; import { fetchUser, fetchAvatar } from "../../pieces/utils";
let user; let user;
let avatar, newAvatar; let avatar, newAvatar;
@@ -18,22 +18,21 @@
let success = {username: '', avatar: '' }; let success = {username: '', avatar: '' };
onMount( async() => { onMount( async() => {
user = await fetch(`http://${process.env.WEBSITE_HOST}:${process.env.WEBSITE_PORT}/api/v2/user`) user = await fetchUser();
.then( (x) => x.json() ); avatar = await fetchAvatar();
// do a .catch?
if (user === undefined) { if (!user) {
console.log('User did not load, something more official should prolly happen') console.log('User did not load, something more official should prolly happen')
} }
// i don't unerstand why this is necessary but it really doesn't like it otherwise // i don't unerstand why this is necessary but it really doesn't like it otherwise
nameTmp = user.username; nameTmp = user.username;
set.tfa = user.isEnabledTwoFactorAuth; set.tfa = user.isEnabledTwoFactorAuth;
avatar = await fetchAvatar(user.username);
}) })
const settingsHandler = async() => { const settingsHandler = async() =>
{
// TODO Luke <--> Eric : Explications
// I don't really care which i use at this point... // I don't really care which i use at this point...
// if (set.username === nameTmp) { // if (set.username === nameTmp) {
if ((set.username.trim() === '') && set.tfa === user.isEnabledTwoFactorAuth) { if ((set.username.trim() === '') && set.tfa === user.isEnabledTwoFactorAuth) {
@@ -46,7 +45,9 @@
else { else {
errors.username = ''; errors.username = '';
} }
await fetch(`http://${process.env.WEBSITE_HOST}:${process.env.WEBSITE_PORT}/api/v2/user`, {
await fetch(`http://${process.env.WEBSITE_HOST}:${process.env.WEBSITE_PORT}/api/v2/user`,
{
method: 'PATCH', method: 'PATCH',
headers: { headers: {
'Content-Type': 'application/json' 'Content-Type': 'application/json'
@@ -55,27 +56,34 @@
"username": set.username, "username": set.username,
"isEnabledTwoFactorAuth": set.tfa "isEnabledTwoFactorAuth": set.tfa
}) })
})
.then((response) => {
if (response.status === 200)
success.username = "Your changes have been saved"
else if (response.status === 201)
push("/2fa");
else if (response.status === 409)
errors.username = `${set.username} is already in use, pick a different one.`;
else
errors.username = "Something went wrong";
} }
) )
.catch((err) => errors.username = err) .then((response) => {
if (!response.ok) {
errors.username = "Something went wrong";
if (response.status === 409) {
errors.username = `${set.username} is already in use, pick a different one.`;
}
throw new Error("HTTP " + response.status);
}
else {
if (response.status === 200) {
success.username = "Your changes have been saved";
}
else if (response.status === 201) {
push("/2fa");
}
}
// .then((result) => console.log(result)) })
// .then(() => console.log('successful sub of new settings')) .catch((error) => {
}; console.log("catch settingsHandler: ", error);
});
}
const uploadAvatar = async() => { const uploadAvatar = async() => {
errors.avatar = ''; errors.avatar = '';
if (newAvatar === undefined) { if (!newAvatar) {
errors.avatar = 'You need to pick a file.' errors.avatar = 'You need to pick a file.'
return; return;
} }
@@ -85,19 +93,23 @@
// tmp // tmp
console.log(data); console.log(data);
const responseWhenChangeAvatar = fetch(`http://${process.env.WEBSITE_HOST}:${process.env.WEBSITE_PORT}/api/v2/user/avatar`, await fetch(`http://${process.env.WEBSITE_HOST}:${process.env.WEBSITE_PORT}/api/v2/user/avatar`,
{ {
method : 'POST', method : 'POST',
body : data, body : data,
}) }
const responseFromServer = await responseWhenChangeAvatar; )
if (responseFromServer.ok === true) { .then((response) => {
if (!response.ok) {
errors.avatar = response.statusText;
throw new Error("HTTP " + response.status);
}
uploadAvatarSuccess = true; uploadAvatarSuccess = true;
success.avatar = 'Your avatar has been updated'; success.avatar = 'Your avatar has been updated';
} })
else { .catch((error) => {
errors.avatar = responseFromServer.statusText; console.log("catch uploadAvatar: ", error);
} });
avatar = await fetchAvatar(user.username); avatar = await fetchAvatar(user.username);
} }
@@ -130,7 +142,7 @@
<Card> <Card>
<!-- ok so it can't actually show us the file we upload until we've uploaded it... --> <!-- ok so it can't actually show us the file we upload until we've uploaded it... -->
{#if avatar !== undefined} {#if avatar}
<img class="avatar" src={avatar} alt="your avatar"/> <img class="avatar" src={avatar} alt="your avatar"/>
{/if} {/if}
<form on:submit|preventDefault={uploadAvatar}> <form on:submit|preventDefault={uploadAvatar}>
@@ -141,7 +153,7 @@
<input type="file" bind:files={newAvatar}/> <input type="file" bind:files={newAvatar}/>
<div class="error">{errors.avatar}</div> <div class="error">{errors.avatar}</div>
</div> </div>
<Button type={newAvatar === undefined ? "primary" : "secondary"}>Upload Avatar</Button> <Button type={!newAvatar ? "primary" : "secondary"}>Upload Avatar</Button>
</form> </form>
</Card> </Card>
</div> </div>

View File

@@ -4,51 +4,52 @@
import Button from "../../pieces/Button.svelte"; import Button from "../../pieces/Button.svelte";
import DisplayAUser from "../../pieces/DisplayAUser.svelte"; import DisplayAUser from "../../pieces/DisplayAUser.svelte";
import Tabs from "../../pieces/Tabs.svelte"; import Tabs from "../../pieces/Tabs.svelte";
import { fetchUser, fetchAllUsers, fetchAvatar } from "../../pieces/utils";
let user; let user;
let allUsers; let allUsers = [];
let myFriendships; let myFriendships = [];
let requestsMade, requestsRecieved; let requestsMade, requestsRecieved;
let blockedUsers; let blockedUsers = [];
let usernameBeingViewed; let usernameBeingViewed;
let friendshipStatusFull; // date, reveiverUsername, status let friendshipStatusFull; // date, reveiverUsername, status
/**** Layout variables ****/ /**** Layout variables ****/
let tabItems: string[] = ['All Users', 'My Friends', 'Friend Requests', 'Blocked Users'] let tabItems: string[] = [
let activeTabItem: string = 'All Users'; "All Users",
"My Friends",
"Friend Requests",
"Blocked Users",
];
let activeTabItem: string = "All Users";
let loadedUser; let loadedUser;
onMount(async () => { onMount(async () => {
user = await fetch(`http://${process.env.WEBSITE_HOST}:${process.env.WEBSITE_PORT}/api/v2/user`) user = await fetchUser();
.then( (x) => x.json() );
fetchAll(); fetchAll();
}); });
const fetchAll = async () => { const fetchAll = async () => {
// no need to await i think it can load in the background // no need to await i think it can load in the background
fetchAllUsers(); fetchAllUsers_Wrapper();
fetchMyFriendships(); fetchMyFriendships();
fetchRequestsMade(); fetchRequestsMade();
fetchRequestsReceived(); fetchRequestsReceived();
fetchBlockedUsers(); fetchBlockedUsers();
} };
/***** Fetch basic things *****/ /***** Fetch basic things *****/
const fetchAllUsers = async() => { const fetchAllUsers_Wrapper = async () => {
allUsers = await fetch(`http://${process.env.WEBSITE_HOST}:${process.env.WEBSITE_PORT}/api/v2/user/all`) allUsers = await fetchAllUsers();
.then( x => x.json() ); if (usernameBeingViewed) {
console.log('got all users ') let found = allUsers.find(
console.log({...allUsers}) (e) => e.username === usernameBeingViewed
if (usernameBeingViewed !== undefined) { );
let found = allUsers.find(e => e.username === usernameBeingViewed); if (!found) {
// console.log("SEARCHING ALL USERS: ") usernameBeingViewed = null;
// console.log({...found}) friendshipStatusFull = null;
if (found === undefined) {
// console.log('none found')
usernameBeingViewed = undefined;
friendshipStatusFull = undefined;
} }
} }
}; };
@@ -57,150 +58,214 @@
// then i need to extract the users // then i need to extract the users
const fetchMyFriendships = async () => { const fetchMyFriendships = async () => {
myFriendships = await fetch(`http://${process.env.WEBSITE_HOST}:${process.env.WEBSITE_PORT}/api/v2/network/myfriends`) myFriendships = await fetch(`http://${process.env.WEBSITE_HOST}:${process.env.WEBSITE_PORT}/api/v2/network/myfriends`)
.then( x => x.json() ); .then((response) => {
if (!response.ok) {
console.log('got my friends ') throw new Error("HTTP " + response.status);
console.log({...myFriendships}) }
return response.json();
})
.catch((error) => {
console.log("catch fetchMyFriendships: ", error);
return [];
});
}; };
const fetchRequestsMade = async () => { const fetchRequestsMade = async () => {
requestsMade = await fetch(`http://${process.env.WEBSITE_HOST}:${process.env.WEBSITE_PORT}/api/v2/network/pending`) requestsMade = await fetch(`http://${process.env.WEBSITE_HOST}:${process.env.WEBSITE_PORT}/api/v2/network/pending`)
.then( x => x.json() ); .then((response) => {
if (!response.ok) {
console.log('got requests made ') throw new Error("HTTP " + response.status);
console.log({...requestsMade}) }
return response.json();
})
.catch((error) => {
console.log("catch fetchRequestsMade: ", error);
return [];
});
}; };
const fetchRequestsReceived = async () => { const fetchRequestsReceived = async () => {
requestsRecieved = await fetch(`http://${process.env.WEBSITE_HOST}:${process.env.WEBSITE_PORT}/api/v2/network/received`) requestsRecieved = await fetch(`http://${process.env.WEBSITE_HOST}:${process.env.WEBSITE_PORT}/api/v2/network/received`)
.then( x => x.json() ); .then((response) => {
if (!response.ok) {
console.log('got requests received ') throw new Error("HTTP " + response.status);
console.log({...requestsRecieved}) }
return response.json();
})
.catch((error) => {
console.log("catch fetchRequestsReceived: ", error);
return [];
});
}; };
const fetchBlockedUsers = async () => { const fetchBlockedUsers = async () => {
blockedUsers = await fetch(`http://${process.env.WEBSITE_HOST}:${process.env.WEBSITE_PORT}/api/v2/network/blocked`) blockedUsers = await fetch(`http://${process.env.WEBSITE_HOST}:${process.env.WEBSITE_PORT}/api/v2/network/blocked`)
.then( x => x.json() ); .then((response) => {
if (!response.ok) {
console.log('got blocked users, is it empty?') throw new Error("HTTP " + response.status);
console.log({...blockedUsers}) }
console.log(Object.keys(blockedUsers)) return response.json();
})
.catch((error) => {
console.log("catch fetchBlockedUsers: ", error);
return [];
});
}; };
/**** END OF MAIN FETCH ****/ /**** END OF MAIN FETCH ****/
// returns everything but BLOCKED // returns everything but BLOCKED
const fetchFriendshipFull = async (aUsername) => { const fetchFriendshipFull = async (aUsername) => {
console.log('fetch friendship from a username')
console.log(aUsername)
friendshipStatusFull = await fetch(`http://${process.env.WEBSITE_HOST}:${process.env.WEBSITE_PORT}/api/v2/network/myfriends?username=${aUsername}`) friendshipStatusFull = await fetch(`http://${process.env.WEBSITE_HOST}:${process.env.WEBSITE_PORT}/api/v2/network/myfriends?username=${aUsername}`)
.then( x => x.json()); .then((response) => {
if (!response.ok) {
console.log({...friendshipStatusFull}) throw new Error("HTTP " + response.status);
}
return response.json();
})
.catch((error) => {
console.log("catch fetchFriendshipFull: ", error);
return [];
});
}; };
const sendFriendRequest = async (aUsername) => { const sendFriendRequest = async (aUsername) => {
console.log('sending a friend request') await fetch(`http://${process.env.WEBSITE_HOST}:${process.env.WEBSITE_PORT}/api/v2/network/relations`,
console.log(aUsername) {
const resp = await fetch(`http://${process.env.WEBSITE_HOST}:${process.env.WEBSITE_PORT}/api/v2/network/relations`, {
method: "POST", method: "POST",
headers: { 'Content-Type': 'application/json'}, headers: { "Content-Type": "application/json" },
body: JSON.stringify({ body: JSON.stringify({
"receiverUsername": aUsername, receiverUsername: aUsername,
"status": "R" status: "R",
}),
}
)
.then((response) => {
if (!response.ok) {
throw new Error("HTTP " + response.status);
}
}) })
}) .catch((error) => {
.then( x => x.json()) console.log("catch sendFriendRequest: ", error);
// .catch( x => console.log({...x})) });
await fetchFriendshipFull(aUsername); await fetchFriendshipFull(aUsername);
await fetchAll(); await fetchAll();
}; };
const viewAUser = async (aUsername) => { const viewAUser = async (aUsername) => {
console.log('Profile Friend updating userBeingViewed')
usernameBeingViewed = aUsername; usernameBeingViewed = aUsername;
await fetchFriendshipFull(aUsername); await fetchFriendshipFull(aUsername);
console.log('Friendship Status Full')
console.log({...friendshipStatusFull})
}; };
const acceptFriendRequest = async (relationshipId) => { const acceptFriendRequest = async (relationshipId) => {
console.log('accept friend request') await fetch(`http://${process.env.WEBSITE_HOST}:${process.env.WEBSITE_PORT}/api/v2/network/relations/${relationshipId}/accept`,
{
method: "PATCH",
}
)
.then((response) => {
if (!response.ok) {
throw new Error("HTTP " + response.status);
}
})
.catch((error) => {
console.log("catch acceptFriendRequest: ", error);
});
const resp = await fetch(`http://${process.env.WEBSITE_HOST}:${process.env.WEBSITE_PORT}/api/v2/network/relations/${relationshipId}/accept`, {
method: "PATCH"})
.then( x => x.json());
await fetchFriendshipFull(usernameBeingViewed); await fetchFriendshipFull(usernameBeingViewed);
await fetchAll(); await fetchAll();
activeTabItem = activeTabItem; activeTabItem = activeTabItem;
}; };
const declineFriendRequest = async (relationshipId) => { const declineFriendRequest = async (relationshipId) => {
console.log('decline friend request') await fetch(`http://${process.env.WEBSITE_HOST}:${process.env.WEBSITE_PORT}/api/v2/network/relations/${relationshipId}/decline`,
{
method: "PATCH",
}
)
.then((response) => {
if (!response.ok) {
throw new Error("HTTP " + response.status);
}
})
.catch((error) => {
console.log("catch declineFriendRequest: ", error);
});
const resp = await fetch(`http://${process.env.WEBSITE_HOST}:${process.env.WEBSITE_PORT}/api/v2/network/relations/${relationshipId}/decline`, {
method: "PATCH"})
.then( x => x.json());
await fetchFriendshipFull(usernameBeingViewed); await fetchFriendshipFull(usernameBeingViewed);
await fetchAll(); await fetchAll();
activeTabItem = activeTabItem; activeTabItem = activeTabItem;
}; };
const unfriend = async (relationshipId) => { const unfriend = async (relationshipId) => {
console.log('Unfriend') await fetch(`http://${process.env.WEBSITE_HOST}:${process.env.WEBSITE_PORT}/api/v2/network/relations/${relationshipId}`,
{
const resp = await fetch(`http://${process.env.WEBSITE_HOST}:${process.env.WEBSITE_PORT}/api/v2/network/relations/${relationshipId}`, { method: "DELETE",
method: "DELETE"}) }
.then( x => x.json()); )
.then((response) => {
if (!response.ok) {
throw new Error("HTTP " + response.status);
}
})
.catch((error) => {
console.log("catch unfriend: ", error);
});
await fetchFriendshipFull(usernameBeingViewed); await fetchFriendshipFull(usernameBeingViewed);
if (Object.keys(friendshipStatusFull).length === 0) if (Object.keys(friendshipStatusFull).length === 0) {
friendshipStatusFull = undefined; friendshipStatusFull = null;
}
await fetchAll(); await fetchAll();
activeTabItem = activeTabItem; activeTabItem = activeTabItem;
}; };
const blockANonFriendUser = async (aUsername) => { const blockANonFriendUser = async (aUsername) => {
console.log('Block a non friend user, their username') await fetch(`http://${process.env.WEBSITE_HOST}:${process.env.WEBSITE_PORT}/api/v2/network/relations`,
console.log(aUsername) {
let sentFriendRequest = await fetch(`http://${process.env.WEBSITE_HOST}:${process.env.WEBSITE_PORT}/api/v2/network/relations`, {
method: "POST", method: "POST",
headers: { 'Content-Type': 'application/json'}, headers: { "Content-Type": "application/json" },
body: JSON.stringify({ body: JSON.stringify({
"receiverUsername": aUsername, receiverUsername: aUsername,
"status": "B" status: "B",
}),
}
)
.then((response) => {
if (!response.ok) {
throw new Error("HTTP " + response.status);
}
}) })
}) .catch((error) => {
.then( x => x.json()) console.log("catch blockANonFriendUser: ", error);
// await fetchBlockedUsers(); });
// await fetchAllUsers();
await fetchAll(); await fetchAll();
usernameBeingViewed = undefined; usernameBeingViewed = null;
friendshipStatusFull = undefined; friendshipStatusFull = null;
activeTabItem = activeTabItem; activeTabItem = activeTabItem;
}; };
const blockAFriend = async (relationshipId) => { const blockAFriend = async (relationshipId) => {
console.log('blocking a friend, the relationshipID') await fetch(`http://${process.env.WEBSITE_HOST}:${process.env.WEBSITE_PORT}/api/v2/network/relations/${relationshipId}/block`,
console.log(relationshipId) {
method: "PATCH"
}
)
.then((response) => {
if (!response.ok) {
throw new Error("HTTP " + response.status);
}
})
.catch((error) => {
console.log("catch blockAFriend: ", error);
});
const resp = await fetch(`http://${process.env.WEBSITE_HOST}:${process.env.WEBSITE_PORT}/api/v2/network/relations/${relationshipId}/block`, {method: "PATCH"})
.then( x => x.json() );
console.log('blocked a user response')
console.log({...resp})
// await fetchBlockedUsers();
// await fetchAllUsers();
await fetchAll(); await fetchAll();
usernameBeingViewed = undefined; usernameBeingViewed = null;
friendshipStatusFull = undefined; friendshipStatusFull = null;
// reloads active tab so you get blocked users for example // reloads active tab so you get blocked users for example
activeTabItem = activeTabItem; activeTabItem = activeTabItem;
@@ -214,17 +279,17 @@
const switchTab = async (e) => { const switchTab = async (e) => {
activeTabItem = e.detail; activeTabItem = e.detail;
if (activeTabItem === 'All Users') { if (activeTabItem === "All Users") {
await fetchAllUsers(); await fetchAllUsers_Wrapper();
} else if (activeTabItem === 'My Friends') { } else if (activeTabItem === "My Friends") {
await fetchMyFriendships(); await fetchMyFriendships();
} else if (activeTabItem === 'Friend Requests') { } else if (activeTabItem === "Friend Requests") {
await fetchRequestsReceived(); await fetchRequestsReceived();
} else if (activeTabItem === 'Blocked Users') { } else if (activeTabItem === "Blocked Users") {
await fetchBlockedUsers(); await fetchBlockedUsers();
console.log('fetching blocked users') console.log("fetching blocked users");
} }
if (usernameBeingViewed !== undefined) if (usernameBeingViewed)
fetchFriendshipFull(usernameBeingViewed); fetchFriendshipFull(usernameBeingViewed);
}; };
@@ -240,7 +305,7 @@
<div class="sidebar-list"> <div class="sidebar-list">
<Tabs items={tabItems} activeItem={activeTabItem} size="small" on:tabChange={switchTab}/> <Tabs items={tabItems} activeItem={activeTabItem} size="small" on:tabChange={switchTab}/>
{#if activeTabItem === 'All Users' && allUsers !== undefined} {#if activeTabItem === 'All Users' && allUsers}
<h3>{activeTabItem}</h3> <h3>{activeTabItem}</h3>
{#if Object.keys(allUsers).length === 0} {#if Object.keys(allUsers).length === 0}
<div class="tip">You are alone on this platform...</div> <div class="tip">You are alone on this platform...</div>
@@ -256,7 +321,7 @@
<div class="status sidebar-item">{aUser.status}</div> <div class="status sidebar-item">{aUser.status}</div>
<br> <br>
{/each} {/each}
{:else if activeTabItem === 'My Friends' && myFriendships !== undefined} {:else if activeTabItem === 'My Friends' && myFriendships}
<h3>{activeTabItem}</h3> <h3>{activeTabItem}</h3>
{#if Object.keys(myFriendships).length === 0} {#if Object.keys(myFriendships).length === 0}
<div class="tip">You don't have any Friends... Yet!</div> <div class="tip">You don't have any Friends... Yet!</div>
@@ -269,7 +334,7 @@
{/if} {/if}
<br> <br>
{/each} {/each}
{:else if activeTabItem === 'Friend Requests' && requestsRecieved !== undefined} {:else if activeTabItem === 'Friend Requests' && requestsRecieved}
<h3>{activeTabItem}</h3> <h3>{activeTabItem}</h3>
{#if Object.keys(requestsRecieved).length === 0} {#if Object.keys(requestsRecieved).length === 0}
<div class="tip">You don't have any Friend Requests</div> <div class="tip">You don't have any Friend Requests</div>
@@ -279,7 +344,7 @@
<div class="status sidebar-item">{aUser.status}</div> <div class="status sidebar-item">{aUser.status}</div>
<br> <br>
{/each} {/each}
{:else if activeTabItem === 'Blocked Users' && blockedUsers !== undefined} {:else if activeTabItem === 'Blocked Users' && blockedUsers}
<h3>{activeTabItem}</h3> <h3>{activeTabItem}</h3>
<!-- seems a little excessive... maybe a lighter way of doing this? doesn't seem like it, i hate it but at least only happens sometimes.default... --> <!-- seems a little excessive... maybe a lighter way of doing this? doesn't seem like it, i hate it but at least only happens sometimes.default... -->
{#if Object.keys(blockedUsers).length === 0} {#if Object.keys(blockedUsers).length === 0}
@@ -295,7 +360,7 @@
<div class="main-display"> <div class="main-display">
{#if usernameBeingViewed !== undefined} {#if usernameBeingViewed}
<DisplayAUser aUsername={usernameBeingViewed} bind:loaded={loadedUser}/> <DisplayAUser aUsername={usernameBeingViewed} bind:loaded={loadedUser}/>
{#if loadedUser === true} {#if loadedUser === true}

View File

@@ -1,112 +0,0 @@
<script lang="ts">
import { onMount } from 'svelte';
// rename to PotatoCanvas?
let canvas;
// let img;
let loaded = false;
// i feel like they told me not to do this, new Image(), isn't there another way?
// never mind they do seem to do this shit...
// no idea if this should be in onMount...
const img = new Image();
img.src = 'img/potato_logo.png';
img.onload = () => {
loaded = true;
// not sure if i'll use this...
}
// $: scaleRatio = window.innerWidth / 10;
$: scaleRatio = 30;
$: nPotoatoRows = Math.floor(window.innerHeight / 200);
$: nPotoatoCols = Math.floor(window.innerWidth / 200);
// $: spacing = (canvas.height - (img.height / scaleRatio * (nPotoatoRows - 1) )) / nPotoatoRows;
// apparently i might need to move all my reactive statements outside the onMount... not sure why...
onMount(() => {
// in this on mount we will set the canvas and the img
const ctx = canvas.getContext('2d');
// let frame = requestAnimationFrame(loop);
ctx.width = window.innerWidth;
ctx.height = window.innerHeight;
// console.log(nPotoatoCols);
// img = fetch('img/potato_logo.png');
// Moving the IMG stuff from her out of mount
// let nPotoatoRows = 4;
// $: nPotoatoRows = Math.floor(canvas.height / 200);
let spacing = (canvas.height - (img.height / scaleRatio * (nPotoatoRows - 1) )) / nPotoatoRows;
// $: spacing = (canvas.height - (img.height / scaleRatio * (nPotoatoRows - 1) )) / nPotoatoRows;
// i prolly need a number of potatos X and Y vars
// i could do it so there are more potatos than can fit on the screen, translate them over, and then after some point
// shift them all back to the next position they would be in, so it looks like they keep going to infinity
// let dx = 1.5;
let dx = 1;
// let dy = -0.5;
let dy = -1;
// let startX = spacing;
// let startY = spacing;
// let startX = 0;
// let startY = 0;
let startX = -(spacing * 2.5);
let startY = -(spacing * 2.5);
let x = startX;
let y = startY;
let frame = requestAnimationFrame(loop);
// i don't think i need t...
function loop(t) {
// yea ok a loop in a loop in a loop, horrible idea...
ctx.clearRect(0, 0, canvas.width, canvas.height);
// this has to be at the end, no?
frame = requestAnimationFrame(loop);
// if (x > 900) {
// x = startX;
// y = startY;
// }
// else {
// x += dx;
// y += dy;
// }
for (let i = 0; i < 20; i++) {
for (let j = 0; j < 10; j++) {
// ctx.drawImage(img, x + (i * spacing * 2), y + (j * spacing), img.width / scaleRatio, img.height / scaleRatio);
ctx.drawImage(img, x + (i * spacing), y + (j * spacing), img.width / scaleRatio, img.height / scaleRatio);
}
}
}
return () => {
cancelAnimationFrame(frame);
};
});
</script>
<canvas
bind:this={canvas}
width={window.innerWidth}
height={window.innerHeight}
></canvas>
<style>
canvas {
width: 100%;
height: 100%;
background-color: #666;
}
</style>

View File

@@ -2,24 +2,17 @@
import { onMount } from 'svelte'; import { onMount } from 'svelte';
import GenerateUserDisplay from './GenerateUserDisplay.svelte'; import GenerateUserDisplay from './GenerateUserDisplay.svelte';
import { fetchUser } from "../pieces/utils";
export let aUsername; export let aUsername;
export let loaded = false; export let loaded = false;
let user; let user;
onMount( async() => { onMount( async() => {
// console.log('Display aUser username: '+ aUsername) aUser = await fetchUser(aUsername);
user = await fetch(`http://${process.env.WEBSITE_HOST}:${process.env.WEBSITE_PORT}/api/v2/user?username=${aUsername}`)
.then( (x) => x.json() );
}) })
export const updateUser = async() => { $: aUsername, fetchUser(aUsername);
user = await fetch(`http://${process.env.WEBSITE_HOST}:${process.env.WEBSITE_PORT}/api/v2/user?username=${aUsername}`)
.then( (x) => x.json() );
};
$: aUsername, updateUser();
$: { $: {
if (user === undefined) if (user === undefined)
@@ -31,8 +24,8 @@
</script> </script>
<div class="background-pages"> <div class="background-pages">
{#if user !== undefined} {#if aUser}
<GenerateUserDisplay user={user}/> <GenerateUserDisplay user={aUser}/>
{:else} {:else}
<h2>Sorry</h2> <h2>Sorry</h2>
<div>Failed to load user {aUsername}</div> <div>Failed to load user {aUsername}</div>

View File

@@ -62,11 +62,11 @@
<!-- is this if excessive? --> <!-- is this if excessive? -->
<div class="outer"> <div class="outer">
{#if user !== undefined} {#if user}
<main> <main>
<!-- <img class="icon" src="img/default_user_icon.png" alt="default user icon"> --> <!-- <img class="icon" src="img/default_user_icon.png" alt="default user icon"> -->
<!-- <img class="icon" src="{user.image_url}" alt="default user icon"> --> <!-- <img class="icon" src="{user.image_url}" alt="default user icon"> -->
<img class="avatar" src="{avatar}" alt="default user icon"> <img class="avatar" src="{avatar}" alt="user avatar">
<div class="error">{errors.avatar}</div> <div class="error">{errors.avatar}</div>
<div class="username">{user.username}</div> <div class="username">{user.username}</div>
<div class="rank">Rank: <div class="rank">Rank:

View File

@@ -9,12 +9,23 @@
$: current = $location; $: current = $location;
let handleClickLogout = async () => { let handleClickLogout = async () =>
await fetch(`http://${process.env.WEBSITE_HOST}:${process.env.WEBSITE_PORT}/api/v2/auth/logout`, { {
await fetch(`http://${process.env.WEBSITE_HOST}:${process.env.WEBSITE_PORT}/api/v2/auth/logout`,
{
method: 'POST', method: 'POST',
}
)
.then((response) => {
if (!response.ok) {
throw new Error("HTTP " + response.status);
}
}) })
.then( () => push('/') ) .catch((error) => {
console.log('clicked logout header') console.log("catch handleClickLogout: ", error);
});
push('/');
}; };
</script> </script>
@@ -59,7 +70,6 @@
} }
.header { .header {
resize: vertical;
overflow: hidden; overflow: hidden;
background: #FB8B24; background: #FB8B24;
box-sizing: border-box; box-sizing: border-box;

View File

@@ -82,7 +82,7 @@
</script> </script>
{#if $location !== '/'} {#if $location !== '/' && $location !== '/game'}
<Layouts <Layouts
--lines_width={style.lines_width} --lines_width={style.lines_width}
--lines_color={style.lines_color} --lines_color={style.lines_color}

View File

@@ -10,10 +10,10 @@
let users: User[] = list_block_user(); let users: User[] = list_block_user();
function user_profile(room_user: string) async function user_profile(room_user: string)
{ {
to_print("in user_profile"); to_print("in user_profile");
settings_user.set(room_user); await settings_user.set(room_user);
layout.set("user"); layout.set("user");
} }

View File

@@ -239,7 +239,7 @@ export async function remove_block_user(username: string): Promise<void>
await fetch_chat_request('unblock', FetchMethod.POST, {username: username} ); await fetch_chat_request('unblock', FetchMethod.POST, {username: username} );
} }
export async function list_block_user(username: string): Promise<string> export async function list_block_user(username: string): Promise<string[]>
{ {
to_print("in list_block_user"); to_print("in list_block_user");

View File

@@ -6,8 +6,11 @@ const address = `http://${process.env.WEBSITE_HOST}:${process.env.WEBSITE_PORT}`
export async function init_socket() export async function init_socket()
{ {
to_print("in init_socket");
console.log("here");
const response = await fetch(`${address}/api/v2/user`); const response = await fetch(`${address}/api/v2/user`);
const response_data = await response.json(); const response_data = await response.json();
to_print("-- response_data:", response_data);
set_user(response_data); set_user(response_data);
@@ -19,6 +22,7 @@ export async function init_socket()
username: response_data.username, username: response_data.username,
}, },
}); });
console.log("horo");
set_socket(socket); set_socket(socket);
socket_states(socket); socket_states(socket);

View File

@@ -1,7 +1,12 @@
export async function fetchAvatar(username: string) export async function fetchAvatar(username?: string)
{ {
return fetch(`http://${process.env.WEBSITE_HOST}:${process.env.WEBSITE_PORT}/api/v2/user/avatar?username=${username}`) let url = `http://${process.env.WEBSITE_HOST}:${process.env.WEBSITE_PORT}/api/v2/user/avatar`;
if (username) {
url += `?username=${username}`;
}
return fetch(url)
.then((response) => { .then((response) => {
if (!response.ok) { if (!response.ok) {
throw new Error("HTTP " + response.status); throw new Error("HTTP " + response.status);
@@ -17,18 +22,20 @@ export async function fetchAvatar(username: string)
}); });
} }
export async function fetchUser() export async function fetchUser(username?: string)
{ {
return fetch(`http://${process.env.WEBSITE_HOST}:${process.env.WEBSITE_PORT}/api/v2/user`) let url = `http://${process.env.WEBSITE_HOST}:${process.env.WEBSITE_PORT}/api/v2/user`;
if (username) {
url += `?username=${username}`;
}
return fetch(url)
.then((response) => { .then((response) => {
if (!response.ok) { if (!response.ok) {
throw new Error("HTTP " + response.status); throw new Error("HTTP " + response.status);
} }
return response.json(); return response.json();
}) })
.then((body) => {
return body;
})
.catch((error) => { .catch((error) => {
console.log("catch fetchUser: ", error); console.log("catch fetchUser: ", error);
return null; return null;
@@ -44,9 +51,6 @@ export async function fetchAllUsers()
} }
return response.json(); return response.json();
}) })
.then((body) => {
return body;
})
.catch((error) => { .catch((error) => {
console.log("catch fetchAllUsers: ", error); console.log("catch fetchAllUsers: ", error);
return []; return [];

View File

@@ -7,95 +7,40 @@ import { wrap } from 'svelte-spa-router/wrap'
import Game from '../pages/game/Game.svelte'; import Game from '../pages/game/Game.svelte';
import Ranking from '../pages/game/Ranking.svelte'; import Ranking from '../pages/game/Ranking.svelte';
import GameSpectator from '../pages/game/GameSpectator.svelte'; import GameSpectator from '../pages/game/GameSpectator.svelte';
import { fetchUser } from "../pieces/utils";
async function checkLogin(detail) {
const user = await fetchUser();
if (!user || !user.username) {
return false;
}
else {
return true;
}
}
export const primaryRoutes = { export const primaryRoutes = {
'/': SplashPage, '/': SplashPage,
'/2fa': TwoFactorAuthentication, '/2fa': TwoFactorAuthentication,
'/game': wrap({ '/game': wrap({
component: Game, component: Game,
conditions: [ conditions: [checkLogin]
async(detail) => {
const user = await fetch('http://' + process.env.WEBSITE_HOST + ":" + process.env.WEBSITE_PORT + '/api/v2/user')
.then((resp) => resp.json())
console.log('in /profile what is in user')
console.log(user)
if (user && user.username)
return true;
else
return false;
}
]
}), }),
'/spectator': wrap({ '/spectator': wrap({
component: GameSpectator, component: GameSpectator,
conditions: [ conditions: [checkLogin]
async(detail) => {
const user = await fetch('http://' + process.env.WEBSITE_HOST + ":" + process.env.WEBSITE_PORT + '/api/v2/user')
.then((resp) => resp.json())
console.log('in /profile what is in user')
console.log(user)
if (user && user.username)
return true;
else
return false;
}
]
}), }),
'/ranking': wrap({ '/ranking': wrap({
component: Ranking, component: Ranking,
conditions: [ conditions: [checkLogin]
async(detail) => {
const user = await fetch('http://' + process.env.WEBSITE_HOST + ":" + process.env.WEBSITE_PORT + '/api/v2/user')
.then((resp) => resp.json())
console.log('in /profile what is in user')
console.log(user)
if (user && user.username)
return true;
else
return false;
}
]
}), }),
'/profile': wrap({ '/profile': wrap({
component: ProfilePage, component: ProfilePage,
conditions: [ conditions: [checkLogin]
async(detail) => {
const user = await fetch('http://' + process.env.WEBSITE_HOST + ":" + process.env.WEBSITE_PORT + '/api/v2/user')
.then((resp) => resp.json())
console.log('in /profile what is in user')
console.log(user)
if (user && user.username)
return true;
else
return false;
}
]
}), }),
'/profile/*': wrap({ '/profile/*': wrap({
component: ProfilePage, component: ProfilePage,
conditions: [ conditions: [checkLogin]
async(detail) => {
const user = await fetch('http://' + process.env.WEBSITE_HOST + ":" + process.env.WEBSITE_PORT + '/api/v2/user')
.then((resp) => resp.json())
console.log('in /profile/* what is in user')
console.log(user)
if (user && user.username)
return true;
else
return false;
}
]
}), }),
'/unauthorized-access': UnauthorizedAccessPage, '/unauthorized-access': UnauthorizedAccessPage,
'*': NotFound '*': NotFound