/**
* STOREHOUSE - node-steam
*
* Uses node-steam-user for notifications and accepts all incoming trade offers,
* node-steamcommunity for confirming trades,
* node-steam-totp to generate 2FA codes
*/
const SteamUser = require('steam-user');
const SteamCommunity = require('steamcommunity');
const SteamTotp = require('steam-totp');
const TradeOfferManager = require('steam-tradeoffer-manager'); // use require('steam-tradeoffer-manager') in production
const FS = require('fs');
let client = new SteamUser();
let manager = new TradeOfferManager({
"steam": client, // Polling every 30 seconds is fine since we get notifications from Steam
"domain": "example.com", // Our domain is example.com
"language": "en" // We want English item descriptions
});
let community = new SteamCommunity();
// Steam logon options
let logOnOptions = {
"accountName": "xxx",
"password": "xxx",
"twoFactorCode": SteamTotp.getAuthCode("xxx")
};
if (FS.existsSync('polldata.json')) {
manager.pollData = JSON.parse(FS.readFileSync('polldata.json').toString('utf8'));
}
client.logOn(logOnOptions);
client.on('loggedOn', function() {
console.log("Logged into Steam");
});
client.on('webSession', function(sessionID, cookies) {
manager.setCookies(cookies, function(err) {
if (err) {
console.log(err);
process.exit(1); // Fatal error since we couldn't get our API key
return;
}
console.log("Got API key: " + manager.apiKey);
});
community.setCookies(cookies);
});
manager.on('newOffer', function(offer) {
console.log("New offer #" + offer.id + " from " + offer.partner.getSteam3RenderedID());
offer.accept(function(err, status) {
if (err) {
console.log("Unable to accept offer: " + err.message);
} else {
console.log("Offer accepted: " + status);
if (status == "pending") {
community.acceptConfirmationForObject("identitySecret", offer.id, function(err) {
if (err) {
console.log("Can't confirm trade offer: " + err.message);
} else {
console.log("Trade offer " + offer.id + " confirmed");
}
});
}
}
});
});
manager.on('receivedOfferChanged', function(offer, oldState) {
console.log(`Offer #${offer.id} changed: ${TradeOfferManager.ETradeOfferState[oldState]} -> ${TradeOfferManager.ETradeOfferState[offer.state]}`);
if (offer.state == TradeOfferManager.ETradeOfferState.Accepted) {
offer.getExchangeDetails((err, status, tradeInitTime, receivedItems, sentItems) => {
if (err) {
console.log(`Error ${err}`);
return;
}
// Create arrays of just the new assetids using Array.prototype.map and arrow functions
let newReceivedItems = receivedItems.map(item => item.new_assetid);
let newSentItems = sentItems.map(item => item.new_assetid);
console.log(`Received items ${newReceivedItems.join(',')} Sent Items ${newSentItems.join(',')} - status ${TradeOfferManager.ETradeStatus[status]}`)
})
}
});
manager.on('pollData', function(pollData) {
FS.writeFileSync('polldata.json', JSON.stringify(pollData));
});
/*
* Example output:
*
* Logged into Steam
* Got API key: <key>
* New offer #474127822 from [U:1:46143802]
* Offer accepted
* Offer #474127822 changed: Active -> Accepted
* Received: Reinforced Robot Humor Suppression Pump, Reinforced Robot Humor Suppresion Pump
*/
