/*
*
* 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.mcopenplatform.muoapi.managerIapi;
import android.content.ComponentName;
import android.content.Context;
import android.content.Intent;
import android.os.IBinder;
import android.os.Message;
import android.os.RemoteException;
import android.util.Log;
import org.doubango.ngn.NgnEngine;
import org.mcopenplatform.muoapi.BuildConfig;
import java.util.HashMap;
import java.util.Map;
public class ManagerMBMSGroupCom extends ManagerIapiBase
implements
org.doubango.ngn.services.mbms.IMyMbmsService.MbmsExternalServiceListener ,
org.doubango.ngn.services.mbms.IMyMbmsService.OnMbmsListener
{
private final static String TAG = org.mcopenplatform.muoapi.utils.Utils.getTAG(ManagerMBMSGroupCom.class.getCanonicalName());
private final org.mcopenplatform.iapi.IMBMSGroupCommListener.Stub mMBMSGroupComListener;
private OnManagerMBMSGroupComListener onManagerMBMSGroupComListener;
public enum StatusTMGI{
NONE,
AVAILABLE,
UNAVAILABLE
}
private Map<Long,StatusTMGI> statusTMGIMap;
protected String ORIGIN_PACKET_MAIN_SERVICE=null;
protected String ORIGIN_PACKET_SERVICE=null;
protected String PACKET_MAIN_SERVICE="com.expway.embmsserver";
protected String PACKET_SERVICE="com.expway.embmsserver.MCOP";
private org.doubango.ngn.services.mbms.IMyMbmsService mbmsService;
public ManagerMBMSGroupCom() {
super();
ORIGIN_PACKET_MAIN_SERVICE=String.valueOf(this.PACKET_MAIN_SERVICE);
ORIGIN_PACKET_SERVICE=String.valueOf(this.PACKET_SERVICE);
mMBMSGroupComListener= new org.mcopenplatform.iapi.IMBMSGroupCommListener.Stub() {
/*
@Override
public void notifySaiList(int[] sai) throws RemoteException {
if(BuildConfig.DEBUG){
String stringData="";
for(int saI:sai)stringData=stringData+";"+saI;
Log.d(TAG,"notifySAIList: "+stringData);
}
//TODO: Should check if any available for this group of TMGI SAIs
}
*/
/*
@Override
public void notifySAIList(int[] SAI) throws RemoteException {
if(BuildConfig.DEBUG){
String stringData="";
for(int saI:SAI)stringData=stringData+";"+saI;
Log.d(TAG,"notifySAIList: "+stringData);
}
//TODO: Should check if any available for this group of TMGI SAIs
}
*/
@Override
public void notifySaiList(int[] sai) throws RemoteException {
if(BuildConfig.DEBUG){
String stringData="";
for(int saI:sai)stringData=stringData+";"+saI;
Log.d(TAG,"notifySAIList: "+stringData);
}
//TODO: Should check if any available for this group of TMGI SAIs
}
@Override
public void notifyCellInfo(int MCC, int MNC, int ECI) throws RemoteException {
if(BuildConfig.DEBUG){
Log.d(TAG,"notifyCellInfo: MCC->"+MCC+" MNC->"+MNC+" ECI->"+ECI);
}
}
@Override
public void notifyMBMSGroupCommAvailability(long TMGI, int available, int goodQuality) throws RemoteException {
notifyMBMSGroupCommAvailabilityMCOP( TMGI, available, goodQuality);
}
@Override
public void notifyOpenMBMSGroupCommResult(long TMGI, int result, String netInterfaceName) throws RemoteException {
if(BuildConfig.DEBUG){
Log.d(TAG,"notifyOpenMBMSGroupCommResult: TMGI->"+TMGI+" result->"+result+" netInterfaceName->"+netInterfaceName);
}
if(result>=0){
if(BuildConfig.DEBUG){
Log.d(TAG,"notifyOpenMBMSGroupCommResult: result is ok");
}
mbmsService.onChangeServiceArea(mbmsService.getSais(TMGI),mContext);
mbmsService.startMbmsManager(netInterfaceName,TMGI);
}
}
@Override
public void notifyCloseMBMSGroupCommResult(long TMGI, int result) throws RemoteException {
if(BuildConfig.DEBUG){
Log.d(TAG,"notifyCloseMBMSGroupCommResult: TMGI->"+TMGI+" result->"+result);
if(result>0){
if(BuildConfig.DEBUG){
Log.d(TAG,"notifyCloseMBMSGroupCommResult: result is ok");
}
mbmsService.stopMbmsManager(TMGI);
}
}
}
};
statusTMGIMap=new HashMap<>();
}
@Override
protected void isServiceConnected() {
}
private void notifyMBMSGroupCommAvailabilityMCOP(long TMGI, int available, int goodQuality){
if(BuildConfig.DEBUG){
Log.d(TAG,"notifyMBMSGroupCommAvailability: TMGI->"+TMGI+" available->"+available+" goodQuality->"+goodQuality);
}
StatusTMGI statusTMGI;
if(TMGI>0 &&
(mbmsService.getMbmsDataOfTmgi(TMGI))!=null &&
(statusTMGI=statusTMGIMap.get(TMGI))!=null){
if(available>=0){
statusTMGI=(StatusTMGI.AVAILABLE);
}else{
statusTMGI=(StatusTMGI.UNAVAILABLE);
}
switch (statusTMGI) {
case AVAILABLE:
if(BuildConfig.DEBUG)Log.d(TAG,"notifyMBMSGroupCommAvailability Status: AVAILABLE");
try {
if(mService!=null){
int[] sais=null;
sais= mbmsService.getSais(TMGI);
int[] frequencies=null;
frequencies=mbmsService.getFrequencies(TMGI);
if(BuildConfig.DEBUG){
String saiString="";
if(sais!=null && sais.length>0)
for(int sai:sais)saiString=saiString+" "+sai;
String freString="";
if(frequencies!=null && frequencies.length>0)
for(int fre:frequencies)freString=freString+" "+fre;
Log.i(TAG,"AVAILABLE TMGI with SAIs: "+sais.length+" frequencies:"+freString );
}
((org.mcopenplatform.iapi.IMBMSGroupComm)mService).openGroupComm(TMGI,
sais,frequencies);
}
} catch (RemoteException e) {
if(BuildConfig.DEBUG)Log.e(TAG,"Error in openGroupComm in ManagerMBMSGroupCom:"+e.getMessage());
}catch (Exception e) {
if(BuildConfig.DEBUG)Log.e(TAG,"Error in openGroupComm in ManagerMBMSGroupCom:"+e.getMessage());
}
break;
case UNAVAILABLE:
if(BuildConfig.DEBUG)Log.d(TAG,"notifyMBMSGroupCommAvailability status: UNAVAILABLE");
case NONE:
break;
}
}else{
Log.e(TAG,"Now, we don´t have this TMGI");
}
}
@Override
protected void startInternal() {
mbmsService= NgnEngine.getInstance().getMbmsService();
mbmsService.setMbmsExternalServiceListener(this);
mbmsService.setOnMbmsListener(this);
}
@Override
protected void stopInternal() {
//Test
stopServer(mContext);
}
//Test
protected void stopServer(Context context) {
Log.d(TAG,"Stopping MBMS SERVER.");
String mMspPackageName = "com.expway.embmsserver";
try {
ComponentName component = new ComponentName( getPACKET_MAIN_SERVICE(),getPACKET_SERVICE());
Intent explicitIntent = new Intent();
explicitIntent.setComponent(component);
Intent intent = explicitIntent;
if (intent != null) {
boolean isStop = context.stopService(intent);
if (!isStop) {
Log.e(TAG, "eMBMS Service not found!");
} else {
Log.v(TAG, "Stopping Service...");
}
} else {
Log.e(TAG, "Could not get explicit intent to eMBMS Service.");
}
} catch (Exception e) {
Log.e(TAG, "Error stopping the eMBMS Service intent.");
}
}
@Override
protected Object registerInterface(IBinder service) {
org.mcopenplatform.iapi.IMBMSGroupComm imbmsGroupCom = org.mcopenplatform.iapi.IMBMSGroupComm.Stub.asInterface(service);
Log.d(TAG,"Register notification in "+getPACKET_SERVICE());
try {
(imbmsGroupCom).registerApplication(mMBMSGroupComListener);
} catch (RemoteException e) {
if(BuildConfig.DEBUG)Log.e(TAG,"Error in registerApplication in ManagerMBMSGroupCom:"+e.getMessage());
}catch (Exception e) {
if(BuildConfig.DEBUG)Log.e(TAG,"Error in registerApplication in ManagerMBMSGroupCom:"+e.getMessage());
}
return imbmsGroupCom;
}
@Override
protected boolean receiveEvent(Message message) {
if(BuildConfig.DEBUG)
Log.d(TAG,"Execute receiveEvent in "+getPACKET_SERVICE()+": what: "+message.what);
return false;
}
/**
* It allows to distinguish between the different PACKET_SERVICE for each of the extended class of ManagerIapiBase
* @return PACKET_SERVICE constant
*/
@Override
protected String getPACKET_SERVICE() {
return PACKET_SERVICE;
}
@Override
protected String getPACKET_MAIN_SERVICE() {
return PACKET_MAIN_SERVICE;
}
@Override
protected void setPACKET_SERVICE(String packetService) {
changedPacket=true;
PACKET_SERVICE = packetService;
}
@Override
protected void setPACKET_MAIN_SERVICE(String packetMainService) {
changedPacket=true;
PACKET_MAIN_SERVICE = packetMainService;
}
@Override
protected boolean checkChangedPacket(){
return changedPacket &&
(ORIGIN_PACKET_MAIN_SERVICE.compareTo(PACKET_MAIN_SERVICE)!=0 ||
ORIGIN_PACKET_SERVICE.compareTo(PACKET_SERVICE)!=0) ;
}
//START EXTERNAL MBMS
@Override
public void startedClient(boolean status) {
//TODO:
}
@Override
public void startedServer(boolean status) {
//TODO:
}
@Override
public void startMbmsMedia(long sessionID,long tmgi){
if(sessionID<=0 || tmgi<=0){
if(BuildConfig.DEBUG)Log.e(TAG,"Error in event startMbmsMedia");
return;
}
if(onManagerMBMSGroupComListener!=null)onManagerMBMSGroupComListener.startMbmsMedia(Long.toString(sessionID),Long.toString(tmgi));
}
@Override
public boolean mbmsListeningServiceAreaCurrent(long TMGI, int[] sai, int[] frequencies) {
//TODO:
return false;
}
@Override
public void stopMbmsMedia(long sessionID,long tmgi){
if(sessionID<=0 || tmgi<=0){
if(BuildConfig.DEBUG)Log.e(TAG,"Error in event stopMbmsMedia");
return;
}
if (mService != null){
try {
if(BuildConfig.DEBUG)
Log.d(TAG,"closeGroupComm tmgi: "+tmgi);
((org.mcopenplatform.iapi.IMBMSGroupComm)mService).closeGroupComm(tmgi);
} catch (RemoteException e) {
if(BuildConfig.DEBUG)Log.e(TAG,"Error in closeGroupComm in ManagerMBMSGroupCom:"+e.getMessage());
}catch (Exception e) {
if(BuildConfig.DEBUG)Log.e(TAG,"Error in closeGroupComm in ManagerMBMSGroupCom:"+e.getMessage());
}
}
if(onManagerMBMSGroupComListener!=null)onManagerMBMSGroupComListener.stopMbmsMedia(Long.toString(sessionID),Long.toString(tmgi));
}
@Override
public void stopServiceMBMS() {
if(BuildConfig.DEBUG)Log.i(TAG,"Execute stopServiceMBMS");
//TODO: incorrect
//Test
for(long tmgi:statusTMGIMap.keySet()){
if (mService != null) {
try {
if(BuildConfig.DEBUG)
Log.d(TAG,"closeGroupComm tmgi: "+tmgi);
((org.mcopenplatform.iapi.IMBMSGroupComm)mService).closeGroupComm(tmgi);
if(onManagerMBMSGroupComListener!=null)onManagerMBMSGroupComListener.stopMbmsMedia(null,Long.toString(tmgi));
} catch (RemoteException e) {
if(BuildConfig.DEBUG)Log.e(TAG,"Error in closeGroupComm in ManagerMBMSGroupCom:"+e.getMessage());
}catch (Exception e) {
if(BuildConfig.DEBUG)Log.e(TAG,"Error in closeGroupComm in ManagerMBMSGroupCom:"+e.getMessage());
}
try {
if(BuildConfig.DEBUG)
Log.d(TAG,"stopMBMSGroupCommMonitoring tmgi: "+tmgi);
((org.mcopenplatform.iapi.IMBMSGroupComm) mService).stopMBMSGroupCommMonitoring(tmgi);
} catch (RemoteException e) {
if (BuildConfig.DEBUG)
Log.e(TAG, "Error in stopMBMSGroupCommMonitoring in ManagerMBMSGroupCom:" + e.getMessage());
} catch (Exception e) {
if (BuildConfig.DEBUG)
Log.e(TAG, "Error in stopMBMSGroupCommMonitoring in ManagerMBMSGroupCom:" + e.getMessage());
}
}
}
}
@Override
public void onNewServiceArea(long TMGI, int[] sai, int[] frequencies, long QCI) {
if(BuildConfig.DEBUG){
String sias="";
for(int sai1:sai)sias=sias+" "+sai1;
Log.i(TAG,"onNewServiceArea TMGI: "+TMGI+" sais: "+sias);
}
if(frequencies==null)frequencies=new int[0];
if(statusTMGIMap!=null && statusTMGIMap.get(TMGI)==null)
statusTMGIMap.put(TMGI,StatusTMGI.NONE);
try {
if(mService!=null){
if(QCI<=0)QCI=0;
((org.mcopenplatform.iapi.IMBMSGroupComm)mService).startMBMSGroupCommMonitoring(TMGI,
sai,
frequencies,
(((QCI>=Integer.MAX_VALUE || QCI<=Integer.MIN_VALUE))?Integer.MAX_VALUE:(int)QCI));
}else {
if(BuildConfig.DEBUG)Log.e(TAG,"Error in service MBMS");
}
} catch (RemoteException e) {
if(BuildConfig.DEBUG)Log.e(TAG,"Error in startMBMSGroupCommMonitoring in ManagerMBMSGroupCom:"+e.getMessage());
}catch (Exception e) {
if(BuildConfig.DEBUG)Log.e(TAG,"Error in startMBMSGroupCommMonitoring in ManagerMBMSGroupCom:"+e.getMessage());
}
if(checkChangedPacket()){
if(BuildConfig.DEBUG)Log.d(TAG,"The packet selection is changed");
}
//TODO: receive new TMGI
}
public interface OnManagerMBMSGroupComListener{
void startMbmsMedia(String sessionID,String tmgi);
void stopMbmsMedia(String sessionID,String tmgi);
}
public void setOnManagerMBMSGroupComListener(OnManagerMBMSGroupComListener onManagerMBMSGroupComListener){
this.onManagerMBMSGroupComListener=onManagerMBMSGroupComListener;
}
}