Room Service

import PhenixSdk
 
let pcast: PhenixPCast = ...  // previously obtained
let roomService = PhenixRoomServiceFactory.createRoomService(pcast)!

import PhenixSdk
 
let roomService: PhenixRoomService = ...  // previously obtained
let selfMember = roomService.getSelf()
 
selfMember.getObservableScreenName().setValue("My New Screen Name")
selfMember.getObservableRole().setValue(NSNumber.init(value: PhenixMemberRole.audience.rawValue))
 
// Commit changes to self if already in a room
selfMember.commitChanges({ (status: PhenixRequestStatus, message: String?) in
    if status == .ok {
      // Successfully updated self
    } else {
      // Handle error
    }
  })

import PhenixSdk
 
let roomService: PhenixRoomService = ...  // previously obtained
let selfMember = roomService.getSelf()
 
selfMember.getObservableScreenName().setValue("My New Screen Name")
selfMember.getObservableRole().setValue(NSNumber.init(value: PhenixMemberRole.audience.rawValue))
 
// Decided to undo changes
selfMember.reload()

import PhenixSdk
 
let roomService: PhenixRoomService = ...  // previously obtained
let selfMember = roomService.getSelf()
 
let selfStream = roomService.createStream("http://myuri.stream", .user, .enabled, .enabled)
 
selfMember.getObservableStreams().setValue([selfStream!])
 
// Now commit changes

import PhenixSdk
 
let roomService: PhenixRoomService = ...  // previously obtained
 
// Either provide alias or roomId, other can be nil or empty
let roomId = "us-central#demo#exampleRoomId"
let alias: String? = nil
 
roomService.getRoomInfo(
    roomId,
    alias,
    { (roomService: PhenixRoomService?, status: PhenixRequestStatus, room: PhenixRoom?) in
      if status == .ok {
        // Do something with room
      } else {
        // Handle error
      }
    })

import PhenixSdk
 
let roomService: PhenixRoomService = ...  // previously obtained
 
let roomName = "My Room Name"
let description = "Deep thoughts only"
 
let roomOptions = PhenixRoomServiceFactory.createRoomOptionsBuilder()
    .withName(roomName)
    .withDescription(description)
    .withType(.multiPartyChat)
    .buildRoomOptions()
 
roomService.createRoom(
    roomOptions,
    { (roomService: PhenixRoomService?, status: PhenixRequestStatus, room: PhenixRoom?) in
      if status == .ok {
        // Do something with room
      } else {
        // Handle error
      }
    })

import PhenixSdk
 
let roomService: PhenixRoomService = ...  // previously obtained
 
// Need to provide either room ID or alias (other can be nil)
let roomId: String? = nil
let alias = "exampleRoom"
 
roomService.joinRoom(
    roomId,
    alias,
    { (roomService: PhenixRoomService?, status: PhenixRequestStatus, room: PhenixRoom?) in
      if status == .ok {
        // Do something with room
      } else {
        // Handle error
      }
    })

import PhenixSdk
 
let roomService: PhenixRoomService = ...  // previously obtained
 
let observableActiveRoom = roomService.getObservableActiveRoom()!
 
// For this simple example, we assume that there is an active room, hence we can force un-wrap.
// In a production environment, this can return nil if we have not currently joined a room. In that case
// you would want to listen as a subscriber on the 'observableActiveRoom' for updates
let activeRoom = observableActiveRoom.getValue()!
let observableMembers = activeRoom.getObservableMembers()!
 
let subscription = observableMembers.subscribe({ (change) in
  let currentMembers = change?.value as! [PhenixMember]
  for member in currentMembers {
    let currentStreams = member.getObservableStreams().getValue() as! [PhenixStream]
    // Now do something with this member's streams
  }
})
 
// The subscription will remain active for as long as 'subscription' is kept alive

import PhenixSdk
 
let roomService: PhenixRoomService = ...  // previously obtained
 
let room = roomService.getObservableActiveRoom().getValue()!
 
room.getObservableDescription().setValue("My New Room Description")
room.commitChanges({ (status: PhenixRequestStatus, message: String?) in
    if status == .ok {
      // Successfully updated room
    } else {
      // Handle error
    }
  })

import PhenixSdk
 
let roomService: PhenixRoomService = ...  // previously obtained
 
roomService.leaveRoom({ (roomService: PhenixRoomService?, status: PhenixRequestStatus) in
    if status == .ok {
      // Successfully left room, no action required
    } else {
      // Handle error
    }
  })

import PhenixSdk
 
let roomService: PhenixRoomService = ...  // previously obtained
 
roomService.destroyRoom({ (roomService: PhenixRoomService?, status: PhenixRequestStatus) in
    if status == .ok {
      // Successfully destroyed room, no action required
    } else {
      // Handle error
    }
  })

import PhenixSdk
 
let room: PhenixImmutableRoom = ...  // previously obtained
 
let disposable = room.getObservableEstimatedSize().subscribe(
    { (change: PhenixObservableChange<NSNumber>?) in
      let currentEstimatedRoomSize =  change?.value.uintValue
      // E.g. update UI
    })