megaco_test_msg_prev3c_lib.erl

OTP是开放电信平台的简称

    {Tag, Req};
cre_Command(serviceChangeReq = Tag, Req) 
  when record(Req, 'ServiceChangeRequest') ->
    {Tag, Req}.
    
cre_CommandReply(addReply = Tag, Rep) 
  when record(Rep, 'AmmsReply') ->
    {Tag, Rep};
cre_CommandReply(moveReply = Tag, Rep) 
  when record(Rep, 'AmmsReply') ->
    {Tag, Rep};
cre_CommandReply(modReply = Tag, Rep) 
  when record(Rep, 'AmmsReply') ->
    {Tag, Rep};
cre_CommandReply(subtractReply = Tag, Rep) 
  when record(Rep, 'AmmsReply') ->
    {Tag, Rep};
cre_CommandReply(auditCapReply = Tag, Rep) 
  when tuple(Rep) ->
    {Tag, Rep};
cre_CommandReply(auditValueReply = Tag, Rep) 
  when tuple(Rep) ->
    {Tag, Rep};
cre_CommandReply(notifyReply = Tag, Rep) 
  when record(Rep, 'NotifyReply') ->
    {Tag, Rep};
cre_CommandReply(serviceChangeReply = Tag, Rep) 
  when record(Rep, 'ServiceChangeReply') ->
    {Tag, Rep}.
    

%% -- TopologyRequest --

cre_TopologyRequest(From, To, TD) 
  when (is_record(From, 'TerminationID') or
	is_record(From, megaco_term_id)) and
       (is_record(To, 'TerminationID') or
	is_record(To, megaco_term_id)) and
       ((TD == bothway) or (TD == isolate) or (TD == oneway)) ->
    #'TopologyRequest'{terminationFrom   = From,
		       terminationTo     = To,
		       topologyDirection = TD};
cre_TopologyRequest(From, To, TDE) 
  when (is_record(From, 'TerminationID') or
	is_record(From, megaco_term_id)) and
       (is_record(To, 'TerminationID') or
	is_record(To, megaco_term_id)) and
       ((TDE == onewayexternal) or (TDE == onewayboth)) ->
    #'TopologyRequest'{terminationFrom            = From,
		       terminationTo              = To,
		       topologyDirection          = oneway, 
		       topologyDirectionExtension = TDE}.

cre_TopologyRequest(From, To, TD, SID) 
  when (is_record(From, 'TerminationID') or
	is_record(From, megaco_term_id)) and
       (is_record(To, 'TerminationID') or
	is_record(To, megaco_term_id)) and
       ((TD == bothway) or (TD == isolate) or (TD == oneway)) and
       (is_integer(SID)) ->
    #'TopologyRequest'{terminationFrom   = From,
		       terminationTo     = To,
		       topologyDirection = TD,
		       streamID          = SID};
cre_TopologyRequest(From, To, SID, TDE) 
  when (is_record(From, 'TerminationID') or
	is_record(From, megaco_term_id)) and
       (is_record(To, 'TerminationID') or
	is_record(To, megaco_term_id)) and
       (is_integer(SID)) and
       ((TDE == onewayexternal) or (TDE == onewayboth)) ->
    #'TopologyRequest'{terminationFrom            = From,
		       terminationTo              = To,
		       topologyDirection          = oneway, 
		       streamID                   = SID,
		       topologyDirectionExtension = TDE}.

cre_AmmRequest(TermIDs, Descs) ->
    d("cre_AmmRequest -> entry with"
      "~n   TermIDs: ~p"
      "~n   Descs:   ~p", [TermIDs, Descs]),
    case is_TerminationIDList(TermIDs) andalso 
	is_AmmRequest_descriptors(Descs) of
	true ->
	    #'AmmRequest'{terminationID = TermIDs,
			  descriptors   = Descs};
	false ->
	    error({invalid_AmmRequest, {TermIDs, Descs}})
    end.

cre_AmmDescriptor(D) when record(D, 'MediaDescriptor') ->
    {mediaDescriptor, D};
cre_AmmDescriptor(D) when record(D, 'ModemDescriptor') ->
    {modemDescriptor, D};
cre_AmmDescriptor(D) when record(D, 'MuxDescriptor') ->
    {muxDescriptor, D};
cre_AmmDescriptor(D) when record(D, 'EventsDescriptor') ->
    {eventsDescriptor, D};
cre_AmmDescriptor(D) when record(D, 'DigitMapDescriptor') ->
    {digitMapDescriptor, D};
cre_AmmDescriptor(D) when record(D, 'AuditDescriptor') ->
    {auditDescriptor, D};
