feat: add function dropShard (#418)

src/index.ts

@@ -1122,6 +1122,27 @@ export class InfluxDB {
 			);
 	}
 
+	/**
+   * Drops a shard with the provided number.
+   * @param shard_id
+   * @return
+   * @example
+   * influx.dropShard(3)
+   */
+	public dropShard(shard_id: number): Promise<void> {
+		return this._pool
+			.json(
+				this._getQueryOpts(
+					{
+						q: `drop shard ${shard_id}`
+					},
+					'POST',
+				),
+			)
+			.then(assertNoErrors)
+			.then(() => undefined);
+	}
+
 	/**
    * WritePoints sends a list of points together in a batch to InfluxDB. In
    * each point you must specify the measurement name to write into as well

test/integrate/data.test.ts

@@ -58,6 +58,17 @@ describe('data operations', () => {
 			.then(() => db.getSeries())
 			.then(res => expect(res).to.not.contain('h2o_quality,location=coyote_creek,randtag=1'));
 	});
+	it('drops shard', () => {
+		let first_shard_number = 0;
+		return db
+			.showShards('influx_test_db')
+			.then(res => {
+				first_shard_number = res[0].id;
+			})
+			.then(() => db.dropShard(first_shard_number))
+			.then(() => db.showShards('influx_test_db'))
+			.then(res => expect(res[0].id).to.not.equal(first_shard_number));
+	});
 
 	it('gets measurements', () => {
 		return db.getMeasurements().then(res => expect(res).to.deep.equal(['h2o_feet', 'h2o_quality']));

test/unit/influx.test.ts

@@ -228,6 +228,11 @@ describe('influxdb', () => {
 			influx.dropDatabase('f"oo');
 		});
 
+		it('.dropShard()', () => {
+			expectQuery('json', 'drop shard 1');
+			influx.dropShard(1);
+		});
+
 		it('.getDatabaseNames()', () => {
 			expectQuery('json', 'show databases', 'GET', dbFixture('showDatabases'));
 			return influx.getDatabaseNames().then(names => {