6 Commits

Author SHA1 Message Date
cf7c3cb910 1.0.11 2022-02-25 21:45:22 +01:00
b8eb82de12 fix(core): update 2022-02-25 21:45:21 +01:00
8c01d5cabf 1.0.10 2022-02-25 21:35:34 +01:00
1eef97ee9a fix(core): update 2022-02-25 21:35:34 +01:00
45544fffd0 1.0.9 2022-02-25 21:33:24 +01:00
f227eaee37 fix(core): update 2022-02-25 21:33:24 +01:00
5 changed files with 49 additions and 9 deletions

4
package-lock.json generated
View File

@ -1,12 +1,12 @@
{
"name": "@mojoio/bobcat",
"version": "1.0.8",
"version": "1.0.11",
"lockfileVersion": 2,
"requires": true,
"packages": {
"": {
"name": "@mojoio/bobcat",
"version": "1.0.8",
"version": "1.0.11",
"license": "MIT",
"dependencies": {
"@pushrocks/smartnetwork": "^2.0.14",

View File

@ -1,6 +1,6 @@
{
"name": "@mojoio/bobcat",
"version": "1.0.8",
"version": "1.0.11",
"private": false,
"description": "a module to talk to bobcat miners",
"main": "dist_ts/index.js",

View File

@ -8,11 +8,16 @@ import * as bobcat from '../ts/index';
let testBobcatManager: bobcat.BobcatManager;
let testBobcat: bobcat.Bobcat;
tap.test('first test', async () => {
tap.test('should create a bobcat manager', async () => {
testBobcatManager = new bobcat.BobcatManager();
expect(testBobcatManager).toBeInstanceOf(bobcat.BobcatManager);
});
tap.test('should create a bobcat', async () => {
testBobcat = new bobcat.Bobcat('bobcat.bleu.de');
expect(testBobcat).toBeInstanceOf(bobcat.Bobcat);
})
tap.test('should add a Bobcat miner', async () => {
const bobcatAddresses = testQenv.getEnvVarOnDemand('BOBCATS').split(',');
console.log(bobcatAddresses);
@ -22,9 +27,8 @@ tap.test('should add a Bobcat miner', async () => {
}
});
tap.test('', async () => {
testBobcat = new bobcat.Bobcat('bobcat.bleu.de');
expect(testBobcat).toBeInstanceOf(bobcat.Bobcat);
tap.test('should run maintenance on bobcats', async () => {
await testBobcatManager.runMaintenance();
})
tap.start();

View File

@ -8,8 +8,8 @@ export class Bobcat {
// STATIC
public static async createFromNetworkAddress(networkAddressArg: string) {
const newBobcat = new Bobcat(networkAddressArg);
await newBobcat.gatherMinerDetails();
await newBobcat.checkMinerStatus();
await newBobcat.checkMinerStatus().catch();
await newBobcat.gatherMinerDetails().catch();
return newBobcat;
}
@ -41,4 +41,26 @@ export class Bobcat {
this.latestMinerDetails = body;
return this.latestMinerDetails;
}
/**
* runs maintenance on the bobcat
*/
public async runMaintenance() {
await this.checkMinerStatus();
await this.gatherMinerDetails();
if (this.latestStatus.status !== 'Synced') {
console.log(`Miner ${this.latestMinerDetails.animal} is not synced. Restarting now!`);
await this.restart().catch();
}
}
public async restart() {
const response = await plugins.smartrequest.request(`http://${this.networkAddress}/admin/reboot`, {
method: 'POST',
headers: {
Authorization: 'Basic ' + Buffer.from('bobcat:miner').toString('base64')
}
});
console.log(response.statusCode);
}
}

View File

@ -11,4 +11,18 @@ export class BobcatManager {
const newBobcat = await Bobcat.createFromNetworkAddress(networkAddressArg);
this.bobcats.push(newBobcat);
}
/**
* runs the maintenance on all managed bobcats
*/
public async runMaintenance() {
console.log(`now running maintenance on ${this.bobcats.length} bobcats!`);
for (const bobcat of this.bobcats) {
await bobcat.runMaintenance();
}
};
public async restart() {
}
}