cre_AmmDescriptor(D) when list(D) ->
    case is_EventBufferDescriptor(D) of
	true ->
	    {eventBufferDescriptor, D};
	false ->
	    case is_SignalsDescriptor(D) of
		true ->
		    {signalsDescriptor, D};
		false ->
		    case is_StatisticsDescriptor(D) of
			true ->
			    {statisticsDescriptor, D};
			false ->
			    error({invalid_AmmDescriptor, D})
		    end
	    end
    end.

cre_AmmsReply(TermIDs) when list(TermIDs) ->
    #'AmmsReply'{terminationID = TermIDs}.

cre_AmmsReply(TermIDs, TAs) when list(TermIDs), list(TAs) ->
    #'AmmsReply'{terminationID    = TermIDs, 
		 terminationAudit = TAs}.

cre_SubtractRequest(TermIDs) when list(TermIDs) ->
    #'SubtractRequest'{terminationID = TermIDs}.

cre_SubtractRequest(TermIDs, Audit) 
  when list(TermIDs), record(Audit, 'AuditDescriptor') ->
    #'SubtractRequest'{terminationID   = TermIDs, 
		       auditDescriptor = Audit}.

cre_AuditRequest(TermID, Audit) 
  when record(TermID, megaco_term_id), 
       record(Audit, 'AuditDescriptor') ->
    #'AuditRequest'{terminationID   = TermID, 
		    auditDescriptor = Audit}.

cre_AuditRequest(TID, Audit, [TID|_] = TIDs) 
  when is_record(TID, megaco_term_id) and  
       is_record(Audit, 'AuditDescriptor') ->
    #'AuditRequest'{terminationID     = TID, 
		    auditDescriptor   = Audit,
		    terminationIDList = TIDs}.

cre_AuditReply(TermIDs) when list(TermIDs) ->
    {contextAuditResult, TermIDs};
cre_AuditReply(ED) when record(ED, 'ErrorDescriptor') ->
    {error, ED};
cre_AuditReply(Audit) when record(Audit, 'AuditResult') ->
    {auditResult, Audit};
cre_AuditReply(ARTL) when record(ARTL, 'TermListAuditResult') ->
    {auditResultTermList, ARTL}.

cre_AuditResult(TID, TAs) 
  when record(TID, megaco_term_id), list(TAs) ->
    #'AuditResult'{terminationID          = TID, 
		   terminationAuditResult = TAs}.

cre_TermListAuditResult(TIDs, TA) 
  when is_list(TIDs) and is_list(TA) ->
    #'TermListAuditResult'{terminationIDList      = TIDs,
			   terminationAuditResult = TA}.
    
cre_TerminationAudit(D) ->
    true = is_TerminationAudit(D),
    D.

cre_AuditReturnParameter(D) when record(D, 'ErrorDescriptor') ->
    {errorDescriptor, D};
cre_AuditReturnParameter(D) when record(D, 'MediaDescriptor') ->
    {mediaDescriptor, D};
cre_AuditReturnParameter(D) when record(D, 'ModemDescriptor') ->
    {modemDescriptor, D};
cre_AuditReturnParameter(D) when record(D, 'MuxDescriptor') ->
    {muxDescriptor, D};
cre_AuditReturnParameter(D) when record(D, 'EventsDescriptor') ->
    {eventsDescriptor, D};
cre_AuditReturnParameter([H|_] = D) when record(H, 'EventSpec') ->
    {eventBufferDescriptor, D};
cre_AuditReturnParameter(D) when record(D, 'DigitMapDescriptor') ->
    {digitMapDescriptor, D};
cre_AuditReturnParameter(D) when record(D, 'ObservedEventsDescriptor') ->
    {observedEventsDescriptor, D};
cre_AuditReturnParameter([H|_] = D) when record(H, 'StatisticsParameter') ->
    {statisticsDescriptor, D};
cre_AuditReturnParameter([H|_] = D) when record(H, 'PackagesItem') ->
    {packagesDescriptor, D};
cre_AuditReturnParameter(D) when record(D, 'AuditDescriptor') ->
    {emptyDescriptors, D};
cre_AuditReturnParameter([H|_] = D) when tuple(H) ->
    {signalsDescriptor, D}.

cre_AuditDescriptor() ->
    #'AuditDescriptor'{}.

cre_AuditDescriptor([H|_] = AT) when atom(H) ->
    #'AuditDescriptor'{auditToken = AT};
cre_AuditDescriptor(APT) ->
    #'AuditDescriptor'{auditPropertyToken = APT}.

cre_AuditDescriptor(AT, APT) ->
    #'AuditDescriptor'{auditToken         = AT, 
		       auditPropertyToken = APT}.

cre_IndAuditParameter(D) when record(D, 'IndAudMediaDescriptor') ->
    {indAudMediaDescriptor, D};
cre_IndAuditParameter(D) when record(D, 'IndAudEventsDescriptor') ->
    {indAudEventsDescriptor, D};
