megaco_test_msg_prev3a_lib.erl

OTP是开放电信平台的简称

       ((Ieps == true) or (Ieps == false)) ->
    CR = #'ContextRequest'{priority       = Prio,
			   emergency      = Em,
			   topologyReq    = Top,
			   iepsCallind    = Ieps},
    strip_ContextRequest(CR);
cre_ContextRequest(Prio, Em, Top, Ctx) 
  when ((is_integer(Prio) and (0 =< Prio) and (Prio =< 15)) or 
	(Prio == asn1_NOVALUE)) and 
       ((Em == true) or (Em == false) or (Em == asn1_NOVALUE)) and
       (is_list(Top) or (Top == asn1_NOVALUE)) and
       (is_list(Ctx)) ->
    CR = #'ContextRequest'{priority    = Prio,
			   emergency   = Em,
			   topologyReq = Top,
			   contextProp = Ctx},
    strip_ContextRequest(CR).

cre_ContextRequest(Prio, Em, Top, Ieps, Ctx) 
  when ((is_integer(Prio) and (0 =< Prio) and (Prio =< 15)) or 
	(Prio == asn1_NOVALUE)) and 
       ((Em == true) or (Em == false) or (Em == asn1_NOVALUE)) and
       (is_list(Top) or (Top == asn1_NOVALUE)) and
       ((Ieps == true) or (Ieps == false) or (Ieps == asn1_NOVALUE)) and
       (is_list(Ctx) or (Ctx == asn1_NOVALUE)) ->
    CR = #'ContextRequest'{priority    = Prio,
			   emergency   = Em,
			   topologyReq = Top,
			   iepsCallind = Ieps,
			   contextProp = Ctx},
    strip_ContextRequest(CR).

strip_ContextRequest(#'ContextRequest'{priority    = asn1_NOVALUE,
				       emergency   = asn1_NOVALUE,
				       topologyReq = asn1_NOVALUE,
				       iepsCallind = asn1_NOVALUE,
				       contextProp = asn1_NOVALUE}) ->
    asn1_NOVALUE;
strip_ContextRequest(#'ContextRequest'{priority    = asn1_NOVALUE,
				       emergency   = asn1_NOVALUE,
				       topologyReq = Top,
				       iepsCallind = Ieps,
				       contextProp = Prop} = CR) ->
    case (((Top  == [])    or (Top  == asn1_NOVALUE)) and
	  ((Ieps == false) or (Ieps == asn1_NOVALUE)) and
	  ((Prop == [])    or (Prop == asn1_NOVALUE))) of
	true ->
	    asn1_NOVALUE;
	false ->
	    CR
    end;
strip_ContextRequest(CR) ->
    CR.

cre_ContextAttrAuditRequest() ->
    strip_ContextAttrAuditRequest(#'ContextAttrAuditRequest'{}).

cre_ContextAttrAuditRequest(Top, Em, Prio) 
  when ((Top  == 'NULL') or (Top  == asn1_NOVALUE)) and
       ((Em   == 'NULL') or (Em   == asn1_NOVALUE)) and
       ((Prio == 'NULL') or (Prio == asn1_NOVALUE)) ->
    CAAR = #'ContextAttrAuditRequest'{topology  = Top,
				      emergency = Em,
				      priority  = Prio},
    strip_ContextAttrAuditRequest(CAAR).

cre_ContextAttrAuditRequest(Top, Em, Prio, Ieps) 
  when ((Top  == 'NULL') or (Top  == asn1_NOVALUE)) and
       ((Em   == 'NULL') or (Em   == asn1_NOVALUE)) and
       ((Prio == 'NULL') or (Prio == asn1_NOVALUE)) and
       ((Ieps == 'NULL') or (Ieps == asn1_NOVALUE)) ->
    CAAR = #'ContextAttrAuditRequest'{topology    = Top,
				      emergency   = Em,
				      priority    = Prio,
				      iepsCallind = Ieps},
    strip_ContextAttrAuditRequest(CAAR).

