Skip to content

Commit

Permalink
feat: add MediasoupRoom
Browse files Browse the repository at this point in the history
  • Loading branch information
woody146 committed Jun 7, 2023
1 parent 2d808ad commit e4b00d1
Show file tree
Hide file tree
Showing 6 changed files with 36 additions and 2 deletions.
1 change: 1 addition & 0 deletions src/entities/index.ts
Original file line number Diff line number Diff line change
@@ -1 +1,2 @@
export * from './mediasoup.slave';
export * from './mediasoup.room';
19 changes: 19 additions & 0 deletions src/entities/mediasoup.room.ts
Original file line number Diff line number Diff line change
@@ -0,0 +1,19 @@
import {
Entity,
PrimaryGeneratedColumn,
BaseEntity,
CreateDateColumn,
Column,
} from 'typeorm';

@Entity()
export class MediasoupRoom extends BaseEntity {
@PrimaryGeneratedColumn('uuid')
id!: string;

@Column({ type: 'jsonb', nullable: true })
metadata?: any;

@CreateDateColumn()
createDate!: Date;
}
4 changes: 3 additions & 1 deletion src/index.ts
Original file line number Diff line number Diff line change
@@ -1 +1,3 @@
export {};
export * from './entities';
export * from './services';
export * from './constants';
1 change: 1 addition & 0 deletions src/services/index.ts
Original file line number Diff line number Diff line change
@@ -1 +1,2 @@
export * from './mediasoup.slave';
export * from './mediasoup.room';
11 changes: 11 additions & 0 deletions src/services/mediasoup.room.ts
Original file line number Diff line number Diff line change
@@ -0,0 +1,11 @@
import { MediasoupRoom } from '../entities';
import { BaseService } from './base';

export class MediasoupRoomService extends BaseService {
async add(data: { metadata?: any }) {
const mediasoupRoom = new MediasoupRoom();
Object.assign(mediasoupRoom, data);
await this.dataSource.getRepository(MediasoupRoom).save(mediasoupRoom);
return mediasoupRoom.id;
}
}
2 changes: 1 addition & 1 deletion src/services/mediasoup.slave.ts
Original file line number Diff line number Diff line change
Expand Up @@ -15,6 +15,6 @@ export class MediasoupSlaveService extends BaseService {
throw new Error('Invalid for param');
}
Object.assign(mediasoupSlave, data);
this.dataSource.getRepository(MediasoupSlave).save(mediasoupSlave);
return this.dataSource.getRepository(MediasoupSlave).save(mediasoupSlave);
}
}

0 comments on commit e4b00d1

Please sign in to comment.