47 lines
1.2 KiB
TypeScript
47 lines
1.2 KiB
TypeScript
import { getRepository, Repository } from "typeorm";
|
|
import { Webhook } from "./entities/Webhook";
|
|
import { BaseRepository } from "./BaseRepository";
|
|
import { decrypt, encrypt } from "../utils/crypt";
|
|
|
|
export class Webhooks extends BaseRepository {
|
|
repository: Repository<Webhook> = getRepository(Webhook);
|
|
|
|
protected async _processEntityFromDB(entity) {
|
|
entity.token = await decrypt(entity.token);
|
|
return entity;
|
|
}
|
|
|
|
protected async _processEntityToDB(entity) {
|
|
entity.token = await encrypt(entity.token);
|
|
return entity;
|
|
}
|
|
|
|
async find(id: string): Promise<Webhook | null> {
|
|
const result = await this.repository.findOne({
|
|
where: {
|
|
id,
|
|
},
|
|
});
|
|
|
|
return result ? this._processEntityFromDB(result) : null;
|
|
}
|
|
|
|
async findByChannelId(channelId: string): Promise<Webhook | null> {
|
|
const result = await this.repository.findOne({
|
|
where: {
|
|
channel_id: channelId,
|
|
},
|
|
});
|
|
|
|
return result ? this.processEntityFromDB(result) : null;
|
|
}
|
|
|
|
async create(data: Partial<Webhook>): Promise<void> {
|
|
data = await this.processEntityToDB(data);
|
|
await this.repository.insert(data);
|
|
}
|
|
|
|
async delete(id: string): Promise<void> {
|
|
await this.repository.delete({ id });
|
|
}
|
|
}
|