cre_ContextAttrAuditRequest(Top, Em, Prio, Ieps, Ctx) 
  when ((Top  == 'NULL') or (Top  == asn1_NOVALUE)) and
       ((Em   == 'NULL') or (Em   == asn1_NOVALUE)) and
       ((Prio == 'NULL') or (Prio == asn1_NOVALUE)) and
       ((Ieps == 'NULL') or (Ieps == asn1_NOVALUE)) and
       (is_list(Ctx)     or (Ctx == asn1_NOVALUE)) ->
    CAAR = #'ContextAttrAuditRequest'{topology       = Top,
				      emergency      = Em,
				      priority       = Prio,
				      iepsCallind    = Ieps,
				      contextPropAud = Ctx},
    strip_ContextAttrAuditRequest(CAAR).

strip_ContextAttrAuditRequest(
  #'ContextAttrAuditRequest'{topology       = asn1_NOVALUE,
			     emergency      = asn1_NOVALUE,
			     priority       = asn1_NOVALUE,
			     iepsCallind    = asn1_NOVALUE,
			     contextPropAud = asn1_NOVALUE}) ->
    asn1_NOVALUE;
strip_ContextAttrAuditRequest(
  #'ContextAttrAuditRequest'{topology       = asn1_NOVALUE,
			     emergency      = asn1_NOVALUE,
			     priority       = asn1_NOVALUE,
			     iepsCallind    = asn1_NOVALUE,
			     contextPropAud = []}) ->
    asn1_NOVALUE;
strip_ContextAttrAuditRequest(CAAR) ->
    CAAR.

cre_CommandRequest(Cmd) ->
    #'CommandRequest'{command = Cmd}.

cre_CommandRequest(Cmd, Opt) 
  when ((Opt == 'NULL') or (Opt == asn1_NOVALUE)) ->
    #'CommandRequest'{command  = Cmd,
		      optional = Opt}.

cre_CommandRequest(Cmd, Opt, WR) 
  when ((Opt == 'NULL') or (Opt == asn1_NOVALUE)) and 
       ((WR  == 'NULL') or (WR  == asn1_NOVALUE)) ->
    #'CommandRequest'{command        = Cmd,
		      optional       = Opt,
		      wildcardReturn = WR}.

cre_Command(addReq = Tag, Req) 
  when record(Req, 'AmmRequest') ->
    {Tag, Req};
cre_Command(moveReq = Tag, Req) 
  when record(Req, 'AmmRequest') ->
    {Tag, Req};
cre_Command(modReq = Tag, Req) 
  when record(Req, 'AmmRequest') ->
    {Tag, Req};
cre_Command(subtractReq = Tag, Req) 
  when record(Req, 'SubtractRequest') ->
    {Tag, Req};
cre_Command(auditCapRequest = Tag, Req) 
  when record(Req, 'AuditRequest') ->
    {Tag, Req};
cre_Command(auditValueRequest = Tag, Req) 
  when record(Req, 'AuditRequest') ->
    {Tag, Req};
cre_Command(notifyReq = Tag, Req) 
  when record(Req, 'NotifyRequest') ->
    {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}.
    
cre_TopologyRequest(From, To, Dir) 
  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
       ((Dir == bothway) or (Dir == isolate) or (Dir == oneway)) ->
    #'TopologyRequest'{terminationFrom   = From,
		       terminationTo     = To,
		       topologyDirection = Dir}.

cre_TopologyRequest(From, To, Dir, 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
       ((Dir == bothway) or (Dir == isolate) or (Dir == oneway)) and
       (is_integer(SID) or (SID == asn1_NOVALUE)) ->
    #'TopologyRequest'{terminationFrom   = From,
		       terminationTo     = To,
		       topologyDirection = Dir,
		       streamID          = SID}.

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_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_AuditResult(TermID, TAs) 
  when record(TermID, megaco_term_id), list(TAs) ->
    #'AuditResult'{terminationID          = TermID, 
		   terminationAuditResult = TAs}.

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_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}.