%% %% Licensed to the Apache Software Foundation (ASF) under one %% or more contributor license agreements. See the NOTICE file %% distributed with this work for additional information %% regarding copyright ownership. The ASF licenses this file %% to you under the Apache License, Version 2.0 (the %% "License"); you may not use this file except in compliance %% with the License. You may obtain a copy of the License at %% %% http://www.apache.org/licenses/LICENSE-2.0 %% %% Unless required by applicable law or agreed to in writing, %% software distributed under the License is distributed on an %% "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY %% KIND, either express or implied. See the License for the %% specific language governing permissions and limitations %% under the License. %% -module(test_client). -export([start/0, start/1]). -include("thriftTest_types.hrl"). -record(options, {port = 9090, client_opts = []}). parse_args(Args) -> parse_args(Args, #options{}). parse_args([], Opts) -> Opts; parse_args([Head | Rest], Opts) -> NewOpts = case catch list_to_integer(Head) of Port when is_integer(Port) -> Opts#options{port = Port}; _Else -> case Head of "framed" -> Opts#options{client_opts = [{framed, true} | Opts#options.client_opts]}; "" -> Opts; _Else -> erlang:error({bad_arg, Head}) end end, parse_args(Rest, NewOpts). start() -> start([]). start(Args) -> #options{port = Port, client_opts = ClientOpts} = parse_args(Args), {ok, Client0} = thrift_client_util:new( "127.0.0.1", Port, thriftTest_thrift, ClientOpts), DemoXtruct = #xtruct{ string_thing = <<"Zero">>, byte_thing = 1, i32_thing = 9128361, i64_thing = 9223372036854775807}, DemoNest = #xtruct2{ byte_thing = 7, struct_thing = DemoXtruct, % Note that we don't set i32_thing, it will come back as undefined % from the Python server, but 0 from the C++ server, since it is not % optional i32_thing = 2}, % Is it safe to match these things? DemoDict = dict:from_list([ {Key, Key-10} || Key <- lists:seq(0,10) ]), DemoSet = sets:from_list([ Key || Key <- lists:seq(-3,3) ]), %DemoInsane = #insanity{ % userMap = dict:from_list([{?thriftTest_FIVE, 5000}]), % xtructs = [#xtruct{ string_thing = <<"Truck">>, byte_thing = 8, i32_thing = 8, i64_thing = 8}]}, {Client01, {ok, ok}} = thrift_client:call(Client0, testVoid, []), {Client02, {ok, <<"Test">>}} = thrift_client:call(Client01, testString, ["Test"]), {Client03, {ok, <<"Test">>}} = thrift_client:call(Client02, testString, [<<"Test">>]), {Client04, {ok, 63}} = thrift_client:call(Client03, testByte, [63]), {Client05, {ok, -1}} = thrift_client:call(Client04, testI32, [-1]), {Client06, {ok, 0}} = thrift_client:call(Client05, testI32, [0]), {Client07, {ok, -34359738368}} = thrift_client:call(Client06, testI64, [-34359738368]), {Client08, {ok, -5.2098523}} = thrift_client:call(Client07, testDouble, [-5.2098523]), {Client09, {ok, DemoXtruct}} = thrift_client:call(Client08, testStruct, [DemoXtruct]), {Client10, {ok, DemoNest}} = thrift_client:call(Client09, testNest, [DemoNest]), {Client11, {ok, DemoDict}} = thrift_client:call(Client10, testMap, [DemoDict]), {Client12, {ok, DemoSet}} = thrift_client:call(Client11, testSet, [DemoSet]), {Client13, {ok, [-1,2,3]}} = thrift_client:call(Client12, testList, [[-1,2,3]]), {Client14, {ok, 1}} = thrift_client:call(Client13, testEnum, [?thriftTest_ONE]), {Client15, {ok, 309858235082523}} = thrift_client:call(Client14, testTypedef, [309858235082523]), % No python implementation, but works with C++ and Erlang. %{Client16, {ok, InsaneResult}} = thrift_client:call(Client15, testInsanity, [DemoInsane]), %io:format("~p~n", [InsaneResult]), Client16 = Client15, {Client17, {ok, #xtruct{string_thing = <<"Message">>}}} = thrift_client:call(Client16, testMultiException, ["Safe", "Message"]), Client18 = try {ClientS1, Result1} = thrift_client:call(Client17, testMultiException, ["Xception", "Message"]), io:format("Unexpected return! ~p~n", [Result1]), ClientS1 catch throw:{ClientS2, {exception, ExnS1 = #xception{}}} -> #xception{errorCode = 1001, message = <<"This is an Xception">>} = ExnS1, ClientS2; throw:{ClientS2, {exception, _ExnS1 = #xception2{}}} -> io:format("Wrong exception type!~n", []), ClientS2 end, Client19 = try {ClientS3, Result2} = thrift_client:call(Client18, testMultiException, ["Xception2", "Message"]), io:format("Unexpected return! ~p~n", [Result2]), ClientS3 catch throw:{ClientS4, {exception, _ExnS2 = #xception{}}} -> io:format("Wrong exception type!~n", []), ClientS4; throw:{ClientS4, {exception, ExnS2 = #xception2{}}} -> #xception2{errorCode = 2002, struct_thing = #xtruct{ string_thing = <<"This is an Xception2">>}} = ExnS2, ClientS4 end, thrift_client:close(Client19).