4954de2a96
This is a very big commit that does an initial job of upgrading everything to the latest version. TSLint gets replaced by ESLint. Instead of plain node, now ts-node is being used. Old modules also get replaced with new ones (mostly ng2 to ngx). Also obsolete configs have been replaced with how it's used today with Angular. This includes: * Upgrade to: ** Angular 12 ** Typescript 4 ** ESLint 7 and replace TSLint ** Bootstrap 5 ** Eerything connected to these * Run with ts-node * Convert wepack config to angular config * Remove typescript-ioc * Update tsconfigs * Run a git command instead of using a library for sshort hash * Move assets to a new location align with default Angular settings * Database migration for new avatarUrl locations * Simplify Model extension align with newest sequelize version * Remove breadcrumb hack * Fix homeserver typo * A few general fixes that are necessary with newest Typescript rules * Define Express.User interface
82 lines
No EOL
3 KiB
TypeScript
82 lines
No EOL
3 KiB
TypeScript
import {
|
|
Context,
|
|
DELETE,
|
|
FormParam,
|
|
HeaderParam,
|
|
Path,
|
|
PathParam,
|
|
POST,
|
|
Security,
|
|
ServiceContext
|
|
} from "typescript-rest";
|
|
import { SuccessResponse, WebhookConfiguration, WebhookOptions } from "../../bridges/models/webhooks";
|
|
import { WebhooksBridge } from "../../bridges/WebhooksBridge";
|
|
import Webhook from "../../db/models/Webhook";
|
|
import { ApiError } from "../ApiError";
|
|
import { LogService } from "matrix-js-snippets";
|
|
import * as request from "request";
|
|
import { ROLE_USER } from "../security/MatrixSecurity";
|
|
|
|
/**
|
|
* API for interacting with the Webhooks bridge, and for setting up proxies to other
|
|
* services.
|
|
*/
|
|
@Path("/api/v1/dimension/webhooks")
|
|
export class DimensionWebhooksService {
|
|
|
|
@Context
|
|
private context: ServiceContext;
|
|
|
|
@POST
|
|
@Path("/travisci/:webhookId")
|
|
public async postTravisCiWebhook(@PathParam("webhookId") webhookId: string, @FormParam("payload") payload: string, @HeaderParam("Signature") signature: string): Promise<void> {
|
|
const webhook = await Webhook.findByPk(webhookId).catch(() => null);
|
|
if (!webhook) throw new ApiError(404, "Webhook not found");
|
|
if (!webhook.targetUrl) throw new ApiError(400, "Webhook not configured");
|
|
|
|
return new Promise((resolve, _reject) => {
|
|
request({
|
|
method: "POST",
|
|
url: webhook.targetUrl,
|
|
form: {payload: payload},
|
|
headers: {
|
|
"Signature": signature,
|
|
},
|
|
}, (err, res, _body) => {
|
|
if (err) {
|
|
LogService.error("DimensionWebhooksService", "Error invoking travis-ci webhook");
|
|
LogService.error("DimensionWebhooksService", res.body);
|
|
|
|
throw new ApiError(500, "Internal Server Error");
|
|
} else resolve();
|
|
});
|
|
});
|
|
}
|
|
|
|
@POST
|
|
@Path("room/:roomId/webhooks/new")
|
|
@Security(ROLE_USER)
|
|
public async newWebhook(@PathParam("roomId") roomId: string, options: WebhookOptions): Promise<WebhookConfiguration> {
|
|
const userId = this.context.request.user.userId;
|
|
const webhooks = new WebhooksBridge(userId);
|
|
return webhooks.createWebhook(roomId, options);
|
|
}
|
|
|
|
@POST
|
|
@Path("room/:roomId/webhooks/:hookId")
|
|
@Security(ROLE_USER)
|
|
public async updateWebhook(@PathParam("roomId") roomId: string, @PathParam("hookId") hookId: string, options: WebhookOptions): Promise<WebhookConfiguration> {
|
|
const userId = this.context.request.user.userId;
|
|
const webhooks = new WebhooksBridge(userId);
|
|
return webhooks.updateWebhook(roomId, hookId, options);
|
|
}
|
|
|
|
@DELETE
|
|
@Path("room/:roomId/webhooks/:hookId")
|
|
@Security(ROLE_USER)
|
|
public async deleteWebhook(@PathParam("roomId") roomId: string, @PathParam("hookId") hookId: string): Promise<SuccessResponse> {
|
|
const userId = this.context.request.user.userId;
|
|
const webhooks = new WebhooksBridge(userId);
|
|
return webhooks.deleteWebhook(roomId, hookId);
|
|
}
|
|
} |