megaco_binary_encoder.erl

OTP是开放电信平台的简称

%% ``The contents of this file are subject to the Erlang Public License,
%% Version 1.1, (the "License"); you may not use this file except in
%% compliance with the License. You should have received a copy of the
%% Erlang Public License along with this software. If not, it can be
%% retrieved via the world wide web at http://www.erlang.org/.
%% 
%% Software distributed under the License is distributed on an "AS IS"
%% basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See
%% the License for the specific language governing rights and limitations
%% under the License.
%% 
%% The Initial Developer of the Original Code is Ericsson Utvecklings AB.
%% Portions created by Ericsson are Copyright 1999, Ericsson Utvecklings
%% AB. All Rights Reserved.''
%% 
%%     $Id$
%%
%%----------------------------------------------------------------------
%% Purpose : Handle ASN.1 BER encoding of Megaco/H.248
%%----------------------------------------------------------------------

-module(megaco_binary_encoder).

-behaviour(megaco_encoder).

%% API
-export([encode_message/3, decode_message/3,
	 decode_mini_message/3, 

	 encode_transaction/3,
	 encode_action_requests/3,
	 encode_action_request/3,
	 
	 version_of/2]).

%% Backward compatible functions:
-export([encode_message/2, decode_message/2]).

-include_lib("megaco/src/engine/megaco_message_internal.hrl").

-define(BIN_LIB, megaco_binary_encoder_lib).


%%----------------------------------------------------------------------
%% Convert a 'MegacoMessage' record into a binary
%% Return {ok, Binary} | {error, Reason}
%%----------------------------------------------------------------------

