3511529170

Build Type

github

Committed by GitHub

Commit Message

<a href="https://github.com/boostcampwm-2022/web03-FanUP/commit/<a class=hub.com/boostcampwm-2022/web03-FanUP/commit/b7c6ec3233e4d08b7ecef6cfb2e6baab8121d23a">b7c6ec323<a href="https://github.com/boostcampwm-2022/web03-FanUP/commit/b7c6ec3233e4d08b7ecef6cfb2e6baab8121d23a">">Merge </a><a class="double-link" href="https://github.com/boostcampwm-2022/web03-FanUP/commit/<a class="double-link" href="https://github.com/boostcampwm-2022/web03-FanUP/commit/49adcd4282fd458967be8462f610b434a41ee6c6">49adcd428</a>">49adcd428</a><a href="https://github.com/boostcampwm-2022/web03-FanUP/commit/b7c6ec3233e4d08b7ecef6cfb2e6baab8121d23a"> into 23f66de67">23f66de67</a>

Pull Request Pull Request #35: Refactor/#34 : Core 서비스로 리팩토링

Run Details

34 of 61 branches covered (55.74%)

Branch coverage included in aggregate %.

26 of 26 new or added lines in 8 files covered. (100.0%)

327 of 502 relevant lines covered (65.14%)

2.38 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/server/services/core/src/fanup/fanup.gateway.ts

import { Logger } from '@nestjs/common';
import {
  ConnectedSocket,
  OnGatewayConnection,
  OnGatewayDisconnect,
  OnGatewayInit,
  WebSocketGateway,
  WebSocketServer,
} from '@nestjs/websockets';
import { Namespace, Socket } from 'socket.io';

@WebSocketGateway(8080, {
  namespace: '/gateway',
})
class FanUPGateway
  implements OnGatewayInit, OnGatewayConnection, OnGatewayDisconnect
{
  private logger = new Logger('Gateway');

  @WebSocketServer()
  nsp: Namespace;

  // 초기화 실행
  afterInit() {
    this.nsp.adapter.on('create-room', (room) => {
      this.logger.log(`"Room:${room}"이 생성되었습니다.`);
    });
    this.nsp.adapter.on('join-room', (room, id) => {
      this.logger.log(`"Socket:${id}"이 "Room:${room}"에 참여하였습니다.`);
    });
    this.nsp.adapter.on('leave-room', (room, id) => {
      this.logger.log(`"Socket:${id}"이 "Room:${room}"에서 나갔습니다.`);
    });
    this.nsp.adapter.on('delete-room', (roomName) => {
      this.logger.log(`"Room:${roomName}"이 삭제되었습니다.`);
    });
    this.logger.log('웹소켓 서버 초기화 ✅');
  }

  // 소켓 연결이 생성되면
  handleConnection(@ConnectedSocket() socket: Socket, ...args: any[]) {
    const socketID = socket.id;

    socket.on('join_room', (roomName) => {
      console.log('gateway에서 옴', roomName);
      socket.join(roomName);
      socket.to(roomName).emit('welcome', socketID);
    });

    socket.on('offer', (offer, targetSocketID) => {
      socket.to(targetSocketID).emit('offer', offer, socketID);
    });

    socket.on('answer', (answer, targetSocketID) => {
      socket.to(targetSocketID).emit('answer', answer, socketID);
    });

    socket.on('ice', (ice, targetSocketID) => {
      socket.to(targetSocketID).emit('ice', ice, socketID);
    });

    socket.on('leave_room', (roomName) => {
      socket.leave(roomName);
      socket.to(roomName).emit('leave', socketID);
    });
  }

  // 소켓 연결이 끊기면 실행
  handleDisconnect(@ConnectedSocket() client: Socket) {}
}

export { FanUPGateway };

1	import { Logger } from '@nestjs/common';	×
2	import {	×
3	ConnectedSocket,
4	OnGatewayConnection,
5	OnGatewayDisconnect,
6	OnGatewayInit,
7	WebSocketGateway,
8	WebSocketServer,
9	} from '@nestjs/websockets';
10	import { Namespace, Socket } from 'socket.io';	×
11
12	@WebSocketGateway(8080, {
13	namespace: '/gateway',
14	})
15	class FanUPGateway	×
16	implements OnGatewayInit, OnGatewayConnection, OnGatewayDisconnect
17	{
18	private logger = new Logger('Gateway');	×
19
20	@WebSocketServer()	×
21	nsp: Namespace;
22
23	// 초기화 실행
24	afterInit() {
25	this.nsp.adapter.on('create-room', (room) => {	×
26	this.logger.log(`"Room:${room}"이 생성되었습니다.`);	×
27	});
28	this.nsp.adapter.on('join-room', (room, id) => {	×
29	this.logger.log(`"Socket:${id}"이 "Room:${room}"에 참여하였습니다.`);	×
30	});
31	this.nsp.adapter.on('leave-room', (room, id) => {	×
32	this.logger.log(`"Socket:${id}"이 "Room:${room}"에서 나갔습니다.`);	×
33	});
34	this.nsp.adapter.on('delete-room', (roomName) => {	×
35	this.logger.log(`"Room:${roomName}"이 삭제되었습니다.`);	×
36	});
37	this.logger.log('웹소켓 서버 초기화 ✅');	×
38	}
39
40	// 소켓 연결이 생성되면
41	handleConnection(@ConnectedSocket() socket: Socket, ...args: any[]) {	×
42	const socketID = socket.id;	×
43
44	socket.on('join_room', (roomName) => {	×
45	console.log('gateway에서 옴', roomName);	×
46	socket.join(roomName);	×
47	socket.to(roomName).emit('welcome', socketID);	×
48	});
49
50	socket.on('offer', (offer, targetSocketID) => {	×
51	socket.to(targetSocketID).emit('offer', offer, socketID);	×
52	});
53
54	socket.on('answer', (answer, targetSocketID) => {	×
55	socket.to(targetSocketID).emit('answer', answer, socketID);	×
56	});
57
58	socket.on('ice', (ice, targetSocketID) => {	×
59	socket.to(targetSocketID).emit('ice', ice, socketID);	×
60	});
61
62	socket.on('leave_room', (roomName) => {	×
63	socket.leave(roomName);	×
64	socket.to(roomName).emit('leave', socketID);	×
65	});
66	}
67
68	// 소켓 연결이 끊기면 실행
69	handleDisconnect(@ConnectedSocket() client: Socket) {}	×
70	}
71
72	export { FanUPGateway };	×

boostcampwm-2022 / web03-FanUP / 3511529170

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous