pouchdb-req-http-query

import PouchDB from 'pouchdb-node'; import httpQuery from 'pouchdb-req-http-query'; async function runHttpQueryExample() { const db = new PouchDB('http-query-test-db'); try { // Example 1: Fetch all documents (equivalent to GET /db/_all_docs) const allDocsRequest = { path: '_all_docs', method: 'GET', query: { include_docs: true, }, headers: { 'Accept': 'application/json' } }; console.log('Executing CouchDB-style GET _all_docs request...'); const allDocsResponse = await httpQuery(db, allDocsRequest); console.log('GET _all_docs response:', JSON.stringify(allDocsResponse, null, 2)); // Example 2: Insert a new document (equivalent to POST /db) const insertDocRequest = { path: '', // Empty path for POST to create new doc at DB root method: 'POST', body: { message: 'Hello from http-query!', timestamp: new Date().toISOString() }, headers: { 'Content-Type': 'application/json' } }; console.log('\nExecuting CouchDB-style POST request to insert document...'); const insertResponse = await httpQuery(db, insertDocRequest); console.log('POST insert response:', JSON.stringify(insertResponse, null, 2)); // Example 3: Get a specific document (equivalent to GET /db/doc_id) if (insertResponse.id) { const getDocRequest = { path: insertResponse.id, method: 'GET', headers: { 'Accept': 'application/json' } }; console.log(`\nExecuting CouchDB-style GET request for document '${insertResponse.id}'...`); const getResponse = await httpQuery(db, getDocRequest); console.log(`GET document '${insertResponse.id}' response:`, JSON.stringify(getResponse, null, 2)); } } catch (error) { console.error('Error during http query example:', error); } finally { await db.destroy(); console.log('\nDatabase destroyed.'); } } runHttpQueryExample();