skeleton for AML decision server handler
This commit is contained in:
Christian Grothoff
parent
3a7045bfca
commit
c30ee88336
149
src/exchange/taler-exchange-httpd_aml-decision.c
Normal file
149
src/exchange/taler-exchange-httpd_aml-decision.c
Normal file
@ -0,0 +1,149 @@
|
|||||||
|
/*
|
||||||
|
This file is part of TALER
|
||||||
|
Copyright (C) 2023 Taler Systems SA
|
||||||
|
|
||||||
|
TALER is free software; you can redistribute it and/or modify it under the
|
||||||
|
terms of the GNU Affero General Public License as published by the Free Software
|
||||||
|
Foundation; either version 3, or (at your option) any later version.
|
||||||
|
|
||||||
|
TALER is distributed in the hope that it will be useful, but WITHOUT ANY
|
||||||
|
WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR
|
||||||
|
A PARTICULAR PURPOSE. See the GNU Affero General Public License for more details.
|
||||||
|
|
||||||
|
You should have received a copy of the GNU Affero General Public License along with
|
||||||
|
TALER; see the file COPYING. If not, see <http://www.gnu.org/licenses/>
|
||||||
|
*/
|
||||||
|
/**
|
||||||
|
* @file taler-exchange-httpd_aml-decision.c
|
||||||
|
* @brief Handle request about an AML decision.
|
||||||
|
* @author Christian Grothoff
|
||||||
|
*/
|
||||||
|
#include "platform.h"
|
||||||
|
#include <gnunet/gnunet_util_lib.h>
|
||||||
|
#include <gnunet/gnunet_json_lib.h>
|
||||||
|
#include <jansson.h>
|
||||||
|
#include <microhttpd.h>
|
||||||
|
#include <pthread.h>
|
||||||
|
#include "taler_json_lib.h"
|
||||||
|
#include "taler_mhd_lib.h"
|
||||||
|
#include "taler_signatures.h"
|
||||||
|
#include "taler-exchange-httpd_responses.h"
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
MHD_RESULT
|
||||||
|
TEH_handler_management_post_aml_decision (
|
||||||
|
struct MHD_Connection *connection,
|
||||||
|
const json_t *root)
|
||||||
|
{
|
||||||
|
const char *justification;
|
||||||
|
struct GNUNET_TIME_Timestamp decision_time;
|
||||||
|
struct TALER_Amount new_threshold;
|
||||||
|
struct TALER_PaytoHashP h_payto;
|
||||||
|
uint32_t new_state32;
|
||||||
|
enum TALER_AmlDecisionState new_state;
|
||||||
|
struct TALER_AmlOfficerPublicKeyP officer_pub;
|
||||||
|
struct TALER_AmlOfficerSignatureP officer_sig;
|
||||||
|
struct GNUNET_JSON_Specification spec[] = {
|
||||||
|
GNUNET_JSON_spec_fixed_auto ("officer_pub",
|
||||||
|
&officer_pub),
|
||||||
|
GNUNET_JSON_spec_fixed_auto ("officer_sig",
|
||||||
|
&officer_sig),
|
||||||
|
GNUNET_JSON_spec_fixed_auto ("h_payto",
|
||||||
|
&h_payto),
|
||||||
|
TALER_JSON_spec_amount ("new_threshold",
|
||||||
|
&new_threshold),
|
||||||
|
GNUNET_JSON_spec_string ("justification",
|
||||||
|
&justification),
|
||||||
|
GNUNET_JSON_spec_timestamp ("decision_time",
|
||||||
|
&decision_time),
|
||||||
|
GNUNET_JSON_spec_uint32 ("new_state",
|
||||||
|
&new_state32),
|
||||||
|
GNUNET_JSON_spec_end ()
|
||||||
|
};
|
||||||
|
|
||||||
|
{
|
||||||
|
enum GNUNET_GenericReturnValue res;
|
||||||
|
|
||||||
|
res = TALER_MHD_parse_json_data (connection,
|
||||||
|
root,
|
||||||
|
spec);
|
||||||
|
if (GNUNET_SYSERR == res)
|
||||||
|
return MHD_NO; /* hard failure */
|
||||||
|
if (GNUNET_NO == res)
|
||||||
|
return MHD_YES; /* failure */
|
||||||
|
}
|
||||||
|
new_state = (enum TALER_AmlDecisionState) new_state32;
|
||||||
|
TEH_METRICS_num_verifications[TEH_MT_SIGNATURE_EDDSA]++;
|
||||||
|
if (GNUNET_OK !=
|
||||||
|
TALER_exchange_aml_decision_verify (justification,
|
||||||
|
decision_time,
|
||||||
|
&new_threshold,
|
||||||
|
&h_payto,
|
||||||
|
new_state,
|
||||||
|
&officer_pub,
|
||||||
|
&officer_sig))
|
||||||
|
{
|
||||||
|
GNUNET_break_op (0);
|
||||||
|
return TALER_MHD_reply_with_error (
|
||||||
|
connection,
|
||||||
|
MHD_HTTP_FORBIDDEN,
|
||||||
|
TALER_EC_EXCHANGE_AML_DECISION_ADD_SIGNATURE_INVALID,
|
||||||
|
NULL);
|
||||||
|
}
|
||||||
|
{
|
||||||
|
enum GNUNET_DB_QueryStatus qs;
|
||||||
|
struct GNUNET_TIME_Timestamp last_date;
|
||||||
|
bool invalid_officer;
|
||||||
|
|
||||||
|
do {
|
||||||
|
qs = TEH_plugin->add_aml_decision (TEH_plugin->cls,
|
||||||
|
justification,
|
||||||
|
decision_time,
|
||||||
|
&new_threshold,
|
||||||
|
&h_payto,
|
||||||
|
new_state,
|
||||||
|
&officer_pub,
|
||||||
|
&officer_sig,
|
||||||
|
&invalid_officer,
|
||||||
|
&last_date);
|
||||||
|
} while (GNUNET_DB_STATUS_SOFT_ERROR == qs);
|
||||||
|
if (qs < 0)
|
||||||
|
{
|
||||||
|
GNUNET_break (0);
|
||||||
|
*mhd_ret = TALER_MHD_reply_with_error (connection,
|
||||||
|
MHD_HTTP_INTERNAL_SERVER_ERROR,
|
||||||
|
TALER_EC_GENERIC_DB_STORE_FAILED,
|
||||||
|
"add aml_decision");
|
||||||
|
return qs;
|
||||||
|
}
|
||||||
|
if (invalid_officer)
|
||||||
|
{
|
||||||
|
return TALER_MHD_reply_with_error (
|
||||||
|
connection,
|
||||||
|
MHD_HTTP_FORBIDDEN,
|
||||||
|
TALER_EC_EXCHANGE_AML_DECISION_INVALID_OFFICER,
|
||||||
|
NULL);
|
||||||
|
}
|
||||||
|
if (GNUNET_TIME_timestamp_cmp (last_date,
|
||||||
|
>,
|
||||||
|
validity_start))
|
||||||
|
{
|
||||||
|
GNUNET_break_op (0);
|
||||||
|
return TALER_MHD_reply_with_error (
|
||||||
|
connection,
|
||||||
|
MHD_HTTP_CONFLICT,
|
||||||
|
TALER_EC_EXCHANGE_AML_DECISION_MORE_RECENT_PRESENT,
|
||||||
|
NULL);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return TALER_MHD_reply_static (
|
||||||
|
connection,
|
||||||
|
MHD_HTTP_NO_CONTENT,
|
||||||
|
NULL,
|
||||||
|
NULL,
|
||||||
|
0);
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
/* end of taler-exchange-httpd_aml-decision.c */
|
||||||
Loading…
Reference in New Issue
Block a user