megaco_test_msg_v2_lib.erl

来自「OTP是开放电信平台的简称」· ERL 代码 · 共 1,969 行 · 第 1/5 页

		      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') and
       is_record(To, 'TerminationID') 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') and
       is_record(To, 'TerminationID') 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) when list(TermIDs), list(Descs) ->
    #'AmmRequest'{terminationID = TermIDs,
		  descriptors   = Descs}.

cre_AmmDescriptor(D) when is_record(D, 'MediaDescriptor') ->
    {mediaDescriptor, D};
cre_AmmDescriptor(D) when is_record(D, 'ModemDescriptor') ->
    {modemDescriptor, D};
cre_AmmDescriptor(D) when is_record(D, 'MuxDescriptor') ->
    {muxDescriptor, D};
cre_AmmDescriptor(D) when is_record(D, 'EventsDescriptor') ->
    {eventsDescriptor, D};
cre_AmmDescriptor(D) when is_record(D, 'DigitMapDescriptor') ->
    {digitMapDescriptor, D};
cre_AmmDescriptor(D) when is_record(D, 'AuditDescriptor') ->
    {auditDescriptor, D};
cre_AmmDescriptor(D) when is_list(D) ->
    case is_EventBufferDescriptor(D) of
	true ->
	    {eventBufferDescriptor, D};
	false ->
	    case is_SignalsDescriptor(D) of
		true ->
		    {signalsDescriptor, D};
		false ->
		    error({invalid_AmmDescriptor, D})
	    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_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(LCD, L, R) 
  when record(LCD, 'IndAudLocalControlDescriptor'),
       record(L, 'IndAudLocalRemoteDescriptor'),
       record(R, 'IndAudLocalRemoteDescriptor') ->
    #'IndAudStreamParms'{localControlDescriptor = LCD,
			 localDescriptor        = L,
			 remoteDescriptor       = R}.

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_IndAudPropertyParm(PkgdName) when list(PkgdName) ->
    #'IndAudPropertyParm'{name = PkgdName}.

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

cre_IndAudLocalRemoteDescriptor(GrpID, Grps) 
  when integer(GrpID), 0 =< GrpID, GrpID =< 65535, list(Grps) ->
    #'IndAudLocalRemoteDescriptor'{propGroupID = GrpID,
				   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_IndAudEventsDescriptor(PkgdName) 
  when list(PkgdName) ->
    #'IndAudEventsDescriptor'{pkgdName = PkgdName}.

cre_IndAudEventsDescriptor(RID, PkgdName) 
  when integer(RID), list(PkgdName) ->
    #'IndAudEventsDescriptor'{requestID = RID, pkgdName = PkgdName};
cre_IndAudEventsDescriptor(PkgdName, SID) 
  when list(PkgdName), integer(SID) ->
    #'IndAudEventsDescriptor'{pkgdName = PkgdName, streamID = SID}.

cre_IndAudEventsDescriptor(RID, PkgdName, SID) 
  when integer(RID), list(PkgdName), integer(SID)  ->
    #'IndAudEventsDescriptor'{requestID = RID, 
			      pkgdName  = PkgdName, 
			      streamID  = SID}.

cre_IndAudEventBufferDescriptor(EventName) when list(EventName) ->
    #'IndAudEventBufferDescriptor'{eventName = EventName}.

cre_IndAudEventBufferDescriptor(EventName, SID) 
  when list(EventName), integer(SID)  ->
    #'IndAudEventBufferDescriptor'{eventName = EventName, streamID = SID}.

cre_IndAudSignalsDescriptor(S) when record(S, 'IndAudSignal') ->
    {signal, S};
cre_IndAudSignalsDescriptor(S) when record(S, 'IndAudSeqSigList') ->
    {seqSigList, S}.

cre_IndAudSeqSigList(ID) when integer(ID), 0=< ID, ID =< 65535 ->
    #'IndAudSeqSigList'{id = ID}.

cre_IndAudSeqSigList(ID, S) 
  when integer(ID), 0=< ID, ID =< 65535,
       record(S, 'IndAudSignal') ->
    #'IndAudSeqSigList'{id = ID, signalList = S}.

cre_IndAudSignal(SigName) when list(SigName) ->
    #'IndAudSignal'{signalName = SigName}.

cre_IndAudSignal(SigName, SID) when list(SigName), integer(SID) ->
    #'IndAudSignal'{signalName = SigName, streamID = SID}.

cre_IndAudDigitMapDescriptor() ->
    #'IndAudDigitMapDescriptor'{}.

cre_IndAudDigitMapDescriptor(DMN) when list(DMN) ->
    #'IndAudDigitMapDescriptor'{digitMapName = DMN}.

cre_IndAudStatisticsDescriptor(StatName) when list(StatName) ->
    #'IndAudStatisticsDescriptor'{statName = StatName}.

cre_IndAudPackagesDescriptor(N, V) 
  when list(N), 
       integer(V), 0 =< V, V =< 99 ->
    #'IndAudPackagesDescriptor'{packageName    = N, 
				packageVersion = V}.

cre_NotifyRequest(TermIDs, D) 
  when list(TermIDs), record(D, 'ObservedEventsDescriptor') ->
    #'NotifyRequest'{terminationID            = TermIDs,
		     observedEventsDescriptor = D}.

cre_NotifyRequest(TermIDs, D, ED) 
  when list(TermIDs), 
       record(D, 'ObservedEventsDescriptor'),
       record(ED, 'ErrorDescriptor') ->
    #'NotifyRequest'{terminationID            = TermIDs,
		     observedEventsDescriptor = D,
		     errorDescriptor          = ED}.
    
cre_NotifyReply(TermIDs) when list(TermIDs) ->
    #'NotifyReply'{terminationID = TermIDs}.

cre_NotifyReply(TermIDs, ED) 
  when list(TermIDs), 
       record(ED, 'ErrorDescriptor') ->
    #'NotifyReply'{terminationID   = TermIDs,
		   errorDescriptor = ED}.

cre_ObservedEventsDescriptor(RID, [H|_] = L) 
  when integer(RID), record(H, 'ObservedEvent') ->
    #'ObservedEventsDescriptor'{requestId        = RID, 
				observedEventLst = L}.

cre_ObservedEvent(EN, EPL) when list(EN), list(EPL) ->
    #'ObservedEvent'{eventName    = EN, 
		     eventParList = EPL};
cre_ObservedEvent(EN, TN) when list(EN), record(TN, 'TimeNotation') ->
    #'ObservedEvent'{eventName    = EN, 
		     timeNotation = TN}.

cre_ObservedEvent(EN, SID, EPL) when list(EN), integer(SID), list(EPL) ->
    #'ObservedEvent'{eventName    = EN, 
		     streamID     = SID, 
		     eventParList = EPL};
cre_ObservedEvent(EN, EPL, TN) 
  when list(EN), list(EPL), record(TN, 'TimeNotation') ->
    #'ObservedEvent'{eventName    = EN, 
		     eventParList = EPL,
		     timeNotation = TN}.

cre_ObservedEvent(EN, SID, EPL, TN) 
  when list(EN), integer(SID), list(EPL), record(TN, 'TimeNotation') ->
    #'ObservedEvent'{eventName    = EN, 
		     streamID     = SID, 
		     eventParList = EPL,
		     timeNotation = TN}.

cre_EventName(N) when is_list(N) ->
    N.

cre_EventParameter(N, V) when list(N), list(V) ->