DevContext

Overview Schema Related Servers Score Discussions

job.service.js.html•16.8 KiB

<!doctype html> <html lang="en"> <head> <title>Code coverage report for src/services/job.service.js</title> <meta charset="utf-8" /> <link rel="stylesheet" href="../../prettify.css" /> <link rel="stylesheet" href="../../base.css" /> <link rel="shortcut icon" type="image/x-icon" href="../../favicon.png" /> <meta name="viewport" content="width=device-width, initial-scale=1" /> <style type='text/css'> .coverage-summary .sorter { background-image: url(../../sort-arrow-sprite.png); } </style> </head> <body> <div class='wrapper'> <div class='pad1'> <h1><a href="../../index.html">All files</a> / <a href="index.html">src/services</a> job.service.js</h1> <div class='clearfix'> <div class='fl pad1y space-right2'> 0% Statements 0/20 </div> <div class='fl pad1y space-right2'> 0% Branches 0/4 </div> <div class='fl pad1y space-right2'> 0% Functions 0/3 </div> <div class='fl pad1y space-right2'> 0% Lines 0/20 </div> </div> Press n or j to go to the next uncovered block, b, p or k for the previous block. <template id="filterTemplate"> <div class="quiet"> Filter: <input type="search" id="fileSearch"> </div> </template> </div> <div class='status-line low'></div> <pre><table class="coverage"> <tr><td class="line-count quiet"><a name='L1'></a><a href='#L1'>1</a> <a name='L2'></a><a href='#L2'>2</a> <a name='L3'></a><a href='#L3'>3</a> <a name='L4'></a><a href='#L4'>4</a> <a name='L5'></a><a href='#L5'>5</a> <a name='L6'></a><a href='#L6'>6</a> <a name='L7'></a><a href='#L7'>7</a> <a name='L8'></a><a href='#L8'>8</a> <a name='L9'></a><a href='#L9'>9</a> <a name='L10'></a><a href='#L10'>10</a> <a name='L11'></a><a href='#L11'>11</a> <a name='L12'></a><a href='#L12'>12</a> <a name='L13'></a><a href='#L13'>13</a> <a name='L14'></a><a href='#L14'>14</a> <a name='L15'></a><a href='#L15'>15</a> <a name='L16'></a><a href='#L16'>16</a> <a name='L17'></a><a href='#L17'>17</a> <a name='L18'></a><a href='#L18'>18</a> <a name='L19'></a><a href='#L19'>19</a> <a name='L20'></a><a href='#L20'>20</a> <a name='L21'></a><a href='#L21'>21</a> <a name='L22'></a><a href='#L22'>22</a> <a name='L23'></a><a href='#L23'>23</a> <a name='L24'></a><a href='#L24'>24</a> <a name='L25'></a><a href='#L25'>25</a> <a name='L26'></a><a href='#L26'>26</a> <a name='L27'></a><a href='#L27'>27</a> <a name='L28'></a><a href='#L28'>28</a> <a name='L29'></a><a href='#L29'>29</a> <a name='L30'></a><a href='#L30'>30</a> <a name='L31'></a><a href='#L31'>31</a> <a name='L32'></a><a href='#L32'>32</a> <a name='L33'></a><a href='#L33'>33</a> <a name='L34'></a><a href='#L34'>34</a> <a name='L35'></a><a href='#L35'>35</a> <a name='L36'></a><a href='#L36'>36</a> <a name='L37'></a><a href='#L37'>37</a> <a name='L38'></a><a href='#L38'>38</a> <a name='L39'></a><a href='#L39'>39</a> <a name='L40'></a><a href='#L40'>40</a> <a name='L41'></a><a href='#L41'>41</a> <a name='L42'></a><a href='#L42'>42</a> <a name='L43'></a><a href='#L43'>43</a> <a name='L44'></a><a href='#L44'>44</a> <a name='L45'></a><a href='#L45'>45</a> <a name='L46'></a><a href='#L46'>46</a> <a name='L47'></a><a href='#L47'>47</a> <a name='L48'></a><a href='#L48'>48</a> <a name='L49'></a><a href='#L49'>49</a> <a name='L50'></a><a href='#L50'>50</a> <a name='L51'></a><a href='#L51'>51</a> <a name='L52'></a><a href='#L52'>52</a> <a name='L53'></a><a href='#L53'>53</a> <a name='L54'></a><a href='#L54'>54</a> <a name='L55'></a><a href='#L55'>55</a> <a name='L56'></a><a href='#L56'>56</a> <a name='L57'></a><a href='#L57'>57</a> <a name='L58'></a><a href='#L58'>58</a> <a name='L59'></a><a href='#L59'>59</a> <a name='L60'></a><a href='#L60'>60</a> <a name='L61'></a><a href='#L61'>61</a> <a name='L62'></a><a href='#L62'>62</a> <a name='L63'></a><a href='#L63'>63</a> <a name='L64'></a><a href='#L64'>64</a> <a name='L65'></a><a href='#L65'>65</a> <a name='L66'></a><a href='#L66'>66</a> <a name='L67'></a><a href='#L67'>67</a> <a name='L68'></a><a href='#L68'>68</a> <a name='L69'></a><a href='#L69'>69</a> <a name='L70'></a><a href='#L70'>70</a> <a name='L71'></a><a href='#L71'>71</a> <a name='L72'></a><a href='#L72'>72</a> <a name='L73'></a><a href='#L73'>73</a> <a name='L74'></a><a href='#L74'>74</a> <a name='L75'></a><a href='#L75'>75</a> <a name='L76'></a><a href='#L76'>76</a> <a name='L77'></a><a href='#L77'>77</a> <a name='L78'></a><a href='#L78'>78</a> <a name='L79'></a><a href='#L79'>79</a> <a name='L80'></a><a href='#L80'>80</a> <a name='L81'></a><a href='#L81'>81</a> <a name='L82'></a><a href='#L82'>82</a> <a name='L83'></a><a href='#L83'>83</a> <a name='L84'></a><a href='#L84'>84</a> <a name='L85'></a><a href='#L85'>85</a> <a name='L86'></a><a href='#L86'>86</a> <a name='L87'></a><a href='#L87'>87</a> <a name='L88'></a><a href='#L88'>88</a> <a name='L89'></a><a href='#L89'>89</a> <a name='L90'></a><a href='#L90'>90</a> <a name='L91'></a><a href='#L91'>91</a> <a name='L92'></a><a href='#L92'>92</a> <a name='L93'></a><a href='#L93'>93</a> <a name='L94'></a><a href='#L94'>94</a> <a name='L95'></a><a href='#L95'>95</a> <a name='L96'></a><a href='#L96'>96</a> <a name='L97'></a><a href='#L97'>97</a> <a name='L98'></a><a href='#L98'>98</a> <a name='L99'></a><a href='#L99'>99</a> <a name='L100'></a><a href='#L100'>100</a> <a name='L101'></a><a href='#L101'>101</a> <a name='L102'></a><a href='#L102'>102</a> <a name='L103'></a><a href='#L103'>103</a></td><td class="line-coverage quiet">                                                                                                                                                                                                             </td><td class="text"><pre class="prettyprint lang-js">/** * BackgroundJobManager * * This service manages the queueing of background AI jobs for entity/document processing. */   import { v4 as uuidv4 } from "uuid"; import logger from "../utils/logger.js"; import initializeDbClient from "../db/client.js";   export class BackgroundJobManager { /** * Creates a new BackgroundJobManager instance */ constructor() { this.dbClient = null; this.initialized = false; }   /** * Initialize the BackgroundJobManager * @returns {Promise<void>} */ async initialize() { try { logger.info("Initializing BackgroundJobManager"); this.dbClient = initializeDbClient(); this.initialized = true; logger.info("BackgroundJobManager initialized successfully"); } catch (error) { logger.error( `Error initializing BackgroundJobManager: ${error.message}`, { error } ); throw error; } }   /** * Enqueue a new background AI job * @param {Object} jobDetails - Details of the job to enqueue * @param {string} jobDetails.task_type - Type of task to perform (e.g., 'enrich_entity_summary_keywords') * @param {string} jobDetails.target_entity_id - ID of the entity/document to process * @param {string} jobDetails.target_entity_type - Type of the target entity (e.g., 'code_entity', 'project_document') * @param {Object} [jobDetails.payload] - Optional additional data needed for the job * @returns {Promise<{job_id: string, success: boolean}>} - Result of the enqueue operation */ async enqueueJob(jobDetails) { if (!this.initialized) { await this.initialize(); }   try { logger.info( `Enqueueing job of type '${jobDetails.task_type}' for entity ID '${jobDetails.target_entity_id}'` );   // Generate a unique job_id (UUID) const job_id = uuidv4();   // Prepare the job record const jobData = { job_id, target_entity_id: jobDetails.target_entity_id, target_entity_type: jobDetails.target_entity_type, task_type: jobDetails.task_type, status: "pending", payload: jobDetails.payload ? JSON.stringify(jobDetails.payload) : null, // max_attempts will use the default value from the schema };   // In a real implementation, we would call the DB function to insert the job // However, as Task 046 (which creates this function) is not completed yet, // we'll simply log the job insertion for now logger.info( `Would insert job with ID '${job_id}' into background_ai_jobs table`, { jobData } );   // Once Task 046 is completed, uncomment the following code: /* // Import the DB query function (created in Task 046) import { addBackgroundAiJob } from '../db/queries.js'; // Insert the job record into the database await addBackgroundAiJob(this.dbClient, jobData); */   logger.info(`Successfully enqueued job with ID '${job_id}'`); return { job_id, success: true }; } catch (error) { logger.error(`Error enqueueing job: ${error.message}`, { error, jobDetails, }); return { success: false, error: error.message }; } } }   // Export a singleton instance export default new BackgroundJobManager();  </pre></td></tr></table></pre> <div class='push'></div> </div> <div class='footer quiet pad2 space-top1 center small'> Code coverage generated by <a href="https://istanbul.js.org/" target="_blank" rel="noopener noreferrer">istanbul</a> at 2025-05-13T21:41:55.836Z </div> <script src="../../prettify.js"></script> <script> window.onload = function () { prettyPrint(); }; </script> <script src="../../sorter.js"></script> <script src="../../block-navigation.js"></script> </body> </html>

Loading blob content...

Latest Blog Posts

Don't Use Large Strings as Cache Keys
By punkpeye on January 11, 2026.
markdown
node-js
cache
What are Claude Skills?
By punkpeye on January 10, 2026.
mcp
skills
How to Test MCP Streamable HTTP Endpoints Using cURL
By punkpeye on January 2, 2026.
tutorial
bash

MCP directory API

We provide all the information about MCP servers via our MCP API.

curl -X GET 'https://glama.ai/api/mcp/v1/servers/aurda012/devcontext'

If you have feedback or need assistance with the MCP directory API, please join our Discord server

job.service.js.html•16.8 KiB