|
|
@@ -0,0 +1,49 @@
|
|
|
+const { Subscription } = require('../app/src/models/Subscription')
|
|
|
+const SubscriptionUpdater = require('../app/src/Features/Subscription/SubscriptionUpdater')
|
|
|
+const minimist = require('minimist')
|
|
|
+
|
|
|
+const { waitForDb } = require('../app/src/infrastructure/mongodb')
|
|
|
+const { ObjectId } = require('mongodb')
|
|
|
+
|
|
|
+const run = async () => {
|
|
|
+ for (const id of ids) {
|
|
|
+ console.log('id', id)
|
|
|
+ const subscription = await Subscription.findOne({ _id: ObjectId(id) })
|
|
|
+ await SubscriptionUpdater.promises.deleteSubscription(
|
|
|
+ subscription,
|
|
|
+ deleterData
|
|
|
+ )
|
|
|
+ console.log('Deleted subscription', id)
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+let ids, deleterData
|
|
|
+const setup = () => {
|
|
|
+ const argv = minimist(process.argv.slice(2))
|
|
|
+ ids = argv.ids
|
|
|
+ if (!ids) {
|
|
|
+ console.error('No ids given')
|
|
|
+ process.exit(1)
|
|
|
+ }
|
|
|
+ ids = ids.split(',')
|
|
|
+
|
|
|
+ const deleterId = argv.deleterId
|
|
|
+ if (!deleterId) {
|
|
|
+ console.error('No deleterId given')
|
|
|
+ process.exit(1)
|
|
|
+ }
|
|
|
+
|
|
|
+ deleterData = { id: ObjectId(deleterId) }
|
|
|
+}
|
|
|
+
|
|
|
+setup()
|
|
|
+
|
|
|
+waitForDb()
|
|
|
+ .then(run)
|
|
|
+ .then(() => {
|
|
|
+ process.exit(0)
|
|
|
+ })
|
|
|
+ .catch(err => {
|
|
|
+ console.log('Aiee, something went wrong!', err)
|
|
|
+ process.exit(1)
|
|
|
+ })
|