package org.elastos.Carrier;

import org.elastos.carrier.exceptions.ElastosException;
import org.elastos.carrier.session.*;

import java.util.HashMap;

public class FriendSessionStream {

    public static HashMap<String, FriendSessionStream> map = new HashMap<>();

    private String id;

    private Session session;
    private Stream stream;

    private StreamState state;
    private String sdp;

    public FriendSessionStream(String friendId){
        this.id = friendId;

        this.state = StreamState.Closed;
        this.sdp = null;
    }

    public String getId(){
        return this.id;
    }

    public void setSession(Session session){
        this.session = session;
    }

    public Session getSession(){
        return this.session;
    }

    public void setStream(Stream stream){
        this.stream = stream;
    }

    public Stream getStream(){
        return this.stream;
    }

    public int getStreamId(){
        return this.stream.getStreamId();
    }

    public void close(){
        // TODO

        try{
            this.session.removeStream(this.stream);
            this.session.close();
        }catch(ElastosException e){
            e.getStackTrace();
        }

        this.state = StreamState.Closed;
        FriendSessionStream.map.remove(this.id);
    }

    public void setState(StreamState state){
        this.state = state;
    }

    public StreamState getState() {
        return this.state;
    }

    public void setSdp(String sdp){
        this.sdp = sdp;
    }
    public String getSdp(){
        return this.sdp;
    }

    // static method
    public static FriendSessionStream getInstanceByStreamId(int streamId){
        FriendSessionStream rs = null;

        for(FriendSessionStream val : FriendSessionStream.map.values()){
            Stream stream = val.getStream();
            if(stream != null && val.getStreamId() == streamId){
                rs = val;
                break;
            }
        }

        return rs;
    }

    public static void closeAll(){
        for(FriendSessionStream val : FriendSessionStream.map.values()){
            val.close();
        }
    }
}