summaryrefslogtreecommitdiff
path: root/src/importer.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/importer.cpp')
-rw-r--r--src/importer.cpp78
1 files changed, 39 insertions, 39 deletions
diff --git a/src/importer.cpp b/src/importer.cpp
index c3757ce..23bdcbe 100644
--- a/src/importer.cpp
+++ b/src/importer.cpp
@@ -69,22 +69,22 @@ static void _batch_query_response_handler(invoice* buffer, char* json)
}
else if (strops::equals(rb, "5")) {
strops::get_json_value(json, "address1", rb, alloc_size);
- strops::copy(buffer->supplier.address.address1, rb, sizeof(buffer->supplier.address.address1));
+ strops::copy(buffer->supplier.addr.address1, rb, sizeof(buffer->supplier.addr.address1));
strops::get_json_value(json, "address2", rb, alloc_size);
- strops::copy(buffer->supplier.address.address2, rb, sizeof(buffer->supplier.address.address2));
+ strops::copy(buffer->supplier.addr.address2, rb, sizeof(buffer->supplier.addr.address2));
strops::get_json_value(json, "city", rb, alloc_size);
- strops::copy(buffer->supplier.address.city, rb, sizeof(buffer->supplier.address.city));
+ strops::copy(buffer->supplier.addr.city, rb, sizeof(buffer->supplier.addr.city));
strops::get_json_value(json, "postal", rb, alloc_size);
- strops::copy(buffer->supplier.address.postal, rb, sizeof(buffer->supplier.address.postal));
+ strops::copy(buffer->supplier.addr.postal, rb, sizeof(buffer->supplier.addr.postal));
strops::get_json_value(json, "region", rb, alloc_size);
- strops::copy(buffer->supplier.address.region, rb, sizeof(buffer->supplier.address.region));
+ strops::copy(buffer->supplier.addr.region, rb, sizeof(buffer->supplier.addr.region));
strops::get_json_value(json, "country_code", rb, alloc_size);
- strops::copy(buffer->supplier.address.country_code, rb, sizeof(buffer->supplier.address.country_code));
+ strops::copy(buffer->supplier.addr.country_code, rb, sizeof(buffer->supplier.addr.country_code));
strops::get_json_value(json, "is_business", rb, alloc_size);
buffer->supplier.type = (strops::equals(rb, "true")) ? contact_type::CONTACT_BUSINESS : contact_type::CONTACT_CONSUMER;
@@ -109,22 +109,22 @@ static void _batch_query_response_handler(invoice* buffer, char* json)
}
else if (strops::equals(rb, "6")) {
strops::get_json_value(json, "address1", rb, alloc_size);
- strops::copy(buffer->customer.address.address1, rb, sizeof(buffer->customer.address.address1));
+ strops::copy(buffer->customer.addr.address1, rb, sizeof(buffer->customer.addr.address1));
strops::get_json_value(json, "address2", rb, alloc_size);
- strops::copy(buffer->customer.address.address2, rb, sizeof(buffer->customer.address.address2));
+ strops::copy(buffer->customer.addr.address2, rb, sizeof(buffer->customer.addr.address2));
strops::get_json_value(json, "city", rb, alloc_size);
- strops::copy(buffer->customer.address.city, rb, sizeof(buffer->customer.address.city));
+ strops::copy(buffer->customer.addr.city, rb, sizeof(buffer->customer.addr.city));
strops::get_json_value(json, "postal", rb, alloc_size);
- strops::copy(buffer->customer.address.postal, rb, sizeof(buffer->customer.address.postal));
+ strops::copy(buffer->customer.addr.postal, rb, sizeof(buffer->customer.addr.postal));
strops::get_json_value(json, "region", rb, alloc_size);
- strops::copy(buffer->customer.address.region, rb, sizeof(buffer->customer.address.region));
+ strops::copy(buffer->customer.addr.region, rb, sizeof(buffer->customer.addr.region));
strops::get_json_value(json, "country_code", rb, alloc_size);
- strops::copy(buffer->customer.address.country_code, rb, sizeof(buffer->customer.address.country_code));
+ strops::copy(buffer->customer.addr.country_code, rb, sizeof(buffer->customer.addr.country_code));
strops::get_json_value(json, "is_business", rb, alloc_size);
buffer->customer.type = (strops::equals(rb, "true")) ? contact_type::CONTACT_BUSINESS : contact_type::CONTACT_CONSUMER;
@@ -149,22 +149,22 @@ static void _batch_query_response_handler(invoice* buffer, char* json)
}
else if (strops::equals(rb, "7")) {
strops::get_json_value(json, "address1", rb, alloc_size);
- strops::copy(buffer->addressee.address.address1, rb, sizeof(buffer->addressee.address.address1));
+ strops::copy(buffer->addressee.addr.address1, rb, sizeof(buffer->addressee.addr.address1));
strops::get_json_value(json, "address2", rb, alloc_size);
- strops::copy(buffer->addressee.address.address2, rb, sizeof(buffer->addressee.address.address2));
+ strops::copy(buffer->addressee.addr.address2, rb, sizeof(buffer->addressee.addr.address2));
strops::get_json_value(json, "city", rb, alloc_size);
- strops::copy(buffer->addressee.address.city, rb, sizeof(buffer->addressee.address.city));
+ strops::copy(buffer->addressee.addr.city, rb, sizeof(buffer->addressee.addr.city));
strops::get_json_value(json, "postal", rb, alloc_size);
- strops::copy(buffer->addressee.address.postal, rb, sizeof(buffer->addressee.address.postal));
+ strops::copy(buffer->addressee.addr.postal, rb, sizeof(buffer->addressee.addr.postal));
strops::get_json_value(json, "region", rb, alloc_size);
- strops::copy(buffer->addressee.address.region, rb, sizeof(buffer->addressee.address.region));
+ strops::copy(buffer->addressee.addr.region, rb, sizeof(buffer->addressee.addr.region));
strops::get_json_value(json, "country_code", rb, alloc_size);
- strops::copy(buffer->addressee.address.country_code, rb, sizeof(buffer->addressee.address.country_code));
+ strops::copy(buffer->addressee.addr.country_code, rb, sizeof(buffer->addressee.addr.country_code));
strops::get_json_value(json, "name", rb, alloc_size);
strops::copy(buffer->addressee.name, rb, sizeof(buffer->addressee.name));
@@ -210,16 +210,16 @@ static int _ai_document_to_invoice_t(void *arg)
char* file_path = request->file_path;
importer::ai_provider_impl impl = importer::get_ai_provider_implementation(administration::get_active_ai_service().provider);
- request->status = importer::status::IMPORT_UPLOADING_FILE;
+ request->status = importer::import_status::IMPORT_UPLOADING_FILE;
char file_id[100];
if (!impl.upload_file(file_path, file_id, 100)) {
- request->status = importer::status::IMPORT_DONE;
+ request->status = importer::import_status::IMPORT_DONE;
request->error = I_ERR_FAILED_UPLOAD;
return 0;
}
- request->status = importer::status::IMPORT_WAITING_FOR_RESPONSE;
+ request->status = importer::import_status::IMPORT_WAITING_FOR_RESPONSE;
const char* queries[] = {
"What is the invoice number/ID? Return json containing sequential_number (string), query_id = 1 (string)",
@@ -252,14 +252,14 @@ static int _ai_document_to_invoice_t(void *arg)
invoice inv = administration::invoice_create_empty();
if (!impl.batch_query_with_file(queries, sizeof(queries) / sizeof(char*), file_id, &inv, _batch_query_response_handler)) {
- request->status = importer::status::IMPORT_DONE;
+ request->status = importer::import_status::IMPORT_DONE;
request->error = I_ERR_FAILED_QUERY;
return 0;
}
inv.extras.status = invoice_status::INVOICE_RECEIVED;
- inv.is_triangulation = !memops::equals(&inv.addressee.address, &inv.customer.address, sizeof(address));
+ inv.is_triangulation = !memops::equals(&inv.addressee.addr, &inv.customer.addr, sizeof(address));
strops::copy(inv.customer.id, MY_COMPANY_ID, MAX_LEN_ID);
@@ -268,10 +268,10 @@ static int _ai_document_to_invoice_t(void *arg)
strops::copy(inv.cost_center_id, "", MAX_LEN_ID);
// Set document references and save copy to disk.
- strops::copy(inv.document.original_path, file_path, MAX_LEN_PATH);
- strops::copy(inv.document.copy_path, "", MAX_LEN_PATH);
+ strops::copy(inv.orig_document.original_path, file_path, MAX_LEN_PATH);
+ strops::copy(inv.orig_document.copy_path, "", MAX_LEN_PATH);
- request->status = importer::status::IMPORT_DONE;
+ request->status = importer::import_status::IMPORT_DONE;
request->result = administration::invoice_create_copy(&inv);
return 0;
}
@@ -281,7 +281,7 @@ importer::invoice_request* importer::ai_document_to_invoice(char* file_path)
importer::invoice_request* result = (importer::invoice_request*)memops::alloc(sizeof(importer::invoice_request));
result->started_at = time(NULL);
result->error = I_ERR_SUCCESS;
- result->status = importer::status::IMPORT_STARTING;
+ result->status = importer::import_status::IMPORT_STARTING;
strops::copy(result->file_path, file_path, MAX_LEN_PATH);
thrd_t thr;
@@ -298,20 +298,20 @@ static int _ai_get_available_models_t(void* arg)
importer::ai_provider_impl impl = importer::get_ai_provider_implementation(request->service);
if (!impl.get_available_models) {
- request->status = importer::status::IMPORT_DONE;
+ request->status = importer::import_status::IMPORT_DONE;
request->error = I_ERR_UNIMPLEMENTED;
return 0;
}
- request->status = importer::status::IMPORT_WAITING_FOR_RESPONSE;
+ request->status = importer::import_status::IMPORT_WAITING_FOR_RESPONSE;
if (!impl.get_available_models(request)) {
- request->status = importer::status::IMPORT_DONE;
+ request->status = importer::import_status::IMPORT_DONE;
request->error = I_ERR_FAILED_QUERY;
return 0;
}
- request->status = importer::status::IMPORT_DONE;
+ request->status = importer::import_status::IMPORT_DONE;
return 0;
}
@@ -321,14 +321,14 @@ importer::model_list_request* importer::ai_get_available_models(ai_provider serv
importer::model_list_request* result = (importer::model_list_request*)memops::alloc(sizeof(importer::model_list_request));
result->started_at = time(NULL);
result->error = I_ERR_SUCCESS;
- result->status = importer::status::IMPORT_STARTING;
+ result->status = importer::import_status::IMPORT_STARTING;
result->result_count = 0;
result->service = service;
memops::zero(result->result, sizeof(result->result));
thrd_t thr;
if (thrd_create(&thr, _ai_get_available_models_t, result) != thrd_success) {
- result->status = importer::status::IMPORT_DONE;
+ result->status = importer::import_status::IMPORT_DONE;
result->error = I_ERR_FAILED_QUERY;
return 0;
}
@@ -336,15 +336,15 @@ importer::model_list_request* importer::ai_get_available_models(ai_provider serv
return result;
}
-const char* importer::status_to_string(importer::status status)
+const char* importer::status_to_string(importer::import_status status)
{
switch(status)
{
- case importer::status::IMPORT_STARTING: return locale::get("import.status.starting");
- case importer::status::IMPORT_UPLOADING_FILE: return locale::get("import.status.uploading_file");
- case importer::status::IMPORT_QUERYING: return locale::get("import.status.querying");
- case importer::status::IMPORT_WAITING_FOR_RESPONSE: return locale::get("import.status.waiting_for_result");
- case importer::status::IMPORT_DONE: return locale::get("import.status.done");
+ case importer::import_status::IMPORT_STARTING: return locale::get("import.status.starting");
+ case importer::import_status::IMPORT_UPLOADING_FILE: return locale::get("import.status.uploading_file");
+ case importer::import_status::IMPORT_QUERYING: return locale::get("import.status.querying");
+ case importer::import_status::IMPORT_WAITING_FOR_RESPONSE: return locale::get("import.status.waiting_for_result");
+ case importer::import_status::IMPORT_DONE: return locale::get("import.status.done");
}
return "";
}
generated by cgit v1.2.3-70-g09d2 (git 2.46.0) at 2026-02-02 20:38:42 +0000