cre_IndAuditParameter(D) when record(D, 'IndAudEventBufferDescriptor') ->
    {indAudEventBufferDescriptor, D};
cre_IndAuditParameter({signal, _} = D) ->
    {indAudSignalsDescriptor, D};
cre_IndAuditParameter({seqSigList, _} = D) ->
    {indAudSignalsDescriptor, D};
cre_IndAuditParameter(D) when record(D, 'IndAudDigitMapDescriptor') ->
    {indAudDigitMapDescriptor, D};
cre_IndAuditParameter(D) when record(D, 'IndAudStatisticsDescriptor') ->
    {indAudStatisticsDescriptor, D};
cre_IndAuditParameter(D) when record(D, 'IndAudPackagesDescriptor') ->
    {indAudPackagesDescriptor, D}.

cre_IndAudMediaDescriptor() ->
    #'IndAudMediaDescriptor'{}.

cre_IndAudMediaDescriptor(TSD) 
  when record(TSD, 'IndAudTerminationStateDescriptor') ->
    #'IndAudMediaDescriptor'{termStateDescr = TSD};
cre_IndAudMediaDescriptor(Parms) when record(Parms, 'IndAudStreamParms') ->
    Streams = {oneStream, Parms},
    #'IndAudMediaDescriptor'{streams = Streams};
cre_IndAudMediaDescriptor(Descs) when list(Descs) ->
    Streams = {multiStream, Descs},
    #'IndAudMediaDescriptor'{streams = Streams}.

cre_IndAudMediaDescriptor(TSD, Parms) 
  when record(TSD, 'IndAudTerminationStateDescriptor'),
       record(Parms, 'IndAudStreamParms') ->
    Streams = {oneStream, Parms},
    #'IndAudMediaDescriptor'{termStateDescr = TSD,
			     streams        = Streams};
cre_IndAudMediaDescriptor(TSD, Descs) 
  when record(TSD, 'IndAudTerminationStateDescriptor'), list(Descs) ->
    Streams = {multiStream, Descs},
    #'IndAudMediaDescriptor'{termStateDescr = TSD,
			     streams        = Streams}.

cre_IndAudStreamDescriptor(SID, Parms) 
  when integer(SID), record(Parms, 'IndAudStreamParms') ->
    #'IndAudStreamDescriptor'{streamID    = SID,
			      streamParms = Parms};
cre_IndAudStreamDescriptor(SID, Parms) ->
    error({invalid_IndAudStreamDescriptor, [SID, Parms]}).

cre_IndAudStreamParms() ->
    #'IndAudStreamParms'{}.

cre_IndAudStreamParms(LCD) when record(LCD, 'IndAudLocalControlDescriptor') ->
    #'IndAudStreamParms'{localControlDescriptor = LCD};
cre_IndAudStreamParms(SD) when record(SD, 'IndAudStatisticsDescriptor') ->
    #'IndAudStreamParms'{statisticsDescriptor = SD}.

cre_IndAudStreamParms(LC, L, R) 
  when record(LC, 'IndAudLocalControlDescriptor'),
       record(L,  'IndAudLocalRemoteDescriptor'),
       record(R,  'IndAudLocalRemoteDescriptor') ->
    #'IndAudStreamParms'{localControlDescriptor = LC,
			 localDescriptor        = L,
			 remoteDescriptor       = R}.

cre_IndAudStreamParms(LC, L, R, S) 
  when record(LC, 'IndAudLocalControlDescriptor'),
       record(L,  'IndAudLocalRemoteDescriptor'),
       record(R,  'IndAudLocalRemoteDescriptor'),
       record(S,  'IndAudStatisticsDescriptor') ->
    #'IndAudStreamParms'{localControlDescriptor = LC,
			 localDescriptor        = L,
			 remoteDescriptor       = R,
			 statisticsDescriptor   = S}.

cre_IndAudLocalControlDescriptor() ->
    #'IndAudLocalControlDescriptor'{}.

cre_IndAudLocalControlDescriptor(SM, RV, RG, PP) 
  when ((SM == 'NULL') or (SM == asn1_NOVALUE)) and
       ((RV == 'NULL') or (RV == asn1_NOVALUE)) and
       ((RG == 'NULL') or (RG == asn1_NOVALUE)) and
       (is_list(PP) or (PP == asn1_NOVALUE)) ->
    #'IndAudLocalControlDescriptor'{streamMode    = SM, 
				    reserveValue  = RV, 
				    reserveGroup  = RG, 
				    propertyParms = PP};
