Compare commits
No commits in common. "c1ca37283c1d4a29f21472c05d631a4601926c25" and "d4081a4f5174331a3dc4533ac9951efe0c28e775" have entirely different histories.
c1ca37283c
...
d4081a4f51
12 changed files with 39 additions and 93 deletions
13
.env.example
13
.env.example
|
@ -13,24 +13,23 @@ BOT_OWNERID=147392775707426816
|
||||||
BOT_CLIENTID=682942374040961060
|
BOT_CLIENTID=682942374040961060
|
||||||
BOT_ENV=4
|
BOT_ENV=4
|
||||||
BOT_ADMINS=147392775707426816,887272961504071690
|
BOT_ADMINS=147392775707426816,887272961504071690
|
||||||
BOT_LOGLEVEL=info
|
|
||||||
|
|
||||||
ABOUT_FUNDING=
|
ABOUT_FUNDING=
|
||||||
ABOUT_REPO=
|
ABOUT_REPO=
|
||||||
|
|
||||||
DATA_DIR=./.temp
|
DATA_DIR=
|
||||||
|
|
||||||
DB_HOST=127.0.0.1
|
DB_HOST=
|
||||||
DB_PORT=3301
|
DB_PORT=
|
||||||
DB_NAME=carddrop
|
DB_NAME=
|
||||||
DB_AUTH_USER=
|
DB_AUTH_USER=
|
||||||
DB_AUTH_PASS=
|
DB_AUTH_PASS=
|
||||||
DB_SYNC=
|
DB_SYNC=
|
||||||
DB_LOGGING=
|
DB_LOGGING=
|
||||||
DB_DATA_LOCATION=./.temp/database
|
DB_DATA_LOCATION=~/.docker
|
||||||
|
|
||||||
DB_CARD_FILE=:memory:
|
DB_CARD_FILE=:memory:
|
||||||
|
|
||||||
EXPRESS_PORT=3302
|
EXPRESS_PORT=3303
|
||||||
|
|
||||||
GDRIVESYNC_AUTO=true
|
GDRIVESYNC_AUTO=true
|
|
@ -53,13 +53,12 @@ jobs:
|
||||||
DATA_DIR: ${{ secrets.PROD_DATA_DIR }}
|
DATA_DIR: ${{ secrets.PROD_DATA_DIR }}
|
||||||
GDRIVESYNC_AUTO: ${{ vars.PROD_GDRIVESYNC_AUTO }}
|
GDRIVESYNC_AUTO: ${{ vars.PROD_GDRIVESYNC_AUTO }}
|
||||||
EXPRESS_PORT: ${{ secrets.PROD_EXPRESS_PORT }}
|
EXPRESS_PORT: ${{ secrets.PROD_EXPRESS_PORT }}
|
||||||
BOT_LOGLEVEL: ${{ vars.PROD_BOT_LOGLEVEL }}
|
|
||||||
with:
|
with:
|
||||||
host: ${{ secrets.PROD_SSH_HOST }}
|
host: ${{ secrets.PROD_SSH_HOST }}
|
||||||
username: ${{ secrets.PROD_SSH_USER }}
|
username: ${{ secrets.PROD_SSH_USER }}
|
||||||
key: ${{ secrets.PROD_SSH_KEY }}
|
key: ${{ secrets.PROD_SSH_KEY }}
|
||||||
port: ${{ secrets.PROD_SSH_PORT }}
|
port: ${{ secrets.PROD_SSH_PORT }}
|
||||||
envs: DB_NAME,DB_AUTH_USER,DB_AUTH_PASS,DB_HOST,DB_PORT,DB_ROOT_HOST,DB_SYNC,DB_LOGGING,DB_DATA_LOCATION,BOT_TOKEN,BOT_VER,BOT_AUTHOR,BOT_OWNERID,BOT_CLIENTID,ABOUT_FUNDING,ABOUT_REPO,BOT_ENV,BOT_ADMINS,DATA_DIR,GDRIVESYNC_AUTO,SERVER_PATH,EXPRESS_PORT,BOT_LOGLEVEL
|
envs: DB_NAME,DB_AUTH_USER,DB_AUTH_PASS,DB_HOST,DB_PORT,DB_ROOT_HOST,DB_SYNC,DB_LOGGING,DB_DATA_LOCATION,BOT_TOKEN,BOT_VER,BOT_AUTHOR,BOT_OWNERID,BOT_CLIENTID,ABOUT_FUNDING,ABOUT_REPO,BOT_ENV,BOT_ADMINS,DATA_DIR,GDRIVESYNC_AUTO,SERVER_PATH,EXPRESS_PORT
|
||||||
script: |
|
script: |
|
||||||
source .sshrc \
|
source .sshrc \
|
||||||
&& cd /home/vylpes/apps/card-drop/card-drop_prod \
|
&& cd /home/vylpes/apps/card-drop/card-drop_prod \
|
||||||
|
|
|
@ -53,13 +53,12 @@ jobs:
|
||||||
DATA_DIR: ${{ secrets.STAGE_DATA_DIR }}
|
DATA_DIR: ${{ secrets.STAGE_DATA_DIR }}
|
||||||
GDRIVESYNC_AUTO: ${{ vars.STAGE_GDRIVESYNC_AUTO }}
|
GDRIVESYNC_AUTO: ${{ vars.STAGE_GDRIVESYNC_AUTO }}
|
||||||
EXPRESS_PORT: ${{ secrets.STAGE_EXPRESS_PORT }}
|
EXPRESS_PORT: ${{ secrets.STAGE_EXPRESS_PORT }}
|
||||||
BOT_LOGLEVEL: ${{ vars.STAGE_BOT_LOGLEVEL }}
|
|
||||||
with:
|
with:
|
||||||
host: ${{ secrets.STAGE_SSH_HOST }}
|
host: ${{ secrets.STAGE_SSH_HOST }}
|
||||||
username: ${{ secrets.STAGE_SSH_USER }}
|
username: ${{ secrets.STAGE_SSH_USER }}
|
||||||
key: ${{ secrets.STAGE_SSH_KEY }}
|
key: ${{ secrets.STAGE_SSH_KEY }}
|
||||||
port: ${{ secrets.STAGE_SSH_PORT }}
|
port: ${{ secrets.STAGE_SSH_PORT }}
|
||||||
envs: DB_NAME,DB_AUTH_USER,DB_AUTH_PASS,DB_HOST,DB_PORT,DB_ROOT_HOST,DB_SYNC,DB_LOGGING,DB_DATA_LOCATION,BOT_TOKEN,BOT_VER,BOT_AUTHOR,BOT_OWNERID,BOT_CLIENTID,ABOUT_FUNDING,ABOUT_REPO,BOT_ENV,BOT_ADMINS,DATA_DIR,GDRIVESYNC_AUTO,SERVER_PATH,EXPRESS_PORT,BOT_LOGLEVEL
|
envs: DB_NAME,DB_AUTH_USER,DB_AUTH_PASS,DB_HOST,DB_PORT,DB_ROOT_HOST,DB_SYNC,DB_LOGGING,DB_DATA_LOCATION,BOT_TOKEN,BOT_VER,BOT_AUTHOR,BOT_OWNERID,BOT_CLIENTID,ABOUT_FUNDING,ABOUT_REPO,BOT_ENV,BOT_ADMINS,DATA_DIR,GDRIVESYNC_AUTO,SERVER_PATH,EXPRESS_PORT
|
||||||
script: |
|
script: |
|
||||||
source .sshrc \
|
source .sshrc \
|
||||||
&& cd /home/vylpes/apps/card-drop/card-drop_stage \
|
&& cd /home/vylpes/apps/card-drop/card-drop_stage \
|
||||||
|
|
22
package-lock.json
generated
22
package-lock.json
generated
|
@ -1906,9 +1906,9 @@
|
||||||
"license": "MIT"
|
"license": "MIT"
|
||||||
},
|
},
|
||||||
"node_modules/@types/node": {
|
"node_modules/@types/node": {
|
||||||
"version": "20.12.8",
|
"version": "20.12.7",
|
||||||
"resolved": "https://registry.npmjs.org/@types/node/-/node-20.12.8.tgz",
|
"resolved": "https://registry.npmjs.org/@types/node/-/node-20.12.7.tgz",
|
||||||
"integrity": "sha512-NU0rJLJnshZWdE/097cdCBbyW1h4hEg0xpovcoAQYHl8dnEyp/NAOiE45pvc+Bd1Dt+2r94v2eGFpQJ4R7g+2w==",
|
"integrity": "sha512-wq0cICSkRLVaf3UGLMGItu/PtdY7oaXaI/RVU+xliKVOtRna3PRY57ZDfztpDL0n11vfymMUnXv8QwYCO7L1wg==",
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
"undici-types": "~5.26.4"
|
"undici-types": "~5.26.4"
|
||||||
}
|
}
|
||||||
|
@ -6831,11 +6831,11 @@
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
"node_modules/jest-mock-extended": {
|
"node_modules/jest-mock-extended": {
|
||||||
"version": "3.0.7",
|
"version": "3.0.6",
|
||||||
"resolved": "https://registry.npmjs.org/jest-mock-extended/-/jest-mock-extended-3.0.7.tgz",
|
"resolved": "https://registry.npmjs.org/jest-mock-extended/-/jest-mock-extended-3.0.6.tgz",
|
||||||
"integrity": "sha512-7lsKdLFcW9B9l5NzZ66S/yTQ9k8rFtnwYdCNuRU/81fqDWicNDVhitTSPnrGmNeNm0xyw0JHexEOShrIKRCIRQ==",
|
"integrity": "sha512-DJuEoFzio0loqdX8NIwkbE9dgIXNzaj//pefOQxGkoivohpxbSQeNHCAiXkDNA/fmM4EIJDoZnSibP4w3dUJ9g==",
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
"ts-essentials": "^10.0.0"
|
"ts-essentials": "^9.4.2"
|
||||||
},
|
},
|
||||||
"peerDependencies": {
|
"peerDependencies": {
|
||||||
"jest": "^24.0.0 || ^25.0.0 || ^26.0.0 || ^27.0.0 || ^28.0.0 || ^29.0.0",
|
"jest": "^24.0.0 || ^25.0.0 || ^26.0.0 || ^27.0.0 || ^28.0.0 || ^29.0.0",
|
||||||
|
@ -10870,11 +10870,11 @@
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
"node_modules/ts-essentials": {
|
"node_modules/ts-essentials": {
|
||||||
"version": "10.0.0",
|
"version": "9.4.2",
|
||||||
"resolved": "https://registry.npmjs.org/ts-essentials/-/ts-essentials-10.0.0.tgz",
|
"resolved": "https://registry.npmjs.org/ts-essentials/-/ts-essentials-9.4.2.tgz",
|
||||||
"integrity": "sha512-77FHNJEyysF9+1s4G6eejuA1lxw7uMchT3ZPy3CIbh7GIunffpshtM8pTe5G6N5dpOzNevqRHew859ceLWVBfw==",
|
"integrity": "sha512-mB/cDhOvD7pg3YCLk2rOtejHjjdSi9in/IBYE13S+8WA5FBSraYf4V/ws55uvs0IvQ/l0wBOlXy5yBNZ9Bl8ZQ==",
|
||||||
"peerDependencies": {
|
"peerDependencies": {
|
||||||
"typescript": ">=4.5.0"
|
"typescript": ">=4.1.0"
|
||||||
},
|
},
|
||||||
"peerDependenciesMeta": {
|
"peerDependenciesMeta": {
|
||||||
"typescript": {
|
"typescript": {
|
||||||
|
|
|
@ -59,3 +59,11 @@ if (!existsSync(`${process.env.DATA_DIR}/cards`) && process.env.GDRIVESYNC_AUTO
|
||||||
}
|
}
|
||||||
|
|
||||||
client.start();
|
client.start();
|
||||||
|
|
||||||
|
const timerHelper = new TimerHelper();
|
||||||
|
|
||||||
|
const id = timerHelper.AddTimer('* * * * * *', 'Europe/London', GiveCurrency);
|
||||||
|
|
||||||
|
console.log(`Timer Created: ${id}`);
|
||||||
|
|
||||||
|
timerHelper.StartAllTimers();
|
|
@ -7,7 +7,6 @@ import AppLogger from "../client/appLogger";
|
||||||
import CardDropHelperMetadata from "../helpers/CardDropHelperMetadata";
|
import CardDropHelperMetadata from "../helpers/CardDropHelperMetadata";
|
||||||
import { readFileSync } from "fs";
|
import { readFileSync } from "fs";
|
||||||
import path from "path";
|
import path from "path";
|
||||||
import User from "../database/entities/app/User";
|
|
||||||
|
|
||||||
export default class Claim extends ButtonEvent {
|
export default class Claim extends ButtonEvent {
|
||||||
public override async execute(interaction: ButtonInteraction) {
|
public override async execute(interaction: ButtonInteraction) {
|
||||||
|
@ -42,17 +41,6 @@ export default class Claim extends ButtonEvent {
|
||||||
|
|
||||||
await inventory.Save(Inventory, inventory);
|
await inventory.Save(Inventory, inventory);
|
||||||
|
|
||||||
let user = await User.FetchOneById(User, userId) || new User(userId, 300);
|
|
||||||
|
|
||||||
AppLogger.LogSilly("Button/Claim", `${user.Id} has ${user.Currency} currency`);
|
|
||||||
|
|
||||||
if (!user.RemoveCurrency(10)) {
|
|
||||||
await interaction.reply(`Not enough currency! You need 10 currency, you have ${user.Currency}`);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
await user.Save(User, user);
|
|
||||||
|
|
||||||
const claim = new eClaim(claimId);
|
const claim = new eClaim(claimId);
|
||||||
claim.SetInventory(inventory);
|
claim.SetInventory(inventory);
|
||||||
|
|
||||||
|
|
|
@ -14,8 +14,6 @@ import Webhooks from "../webhooks";
|
||||||
import CardMetadataFunction from "../Functions/CardMetadataFunction";
|
import CardMetadataFunction from "../Functions/CardMetadataFunction";
|
||||||
import { SeriesMetadata } from "../contracts/SeriesMetadata";
|
import { SeriesMetadata } from "../contracts/SeriesMetadata";
|
||||||
import AppLogger from "./appLogger";
|
import AppLogger from "./appLogger";
|
||||||
import TimerHelper from "../helpers/TimerHelper";
|
|
||||||
import GiveCurrency from "../timers/GiveCurrency";
|
|
||||||
|
|
||||||
export class CoreClient extends Client {
|
export class CoreClient extends Client {
|
||||||
private static _commandItems: ICommandItem[];
|
private static _commandItems: ICommandItem[];
|
||||||
|
@ -25,7 +23,6 @@ export class CoreClient extends Client {
|
||||||
private _events: Events;
|
private _events: Events;
|
||||||
private _util: Util;
|
private _util: Util;
|
||||||
private _webhooks: Webhooks;
|
private _webhooks: Webhooks;
|
||||||
private _timerHelper: TimerHelper;
|
|
||||||
|
|
||||||
public static ClaimId: string;
|
public static ClaimId: string;
|
||||||
public static Environment: Environment;
|
public static Environment: Environment;
|
||||||
|
@ -62,7 +59,6 @@ export class CoreClient extends Client {
|
||||||
this._events = new Events();
|
this._events = new Events();
|
||||||
this._util = new Util();
|
this._util = new Util();
|
||||||
this._webhooks = new Webhooks();
|
this._webhooks = new Webhooks();
|
||||||
this._timerHelper = new TimerHelper();
|
|
||||||
|
|
||||||
AppLogger.LogInfo("Client", `Environment: ${CoreClient.Environment}`);
|
AppLogger.LogInfo("Client", `Environment: ${CoreClient.Environment}`);
|
||||||
|
|
||||||
|
@ -76,12 +72,7 @@ export class CoreClient extends Client {
|
||||||
}
|
}
|
||||||
|
|
||||||
await AppDataSource.initialize()
|
await AppDataSource.initialize()
|
||||||
.then(() => {
|
.then(() => AppLogger.LogInfo("Client", "App Data Source Initialised"))
|
||||||
AppLogger.LogInfo("Client", "App Data Source Initialised");
|
|
||||||
|
|
||||||
const timerId = this._timerHelper.AddTimer("*/30 * * * * *", "Europe/London", GiveCurrency, false);
|
|
||||||
this._timerHelper.StartTimer(timerId);
|
|
||||||
})
|
|
||||||
.catch(err => {
|
.catch(err => {
|
||||||
AppLogger.LogError("Client", "App Data Source Initialisation Failed");
|
AppLogger.LogError("Client", "App Data Source Initialisation Failed");
|
||||||
AppLogger.LogError("Client", err);
|
AppLogger.LogError("Client", err);
|
||||||
|
|
|
@ -27,12 +27,6 @@ export default class AppBaseEntity {
|
||||||
await repository.save(entity);
|
await repository.save(entity);
|
||||||
}
|
}
|
||||||
|
|
||||||
public static async SaveAll<T extends AppBaseEntity>(target: EntityTarget<T>, entities: DeepPartial<T>[]): Promise<void> {
|
|
||||||
const repository = AppDataSource.getRepository<T>(target);
|
|
||||||
|
|
||||||
await repository.save(entities);
|
|
||||||
}
|
|
||||||
|
|
||||||
public static async Remove<T extends AppBaseEntity>(target: EntityTarget<T>, entity: T): Promise<void> {
|
public static async Remove<T extends AppBaseEntity>(target: EntityTarget<T>, entity: T): Promise<void> {
|
||||||
const repository = AppDataSource.getRepository<T>(target);
|
const repository = AppDataSource.getRepository<T>(target);
|
||||||
|
|
||||||
|
|
|
@ -13,15 +13,7 @@ export default class User extends AppBaseEntity {
|
||||||
@Column()
|
@Column()
|
||||||
Currency: number;
|
Currency: number;
|
||||||
|
|
||||||
public AddCurrency(amount: number) {
|
public UpdateCurrency(currency: number) {
|
||||||
this.Currency += amount;
|
this.Currency = currency;
|
||||||
}
|
|
||||||
|
|
||||||
public RemoveCurrency(amount: number): boolean {
|
|
||||||
if (this.Currency < amount) return false;
|
|
||||||
|
|
||||||
this.Currency -= amount;
|
|
||||||
|
|
||||||
return true;
|
|
||||||
}
|
}
|
||||||
}
|
}
|
|
@ -5,8 +5,6 @@ interface Timer {
|
||||||
id: string;
|
id: string;
|
||||||
job: CronJob;
|
job: CronJob;
|
||||||
context: Map<string, any>;
|
context: Map<string, any>;
|
||||||
onTick: ((context: Map<string, any>) => void) | ((context: Map<string, any>) => Promise<void>);
|
|
||||||
runOnStart: boolean;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
export default class TimerHelper {
|
export default class TimerHelper {
|
||||||
|
@ -19,8 +17,7 @@ export default class TimerHelper {
|
||||||
public AddTimer(
|
public AddTimer(
|
||||||
cronTime: string,
|
cronTime: string,
|
||||||
timeZone: string,
|
timeZone: string,
|
||||||
onTick: ((context: Map<string, any>) => void) | ((context: Map<string, any>) => Promise<void>),
|
onTick: ((context: Map<string, any>) => void) | ((context: Map<string, any>) => Promise<void>)): string {
|
||||||
runOnStart: boolean = false): string {
|
|
||||||
const context = new Map<string, any>();
|
const context = new Map<string, any>();
|
||||||
|
|
||||||
const job = new CronJob(
|
const job = new CronJob(
|
||||||
|
@ -39,15 +36,13 @@ export default class TimerHelper {
|
||||||
id,
|
id,
|
||||||
job,
|
job,
|
||||||
context,
|
context,
|
||||||
onTick,
|
|
||||||
runOnStart,
|
|
||||||
});
|
});
|
||||||
|
|
||||||
return id;
|
return id;
|
||||||
}
|
}
|
||||||
|
|
||||||
public StartAllTimers() {
|
public StartAllTimers() {
|
||||||
this._timers.forEach(timer => this.StartJob(timer));
|
this._timers.forEach(timer => timer.job.start());
|
||||||
}
|
}
|
||||||
|
|
||||||
public StopAllTimers() {
|
public StopAllTimers() {
|
||||||
|
@ -59,7 +54,7 @@ export default class TimerHelper {
|
||||||
|
|
||||||
if (!timer) return;
|
if (!timer) return;
|
||||||
|
|
||||||
this.StartJob(timer);
|
timer.job.start();
|
||||||
}
|
}
|
||||||
|
|
||||||
public StopTimer(id: string) {
|
public StopTimer(id: string) {
|
||||||
|
@ -69,12 +64,4 @@ export default class TimerHelper {
|
||||||
|
|
||||||
timer.job.stop();
|
timer.job.stop();
|
||||||
}
|
}
|
||||||
|
|
||||||
private StartJob(timer: Timer) {
|
|
||||||
timer.job.start();
|
|
||||||
|
|
||||||
if (timer.runOnStart) {
|
|
||||||
timer.onTick(timer.context);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
}
|
|
@ -52,8 +52,4 @@ export default class Registry {
|
||||||
CoreClient.RegisterButtonEvent("series", new SeriesEvent());
|
CoreClient.RegisterButtonEvent("series", new SeriesEvent());
|
||||||
CoreClient.RegisterButtonEvent("trade", new TradeButtonEvent());
|
CoreClient.RegisterButtonEvent("trade", new TradeButtonEvent());
|
||||||
}
|
}
|
||||||
|
|
||||||
public static RegisterTimers() {
|
|
||||||
|
|
||||||
}
|
|
||||||
}
|
}
|
|
@ -1,16 +1,9 @@
|
||||||
import AppLogger from "../client/appLogger";
|
export default function GiveCurrency(context: Map<string, any>) {
|
||||||
import User from "../database/entities/app/User";
|
let calledTimes = context.get('times') as number;
|
||||||
|
|
||||||
export default async function GiveCurrency(context: Map<string, any>) {
|
if (!calledTimes) calledTimes = 1;
|
||||||
AppLogger.LogInfo("Timers/GiveCurrency", "Giving currency to every known user");
|
|
||||||
|
|
||||||
const users = await User.FetchAll(User);
|
console.log(`This has been called ${calledTimes} times!`);
|
||||||
|
|
||||||
for (const user of users) {
|
context.set('times', calledTimes + 1);
|
||||||
user.AddCurrency(5);
|
|
||||||
}
|
|
||||||
|
|
||||||
User.SaveAll(User, users);
|
|
||||||
|
|
||||||
AppLogger.LogInfo("Timers/GiveCurrency", `Successfully gave +5 currency to ${users.length} users`);
|
|
||||||
}
|
}
|
Loading…
Reference in a new issue