From dc85e0e789f7dbbe159d0fc8528227b2bd0bcf6b Mon Sep 17 00:00:00 2001
From: Granyaa <MrGrayDanY@gmail.com>
Date: Wed, 14 Jan 2026 16:06:07 +0200
Subject: [PATCH] Added bucket functionality

---
 attachments/nano_attachment/nano_attachment.c | 27 ++++-----
 .../nano_attachment/nano_attachment_bucket.c  | 56 +++++++++++++++++++
 .../nano_attachment/nano_attachment_bucket.h  |  5 ++
 .../nano_attachment/nano_initializer.h        |  2 +
 4 files changed, 75 insertions(+), 15 deletions(-)

diff --git a/attachments/nano_attachment/nano_attachment.c b/attachments/nano_attachment/nano_attachment.c
index 2008cc7..7c6cfd5 100755
--- a/attachments/nano_attachment/nano_attachment.c
+++ b/attachments/nano_attachment/nano_attachment.c
@@ -278,31 +278,28 @@ isNanoQueueEmpty(NanoAttachment *attachment)
     return false;
 }
 
-// TODO: Implement
-// [hash on session id] -> [verdict+modification]
-// Updating the table, and then return the session ID to the caller
 SessionID
 PopFromNanoQueue(NanoAttachment *attachment)
 {
-    // Pop from queue
-    // Put into hash table.
-
+    AttachmentVerdictResponse response;
     SessionID session_id = 0;
+    NanoCommunicationResult res;
+    // Pop from queue
+
+    res = NanoAsyncAddResponse(attachment, session_id, &response);
+    if (res != NANO_OK) {
+        return 0;
+    }
+
     return session_id;
 }
 
-// TODO: Implement
-// given a sessionID return a verdict from the table.
 AttachmentVerdictResponse
 getAttachmentVerdictResponse(NanoAttachment *attachment, SessionID session_id)
 {
-    (void)attachment;
-    (void)session_id;
-    return (AttachmentVerdictResponse) {
-        .verdict = ATTACHMENT_VERDICT_INSPECT,
-        .session_id = session_id,
-        .modifications = NULL
-    };
+    AttachmentVerdictResponse response = NanoAsyncFindResponse(attachment, session_id);
+    NanoAsyncRemoveResponse(attachment, session_id);
+    return response;
 }
 
 
diff --git a/attachments/nano_attachment/nano_attachment_bucket.c b/attachments/nano_attachment/nano_attachment_bucket.c
index 21b0b40..b847de9 100644
--- a/attachments/nano_attachment/nano_attachment_bucket.c
+++ b/attachments/nano_attachment/nano_attachment_bucket.c
@@ -1 +1,57 @@
 #include "nano_attachment_bucket.h"
+
+#define CP_ASYNC_CTX_BUCKETS 2048 ///< Hash table buckets for better distribution
+
+///
+/// @brief Hash function for session IDs using Knuth's multiplicative method
+/// @param[in] session_id Session ID to hash
+/// @return Hash bucket index
+///
+static uint
+nano_attachment_async_ctx_hash(SessionID session_id)
+{
+    // Knuth's multiplicative hash with golden ratio constant
+    static const uint32_t KNUTH_CONSTANT = 2654435761U; // (sqrt(5) - 1) / 2 * 2^32
+    return (session_id * KNUTH_CONSTANT) % CP_ASYNC_CTX_BUCKETS;
+}
+
+AttachmentVerdictResponse
+NanoAsyncFindResponse(NanoAttachment *attachment, SessionID session_id)
+{
+    AttachmentVerdictResponse response;
+    uint bucket = nano_attachment_async_ctx_hash(session_id);
+
+    response.verdict = attachment->async_buckets[bucket]->verdict;
+    response.session_id = attachment->async_buckets[bucket]->session_id;
+    response.modifications = attachment->async_buckets[bucket]->modifications;
+    response.web_response_data = attachment->async_buckets[bucket]->web_response_data;
+    
+    return response;
+}
+
+NanoCommunicationResult
+NanoAsyncAddResponse(NanoAttachment *attachment, SessionID session_id, AttachmentVerdictResponse *response)
+{
+    uint bucket;
+    
+    if (response == NULL) {
+        return NANO_ERROR;
+    }
+
+    bucket = nano_attachment_async_ctx_hash(session_id);
+    attachment->async_buckets[bucket]->session_id = response->session_id;
+    attachment->async_buckets[bucket]->verdict = response->verdict;
+    attachment->async_buckets[bucket]->modifications = response->modifications;
+    attachment->async_buckets[bucket]->web_response_data = response->web_response_data;
+    return NANO_OK;
+}
+
+void
+NanoAsyncRemoveResponse(NanoAttachment *attachment, SessionID session_id)
+{
+    uint bucket = nano_attachment_async_ctx_hash(ctx->session_id);
+    attachment->async_buckets[bucket]->session_id = 0;
+    attachment->async_buckets[bucket]->verdict = ATTACHMENT_VERDICT_INSPECT;
+    attachment->async_buckets[bucket]->modifications = NULL;
+    attachment->async_buckets[bucket]->web_response_data = NULL;
+}
diff --git a/attachments/nano_attachment/nano_attachment_bucket.h b/attachments/nano_attachment/nano_attachment_bucket.h
index 6069899..ac8685d 100644
--- a/attachments/nano_attachment/nano_attachment_bucket.h
+++ b/attachments/nano_attachment/nano_attachment_bucket.h
@@ -5,4 +5,9 @@
 #include "nano_attachment_common.h"
 #include "nano_initializer.h"
 
+AttachmentVerdictResponse NanoAsyncFindResponse(NanoAttachment *attachment, SessionID session_id);
+
+NanoCommunicationResult NanoAsyncAddResponse(NanoAttachment *attachment, SessionID session_id, AttachmentVerdictResponse *response);
+
+void NanoAsyncRemoveResponse(NanoAttachment *attachment, SessionID session_id);
 #endif // __NANO_ATTACHMENT_BUCKET_H__
diff --git a/attachments/nano_attachment/nano_initializer.h b/attachments/nano_attachment/nano_initializer.h
index 403c2ad..6ae4d31 100644
--- a/attachments/nano_attachment/nano_initializer.h
+++ b/attachments/nano_attachment/nano_initializer.h
@@ -86,6 +86,8 @@ typedef struct NanoAttachment {
     uint64_t metric_data[METRIC_TYPES_COUNT];
     uint64_t metric_average_data_divisor[METRIC_TYPES_COUNT];
 #endif
+
+    AttachmentVerdictResponse async_buckets[CP_ASYNC_CTX_BUCKETS]; ///< Buckets for storing verdict responses.
 } NanoAttachment;
 
 ///