let multichain = require("multichain-node")({
    port: 7752,  // check in params.dat “default-rpc-port” settings
    host: '127.0.0.1',
    user: "multichainrpc",
    pass: "45H3cZVZf5LfNaAEsHJVzvQJQBHu4FTtvgS2bWg3sSpF"
    });


function writeInStream(key, InputString){

    let bufStr = Buffer.from(InputString, 'utf8');
        hexstring = bufStr.toString('hex')

        console.log("converting to hexa :", hexstring);

    multichain.publish({
        stream: "stream1",
        "key": key,
        data: hexstring
        },(err,res)=>{

            if(err!=null){
                console.log("error",err);
            }else{
                console.log("response :",res);
            }

        }
    );

}

function readFromStream(key){

    multichain.listStreamKeyItems(
        {
            stream:"stream1",
            key:key,
            verbose:true,
            count: 10,
            start:0
        }, (err,res)=> {
            data = res[res.length-1].data;
            stringval = Buffer.from(data, 'hex').toString();
            console.log(stringval);
        }
    );
}

writeInStream("mykey","rangasthalam");
readFromStream("mykey")