-module(oadr3@operations).
-compile([no_auto_import, nowarn_unused_vars, nowarn_unused_function, nowarn_nomatch, inline]).
-define(FILEPATH, "src/oadr3/operations.gleam").
-export([delete_ven_request/2, delete_ven_response/1, update_ven_request/3, update_ven_response/1, search_ven_by_id_request/2, search_ven_by_id_response/1, create_ven_request/2, create_ven_response/1, search_vens_request/5, search_vens_response/1, delete_subscription_request/2, delete_subscription_response/1, update_subscription_request/3, update_subscription_response/1, search_subscription_by_id_request/2, search_subscription_by_id_response/1, create_subscription_request/2, create_subscription_response/1, search_subscriptions_request/6, search_subscriptions_response/1, delete_ven_resource_request/2, delete_ven_resource_response/1, update_ven_resource_request/3, update_ven_resource_response/1, search_ven_resource_by_id_request/2, search_ven_resource_by_id_response/1, create_resource_request/2, create_resource_response/1, search_ven_resources_request/6, search_ven_resources_response/1, delete_report_request/2, delete_report_response/1, update_report_request/3, update_report_response/1, search_reports_by_report_id_request/2, search_reports_by_report_id_response/1, create_report_request/2, create_report_response/1, search_all_reports_request/6, search_all_reports_response/1, delete_program_request/2, delete_program_response/1, update_program_request/3, update_program_response/1, search_program_by_program_id_request/2, search_program_by_program_id_response/1, create_program_request/2, create_program_response/1, search_all_programs_request/4, search_all_programs_response/1, list_all_mqtt_notifier_topics_ven_resources_request/2, list_all_mqtt_notifier_topics_ven_resources_response/1, list_all_mqtt_notifier_topics_ven_programs_request/2, list_all_mqtt_notifier_topics_ven_programs_response/1, list_all_mqtt_notifier_topics_ven_events_request/2, list_all_mqtt_notifier_topics_ven_events_response/1, list_all_mqtt_notifier_topics_ven_request/2, list_all_mqtt_notifier_topics_ven_response/1, list_all_mqtt_notifier_topics_vens_request/1, list_all_mqtt_notifier_topics_vens_response/1, list_all_mqtt_notifier_topics_subscriptions_request/1, list_all_mqtt_notifier_topics_subscriptions_response/1, list_all_mqtt_notifier_topics_resources_request/1, list_all_mqtt_notifier_topics_resources_response/1, list_all_mqtt_notifier_topics_reports_request/1, list_all_mqtt_notifier_topics_reports_response/1, list_all_mqtt_notifier_topics_program_events_request/2, list_all_mqtt_notifier_topics_program_events_response/1, list_all_mqtt_notifier_topics_program_request/2, list_all_mqtt_notifier_topics_program_response/1, list_all_mqtt_notifier_topics_programs_request/1, list_all_mqtt_notifier_topics_programs_response/1, list_all_mqtt_notifier_topics_events_request/1, list_all_mqtt_notifier_topics_events_response/1, list_all_notifiers_request/1, list_all_notifiers_response/1, delete_event_request/2, delete_event_response/1, update_event_request/3, update_event_response/1, search_events_by_id_request/2, search_events_by_id_response/1, create_event_request/2, create_event_response/1, search_all_events_request/6, search_all_events_response/1, fetch_token_request/1, fetch_token_response/1, get_auth_server_info_request/1, get_auth_server_info_response/1]).
-file("src/oadr3/operations.gleam", 12).
-spec delete_ven_request(gleam@http@request:request(JFH), binary()) -> gleam@http@request:request(JFH).
delete_ven_request(Base, Ven_id) ->
Method = delete,
Path = <<"/vens/"/utf8, Ven_id/binary>>,
Query = [],
_pipe = Base,
_pipe@1 = oadr3@utils:set_method(_pipe, Method),
_pipe@2 = oadr3@utils:append_path(_pipe@1, Path),
oadr3@utils:set_query(_pipe@2, Query).
-file("src/oadr3/operations.gleam", 22).
-spec delete_ven_response(gleam@http@response:response(bitstring())) -> {ok,
{ok, {oadr3@schema:object_metadata(), oadr3@schema:bl_ven_request()}} |
{error, gleam@http@response:response(bitstring())}} |
{error, gleam@json:decode_error()}.
delete_ven_response(Response) ->
{response, Status, _, Body} = Response,
case Status of
200 ->
_pipe = gleam@json:parse_bits(Body, oadr3@schema:ven_decoder()),
gleam@result:map(_pipe, fun(Field@0) -> {ok, Field@0} end);
_ ->
_pipe@1 = Response,
_pipe@2 = {error, _pipe@1},
{ok, _pipe@2}
end.
-file("src/oadr3/operations.gleam", 30).
-spec update_ven_request(
gleam@http@request:request(any()),
binary(),
oadr3@utils:any_()
) -> gleam@http@request:request(bitstring()).
update_ven_request(Base, Ven_id, Data) ->
Method = put,
Path = <<"/vens/"/utf8, Ven_id/binary>>,
Query = [],
Body = oadr3@utils:json_to_bits(oadr3@schema:ven_request_encode(Data)),
_pipe = Base,
_pipe@1 = oadr3@utils:set_method(_pipe, Method),
_pipe@2 = oadr3@utils:append_path(_pipe@1, Path),
_pipe@3 = oadr3@utils:set_query(_pipe@2, Query),
oadr3@utils:set_body(_pipe@3, <<"application/json"/utf8>>, Body).
-file("src/oadr3/operations.gleam", 42).
-spec update_ven_response(gleam@http@response:response(bitstring())) -> {ok,
{ok, {oadr3@schema:object_metadata(), oadr3@schema:bl_ven_request()}} |
{error, gleam@http@response:response(bitstring())}} |
{error, gleam@json:decode_error()}.
update_ven_response(Response) ->
{response, Status, _, Body} = Response,
case Status of
200 ->
_pipe = gleam@json:parse_bits(Body, oadr3@schema:ven_decoder()),
gleam@result:map(_pipe, fun(Field@0) -> {ok, Field@0} end);
_ ->
_pipe@1 = Response,
_pipe@2 = {error, _pipe@1},
{ok, _pipe@2}
end.
-file("src/oadr3/operations.gleam", 50).
-spec search_ven_by_id_request(gleam@http@request:request(JGT), binary()) -> gleam@http@request:request(JGT).
search_ven_by_id_request(Base, Ven_id) ->
Method = get,
Path = <<"/vens/"/utf8, Ven_id/binary>>,
Query = [],
_pipe = Base,
_pipe@1 = oadr3@utils:set_method(_pipe, Method),
_pipe@2 = oadr3@utils:append_path(_pipe@1, Path),
oadr3@utils:set_query(_pipe@2, Query).
-file("src/oadr3/operations.gleam", 60).
-spec search_ven_by_id_response(gleam@http@response:response(bitstring())) -> {ok,
{ok, {oadr3@schema:object_metadata(), oadr3@schema:bl_ven_request()}} |
{error, gleam@http@response:response(bitstring())}} |
{error, gleam@json:decode_error()}.
search_ven_by_id_response(Response) ->
{response, Status, _, Body} = Response,
case Status of
200 ->
_pipe = gleam@json:parse_bits(Body, oadr3@schema:ven_decoder()),
gleam@result:map(_pipe, fun(Field@0) -> {ok, Field@0} end);
_ ->
_pipe@1 = Response,
_pipe@2 = {error, _pipe@1},
{ok, _pipe@2}
end.
-file("src/oadr3/operations.gleam", 68).
-spec create_ven_request(gleam@http@request:request(any()), oadr3@utils:any_()) -> gleam@http@request:request(bitstring()).
create_ven_request(Base, Data) ->
Method = post,
Path = <<"/vens"/utf8>>,
Query = [],
Body = oadr3@utils:json_to_bits(oadr3@schema:ven_request_encode(Data)),
_pipe = Base,
_pipe@1 = oadr3@utils:set_method(_pipe, Method),
_pipe@2 = oadr3@utils:append_path(_pipe@1, Path),
_pipe@3 = oadr3@utils:set_query(_pipe@2, Query),
oadr3@utils:set_body(_pipe@3, <<"application/json"/utf8>>, Body).
-file("src/oadr3/operations.gleam", 80).
-spec create_ven_response(gleam@http@response:response(bitstring())) -> {ok,
{ok, {oadr3@schema:object_metadata(), oadr3@schema:bl_ven_request()}} |
{error, gleam@http@response:response(bitstring())}} |
{error, gleam@json:decode_error()}.
create_ven_response(Response) ->
{response, Status, _, Body} = Response,
case Status of
201 ->
_pipe = gleam@json:parse_bits(Body, oadr3@schema:ven_decoder()),
gleam@result:map(_pipe, fun(Field@0) -> {ok, Field@0} end);
_ ->
_pipe@1 = Response,
_pipe@2 = {error, _pipe@1},
{ok, _pipe@2}
end.
-file("src/oadr3/operations.gleam", 88).
-spec search_vens_request(
gleam@http@request:request(JIN),
gleam@option:option(binary()),
gleam@option:option(any()),
gleam@option:option(integer()),
gleam@option:option(integer())
) -> gleam@http@request:request(JIN).
search_vens_request(Base, Ven_name, Targets, Skip, Limit) ->
Method = get,
Path = <<"/vens"/utf8>>,
Query = [{<<"ven_name"/utf8>>, Ven_name},
{<<"targets"/utf8>>,
gleam@option:map(
Targets,
fun(_) -> erlang:error(#{gleam_error => panic,
message => <<"query parameter is not supported"/utf8>>,
file => <<?FILEPATH/utf8>>,
module => <<"oadr3/operations"/utf8>>,
function => <<"search_vens_request"/utf8>>,
line => 101}) end
)},
{<<"skip"/utf8>>,
gleam@option:map(Skip, fun erlang:integer_to_binary/1)},
{<<"limit"/utf8>>,
gleam@option:map(Limit, fun erlang:integer_to_binary/1)}],
_pipe = Base,
_pipe@1 = oadr3@utils:set_method(_pipe, Method),
_pipe@2 = oadr3@utils:append_path(_pipe@1, Path),
oadr3@utils:set_query(_pipe@2, Query).
-file("src/oadr3/operations.gleam", 112).
-spec search_vens_response(gleam@http@response:response(bitstring())) -> {ok,
{ok,
list({oadr3@schema:object_metadata(),
oadr3@schema:bl_ven_request()})} |
{error, gleam@http@response:response(bitstring())}} |
{error, gleam@json:decode_error()}.
search_vens_response(Response) ->
{response, Status, _, Body} = Response,
case Status of
200 ->
_pipe = gleam@json:parse_bits(
Body,
gleam@dynamic@decode:list(oadr3@schema:ven_decoder())
),
gleam@result:map(_pipe, fun(Field@0) -> {ok, Field@0} end);
_ ->
_pipe@1 = Response,
_pipe@2 = {error, _pipe@1},
{ok, _pipe@2}
end.
-file("src/oadr3/operations.gleam", 122).
-spec delete_subscription_request(gleam@http@request:request(JJG), binary()) -> gleam@http@request:request(JJG).
delete_subscription_request(Base, Subscription_id) ->
Method = delete,
Path = <<"/subscriptions/"/utf8, Subscription_id/binary>>,
Query = [],
_pipe = Base,
_pipe@1 = oadr3@utils:set_method(_pipe, Method),
_pipe@2 = oadr3@utils:append_path(_pipe@1, Path),
oadr3@utils:set_query(_pipe@2, Query).
-file("src/oadr3/operations.gleam", 132).
-spec delete_subscription_response(gleam@http@response:response(bitstring())) -> {ok,
{ok,
{oadr3@schema:object_metadata(),
oadr3@schema:subscription_request(),
oadr3@schema:anon97535fea()}} |
{error, gleam@http@response:response(bitstring())}} |
{error, gleam@json:decode_error()}.
delete_subscription_response(Response) ->
{response, Status, _, Body} = Response,
case Status of
200 ->
_pipe = gleam@json:parse_bits(
Body,
oadr3@schema:subscription_decoder()
),
gleam@result:map(_pipe, fun(Field@0) -> {ok, Field@0} end);
_ ->
_pipe@1 = Response,
_pipe@2 = {error, _pipe@1},
{ok, _pipe@2}
end.
-file("src/oadr3/operations.gleam", 141).
-spec update_subscription_request(
gleam@http@request:request(any()),
binary(),
oadr3@schema:subscription_request()
) -> gleam@http@request:request(bitstring()).
update_subscription_request(Base, Subscription_id, Data) ->
Method = put,
Path = <<"/subscriptions/"/utf8, Subscription_id/binary>>,
Query = [],
Body = oadr3@utils:json_to_bits(
oadr3@schema:subscription_request_encode(Data)
),
_pipe = Base,
_pipe@1 = oadr3@utils:set_method(_pipe, Method),
_pipe@2 = oadr3@utils:append_path(_pipe@1, Path),
_pipe@3 = oadr3@utils:set_query(_pipe@2, Query),
oadr3@utils:set_body(_pipe@3, <<"application/json"/utf8>>, Body).
-file("src/oadr3/operations.gleam", 153).
-spec update_subscription_response(gleam@http@response:response(bitstring())) -> {ok,
{ok,
{oadr3@schema:object_metadata(),
oadr3@schema:subscription_request(),
oadr3@schema:anon97535fea()}} |
{error, gleam@http@response:response(bitstring())}} |
{error, gleam@json:decode_error()}.
update_subscription_response(Response) ->
{response, Status, _, Body} = Response,
case Status of
200 ->
_pipe = gleam@json:parse_bits(
Body,
oadr3@schema:subscription_decoder()
),
gleam@result:map(_pipe, fun(Field@0) -> {ok, Field@0} end);
_ ->
_pipe@1 = Response,
_pipe@2 = {error, _pipe@1},
{ok, _pipe@2}
end.
-file("src/oadr3/operations.gleam", 162).
-spec search_subscription_by_id_request(
gleam@http@request:request(JKS),
binary()
) -> gleam@http@request:request(JKS).
search_subscription_by_id_request(Base, Subscription_id) ->
Method = get,
Path = <<"/subscriptions/"/utf8, Subscription_id/binary>>,
Query = [],
_pipe = Base,
_pipe@1 = oadr3@utils:set_method(_pipe, Method),
_pipe@2 = oadr3@utils:append_path(_pipe@1, Path),
oadr3@utils:set_query(_pipe@2, Query).
-file("src/oadr3/operations.gleam", 172).
-spec search_subscription_by_id_response(
gleam@http@response:response(bitstring())
) -> {ok,
{ok,
{oadr3@schema:object_metadata(),
oadr3@schema:subscription_request(),
oadr3@schema:anon97535fea()}} |
{error, gleam@http@response:response(bitstring())}} |
{error, gleam@json:decode_error()}.
search_subscription_by_id_response(Response) ->
{response, Status, _, Body} = Response,
case Status of
200 ->
_pipe = gleam@json:parse_bits(
Body,
oadr3@schema:subscription_decoder()
),
gleam@result:map(_pipe, fun(Field@0) -> {ok, Field@0} end);
_ ->
_pipe@1 = Response,
_pipe@2 = {error, _pipe@1},
{ok, _pipe@2}
end.
-file("src/oadr3/operations.gleam", 181).
-spec create_subscription_request(
gleam@http@request:request(any()),
oadr3@schema:subscription_request()
) -> gleam@http@request:request(bitstring()).
create_subscription_request(Base, Data) ->
Method = post,
Path = <<"/subscriptions"/utf8>>,
Query = [],
Body = oadr3@utils:json_to_bits(
oadr3@schema:subscription_request_encode(Data)
),
_pipe = Base,
_pipe@1 = oadr3@utils:set_method(_pipe, Method),
_pipe@2 = oadr3@utils:append_path(_pipe@1, Path),
_pipe@3 = oadr3@utils:set_query(_pipe@2, Query),
oadr3@utils:set_body(_pipe@3, <<"application/json"/utf8>>, Body).
-file("src/oadr3/operations.gleam", 193).
-spec create_subscription_response(gleam@http@response:response(bitstring())) -> {ok,
{ok,
{oadr3@schema:object_metadata(),
oadr3@schema:subscription_request(),
oadr3@schema:anon97535fea()}} |
{error, gleam@http@response:response(bitstring())}} |
{error, gleam@json:decode_error()}.
create_subscription_response(Response) ->
{response, Status, _, Body} = Response,
case Status of
201 ->
_pipe = gleam@json:parse_bits(
Body,
oadr3@schema:subscription_decoder()
),
gleam@result:map(_pipe, fun(Field@0) -> {ok, Field@0} end);
_ ->
_pipe@1 = Response,
_pipe@2 = {error, _pipe@1},
{ok, _pipe@2}
end.
-file("src/oadr3/operations.gleam", 202).
-spec search_subscriptions_request(
gleam@http@request:request(JMM),
gleam@option:option(binary()),
gleam@option:option(binary()),
gleam@option:option(any()),
gleam@option:option(integer()),
gleam@option:option(integer())
) -> gleam@http@request:request(JMM).
search_subscriptions_request(
Base,
Program_id,
Client_name,
Objects,
Skip,
Limit
) ->
Method = get,
Path = <<"/subscriptions"/utf8>>,
Query = [{<<"program_id"/utf8>>, Program_id},
{<<"client_name"/utf8>>, Client_name},
{<<"objects"/utf8>>,
gleam@option:map(
Objects,
fun(_) -> erlang:error(#{gleam_error => panic,
message => <<"query parameter is not supported"/utf8>>,
file => <<?FILEPATH/utf8>>,
module => <<"oadr3/operations"/utf8>>,
function => <<"search_subscriptions_request"/utf8>>,
line => 217}) end
)},
{<<"skip"/utf8>>,
gleam@option:map(Skip, fun erlang:integer_to_binary/1)},
{<<"limit"/utf8>>,
gleam@option:map(Limit, fun erlang:integer_to_binary/1)}],
_pipe = Base,
_pipe@1 = oadr3@utils:set_method(_pipe, Method),
_pipe@2 = oadr3@utils:append_path(_pipe@1, Path),
oadr3@utils:set_query(_pipe@2, Query).
-file("src/oadr3/operations.gleam", 228).
-spec search_subscriptions_response(gleam@http@response:response(bitstring())) -> {ok,
{ok,
list({oadr3@schema:object_metadata(),
oadr3@schema:subscription_request(),
oadr3@schema:anon97535fea()})} |
{error, gleam@http@response:response(bitstring())}} |
{error, gleam@json:decode_error()}.
search_subscriptions_response(Response) ->
{response, Status, _, Body} = Response,
case Status of
200 ->
_pipe = gleam@json:parse_bits(
Body,
gleam@dynamic@decode:list(oadr3@schema:subscription_decoder())
),
gleam@result:map(_pipe, fun(Field@0) -> {ok, Field@0} end);
_ ->
_pipe@1 = Response,
_pipe@2 = {error, _pipe@1},
{ok, _pipe@2}
end.
-file("src/oadr3/operations.gleam", 238).
-spec delete_ven_resource_request(gleam@http@request:request(JNF), binary()) -> gleam@http@request:request(JNF).
delete_ven_resource_request(Base, Resource_id) ->
Method = delete,
Path = <<"/resources/"/utf8, Resource_id/binary>>,
Query = [],
_pipe = Base,
_pipe@1 = oadr3@utils:set_method(_pipe, Method),
_pipe@2 = oadr3@utils:append_path(_pipe@1, Path),
oadr3@utils:set_query(_pipe@2, Query).
-file("src/oadr3/operations.gleam", 248).
-spec delete_ven_resource_response(gleam@http@response:response(bitstring())) -> {ok,
{ok,
{oadr3@schema:object_metadata(),
oadr3@schema:bl_resource_request()}} |
{error, gleam@http@response:response(bitstring())}} |
{error, gleam@json:decode_error()}.
delete_ven_resource_response(Response) ->
{response, Status, _, Body} = Response,
case Status of
200 ->
_pipe = gleam@json:parse_bits(Body, oadr3@schema:resource_decoder()),
gleam@result:map(_pipe, fun(Field@0) -> {ok, Field@0} end);
_ ->
_pipe@1 = Response,
_pipe@2 = {error, _pipe@1},
{ok, _pipe@2}
end.
-file("src/oadr3/operations.gleam", 256).
-spec update_ven_resource_request(
gleam@http@request:request(any()),
binary(),
oadr3@utils:any_()
) -> gleam@http@request:request(bitstring()).
update_ven_resource_request(Base, Resource_id, Data) ->
Method = put,
Path = <<"/resources/"/utf8, Resource_id/binary>>,
Query = [],
Body = oadr3@utils:json_to_bits(oadr3@schema:resource_request_encode(Data)),
_pipe = Base,
_pipe@1 = oadr3@utils:set_method(_pipe, Method),
_pipe@2 = oadr3@utils:append_path(_pipe@1, Path),
_pipe@3 = oadr3@utils:set_query(_pipe@2, Query),
oadr3@utils:set_body(_pipe@3, <<"application/json"/utf8>>, Body).
-file("src/oadr3/operations.gleam", 268).
-spec update_ven_resource_response(gleam@http@response:response(bitstring())) -> {ok,
{ok,
{oadr3@schema:object_metadata(),
oadr3@schema:bl_resource_request()}} |
{error, gleam@http@response:response(bitstring())}} |
{error, gleam@json:decode_error()}.
update_ven_resource_response(Response) ->
{response, Status, _, Body} = Response,
case Status of
200 ->
_pipe = gleam@json:parse_bits(Body, oadr3@schema:resource_decoder()),
gleam@result:map(_pipe, fun(Field@0) -> {ok, Field@0} end);
_ ->
_pipe@1 = Response,
_pipe@2 = {error, _pipe@1},
{ok, _pipe@2}
end.
-file("src/oadr3/operations.gleam", 276).
-spec search_ven_resource_by_id_request(
gleam@http@request:request(JOR),
binary()
) -> gleam@http@request:request(JOR).
search_ven_resource_by_id_request(Base, Resource_id) ->
Method = get,
Path = <<"/resources/"/utf8, Resource_id/binary>>,
Query = [],
_pipe = Base,
_pipe@1 = oadr3@utils:set_method(_pipe, Method),
_pipe@2 = oadr3@utils:append_path(_pipe@1, Path),
oadr3@utils:set_query(_pipe@2, Query).
-file("src/oadr3/operations.gleam", 286).
-spec search_ven_resource_by_id_response(
gleam@http@response:response(bitstring())
) -> {ok,
{ok,
{oadr3@schema:object_metadata(),
oadr3@schema:bl_resource_request()}} |
{error, gleam@http@response:response(bitstring())}} |
{error, gleam@json:decode_error()}.
search_ven_resource_by_id_response(Response) ->
{response, Status, _, Body} = Response,
case Status of
200 ->
_pipe = gleam@json:parse_bits(Body, oadr3@schema:resource_decoder()),
gleam@result:map(_pipe, fun(Field@0) -> {ok, Field@0} end);
_ ->
_pipe@1 = Response,
_pipe@2 = {error, _pipe@1},
{ok, _pipe@2}
end.
-file("src/oadr3/operations.gleam", 294).
-spec create_resource_request(
gleam@http@request:request(any()),
oadr3@utils:any_()
) -> gleam@http@request:request(bitstring()).
create_resource_request(Base, Data) ->
Method = post,
Path = <<"/resources"/utf8>>,
Query = [],
Body = oadr3@utils:json_to_bits(oadr3@schema:resource_request_encode(Data)),
_pipe = Base,
_pipe@1 = oadr3@utils:set_method(_pipe, Method),
_pipe@2 = oadr3@utils:append_path(_pipe@1, Path),
_pipe@3 = oadr3@utils:set_query(_pipe@2, Query),
oadr3@utils:set_body(_pipe@3, <<"application/json"/utf8>>, Body).
-file("src/oadr3/operations.gleam", 306).
-spec create_resource_response(gleam@http@response:response(bitstring())) -> {ok,
{ok,
{oadr3@schema:object_metadata(),
oadr3@schema:bl_resource_request()}} |
{error, gleam@http@response:response(bitstring())}} |
{error, gleam@json:decode_error()}.
create_resource_response(Response) ->
{response, Status, _, Body} = Response,
case Status of
201 ->
_pipe = gleam@json:parse_bits(Body, oadr3@schema:resource_decoder()),
gleam@result:map(_pipe, fun(Field@0) -> {ok, Field@0} end);
_ ->
_pipe@1 = Response,
_pipe@2 = {error, _pipe@1},
{ok, _pipe@2}
end.
-file("src/oadr3/operations.gleam", 314).
-spec search_ven_resources_request(
gleam@http@request:request(JQL),
gleam@option:option(binary()),
gleam@option:option(binary()),
gleam@option:option(any()),
gleam@option:option(integer()),
gleam@option:option(integer())
) -> gleam@http@request:request(JQL).
search_ven_resources_request(Base, Resource_name, Ven_id, Targets, Skip, Limit) ->
Method = get,
Path = <<"/resources"/utf8>>,
Query = [{<<"resource_name"/utf8>>, Resource_name},
{<<"ven_id"/utf8>>, Ven_id},
{<<"targets"/utf8>>,
gleam@option:map(
Targets,
fun(_) -> erlang:error(#{gleam_error => panic,
message => <<"query parameter is not supported"/utf8>>,
file => <<?FILEPATH/utf8>>,
module => <<"oadr3/operations"/utf8>>,
function => <<"search_ven_resources_request"/utf8>>,
line => 329}) end
)},
{<<"skip"/utf8>>,
gleam@option:map(Skip, fun erlang:integer_to_binary/1)},
{<<"limit"/utf8>>,
gleam@option:map(Limit, fun erlang:integer_to_binary/1)}],
_pipe = Base,
_pipe@1 = oadr3@utils:set_method(_pipe, Method),
_pipe@2 = oadr3@utils:append_path(_pipe@1, Path),
oadr3@utils:set_query(_pipe@2, Query).
-file("src/oadr3/operations.gleam", 340).
-spec search_ven_resources_response(gleam@http@response:response(bitstring())) -> {ok,
{ok,
list({oadr3@schema:object_metadata(),
oadr3@schema:bl_resource_request()})} |
{error, gleam@http@response:response(bitstring())}} |
{error, gleam@json:decode_error()}.
search_ven_resources_response(Response) ->
{response, Status, _, Body} = Response,
case Status of
200 ->
_pipe = gleam@json:parse_bits(
Body,
gleam@dynamic@decode:list(oadr3@schema:resource_decoder())
),
gleam@result:map(_pipe, fun(Field@0) -> {ok, Field@0} end);
_ ->
_pipe@1 = Response,
_pipe@2 = {error, _pipe@1},
{ok, _pipe@2}
end.
-file("src/oadr3/operations.gleam", 350).
-spec delete_report_request(gleam@http@request:request(JRE), binary()) -> gleam@http@request:request(JRE).
delete_report_request(Base, Report_id) ->
Method = delete,
Path = <<"/reports/"/utf8, Report_id/binary>>,
Query = [],
_pipe = Base,
_pipe@1 = oadr3@utils:set_method(_pipe, Method),
_pipe@2 = oadr3@utils:append_path(_pipe@1, Path),
oadr3@utils:set_query(_pipe@2, Query).
-file("src/oadr3/operations.gleam", 360).
-spec delete_report_response(gleam@http@response:response(bitstring())) -> {ok,
{ok,
{oadr3@schema:object_metadata(),
oadr3@schema:report_request(),
oadr3@schema:anon97535fea()}} |
{error, gleam@http@response:response(bitstring())}} |
{error, gleam@json:decode_error()}.
delete_report_response(Response) ->
{response, Status, _, Body} = Response,
case Status of
200 ->
_pipe = gleam@json:parse_bits(Body, oadr3@schema:report_decoder()),
gleam@result:map(_pipe, fun(Field@0) -> {ok, Field@0} end);
_ ->
_pipe@1 = Response,
_pipe@2 = {error, _pipe@1},
{ok, _pipe@2}
end.
-file("src/oadr3/operations.gleam", 368).
-spec update_report_request(
gleam@http@request:request(any()),
binary(),
oadr3@schema:report_request()
) -> gleam@http@request:request(bitstring()).
update_report_request(Base, Report_id, Data) ->
Method = put,
Path = <<"/reports/"/utf8, Report_id/binary>>,
Query = [],
Body = oadr3@utils:json_to_bits(oadr3@schema:report_request_encode(Data)),
_pipe = Base,
_pipe@1 = oadr3@utils:set_method(_pipe, Method),
_pipe@2 = oadr3@utils:append_path(_pipe@1, Path),
_pipe@3 = oadr3@utils:set_query(_pipe@2, Query),
oadr3@utils:set_body(_pipe@3, <<"application/json"/utf8>>, Body).
-file("src/oadr3/operations.gleam", 380).
-spec update_report_response(gleam@http@response:response(bitstring())) -> {ok,
{ok,
{oadr3@schema:object_metadata(),
oadr3@schema:report_request(),
oadr3@schema:anon97535fea()}} |
{error, gleam@http@response:response(bitstring())}} |
{error, gleam@json:decode_error()}.
update_report_response(Response) ->
{response, Status, _, Body} = Response,
case Status of
200 ->
_pipe = gleam@json:parse_bits(Body, oadr3@schema:report_decoder()),
gleam@result:map(_pipe, fun(Field@0) -> {ok, Field@0} end);
_ ->
_pipe@1 = Response,
_pipe@2 = {error, _pipe@1},
{ok, _pipe@2}
end.
-file("src/oadr3/operations.gleam", 388).
-spec search_reports_by_report_id_request(
gleam@http@request:request(JSQ),
binary()
) -> gleam@http@request:request(JSQ).
search_reports_by_report_id_request(Base, Report_id) ->
Method = get,
Path = <<"/reports/"/utf8, Report_id/binary>>,
Query = [],
_pipe = Base,
_pipe@1 = oadr3@utils:set_method(_pipe, Method),
_pipe@2 = oadr3@utils:append_path(_pipe@1, Path),
oadr3@utils:set_query(_pipe@2, Query).
-file("src/oadr3/operations.gleam", 398).
-spec search_reports_by_report_id_response(
gleam@http@response:response(bitstring())
) -> {ok,
{ok,
{oadr3@schema:object_metadata(),
oadr3@schema:report_request(),
oadr3@schema:anon97535fea()}} |
{error, gleam@http@response:response(bitstring())}} |
{error, gleam@json:decode_error()}.
search_reports_by_report_id_response(Response) ->
{response, Status, _, Body} = Response,
case Status of
200 ->
_pipe = gleam@json:parse_bits(Body, oadr3@schema:report_decoder()),
gleam@result:map(_pipe, fun(Field@0) -> {ok, Field@0} end);
_ ->
_pipe@1 = Response,
_pipe@2 = {error, _pipe@1},
{ok, _pipe@2}
end.
-file("src/oadr3/operations.gleam", 406).
-spec create_report_request(
gleam@http@request:request(any()),
oadr3@schema:report_request()
) -> gleam@http@request:request(bitstring()).
create_report_request(Base, Data) ->
Method = post,
Path = <<"/reports"/utf8>>,
Query = [],
Body = oadr3@utils:json_to_bits(oadr3@schema:report_request_encode(Data)),
_pipe = Base,
_pipe@1 = oadr3@utils:set_method(_pipe, Method),
_pipe@2 = oadr3@utils:append_path(_pipe@1, Path),
_pipe@3 = oadr3@utils:set_query(_pipe@2, Query),
oadr3@utils:set_body(_pipe@3, <<"application/json"/utf8>>, Body).
-file("src/oadr3/operations.gleam", 418).
-spec create_report_response(gleam@http@response:response(bitstring())) -> {ok,
{ok,
{oadr3@schema:object_metadata(),
oadr3@schema:report_request(),
oadr3@schema:anon97535fea()}} |
{error, gleam@http@response:response(bitstring())}} |
{error, gleam@json:decode_error()}.
create_report_response(Response) ->
{response, Status, _, Body} = Response,
case Status of
201 ->
_pipe = gleam@json:parse_bits(Body, oadr3@schema:report_decoder()),
gleam@result:map(_pipe, fun(Field@0) -> {ok, Field@0} end);
_ ->
_pipe@1 = Response,
_pipe@2 = {error, _pipe@1},
{ok, _pipe@2}
end.
-file("src/oadr3/operations.gleam", 426).
-spec search_all_reports_request(
gleam@http@request:request(JUG),
gleam@option:option(binary()),
gleam@option:option(binary()),
gleam@option:option(binary()),
gleam@option:option(integer()),
gleam@option:option(integer())
) -> gleam@http@request:request(JUG).
search_all_reports_request(Base, Program_id, Event_id, Client_name, Skip, Limit) ->
Method = get,
Path = <<"/reports"/utf8>>,
Query = [{<<"program_id"/utf8>>, Program_id},
{<<"event_id"/utf8>>, Event_id},
{<<"client_name"/utf8>>, Client_name},
{<<"skip"/utf8>>,
gleam@option:map(Skip, fun erlang:integer_to_binary/1)},
{<<"limit"/utf8>>,
gleam@option:map(Limit, fun erlang:integer_to_binary/1)}],
_pipe = Base,
_pipe@1 = oadr3@utils:set_method(_pipe, Method),
_pipe@2 = oadr3@utils:append_path(_pipe@1, Path),
oadr3@utils:set_query(_pipe@2, Query).
-file("src/oadr3/operations.gleam", 449).
-spec search_all_reports_response(gleam@http@response:response(bitstring())) -> {ok,
{ok,
list({oadr3@schema:object_metadata(),
oadr3@schema:report_request(),
oadr3@schema:anon97535fea()})} |
{error, gleam@http@response:response(bitstring())}} |
{error, gleam@json:decode_error()}.
search_all_reports_response(Response) ->
{response, Status, _, Body} = Response,
case Status of
200 ->
_pipe = gleam@json:parse_bits(
Body,
gleam@dynamic@decode:list(oadr3@schema:report_decoder())
),
gleam@result:map(_pipe, fun(Field@0) -> {ok, Field@0} end);
_ ->
_pipe@1 = Response,
_pipe@2 = {error, _pipe@1},
{ok, _pipe@2}
end.
-file("src/oadr3/operations.gleam", 459).
-spec delete_program_request(gleam@http@request:request(JUZ), binary()) -> gleam@http@request:request(JUZ).
delete_program_request(Base, Program_id) ->
Method = delete,
Path = <<"/programs/"/utf8, Program_id/binary>>,
Query = [],
_pipe = Base,
_pipe@1 = oadr3@utils:set_method(_pipe, Method),
_pipe@2 = oadr3@utils:append_path(_pipe@1, Path),
oadr3@utils:set_query(_pipe@2, Query).
-file("src/oadr3/operations.gleam", 469).
-spec delete_program_response(gleam@http@response:response(bitstring())) -> {ok,
{ok, {oadr3@schema:object_metadata(), oadr3@schema:program_request()}} |
{error, gleam@http@response:response(bitstring())}} |
{error, gleam@json:decode_error()}.
delete_program_response(Response) ->
{response, Status, _, Body} = Response,
case Status of
200 ->
_pipe = gleam@json:parse_bits(Body, oadr3@schema:program_decoder()),
gleam@result:map(_pipe, fun(Field@0) -> {ok, Field@0} end);
_ ->
_pipe@1 = Response,
_pipe@2 = {error, _pipe@1},
{ok, _pipe@2}
end.
-file("src/oadr3/operations.gleam", 477).
-spec update_program_request(
gleam@http@request:request(any()),
binary(),
oadr3@schema:program_request()
) -> gleam@http@request:request(bitstring()).
update_program_request(Base, Program_id, Data) ->
Method = put,
Path = <<"/programs/"/utf8, Program_id/binary>>,
Query = [],
Body = oadr3@utils:json_to_bits(oadr3@schema:program_request_encode(Data)),
_pipe = Base,
_pipe@1 = oadr3@utils:set_method(_pipe, Method),
_pipe@2 = oadr3@utils:append_path(_pipe@1, Path),
_pipe@3 = oadr3@utils:set_query(_pipe@2, Query),
oadr3@utils:set_body(_pipe@3, <<"application/json"/utf8>>, Body).
-file("src/oadr3/operations.gleam", 489).
-spec update_program_response(gleam@http@response:response(bitstring())) -> {ok,
{ok, {oadr3@schema:object_metadata(), oadr3@schema:program_request()}} |
{error, oadr3@schema:problem()}} |
{error, gleam@json:decode_error()}.
update_program_response(Response) ->
{response, Status, _, Body} = Response,
case Status of
200 ->
_pipe = gleam@json:parse_bits(Body, oadr3@schema:program_decoder()),
gleam@result:map(_pipe, fun(Field@0) -> {ok, Field@0} end);
_ ->
_pipe@1 = gleam@json:parse_bits(
Body,
oadr3@schema:problem_decoder()
),
gleam@result:map(_pipe@1, fun(Field@0) -> {error, Field@0} end)
end.
-file("src/oadr3/operations.gleam", 497).
-spec search_program_by_program_id_request(
gleam@http@request:request(JWL),
binary()
) -> gleam@http@request:request(JWL).
search_program_by_program_id_request(Base, Program_id) ->
Method = get,
Path = <<"/programs/"/utf8, Program_id/binary>>,
Query = [],
_pipe = Base,
_pipe@1 = oadr3@utils:set_method(_pipe, Method),
_pipe@2 = oadr3@utils:append_path(_pipe@1, Path),
oadr3@utils:set_query(_pipe@2, Query).
-file("src/oadr3/operations.gleam", 507).
-spec search_program_by_program_id_response(
gleam@http@response:response(bitstring())
) -> {ok,
{ok, {oadr3@schema:object_metadata(), oadr3@schema:program_request()}} |
{error, gleam@http@response:response(bitstring())}} |
{error, gleam@json:decode_error()}.
search_program_by_program_id_response(Response) ->
{response, Status, _, Body} = Response,
case Status of
200 ->
_pipe = gleam@json:parse_bits(Body, oadr3@schema:program_decoder()),
gleam@result:map(_pipe, fun(Field@0) -> {ok, Field@0} end);
_ ->
_pipe@1 = Response,
_pipe@2 = {error, _pipe@1},
{ok, _pipe@2}
end.
-file("src/oadr3/operations.gleam", 515).
-spec create_program_request(
gleam@http@request:request(any()),
oadr3@schema:program_request()
) -> gleam@http@request:request(bitstring()).
create_program_request(Base, Data) ->
Method = post,
Path = <<"/programs"/utf8>>,
Query = [],
Body = oadr3@utils:json_to_bits(oadr3@schema:program_request_encode(Data)),
_pipe = Base,
_pipe@1 = oadr3@utils:set_method(_pipe, Method),
_pipe@2 = oadr3@utils:append_path(_pipe@1, Path),
_pipe@3 = oadr3@utils:set_query(_pipe@2, Query),
oadr3@utils:set_body(_pipe@3, <<"application/json"/utf8>>, Body).
-file("src/oadr3/operations.gleam", 527).
-spec create_program_response(gleam@http@response:response(bitstring())) -> {ok,
{ok, {oadr3@schema:object_metadata(), oadr3@schema:program_request()}} |
{error, gleam@http@response:response(bitstring())}} |
{error, gleam@json:decode_error()}.
create_program_response(Response) ->
{response, Status, _, Body} = Response,
case Status of
201 ->
_pipe = gleam@json:parse_bits(Body, oadr3@schema:program_decoder()),
gleam@result:map(_pipe, fun(Field@0) -> {ok, Field@0} end);
_ ->
_pipe@1 = Response,
_pipe@2 = {error, _pipe@1},
{ok, _pipe@2}
end.
-file("src/oadr3/operations.gleam", 535).
-spec search_all_programs_request(
gleam@http@request:request(JYF),
gleam@option:option(any()),
gleam@option:option(integer()),
gleam@option:option(integer())
) -> gleam@http@request:request(JYF).
search_all_programs_request(Base, Targets, Skip, Limit) ->
Method = get,
Path = <<"/programs"/utf8>>,
Query = [{<<"targets"/utf8>>,
gleam@option:map(
Targets,
fun(_) -> erlang:error(#{gleam_error => panic,
message => <<"query parameter is not supported"/utf8>>,
file => <<?FILEPATH/utf8>>,
module => <<"oadr3/operations"/utf8>>,
function => <<"search_all_programs_request"/utf8>>,
line => 546}) end
)},
{<<"skip"/utf8>>,
gleam@option:map(Skip, fun erlang:integer_to_binary/1)},
{<<"limit"/utf8>>,
gleam@option:map(Limit, fun erlang:integer_to_binary/1)}],
_pipe = Base,
_pipe@1 = oadr3@utils:set_method(_pipe, Method),
_pipe@2 = oadr3@utils:append_path(_pipe@1, Path),
oadr3@utils:set_query(_pipe@2, Query).
-file("src/oadr3/operations.gleam", 557).
-spec search_all_programs_response(gleam@http@response:response(bitstring())) -> {ok,
{ok,
list({oadr3@schema:object_metadata(),
oadr3@schema:program_request()})} |
{error, gleam@http@response:response(bitstring())}} |
{error, gleam@json:decode_error()}.
search_all_programs_response(Response) ->
{response, Status, _, Body} = Response,
case Status of
200 ->
_pipe = gleam@json:parse_bits(
Body,
gleam@dynamic@decode:list(oadr3@schema:program_decoder())
),
gleam@result:map(_pipe, fun(Field@0) -> {ok, Field@0} end);
_ ->
_pipe@1 = Response,
_pipe@2 = {error, _pipe@1},
{ok, _pipe@2}
end.
-file("src/oadr3/operations.gleam", 567).
-spec list_all_mqtt_notifier_topics_ven_resources_request(
gleam@http@request:request(JYY),
binary()
) -> gleam@http@request:request(JYY).
list_all_mqtt_notifier_topics_ven_resources_request(Base, Ven_id) ->
Method = get,
Path = <<<<"/notifiers/mqtt/topics/vens/"/utf8, Ven_id/binary>>/binary,
"/resources"/utf8>>,
Query = [],
_pipe = Base,
_pipe@1 = oadr3@utils:set_method(_pipe, Method),
_pipe@2 = oadr3@utils:append_path(_pipe@1, Path),
oadr3@utils:set_query(_pipe@2, Query).
-file("src/oadr3/operations.gleam", 577).
-spec list_all_mqtt_notifier_topics_ven_resources_response(
gleam@http@response:response(bitstring())
) -> {ok,
{ok, oadr3@schema:notifier_topics_response()} |
{error, gleam@http@response:response(bitstring())}} |
{error, gleam@json:decode_error()}.
list_all_mqtt_notifier_topics_ven_resources_response(Response) ->
{response, Status, _, Body} = Response,
case Status of
200 ->
_pipe = gleam@json:parse_bits(
Body,
oadr3@schema:notifier_topics_response_decoder()
),
gleam@result:map(_pipe, fun(Field@0) -> {ok, Field@0} end);
_ ->
_pipe@1 = Response,
_pipe@2 = {error, _pipe@1},
{ok, _pipe@2}
end.
-file("src/oadr3/operations.gleam", 587).
-spec list_all_mqtt_notifier_topics_ven_programs_request(
gleam@http@request:request(JZQ),
binary()
) -> gleam@http@request:request(JZQ).
list_all_mqtt_notifier_topics_ven_programs_request(Base, Ven_id) ->
Method = get,
Path = <<<<"/notifiers/mqtt/topics/vens/"/utf8, Ven_id/binary>>/binary,
"/programs"/utf8>>,
Query = [],
_pipe = Base,
_pipe@1 = oadr3@utils:set_method(_pipe, Method),
_pipe@2 = oadr3@utils:append_path(_pipe@1, Path),
oadr3@utils:set_query(_pipe@2, Query).
-file("src/oadr3/operations.gleam", 597).
-spec list_all_mqtt_notifier_topics_ven_programs_response(
gleam@http@response:response(bitstring())
) -> {ok,
{ok, oadr3@schema:notifier_topics_response()} |
{error, gleam@http@response:response(bitstring())}} |
{error, gleam@json:decode_error()}.
list_all_mqtt_notifier_topics_ven_programs_response(Response) ->
{response, Status, _, Body} = Response,
case Status of
200 ->
_pipe = gleam@json:parse_bits(
Body,
oadr3@schema:notifier_topics_response_decoder()
),
gleam@result:map(_pipe, fun(Field@0) -> {ok, Field@0} end);
_ ->
_pipe@1 = Response,
_pipe@2 = {error, _pipe@1},
{ok, _pipe@2}
end.
-file("src/oadr3/operations.gleam", 607).
-spec list_all_mqtt_notifier_topics_ven_events_request(
gleam@http@request:request(KAI),
binary()
) -> gleam@http@request:request(KAI).
list_all_mqtt_notifier_topics_ven_events_request(Base, Ven_id) ->
Method = get,
Path = <<<<"/notifiers/mqtt/topics/vens/"/utf8, Ven_id/binary>>/binary,
"/events"/utf8>>,
Query = [],
_pipe = Base,
_pipe@1 = oadr3@utils:set_method(_pipe, Method),
_pipe@2 = oadr3@utils:append_path(_pipe@1, Path),
oadr3@utils:set_query(_pipe@2, Query).
-file("src/oadr3/operations.gleam", 617).
-spec list_all_mqtt_notifier_topics_ven_events_response(
gleam@http@response:response(bitstring())
) -> {ok,
{ok, oadr3@schema:notifier_topics_response()} |
{error, gleam@http@response:response(bitstring())}} |
{error, gleam@json:decode_error()}.
list_all_mqtt_notifier_topics_ven_events_response(Response) ->
{response, Status, _, Body} = Response,
case Status of
200 ->
_pipe = gleam@json:parse_bits(
Body,
oadr3@schema:notifier_topics_response_decoder()
),
gleam@result:map(_pipe, fun(Field@0) -> {ok, Field@0} end);
_ ->
_pipe@1 = Response,
_pipe@2 = {error, _pipe@1},
{ok, _pipe@2}
end.
-file("src/oadr3/operations.gleam", 627).
-spec list_all_mqtt_notifier_topics_ven_request(
gleam@http@request:request(KBA),
binary()
) -> gleam@http@request:request(KBA).
list_all_mqtt_notifier_topics_ven_request(Base, Ven_id) ->
Method = get,
Path = <<"/notifiers/mqtt/topics/vens/"/utf8, Ven_id/binary>>,
Query = [],
_pipe = Base,
_pipe@1 = oadr3@utils:set_method(_pipe, Method),
_pipe@2 = oadr3@utils:append_path(_pipe@1, Path),
oadr3@utils:set_query(_pipe@2, Query).
-file("src/oadr3/operations.gleam", 637).
-spec list_all_mqtt_notifier_topics_ven_response(
gleam@http@response:response(bitstring())
) -> {ok,
{ok, oadr3@schema:notifier_topics_response()} |
{error, gleam@http@response:response(bitstring())}} |
{error, gleam@json:decode_error()}.
list_all_mqtt_notifier_topics_ven_response(Response) ->
{response, Status, _, Body} = Response,
case Status of
200 ->
_pipe = gleam@json:parse_bits(
Body,
oadr3@schema:notifier_topics_response_decoder()
),
gleam@result:map(_pipe, fun(Field@0) -> {ok, Field@0} end);
_ ->
_pipe@1 = Response,
_pipe@2 = {error, _pipe@1},
{ok, _pipe@2}
end.
-file("src/oadr3/operations.gleam", 647).
-spec list_all_mqtt_notifier_topics_vens_request(
gleam@http@request:request(KBS)
) -> gleam@http@request:request(KBS).
list_all_mqtt_notifier_topics_vens_request(Base) ->
Method = get,
Path = <<"/notifiers/mqtt/topics/vens"/utf8>>,
Query = [],
_pipe = Base,
_pipe@1 = oadr3@utils:set_method(_pipe, Method),
_pipe@2 = oadr3@utils:append_path(_pipe@1, Path),
oadr3@utils:set_query(_pipe@2, Query).
-file("src/oadr3/operations.gleam", 657).
-spec list_all_mqtt_notifier_topics_vens_response(
gleam@http@response:response(bitstring())
) -> {ok,
{ok, oadr3@schema:notifier_topics_response()} |
{error, gleam@http@response:response(bitstring())}} |
{error, gleam@json:decode_error()}.
list_all_mqtt_notifier_topics_vens_response(Response) ->
{response, Status, _, Body} = Response,
case Status of
200 ->
_pipe = gleam@json:parse_bits(
Body,
oadr3@schema:notifier_topics_response_decoder()
),
gleam@result:map(_pipe, fun(Field@0) -> {ok, Field@0} end);
_ ->
_pipe@1 = Response,
_pipe@2 = {error, _pipe@1},
{ok, _pipe@2}
end.
-file("src/oadr3/operations.gleam", 667).
-spec list_all_mqtt_notifier_topics_subscriptions_request(
gleam@http@request:request(KCK)
) -> gleam@http@request:request(KCK).
list_all_mqtt_notifier_topics_subscriptions_request(Base) ->
Method = get,
Path = <<"/notifiers/mqtt/topics/subscriptions"/utf8>>,
Query = [],
_pipe = Base,
_pipe@1 = oadr3@utils:set_method(_pipe, Method),
_pipe@2 = oadr3@utils:append_path(_pipe@1, Path),
oadr3@utils:set_query(_pipe@2, Query).
-file("src/oadr3/operations.gleam", 677).
-spec list_all_mqtt_notifier_topics_subscriptions_response(
gleam@http@response:response(bitstring())
) -> {ok,
{ok, oadr3@schema:notifier_topics_response()} |
{error, gleam@http@response:response(bitstring())}} |
{error, gleam@json:decode_error()}.
list_all_mqtt_notifier_topics_subscriptions_response(Response) ->
{response, Status, _, Body} = Response,
case Status of
200 ->
_pipe = gleam@json:parse_bits(
Body,
oadr3@schema:notifier_topics_response_decoder()
),
gleam@result:map(_pipe, fun(Field@0) -> {ok, Field@0} end);
_ ->
_pipe@1 = Response,
_pipe@2 = {error, _pipe@1},
{ok, _pipe@2}
end.
-file("src/oadr3/operations.gleam", 687).
-spec list_all_mqtt_notifier_topics_resources_request(
gleam@http@request:request(KDC)
) -> gleam@http@request:request(KDC).
list_all_mqtt_notifier_topics_resources_request(Base) ->
Method = get,
Path = <<"/notifiers/mqtt/topics/resources"/utf8>>,
Query = [],
_pipe = Base,
_pipe@1 = oadr3@utils:set_method(_pipe, Method),
_pipe@2 = oadr3@utils:append_path(_pipe@1, Path),
oadr3@utils:set_query(_pipe@2, Query).
-file("src/oadr3/operations.gleam", 697).
-spec list_all_mqtt_notifier_topics_resources_response(
gleam@http@response:response(bitstring())
) -> {ok,
{ok, oadr3@schema:notifier_topics_response()} |
{error, gleam@http@response:response(bitstring())}} |
{error, gleam@json:decode_error()}.
list_all_mqtt_notifier_topics_resources_response(Response) ->
{response, Status, _, Body} = Response,
case Status of
200 ->
_pipe = gleam@json:parse_bits(
Body,
oadr3@schema:notifier_topics_response_decoder()
),
gleam@result:map(_pipe, fun(Field@0) -> {ok, Field@0} end);
_ ->
_pipe@1 = Response,
_pipe@2 = {error, _pipe@1},
{ok, _pipe@2}
end.
-file("src/oadr3/operations.gleam", 707).
-spec list_all_mqtt_notifier_topics_reports_request(
gleam@http@request:request(KDU)
) -> gleam@http@request:request(KDU).
list_all_mqtt_notifier_topics_reports_request(Base) ->
Method = get,
Path = <<"/notifiers/mqtt/topics/reports"/utf8>>,
Query = [],
_pipe = Base,
_pipe@1 = oadr3@utils:set_method(_pipe, Method),
_pipe@2 = oadr3@utils:append_path(_pipe@1, Path),
oadr3@utils:set_query(_pipe@2, Query).
-file("src/oadr3/operations.gleam", 717).
-spec list_all_mqtt_notifier_topics_reports_response(
gleam@http@response:response(bitstring())
) -> {ok,
{ok, oadr3@schema:notifier_topics_response()} |
{error, gleam@http@response:response(bitstring())}} |
{error, gleam@json:decode_error()}.
list_all_mqtt_notifier_topics_reports_response(Response) ->
{response, Status, _, Body} = Response,
case Status of
200 ->
_pipe = gleam@json:parse_bits(
Body,
oadr3@schema:notifier_topics_response_decoder()
),
gleam@result:map(_pipe, fun(Field@0) -> {ok, Field@0} end);
_ ->
_pipe@1 = Response,
_pipe@2 = {error, _pipe@1},
{ok, _pipe@2}
end.
-file("src/oadr3/operations.gleam", 727).
-spec list_all_mqtt_notifier_topics_program_events_request(
gleam@http@request:request(KEM),
binary()
) -> gleam@http@request:request(KEM).
list_all_mqtt_notifier_topics_program_events_request(Base, Program_id) ->
Method = get,
Path = <<<<"/notifiers/mqtt/topics/programs/"/utf8, Program_id/binary>>/binary,
"/events"/utf8>>,
Query = [],
_pipe = Base,
_pipe@1 = oadr3@utils:set_method(_pipe, Method),
_pipe@2 = oadr3@utils:append_path(_pipe@1, Path),
oadr3@utils:set_query(_pipe@2, Query).
-file("src/oadr3/operations.gleam", 737).
-spec list_all_mqtt_notifier_topics_program_events_response(
gleam@http@response:response(bitstring())
) -> {ok,
{ok, oadr3@schema:notifier_topics_response()} |
{error, gleam@http@response:response(bitstring())}} |
{error, gleam@json:decode_error()}.
list_all_mqtt_notifier_topics_program_events_response(Response) ->
{response, Status, _, Body} = Response,
case Status of
200 ->
_pipe = gleam@json:parse_bits(
Body,
oadr3@schema:notifier_topics_response_decoder()
),
gleam@result:map(_pipe, fun(Field@0) -> {ok, Field@0} end);
_ ->
_pipe@1 = Response,
_pipe@2 = {error, _pipe@1},
{ok, _pipe@2}
end.
-file("src/oadr3/operations.gleam", 747).
-spec list_all_mqtt_notifier_topics_program_request(
gleam@http@request:request(KFE),
binary()
) -> gleam@http@request:request(KFE).
list_all_mqtt_notifier_topics_program_request(Base, Program_id) ->
Method = get,
Path = <<"/notifiers/mqtt/topics/programs/"/utf8, Program_id/binary>>,
Query = [],
_pipe = Base,
_pipe@1 = oadr3@utils:set_method(_pipe, Method),
_pipe@2 = oadr3@utils:append_path(_pipe@1, Path),
oadr3@utils:set_query(_pipe@2, Query).
-file("src/oadr3/operations.gleam", 757).
-spec list_all_mqtt_notifier_topics_program_response(
gleam@http@response:response(bitstring())
) -> {ok,
{ok, oadr3@schema:notifier_topics_response()} |
{error, gleam@http@response:response(bitstring())}} |
{error, gleam@json:decode_error()}.
list_all_mqtt_notifier_topics_program_response(Response) ->
{response, Status, _, Body} = Response,
case Status of
200 ->
_pipe = gleam@json:parse_bits(
Body,
oadr3@schema:notifier_topics_response_decoder()
),
gleam@result:map(_pipe, fun(Field@0) -> {ok, Field@0} end);
_ ->
_pipe@1 = Response,
_pipe@2 = {error, _pipe@1},
{ok, _pipe@2}
end.
-file("src/oadr3/operations.gleam", 767).
-spec list_all_mqtt_notifier_topics_programs_request(
gleam@http@request:request(KFW)
) -> gleam@http@request:request(KFW).
list_all_mqtt_notifier_topics_programs_request(Base) ->
Method = get,
Path = <<"/notifiers/mqtt/topics/programs"/utf8>>,
Query = [],
_pipe = Base,
_pipe@1 = oadr3@utils:set_method(_pipe, Method),
_pipe@2 = oadr3@utils:append_path(_pipe@1, Path),
oadr3@utils:set_query(_pipe@2, Query).
-file("src/oadr3/operations.gleam", 777).
-spec list_all_mqtt_notifier_topics_programs_response(
gleam@http@response:response(bitstring())
) -> {ok,
{ok, oadr3@schema:notifier_topics_response()} |
{error, gleam@http@response:response(bitstring())}} |
{error, gleam@json:decode_error()}.
list_all_mqtt_notifier_topics_programs_response(Response) ->
{response, Status, _, Body} = Response,
case Status of
200 ->
_pipe = gleam@json:parse_bits(
Body,
oadr3@schema:notifier_topics_response_decoder()
),
gleam@result:map(_pipe, fun(Field@0) -> {ok, Field@0} end);
_ ->
_pipe@1 = Response,
_pipe@2 = {error, _pipe@1},
{ok, _pipe@2}
end.
-file("src/oadr3/operations.gleam", 787).
-spec list_all_mqtt_notifier_topics_events_request(
gleam@http@request:request(KGO)
) -> gleam@http@request:request(KGO).
list_all_mqtt_notifier_topics_events_request(Base) ->
Method = get,
Path = <<"/notifiers/mqtt/topics/events"/utf8>>,
Query = [],
_pipe = Base,
_pipe@1 = oadr3@utils:set_method(_pipe, Method),
_pipe@2 = oadr3@utils:append_path(_pipe@1, Path),
oadr3@utils:set_query(_pipe@2, Query).
-file("src/oadr3/operations.gleam", 797).
-spec list_all_mqtt_notifier_topics_events_response(
gleam@http@response:response(bitstring())
) -> {ok,
{ok, oadr3@schema:notifier_topics_response()} |
{error, gleam@http@response:response(bitstring())}} |
{error, gleam@json:decode_error()}.
list_all_mqtt_notifier_topics_events_response(Response) ->
{response, Status, _, Body} = Response,
case Status of
200 ->
_pipe = gleam@json:parse_bits(
Body,
oadr3@schema:notifier_topics_response_decoder()
),
gleam@result:map(_pipe, fun(Field@0) -> {ok, Field@0} end);
_ ->
_pipe@1 = Response,
_pipe@2 = {error, _pipe@1},
{ok, _pipe@2}
end.
-file("src/oadr3/operations.gleam", 807).
-spec list_all_notifiers_request(gleam@http@request:request(KHG)) -> gleam@http@request:request(KHG).
list_all_notifiers_request(Base) ->
Method = get,
Path = <<"/notifiers"/utf8>>,
Query = [],
_pipe = Base,
_pipe@1 = oadr3@utils:set_method(_pipe, Method),
_pipe@2 = oadr3@utils:append_path(_pipe@1, Path),
oadr3@utils:set_query(_pipe@2, Query).
-file("src/oadr3/operations.gleam", 817).
-spec list_all_notifiers_response(gleam@http@response:response(bitstring())) -> {ok,
{ok, oadr3@schema:notifiers_response()} |
{error, gleam@http@response:response(bitstring())}} |
{error, gleam@json:decode_error()}.
list_all_notifiers_response(Response) ->
{response, Status, _, Body} = Response,
case Status of
200 ->
_pipe = gleam@json:parse_bits(
Body,
oadr3@schema:notifiers_response_decoder()
),
gleam@result:map(_pipe, fun(Field@0) -> {ok, Field@0} end);
_ ->
_pipe@1 = Response,
_pipe@2 = {error, _pipe@1},
{ok, _pipe@2}
end.
-file("src/oadr3/operations.gleam", 827).
-spec delete_event_request(gleam@http@request:request(KHY), binary()) -> gleam@http@request:request(KHY).
delete_event_request(Base, Event_id) ->
Method = delete,
Path = <<"/events/"/utf8, Event_id/binary>>,
Query = [],
_pipe = Base,
_pipe@1 = oadr3@utils:set_method(_pipe, Method),
_pipe@2 = oadr3@utils:append_path(_pipe@1, Path),
oadr3@utils:set_query(_pipe@2, Query).
-file("src/oadr3/operations.gleam", 837).
-spec delete_event_response(gleam@http@response:response(bitstring())) -> {ok,
{ok, {oadr3@schema:object_metadata(), oadr3@schema:event_request()}} |
{error, gleam@http@response:response(bitstring())}} |
{error, gleam@json:decode_error()}.
delete_event_response(Response) ->
{response, Status, _, Body} = Response,
case Status of
200 ->
_pipe = gleam@json:parse_bits(Body, oadr3@schema:event_decoder()),
gleam@result:map(_pipe, fun(Field@0) -> {ok, Field@0} end);
_ ->
_pipe@1 = Response,
_pipe@2 = {error, _pipe@1},
{ok, _pipe@2}
end.
-file("src/oadr3/operations.gleam", 845).
-spec update_event_request(
gleam@http@request:request(any()),
binary(),
oadr3@schema:event_request()
) -> gleam@http@request:request(bitstring()).
update_event_request(Base, Event_id, Data) ->
Method = put,
Path = <<"/events/"/utf8, Event_id/binary>>,
Query = [],
Body = oadr3@utils:json_to_bits(oadr3@schema:event_request_encode(Data)),
_pipe = Base,
_pipe@1 = oadr3@utils:set_method(_pipe, Method),
_pipe@2 = oadr3@utils:append_path(_pipe@1, Path),
_pipe@3 = oadr3@utils:set_query(_pipe@2, Query),
oadr3@utils:set_body(_pipe@3, <<"application/json"/utf8>>, Body).
-file("src/oadr3/operations.gleam", 857).
-spec update_event_response(gleam@http@response:response(bitstring())) -> {ok,
{ok, {oadr3@schema:object_metadata(), oadr3@schema:event_request()}} |
{error, gleam@http@response:response(bitstring())}} |
{error, gleam@json:decode_error()}.
update_event_response(Response) ->
{response, Status, _, Body} = Response,
case Status of
200 ->
_pipe = gleam@json:parse_bits(Body, oadr3@schema:event_decoder()),
gleam@result:map(_pipe, fun(Field@0) -> {ok, Field@0} end);
_ ->
_pipe@1 = Response,
_pipe@2 = {error, _pipe@1},
{ok, _pipe@2}
end.
-file("src/oadr3/operations.gleam", 865).
-spec search_events_by_id_request(gleam@http@request:request(KJK), binary()) -> gleam@http@request:request(KJK).
search_events_by_id_request(Base, Event_id) ->
Method = get,
Path = <<"/events/"/utf8, Event_id/binary>>,
Query = [],
_pipe = Base,
_pipe@1 = oadr3@utils:set_method(_pipe, Method),
_pipe@2 = oadr3@utils:append_path(_pipe@1, Path),
oadr3@utils:set_query(_pipe@2, Query).
-file("src/oadr3/operations.gleam", 875).
-spec search_events_by_id_response(gleam@http@response:response(bitstring())) -> {ok,
{ok, {oadr3@schema:object_metadata(), oadr3@schema:event_request()}} |
{error, gleam@http@response:response(bitstring())}} |
{error, gleam@json:decode_error()}.
search_events_by_id_response(Response) ->
{response, Status, _, Body} = Response,
case Status of
200 ->
_pipe = gleam@json:parse_bits(Body, oadr3@schema:event_decoder()),
gleam@result:map(_pipe, fun(Field@0) -> {ok, Field@0} end);
_ ->
_pipe@1 = Response,
_pipe@2 = {error, _pipe@1},
{ok, _pipe@2}
end.
-file("src/oadr3/operations.gleam", 883).
-spec create_event_request(
gleam@http@request:request(any()),
oadr3@schema:event_request()
) -> gleam@http@request:request(bitstring()).
create_event_request(Base, Data) ->
Method = post,
Path = <<"/events"/utf8>>,
Query = [],
Body = oadr3@utils:json_to_bits(oadr3@schema:event_request_encode(Data)),
_pipe = Base,
_pipe@1 = oadr3@utils:set_method(_pipe, Method),
_pipe@2 = oadr3@utils:append_path(_pipe@1, Path),
_pipe@3 = oadr3@utils:set_query(_pipe@2, Query),
oadr3@utils:set_body(_pipe@3, <<"application/json"/utf8>>, Body).
-file("src/oadr3/operations.gleam", 895).
-spec create_event_response(gleam@http@response:response(bitstring())) -> {ok,
{ok, {oadr3@schema:object_metadata(), oadr3@schema:event_request()}} |
{error, gleam@http@response:response(bitstring())}} |
{error, gleam@json:decode_error()}.
create_event_response(Response) ->
{response, Status, _, Body} = Response,
case Status of
201 ->
_pipe = gleam@json:parse_bits(Body, oadr3@schema:event_decoder()),
gleam@result:map(_pipe, fun(Field@0) -> {ok, Field@0} end);
_ ->
_pipe@1 = Response,
_pipe@2 = {error, _pipe@1},
{ok, _pipe@2}
end.
-file("src/oadr3/operations.gleam", 903).
-spec search_all_events_request(
gleam@http@request:request(KLG),
gleam@option:option(binary()),
gleam@option:option(any()),
gleam@option:option(integer()),
gleam@option:option(integer()),
gleam@option:option(boolean())
) -> gleam@http@request:request(KLG).
search_all_events_request(Base, Program_id, Targets, Skip, Limit, Active) ->
Method = get,
Path = <<"/events"/utf8>>,
Query = [{<<"program_id"/utf8>>, Program_id},
{<<"targets"/utf8>>,
gleam@option:map(
Targets,
fun(_) -> erlang:error(#{gleam_error => panic,
message => <<"query parameter is not supported"/utf8>>,
file => <<?FILEPATH/utf8>>,
module => <<"oadr3/operations"/utf8>>,
function => <<"search_all_events_request"/utf8>>,
line => 917}) end
)},
{<<"skip"/utf8>>,
gleam@option:map(Skip, fun erlang:integer_to_binary/1)},
{<<"limit"/utf8>>,
gleam@option:map(Limit, fun erlang:integer_to_binary/1)},
{<<"active"/utf8>>,
gleam@option:map(Active, fun gleam@bool:to_string/1)}],
_pipe = Base,
_pipe@1 = oadr3@utils:set_method(_pipe, Method),
_pipe@2 = oadr3@utils:append_path(_pipe@1, Path),
oadr3@utils:set_query(_pipe@2, Query).
-file("src/oadr3/operations.gleam", 929).
-spec search_all_events_response(gleam@http@response:response(bitstring())) -> {ok,
{ok,
list({oadr3@schema:object_metadata(),
oadr3@schema:event_request()})} |
{error, gleam@http@response:response(bitstring())}} |
{error, gleam@json:decode_error()}.
search_all_events_response(Response) ->
{response, Status, _, Body} = Response,
case Status of
200 ->
_pipe = gleam@json:parse_bits(
Body,
gleam@dynamic@decode:list(oadr3@schema:event_decoder())
),
gleam@result:map(_pipe, fun(Field@0) -> {ok, Field@0} end);
_ ->
_pipe@1 = Response,
_pipe@2 = {error, _pipe@1},
{ok, _pipe@2}
end.
-file("src/oadr3/operations.gleam", 939).
-spec fetch_token_request(gleam@http@request:request(KLZ)) -> gleam@http@request:request(KLZ).
fetch_token_request(Base) ->
Method = post,
Path = <<"/auth/token"/utf8>>,
Query = [],
_pipe = Base,
_pipe@1 = oadr3@utils:set_method(_pipe, Method),
_pipe@2 = oadr3@utils:append_path(_pipe@1, Path),
oadr3@utils:set_query(_pipe@2, Query).
-file("src/oadr3/operations.gleam", 949).
-spec fetch_token_response(gleam@http@response:response(bitstring())) -> {ok,
{ok, oadr3@schema:client_credential_response()} |
{error, gleam@http@response:response(bitstring())}} |
{error, gleam@json:decode_error()}.
fetch_token_response(Response) ->
{response, Status, _, Body} = Response,
case Status of
200 ->
_pipe = gleam@json:parse_bits(
Body,
oadr3@schema:client_credential_response_decoder()
),
gleam@result:map(_pipe, fun(Field@0) -> {ok, Field@0} end);
_ ->
_pipe@1 = Response,
_pipe@2 = {error, _pipe@1},
{ok, _pipe@2}
end.
-file("src/oadr3/operations.gleam", 959).
-spec get_auth_server_info_request(gleam@http@request:request(KMR)) -> gleam@http@request:request(KMR).
get_auth_server_info_request(Base) ->
Method = get,
Path = <<"/auth/server"/utf8>>,
Query = [],
_pipe = Base,
_pipe@1 = oadr3@utils:set_method(_pipe, Method),
_pipe@2 = oadr3@utils:append_path(_pipe@1, Path),
oadr3@utils:set_query(_pipe@2, Query).
-file("src/oadr3/operations.gleam", 969).
-spec get_auth_server_info_response(gleam@http@response:response(bitstring())) -> {ok,
{ok, oadr3@schema:auth_server_info()} | {error, oadr3@schema:problem()}} |
{error, gleam@json:decode_error()}.
get_auth_server_info_response(Response) ->
{response, Status, _, Body} = Response,
case Status of
200 ->
_pipe = gleam@json:parse_bits(
Body,
oadr3@schema:auth_server_info_decoder()
),
gleam@result:map(_pipe, fun(Field@0) -> {ok, Field@0} end);
_ ->
_pipe@1 = gleam@json:parse_bits(
Body,
oadr3@schema:problem_decoder()
),
gleam@result:map(_pipe@1, fun(Field@0) -> {error, Field@0} end)
end.