cre_IndAudLocalControlDescriptor(RV, RG, PP, SMS) 
  when ((RV == 'NULL') or (RV == asn1_NOVALUE)) and
       ((RG == 'NULL') or (RG == asn1_NOVALUE)) and
       (is_list(PP) or (PP == asn1_NOVALUE))    and
       is_atom(SMS) ->
    #'IndAudLocalControlDescriptor'{reserveValue  = RV, 
				    reserveGroup  = RG, 
				    propertyParms = PP,
				    streamModeSel = SMS}.

cre_IndAudLocalControlDescriptor(SM, RV, RG, PP, SMS) 
  when (SM == 'NULL') and 
       (is_atom(SMS) and (SMS =/= asn1_NOVALUE)) ->
    error({invalid_IndAudLocalControlDescriptor, [SM, RV, RG, PP, SMS]});
cre_IndAudLocalControlDescriptor(SM, RV, RG, PP, SMS) 
  when ((SM == 'NULL') or (SM == asn1_NOVALUE)) and 
       ((RV == 'NULL') or (RV == asn1_NOVALUE)) and
       ((RG == 'NULL') or (RG == asn1_NOVALUE)) and
       (is_list(PP)    or (PP == asn1_NOVALUE)) and
       is_atom(SMS) ->
    case is_StreamMode(SMS) of
	true ->
	    #'IndAudLocalControlDescriptor'{streamMode    = SM, 
					    reserveValue  = RV, 
					    reserveGroup  = RG, 
					    propertyParms = PP,
					    streamModeSel = SMS};
	false ->
	    error({invalid_IndAudLocalControlDescriptor, SMS})
    end.

cre_IndAudPropertyParm(PkgdName) when list(PkgdName) ->
    #'IndAudPropertyParm'{name = PkgdName}.

cre_IndAudPropertyParm(PkgdName, PP) 
  when is_list(PkgdName) and is_record(PP, 'PropertyParm') ->
    #'IndAudPropertyParm'{name = PkgdName, propertyParms = PP}.

cre_IndAudLocalRemoteDescriptor(Grps) 
  when list(Grps) ->
    #'IndAudLocalRemoteDescriptor'{propGrps = Grps}.

cre_IndAudLocalRemoteDescriptor(GID, Grps) 
  when is_integer(GID) and (0 =< GID) and (GID =< 65535) and is_list(Grps) ->
    #'IndAudLocalRemoteDescriptor'{propGroupID = GID,
				   propGrps    = Grps}.

cre_IndAudPropertyGroup([]) ->
    [];
cre_IndAudPropertyGroup([H|_] = PG) 
  when record(H, 'IndAudPropertyParm') ->
    PG.

cre_IndAudTerminationStateDescriptor([] = PP) ->
    #'IndAudTerminationStateDescriptor'{propertyParms = PP};
cre_IndAudTerminationStateDescriptor([H|_] = PP) 
  when record(H, 'IndAudPropertyParm') ->
    #'IndAudTerminationStateDescriptor'{propertyParms = PP}.

cre_IndAudTerminationStateDescriptor([] = PP, EBC, SS) 
  when ((EBC == 'NULL') or (EBC == asn1_NOVALUE)) and
       ((SS  == 'NULL') or (SS  == asn1_NOVALUE)) ->
    #'IndAudTerminationStateDescriptor'{propertyParms      = PP,
					eventBufferControl = EBC,
					serviceState       = SS};
cre_IndAudTerminationStateDescriptor([H|_] = PP, EBC, SS) 
  when is_record(H, 'IndAudPropertyParm') and
       ((EBC == 'NULL') or (EBC == asn1_NOVALUE)) and
       ((SS  == 'NULL') or (SS  == asn1_NOVALUE)) ->
    #'IndAudTerminationStateDescriptor'{propertyParms      = PP,
					eventBufferControl = EBC,
					serviceState       = SS}.

cre_IndAudTerminationStateDescriptor(PP, EBC, SS, SSS) 
  when (SS  == 'NULL') and
       ((is_atom(SSS) and (SSS =/= asn1_NOVALUE))) ->
    error({invalid_IndAudTerminationStateDescriptor, [PP, EBC, SS, SSS]});
cre_IndAudTerminationStateDescriptor([] = PP, EBC, SS, SSS) 
  when ((EBC == 'NULL') or (EBC == asn1_NOVALUE)) and
       ((SS  == 'NULL') or (SS  == asn1_NOVALUE)) and
       is_atom(SSS) ->
    #'IndAudTerminationStateDescriptor'{propertyParms      = PP,
					eventBufferControl = EBC,
					serviceState       = SS,
					serviceStateSel    = SSS};
cre_IndAudTerminationStateDescriptor([H|_] = PP, EBC, SS, SSS) 
  when is_record(H, 'IndAudPropertyParm') and
       ((EBC == 'NULL') or (EBC == asn1_NOVALUE)) and
       ((SS  == 'NULL') or (SS  == asn1_NOVALUE)) and
       is_atom(SSS) ->