Room Service

var roomService = new sdk.RoomService(pcast);

roomService.start(role, screenName);

var self = roomService.getSelf();
 
self.getObservableScreenName.setValue('My New Screen Name');
 
// Commit changes to self if already in a room
self.commitChanges(function commitChangesCallback(error, response) {
  if (error) {
    // Handle error
  }
 
  if (response.status !== 'ok' && response.status !== 'not-in-room') {
    // Handle error
  }
 
  if (response.status === 'not-in-room') {
    // Changes not committed. Enter a room and the self model will automatically be committed.
  }
 
  if (response.status === 'ok') {
    // Successfully updated self
  }
});

var self = roomService.getSelf();
var selfStream = {
  uri: publisher.getStreamId(),
  type: 'User',
  audioState: 'TrackEnabled',
  videoState: 'TrackEnabled',
};
 
self.setStreams([selfStream]);

roomService.getRoomInfo(
  roomId,
  alias,
  function getRoomInfoCallback(error, response) {
    if (error) {
      // Handle error
    }
 
    if (response.status !== 'ok') {
      // Handle error
    }
 
    // Successfully got room info
    if (response.status === 'ok' && response.room) {
      // Do something with room
    }
  }
);

roomService.createRoom(room, function createRoomCallback(error, response) {
  if (error) {
    // Handle error
  }
 
  if (response.status === 'already-exists') {
    // No action required
  }
 
  if (response.status !== 'ok') {
    // Handle error
  }
 
  // Successfully created room
  if (response.status === 'ok' && response.room) {
    // Do something with room
  }
});

roomService.enterRoom(
  roomId,
  alias,
  function enterRoomCallback(error, response) {
    if (error) {
      // Handle error
    }
 
    if (response.status === 'not-found') {
      // Handle room not found - createRoom
    }
 
    if (response.status !== 'ok') {
      // Handle error
    }
 
    // Successfully entered room
    if (response.status === 'ok' && response.room) {
      // Do something with room model - now the active room
    }
  }
);

var observableActiveRoom = roomService.getObservableActiveRoom();
var activeRoom = observableActiveRoom.getValue();
var membersObservable = activeRoom.getObservableMembers();
var pcastStreamURIPrefix = 'pcast://phenixp2p.com/';
 
membersObservable.subscribe(function (members) {
  members.forEach(function (member) {
    var memberStreams = member.getObservableStreams().getValue();
 
    memberStreams.forEach(function (stream) {
      // Subscribe if its a PCast stream
      if (stream.uri.indexOf(pcastStreamURIPrefix) === 0) {
        var streamId = stream.uri.substring(
          pcastStreamURIPrefix.length,
          stream.uri.length
        );
 
        // subscribe with pcast.subscribe
      }
    });
  });
});

var room = roomService.getObservableActiveRoom().getValue();
 
room.getObservableDescription().setValue('My New Room Description');
 
// Commit changes to self if already in a room
room.commitChanges(function commitChangesCallback(error, response) {
  if (error) {
    // Handle error
  }
 
  if (response.status !== 'ok' && response.status !== 'not-in-room') {
    // Handle error
  }
 
  if (response.status === 'not-in-room') {
    // Changes not committed. Enter the room and then re-submit
  }
 
  if (response.status === 'ok') {
    // Successfully updated room
  }
});

roomService.leaveRoom(function leaveRoomCallback(error, response) {
  // No action required
});

const doNotForcefullyLeaveRoom = false;
 
roomService.leaveRoom(function leaveRoomCallback(error, response) {
  if (error) {
    // Handle error
  }
 
  if (response.status === 'not-in-room') {
    // Do nothing
  }
 
  if (response.status !== 'ok') {
    // Handle error
  }
 
  // Successfully left room
  if (response.status === 'ok') {
    // No action required
  }
}, doNotForcefullyLeaveRoom);