Create a Function to Fetch and Store Messages from Negarit (message queue)

[biniyam-29]

Develop a backend function for fetching messages directly from Negarit’s service and storing them in the SoulSync database. This function will handle messages such as mentor requests or updates, ensuring they are stored securely and made available for the platform’s matchmaking processes. The function will run independently of the frontend, triggered periodically or by specific events.

Detailed Requirements:

1. Purpose:

• Automate the retrieval and storage of messages from Negarit to keep SoulSync’s database updated in real time,

2. Negarit API Integration:

• Use Negarit’s API to fetch messages.
• Ensure the API integration is robust and capable of handling large volumes of messages.

3. Data Processing:

• Extract relevant fields from each message:
• messageContent: Text of the message.
• senderId: Identifier for the message sender.
• timestamp: When the message was created.
• Perform any necessary transformations to align the message format with SoulSync’s database schema.

4. Database Storage:

• Save each message to the database, ensuring data integrity.
• Implement checks to prevent duplicate messages from being stored unnecessarily.

5. Error Handling & Logging:

• Log all successful fetch and save operations for monitoring purposes.
• For errors (e.g., connection issues, invalid data), log detailed error messages and implement retry logic where applicable.

6. Scalability & Security:

• Ensure the function can handle high volumes of messages if SoulSync scales. (eg. Batch Processing)
• Use secure API keys or tokens to authenticate with Negarit.