updates offer in Cosmos DB SQL API

update_offer_cosmos_sqlapi.js

var _ = require('lodash');
const { CosmosClient } = require("@azure/cosmos");
 
const endpoint = "https://cosmosdbtestpr.documents.azure.com:443/";
const key = "xxxx==";
const client = new CosmosClient({ endpoint, key });
const databaseName = "testdb2";
const db = null;
const initialOffer = 1000;
const finalOffer = 600;

async function createDatabase(database) {
    const { database: db } = await client.databases.createIfNotExists({ id: database,throughput:initialOffer });
    this.db = db;
    console.log("created db");
    // createIfNotExists returns database object not databaseResponse . need to correct https://docs.microsoft.com/en-us/javascript/api/@azure/cosmos/databases?view=azure-node-latest#createifnotexists-databaserequest--requestoptions-
    this.db_resource = (await db.read()).resource._self // dbs/4O9xAA==/
}

async function offerDetails() {
    const {resources: offers} = await client.offers.readAll().fetchAll();
    _.map(offers, function (item) { 
        console.log(item.resource + " -> " + item.content.offerThroughput)
     });
}

async function changeOffer(resourceUrl,newOffer){

    const { resources: offers } = await client.offers
    .query({
      query: `SELECT * FROM root WHERE root.resource = "${resourceUrl}"`,
    })
    .fetchAll();

    async function replaceOffer(item){
        const offer = client.offer(item.id);
        await offer.replace(item);    
    }

    _.map(offers, function (item) { 
        item.content.offerThroughput = newOffer;
        replaceOffer(item);
     });
}

async function init() {
    await createDatabase(databaseName).catch(err => { console.error(err); });
    await offerDetails();
    await changeOffer(this.db_resource, finalOffer);
    await offerDetails();
}

init()