/*

 *  Copyright (C) 2020, University of the Basque Country (UPV/EHU)

 *
 * Contact for licensing options: <licensing-mcpttclient(at)mcopenplatform(dot)com>
 *
 * This file is part of MCOP MCPTT Client
 *
 * This is free software: you can redistribute it and/or modify it under the terms of
 * the GNU General Public License as published by the Free Software Foundation, either version 3
 * of the License, or (at your option) any later version.
 *
 * This is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY;
 * without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
 * See the GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License along
 * with this program; if not, write to the Free Software Foundation, Inc.,
 * 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
 */
 
 package org.doubango.ngn.sip;
 
 import android.content.Context;
 import android.util.Log;
 
 import org.doubango.ngn.BuildConfig;
 import org.doubango.ngn.NgnEngine;
 import org.doubango.ngn.utils.NgnObservableHashMap;
 import org.doubango.tinyWRAP.ActionConfig;
 import org.doubango.tinyWRAP.PublicationAffiliationSession;
 import org.doubango.tinyWRAP.SipSession;
 import org.doubango.utils.Utils;
 
 public class MyPublicationAffiliationSession extends NgnSipSession {
 	private final static String TAG = Utils.getTAG(MyPublicationAffiliationSession.class.getCanonicalName());
 
 	private final PublicationAffiliationSession mSession;
 
 	private final static NgnObservableHashMap<Long, MyPublicationAffiliationSession> sSessions = new NgnObservableHashMap<Long, MyPublicationAffiliationSession>(
 			true);
 
 	public static MyPublicationAffiliationSession createOutgoingSession(
 			NgnSipStack sipStack, String toUri) {
 		synchronized (sSessions) {
 			final MyPublicationAffiliationSession pubSession = new MyPublicationAffiliationSession(
 					sipStack, toUri);
 			sSessions.put(pubSession.getId(), pubSession);
 			return pubSession;
 		}
 	}
 
 	public static void releaseSession(MyPublicationAffiliationSession session) {
 		synchronized (sSessions) {
 			if (session != null && sSessions.containsKey(session.getId())) {
 				long id = session.getId();
 				session.decRef();
 				sSessions.remove(id);
 			}
 		}
 	}
 
 	public static void releaseSession(long id) {
 		synchronized (sSessions) {
 			MyPublicationAffiliationSession session = MyPublicationAffiliationSession
 					.getSession(id);
 			if (session != null) {
 				session.decRef();
 				sSessions.remove(id);
 			}
 		}
 	}
 
 	public static MyPublicationAffiliationSession getSession(long id) {
 		synchronized (sSessions) {
 			if (sSessions.containsKey(id))
 				return sSessions.get(id);
 			else
 				return null;
 		}
 	}
 
 	public static int getSize() {
 		synchronized (sSessions) {
 			return sSessions.size();
 		}
 	}
 
 	public static boolean hasSession(long id) {
 		synchronized (sSessions) {
 			return sSessions.containsKey(id);
 		}
 	}
 
 	protected MyPublicationAffiliationSession(NgnSipStack sipStack, String toUri) {
 		super(sipStack);
 		mSession = new PublicationAffiliationSession(sipStack);
 
 		super.init();
 		super.setSigCompId(sipStack.getSigCompId());
 		super.setToUri(toUri);
 		super.setFromUri(toUri);
 
 		// default
 		//mSession.addHeader("Event", "presence");
 	}
 
 	@Override
 	protected SipSession getSession() {
 		return mSession;
 	}
 
 	public boolean setEvent(String event) {
 		return mSession.addHeader("Event", event);
 	}
 
 	public boolean setContentType(String contentType) {
 		return mSession.addHeader("Content-Type", contentType);
 	}
 
 	public boolean publish(byte[] bytes, String event, String contentType, Context context) {
 		if (bytes != null) {
 			NgnSipPrefrences profileNow= NgnEngine.getInstance().getProfilesService().getProfileNow(context);
 			if(profileNow!=null && !mSipStack.setMCPTTPSIAffiliation(profileNow.getMcpttPsiAffiliation())){
 				Log.e(TAG,"Error configuration PSI for affiliation");
 			}
 
 			if(BuildConfig.DEBUG && bytes!=null){
 				String stringDataSendPublish=new String(bytes);
 				Log.w(TAG,"PUBLISH: event->"+event+" contentType->"+contentType);
 				String lines[] = Utils.stringToArray(stringDataSendPublish);
 				for(String line:lines)Log.w(TAG,line);
 
 			}
 
 			Log.d(TAG,"Start publish of Affiliation");
 			final java.nio.ByteBuffer byteBuffer = java.nio.ByteBuffer.allocateDirect(bytes.length);
 			byteBuffer.put(bytes);
 			ActionConfig config = new ActionConfig();
 			final boolean ret = mSession.publish(byteBuffer, byteBuffer.capacity(), config);
 			config.delete();
 			if(ret){
 				Log.d(TAG,"Publish OK.");
 			}else{
 				Log.d(TAG,"Publish Failed.");
 			}
 			return ret;
 		}
 		else{
 			Log.e(TAG, "Null content");
 		}
 		return false;
 	}
 
 	public boolean unPublish(byte[] bytes, String event, String contentType, Context context) {
 		boolean ret;
 		if (bytes != null) {
 			NgnSipPrefrences profileNow= NgnEngine.getInstance().getProfilesService().getProfileNow(context);
 			if(profileNow!=null && !mSipStack.setMCPTTPSIAffiliation(profileNow.getMcpttPsiAffiliation())){
 				Log.e(TAG,"Error configuration PSI for affiliation.");
 			}
 			final java.nio.ByteBuffer byteBuffer = java.nio.ByteBuffer.allocateDirect(bytes.length);
 			byteBuffer.put(bytes);
 			ActionConfig config = new ActionConfig();
 			ret = mSession.unPublish(byteBuffer, byteBuffer.capacity(), config);
 			config.delete();
 			return ret;
 		}
 		else{
 			Log.d(TAG, "Null content");
 			ActionConfig config = new ActionConfig();
 			final java.nio.ByteBuffer byteBuffer = java.nio.ByteBuffer.allocateDirect(0);
 
 			ret = mSession.unPublish(byteBuffer, byteBuffer.capacity(), config);
 			config.delete();
 		}
 		return ret;
 	}
 	
 	public boolean publish(byte[] bytes, Context context) {
 		return publish(bytes, null, null,context);
 	}
 	public boolean unPublish(byte[] bytes, Context context) {
 		Log.d(TAG,"Send unpublish.");
 		return unPublish(bytes, null, null, context);
 	}
 
 }