encode_message(EC, 
	       #'MegacoMessage'{mess = #'Message'{version = V}} = MegaMsg) ->
    encode_message(EC, V, MegaMsg).

encode_message([{version3,_}|EC], 1, MegaMsg) ->
    AsnMod   = megaco_ber_media_gateway_control_v1,
    TransMod = megaco_binary_transformer_v1,
    ?BIN_LIB:encode_message(EC, MegaMsg, AsnMod, TransMod, io_list);
encode_message(EC, 1, MegaMsg) ->
    AsnMod   = megaco_ber_media_gateway_control_v1,
    TransMod = megaco_binary_transformer_v1,
    ?BIN_LIB:encode_message(EC, MegaMsg, AsnMod, TransMod, io_list);
encode_message([{version3,_}|EC], 2, MegaMsg) ->
    AsnMod   = megaco_ber_media_gateway_control_v2,
    TransMod = megaco_binary_transformer_v2,
    ?BIN_LIB:encode_message(EC, MegaMsg, AsnMod, TransMod, io_list);
encode_message(EC, 2, MegaMsg) ->
    AsnMod   = megaco_ber_media_gateway_control_v2,
    TransMod = megaco_binary_transformer_v2,
    ?BIN_LIB:encode_message(EC, MegaMsg, AsnMod, TransMod, io_list);
encode_message([{version3,prev3c}|EC], 3, MegaMsg) ->
    AsnMod   = megaco_ber_media_gateway_control_prev3c,
    TransMod = megaco_binary_transformer_prev3c,
    ?BIN_LIB:encode_message(EC, MegaMsg, AsnMod, TransMod, io_list);
encode_message([{version3,prev3b}|EC], 3, MegaMsg) ->
    AsnMod   = megaco_ber_media_gateway_control_prev3b,
    TransMod = megaco_binary_transformer_prev3b,
    ?BIN_LIB:encode_message(EC, MegaMsg, AsnMod, TransMod, io_list);
encode_message([{version3,prev3a}|EC], 3, MegaMsg) ->
    AsnMod   = megaco_ber_media_gateway_control_prev3a,
    TransMod = megaco_binary_transformer_prev3a,
    ?BIN_LIB:encode_message(EC, MegaMsg, AsnMod, TransMod, io_list);
encode_message([{version3,v3}|EC], 3, MegaMsg) ->
    AsnMod   = megaco_ber_media_gateway_control_v3,
    TransMod = megaco_binary_transformer_v3,
    ?BIN_LIB:encode_message(EC, MegaMsg, AsnMod, TransMod, io_list);
encode_message(EC, 3, MegaMsg) ->
    AsnMod   = megaco_ber_media_gateway_control_v3,
    TransMod = megaco_binary_transformer_v3,
    ?BIN_LIB:encode_message(EC, MegaMsg, AsnMod, TransMod, io_list).


%%----------------------------------------------------------------------
%% Convert a transaction (or transactions in the case of ack) record(s) 
%% into a binary
%% Return {ok, Binary} | {error, Reason}
%%----------------------------------------------------------------------

encode_transaction([{version3,_}|EC], 1, Trans) ->
    AsnMod   = megaco_ber_media_gateway_control_v1,
    TransMod = megaco_binary_transformer_v1,
    ?BIN_LIB:encode_transaction(EC, Trans, AsnMod, TransMod, io_list);
encode_transaction(EC, 1, Trans) ->
    AsnMod   = megaco_ber_media_gateway_control_v1,
    TransMod = megaco_binary_transformer_v1,
    ?BIN_LIB:encode_transaction(EC, Trans, AsnMod, TransMod, io_list);
encode_transaction([{version3,_}|EC], 2, Trans) ->
    AsnMod   = megaco_ber_media_gateway_control_v2,
    TransMod = megaco_binary_transformer_v2,
    ?BIN_LIB:encode_transaction(EC, Trans, AsnMod, TransMod, io_list);
encode_transaction(EC, 2, Trans) ->
    AsnMod   = megaco_ber_media_gateway_control_v2,
    TransMod = megaco_binary_transformer_v2,
    ?BIN_LIB:encode_transaction(EC, Trans, AsnMod, TransMod, io_list);
encode_transaction([{version3,prev3c}|EC], 3, Trans) ->
    AsnMod   = megaco_ber_media_gateway_control_prev3c,
    TransMod = megaco_binary_transformer_prev3c,
    ?BIN_LIB:encode_transaction(EC, Trans, AsnMod, TransMod, io_list);
encode_transaction([{version3,prev3b}|EC], 3, Trans) ->
    AsnMod   = megaco_ber_media_gateway_control_prev3b,
    TransMod = megaco_binary_transformer_prev3b,
    ?BIN_LIB:encode_transaction(EC, Trans, AsnMod, TransMod, io_list);
encode_transaction([{version3,prev3a}|EC], 3, Trans) ->
    AsnMod   = megaco_ber_media_gateway_control_prev3a,
    TransMod = megaco_binary_transformer_prev3a,
    ?BIN_LIB:encode_transaction(EC, Trans, AsnMod, TransMod, io_list);
encode_transaction([{version3,v3}|EC], 3, Trans) ->
    AsnMod   = megaco_ber_media_gateway_control_v3,
    TransMod = megaco_binary_transformer_v3,
    ?BIN_LIB:encode_transaction(EC, Trans, AsnMod, TransMod, io_list);
encode_transaction(EC, 3, Trans) ->
    AsnMod   = megaco_ber_media_gateway_control_v3,
    TransMod = megaco_binary_transformer_v3,
    ?BIN_LIB:encode_transaction(EC, Trans, AsnMod, TransMod, io_list).


%%----------------------------------------------------------------------
%% Convert a list of ActionRequest record's into a binary
%% Return {ok, DeepIoList} | {error, Reason}
%%----------------------------------------------------------------------
encode_action_requests([{version3,_}|EC], 1, ActReqs) 
  when list(ActReqs) ->
    AsnMod   = megaco_ber_media_gateway_control_v1,
    TransMod = megaco_binary_transformer_v1,
    ?BIN_LIB:encode_action_requests(EC, ActReqs, AsnMod, TransMod, io_list);
encode_action_requests(EC, 1, ActReqs) when list(ActReqs) ->
    AsnMod   = megaco_ber_media_gateway_control_v1,
    TransMod = megaco_binary_transformer_v1,
    ?BIN_LIB:encode_action_requests(EC, ActReqs, AsnMod, TransMod, io_list);
encode_action_requests([{version3,_}|EC], 2, ActReqs) 
  when list(ActReqs) ->
    AsnMod   = megaco_ber_media_gateway_control_v2,
    TransMod = megaco_binary_transformer_v2,
    ?BIN_LIB:encode_action_requests(EC, ActReqs, AsnMod, TransMod, io_list);
encode_action_requests(EC, 2, ActReqs) when list(ActReqs) ->
    AsnMod   = megaco_ber_media_gateway_control_v2,
    TransMod = megaco_binary_transformer_v2,
    ?BIN_LIB:encode_action_requests(EC, ActReqs, AsnMod, TransMod, io_list);
encode_action_requests([{version3,prev3c}|EC], 3, ActReqs) 
  when list(ActReqs) ->
    AsnMod   = megaco_ber_media_gateway_control_prev3c,
    TransMod = megaco_binary_transformer_prev3c,
    ?BIN_LIB:encode_action_requests(EC, ActReqs, AsnMod, TransMod, io_list);
encode_action_requests([{version3,prev3b}|EC], 3, ActReqs) 
  when list(ActReqs) ->
    AsnMod   = megaco_ber_media_gateway_control_prev3b,
    TransMod = megaco_binary_transformer_prev3b,
    ?BIN_LIB:encode_action_requests(EC, ActReqs, AsnMod, TransMod, io_list);
encode_action_requests([{version3,prev3a}|EC], 3, ActReqs) 
  when list(ActReqs) ->
    AsnMod   = megaco_ber_media_gateway_control_prev3a,
    TransMod = megaco_binary_transformer_prev3a,
    ?BIN_LIB:encode_action_requests(EC, ActReqs, AsnMod, TransMod, io_list);
encode_action_requests([{version3,v3}|EC], 3, ActReqs) 
  when list(ActReqs) ->
    AsnMod   = megaco_ber_media_gateway_control_v3,
    TransMod = megaco_binary_transformer_v3,
    ?BIN_LIB:encode_action_requests(EC, ActReqs, AsnMod, TransMod, io_list);
encode_action_requests(EC, 3, ActReqs) when list(ActReqs) ->
    AsnMod   = megaco_ber_media_gateway_control_v3,
    TransMod = megaco_binary_transformer_v3,
    ?BIN_LIB:encode_action_requests(EC, ActReqs, AsnMod, TransMod, io_list).


%%----------------------------------------------------------------------
%% Convert a ActionRequest record into a binary
%% Return {ok, DeepIoList} | {error, Reason}
%%----------------------------------------------------------------------
encode_action_request([{version3,_}|EC], 1, ActReq) ->
    AsnMod   = megaco_ber_media_gateway_control_v1,
    TransMod = megaco_binary_transformer_v1,
    ?BIN_LIB:encode_action_request(EC, ActReq, AsnMod, TransMod, io_list);
encode_action_request(EC, 1, ActReq) ->
    AsnMod   = megaco_ber_media_gateway_control_v1,
    TransMod = megaco_binary_transformer_v1,
    ?BIN_LIB:encode_action_request(EC, ActReq, AsnMod, TransMod, io_list);
encode_action_request([{version3,_}|EC], 2, ActReq) ->
    AsnMod   = megaco_ber_media_gateway_control_v2,
    TransMod = megaco_binary_transformer_v2,
    ?BIN_LIB:encode_action_request(EC, ActReq, AsnMod, TransMod, io_list);
encode_action_request(EC, 2, ActReq) ->
    AsnMod   = megaco_ber_media_gateway_control_v2,
    TransMod = megaco_binary_transformer_v2,
    ?BIN_LIB:encode_action_request(EC, ActReq, AsnMod, TransMod, io_list);
encode_action_request([{version3,prev3c}|EC], 3, ActReq) ->
    AsnMod   = megaco_ber_media_gateway_control_prev3c,
    TransMod = megaco_binary_transformer_prev3c,
    ?BIN_LIB:encode_action_request(EC, ActReq, AsnMod, TransMod, io_list);
encode_action_request([{version3,prev3b}|EC], 3, ActReq) ->
    AsnMod   = megaco_ber_media_gateway_control_prev3b,
    TransMod = megaco_binary_transformer_prev3b,
    ?BIN_LIB:encode_action_request(EC, ActReq, AsnMod, TransMod, io_list);
encode_action_request([{version3,prev3a}|EC], 3, ActReq) ->
    AsnMod   = megaco_ber_media_gateway_control_prev3a,
    TransMod = megaco_binary_transformer_prev3a,
    ?BIN_LIB:encode_action_request(EC, ActReq, AsnMod, TransMod, io_list);
encode_action_request([{version3,v3}|EC], 3, ActReq) ->
    AsnMod   = megaco_ber_media_gateway_control_v3,
    TransMod = megaco_binary_transformer_v3,
    ?BIN_LIB:encode_action_request(EC, ActReq, AsnMod, TransMod, io_list);
encode_action_request(EC, 3, ActReq) ->
    AsnMod   = megaco_ber_media_gateway_control_v3,
    TransMod = megaco_binary_transformer_v3,
    ?BIN_LIB:encode_action_request(EC, ActReq, AsnMod, TransMod, io_list).


%%----------------------------------------------------------------------
%% Detect (check) which version a message is
%% Return {ok, Version} | {error, Reason}
%%----------------------------------------------------------------------

version_of([{version3,prev3c},driver|EC], Binary) ->
    Decoders = [megaco_ber_bin_drv_media_gateway_control_v1,
		megaco_ber_bin_drv_media_gateway_control_v2,
		megaco_ber_bin_drv_media_gateway_control_prev3c],
    ?BIN_LIB:version_of(EC, Binary, dynamic, Decoders);
version_of([{version3,prev3b},driver|EC], Binary) ->
    Decoders = [megaco_ber_bin_drv_media_gateway_control_v1,
		megaco_ber_bin_drv_media_gateway_control_v2,
		megaco_ber_bin_drv_media_gateway_control_prev3b],
    ?BIN_LIB:version_of(EC, Binary, dynamic, Decoders);
version_of([{version3,prev3a},driver|EC], Binary) ->
    Decoders = [megaco_ber_bin_drv_media_gateway_control_v1,
		megaco_ber_bin_drv_media_gateway_control_v2,
		megaco_ber_bin_drv_media_gateway_control_prev3a],
    ?BIN_LIB:version_of(EC, Binary, dynamic, Decoders);
version_of([{version3,v3},driver|EC], Binary) ->
    Decoders = [megaco_ber_bin_drv_media_gateway_control_v1,
		megaco_ber_bin_drv_media_gateway_control_v2,
		megaco_ber_bin_drv_media_gateway_control_v3],
    ?BIN_LIB:version_of(EC, Binary, dynamic, Decoders);
version_of([driver|EC], Binary) ->
    Decoders = [megaco_ber_bin_drv_media_gateway_control_v1,
		megaco_ber_bin_drv_media_gateway_control_v2,
		megaco_ber_bin_drv_media_gateway_control_v3],
    ?BIN_LIB:version_of(EC, Binary, dynamic, Decoders);
version_of([{version3,prev3b}|EC], Binary) ->
    Decoders = [megaco_ber_bin_media_gateway_control_v1,
		megaco_ber_bin_media_gateway_control_v2,
		megaco_ber_bin_media_gateway_control_prev3b],
    ?BIN_LIB:version_of(EC, Binary, dynamic, Decoders);
version_of([{version3,prev3a}|EC], Binary) ->
    Decoders = [megaco_ber_bin_media_gateway_control_v1,
		megaco_ber_bin_media_gateway_control_v2,
		megaco_ber_bin_media_gateway_control_prev3a],
    ?BIN_LIB:version_of(EC, Binary, dynamic, Decoders);
version_of([{version3,v3}|EC], Binary) ->
    Decoders = [megaco_ber_bin_media_gateway_control_v1,
		megaco_ber_bin_media_gateway_control_v2,
		megaco_ber_bin_media_gateway_control_v3],
    ?BIN_LIB:version_of(EC, Binary, dynamic, Decoders);
version_of(EC, Binary) ->
    Decoders = [megaco_ber_bin_media_gateway_control_v1,
		megaco_ber_bin_media_gateway_control_v2,
		megaco_ber_bin_media_gateway_control_v3],
    ?BIN_LIB:version_of(EC, Binary, dynamic, Decoders).

	    
%%----------------------------------------------------------------------
%% Convert a binary into a 'MegacoMessage' record
%% Return {ok, MegacoMessageRecord} | {error, Reason}
%%----------------------------------------------------------------------

decode_message(EC, Binary) ->
    decode_message(EC, 1, Binary).

decode_message([{version3,prev3c},driver|EC], dynamic, Binary) ->