yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

chore: verify status code

This commit is contained in:
Dennis Zhuang 2024-03-25 10:05:39 -07:00
parent ef0fee52f4
commit 64eeeb7494
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
apps/emqx_bridge_greptimedb/test/emqx_bridge_greptimedb_SUITE.erl
View File

@ -324,7 +324,7 @@ query_by_clientid(Topic, ClientId, Config) ->
{"Content-Type", "application/x-www-form-urlencoded"} {"Content-Type", "application/x-www-form-urlencoded"}
], ],
Body = <<"sql=select * from \"", Topic/binary, "\" where clientid='", ClientId/binary, "'">>, Body = <<"sql=select * from \"", Topic/binary, "\" where clientid='", ClientId/binary, "'">>,
{ok, _, _Headers, RawBody0} = {ok, StatusCode, _Headers, RawBody0} =
ehttpc:request( ehttpc:request(
EHttpcPoolName, EHttpcPoolName,
post, post,
@ -343,12 +343,12 @@ query_by_clientid(Topic, ClientId, Config) ->
} }
} }
] ]
} -> } when StatusCode >= 200 andalso StatusCode =< 300 ->
make_row(Schema, Rows); make_row(Schema, Rows);
#{ #{
<<"code">> := Code, <<"code">> := Code,
<<"error">> := Error <<"error">> := Error
} -> } when StatusCode > 300 ->
GreptimedbName = ?config(greptimedb_name, Config), GreptimedbName = ?config(greptimedb_name, Config),
Type = greptimedb_type_bin(?config(greptimedb_type, Config)), Type = greptimedb_type_bin(?config(greptimedb_type, Config)),
BridgeId = emqx_bridge_resource:bridge_id(Type, GreptimedbName), BridgeId = emqx_bridge_resource:bridge_id(Type, GreptimedbName),
@ -366,7 +366,9 @@ query_by_clientid(Topic, ClientId, Config) ->
_ -> _ ->
%% Table not found %% Table not found
#{} #{}
end end;
Error ->
{error, Error}
end. end.
make_row(null, _Rows) -> make_row(null, _Rows) ->